Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 63 for target_id (0.04 sec)

  1. 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)
  2. 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)
  3. 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.
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Mar 30 00:56:02 UTC 2025
    - 7.1K bytes
    - Viewed (0)
  4. cmd/event-notification.go

    		return arns
    	}
    	region := globalSite.Region()
    	for targetID := range evnot.targetList.TargetMap() {
    		// httpclient target is part of ListenNotification
    		// which doesn't need to be listed as part of the ARN list
    		// This list is only meant for external targets, filter
    		// this out pro-actively.
    		if !strings.HasPrefix(targetID.ID, "httpclient+") {
    			arns = append(arns, targetID.ToARN(region).String())
    		}
    	}
    
    	return arns
    }
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Jun 21 22:22:24 UTC 2024
    - 7.7K bytes
    - Viewed (0)
  5. 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.
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Thu Aug 21 04:25:07 UTC 2025
    - 10K bytes
    - Viewed (0)
  6. 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());
            }
    Registered: Sat Dec 20 09:19:18 UTC 2025
    - Last Modified: Fri Nov 28 16:29:12 UTC 2025
    - 10.5K bytes
    - Viewed (0)
  7. internal/config/lambda/target/webhook.go

    	totalRequests  int64
    	failedRequests int64
    
    	lazyInit lazyInit
    
    	id         event.TargetID
    	args       WebhookArgs
    	transport  *http.Transport
    	httpClient *http.Client
    	loggerOnce logger.LogOnce
    	cancel     context.CancelFunc
    	cancelCh   <-chan struct{}
    }
    
    // ID - returns target ID.
    func (target *WebhookTarget) ID() event.TargetID {
    	return target.id
    }
    
    // IsActive - Return true if target is up and active
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Mon Jul 08 21:39:49 UTC 2024
    - 6.7K bytes
    - Viewed (0)
  8. internal/event/config.go

    	if q.ARN.region == "" {
    		if !targetList.Exists(q.ARN.TargetID) {
    			return &ErrARNNotFound{q.ARN}
    		}
    		return nil
    	}
    
    	if region != "" && q.ARN.region != region {
    		return &ErrUnknownRegion{q.ARN.region}
    	}
    
    	if !targetList.Exists(q.ARN.TargetID) {
    		return &ErrARNNotFound{q.ARN}
    	}
    
    	return nil
    }
    
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 8.4K bytes
    - Viewed (0)
  9. internal/event/target/mqtt.go

    // MQTTTarget - MQTT target.
    type MQTTTarget struct {
    	initOnce once.Init
    
    	id         event.TargetID
    	args       MQTTArgs
    	client     mqtt.Client
    	store      store.Store[event.Event]
    	quitCh     chan struct{}
    	loggerOnce logger.LogOnce
    }
    
    // ID - returns target ID.
    func (target *MQTTTarget) ID() event.TargetID {
    	return target.id
    }
    
    // Name - returns the Name of the target.
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 8.2K bytes
    - Viewed (0)
  10. src/main/java/org/codelibs/fess/job/GenerateThumbnailJob.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());
            }
    Registered: Sat Dec 20 09:19:18 UTC 2025
    - Last Modified: Fri Nov 28 16:29:12 UTC 2025
    - 11.7K bytes
    - Viewed (0)
Back to top