Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 39 for NodeMetadata (0.16 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. pilot/pkg/security/authz/builder/builder_test.go

    	}
    	return p
    }
    
    func node(version *model.IstioVersion) *model.Proxy {
    	return &model.Proxy{
    		ID:              "test-node",
    		ConfigNamespace: "foo",
    		Labels:          httpbin,
    		Metadata: &model.NodeMetadata{
    			Labels:    httpbin,
    			Namespace: "foo",
    		},
    		IstioVersion: version,
    	}
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed Apr 17 22:20:44 UTC 2024
    - 13.8K bytes
    - Viewed (0)
  9. 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)
  10. 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)
Back to top