Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 45 for ep (0.02 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top