Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for queueLimit (0.1 sec)

  1. 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)
  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/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)
  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. cmd/config-versions.go

    type ConsoleLogger struct {
    	Enable bool `json:"enable"`
    }
    
    // serverConfigV33 is just like version '32', removes clientID from NATS and MQTT, and adds queueDir, queueLimit in all notification targets.
    type serverConfigV33 struct {
    	quick.Config `json:"-"` // ignore interfaces
    
    	Version string `json:"version"`
    
    	// S3 API configuration.
    	Credential auth.Credentials `json:"credential"`
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 2.5K bytes
    - Viewed (0)
Back to top