nsq_cli

package
v0.0.5 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Mar 19, 2021 License: MIT Imports: 12 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var Name = "nsq"

Functions

func Get

func Get(names ...string) *nsqClient

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    jsonx.Duration `json:"dial_timeout"`
	ReadTimeout    jsonx.Duration `json:"read_timeout"`
	WriteTimeout   jsonx.Duration `json:"write_timeout"`
	DrainTimeout   jsonx.Duration `json:"drain_timeout"`
}

func GetDefaultCfg

func GetDefaultCfg() Cfg

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL