Search Options

Results per page
Sort
Preferred Languages
Advance

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

  1. internal/event/target/nsq.go

    	EnvNSQQueueLimit    = "MINIO_NOTIFY_NSQ_QUEUE_LIMIT"
    )
    
    // NSQArgs - NSQ target arguments.
    type NSQArgs struct {
    	Enable      bool      `json:"enable"`
    	NSQDAddress xnet.Host `json:"nsqdAddress"`
    	Topic       string    `json:"topic"`
    	TLS         struct {
    		Enable     bool `json:"enable"`
    		SkipVerify bool `json:"skipVerify"`
    	} `json:"tls"`
    	QueueDir   string `json:"queueDir"`
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 7.1K bytes
    - Viewed (0)
  2. 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)
  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