Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 14 of 14 for EndpointServerPools (0.18 sec)

  1. cmd/peer-s3-client.go

    // S3PeerSys - S3 peer call system.
    type S3PeerSys struct {
    	peerClients []peerS3Client // Excludes self
    	poolsCount  int
    }
    
    // NewS3PeerSys - creates new S3 peer calls.
    func NewS3PeerSys(endpoints EndpointServerPools) *S3PeerSys {
    	return &S3PeerSys{
    		peerClients: newPeerS3Clients(endpoints),
    		poolsCount:  len(endpoints),
    	}
    }
    
    // HealBucket - heals buckets at node level
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Aug 13 22:26:05 UTC 2024
    - 15.4K bytes
    - Viewed (0)
  2. cmd/server-main.go

    	<-globalOSSignalCh
    }
    
    // Initialize object layer with the supplied disks, objectLayer is nil upon any error.
    func newObjectLayer(ctx context.Context, endpointServerPools EndpointServerPools) (newObject ObjectLayer, err error) {
    	return newErasureServerPools(ctx, endpointServerPools)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Sep 24 21:50:11 UTC 2024
    - 35.2K bytes
    - Viewed (1)
  3. cmd/notification.go

    		}
    	}
    	return reply
    }
    
    // Construct a list of offline disks information for a given node.
    // If offlineHost is empty, do it for the local disks.
    func getOfflineDisks(offlineHost string, endpoints EndpointServerPools) []madmin.Disk {
    	var offlineDisks []madmin.Disk
    	for _, pool := range endpoints {
    		for _, ep := range pool.Endpoints {
    			if offlineHost == "" && ep.IsLocal || offlineHost == ep.Host {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 09 16:58:30 UTC 2024
    - 46.2K bytes
    - Viewed (0)
  4. cmd/peer-rest-client.go

    // The two slices will point to the same clients,
    // but 'all' will contain nil entry for local client.
    // The 'all' slice will be in the same order across the cluster.
    func newPeerRestClients(endpoints EndpointServerPools) (remote, all []*peerRESTClient) {
    	if !globalIsDistErasure {
    		// Only useful in distributed setups
    		return nil, nil
    	}
    
    	hosts := endpoints.hostsSorted()
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 09 16:58:30 UTC 2024
    - 26.1K bytes
    - Viewed (0)
Back to top