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, i indexer.Indexer, db *storage.Database, ...) *AsynqWorker
  • func (t *AsynqWorker) Done() <-chan struct{}
  • func (t *AsynqWorker) Run(ctx context.Context) error
• 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, i indexer.Indexer, db *storage.Database, server *distributed.TipSetWorker) *AsynqWorker

func (*AsynqWorker) Done

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

func (*AsynqWorker) Run

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

type WorkerErrorHandler

type WorkerErrorHandler struct{}

func (*WorkerErrorHandler) HandleError

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