std

Jul 5, 2022

Changes in this version

type Job

+ ID string

+ type NsqHandler struct

+ func (NsqHandler) HandleMessage(m *nsq.Message) error

Sep 13, 2021

Changes in this version

+ var Invoker = func(payloadType reflect.Type, payloadValue, funcValue reflect.Value, ...)

Sep 10, 2021

Changes in this version

+ func Listen(job interface{}, fn interface{})

Sep 3, 2021

Changes in this version

+ func AddHandler(job interface{}, fn interface{})

+ func GetHandler(name string) (interface{}, bool)

+ func GetPayloadName(payload interface{}) string

+ func InvokeHandler(payload interface{}) (e error)

+ func MarshalPayload(payload interface{}) ([]byte, error)

+ type Job struct

+ Payload []byte

+ PayloadType string

+ func ToJob(payload interface{}) (j Job, e error)

+ func (j Job) Invoke() (e error)

+ type JobHandler struct

+ func (JobHandler) HandleMessage(m *nsq.Message) error

+ type Worker struct

+ func NewWorker(concurrency int, connection contracts.Connection) *Worker

+ func (w *Worker) Close() error

+ func (w *Worker) Run(done chan struct{}) error