Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 8 of 8 for queue_limit (0.06 sec)

  1. internal/event/target/kafka.go

    	Enable             bool          `json:"enable"`
    	Brokers            []xnet.Host   `json:"brokers"`
    	Topic              string        `json:"topic"`
    	QueueDir           string        `json:"queueDir"`
    	QueueLimit         uint64        `json:"queueLimit"`
    	Version            string        `json:"version"`
    	BatchSize          uint32        `json:"batchSize"`
    	BatchCommitTimeout time.Duration `json:"batchCommitTimeout"`
    	TLS                struct {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 13.6K bytes
    - Viewed (0)
  2. internal/event/target/postgresql.go

    	Password           string    `json:"password"` // default: no password
    	Database           string    `json:"database"` // default: same as user
    	QueueDir           string    `json:"queueDir"`
    	QueueLimit         uint64    `json:"queueLimit"`
    	MaxOpenConnections int       `json:"maxOpenConnections"`
    }
    
    // Validate PostgreSQLArgs fields
    func (p PostgreSQLArgs) Validate() error {
    	if !p.Enable {
    		return nil
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 13.3K bytes
    - Viewed (0)
  3. internal/event/target/amqp.go

    	PublisherConfirms bool     `json:"publisherConfirms"`
    	QueueDir          string   `json:"queueDir"`
    	QueueLimit        uint64   `json:"queueLimit"`
    }
    
    //lint:file-ignore ST1003 We cannot change these exported names.
    
    // AMQP input constants.
    const (
    	AmqpQueueDir   = "queue_dir"
    	AmqpQueueLimit = "queue_limit"
    
    	AmqpURL               = "url"
    	AmqpExchange          = "exchange"
    	AmqpRoutingKey        = "routing_key"
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 10K bytes
    - Viewed (0)
  4. internal/event/target/mysql.go

    	User               string   `json:"user"`
    	Password           string   `json:"password"`
    	Database           string   `json:"database"`
    	QueueDir           string   `json:"queueDir"`
    	QueueLimit         uint64   `json:"queueLimit"`
    	MaxOpenConnections int      `json:"maxOpenConnections"`
    }
    
    // Validate MySQLArgs fields
    func (m MySQLArgs) Validate() error {
    	if !m.Enable {
    		return nil
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 11.6K bytes
    - Viewed (0)
  5. internal/event/target/nats.go

    	ClientCert      string    `json:"clientCert"`
    	ClientKey       string    `json:"clientKey"`
    	PingInterval    int64     `json:"pingInterval"`
    	QueueDir        string    `json:"queueDir"`
    	QueueLimit      uint64    `json:"queueLimit"`
    	JetStream       struct {
    		Enable bool `json:"enable"`
    	} `json:"jetStream"`
    	Streaming struct {
    		Enable             bool   `json:"enable"`
    		ClusterID          string `json:"clusterID"`
    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/elasticsearch.go

    	Format     string          `json:"format"`
    	URL        xnet.URL        `json:"url"`
    	Index      string          `json:"index"`
    	QueueDir   string          `json:"queueDir"`
    	QueueLimit uint64          `json:"queueLimit"`
    	Transport  *http.Transport `json:"-"`
    	Username   string          `json:"username"`
    	Password   string          `json:"password"`
    }
    
    // Validate ElasticsearchArgs fields
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 15K bytes
    - Viewed (0)
  7. internal/config/notify/parse.go

    			Enable:             enabled,
    			Brokers:            brokers,
    			Topic:              env.Get(topicEnv, kv.Get(target.KafkaTopic)),
    			QueueDir:           env.Get(queueDirEnv, kv.Get(target.KafkaQueueDir)),
    			QueueLimit:         queueLimit,
    			Version:            env.Get(versionEnv, kv.Get(target.KafkaVersion)),
    			BatchSize:          uint32(batchSize),
    			BatchCommitTimeout: batchCommitTimeout,
    		}
    
    		tlsEnableEnv := target.EnvKafkaTLS
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 47K bytes
    - Viewed (0)
  8. internal/config/notify/legacy.go

    			Value: cfg.TLS.ClientTLSCert,
    		},
    		config.KV{
    			Key:   target.KafkaClientTLSKey,
    			Value: cfg.TLS.ClientTLSKey,
    		},
    		config.KV{
    			Key:   target.KafkaQueueLimit,
    			Value: strconv.Itoa(int(cfg.QueueLimit)),
    		},
    		config.KV{
    			Key:   target.KafkaTLS,
    			Value: config.FormatBool(cfg.TLS.Enable),
    		},
    		config.KV{
    			Key:   target.KafkaTLSSkipVerify,
    			Value: config.FormatBool(cfg.TLS.SkipVerify),
    		},
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Mar 19 04:37:54 UTC 2024
    - 13.1K bytes
    - Viewed (0)
Back to top