asynctaskext

Documentation

Index

• type AsyncTaskExt
  • func (t *AsyncTaskExt) Application() *gobay.Application
  • func (t *AsyncTaskExt) Close() error
  • func (t *AsyncTaskExt) Init(app *gobay.Application) error
  • func (t *AsyncTaskExt) Object() interface{}
  • func (t *AsyncTaskExt) RegisterWorkerHandler(name string, handler interface{}) error
  • func (t *AsyncTaskExt) RegisterWorkerHandlers(handlers map[string]interface{}) error
  • func (t *AsyncTaskExt) SendTask(sign *tasks.Signature) (*result.AsyncResult, error)
  • func (t *AsyncTaskExt) StartWorker(queue string, concurrency int) error

Types

type AsyncTaskExt

type AsyncTaskExt struct {
	NS string
	// contains filtered or unexported fields
}

func (*AsyncTaskExt) Application

func (t *AsyncTaskExt) Application() *gobay.Application

func (*AsyncTaskExt) Close

func (t *AsyncTaskExt) Close() error

func (*AsyncTaskExt) Init

func (t *AsyncTaskExt) Init(app *gobay.Application) error

func (*AsyncTaskExt) Object

func (t *AsyncTaskExt) Object() interface{}

func (*AsyncTaskExt) RegisterWorkerHandler

func (t *AsyncTaskExt) RegisterWorkerHandler(name string, handler interface{}) error

RegisterWorkerHandler add task handler to worker to process task messages

func (*AsyncTaskExt) RegisterWorkerHandlers

func (t *AsyncTaskExt) RegisterWorkerHandlers(handlers map[string]interface{}) error

RegisterWorkerHandlers add task handlers to worker to process task messages

func (*AsyncTaskExt) SendTask

func (t *AsyncTaskExt) SendTask(sign *tasks.Signature) (*result.AsyncResult, error)

SendTask publish task messages to broker

func (*AsyncTaskExt) StartWorker

func (t *AsyncTaskExt) StartWorker(queue string, concurrency int) error

StartWorker start a worker that consume task messages for queue