queue

Documentation

Index

• type AsynQ
  • func NewAsynq(client *asynq.Client) *AsynQ
  • func (r *AsynQ) EnqueueTipSet(ctx context.Context, ts *types.TipSet, indexType indexer.IndexerType, ...) error
• type AsynqWorker
  • func NewAsynqWorker(name string, server *distributed.TipSetWorker, handlers ...TaskHandler) *AsynqWorker
  • func (t *AsynqWorker) Done() <-chan struct{}
  • func (t *AsynqWorker) Run(ctx context.Context) error
• type TaskHandler
• type WorkerErrorHandler
  • func (w *WorkerErrorHandler) HandleError(ctx context.Context, task *asynq.Task, err error)

Types

type AsynQ

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

func NewAsynq

func NewAsynq(client *asynq.Client) *AsynQ

func (*AsynQ) EnqueueTipSet

func (r *AsynQ) EnqueueTipSet(ctx context.Context, ts *types.TipSet, indexType indexer.IndexerType, taskNames ...string) error

type AsynqWorker

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

func NewAsynqWorker

func NewAsynqWorker(name string, server *distributed.TipSetWorker, handlers ...TaskHandler) *AsynqWorker

func (*AsynqWorker) Done

func (t *AsynqWorker) Done() <-chan struct{}

func (*AsynqWorker) Run

func (t *AsynqWorker) Run(ctx context.Context) error

type TaskHandler

type TaskHandler interface {
	Type() string
	Handler() asynq.HandlerFunc
}

type WorkerErrorHandler

type WorkerErrorHandler struct{}

func (*WorkerErrorHandler) HandleError

func (w *WorkerErrorHandler) HandleError(ctx context.Context, task *asynq.Task, err error)