- Sort Score
- Result 10 results
- Languages All
Results 1 - 6 of 6 for targetsMap (2.24 sec)
-
cmd/bucket-replication-utils_test.go
} continue } if len(dsc.targetsMap) != len(test.expDsc.targetsMap) { t.Errorf("Test%d (%s): Invalid number of entries in targetsMap got %d , want %d", i+1, test.name, len(dsc.targetsMap), len(test.expDsc.targetsMap)) } for arn, tdsc := range dsc.targetsMap { expDsc, ok := test.expDsc.targetsMap[arn] if !ok || expDsc != tdsc {
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Wed Apr 09 14:28:39 UTC 2025 - 9.3K bytes - Viewed (0) -
internal/config/lambda/event/targetlist.go
ID() TargetID IsActive() (bool, error) Send(Event) (*http.Response, error) Stat() TargetStat Close() error } // TargetStats is a collection of stats for multiple targets. type TargetStats struct { TargetStats map[string]TargetStat } // TargetStat is the stats of a single target. type TargetStat struct { ID TargetID ActiveRequests int64 TotalRequests int64 FailedRequests int64
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 4.3K bytes - Viewed (0) -
internal/event/targetlist.go
EventsSkipped int64 CurrentQueuedCalls int64 // Deprecated EventsErrorsTotal int64 // Deprecated CurrentSendCalls int64 // Deprecated TargetStats map[TargetID]TargetStat } // TargetStat is the stats of a single target. type TargetStat struct { CurrentSendCalls int64 // CurrentSendCalls is the number of concurrent async Send calls to all targets CurrentQueue int // Populated if target has a store.
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 9.2K bytes - Viewed (0) -
internal/bucket/replication/replication.go
if len(c.Rules) == 0 { return errReplicationNoRule } // Validate all the rules in the replication config targetMap := make(map[string]struct{}) priorityMap := make(map[string]struct{}) var legacyArn bool for _, r := range c.Rules { if _, ok := targetMap[r.Destination.Bucket]; !ok { targetMap[r.Destination.Bucket] = struct{}{} } if err := r.Validate(bucket, sameTarget); err != nil { return err }
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Sun Mar 30 00:56:02 UTC 2025 - 8.9K bytes - Viewed (0) -
internal/config/lambda/target/webhook.go
} // Stat - returns lambda webhook target statistics such as // current calls in progress, successfully completed functions // failed functions. func (target *WebhookTarget) Stat() event.TargetStat { return event.TargetStat{ ID: target.id, ActiveRequests: atomic.LoadInt64(&target.activeRequests), TotalRequests: atomic.LoadInt64(&target.totalRequests),
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Mon Jul 08 21:39:49 UTC 2024 - 6.7K bytes - Viewed (0) -
cmd/event-notification.go
// GetARNList - returns available ARNs. func (evnot *EventNotifier) GetARNList() []string { arns := []string{} if evnot == nil { return arns } region := globalSite.Region() for targetID := range evnot.targetList.TargetMap() { // httpclient target is part of ListenNotification // which doesn't need to be listed as part of the ARN list // This list is only meant for external targets, filter // this out pro-actively.
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Fri Jun 21 22:22:24 UTC 2024 - 7.7K bytes - Viewed (0)