- Sort Score
- Result 10 results
- Languages All
Results 1 - 2 of 2 for SetNotifyNATS (0.11 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 Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Mar 19 04:37:54 UTC 2024 - 13.1K 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 Nov 03 19:28:11 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 5.4K bytes - Viewed (0)