Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for targetsMap (2.24 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 Dec 28 19:28:13 UTC 2025
    - Last Modified: Wed Apr 09 14:28:39 UTC 2025
    - 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 Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 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 Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 9.2K bytes
    - Viewed (0)
  4. 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)
  5. 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)
  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 Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Jun 21 22:22:24 UTC 2024
    - 7.7K bytes
    - Viewed (0)
Back to top