- Sort Score
- Result 10 results
- Languages All
Results 1 - 9 of 9 for endpointSet (0.16 sec)
-
cmd/endpoint-ellipses_test.go
testCases := []struct { arg string es endpointSet success bool }{ // Tests invalid inputs. { "...", endpointSet{}, false, }, // No range specified. { "{...}", endpointSet{}, false, }, // Invalid range. { "http://minio{2...3}/export/set{1...0}", endpointSet{}, false, },
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 15.2K bytes - Viewed (0) -
pkg/proxy/endpointslicecache.go
func (cache *EndpointSliceCache) addEndpoints(svcPortName *ServicePortName, portNum int, endpointSet map[string]Endpoint, endpoints []discovery.Endpoint) map[string]Endpoint { if endpointSet == nil { endpointSet = map[string]Endpoint{} } // iterate through endpoints to add them to endpointSet. for _, endpoint := range endpoints { if len(endpoint.Addresses) == 0 {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 29 21:07:21 UTC 2024 - 11.7K bytes - Viewed (0) -
pkg/controller/endpointslicemirroring/reconciler_helpers.go
endpointsByKey: map[addrTypePortMapKey]endpointsliceutil.EndpointSet{}, numDesiredEndpoints: 0, } } // desiredCalc helps calculate desired endpoints and ports. type desiredCalc struct { portsByKey map[addrTypePortMapKey][]discovery.EndpointPort endpointsByKey map[addrTypePortMapKey]endpointsliceutil.EndpointSet numDesiredEndpoints int }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jul 11 18:08:12 UTC 2023 - 4.7K bytes - Viewed (0) -
cmd/endpoint-ellipses.go
} return totalSizes } // Parses all arguments and returns an endpointSet which is a collection // of endpoints following the ellipses pattern, this is what is used // by the object layer for initializing itself. func parseEndpointSet(setDriveCount uint64, args ...string) (ep endpointSet, err error) { argPatterns := make([]ellipses.ArgPattern, len(args)) for i, arg := range args {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 14.7K bytes - Viewed (0) -
pkg/controller/endpointslicemirroring/reconciler.go
// and delete. func (r *reconciler) reconcileByPortMapping( endpoints *corev1.Endpoints, existingSlices []*discovery.EndpointSlice, desiredSet endpointsliceutil.EndpointSet, endpointPorts []discovery.EndpointPort, addressType discovery.AddressType, ) (slicesByAction, totalsByAction) { slices := slicesByAction{} totals := totalsByAction{}
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jul 11 18:08:12 UTC 2023 - 13.1K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/endpointslice_test.go
} func testEndpointsEqual(a, b []*model.IstioEndpoint) bool { if len(a) != len(b) { return false } m1 := make(map[endpointKey]int) m2 := make(map[endpointKey]int) for _, i := range a { m1[endpointKey{i.Address, i.ServicePortName}]++ } for _, i := range b { m2[endpointKey{i.Address, i.ServicePortName}]++ } return reflect.DeepEqual(m1, m2)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Aug 14 18:50:38 UTC 2023 - 4.5K bytes - Viewed (0) -
pilot/pkg/xds/debug_test.go
} if (ss.RouteAcked != "") != wantAcked { errorHandler("wanted RouteAcked set %v got %v for %v", wantAcked, ss.RouteAcked, nodeID) } if (ss.EndpointSent != "") != wantSent { errorHandler("wanted EndpointSent set %v got %v for %v", wantSent, ss.EndpointSent, nodeID) } if (ss.EndpointAcked != "") != wantAcked { errorHandler("wanted EndpointAcked set %v got %v for %v", wantAcked, ss.EndpointAcked, nodeID)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jan 12 18:20:36 UTC 2024 - 7.8K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/endpointslice.go
return types.NamespacedName{ Namespace: slice.GetNamespace(), Name: serviceNameForEndpointSlice(slice.GetLabels()), } } // endpointKey unique identifies an endpoint by IP and port name // This is used for deduping endpoints across slices. type endpointKey struct { ip string port string } type endpointSliceCache struct { mu sync.RWMutex
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 16.9K bytes - Viewed (0) -
pilot/pkg/xds/debug.go
ListenerAcked string `json:"listener_acked,omitempty"` RouteSent string `json:"route_sent,omitempty"` RouteAcked string `json:"route_acked,omitempty"` EndpointSent string `json:"endpoint_sent,omitempty"` EndpointAcked string `json:"endpoint_acked,omitempty"` ExtensionConfigSent string `json:"extensionconfig_sent,omitempty"`
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 30 00:26:45 UTC 2024 - 39.5K bytes - Viewed (0)