- Sort Score
- Result 10 results
- Languages All
Results 1 - 2 of 2 for SetNotifyNATS (0.04 sec)
-
internal/config/notify/legacy.go
Value: cfg.QueueDir, }, config.KV{ Key: target.NSQQueueLimit, Value: strconv.Itoa(int(cfg.QueueLimit)), }, } return nil } // SetNotifyNATS - helper for config migration from older config. func SetNotifyNATS(s config.Config, natsName string, cfg target.NATSArgs) error { if !cfg.Enable { return nil } if err := cfg.Validate(); err != nil { return err }Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Sun Apr 27 04:30:57 UTC 2025 - 13.3K bytes - Viewed (0) -
cmd/config-migrate.go
notify.SetNotifyMQTT(newCfg, k, args) } for k, args := range cfg.Notify.MySQL { notify.SetNotifyMySQL(newCfg, k, args) } for k, args := range cfg.Notify.NATS { notify.SetNotifyNATS(newCfg, k, args) } for k, args := range cfg.Notify.NSQ { notify.SetNotifyNSQ(newCfg, k, args) } for k, args := range cfg.Notify.PostgreSQL { notify.SetNotifyPostgres(newCfg, k, args) }
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 5.4K bytes - Viewed (0)