Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 93 for Yarn (0.15 sec)

  1. 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 May 05 19:28:20 GMT 2024
    - Last Modified: Tue Jun 01 21:59:40 GMT 2021
    - 3.8K bytes
    - Viewed (0)
  2. logger/logger.go

    	if l.LogLevel >= Info {
    		l.Printf(l.infoStr+msg, append([]interface{}{utils.FileWithLineNum()}, data...)...)
    	}
    }
    
    // Warn print warn messages
    func (l *logger) Warn(ctx context.Context, msg string, data ...interface{}) {
    	if l.LogLevel >= Warn {
    		l.Printf(l.warnStr+msg, append([]interface{}{utils.FileWithLineNum()}, data...)...)
    	}
    }
    
    // Error print error messages
    Go
    - Registered: Sun May 05 09:35:13 GMT 2024
    - Last Modified: Tue Nov 07 02:19:41 GMT 2023
    - 5.8K bytes
    - Viewed (0)
  3. cmd/bucket-targets.go

    			}
    		}
    		sys.incTargetErr(bucket, arn)
    	}()
    	return nil
    }
    
    // GetRemoteBucketTargetByArn returns BucketTarget for a ARN
    func (sys *BucketTargetSys) GetRemoteBucketTargetByArn(ctx context.Context, bucket, arn string) madmin.BucketTarget {
    	sys.RLock()
    	defer sys.RUnlock()
    	var tgt madmin.BucketTarget
    	for _, t := range sys.targetsMap[bucket] {
    		if t.Arn == arn {
    			tgt = t.Clone()
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 01:09:56 GMT 2024
    - 20.9K bytes
    - Viewed (0)
  4. istioctl/pkg/multicluster/remote_secret.go

    			}
    			client, err := ctx.CLIClient()
    			if err != nil {
    				return err
    			}
    			out, warn, err := CreateRemoteSecret(client, opts)
    			if err != nil {
    				_, _ = fmt.Fprintf(c.OutOrStderr(), "error: %v\n", err)
    				return err
    			}
    			if warn != nil {
    				_, _ = fmt.Fprintf(c.OutOrStderr(), "warn: %v\n", warn)
    			}
    			_, _ = fmt.Fprint(c.OutOrStdout(), out)
    			return nil
    		},
    	}
    Go
    - Registered: Wed May 01 22:53:12 GMT 2024
    - Last Modified: Wed Oct 11 01:43:17 GMT 2023
    - 24K bytes
    - Viewed (0)
  5. internal/bucket/replication/destination.go

    }
    
    func (d Destination) String() string {
    	return d.ARN
    }
    
    // LegacyArn returns true if arn format has prefix "arn:aws:s3:::" which was
    // used prior to multi-destination
    func (d Destination) LegacyArn() bool {
    	return strings.HasPrefix(d.ARN, DestinationARNPrefix)
    }
    
    // TargetArn returns true if arn format has prefix  "arn:minio:replication:::"
    // used for multi-destination targets
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Sep 04 19:57:37 GMT 2023
    - 4K bytes
    - Viewed (2)
  6. internal/config/identity/openid/openid.go

    // authenticated via policy-claim based OpenID provider.
    var DummyRoleARN = func() arn.ARN {
    	v, err := arn.NewIAMRoleARN("dummy-internal", "")
    	if err != nil {
    		panic("should not happen!")
    	}
    	return v
    }()
    
    // Config - OpenID Config
    type Config struct {
    	Enabled bool
    
    	// map of roleARN to providerCfg's
    	arnProviderCfgsMap map[arn.ARN]*providerCfg
    
    	// map of config names to providerCfg's
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Nov 16 04:42:31 GMT 2023
    - 16.5K bytes
    - Viewed (0)
  7. internal/config/identity/openid/jwt.go

    	pk.RLock()
    	defer pk.RUnlock()
    	return pk.pkMap[kid]
    }
    
    // PopulatePublicKey - populates a new publickey from the JWKS URL.
    func (r *Config) PopulatePublicKey(arn arn.ARN) error {
    	pCfg := r.arnProviderCfgsMap[arn]
    	if pCfg.JWKS.URL == nil || pCfg.JWKS.URL.String() == "" {
    		return nil
    	}
    
    	// Add client secret for the client ID for HMAC based signature.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Nov 16 04:42:31 GMT 2023
    - 8.3K bytes
    - Viewed (5)
  8. internal/config/lambda/event/targetlist.go

    // Lookup - checks whether target by target ID exists is valid or not.
    func (list *TargetList) Lookup(arnStr string) (Target, error) {
    	list.RLock()
    	defer list.RUnlock()
    
    	arn, err := ParseARN(arnStr)
    	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
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Mar 07 16:12:41 GMT 2023
    - 4.3K bytes
    - Viewed (0)
  9. cmd/iam.go

    }
    
    // GetRolePolicy - returns policies associated with a role ARN.
    func (sys *IAMSys) GetRolePolicy(arnStr string) (arn.ARN, string, error) {
    	roleArn, err := arn.Parse(arnStr)
    	if err != nil {
    		return arn.ARN{}, "", fmt.Errorf("RoleARN parse err: %v", err)
    	}
    	rolePolicy, ok := sys.rolesMap[roleArn]
    	if !ok {
    		return arn.ARN{}, "", fmt.Errorf("RoleARN %s is not defined.", arnStr)
    	}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 25 21:28:16 GMT 2024
    - 71.1K bytes
    - Viewed (1)
  10. cmd/sts-handlers_test.go

    		// Built-in user should be imported without errors even if LDAP is
    		// enabled.
    		allUsersFile: `{
      "foo": {
        "secretKey": "foobar123",
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 25 15:50:16 GMT 2024
    - 85.7K bytes
    - Viewed (0)
Back to top