Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 40 for NodeMetadata (0.21 sec)

  1. pilot/pkg/networking/core/accesslog_test.go

    	}{
    		{
    			name: "telemetry",
    			push: env.PushContext(),
    			proxy: &model.Proxy{
    				ConfigNamespace: "default",
    				Labels:          map[string]string{"app": "test"},
    				Metadata:        &model.NodeMetadata{Labels: map[string]string{"app": "test"}},
    			},
    			tcp:   &tcp.TcpProxy{},
    			class: networking.ListenerClassSidecarInbound,
    			expected: &tcp.TcpProxy{
    				AccessLog: []*accesslog.AccessLog{
    					{
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri Jun 14 04:34:30 UTC 2024
    - 19.9K bytes
    - Viewed (0)
  2. pilot/pkg/model/context_test.go

    				DNSDomain:    "local",
    				Metadata:     &model.NodeMetadata{},
    				IstioVersion: model.MaxIstioVersion,
    			},
    			out: "router~10.3.3.3~random~local",
    		},
    		{
    			in: &model.Proxy{
    				Type:        model.SidecarProxy,
    				ID:          "random",
    				IPAddresses: []string{"10.3.3.3", "10.4.4.4", "10.5.5.5", "10.6.6.6"},
    				DNSDomain:   "local",
    				Metadata: &model.NodeMetadata{
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri Apr 05 23:51:52 UTC 2024
    - 11.2K bytes
    - Viewed (0)
  3. pilot/pkg/xds/workload_test.go

    		s := xds.NewFakeDiscoveryServer(t, xds.FakeOptions{
    			KubernetesObjects: []runtime.Object{mkPod("pod", "sa", "127.0.0.1", "not-node")},
    		})
    		ads := s.ConnectDeltaADS().WithType(v3.AddressType).WithMetadata(model.NodeMetadata{NodeName: "node"})
    		ads.Request(&discovery.DeltaDiscoveryRequest{
    			ResourceNamesSubscribe:   []string{"*"},
    			ResourceNamesUnsubscribe: []string{"*"},
    		})
    		ads.ExpectEmptyResponse()
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Apr 18 19:09:43 UTC 2024
    - 15.9K bytes
    - Viewed (0)
  4. pkg/model/proxy.go

    	RawMetadata map[string]any
    	// Locality from Envoy bootstrap
    	Locality *core.Locality
    }
    
    // BootstrapNodeMetadata is a superset of NodeMetadata, intended to model the entirety of the node metadata
    // we configure in the Envoy bootstrap. This is split out from NodeMetadata to explicitly segment the parameters
    // that are consumed by Pilot from the parameters used only as part of the bootstrap. Fields used by bootstrap only
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Apr 25 17:18:17 UTC 2024
    - 18.7K bytes
    - Viewed (0)
  5. pilot/pkg/serviceregistry/kube/controller/endpoint_builder_test.go

    			proxy: &model.Proxy{
    				Metadata: &model.NodeMetadata{},
    			},
    			expected: labels.Instance{},
    		},
    		{
    			name: "region only",
    			ctl:  testController{},
    			proxy: &model.Proxy{
    				Labels: labels.Instance{
    					"k1":                       "v1",
    					label.TopologyNetwork.Name: "mynetwork",
    				},
    				Metadata: &model.NodeMetadata{
    					Labels: labels.Instance{
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu May 23 21:07:03 UTC 2024
    - 7.8K bytes
    - Viewed (0)
  6. pilot/pkg/xds/sds_test.go

    	istiosystem := &model.Proxy{
    		Metadata:         &model.NodeMetadata{ClusterID: constants.DefaultClusterName},
    		VerifiedIdentity: &spiffe.Identity{Namespace: "istio-system"},
    		Type:             model.Router,
    		ConfigNamespace:  "istio-system",
    	}
    	otherNamespace := &model.Proxy{
    		Metadata:         &model.NodeMetadata{ClusterID: constants.DefaultClusterName},
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon May 13 20:55:20 UTC 2024
    - 17.7K bytes
    - Viewed (0)
  7. pilot/pkg/networking/core/tracing_test.go

    		},
    	}
    	opts.proxy = &model.Proxy{
    		Metadata: &model.NodeMetadata{},
    	}
    
    	return opts
    }
    
    func fakeOptsNoTelemetryAPI() gatewayListenerOpts {
    	var opts gatewayListenerOpts
    	opts.push = &model.PushContext{
    		Mesh: &meshconfig.MeshConfig{
    			EnableTracing: true,
    		},
    	}
    	opts.proxy = &model.Proxy{
    		Metadata: &model.NodeMetadata{
    			ProxyConfig: &model.NodeMetaProxyConfig{
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon Apr 08 20:47:52 UTC 2024
    - 38.6K bytes
    - Viewed (0)
  8. pilot/pkg/networking/core/cluster_tls_test.go

    			"foo.com",
    			&model.Proxy{Metadata: &model.NodeMetadata{}},
    			false, false, model.MTLSUnknown,
    			tlsSettings,
    			userSupplied,
    		},
    		{
    			"Metadata cert path override ISTIO_MUTUAL",
    			tlsSettings,
    			[]string{"custom.foo.com"},
    			"custom.foo.com",
    			&model.Proxy{Metadata: &model.NodeMetadata{
    				TLSClientCertChain: "/custom/chain.pem",
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon May 06 03:53:05 UTC 2024
    - 60.9K bytes
    - Viewed (0)
  9. pilot/pkg/model/context.go

    // Any non-string values are ignored.
    func ParseMetadata(metadata *structpb.Struct) (*NodeMetadata, error) {
    	if metadata == nil {
    		return &NodeMetadata{}, nil
    	}
    
    	bootstrapNodeMeta, err := ParseBootstrapNodeMetadata(metadata)
    	if err != nil {
    		return nil, err
    	}
    	return &bootstrapNodeMeta.NodeMetadata, nil
    }
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon Jun 03 08:29:05 UTC 2024
    - 33.6K bytes
    - Viewed (0)
  10. pilot/pkg/serviceregistry/kube/controller/controller_test.go

    		want  []model.ServiceTarget
    	}{
    		{
    			name:  "proxy with unspecified IP",
    			proxy: &model.Proxy{Metadata: &model.NodeMetadata{}, IPAddresses: nil},
    			want:  nil,
    		},
    		{
    			name:  "proxy with IP not in the registry",
    			proxy: &model.Proxy{Metadata: &model.NodeMetadata{}, IPAddresses: []string{"1.1.1.1"}},
    			want:  nil,
    		},
    		{
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu May 23 21:07:03 UTC 2024
    - 85K bytes
    - Viewed (0)
Back to top