Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for SetNotifyNATS (0.11 sec)

  1. 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)
  2. 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)
Back to top