- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 4,062 for structpb (0.29 sec)
-
pilot/pkg/networking/core/cluster_waypoint.go
// Ensure VIP cluster has services metadata for stats filter usage im := getOrCreateIstioMetadata(localCluster.cluster) im.Fields["services"] = &structpb.Value{ Kind: &structpb.Value_ListValue{ ListValue: &structpb.ListValue{ Values: []*structpb.Value{}, }, }, } svcMetaList := im.Fields["services"].GetListValue() svcMetaList.Values = append(svcMetaList.Values, buildServiceMetadata(svc))
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 9K bytes - Viewed (0) -
pkg/config/analysis/local/helpers_test.go
var K8SCollection1 = r2.Builder{ Group: "testdata.istio.io", Kind: "Kind1", Plural: "Kind1s", Version: "v1alpha1", Proto: "google.protobuf.Struct", ReflectType: reflect.TypeOf(&structpb.Struct{}).Elem(), ProtoPackage: "github.com/gogo/protobuf/types", ClusterScoped: false, ValidateProto: validation.EmptyValidate, }.MustBuild()
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Feb 02 17:36:47 UTC 2024 - 1.7K bytes - Viewed (0) -
pilot/pkg/xds/eds_sh_test.go
t.Helper() ads := s.ConnectADS().WithID(sidecarID) metadata := &structpb.Struct{Fields: map[string]*structpb.Value{ "ISTIO_VERSION": {Kind: &structpb.Value_StringValue{StringValue: "1.3"}}, "NETWORK": {Kind: &structpb.Value_StringValue{StringValue: network}}, }} ads.RequestResponseAck(t, &discovery.DiscoveryRequest{ Node: &core.Node{
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jan 12 18:20:36 UTC 2024 - 10.8K bytes - Viewed (0) -
operator/pkg/tpath/struct.go
} // For protobuf types, switch them out with standard types; otherwise we will traverse protobuf internals rather // than the standard representation if v, ok := node.(*structpb.Struct); ok { node = v.AsMap() } if v, ok := node.(*structpb.Value); ok { node = v.AsInterface() } val := reflect.ValueOf(node) kind := reflect.TypeOf(node).Kind() var structElems reflect.Value switch kind { case reflect.Map:
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Jul 25 19:30:47 UTC 2022 - 4.4K bytes - Viewed (0) -
operator/pkg/validate/validate_values.go
return util.Errors{err} } val := &v1alpha1.Values{} if err := util.UnmarshalWithJSONPB(string(vs), val, false); err != nil { return util.Errors{err} } return ValuesValidate(DefaultValuesValidations, root.(*structpb.Struct).AsMap(), nil) } // ValuesValidate validates the values of the tree using the supplied Func func ValuesValidate(validations map[string]ValidatorFunc, node any, path util.Path) (errs util.Errors) { pstr := path.String()
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Jul 25 19:30:47 UTC 2022 - 2.3K bytes - Viewed (0) -
pilot/pkg/model/telemetry_test.go
Labels: &structpb.Struct{ Fields: map[string]*structpb.Value{ "req1": {Kind: &structpb.Value_StringValue{StringValue: "%REQ_WITHOUT_QUERY(key1:val1)%"}}, "req2": {Kind: &structpb.Value_StringValue{StringValue: "%REQ_WITHOUT_QUERY(key2:val1)%"}}, "key1": {Kind: &structpb.Value_StringValue{StringValue: "%METADATA(CLUSTER:istio)%"}},
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jun 14 04:34:30 UTC 2024 - 39.6K bytes - Viewed (0) -
pilot/pkg/networking/core/cluster_tls.go
"istio.io/istio/pkg/log" "istio.io/istio/pkg/security" "istio.io/istio/pkg/wellknown" ) var istioMtlsTransportSocketMatch = &structpb.Struct{ Fields: map[string]*structpb.Value{ model.TLSModeLabelShortname: {Kind: &structpb.Value_StringValue{StringValue: model.IstioMutualTLSModeLabel}}, }, } var internalUpstreamSocket = &core.TransportSocket{ Name: "envoy.transport_sockets.internal_upstream",
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Apr 18 19:09:43 UTC 2024 - 19.2K bytes - Viewed (0) -
pilot/pkg/model/context_test.go
} }) } } func mapToStruct(msg map[string]any) (*structpb.Struct, error) { if msg == nil { return &structpb.Struct{}, nil } b, err := json.Marshal(msg) if err != nil { return nil, err } pbs := &structpb.Struct{} if err := protomarshal.Unmarshal(b, pbs); err != nil { return nil, err } return pbs, nil }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Apr 05 23:51:52 UTC 2024 - 11.2K bytes - Viewed (0) -
pilot/pkg/networking/core/cluster.go
} } // Build a struct which contains service metadata and will be added into cluster label. func buildServiceMetadata(svc *model.Service) *structpb.Value { return &structpb.Value{ Kind: &structpb.Value_StructValue{ StructValue: &structpb.Struct{ Fields: map[string]*structpb.Value{ // service fqdn "host": { Kind: &structpb.Value_StringValue{
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 01:56:28 UTC 2024 - 33K bytes - Viewed (0) -
pkg/istio-agent/grpcxds/grpc_bootstrap.go
} } return &bootstrap, err } func extractMeta(node *model.Node) (*structpb.Struct, error) { bytes, err := json.Marshal(node.Metadata) if err != nil { return nil, err } rawMeta := map[string]any{} if err := json.Unmarshal(bytes, &rawMeta); err != nil { return nil, err } xdsMeta, err := structpb.NewStruct(rawMeta) if err != nil { return nil, err } return xdsMeta, nil }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sat Mar 30 00:31:03 UTC 2024 - 7.1K bytes - Viewed (0)