Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 7 of 7 for targetsMap (0.06 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
Back to top