- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for getAll (0.2 sec)
-
internal/event/target/kafka.go
if key.IsLast || target.batch.IsFull() { return target.commitBatch() } return nil } func (target *KafkaTarget) commitBatch() error { keys, msgs, err := target.batch.GetAll() if err != nil { return err } if err = target.producer.SendMessages(msgs); err != nil { if isKafkaConnErr(err) { return store.ErrNotConnected } return err }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Feb 20 08:16:35 GMT 2024 - 13K bytes - Viewed (0) -
cmd/bucket-replication-stats.go
rs.Completed = true case replication.Pending: rs.Pending = true case replication.Failed: rs.Failed = true rs.Err = err } } // GetAll returns replication metrics for all buckets at once. func (r *ReplicationStats) GetAll() map[string]BucketReplicationStats { if r == nil { return map[string]BucketReplicationStats{} } r.RLock()
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 13.4K bytes - Viewed (0) -
cmd/notification.go
if nErr.Err != nil { peersLogOnceIf(logger.SetReqInfo(ctx, reqInfo), nErr.Err, nErr.Host.String()) } } replicationStatsList := globalReplicationStats.GetAll() bucketStatsMap := BucketStatsMap{ Stats: make(map[string]BucketStats, len(replicationStatsList)), Timestamp: UTCNow(), } for k, replicationStats := range replicationStatsList {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 12 18:13:36 GMT 2024 - 44.5K bytes - Viewed (0)