- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 139 for online (0.18 sec)
-
cmd/metrics-v3-cluster-health.go
import "context" const ( healthDrivesOfflineCount = "drives_offline_count" healthDrivesOnlineCount = "drives_online_count" healthDrivesCount = "drives_count" ) var ( healthDrivesOfflineCountMD = NewGaugeMD(healthDrivesOfflineCount, "Count of offline drives in the cluster") healthDrivesOnlineCountMD = NewGaugeMD(healthDrivesOnlineCount, "Count of online drives in the cluster")
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Mar 10 09:15:15 GMT 2024 - 3.9K bytes - Viewed (0) -
cmd/metrics-v3-system-drive.go
m.Set(driveTotalInodes, float64(drive.UsedInodes+drive.FreeInodes), labels...) var healing, online float64 if drive.Healing { healing = 1 } m.Set(driveHealing, healing, labels...) if drive.State == "ok" { online = 1 } m.Set(driveOnline, online, labels...) } func (m *MetricValues) setDriveAPIMetrics(disk madmin.Disk, labels []string) { if disk.Metrics == nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 25 22:01:31 GMT 2024 - 7.8K bytes - Viewed (0) -
cmd/site-replication-metrics.go
} epHealth, ok := epMap[v.Endpoint] if ok { metric.Endpoint = epHealth.Endpoint metric.TotalDowntime = epHealth.offlineDuration metric.LastOnline = epHealth.lastOnline metric.Online = epHealth.Online metric.Latency = madmin.LatencyStat{ Curr: epHealth.latency.curr, Avg: epHealth.latency.avg, Max: epHealth.latency.peak, } } m[dID] = metric } return m }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Feb 06 06:00:45 GMT 2024 - 8.2K bytes - Viewed (0) -
api/maven-api-core/src/main/java/org/apache/maven/api/plugin/annotations/Mojo.java
* @return uses the Maven project and its child modules */ boolean aggregator() default false; /** * does this Mojo need to be online to be executed? * @return need to be online */ boolean onlineRequired() default false; /** * TODO: v4: add a SPI for the configurator * configurator bean name. * @return the configurator bean name
Java - Registered: Sun May 05 03:35:11 GMT 2024 - Last Modified: Fri Apr 12 10:50:18 GMT 2024 - 2.5K bytes - Viewed (0) -
cmd/metrics-v3-cluster-erasure-set.go
erasureSetOverallWriteQuorum = "overall_write_quorum" erasureSetOverallHealth = "overall_health" erasureSetReadQuorum = "read_quorum" erasureSetWriteQuorum = "write_quorum" erasureSetOnlineDrivesCount = "online_drives_count" erasureSetHealingDrivesCount = "healing_drives_count" erasureSetHealth = "health" ) const ( poolIDL = "pool_id" setIDL = "set_id" ) var (
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Mar 10 09:15:15 GMT 2024 - 3.1K bytes - Viewed (0) -
cmd/lock-rest-client_test.go
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") }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Nov 21 01:09:35 GMT 2023 - 2K bytes - Viewed (0) -
buildscripts/verify-healing-empty-erasure-set.sh
fi sleep 1 if pgrep minio; then # forcibly killing, to proceed further properly. if ! pkill -9 minio; then echo "no minio process running anymore, proceed." fi fi } function check_online() { if ! grep -q 'Status:' ${WORK_DIR}/dist-minio-*.log; then echo "1" fi } function purge() { rm -rf "$1" } function __init__() { echo "Initializing environment" mkdir -p "$WORK_DIR"
Shell Script - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 25 21:55:41 GMT 2024 - 3.2K bytes - Viewed (0) -
cmd/metrics-v3-cache.go
clusterDriveMetrics: newClusterStorageInfoCache(), nodesUpDown: newNodesUpDownCache(), } } type nodesOnline struct { Online, Offline int } func newNodesUpDownCache() *cachevalue.Cache[nodesOnline] { loadNodesUpDown := func() (v nodesOnline, err error) { v.Online, v.Offline = globalNotificationSys.GetPeerOnlineCount() return } return cachevalue.NewFromFunc(1*time.Minute,
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 23 23:56:12 GMT 2024 - 7.9K bytes - Viewed (0) -
cmd/storage-interface.go
// Storage operations. // Returns true if disk is online and its valid i.e valid format.json. // This has nothing to do with if the drive is hung or not responding. // 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
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 23 17:15:52 GMT 2024 - 4.9K bytes - Viewed (0) -
cmd/server-startup-msg_test.go
{Endpoint: "http://127.0.0.1:9001/data/4/", State: madmin.DriveStateOffline}, } infoStorage.Backend.Type = madmin.Erasure if msg := getStorageInfoMsg(infoStorage); !strings.Contains(msg, "7 Online, 1 Offline") { t.Fatal("Unexpected storage info message, found:", msg) } } // Tests stripping standard ports from apiEndpoints. func TestStripStandardPorts(t *testing.T) {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Jun 20 00:53:08 GMT 2023 - 4K bytes - Viewed (0)