- Sort Score
- Result 10 results
- Languages All
Results 1 - 8 of 8 for EndpointServerPools (0.1 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)