- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 61 for endpoints1 (0.34 sec)
-
pkg/proxy/nftables/proxier.go
// set of active ClusterIPs. clusterIPsSet = "cluster-ips" // handling for services with no endpoints serviceEndpointsCheckChain = "service-endpoints-check" nodePortEndpointsCheckChain = "nodeport-endpoints-check" noEndpointServicesMap = "no-endpoint-services" noEndpointNodePortsMap = "no-endpoint-nodeports" rejectChain = "reject-chain"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Jun 08 13:48:54 UTC 2024 - 55.5K bytes - Viewed (0) -
pilot/pkg/networking/util/util.go
func cloneLocalityLbEndpoints(endpoints []*endpoint.LocalityLbEndpoints) []*endpoint.LocalityLbEndpoints { out := make([]*endpoint.LocalityLbEndpoints, 0, len(endpoints)) for _, ep := range endpoints { clone := CloneLocalityLbEndpoint(ep) out = append(out, clone) } return out } // return a shallow copy of LocalityLbEndpoints func CloneLocalityLbEndpoint(ep *endpoint.LocalityLbEndpoints) *endpoint.LocalityLbEndpoints {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 01:56:28 UTC 2024 - 28.5K bytes - Viewed (0) -
pkg/workloadapi/workload.proto
// that match less (or, eventually, none) preferences. // For instance, with `[NETWORK, REGION, ZONE]`, we will send to: // 1. Endpoints matching `[NETWORK, REGION, ZONE]` // 2. Endpoints matching `[NETWORK, REGION]` // 3. Endpoints matching `[NETWORK]` // 4. Any endpoints FAILOVER = 2; }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Jun 12 18:02:35 UTC 2024 - 12.9K bytes - Viewed (0) -
internal/kms/config.go
func expandEndpoints(s string) ([]string, error) { var endpoints []string for _, endpoint := range strings.Split(s, ",") { endpoint = strings.TrimSpace(endpoint) if endpoint == "" { continue } if !ellipses.HasEllipses(endpoint) { endpoints = append(endpoints, endpoint) continue } pattern, err := ellipses.FindEllipsesPatterns(endpoint) if err != nil {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Wed Jun 12 14:31:26 UTC 2024 - 13.9K bytes - Viewed (0) -
pilot/pkg/model/endpointshards.go
if oldIstioEndpoints == nil { // If there are no old endpoints, we should push with incoming endpoints as there is nothing to compare. needPush = true } else { newIstioEndpoints = make([]*IstioEndpoint, 0, len(istioEndpoints)) // Check if new Endpoints are ready to be pushed. This check // will ensure that if a new pod comes with a non ready endpoint, // we do not unnecessarily push that config to Envoy.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jun 14 04:34:37 UTC 2024 - 15.6K bytes - Viewed (0) -
samples/addons/prometheus.yaml
tls_config: ca_file: /var/run/secrets/kubernetes.io/serviceaccount/ca.crt insecure_skip_verify: true - honor_labels: true job_name: kubernetes-service-endpoints kubernetes_sd_configs: - role: endpoints relabel_configs: - action: keep regex: true source_labels: - __meta_kubernetes_service_annotation_prometheus_io_scrape - action: drop
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Jun 12 18:57:35 UTC 2024 - 16.2K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/ambient/services.go
if svc.Spec.TrafficDistribution != nil && *svc.Spec.TrafficDistribution == v1.ServiceTrafficDistributionPreferClose { lb = &workloadapi.LoadBalancing{ // Prefer endpoints in close zones, but allow spilling over to further endpoints where required. RoutingPreference: []workloadapi.LoadBalancing_Scope{ workloadapi.LoadBalancing_NETWORK, workloadapi.LoadBalancing_REGION, workloadapi.LoadBalancing_ZONE,
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Jun 05 12:29:55 UTC 2024 - 7.6K bytes - Viewed (0) -
pilot/pkg/networking/core/cluster_builder_test.go
}, } sortEndpoints := func(endpoints []*endpoint.LocalityLbEndpoints) { sort.SliceStable(endpoints, func(i, j int) bool { if strings.Compare(endpoints[i].Locality.Region, endpoints[j].Locality.Region) < 0 { return true } if strings.Compare(endpoints[i].Locality.Zone, endpoints[j].Locality.Zone) < 0 { return true }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 01:56:28 UTC 2024 - 110.4K bytes - Viewed (0) -
cmd/test-utils_test.go
} for i := range endpoints { endpoints[i].SetPoolIndex(poolIdx) endpoints[i].SetSetIndex(i / drivesPerSet) endpoints[i].SetDiskIndex(i % drivesPerSet) } return endpoints } func getEndpointsLocalAddr(endpointServerPools EndpointServerPools) string { for _, endpoints := range endpointServerPools { for _, endpoint := range endpoints.Endpoints { if endpoint.IsLocal && endpoint.Type() == URLEndpointType {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 15:50:49 UTC 2024 - 76.9K bytes - Viewed (0) -
pilot/pkg/networking/core/cluster_builder.go
} // buildExternalSDSCluster generates a cluster that acts as external SDS server func (cb *ClusterBuilder) buildExternalSDSCluster(addr string) *cluster.Cluster { ep := &endpoint.LbEndpoint{ HostIdentifier: &endpoint.LbEndpoint_Endpoint{ Endpoint: &endpoint.Endpoint{ Address: &core.Address{ Address: &core.Address_Pipe{ Pipe: &core.Pipe{ Path: addr, }, }, }, }, }, }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 01:56:28 UTC 2024 - 31.6K bytes - Viewed (0)