Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 8 of 8 for EndpointServerPools (0.1 sec)

  1. cmd/endpoint.go

    	SetCount     int
    	DrivesPerSet int
    	Endpoints    Endpoints
    	CmdLine      string
    	Platform     string
    }
    
    // EndpointServerPools - list of list of endpoints
    type EndpointServerPools []PoolEndpoints
    
    // ESCount returns the total number of erasure sets in this cluster
    func (l EndpointServerPools) ESCount() (count int) {
    	for _, p := range l {
    		count += p.SetCount
    	}
    	return
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jun 21 22:22:24 UTC 2024
    - 34.2K bytes
    - Viewed (0)
  2. cmd/endpoint-ellipses.go

    // both ellipses and without ellipses transparently.
    func createServerEndpoints(serverAddr string, poolArgs []poolDisksLayout, legacy bool) (
    	endpointServerPools EndpointServerPools, setupType SetupType, err error,
    ) {
    	if len(poolArgs) == 0 {
    		return nil, -1, errInvalidArgument
    	}
    
    	poolEndpoints, setupType, err := CreatePoolEndpoints(serverAddr, poolArgs...)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Aug 14 17:11:51 UTC 2024
    - 14.7K bytes
    - Viewed (0)
  3. cmd/storage-rest-server.go

    func registerStorageRESTHandlers(router *mux.Router, endpointServerPools EndpointServerPools, gm *grid.Manager) {
    	h := func(f http.HandlerFunc) http.HandlerFunc {
    		return collectInternodeStats(httpTraceHdrs(f))
    	}
    
    	globalLocalDrivesMap = make(map[string]StorageAPI)
    	globalLocalSetDrives = make([][][]StorageAPI, len(endpointServerPools))
    	for pool := range globalLocalSetDrives {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Aug 14 17:11:51 UTC 2024
    - 45.7K bytes
    - Viewed (0)
  4. cmd/globals.go

    	// global console system to send console logs to
    	// registered listeners
    	globalConsoleSys *HTTPConsoleLoggerSys
    
    	// All unique drives for this deployment
    	globalEndpoints EndpointServerPools
    	// All unique nodes for this deployment
    	globalNodes []Node
    
    	// The name of this local node, fetched from arguments
    	globalLocalNodeName    string
    	globalLocalNodeNameHex string
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Sep 03 18:23:41 UTC 2024
    - 16.2K bytes
    - Viewed (0)
  5. 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)
  6. 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)
  7. 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)
  8. 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