worker

package

v1.0.0 Latest Latest Go to latest Published: Dec 30, 2020 License: MIT Imports: 13 Imported by: 0

Details

This section is empty.

This section is empty.

func IsErrorConnect(err error) bool

func IsErrorRead(err error) bool

func IsErrorWrite(err error) bool

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

func (w *CBNSQWorker) Send(message *nsq.Message) ([]byte, error)

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

func (w *FastCGIWorker) Send(message *nsq.Message) ([]byte, error)

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

func (w *HTTPWorker) Send(message *nsq.Message) ([]byte, error)

给HTTP发消息

type Worker interface {
	Send(*nsq.Message) ([]byte, error)
	// contains filtered or unexported methods
}

worker接口

func NewWorker(addr, protocol, extra string, timeoutDial, timeoutWrite, timeoutRead time.Duration) (Worker, error)