Versions in this module Expand all Collapse all v1 v1.0.0 Dec 30, 2020 Changes in this version + func IsErrorConnect(err error) bool + func IsErrorRead(err error) bool + func IsErrorWrite(err error) bool + type CBNSQWorker struct + func (w *CBNSQWorker) Send(message *nsq.Message) ([]byte, error) + type FastCGIWorker struct + func (w *FastCGIWorker) Send(message *nsq.Message) ([]byte, error) + type HTTPWorker struct + func (w *HTTPWorker) Send(message *nsq.Message) ([]byte, error) + type Worker interface + Send func(*nsq.Message) ([]byte, error) + func NewWorker(addr, protocol, extra string, ...) (Worker, error)
Go to main page