Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 2 of 2 for nsqdAddress (0.04 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

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