Search Options

Display Count
Sort
Preferred Language
Advanced Search

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.

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to Top