Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 198 for arn1 (0.19 sec)

  1. cmd/bucket-replication-utils_test.go

    		name: "replication status for 3 targets - one failed",
    		rs: ReplicationState{
    			ReplicationStatusInternal: "arn1=COMPLETED;arn2=COMPLETED;arn3=FAILED;",
    			Targets:                   map[string]replication.StatusType{"arn1": "COMPLETED", "arn2": "COMPLETED", "arn3": "FAILED"},
    		},
    		expStatus: replication.Failed,
    	},
    	{ // 5. replication status for replica version
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Tue Aug 08 20:27:40 GMT 2023
    - 9.3K bytes
    - Viewed (0)
  2. cmd/bucket-replication_test.go

    				ReplicationStatusInternal: "arn1:PENDING;",
    				ReplicationStatus:         replication.Pending,
    				VersionID:                 "a3348c34-c352-4498-82f0-1098e8b34df9",
    			},
    			rcfg: replicationConfig{remotes: &madmin.BucketTargets{Targets: []madmin.BucketTarget{{
    				Arn: "arn1",
    			}}}},
    			dsc:          ReplicateDecision{targetsMap: map[string]replicateTargetDecision{"arn1": newReplicateTargetDecision("arn1", true, false)}},
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Sat Sep 16 09:28:06 GMT 2023
    - 12.2K bytes
    - Viewed (0)
  3. cmd/bucket-replication-utils.go

    func (rs *ReplicationState) targetState(arn string) (r replicatedTargetInfo) {
    	return replicatedTargetInfo{
    		Arn:                   arn,
    		PrevReplicationStatus: rs.Targets[arn],
    		VersionPurgeStatus:    rs.PurgeTargets[arn],
    		ResyncTimestamp:       rs.ResetStatusesMap[arn],
    	}
    }
    
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Jan 18 07:03:17 GMT 2024
    - 26.2K bytes
    - Viewed (0)
  4. internal/arn/arn.go

    func (arn ARN) String() string {
    	return strings.Join(
    		[]string{
    			arnPrefixArn,
    			arn.Partition,
    			arn.Service,
    			arn.Region,
    			"", // account-id is always empty in this implementation
    			arn.ResourceType + "/" + arn.ResourceID,
    		},
    		":",
    	)
    }
    
    // Parse - parses an ARN string into a type.
    func Parse(arnStr string) (arn ARN, err error) {
    	ps := strings.Split(arnStr, ":")
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Apr 04 08:31:34 GMT 2024
    - 3.5K bytes
    - Viewed (0)
  5. internal/event/arn.go

    import (
    	"encoding/xml"
    	"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:sqs:" + arn.region + ":" + arn.TargetID.String()
    }
    
    // MarshalXML - encodes to XML data.
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Tue Jun 01 21:59:40 GMT 2021
    - 2.1K bytes
    - Viewed (0)
  6. internal/config/lambda/event/arn.go

    package event
    
    import (
    	"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()
    }
    
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Tue Mar 07 16:12:41 GMT 2023
    - 1.6K bytes
    - Viewed (0)
  7. internal/arn/arn_test.go

    			},
    			wantArn: ARN{},
    			wantErr: true,
    		},
    		{
    			name: "invalid ARN partition must fail",
    			args: args{
    				arnStr: "arn:invalid:iam:us-east-1::role/my-role",
    			},
    			wantArn: ARN{},
    			wantErr: true,
    		},
    		{
    			name: "invalid ARN service must fail",
    			args: args{
    				arnStr: "arn:minio:invalid:us-east-1::role/my-role",
    			},
    			wantArn: ARN{},
    			wantErr: true,
    		},
    		{
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Apr 04 08:31:34 GMT 2024
    - 5.1K bytes
    - Viewed (0)
  8. internal/config/lambda/event/arn_test.go

    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()
    
    		if result != testCase.expectedResult {
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Tue Mar 07 16:12:41 GMT 2023
    - 2.2K bytes
    - Viewed (0)
  9. internal/event/arn_test.go

    		data        []byte
    		expectedARN *ARN
    		expectErr   bool
    	}{
    		{[]byte("<ARN></ARN>"), nil, true},
    		{[]byte("<ARN>arn:minio:sqs:::</ARN>"), nil, true},
    		{[]byte("<ARN>arn:minio:sqs::1:webhook</ARN>"), &ARN{TargetID{"1", "webhook"}, ""}, false},
    		{[]byte("<ARN>arn:minio:sqs:us-east-1:1:webhook</ARN>"), &ARN{TargetID{"1", "webhook"}, "us-east-1"}, false},
    	}
    
    	for i, testCase := range testCases {
    		arn := &ARN{}
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Tue Jun 01 21:59:40 GMT 2021
    - 3.8K bytes
    - Viewed (0)
  10. internal/bucket/replication/replication.go

    		if _, ok := tgtsMap[rule.Destination.ARN]; !ok {
    			tgtsMap[rule.Destination.ARN] = struct{}{}
    		}
    	}
    	for k := range tgtsMap {
    		arns = append(arns, k)
    	}
    	return arns
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Mar 28 17:44:56 GMT 2024
    - 8.9K bytes
    - Viewed (0)
Back to top