- Sort Score
- Result 10 results
- Languages All
Results 1 - 6 of 6 for endpointSet (0.19 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) -
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) -
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)