Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 11 - 20 of 52 for target_id (0.07 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  1. 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)
  2. 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},
    	}
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Jan 05 18:43:06 GMT 2024
    - 6.8K bytes
    - Click Count (0)
  3. 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)
  4. internal/event/rules_test.go

    	rulesCase2.Add(NewPattern("2010*", ""), TargetID{"1", "webhook"})
    
    	rulesCase3 := make(Rules)
    	rulesCase3.Add(NewPattern("", "*.jpg"), TargetID{"1", "webhook"})
    
    	testCases := []struct {
    		rules    Rules
    		prefix   string
    		targetID TargetID
    	}{
    		{rulesCase1, "2010*", TargetID{"1", "webhook"}},
    		{rulesCase2, "2000*", TargetID{"2", "amqp"}},
    		{rulesCase3, "2010*", TargetID{"1", "webhook"}},
    	}
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Tue Jun 01 21:59:40 GMT 2021
    - 8.8K bytes
    - Click Count (0)
  5. internal/event/arn_test.go

    	"reflect"
    	"testing"
    )
    
    func TestARNString(t *testing.T) {
    	testCases := []struct {
    		arn            ARN
    		expectedResult string
    	}{
    		{ARN{}, ""},
    		{ARN{TargetID{"1", "webhook"}, ""}, "arn:minio:sqs::1:webhook"},
    		{ARN{TargetID{"1", "webhook"}, "us-east-1"}, "arn:minio:sqs:us-east-1:1:webhook"},
    	}
    
    	for i, testCase := range testCases {
    		result := testCase.arn.String()
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Tue Jun 01 21:59:40 GMT 2021
    - 3.8K 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/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 error
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 4.3K bytes
    - Click Count (0)
  8. 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"}}},
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Wed Apr 09 14:28:39 GMT 2025
    - 28.9K bytes
    - Click Count (0)
  9. 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)
  10. 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)
Back to Top