- Sort Score
- Result 10 results
- Languages All
Results 1 - 4 of 4 for nsqd_address (0.05 sec)
-
internal/event/target/nsq.go
EnvNSQQueueLimit = "MINIO_NOTIFY_NSQ_QUEUE_LIMIT" ) // NSQArgs - NSQ target arguments. type NSQArgs struct { Enable bool `json:"enable"` NSQDAddress xnet.Host `json:"nsqdAddress"` Topic string `json:"topic"` TLS struct { Enable bool `json:"enable"` SkipVerify bool `json:"skipVerify"` } `json:"tls"` QueueDir string `json:"queueDir"`
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Sun Mar 30 00:56:02 UTC 2025 - 7.1K bytes - Viewed (0) -
docs/bucket/notifications/README.md
To update the configuration, use `mc admin config get` command to get the current configuration for `notify_nsq`. ``` KEY: notify_nsq[:name] publish bucket notifications to NSQ endpoints ARGS: nsqd_address* (address) NSQ server address e.g. '127.0.0.1:4150' topic* (string) NSQ topic tls (on|off) set to 'on' to enable TLS
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Tue Aug 12 18:20:36 UTC 2025 - 84.2K bytes - Viewed (0) -
internal/config/notify/legacy.go
return err } s[config.NotifyNSQSubSys][nsqName] = config.KVS{ config.KV{ Key: config.Enable, Value: config.EnableOn, }, config.KV{ Key: target.NSQAddress, Value: cfg.NSQDAddress.String(), }, config.KV{ Key: target.NSQTopic, Value: cfg.Topic, }, config.KV{ Key: target.NSQTLS, Value: config.FormatBool(cfg.TLS.Enable), },Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Sun Apr 27 04:30:57 UTC 2025 - 13.3K bytes - Viewed (0) -
internal/config/notify/parse.go
} queueDirEnv := target.EnvNSQQueueDir if k != config.Default { queueDirEnv = queueDirEnv + config.Default + k } nsqArgs := target.NSQArgs{ Enable: enabled, NSQDAddress: *nsqdAddress, Topic: env.Get(topicEnv, kv.Get(target.NSQTopic)), QueueDir: env.Get(queueDirEnv, kv.Get(target.NSQQueueDir)), QueueLimit: queueLimit, }Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 47.5K bytes - Viewed (0)