- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 2,786 for structpb (0.28 sec)
-
security/pkg/nodeagent/caclient/providers/citadel/client.go
} } // CSRSign calls Citadel to sign a CSR. func (c *CitadelClient) CSRSign(csrPEM []byte, certValidTTLInSec int64) (res []string, err error) { crMetaStruct := &structpb.Struct{ Fields: map[string]*structpb.Value{ security.CertSigner: { Kind: &structpb.Value_StringValue{StringValue: c.opts.CertSigner}, }, }, } req := &pb.IstioCertificateRequest{ Csr: string(csrPEM),
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 16 22:12:28 UTC 2024 - 4.9K bytes - Viewed (0) -
operator/pkg/util/util.go
} return buf.String(), nil } func ValueString(v *structpb.Value) string { switch x := v.Kind.(type) { case *structpb.Value_StringValue: return x.StringValue case *structpb.Value_NumberValue: return fmt.Sprint(x.NumberValue) default: return v.String() } } func MustStruct(m map[string]any) *structpb.Struct { s, _ := structpb.NewStruct(m) return s
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 02 13:01:43 UTC 2023 - 3.9K bytes - Viewed (0) -
pkg/config/xds/xds.go
"google.golang.org/protobuf/proto" "google.golang.org/protobuf/types/known/structpb" networking "istio.io/api/networking/v1alpha3" "istio.io/istio/pkg/util/protomarshal" ) // nolint: interfacer func BuildXDSObjectFromStruct(applyTo networking.EnvoyFilter_ApplyTo, value *structpb.Struct, strict bool) (proto.Message, error) { if value == nil { // for remove ops return nil, nil }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sat Jan 14 02:41:27 UTC 2023 - 3K bytes - Viewed (0) -
pkg/test/framework/components/istio/istio.go
type OperatorValues map[string]*structpb.Value // This regular expression matches list object index selection expression such as // abc[100], Tba_a[0]. var listObjRex = regexp.MustCompile(`^([a-zA-Z]?[a-z_A-Z\d]*)\[([ ]*[\d]+)[ ]*\]$`) func getConfigValue(path []string, val map[string]*structpb.Value) *structpb.Value { retVal := structpb.NewNullValue() if len(path) > 0 {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Oct 30 17:47:34 UTC 2023 - 8K bytes - Viewed (0) -
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) -
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) -
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) -
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)