- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 428 for statRps (0.07 sec)
-
cmd/bucket-replication-stats.go
for _, s := range b.Stats { if s.hasReplicationUsage() { return true } } return false } // ReplicationStats holds the global in-memory replication stats type ReplicationStats struct { // map of site deployment ID to site replication status // for site replication - maintain stats at global level srStats *SRStats // active worker stats workers *ActiveWorkerStat // queue stats cache
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Aug 15 12:04:40 UTC 2024 - 13.6K bytes - Viewed (0) -
guava/src/com/google/common/math/Stats.java
* versions. */ public static Stats fromByteArray(byte[] byteArray) { checkNotNull(byteArray); checkArgument( byteArray.length == BYTES, "Expected Stats.BYTES = %s remaining , got %s", BYTES, byteArray.length); return readFrom(ByteBuffer.wrap(byteArray).order(ByteOrder.LITTLE_ENDIAN)); } /**
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Wed Oct 23 16:45:30 UTC 2024 - 24.9K bytes - Viewed (0) -
cmd/http-stats.go
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Sep 24 17:13:00 UTC 2024 - 11.4K bytes - Viewed (0) -
cmd/bucket-stats.go
} func newBucketReplicationStats() *BucketReplicationStats { return &BucketReplicationStats{ Stats: make(map[string]*BucketReplicationStat), } } // Empty returns true if there are no target stats func (brs *BucketReplicationStats) Empty() bool { return len(brs.Stats) == 0 && brs.ReplicaSize == 0 } // Clone creates a new BucketReplicationStats copy
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Sep 12 11:39:51 UTC 2024 - 13.4K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/app/web/api/admin/stats/ApiAdminStatsAction.java
Registered: Thu Oct 31 13:40:30 UTC 2024 - Last Modified: Thu Feb 22 01:37:57 UTC 2024 - 12.1K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/app/web/api/ApiResult.java
protected String version = ComponentUtil.getSystemHelper().getProductVersion(); protected int status; public ApiResponse status(final Status status) { this.status = status.getId(); return this; } public ApiResult result() { return new ApiResult(this); } } public static class ApiUpdateResponse extends ApiResponse {
Registered: Thu Oct 31 13:40:30 UTC 2024 - Last Modified: Fri Oct 11 21:20:39 UTC 2024 - 12.5K bytes - Viewed (0) -
cmd/bucket-lifecycle.go
xnet "github.com/minio/pkg/v3/net" "github.com/zeebo/xxh3" ) const ( // Disabled means the lifecycle rule is inactive Disabled = "Disabled" // TransitionStatus status of transition TransitionStatus = "transition-status" // TransitionedObjectName name of transitioned object TransitionedObjectName = "transitioned-object" // TransitionedVersionID is version of remote object
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed Oct 23 15:35:37 UTC 2024 - 33.7K bytes - Viewed (0) -
internal/logger/target/http/http.go
func (h *Target) IsOnline(ctx context.Context) bool { return h.status.Load() == statusOnline } // Stats returns the target statistics. func (h *Target) Stats() types.TargetStats { h.logChMu.RLock() queueLength := len(h.logCh) h.logChMu.RUnlock() stats := types.TargetStats{ TotalMessages: h.totalMessages.Load(), FailedMessages: h.failedMessages.Load(),
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed Sep 11 22:20:42 UTC 2024 - 15.6K bytes - Viewed (0) -
tensorflow/c/eager/c_api_experimental.cc
if (h == nullptr) { status->status = tensorflow::errors::InvalidArgument("Invalid handle"); return -1; } return tensorflow::unwrap(h)->DeviceId(&status->status); } TF_CAPI_EXPORT extern void TFE_TensorHandleGetStatus(TFE_TensorHandle* h, TF_Status* status) { status->status = tensorflow::unwrap(h)->TensorHandleStatus(); }
Registered: Tue Nov 05 12:39:12 UTC 2024 - Last Modified: Sat Oct 12 05:11:17 UTC 2024 - 35.9K bytes - Viewed (0) -
internal/logger/target/kafka/kafka.go
msg := sarama.ProducerMessage{ Topic: h.kconfig.Topic, Value: sarama.ByteEncoder(logJSON), } _, _, err = h.producer.SendMessage(&msg) if err != nil { atomic.StoreInt32(&h.status, statusOffline) } else { atomic.StoreInt32(&h.status, statusOnline) } return err } // Init initialize kafka target func (h *Target) init() error { if os.Getenv("_MINIO_KAFKA_DEBUG") != "" {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Sep 06 23:06:30 UTC 2024 - 10.2K bytes - Viewed (0)