- Sort Score
- Result 10 results
- Languages All
Results 1 - 7 of 7 for targetsMap (0.06 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 Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Aug 08 20:27:40 UTC 2023 - 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 Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Mar 07 16:12:41 UTC 2023 - 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 Nov 03 19:28:11 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 9.2K bytes - Viewed (0) -
src/test/java/org/codelibs/fess/it/admin/PluginTests.java
final Map<String, Object> targetMap = available.stream().filter(map -> !map.get("name").toString().startsWith("fess-")).toList().get(0); final Artifact target = getArtifactFromMap(targetMap); // Install { checkPutMethod(targetMap, getInstallEndpointSuffix()).then().body("response.status", equalTo(0));
Registered: Thu Oct 31 13:40:30 UTC 2024 - Last Modified: Mon Jul 01 02:20:48 UTC 2024 - 6.3K 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 Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Mar 28 17:44:56 UTC 2024 - 8.9K 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 Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Jun 21 22:22:24 UTC 2024 - 7.7K 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 Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Jul 08 21:39:49 UTC 2024 - 6.7K bytes - Viewed (0)