- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 181 for It (0.09 sec)
-
pilot/pkg/serviceregistry/kube/controller/endpointslice.go
} } // getPod fetches a pod by name or IP address. // A pod may be missing (nil) for two reasons: // - It is an endpoint without an associated Pod. In this case, expectPod will be false. // - It is an endpoint with an associate Pod, but its not found. In this case, expectPod will be true.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 16.9K bytes - Viewed (0) -
manifests/charts/istio-control/istio-discovery/values.yaml
# By default, a template `sidecar` is always provided, which contains the template of default sidecar. # To inject other additional templates, define it using the `templates` option, and add it to # the default templates list. # For example: # # templates: # hello: | # metadata: # labels: # hello: world #
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Jun 03 01:55:05 UTC 2024 - 21.1K bytes - Viewed (0) -
pilot/pkg/networking/core/loadbalancer/loadbalancer.go
loadAssignment.Endpoints[index].Priority = uint32(i) } } } } // WrappedLocalityLbEndpoints contain an envoy LocalityLbEndpoints // and the original IstioEndpoints used to generate it. // It is used to do failover priority label match with proxy labels. type WrappedLocalityLbEndpoints struct { IstioEndpoints []*model.IstioEndpoint LocalityLbEndpoints *endpoint.LocalityLbEndpoints }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 23 05:38:57 UTC 2024 - 11.8K bytes - Viewed (0) -
security/pkg/nodeagent/sds/sdsservice.go
// case we always write a certificate. A workload can technically run without any mTLS/CA // configured, in which case this will fail; if it becomes noisy we should disable the entire SDS // server in these cases. go func() { // TODO: do we need max timeout for retry, seems meaningless to retry forever if it never succeed b := backoff.NewExponentialBackOff(backoff.DefaultOption())
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sat May 25 00:20:04 UTC 2024 - 10.9K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/multicluster.go
// Note: stop here should be the overall pilot stop, NOT the leader election stop. We are // basically lazy loading the informer, if we stop it when we lose the lock we will never // recreate it again. client.RunAndWait(clusterStopCh) nc.Run(leaderStop) }) election.Run(clusterStopCh) return nil }) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 12.7K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/ambient/ambientindex_workloadentry_test.go
// Add a new pod to the service, we should see it s.addWorkloadEntries(t, "127.0.0.4", "name4", "sa4", map[string]string{"app": "a"}) s.assertWorkloads(t, "", workloadapi.WorkloadStatus_HEALTHY, "name1", "name2", "name3", "name4") s.assertWorkloads(t, s.addrXdsName("10.0.0.1"), workloadapi.WorkloadStatus_HEALTHY, "name1", "name2", "name4") s.assertEvent(t, s.wleXdsName("name4")) // Delete it, should remove from the Service as well
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 08 01:04:50 UTC 2024 - 15.6K bytes - Viewed (0) -
pilot/pkg/xds/workload_test.go
}) ads.ExpectEmptyResponse() // Create pod we are not subscribe to; should be a NOP createPod(s, "pod", "sa", "127.0.0.1", "not-node") ads.ExpectNoResponse() // Now subscribe to it, should get it back resp := ads.RequestResponseAck(&discovery.DeltaDiscoveryRequest{ ResourceNamesSubscribe: []string{"/127.0.0.1"}, }) expect(resp, "Kubernetes//Pod/default/pod") // Subscribe to unknown pod
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/kube/inject/webhook.go
string(req.Object.Raw))) return toAdmissionResponse(err) } // Managed fields is sometimes extremely large, leading to excessive CPU time on patch generation // It does not impact the injection output at all, so we can just remove it. pod.ManagedFields = nil // Deal with potential empty fields, e.g., when the pod is created by a deployment podName := potentialPodName(pod.ObjectMeta)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 14 17:59:39 UTC 2024 - 42.2K bytes - Viewed (0) -
pilot/pkg/bootstrap/server.go
} if s.CA == nil { return false } // For Kubernetes CA, we don't distribute it; it is mounted in all pods by Kubernetes. // This is never called - isK8SSigning is true. if features.PilotCertProvider == constants.CertProviderKubernetes { return false } // For no CA we don't distribute it either, as there is no cert if features.PilotCertProvider == constants.CertProviderNone { return false
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 17:48:28 UTC 2024 - 46.3K bytes - Viewed (0) -
pilot/pkg/model/telemetry.go
// Insert the default provider. It has no overrides; presence of the key is sufficient to // get the filter created. providers[dp] = map[tpb.WorkloadMode]map[string]metricOverride{} } } providerNames := mesh.GetDefaultProviders().GetMetrics() for _, m := range metrics { names := getProviderNames(m.Providers)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 15 18:14:09 UTC 2024 - 35.2K bytes - Viewed (0)