Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var AddrFlag = &cli.StringSliceFlag{ Name: "nsq-addr", EnvVars: []string{"NSQ_ADDR"}, Usage: "nsq address", }
AddrFlag - NSQ address command line flag.
View Source
var ChannelFlag = &cli.StringFlag{ Name: "nsq-channel", EnvVars: []string{"NSQ_CHANNEL"}, Usage: "nsq channel", Value: "consumer", }
ChannelFlag - NSQ channel command line flag.
View Source
var LookupAddrFlag = &cli.StringSliceFlag{ Name: "nsqlookup-addr", EnvVars: []string{"NSQLOOKUP_ADDR"}, Usage: "nsqlookup address", }
LookupAddrFlag - NSQ lookup address command line flag.
View Source
var TopicFlag = &cli.StringSliceFlag{ Name: "nsq-topic", EnvVars: []string{"NSQ_TOPIC"}, Usage: "nsq topic", }
TopicFlag - NSQ topic command line flag.
Functions ¶
func Connect ¶
func Connect(c *cli.Context) (err error)
Connect - Connects to NSQ from nsq-addr and nsqlookup-addr flags.
func RequireAll ¶
func RequireAll(c *cli.Context) error
RequireAll - Checks for all flags and reports errors if some are missing.
Types ¶
This section is empty.
Click to show internal directories.
Click to hide internal directories.