- Sort Score
- Num 10 results
- Language All
Results 1 - 10 of 50 for target_id (0.06 seconds)
-
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,
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri May 10 14:50:39 GMT 2024 - 1.9K bytes - Click Count (0) -
cmd/metrics-v2.go
Name: "target_total_events", Help: "Total number of events sent (or) queued to the target", Type: counterMetric, }, VariableLabels: map[string]string{"target_id": id.ID, "target_name": id.Name}, Value: float64(st.TotalEvents), }) metrics = append(metrics, MetricV2{ Description: MetricDescription{ Namespace: minioNamespace,
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 133.6K bytes - Click Count (0) -
internal/event/targetlist_test.go
{targetListCase2, &ExampleTarget{TargetID{"1", "webhook"}, false, false}, []TargetID{{"2", "testcase"}, {"1", "webhook"}}, false}, {targetListCase3, &ExampleTarget{TargetID{"3", "testcase"}, false, false}, nil, true}, } for i, testCase := range testCases { err := testCase.targetList.Add(testCase.target) expectErr := (err != nil)Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Wed Apr 09 14:28:39 GMT 2025 - 6K bytes - Click Count (0) -
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
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 1.9K bytes - Click Count (0) -
internal/event/targetidset.go
if _, ok := sset[k]; !ok { 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
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 1.8K bytes - Click Count (0) -
internal/event/rules.go
// Match - returns TargetIDSet matching object name in rules. func (rules Rules) Match(objectName string) TargetIDSet { targetIDs := NewTargetIDSet() for pattern, targetIDSet := range rules { if wildcard.MatchSimple(pattern, objectName) { targetIDs = targetIDs.Union(targetIDSet) } } return targetIDs } // Clone - returns copy of this rules. func (rules Rules) Clone() Rules { rulesCopy := make(Rules)
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri May 24 23:05:23 GMT 2024 - 2.7K bytes - Click Count (0) -
internal/event/targetlist.go
func (list *TargetList) Exists(id TargetID) bool { list.RLock() defer list.RUnlock() _, found := list.targets[id] return found } // TargetIDResult returns result of Remove/Send operation, sets err if // any for the associated TargetID type TargetIDResult struct { // ID where the remove or send were initiated. ID TargetID
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 9.2K bytes - Click Count (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.
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Mar 30 00:56:02 GMT 2025 - 2K bytes - Click Count (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) {
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Mar 30 00:56:02 GMT 2025 - 1.6K bytes - Click Count (0) -
internal/config/lambda/event/targetlist.go
if err != nil { return nil, err } id, found := list.targets[arn.TargetID] if !found { return nil, &ErrARNNotFound{} } return id, nil } // TargetIDResult returns result of Remove/Send operation, sets err if // any for the associated TargetID type TargetIDResult struct { // ID where the remove or send were initiated. ID TargetID // Stores any error while removing a target or while sending an event. Err errorCreated: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 4.3K bytes - Click Count (0)