server

package

v0.0.0-...-b15c4a3 Latest Latest Go to latest Published: Jan 6, 2022 License: MIT Imports: 12 Imported by: 0

Details

This section is empty.

View Source

var (
	ErrTimeout = errors.New("exec Func time out")
	ErrFunc    = errors.New("func format error")
)

This section is empty.

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

func NewFuncWorker(name string, wFunc interface{}) FuncWorker

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

func GetServer() *Server

func NewServer(opts ...WorkerOpt) *Server

func (s *Server) CloneBackend() backend.Backend

func (s *Server) CloneBroker() broker.Broker

func (s *Server) Reg(funcName string, wFunc interface{})

func (s *Server) Run(numWorkers int) (err error)

启动

func (s *Server) ShutDown()

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

func NewWorker() *Worker

func (w *Worker) RetryTask(msg *message.Message) (err error)

func (w *Worker) Run(numWorker int) error

func (w *Worker) Stop()

type WorkerOpt func(w *Worker)

func WithBackend(backend backend.Backend) WorkerOpt

func WithBroker(broker broker.Broker) WorkerOpt