nsqc

Documentation

Index

• Variables
• func Get(names ...string) *nsqClient
• func Update(name string, cfg Cfg) error
• type Cfg
  • func GetDefaultCfg() Cfg
  • func (t Cfg) Build() (c *nsqClient, err error)

Variables

var Name = "nsq"

Functions

func Get

func Get(names ...string) *nsqClient

func Update

func Update(name string, cfg Cfg) error

Types

type Cfg

type Cfg struct {
	Name           string        `json:"name"`
	Topic          string        `json:"topic"`
	Channel        string        `json:"channel"`
	Address        string        `json:"address"`
	Lookup         []string      `json:"lookup"`
	MaxInFlight    int           `json:"max_in_flight"`
	MaxConcurrency int           `json:"max_concurrency"`
	DialTimeout    time.Duration `json:"dial_timeout"`
	ReadTimeout    time.Duration `json:"read_timeout"`
	WriteTimeout   time.Duration `json:"write_timeout"`
	DrainTimeout   time.Duration `json:"drain_timeout"`
}

func GetDefaultCfg

func GetDefaultCfg() Cfg

func (Cfg) Build

func (t Cfg) Build() (c *nsqClient, err error)