- Sort Score
- Num 10 results
- Language All
Results 1 - 2 of 2 for nsqdAddress (0.04 seconds)
The search processing time has exceeded the limit. The displayed results may be partial.
-
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, }Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 47.5K bytes - Click Count (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), },Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Apr 27 04:30:57 GMT 2025 - 13.3K bytes - Click Count (0)