- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 25 for stats (0.22 sec)
-
cmd/admin-handlers.go
} // fetchKMSStatusV2 fetches KMS-related status information for all instances func fetchKMSStatusV2(ctx context.Context) []madmin.KMS { if GlobalKMS == nil { return []madmin.KMS{} } results := GlobalKMS.Verify(ctx) stats := []madmin.KMS{} for _, result := range results { stats = append(stats, madmin.KMS{ Status: result.Status, Endpoint: result.Endpoint,
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Sun Apr 21 11:43:18 GMT 2024 - 97.3K bytes - Viewed (2) -
cmd/bucket-replication.go
for bucket, brs := range s.statusMap { var updt bool // Save the replication status if one resync to any bucket target is still not finished for _, st := range brs.TargetsMap { if st.LastUpdate.Equal(timeSentinel) { updt = true break } } // Save the replication status if a new stats update is found and not saved in the backend yet
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Sat Apr 20 09:05:54 GMT 2024 - 112K bytes - Viewed (1) -
cmd/globals.go
globalDriveMonitoring = env.Get("_MINIO_DRIVE_ACTIVE_MONITORING", config.EnableOn) == config.EnableOn // Is MINIO_CI_CD set? globalIsCICD bool globalRootDiskThreshold uint64 // Used for collecting stats for netperf globalNetPerfMinDuration = time.Second * 10 globalNetPerfRX netPerfRX globalSiteNetPerfRX netPerfRX globalObjectPerfBucket = "minio-perf-test-tmp-bucket"
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Sun Apr 21 11:43:18 GMT 2024 - 16.5K bytes - Viewed (0) -
manifests/charts/base/crds/crd-all.gen.yaml
type: object status: description: Specifies the HTTP response status to be returned. maximum: 4294967295 minimum: 0 type: integer required: - status type: object fault:
Others - Registered: Wed Apr 24 22:53:08 GMT 2024 - Last Modified: Mon Apr 22 20:20:47 GMT 2024 - 606.1K bytes - Viewed (0) -
cmd/object-api-interface.go
} // SetReplicaStatus sets replica status and timestamp for delete operations in ObjectOptions func (o *ObjectOptions) SetReplicaStatus(st replication.StatusType) { o.DeleteReplication.ReplicaStatus = st o.DeleteReplication.ReplicaTimeStamp = UTCNow() } // DeleteMarkerReplicationStatus - returns replication status of delete marker from DeleteReplication state in ObjectOptions
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Sat Apr 20 09:05:54 GMT 2024 - 16.9K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/ExecutionList.java
// Fail fast on a null. We throw NPE here because the contract of Executor states that it throws // NPE on null listener, so we propagate that contract up into the add method as well. checkNotNull(runnable, "Runnable was null."); checkNotNull(executor, "Executor was null."); // Lock while we check state. We must maintain the lock while adding the new pair so that
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Mon Apr 22 21:17:24 GMT 2024 - 6.9K bytes - Viewed (0) -
cmd/utils.go
entry.Error = opts.Error entry.API.Name = opts.APIName entry.API.Bucket = opts.Bucket entry.API.Objects = []xaudit.ObjectVersion{{ObjectName: opts.Object, VersionID: opts.VersionID}} entry.API.Status = opts.Status entry.Tags = make(map[string]interface{}, len(opts.Tags)) for k, v := range opts.Tags { entry.Tags[k] = v } // Merge tag information if found - this is currently needed for tags
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Sun Apr 21 11:43:18 GMT 2024 - 32K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/connection/RealConnectionPool.kt
*/ private fun openConnections(state: AddressState): Long { // This policy does not require minimum connections, don't run again if (state.policy.minimumConcurrentCalls == 0) return -1L var concurrentCallCapacity = 0 for (connection in connections) { if (state.address != connection.route.address) continue connection.withLock {
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 16.2K bytes - Viewed (0) -
istioctl/pkg/writer/ztunnel/configdump/api.go
Identity string `json:"identity"` State string `json:"state"` CertChain []*Cert `json:"certChain"` } type Cert struct { Pem string `json:"pem"` SerialNumber string `json:"serialNumber"` ValidFrom string `json:"validFrom"` ExpirationTime string `json:"expirationTime"` } type WorkloadState struct { State string `json:"state,omitempty"`
Go - Registered: Wed Apr 24 22:53:08 GMT 2024 - Last Modified: Mon Apr 22 15:39:28 GMT 2024 - 4.9K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Connection.kt
@Suppress("NAME_SHADOWING") class Http2Connection internal constructor(builder: Builder) : Closeable { internal val lock: ReentrantLock = ReentrantLock() internal val condition: Condition = lock.newCondition() // Internal state of this connection is guarded by 'lock'. No blocking operations may be // performed while holding this lock! // // Socket writes are guarded by frameWriter. //
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 32.6K bytes - Viewed (0)