Search Options

Results per page
Sort
Preferred Languages
Advance

Results 31 - 40 of 214 for target01 (0.15 sec)

  1. internal/event/targetlist.go

    	list.Lock()
    	defer list.Unlock()
    
    	for _, target := range targets {
    		if _, ok := list.targets[target.ID()]; ok {
    			return fmt.Errorf("target %v already exists", target.ID())
    		}
    		list.targets[target.ID()] = target
    	}
    
    	return nil
    }
    
    // Exists - checks whether target by target ID exists or not.
    func (list *TargetList) Exists(id TargetID) bool {
    	list.RLock()
    	defer list.RUnlock()
    
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 9.2K bytes
    - Viewed (0)
  2. internal/config/lambda/event/targetlist.go

    		target, ok := list.targets[id]
    		if ok {
    			target.Close()
    			delete(list.targets, id)
    		}
    	}
    }
    
    // Targets - list all targets
    func (list *TargetList) Targets() []Target {
    	if list == nil {
    		return []Target{}
    	}
    
    	list.RLock()
    	defer list.RUnlock()
    
    	targets := make([]Target, 0, len(list.targets))
    	for _, tgt := range list.targets {
    		targets = append(targets, tgt)
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Tue Mar 07 16:12:41 UTC 2023
    - 4.3K bytes
    - Viewed (0)
  3. internal/config/lambda/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.TargetID.ID == "" && arn.TargetID.Name == "" && arn.region == "" {
    		return ""
    	}
    
    	return "arn:minio:s3-object-lambda:" + arn.region + ":" + arn.TargetID.String()
    }
    
    // ParseARN - parses string to ARN.
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Tue Mar 07 16:12:41 UTC 2023
    - 1.6K bytes
    - Viewed (0)
  4. internal/event/rulesmap.go

    package event
    
    // RulesMap - map of rules for every event name.
    type RulesMap map[Name]Rules
    
    // add - adds event names, prefixes, suffixes and target ID to rules map.
    func (rulesMap RulesMap) add(eventNames []Name, pattern string, targetID TargetID) {
    	rules := make(Rules)
    	rules.Add(pattern, targetID)
    
    	for _, eventName := range eventNames {
    		for _, name := range eventName.Expand() {
    			rulesMap[name] = rulesMap[name].Union(rules)
    		}
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Tue Jun 01 21:59:40 UTC 2021
    - 2.6K bytes
    - Viewed (0)
  5. 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,
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri May 10 14:50:39 UTC 2024
    - 1.9K bytes
    - Viewed (0)
  6. 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()
    
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Tue Jun 01 21:59:40 UTC 2021
    - 3.8K bytes
    - Viewed (0)
  7. platforms/native/platform-native/src/main/java/org/gradle/nativeplatform/platform/NativePlatform.java

         */
        void architecture(String name);
    
        /**
         * The operating system being targeted.
         * Defaults to the default operating system targeted by the tool chain (normally the current operating system).
         */
        @Nested
        OperatingSystem getOperatingSystem();
    
        /**
         * Sets the operating system being targeted.
         * <p>
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Thu Nov 16 20:20:03 UTC 2023
    - 2.3K bytes
    - Viewed (0)
  8. 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 Jun 16 00:44:34 UTC 2024
    - Last Modified: Tue Mar 07 16:12:41 UTC 2023
    - 2.2K bytes
    - Viewed (0)
  9. 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 Jun 16 00:44:34 UTC 2024
    - Last Modified: Tue Dec 05 10:16:33 UTC 2023
    - 29K bytes
    - Viewed (0)
  10. releasenotes/notes/se-target-port.yaml

    dwq <******@****.***> 1711400865 +0800
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon Mar 25 21:07:45 UTC 2024
    - 233 bytes
    - Viewed (0)
Back to top