- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 4,062 for structpb (0.24 sec)
-
pilot/pkg/util/protoconv/protoconv.go
return nil } return out } func TypedStructWithFields(typeURL string, fields map[string]interface{}) *anypb.Any { value, err := structpb.NewStruct(fields) if err != nil { log.Error(fmt.Sprintf("error marshaling struct %s: %v", typeURL, err)) } return MessageToAny(&udpa.TypedStruct{ TypeUrl: typeURL, Value: value, }) } func SilentlyUnmarshalAny[T any](a *anypb.Any) *T {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Feb 02 04:55:40 UTC 2024 - 2.7K bytes - Viewed (0) -
pilot/pkg/model/envoyfilter_test.go
t.Errorf("expected %v to match %v, got %v", ver, match, got) } } }) } } func TestConvertEnvoyFilter(t *testing.T) { buildPatchStruct := func(config string) *structpb.Struct { val := &structpb.Struct{} _ = protomarshal.UnmarshalString(config, val) return val } cfilter := convertToEnvoyFilterWrapper(&config.Config{ Meta: config.Meta{Name: "test", Namespace: "testns"},
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Dec 27 04:20:28 UTC 2023 - 7.4K bytes - Viewed (0) -
pkg/wasm/convert_test.go
return module, err } func (c *mockCache) Cleanup() {} func messageToStruct(t *testing.T, m proto.Message) *structpb.Struct { st, err := conversion.MessageToStruct(m) if err != nil { t.Fatal(err) } return st } func newStruct(t *testing.T, m map[string]any) *structpb.Struct { st, err := structpb.NewStruct(m) if err != nil { t.Fatal(err) } return st }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Apr 17 20:06:41 UTC 2024 - 13.6K bytes - Viewed (0) -
operator/pkg/validate/validate.go
func Validate(validations map[string]ValidatorFunc, structPtr any, path util.Path, checkRequired bool) (errs util.Errors) { scope.Debugf("validate with path %s, %v (%T)", path, structPtr, structPtr) if structPtr == nil { return nil } if util.IsStruct(structPtr) { scope.Debugf("validate path %s, skipping struct type %T", path, structPtr) return nil } if !util.IsPtr(structPtr) { metrics.CRValidationErrorTotal.Increment()
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jan 12 16:04:15 UTC 2023 - 7.7K bytes - Viewed (0) -
pkg/config/schema/collection/schemas_test.go
Proto: "google.protobuf.Empty", }.MustBuild() structResource = resource.Builder{ Kind: "Struct", Plural: "structs", ProtoPackage: "google.golang.org/protobuf/types/known/structpb", Proto: "google.protobuf.Struct", }.MustBuild() ) func TestSchemas_Basic(t *testing.T) { g := NewWithT(t) schemas := collection.SchemasFor(emptyResource)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Oct 31 14:48:28 UTC 2023 - 5.4K bytes - Viewed (0) -
operator/pkg/apis/istio/v1alpha1/values_types.pb.go
IngressPorts []*structpb.Struct `protobuf:"bytes,36,rep,name=ingressPorts,proto3" json:"ingressPorts,omitempty"` AdditionalContainers []*structpb.Struct `protobuf:"bytes,37,rep,name=additionalContainers,proto3" json:"additionalContainers,omitempty"` ConfigVolumes []*structpb.Struct `protobuf:"bytes,38,rep,name=configVolumes,proto3" json:"configVolumes,omitempty"`
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Jun 03 01:55:05 UTC 2024 - 329.6K bytes - Viewed (0) -
pilot/pkg/networking/core/cluster_builder.go
return } im := getOrCreateIstioMetadata(cluster) // Add services field into istio metadata im.Fields["services"] = &structpb.Value{ Kind: &structpb.Value_ListValue{ ListValue: &structpb.ListValue{ Values: []*structpb.Value{}, }, }, } svcMetaList := im.Fields["services"].GetListValue()
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 01:56:28 UTC 2024 - 31.6K bytes - Viewed (0) -
pilot/pkg/networking/core/cluster_builder_test.go
FilterMetadata: map[string]*structpb.Struct{ util.IstioMetadataKey: { Fields: map[string]*structpb.Value{ "services": {Kind: &structpb.Value_ListValue{ListValue: &structpb.ListValue{Values: []*structpb.Value{ {Kind: &structpb.Value_StructValue{StructValue: &structpb.Struct{Fields: map[string]*structpb.Value{ "host": { Kind: &structpb.Value_StringValue{
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 01:56:28 UTC 2024 - 110.4K bytes - Viewed (0) -
istioctl/pkg/version/version.go
}) default: return nil, fmt.Errorf("unexpected resource type %q", resource.TypeUrl) } } return &pi, nil } } func getIstioVersionFromXdsMetadata(metadata *structpb.Struct) string { meta, err := model.ParseMetadata(metadata) if err != nil { return "unknown sidecar version" } return meta.IstioVersion
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Mar 15 01:18:49 UTC 2024 - 8.3K bytes - Viewed (0) -
pilot/pkg/xds/endpoints/endpoint_builder.go
// We skip this for service waypoint, which doesn't need to dynamically match mTLS vs HBONE. ep.Metadata.FilterMetadata[util.EnvoyTransportSocketMetadataKey] = &structpb.Struct{ Fields: map[string]*structpb.Value{ model.TunnelLabelShortName: {Kind: &structpb.Value_StringValue{StringValue: model.TunnelHTTP}}, }, } } } return ep }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sun Apr 28 02:18:19 UTC 2024 - 26.1K bytes - Viewed (0)