Home
last modified time | relevance | path

Searched refs:ConnectToNSQDs (Results 1 – 5 of 5) sorted by relevance

/dports/net/nsq/nsq-1.2.1/apps/nsq_tail/
H A Dnsq_tail.go119 err = consumer.ConnectToNSQDs(nsqdTCPAddrs)
/dports/net/nsq/nsq-1.2.1/apps/nsq_to_http/
H A Dnsq_to_http.go284 err = consumer.ConnectToNSQDs(nsqdTCPAddrs)
/dports/net/nsq/nsq-1.2.1/apps/nsq_to_nsq/
H A Dnsq_to_nsq.go387 err := consumer.ConnectToNSQDs(nsqdTCPAddrs)
/dports/net/nsq/nsq-1.2.1/apps/nsq_to_file/
H A Dfile_logger.go63 err = consumer.ConnectToNSQDs(opts.NSQDTCPAddrs)
/dports/net/nsq/nsq-1.2.1/vendor/github.com/nsqio/go-nsq/
H A Dconsumer.go507 func (r *Consumer) ConnectToNSQDs(addresses []string) error { func