- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 83 for ipAddresses (0.22 sec)
-
pilot/pkg/serviceregistry/kube/controller/endpoint_builder.go
ClusterID: c.Cluster(), }, tlsMode: model.GetTLSModeFromEndpointLabels(proxy.Labels), nodeName: proxy.GetNodeName(), } var networkID network.ID if len(proxy.IPAddresses) > 0 { networkID = out.endpointNetwork(proxy.IPAddresses[0]) } out.labels = labelutil.AugmentLabels(proxy.Labels, c.Cluster(), locality, out.nodeName, networkID) return out } func (b *EndpointBuilder) buildIstioEndpoint(
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 4.8K bytes - Viewed (0) -
pilot/pkg/autoregistration/controller_test.go
"missing group": {IPAddresses: []string{"1.2.3.4"}, Metadata: &model.NodeMetadata{Namespace: wgA.Namespace}}, "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}},
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/xds/xds_test.go
func TestServiceScoping(t *testing.T) { baseProxy := func() *model.Proxy { return &model.Proxy{ Metadata: &model.NodeMetadata{}, ID: "app.app", Type: model.SidecarProxy, IPAddresses: []string{"1.1.1.1"}, ConfigNamespace: "app", } } t.Run("STATIC", func(t *testing.T) { s := xds.NewFakeDiscoveryServer(t, xds.FakeOptions{ ConfigString: scopeConfig,
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Mar 27 16:59:05 UTC 2024 - 13.8K bytes - Viewed (0) -
cmd/kube-controller-manager/app/networking.go
go servicecidrs.NewController( ctx, controllerContext.InformerFactory.Networking().V1alpha1().ServiceCIDRs(), controllerContext.InformerFactory.Networking().V1alpha1().IPAddresses(), controllerContext.ClientBuilder.ClientOrDie("service-cidrs-controller"), ).Run(ctx, 5) // TODO use component config return nil, true, nil
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Feb 26 06:51:56 UTC 2024 - 1.7K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/options/serving_test.go
BasicConstraintsValid: true, IsCA: true, } if ip := netutils.ParseIPSloppy(host); ip != nil { template.IPAddresses = append(template.IPAddresses, ip) } else { template.DNSNames = append(template.DNSNames, host) } template.IPAddresses = append(template.IPAddresses, alternateIPs...) template.DNSNames = append(template.DNSNames, alternateDNS...)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 09 15:52:39 UTC 2024 - 13.8K bytes - Viewed (0) -
pilot/cmd/pilot-agent/options/agent.go
PurgeInterval: wasmPurgeInterval, HTTPRequestTimeout: wasmHTTPRequestTimeout, HTTPRequestMaxRetries: wasmHTTPRequestMaxRetries, }, ProxyIPAddresses: proxy.IPAddresses, ServiceNode: proxy.ServiceNode(), EnvoyStatusPort: envoyStatusPortEnv, EnvoyPrometheusPort: envoyPrometheusPortEnv, MinimumDrainDuration: minimumDrainDurationEnv,
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Jun 05 10:02:56 UTC 2024 - 3.4K bytes - Viewed (0) -
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, }, { name: "proxy with IP from the registry, 1 matching WE, but no matching Service",
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 85K bytes - Viewed (0) -
pkg/controller/servicecidrs/servicecidrs_controller.go
c := &Controller{ client: client, queue: workqueue.NewTypedRateLimitingQueueWithConfig( workqueue.DefaultTypedControllerRateLimiter[string](), workqueue.TypedRateLimitingQueueConfig[string]{Name: "ipaddresses"}, ), tree: iptree.New[sets.Set[string]](), workerLoopPeriod: time.Second, } _, _ = serviceCIDRInformer.Informer().AddEventHandler(cache.ResourceEventHandlerFuncs{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 18K bytes - Viewed (0) -
pilot/pkg/xds/vm_test.go
Labels: map[string]string{ "merge": "wg", "wg": "1", }, }, }, Status: nil, }) proxy := &model.Proxy{ Labels: map[string]string{"merge": "me"}, IPAddresses: []string{"1.1.1.1"}, Metadata: &model.NodeMetadata{ AutoRegisterGroup: "wg", Namespace: "namespace", Network: "network1", Labels: map[string]string{"merge": "meta", "meta": "2"},
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jan 12 18:20:36 UTC 2024 - 2.3K bytes - Viewed (0) -
pilot/pkg/networking/core/listener_test.go
pr := &model.Proxy{ Type: model.SidecarProxy, IPAddresses: []string{"2001:1::1"}, Metadata: &model.NodeMetadata{ Namespace: "not-default", }, ConfigNamespace: "not-default", } return pr } var ( tnow = time.Now() proxyHTTP10 = model.Proxy{ Type: model.SidecarProxy, IPAddresses: []string{"1.1.1.1"}, ID: "v0.default",
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 01:56:28 UTC 2024 - 93.6K bytes - Viewed (0)