- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 21 for NodeMetadata (0.16 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
pilot/pkg/xds/proxy_dependencies_test.go
} sidecar := &model.Proxy{ Type: model.SidecarProxy, IPAddresses: []string{"127.0.0.1"}, Metadata: &model.NodeMetadata{}, SidecarScope: &model.SidecarScope{Name: generalName, Namespace: nsName}, } gateway := &model.Proxy{ Type: model.Router, ConfigNamespace: nsName, Metadata: &model.NodeMetadata{Namespace: nsName}, Labels: map[string]string{"gateway": "gateway"}, }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Apr 17 22:20:44 UTC 2024 - 13.5K bytes - Viewed (0) -
pilot/pkg/networking/core/listener_builder_test.go
useExactBalance bool }{ { useExactBalance: false, }, { useExactBalance: true, }, } for _, tt := range tests { proxy := &model.Proxy{ Metadata: &model.NodeMetadata{ InboundListenerExactBalance: model.StringBool(tt.useExactBalance), OutboundListenerExactBalance: model.StringBool(tt.useExactBalance), }, }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 01:56:28 UTC 2024 - 24.7K bytes - Viewed (0) -
pilot/pkg/autoregistration/controller_test.go
"missing ip": {Metadata: &model.NodeMetadata{Namespace: wgA.Namespace, AutoRegisterGroup: wgA.Name}}, "missing namespace": {IPAddresses: []string{"1.2.3.4"}, Metadata: &model.NodeMetadata{AutoRegisterGroup: wgA.Name}}, "non-existent group": {IPAddresses: []string{"1.2.3.4"}, Metadata: &model.NodeMetadata{Namespace: wgA.Namespace, AutoRegisterGroup: "dne"}},
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 16 00:00:36 UTC 2024 - 31.4K bytes - Viewed (0) -
pilot/pkg/networking/core/networkfilter_test.go
cg := NewConfigGenTest(t, TestOptions{Services: services}) fcc := inboundChainConfig{ port: model.ServiceInstancePort{ServicePort: &model.Port{}}, } node := &model.Proxy{Metadata: &model.NodeMetadata{IdleTimeout: tt.idleTimeout}} listenerFilters := NewListenerBuilder(cg.SetupProxy(node), cg.PushContext()).buildInboundNetworkFilters(fcc) tcp := &tcp.TcpProxy{}
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Apr 17 22:20:44 UTC 2024 - 25.8K bytes - Viewed (0)