mirror of
https://github.com/hanzoai/ingress.git
synced 2026-10-30 14:58:23 +00:00
zeekay
ff6913cdcb
- Fork github.com/traefik/paerser to github.com/hanzoai/ingress-parser with rebranded prefixes (TRAEFIK_ → INGRESS_, traefik. → ingress.) - Update all 71 Go files importing paerser to use ingress-parser - CLI flags: traefik.configfile → ingress.configfile - Env prefix: TRAEFIK_* → INGRESS_* - Deprecation loader: traefik. label prefix → ingress. - Recompute digest auth test hashes for realm "ingress" - Rename traefiker test realm → ingresser - Fix remaining comment URLs to hanzoai/ingress 7 remaining "traefik" refs are Go import paths for external packages (traefik/yaegi, traefik/grpc-web) — these are the packages' module identity, cannot be renamed without forking the entire Go interpreter and gRPC-Web proxy.
76 lines
1.7 KiB
Go
76 lines
1.7 KiB
Go
package kv
|
|
|
|
import (
|
|
"path"
|
|
"reflect"
|
|
|
|
"github.com/kvtools/valkeyrie/store"
|
|
"github.com/hanzoai/ingress-parser/parser"
|
|
)
|
|
|
|
// Decode decodes the given KV pairs into the given element.
|
|
// The operation goes through three stages roughly summarized as:
|
|
// KV pairs -> tree of untyped nodes
|
|
// untyped nodes -> nodes augmented with metadata such as kind (inferred from element)
|
|
// "typed" nodes -> typed element.
|
|
func Decode(pairs []*store.KVPair, element any, rootName string) error {
|
|
if element == nil {
|
|
return nil
|
|
}
|
|
|
|
filters := getRootFieldNames(rootName, element)
|
|
|
|
node, err := DecodeToNode(pairs, rootName, filters...)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
|
|
metaOpts := parser.MetadataOpts{TagName: "kv", AllowSliceAsStruct: false}
|
|
err = parser.AddMetadata(element, node, metaOpts)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
|
|
return parser.Fill(element, node, parser.FillerOpts{AllowSliceAsStruct: false})
|
|
}
|
|
|
|
func getRootFieldNames(rootName string, element any) []string {
|
|
if element == nil {
|
|
return nil
|
|
}
|
|
|
|
rootType := reflect.TypeOf(element)
|
|
|
|
return getFieldNames(rootName, rootType)
|
|
}
|
|
|
|
func getFieldNames(rootName string, rootType reflect.Type) []string {
|
|
var names []string
|
|
|
|
if rootType.Kind() == reflect.Ptr {
|
|
rootType = rootType.Elem()
|
|
}
|
|
|
|
if rootType.Kind() != reflect.Struct {
|
|
return nil
|
|
}
|
|
|
|
for i := range rootType.NumField() {
|
|
field := rootType.Field(i)
|
|
|
|
if !parser.IsExported(field) {
|
|
continue
|
|
}
|
|
|
|
if field.Anonymous &&
|
|
(field.Type.Kind() == reflect.Ptr && field.Type.Elem().Kind() == reflect.Struct || field.Type.Kind() == reflect.Struct) {
|
|
names = append(names, getFieldNames(rootName, field.Type)...)
|
|
continue
|
|
}
|
|
|
|
names = append(names, path.Join(rootName, field.Name))
|
|
}
|
|
|
|
return names
|
|
}
|