- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 1,589 for targetID (0.06 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)