Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for endpointServerPools (0.07 sec)

  1. 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 Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 14.6K bytes
    - Viewed (0)
  2. cmd/test-utils_test.go

    func newTestObjectLayer(ctx context.Context, endpointServerPools EndpointServerPools) (newObject ObjectLayer, err error) {
    	initAllSubsystems(ctx)
    
    	return newErasureServerPools(ctx, endpointServerPools)
    }
    
    // initObjectLayer - Instantiates object layer and returns it.
    func initObjectLayer(ctx context.Context, endpointServerPools EndpointServerPools) (ObjectLayer, []StorageAPI, error) {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 77K bytes
    - Viewed (0)
  3. cmd/erasure-server-pool.go

    // Initialize new pool of erasure sets.
    func newErasureServerPools(ctx context.Context, endpointServerPools EndpointServerPools) (ObjectLayer, error) {
    	var (
    		deploymentID       string
    		commonParityDrives int
    		err                error
    
    		formats      = make([]*formatErasureV3, len(endpointServerPools))
    		storageDisks = make([][]StorageAPI, len(endpointServerPools))
    		z            = &erasureServerPools{
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 89.1K bytes
    - Viewed (0)
  4. 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 Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 15.6K bytes
    - Viewed (0)
  5. 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 Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 45.9K bytes
    - Viewed (0)
Back to top