Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 1,712 for targetID (0.05 sec)

  1. internal/event/rules_test.go

    	rulesCase2.Add(NewPattern("2010*", ""), TargetID{"1", "webhook"})
    
    	rulesCase3 := make(Rules)
    	rulesCase3.Add(NewPattern("", "*.jpg"), TargetID{"1", "webhook"})
    
    	testCases := []struct {
    		rules    Rules
    		prefix   string
    		targetID TargetID
    	}{
    		{rulesCase1, "2010*", TargetID{"1", "webhook"}},
    		{rulesCase2, "2000*", TargetID{"2", "amqp"}},
    		{rulesCase3, "2010*", TargetID{"1", "webhook"}},
    	}
    
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Tue Jun 01 21:59:40 UTC 2021
    - 8.8K bytes
    - Viewed (0)
  2. 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)
  3. 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)
  4. internal/event/rulesmap.go

    package event
    
    // RulesMap - map of rules for every event name.
    type RulesMap map[Name]Rules
    
    // add - adds event names, prefixes, suffixes and target ID to rules map.
    func (rulesMap RulesMap) add(eventNames []Name, pattern string, targetID TargetID) {
    	rules := make(Rules)
    	rules.Add(pattern, targetID)
    
    	for _, eventName := range eventNames {
    		for _, name := range eventName.Expand() {
    			rulesMap[name] = rulesMap[name].Union(rules)
    		}
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Tue Jun 01 21:59:40 UTC 2021
    - 2.6K bytes
    - Viewed (0)
  5. internal/event/arn_test.go

    	"reflect"
    	"testing"
    )
    
    func TestARNString(t *testing.T) {
    	testCases := []struct {
    		arn            ARN
    		expectedResult string
    	}{
    		{ARN{}, ""},
    		{ARN{TargetID{"1", "webhook"}, ""}, "arn:minio:sqs::1:webhook"},
    		{ARN{TargetID{"1", "webhook"}, "us-east-1"}, "arn:minio:sqs:us-east-1:1:webhook"},
    	}
    
    	for i, testCase := range testCases {
    		result := testCase.arn.String()
    
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Tue Jun 01 21:59:40 UTC 2021
    - 3.8K bytes
    - Viewed (0)
  6. 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)
  7. 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)
  8. 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)
  9. internal/config/lambda/event/arn_test.go

    import (
    	"testing"
    )
    
    func TestARNString(t *testing.T) {
    	testCases := []struct {
    		arn            ARN
    		expectedResult string
    	}{
    		{ARN{}, ""},
    		{ARN{TargetID{"1", "webhook"}, ""}, "arn:minio:s3-object-lambda::1:webhook"},
    		{ARN{TargetID{"1", "webhook"}, "us-east-1"}, "arn:minio:s3-object-lambda:us-east-1:1:webhook"},
    	}
    
    	for i, testCase := range testCases {
    		result := testCase.arn.String()
    
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Tue Mar 07 16:12:41 UTC 2023
    - 2.2K 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