connections

Documentation

Index

• Constants
• Variables
• func CallErrorHandler(e error, handler contracts.ErrorHandler) error
• type Mem
  • func NewMem() *Mem
  • func (m *Mem) Consume(concurrency int, exit chan struct{}, handler contracts.ErrorHandler) error
  • func (m *Mem) Dispatch(payload interface{}, delay ...time.Duration) error
  • func (m *Mem) Stop() error
• type Nsq
  • func NewNsq(config map[string]interface{}) *Nsq
  • func NewNsqFromConfig(conf NsqConfig) *Nsq
  • func (n *Nsq) Consume(concurrency int, exit chan struct{}, handler contracts.ErrorHandler) (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
• type Redis
  • func NewRedis(rdb redis.UniversalClient, queue string) *Redis
  • func (r *Redis) Consume(concurrency int, exit chan struct{}, handler contracts.ErrorHandler) error
  • func (r *Redis) Dispatch(payload interface{}, delay ...time.Duration) error
  • func (r *Redis) Stop() error
• type WrapperHandler
  • func (wh WrapperHandler) HandleMessage(message *nsq.Message) error

Constants

const AddrStep = ","

Variables

var (
	DefaultMemBuffer = 1024
)

Functions

func CallErrorHandler

func CallErrorHandler(e error, handler contracts.ErrorHandler) error

Types

type Mem

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

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

func NewMem

func NewMem() *Mem

func (*Mem) Consume

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

func (*Mem) Dispatch

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

func (*Mem) Stop

func (m *Mem) Stop() error

type Nsq

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

func NewNsq

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

func NewNsqFromConfig

func NewNsqFromConfig(conf NsqConfig) *Nsq

func (*Nsq) Consume

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

func (*Nsq) Dispatch

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

func (*Nsq) SetHandler

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

func (*Nsq) Stop

func (n *Nsq) Stop() error

type NsqConfig

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

type Redis

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

func NewRedis

func NewRedis(rdb redis.UniversalClient, queue string) *Redis

func (*Redis) Consume

func (r *Redis) Consume(concurrency int, exit chan struct{}, handler contracts.ErrorHandler) error

func (*Redis) Dispatch

func (r *Redis) Dispatch(payload interface{}, delay ...time.Duration) error

func (*Redis) Stop

func (r *Redis) Stop() error

type WrapperHandler

type WrapperHandler struct {
	Handler func(message *nsq.Message) error
}

func (WrapperHandler) HandleMessage

func (wh WrapperHandler) HandleMessage(message *nsq.Message) error