- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 15 for sein (0.2 sec)
-
cmd/bootstrap-peer-server.go
ns1 := s1.NEndpoints ns2 := s2.NEndpoints if ns1 != ns2 { return fmt.Errorf("Expected number of endpoints %d, seen %d", ns1, ns2) } for i, cmdLine := range s1.CmdLines { if cmdLine != s2.CmdLines[i] { return fmt.Errorf("Expected command line argument %s, seen %s", cmdLine, s2.CmdLines[i]) } } if reflect.DeepEqual(s1.MinioEnv, s2.MinioEnv) { return nil }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 7.5K bytes - Viewed (0) -
cmd/erasure-server-pool-rebalance.go
wk.Take() go rebalanceEntry(entry) }, ) if err == nil || errors.Is(err, context.Canceled) { return } setN := humanize.Ordinal(setIdx + 1) rebalanceLogIf(ctx, fmt.Errorf("listing objects from %s set failed with %v", setN, err), "rebalance-listing-failed"+setN) }(setIdx) } wk.Wait() return nil } type rebalSaveOpts uint8 const (
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 26 19:29:28 GMT 2024 - 27.2K bytes - Viewed (0) -
cmd/bucket-targets.go
defaultHealthCheckReloadDuration = 30 * time.Minute ) type arnTarget struct { Client *TargetClient lastRefresh time.Time } // arnErrs represents number of errors seen for a ARN and if update is in progress // to refresh remote targets from bucket metadata. type arnErrs struct { count int64 updateInProgress bool bucket string }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 01:09:56 GMT 2024 - 20.9K bytes - Viewed (0) -
cmd/metrics-v2.go
return MetricDescription{ Namespace: clusterMetricNamespace, Subsystem: replicationSubsystem, Name: recentBacklogCount, Help: "Total number of objects seen in replication backlog in the last 5 minutes", Type: gaugeMetric, } } func getClusterRepCredentialErrorsMD(namespace MetricNamespace) MetricDescription { return MetricDescription{
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 25 22:01:31 GMT 2024 - 132.6K bytes - Viewed (0) -
cmd/erasure-server-pool.go
// If there is not enough space the pool will return 0 bytes available. // The size of each will be multiplied by the number of sets. // Negative sizes are seen as 0 bytes. func (z *erasureServerPools) getServerPoolsAvailableSpace(ctx context.Context, bucket, object string, size int64) serverPoolsAvailableSpace { serverPools := make(serverPoolsAvailableSpace, len(z.serverPools))
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 03 20:08:20 GMT 2024 - 80.5K bytes - Viewed (0) -
cmd/erasure-server-pool-decom.go
) if err == nil || errors.Is(err, context.Canceled) { break } setN := humanize.Ordinal(setIdx + 1) retryDur := time.Duration(rand.Float64() * float64(5*time.Second)) decomLogOnceIf(ctx, fmt.Errorf("listing objects from %s set failed with %v, retrying in %v", setN, err, retryDur), "decom-listing-failed"+setN) time.Sleep(retryDur) } }(setIdx) } wk.Wait() return nil }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 15:18:21 GMT 2024 - 41.5K bytes - Viewed (1) -
cmd/storage-rest-client.go
// IsOnline - returns whether RPC client failed to connect or not. func (client *storageRESTClient) IsOnline() bool { return client.gridConn.State() == grid.StateConnected } // LastConn - returns when the disk is seen to be connected the last time func (client *storageRESTClient) LastConn() time.Time { return client.restClient.LastConn() } func (client *storageRESTClient) IsLocal() bool { return false }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 26.1K bytes - Viewed (0) -
docs/metrics/prometheus/list.md
| `minio_cluster_replication_max_queued_count` | Maximum number of objects queued for replication seen since server start | | `minio_cluster_replication_recent_backlog_count` | Total number of objects seen in replication backlog in the last 5 minutes |
Plain Text - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 25 22:01:31 GMT 2024 - 43.4K bytes - Viewed (2) -
internal/grid/handlers.go
return h != handlerInvalid && h < handlerLast } func (h HandlerID) isTestHandler() bool { return h >= handlerTest && h <= handlerTest2 } // RemoteErr is a remote error type. // Any error seen on a remote will be returned like this. type RemoteErr string // NewRemoteErr creates a new remote error. // The error type is not preserved. func NewRemoteErr(err error) *RemoteErr { if err == nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 23 17:15:52 GMT 2024 - 27.1K bytes - Viewed (0) -
cmd/site-replication.go
Enabled bool MaxBuckets int // maximum buckets seen across sites MaxUsers int // maximum users seen across sites MaxGroups int // maximum groups seen across sites MaxPolicies int // maximum policies across sites
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 01:09:56 GMT 2024 - 184.2K bytes - Viewed (1)