- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 513 for isOnline (0.14 sec)
-
cmd/lock-rest-client.go
"github.com/minio/minio/internal/grid" ) // lockRESTClient is authenticable lock REST client type lockRESTClient struct { connection *grid.Connection } // IsOnline - returns whether REST client failed to connect or not. func (c *lockRESTClient) IsOnline() bool { return c.connection.State() == grid.StateConnected } // Not a local locker func (c *lockRESTClient) IsLocal() bool { return false }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Nov 24 17:07:14 UTC 2023 - 3.3K bytes - Viewed (0) -
cmd/consolelogger.go
return &HTTPConsoleLoggerSys{ pubsub: pubsub.New[log.Info, madmin.LogMask](8), console: console.New(w), logBuf: ring.New(defaultLogBufferCount), } } // IsOnline always true in case of console logger func (sys *HTTPConsoleLoggerSys) IsOnline(_ context.Context) bool { return true } // SetNodeName - sets the node name if any after distributed setup has initialized
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 5.5K bytes - Viewed (0) -
internal/dsync/locker.go
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Tue Jan 18 20:44:38 UTC 2022 - 2.7K bytes - Viewed (0) -
cmd/lock-rest-client_test.go
defer cancel() err = initGlobalGrid(ctx, []PoolEndpoints{{Endpoints: Endpoints{endpoint, endpointLocal}}}) if err != nil { t.Fatal(err) } lkClient := newlockRESTClient(endpoint) if lkClient.IsOnline() { t.Fatalf("unexpected result. connection was online") } // Attempt all calls. _, err = lkClient.RLock(context.Background(), dsync.LockArgs{}) if err == nil { t.Fatal("Expected for Rlock to fail") }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Tue Nov 21 01:09:35 UTC 2023 - 2K bytes - Viewed (0) -
internal/logger/target/testlogger/testlogger.go
return "" } func (t *testLogger) Stats() types.TargetStats { return types.TargetStats{} } func (t *testLogger) Init(ctx context.Context) error { return nil } func (t *testLogger) IsOnline(ctx context.Context) bool { return t.current.Load() != nil } func (t *testLogger) Cancel() { t.current.Store(nil) } func (t *testLogger) Send(ctx context.Context, entry interface{}) error {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 4K bytes - Viewed (0) -
cmd/naughty-disk_test.go
} func (d *naughtyDisk) String() string { return d.disk.String() } func (d *naughtyDisk) IsOnline() bool { if err := d.calcError(); err != nil { return err == errDiskNotFound } return d.disk.IsOnline() } func (d *naughtyDisk) LastConn() time.Time { return d.disk.LastConn() } func (d *naughtyDisk) IsLocal() bool { return d.disk.IsLocal() }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 15:51:27 UTC 2024 - 9.4K bytes - Viewed (0) -
cmd/storage-interface.go
// For that individual storage API calls will fail properly. The purpose // of this function is to know if the "drive" has "format.json" or not // if it has a "format.json" then is it correct "format.json" or not. IsOnline() bool // Returns the last time this disk (re)-connected LastConn() time.Time // Indicates if disk is local or not. IsLocal() bool // Returns hostname if disk is remote. Hostname() string
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 15:51:27 UTC 2024 - 5K bytes - Viewed (0) -
internal/dsync/dsync-client_test.go
} return &ReconnectRESTClient{ u: u, rest: rest.NewClient(u, tr, nil), } } // Close closes the underlying socket file descriptor. func (restClient *ReconnectRESTClient) IsOnline() bool { // If rest client has not connected yet there is nothing to close. return restClient.rest != nil } func (restClient *ReconnectRESTClient) IsLocal() bool { return false }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Jan 20 17:36:09 UTC 2022 - 4.4K bytes - Viewed (0) -
internal/logger/targets.go
// a single log entry and Send it to the log target // // e.g. Send the log to a http server type Target interface { String() string Endpoint() string Stats() types.TargetStats Init(ctx context.Context) error IsOnline(ctx context.Context) bool Cancel() Send(ctx context.Context, entry interface{}) error Type() types.TargetType } type targetsList struct { list []Target mu sync.RWMutex }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 03 15:44:50 UTC 2024 - 6K bytes - Viewed (0) -
cmd/site-replication-metrics.go
Endpoint string `json:"endpoint"` TotalDowntime time.Duration `json:"totalDowntime"` LastOnline time.Time `json:"lastOnline"` Online bool `json:"isOnline"` Latency madmin.LatencyStat `json:"latency"` // replication metrics across buckets roll up ReplicatedSize int64 `json:"replicatedSize"` // Total number of completed operations
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Tue Feb 06 06:00:45 UTC 2024 - 8.2K bytes - Viewed (0)