- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 39 for NodeMetadata (0.16 sec)
-
pilot/pkg/networking/core/cluster_traffic_policy_test.go
t.Fatalf("expected alpn list %v; got %v", util.ALPNInMeshWithMxc, got) } }, }, } proxy := &model.Proxy{ Type: model.SidecarProxy, Metadata: &model.NodeMetadata{}, IstioVersion: &model.IstioVersion{Major: 1, Minor: 5}, } push := model.NewPushContext() for _, test := range tests { t.Run(test.name, func(t *testing.T) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon May 06 03:53:05 UTC 2024 - 9K bytes - Viewed (0) -
pkg/bootstrap/option/instances.go
} func Zone(value string) Instance { return newOptionOrSkipIfZero("zone", value) } func SubZone(value string) Instance { return newOptionOrSkipIfZero("sub_zone", value) } func NodeMetadata(meta *model.BootstrapNodeMetadata, rawMeta map[string]any) Instance { return newOptionOrSkipIfZero("meta_json_str", meta).withConvert(nodeMetadataConverter(meta, rawMeta)) } func RuntimeFlags(flags map[string]any) Instance {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 14 17:02:38 UTC 2024 - 9K bytes - Viewed (0) -
pilot/pkg/xds/bench_test.go
}) proxy := &model.Proxy{ Type: model.SidecarProxy, IPAddresses: []string{"10.3.3.3"}, ID: "random", ConfigNamespace: "default", Metadata: &model.NodeMetadata{}, } push := s.PushContext() proxy.SetSidecarScope(push) b.ResetTimer() var c model.Resources for n := 0; n < b.N; n++ { watchedResources := []string{}
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Apr 22 18:13:40 UTC 2024 - 19.7K bytes - Viewed (0) -
pilot/pkg/networking/core/fake.go
func (f *ConfigGenTest) SetupProxy(p *model.Proxy) *model.Proxy { // Setup defaults if p == nil { p = &model.Proxy{} } if p.Metadata == nil { p.Metadata = &model.NodeMetadata{} } if p.Metadata.IstioVersion == "" { p.Metadata.IstioVersion = "1.23.0" } if p.IstioVersion == nil { p.IstioVersion = model.ParseIstioVersion(p.Metadata.IstioVersion) } if p.Type == "" {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 11.5K bytes - Viewed (0) -
pilot/pkg/model/telemetry_test.go
reportingDisabled = !reportingEnabled ) func TestTracing(t *testing.T) { sidecar := &Proxy{ ConfigNamespace: "default", Labels: map[string]string{"app": "test"}, Metadata: &NodeMetadata{Labels: map[string]string{"app": "test"}}, } envoy := &tpb.Telemetry{ Tracing: []*tpb.Tracing{ { Providers: []*tpb.ProviderRef{ { Name: "envoy", }, }, },
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jun 14 04:34:30 UTC 2024 - 39.6K bytes - Viewed (0) -
pkg/bootstrap/config.go
// Add locality options. opts := getLocalityOptions(node.Locality) opts = append(opts, getStatsOptions(node.Metadata)...) opts = append(opts, option.NodeMetadata(node.Metadata, node.RawMetadata), option.RuntimeFlags(extractRuntimeFlags(node.Metadata.ProxyConfig, policy)), option.EnvoyStatusPort(node.Metadata.EnvoyStatusPort),
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 14 17:02:38 UTC 2024 - 27.6K bytes - Viewed (0) -
pilot/pkg/serviceregistry/serviceregistry_test.go
for _, ambient := range []bool{false, true} { name := "disabled" if ambient { name = "enabled" } m := mesh.DefaultMeshConfig() var nodeMeta *model.NodeMetadata if ambient { nodeMeta = &model.NodeMetadata{EnableHBONE: true} pod = pod.DeepCopy() pod.Annotations[constants.AmbientRedirection] = constants.AmbientRedirectionEnabled } opts := xds.FakeOptions{MeshConfig: m}
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 51.2K bytes - Viewed (0) -
pilot/pkg/security/authz/builder/builder_test.go
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Apr 17 22:20:44 UTC 2024 - 13.8K bytes - Viewed (0) -
pilot/pkg/networking/core/cluster_builder_test.go
return mc } func newSidecarProxy() *model.Proxy { return &model.Proxy{Type: model.SidecarProxy, Metadata: &model.NodeMetadata{}} } func newGatewayProxy() *model.Proxy { return &model.Proxy{Type: model.Router, Metadata: &model.NodeMetadata{}} } // Helper function to extract TLS context from a cluster func getTLSContext(t *testing.T, c *cluster.Cluster) *tls.UpstreamTlsContext {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 01:56:28 UTC 2024 - 110.4K bytes - Viewed (0) -
pkg/istio-agent/agent_test.go
t.Helper() m := map[string]any{} for k, v := range proxyConfig.ProxyMetadata { if strings.HasPrefix(k, bootstrap.IstioMetaPrefix) { m[strings.TrimPrefix(k, bootstrap.IstioMetaPrefix)] = v } } b, err := json.Marshal(m) if err != nil { t.Fatal(err) } meta := model.NodeMetadata{} if err := json.Unmarshal(b, &meta); err != nil {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 16 22:12:28 UTC 2024 - 33.4K bytes - Viewed (0)