queue

package
v0.24.1 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Sep 25, 2025 License: Apache-2.0, MIT Imports: 15 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

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 added in v0.12.0 

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)

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.