Search Options

Results per page
Sort
Preferred Languages
Advance

Results 51 - 60 of 425 for arns (0.03 sec)

  1. cmd/batch-handlers_test.go

    )
    
    func TestBatchJobPrefix_UnmarshalYAML(t *testing.T) {
    	type args struct {
    		yamlStr string
    	}
    	type PrefixTemp struct {
    		Prefix BatchJobPrefix `yaml:"prefix"`
    	}
    	tests := []struct {
    		name    string
    		b       PrefixTemp
    		args    args
    		want    []string
    		wantErr bool
    	}{
    		{
    			name: "test1",
    			b:    PrefixTemp{},
    			args: args{
    				yamlStr: `
    prefix: "foo"
    `,
    			},
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 01 12:53:30 UTC 2024
    - 1.7K bytes
    - Viewed (0)
  2. internal/config/policy/plugin/config.go

    	}
    	if err = args.Validate(); err != nil {
    		return args, err
    	}
    	return args, nil
    }
    
    // New - initializes Authorization Management Plugin.
    func New(args Args) *AuthZPlugin {
    	if args.URL == nil || args.URL.Scheme == "" && args.AuthToken == "" {
    		return nil
    	}
    	return &AuthZPlugin{
    		args:   args,
    		client: &http.Client{Transport: args.Transport},
    	}
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 5.8K bytes
    - Viewed (0)
  3. cmd/bucket-policy.go

    	policy, _, err := globalBucketMetadataSys.GetPolicyConfig(bucket)
    	return policy, err
    }
    
    // IsAllowed - checks given policy args is allowed to continue the Rest API.
    func (sys *PolicySys) IsAllowed(args policy.BucketPolicyArgs) bool {
    	p, err := sys.Get(args.BucketName)
    	if err == nil {
    		return p.IsAllowed(args)
    	}
    
    	// Log unhandled errors.
    	if _, ok := err.(BucketPolicyNotFound); !ok {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 8K bytes
    - Viewed (0)
  4. internal/logger/legacy.go

    func SetLoggerHTTPAudit(scfg config.Config, k string, args http.Config) {
    	if !args.Enabled {
    		// Do not enable audit targets, if not enabled
    		return
    	}
    	scfg[config.AuditWebhookSubSys][k] = config.KVS{
    		config.KV{
    			Key:   config.Enable,
    			Value: config.EnableOn,
    		},
    		config.KV{
    			Key:   Endpoint,
    			Value: args.Endpoint.String(),
    		},
    		config.KV{
    			Key:   AuthToken,
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 03 09:47:07 UTC 2023
    - 2K bytes
    - Viewed (0)
  5. internal/event/target/nats.go

    	}
    
    	if target.stanConn != nil {
    		if target.args.Streaming.Async {
    			_, err = target.stanConn.PublishAsync(target.args.Subject, data, nil)
    		} else {
    			err = target.stanConn.Publish(target.args.Subject, data)
    		}
    	} else {
    		if target.jstream != nil {
    			_, err = target.jstream.Publish(target.args.Subject, data)
    		} else {
    			err = target.natsConn.Publish(target.args.Subject, data)
    		}
    	}
    	return err
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 12.9K bytes
    - Viewed (0)
  6. internal/event/target/nsq.go

    }
    
    func (target *NSQTarget) initNSQ() error {
    	args := target.args
    
    	config := nsq.NewConfig()
    	if args.TLS.Enable {
    		config.TlsV1 = true
    		config.TlsConfig = &tls.Config{
    			InsecureSkipVerify: args.TLS.SkipVerify,
    		}
    	}
    	target.config = config
    
    	producer, err := nsq.NewProducer(args.NSQDAddress.String(), config)
    	if err != nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 7.1K bytes
    - Viewed (0)
  7. android/guava/src/com/google/common/reflect/AbstractInvocationHandler.java

          throws Throwable {
        if (args == null) {
          args = NO_ARGS;
        }
        if (args.length == 0 && method.getName().equals("hashCode")) {
          return hashCode();
        }
        if (args.length == 1
            && method.getName().equals("equals")
            && method.getParameterTypes()[0] == Object.class) {
          Object arg = args[0];
          if (arg == null) {
            return false;
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Jan 05 17:43:40 UTC 2022
    - 5.2K bytes
    - Viewed (0)
  8. impl/maven-cli/src/main/java/org/apache/maven/cling/invoker/mvn/BaseMavenParser.java

        }
    
        protected O parseMavenCliOptions(List<String> args) throws ParserException {
            return parseArgs(Options.SOURCE_CLI, args);
        }
    
        protected O parseMavenConfigOptions(Path configFile) throws ParserException, IOException {
            try (Stream<String> lines = Files.lines(configFile, Charset.defaultCharset())) {
                List<String> args =
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 2.9K bytes
    - Viewed (0)
  9. internal/event/target/mqtt.go

    // NewMQTTTarget - creates new MQTT target.
    func NewMQTTTarget(id string, args MQTTArgs, loggerOnce logger.LogOnce) (*MQTTTarget, error) {
    	if args.MaxReconnectInterval == 0 {
    		// Default interval
    		// https://github.com/eclipse/paho.mqtt.golang/blob/master/options.go#L115
    		args.MaxReconnectInterval = 10 * time.Minute
    	}
    
    	if args.KeepAlive == 0 {
    		args.KeepAlive = 10 * time.Second
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 8.2K bytes
    - Viewed (0)
  10. tests/connpool_test.go

    func (c *wrapperTx) ExecContext(ctx context.Context, query string, args ...interface{}) (sql.Result, error) {
    	c.conn.got = append(c.conn.got, query)
    	return c.Tx.ExecContext(ctx, query, args...)
    }
    
    func (c *wrapperTx) QueryContext(ctx context.Context, query string, args ...interface{}) (*sql.Rows, error) {
    	c.conn.got = append(c.conn.got, query)
    	return c.Tx.QueryContext(ctx, query, args...)
    }
    
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Tue Feb 06 02:54:40 UTC 2024
    - 5.5K bytes
    - Viewed (0)
Back to top