Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for nsqdAddress (0.07 sec)

  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,
    		}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 47K bytes
    - Viewed (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),
    		},
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Mar 19 04:37:54 UTC 2024
    - 13.1K bytes
    - Viewed (0)
  3. internal/config/notify/help.go

    			Key:         config.Comment,
    			Description: config.DefaultComment,
    			Optional:    true,
    			Type:        "sentence",
    		},
    	}
    
    	HelpNSQ = config.HelpKVS{
    		config.HelpKV{
    			Key:         target.NSQAddress,
    			Description: "NSQ server address e.g. '127.0.0.1:4150'",
    			Type:        "address",
    			Sensitive:   true,
    		},
    		config.HelpKV{
    			Key:         target.NSQTopic,
    			Description: "NSQ topic",
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 19.2K bytes
    - Viewed (0)
Back to top