- Sort Score
- Result 10 results
- Languages All
Results 1 - 2 of 2 for incProxy (0.16 sec)
-
cmd/bucket-replication-stats.go
r.qCache.bucketStats[bucket] = v atomic.AddInt64(&r.qCache.srQueueStats.nowBytes, -1*sz) atomic.AddInt64(&r.qCache.srQueueStats.nowCount, -1) } // incProxy increments proxy metrics for proxied calls func (r *ReplicationStats) incProxy(bucket string, api replProxyAPI, isErr bool) { r.pCache.inc(bucket, api, isErr) } func (r *ReplicationStats) getProxyStats(bucket string) ProxyMetric {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Feb 22 06:26:06 UTC 2024 - 13.4K bytes - Viewed (0) -
cmd/object-handlers.go
if !proxytgts.Empty() { globalReplicationStats.incProxy(bucket, getObjectAPI, false) // proxy to replication target if active-active replication is in place. reader, proxy, perr = proxyGetToReplicationTarget(ctx, bucket, object, rs, r.Header, opts, proxytgts) if perr != nil { globalReplicationStats.incProxy(bucket, getObjectAPI, true) proxyGetErr := ErrorRespToObjectError(perr, bucket, object)
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Jun 14 13:28:35 UTC 2024 - 124.2K bytes - Viewed (0)