Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 15 for queue_limit (0.12 sec)

  1. docs/bucket/notifications/README.md

    To update the configuration, use `mc admin config get` command to get the current configuration.
    
    ```sh
    $ mc admin config get myminio/ notify_mqtt
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Jan 18 07:03:17 UTC 2024
    - 84K bytes
    - Viewed (0)
  2. internal/event/target/webhook.go

    	Endpoint   xnet.URL        `json:"endpoint"`
    	AuthToken  string          `json:"authToken"`
    	Transport  *http.Transport `json:"-"`
    	QueueDir   string          `json:"queueDir"`
    	QueueLimit uint64          `json:"queueLimit"`
    	ClientCert string          `json:"clientCert"`
    	ClientKey  string          `json:"clientKey"`
    }
    
    // Validate WebhookArgs fields
    func (w WebhookArgs) Validate() error {
    	if !w.Enable {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 8.8K bytes
    - Viewed (0)
  3. internal/event/target/nsq.go

    	Topic       string    `json:"topic"`
    	TLS         struct {
    		Enable     bool `json:"enable"`
    		SkipVerify bool `json:"skipVerify"`
    	} `json:"tls"`
    	QueueDir   string `json:"queueDir"`
    	QueueLimit uint64 `json:"queueLimit"`
    }
    
    // Validate NSQArgs fields
    func (n NSQArgs) Validate() error {
    	if !n.Enable {
    		return nil
    	}
    
    	if n.NSQDAddress.IsEmpty() {
    		return errors.New("empty nsqdAddress")
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 7.1K bytes
    - Viewed (0)
  4. internal/event/target/mqtt.go

    	KeepAlive            time.Duration  `json:"keepAliveInterval"`
    	RootCAs              *x509.CertPool `json:"-"`
    	QueueDir             string         `json:"queueDir"`
    	QueueLimit           uint64         `json:"queueLimit"`
    }
    
    // Validate MQTTArgs fields
    func (m MQTTArgs) Validate() error {
    	if !m.Enable {
    		return nil
    	}
    	u, err := xnet.ParseURL(m.Broker.String())
    	if err != nil {
    		return err
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 8.2K bytes
    - Viewed (0)
  5. 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)
  6. internal/event/target/redis.go

    	Addr       xnet.Host `json:"address"`
    	Password   string    `json:"password"`
    	User       string    `json:"user"`
    	Key        string    `json:"key"`
    	QueueDir   string    `json:"queueDir"`
    	QueueLimit uint64    `json:"queueLimit"`
    }
    
    // RedisAccessEvent holds event log data and timestamp
    type RedisAccessEvent struct {
    	Event     []event.Event
    	EventTime string
    }
    
    // Validate RedisArgs fields
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 9.1K bytes
    - Viewed (0)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top