Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 1,589 for targetID (0.06 sec)

  1. internal/config/lambda/event/targetidset.go

    			nset.add(k)
    		}
    	}
    
    	return nset
    }
    
    // NewTargetIDSet - creates new TargetID set with given TargetIDs.
    func NewTargetIDSet(targetIDs ...TargetID) TargetIDSet {
    	set := make(TargetIDSet)
    	for _, targetID := range targetIDs {
    		set.add(targetID)
    	}
    	return set
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 1.9K bytes
    - Viewed (0)
  2. internal/event/targetlist.go

    	for id := range targetIDSet {
    		target, ok := list.targets[id]
    		if ok {
    			target.Close()
    			delete(list.targets, id)
    		}
    	}
    }
    
    // Targets - list all targets
    func (list *TargetList) Targets() []Target {
    	if list == nil {
    		return []Target{}
    	}
    
    	list.RLock()
    	defer list.RUnlock()
    
    	targets := []Target{}
    	for _, tgt := range list.targets {
    		targets = append(targets, tgt)
    	}
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 9.2K bytes
    - Viewed (0)
  3. internal/event/targetlist_test.go

    )
    
    type ExampleTarget struct {
    	id       TargetID
    	sendErr  bool
    	closeErr bool
    }
    
    func (target ExampleTarget) ID() TargetID {
    	return target.id
    }
    
    // Save - Sends event directly without persisting.
    func (target ExampleTarget) Save(eventData Event) error {
    	return target.send(eventData)
    }
    
    // Store - Returns a nil store.
    func (target ExampleTarget) Store() TargetStore {
    	return nil
    }
    
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Wed Apr 09 14:28:39 UTC 2025
    - 6K bytes
    - Viewed (0)
  4. internal/event/rulesmap_test.go

    	testCases := []struct {
    		eventNames     []Name
    		pattern        string
    		targetID       TargetID
    		expectedResult RulesMap
    	}{
    		{[]Name{ObjectAccessedAll}, "", TargetID{"1", "webhook"}, rulesMapCase1},
    		{[]Name{ObjectAccessedAll, ObjectCreatedPut}, "", TargetID{"1", "webhook"}, rulesMapCase2},
    		{[]Name{ObjectRemovedDelete}, "2010*.jpg", TargetID{"1", "webhook"}, rulesMapCase3},
    	}
    
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Jan 05 18:43:06 UTC 2024
    - 6.8K bytes
    - Viewed (0)
  5. internal/config/lambda/event/targetlist.go

    		target, ok := list.targets[id]
    		if ok {
    			target.Close()
    			delete(list.targets, id)
    		}
    	}
    }
    
    // Targets - list all targets
    func (list *TargetList) Targets() []Target {
    	if list == nil {
    		return []Target{}
    	}
    
    	list.RLock()
    	defer list.RUnlock()
    
    	targets := make([]Target, 0, len(list.targets))
    	for _, tgt := range list.targets {
    		targets = append(targets, tgt)
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 4.3K bytes
    - Viewed (0)
  6. internal/event/arn.go

    	"strings"
    )
    
    // ARN - SQS resource name representation.
    type ARN struct {
    	TargetID
    	region string
    }
    
    // String - returns string representation.
    func (arn ARN) String() string {
    	if arn.ID == "" && arn.Name == "" && arn.region == "" {
    		return ""
    	}
    
    	return "arn:minio:sqs:" + arn.region + ":" + arn.TargetID.String()
    }
    
    // MarshalXML - encodes to XML data.
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Mar 30 00:56:02 UTC 2025
    - 2K bytes
    - Viewed (0)
  7. internal/event/targetidset.go

    import "maps"
    
    // TargetIDSet - Set representation of TargetIDs.
    type TargetIDSet map[TargetID]struct{}
    
    // Clone - returns copy of this set.
    func (set TargetIDSet) Clone() TargetIDSet {
    	setCopy := NewTargetIDSet()
    	maps.Copy(setCopy, set)
    	return setCopy
    }
    
    // add - adds TargetID to the set.
    func (set TargetIDSet) add(targetID TargetID) {
    	set[targetID] = struct{}{}
    }
    
    // Union - returns union with given set as new set.
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 1.8K bytes
    - Viewed (0)
  8. cmd/metrics-v3-audit.go

    	auditTotalMessages     = "total_messages"
    	targetID               = "target_id"
    )
    
    var (
    	auditFailedMessagesMD = NewCounterMD(auditFailedMessages,
    		"Total number of messages that failed to send since start",
    		targetID)
    	auditTargetQueueLengthMD = NewGaugeMD(auditTargetQueueLength,
    		"Number of unsent messages in queue for target",
    		targetID)
    	auditTotalMessagesMD = NewCounterMD(auditTotalMessages,
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri May 10 14:50:39 UTC 2024
    - 1.9K bytes
    - Viewed (0)
  9. internal/config/lambda/event/arn.go

    import (
    	"strings"
    )
    
    // ARN - SQS resource name representation.
    type ARN struct {
    	TargetID
    	region string
    }
    
    // String - returns string representation.
    func (arn ARN) String() string {
    	if arn.ID == "" && arn.Name == "" && arn.region == "" {
    		return ""
    	}
    
    	return "arn:minio:s3-object-lambda:" + arn.region + ":" + arn.TargetID.String()
    }
    
    // ParseARN - parses string to ARN.
    func ParseARN(s string) (*ARN, error) {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Mar 30 00:56:02 UTC 2025
    - 1.6K bytes
    - Viewed (0)
  10. internal/event/config_test.go

    	}{
    		{config1, "eu-west-1", []ARN{{TargetID{"1", "webhook"}, "eu-west-1"}}},
    		{config1, "", []ARN{{TargetID{"1", "webhook"}, ""}}},
    		{config2, "us-east-1", []ARN{{TargetID{"1", "webhook"}, "us-east-1"}}},
    		{config2, "", []ARN{{TargetID{"1", "webhook"}, ""}}},
    		{config3, "us-east-1", []ARN{{TargetID{"1", "webhook"}, "us-east-1"}, {TargetID{"2", "amqp"}, "us-east-1"}}},
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Wed Apr 09 14:28:39 UTC 2025
    - 28.9K bytes
    - Viewed (0)
Back to top