- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 53 for ep (0.02 sec)
-
istioctl/pkg/writer/envoy/configdump/endpoint.go
return ep.GetEndpoint().GetAddress().GetSocketAddress().GetPortValue() } func retrieveEndpointAddresses(ep *endpoint.LbEndpoint) []string { addrs := []*core.Address{ep.GetEndpoint().GetAddress()} for _, a := range ep.GetEndpoint().GetAdditionalAddresses() { addrs = append(addrs, a.GetAddress()) } result := make([]string, 0, len(addrs)) for _, addr := range addrs {
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Mon Jul 22 09:57:29 UTC 2024 - 6.1K bytes - Viewed (0) -
cmd/endpoint.go
*url.URL IsLocal bool PoolIdx, SetIdx, DiskIdx int } // Equal returns true if endpoint == ep func (endpoint Endpoint) Equal(ep Endpoint) bool { if endpoint.IsLocal == ep.IsLocal && endpoint.PoolIdx == ep.PoolIdx && endpoint.SetIdx == ep.SetIdx && endpoint.DiskIdx == ep.DiskIdx { if endpoint.Path == ep.Path && endpoint.Host == ep.Host { return true } } return false } func (endpoint Endpoint) String() string {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Jun 21 22:22:24 UTC 2024 - 34.2K bytes - Viewed (0) -
cmd/bucket-targets.go
h.Online = false sys.hc[ep.Host] = h } } func (sys *BucketTargetSys) initHC(ep *url.URL) { sys.hMutex.Lock() sys.hc[ep.Host] = epHealth{ Endpoint: ep.Host, Scheme: ep.Scheme, Online: true, } sys.hMutex.Unlock() } // newHCClient initializes an anonymous client for performing health check on the remote endpoints func newHCClient() *madmin.AnonymousClient {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Jun 21 22:22:24 UTC 2024 - 20.9K bytes - Viewed (0) -
cmd/erasure.go
offlineDisks = make(madmin.BackendDisks) for _, disk := range disksInfo { ep := disk.Endpoint if _, ok := offlineDisks[ep]; !ok { offlineDisks[ep] = 0 } if _, ok := onlineDisks[ep]; !ok { onlineDisks[ep] = 0 } } // Wait for the routines. for _, disk := range disksInfo { ep := disk.Endpoint state := disk.State
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Oct 04 22:23:33 UTC 2024 - 16.1K bytes - Viewed (0) -
cmd/warm-backend-azure.go
} return nil } func (conf azureConf) NewClient() (clnt *azblob.Client, clntErr error) { if err := conf.Validate(); err != nil { return nil, err } ep := conf.Endpoint if ep == "" { ep = fmt.Sprintf("https://%s.blob.core.windows.net", conf.AccountName) } if conf.IsSPEnabled() {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Oct 31 22:10:24 UTC 2024 - 7K bytes - Viewed (0) -
ci/official/containers/linux_arm64/builder.devtoolset/gcc9-fixups.patch
--- a/stdlib/setenv.c +++ b/stdlib/setenv.c @@ -319,6 +319,7 @@ unsetenv (const char *name) ep = __environ; if (ep != NULL) + { while (*ep != NULL) if (!strncmp (*ep, name, len) && (*ep)[len] == '=') { @@ -332,6 +333,7 @@ unsetenv (const char *name) } else ++ep; + } UNLOCK; diff --git a/support/Makefile b/support/Makefile
Registered: Tue Nov 05 12:39:12 UTC 2024 - Last Modified: Mon Sep 18 14:52:45 UTC 2023 - 8.9K bytes - Viewed (0) -
cmd/admin-handlers-pools.go
// first node. The following is required to serialize (the effects of) // concurrent rebalance-start commands. if ep := globalEndpoints[0].Endpoints[0]; !ep.IsLocal { for nodeIdx, proxyEp := range globalProxyEndpoints { if proxyEp.Endpoint.Host == ep.Host { if proxyRequestByNodeIndex(ctx, w, r, nodeIdx) { return } } } }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Jun 28 00:22:30 UTC 2024 - 10.9K bytes - Viewed (0) -
cmd/bootstrap-peer-server.go
} scfg := &ServerSystemConfig{NEndpoints: globalEndpoints.NEndpoints(), MinioEnv: envValues, Checksum: binaryChecksum} var cmdLines []string for _, ep := range globalEndpoints { cmdLines = append(cmdLines, ep.CmdLine) } scfg.CmdLines = cmdLines return scfg } func (s *bootstrapRESTServer) VerifyHandler(params *grid.MSS) (*ServerSystemConfig, *grid.RemoteErr) {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Oct 01 22:13:18 UTC 2024 - 8.4K bytes - Viewed (0) -
cmd/lock-rest-client.go
if endpoint.IsLocal { return globalLockServer } return newlockRESTClient(endpoint) } // Returns a lock rest client. func newlockRESTClient(ep Endpoint) *lockRESTClient { return &lockRESTClient{globalLockGrid.Load().Connection(ep.GridHost())}
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Jul 29 18:10:04 UTC 2024 - 3.3K bytes - Viewed (0) -
istioctl/pkg/writer/ztunnel/configdump/services.go
for _, addr := range svc.Addresses { _, ip, _ := strings.Cut(addr, "/") ips = append(ips, ip) } allEndpoints := len(svc.Endpoints) healthyEndpoints := 0 for _, ep := range svc.Endpoints { w, f := workloadsByUID[ep.WorkloadUID] if !f { continue } if w.Status != "Healthy" { continue } healthyEndpoints++ }
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Wed Jul 24 09:07:30 UTC 2024 - 3.2K bytes - Viewed (0)