- Sort Score
- Num 10 results
- Language All
Results 1 - 10 of 29 for target_id (0.06 seconds)
The search processing time has exceeded the limit. The displayed results may be partial.
-
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/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/event/target/nsq.go
// NSQTarget - NSQ target. type NSQTarget struct { initOnce once.Init id event.TargetID args NSQArgs producer *nsq.Producer store store.Store[event.Event] config *nsq.Config loggerOnce logger.LogOnce quitCh chan struct{} } // ID - returns target ID. func (target *NSQTarget) ID() event.TargetID { return target.id } // Name - returns the Name of the target.Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Mar 30 00:56:02 GMT 2025 - 7.1K bytes - Click Count (0) -
internal/event/target/amqp.go
type AMQPTarget struct { initOnce once.Init id event.TargetID args AMQPArgs conn *amqp091.Connection connMutex sync.Mutex store store.Store[event.Event] loggerOnce logger.LogOnce quitCh chan struct{} } // ID - returns TargetID. func (target *AMQPTarget) ID() event.TargetID { return target.id } // Name - returns the Name of the target.Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Thu Aug 21 04:25:07 GMT 2025 - 10K bytes - Click Count (0) -
internal/event/target/redis.go
type RedisTarget struct { initOnce once.Init id event.TargetID args RedisArgs pool *redis.Pool store store.Store[event.Event] firstPing bool loggerOnce logger.LogOnce quitCh chan struct{} } // ID - returns target ID. func (target *RedisTarget) ID() event.TargetID { return target.id } // Name - returns the Name of the target.Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Mar 30 00:56:02 GMT 2025 - 9.1K bytes - Click Count (0) -
src/main/java/org/codelibs/fess/job/SuggestJob.java
buf.append(File.separator); buf.append("classes"); // target/classes final String userDir = System.getProperty("user.dir"); final File targetDir = new File(userDir, "target"); final File targetClassesDir = new File(targetDir, "classes"); if (targetClassesDir.isDirectory()) { buf.append(cpSeparator); buf.append(targetClassesDir.getAbsolutePath()); }
Created: Sat Dec 20 09:19:18 GMT 2025 - Last Modified: Fri Nov 28 16:29:12 GMT 2025 - 10.5K bytes - Click Count (0)