connections

package

v0.0.6 Latest Latest Go to latest Published: Apr 8, 2022 License: BSD-3-Clause Imports: 6 Imported by: 1

Details

View Source

const AddrStep = ","

This section is empty.

This section is empty.

type Mem struct {
	// contains filtered or unexported fields
}

Mem, in-memory queue, only works on single machine

func NewMem() *Mem

func (m *Mem) Consume(concurrency int, exit chan struct{}) error

func (m *Mem) Dispatch(payload interface{}, delay ...time.Duration) error

func (m *Mem) Stop() error

type Nsq struct {
	// contains filtered or unexported fields
}

func NewNsq(config map[string]interface{}) *Nsq

func NewNsqFromConfig(conf NsqConfig) *Nsq

func (n *Nsq) Consume(concurrency int, exit chan struct{}) (err error)

func (n *Nsq) Dispatch(payload interface{}, delay ...time.Duration) (err error)

func (n *Nsq) SetHandler(h nsq.Handler) *Nsq

func (n *Nsq) Stop() error

type NsqConfig struct {
	Lookupd, Nsqd, Topic, Channel string
	UsingLookup                   bool
	// contains filtered or unexported fields
}