- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 22 for newEndpoint (0.19 sec)
-
cmd/endpoint.go
} return nil } // NewEndpoints - returns new endpoint list based on input args. func NewEndpoints(args ...string) (endpoints Endpoints, err error) { var endpointType EndpointType var scheme string uniqueArgs := set.NewStringSet() // Loop through args and adds to endpoint list. for i, arg := range args { endpoint, err := NewEndpoint(arg) if err != nil {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 34.1K bytes - Viewed (0) -
platforms/core-runtime/messaging/src/main/java/org/gradle/internal/remote/internal/hub/MessageHub.java
streamFailureHandler = DISCARD; } ChannelIdentifier identifier = new ChannelIdentifier(channelName); EndPointQueue queue = incomingQueue.getChannel(identifier).newEndpoint(); workers.execute(new Handler(queue, dispatch, boundedDispatch, rejectedMessageListener, streamFailureHandler)); } finally { lock.unlock(); } } /**
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 08:59:22 UTC 2023 - 16.2K bytes - Viewed (0) -
cmd/endpoint_test.go
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Sat Jan 13 07:53:03 UTC 2024 - 18.9K bytes - Viewed (0) -
pkg/proxy/ipvs/proxier.go
} } } else { endpoints = clusterEndpoints } } newEndpoints := sets.New[string]() for _, epInfo := range endpoints { newEndpoints.Insert(epInfo.String()) } // Create new endpoints for _, ep := range newEndpoints.UnsortedList() { ip, port, err := net.SplitHostPort(ep) if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Apr 28 15:51:23 UTC 2024 - 77.7K bytes - Viewed (0) -
pkg/controller/endpoint/endpoints_controller.go
return nil } newEndpoints := currentEndpoints.DeepCopy() newEndpoints.Subsets = subsets newEndpoints.Labels = service.Labels if newEndpoints.Annotations == nil { newEndpoints.Annotations = make(map[string]string) } if !endpointsLastChangeTriggerTime.IsZero() { newEndpoints.Annotations[v1.EndpointsLastChangeTriggerTime] =
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 26.3K bytes - Viewed (0) -
src/vendor/golang.org/x/net/lif/lif.go
package lif import ( "syscall" ) type endpoint struct { af int s uintptr } func (ep *endpoint) close() error { return syscall.Close(int(ep.s)) } func newEndpoints(af int) ([]endpoint, error) { var lastErr error var eps []endpoint afs := []int{syscall.AF_INET, syscall.AF_INET6} if af != syscall.AF_UNSPEC { afs = []int{af} } for _, af := range afs {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Oct 19 23:33:33 UTC 2023 - 950 bytes - Viewed (0) -
pkg/proxy/healthcheck/service_health.go
"serviceProxyHealthy": %v } `, h.name.Namespace, h.name.Name, count, kubeProxyHealthy)), "\n")) } func (hcs *server) SyncEndpoints(newEndpoints map[types.NamespacedName]int) error { hcs.lock.Lock() defer hcs.lock.Unlock() for nsn, count := range newEndpoints { if hcs.services[nsn] == nil { continue } klog.V(3).InfoS("Reporting endpoints for healthcheck", "endpointCount", count, "service", nsn)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 30 09:25:48 UTC 2023 - 8.9K bytes - Viewed (0) -
src/vendor/golang.org/x/net/lif/address.go
// // The provided af must be an address family and name must be a data // link name. The zero value of af or name means a wildcard. func Addrs(af int, name string) ([]Addr, error) { eps, err := newEndpoints(af) if len(eps) == 0 { return nil, err } defer func() { for _, ep := range eps { ep.close() } }() lls, err := links(eps, name) if len(lls) == 0 { return nil, err }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Oct 19 23:33:33 UTC 2023 - 2.5K bytes - Viewed (0) -
src/vendor/golang.org/x/net/lif/link.go
// // The provided af must be an address family and name must be a data // link name. The zero value of af or name means a wildcard. func Links(af int, name string) ([]Link, error) { eps, err := newEndpoints(af) if len(eps) == 0 { return nil, err } defer func() { for _, ep := range eps { ep.close() } }() return links(eps, name) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Oct 19 23:33:33 UTC 2023 - 3.7K bytes - Viewed (0) -
cmd/test-utils_test.go
Endpoints: endpoints, CmdLine: strings.Join(args, " "), }} } func mustGetNewEndpoints(poolIdx int, drivesPerSet int, args ...string) (endpoints Endpoints) { endpoints, err := NewEndpoints(args...) if err != nil { panic(err) } for i := range endpoints { endpoints[i].SetPoolIndex(poolIdx) endpoints[i].SetSetIndex(i / drivesPerSet) endpoints[i].SetDiskIndex(i % drivesPerSet)
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 15:50:49 UTC 2024 - 76.9K bytes - Viewed (0)