worker

Documentation

Index

• func IsErrorConnect(err error) bool
• func IsErrorRead(err error) bool
• func IsErrorWrite(err error) bool
• type CBNSQWorker
  • func (w *CBNSQWorker) Send(message *nsq.Message) ([]byte, error)
• type FastCGIWorker
  • func (w *FastCGIWorker) Send(message *nsq.Message) ([]byte, error)
• type HTTPWorker
  • func (w *HTTPWorker) Send(message *nsq.Message) ([]byte, error)
• type Worker
  • func NewWorker(addr, protocol, extra string, ...) (Worker, error)

Functions

func IsErrorConnect

func IsErrorConnect(err error) bool

func IsErrorRead

func IsErrorRead(err error) bool

func IsErrorWrite

func IsErrorWrite(err error) bool

Types

type CBNSQWorker

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

func (*CBNSQWorker) Send

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

type FastCGIWorker

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

func (*FastCGIWorker) Send

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

type HTTPWorker

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

func (*HTTPWorker) Send

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

给HTTP发消息

type Worker

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

worker接口

func NewWorker

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