tasker

Documentation

Index

• type QueueName
• type Task
• type TaskName
• type TaskerClient
  • func NewTaskerClient(o TaskerClientOpts) *TaskerClient
  • func (c *TaskerClient) CreateTask(ctx context.Context, taskName TaskName, queueName QueueName, task *Task, ...) (*asynq.TaskInfo, error)
• type TaskerClientOpts
• type TaskerServer
  • func NewTaskerServer(o TaskerServerOpts) *TaskerServer
  • func (ts *TaskerServer) RegisterHandlers(taskName TaskName, taskHandler func(context.Context, *asynq.Task) error)
  • func (ts *TaskerServer) RegisterMiddlewareStack(middlewareStack []asynq.MiddlewareFunc)
  • func (ts *TaskerServer) Start() error
  • func (ts *TaskerServer) Stop()
• type TaskerServerOpts

Types

type QueueName

type QueueName string

const (
	HighPriority    QueueName = "high_priority"
	DefaultPriority QueueName = "default_priority"
)

type Task

type Task struct {
	Id      string          `json:"id"`
	Payload json.RawMessage `json:"payload"`
}

type TaskName

type TaskName string

const (
	AccountRegisterTask  TaskName = "sys:register_account"
	AccountRefillGasTask TaskName = "sys:refill_gas"
	SignTransferTask     TaskName = "usr:sign_transfer"
	SignTransferTaskAuth TaskName = "usr:sign_transfer_auth"
	DispatchTxTask       TaskName = "rpc:dispatch"
)

type TaskerClient

type TaskerClient struct {
	Client *asynq.Client
}

func NewTaskerClient

func NewTaskerClient(o TaskerClientOpts) *TaskerClient

func (*TaskerClient) CreateTask

func (c *TaskerClient) CreateTask(ctx context.Context, taskName TaskName, queueName QueueName, task *Task, extraOpts ...asynq.Option) (*asynq.TaskInfo, error)

type TaskerClientOpts

type TaskerClientOpts struct {
	RedisPool *redis.RedisPool
}

type TaskerServer

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

func NewTaskerServer

func NewTaskerServer(o TaskerServerOpts) *TaskerServer

func (*TaskerServer) RegisterHandlers

func (ts *TaskerServer) RegisterHandlers(taskName TaskName, taskHandler func(context.Context, *asynq.Task) error)

func (*TaskerServer) RegisterMiddlewareStack

func (ts *TaskerServer) RegisterMiddlewareStack(middlewareStack []asynq.MiddlewareFunc)

func (*TaskerServer) Start

func (ts *TaskerServer) Start() error

func (*TaskerServer) Stop

func (ts *TaskerServer) Stop()

type TaskerServerOpts

type TaskerServerOpts struct {
	Concurrency      int
	ErrorHandler     asynq.ErrorHandler
	IsFailureHandler func(error) bool
	Logg             logf.Logger
	LogLevel         asynq.LogLevel
	RedisPool        *redis.RedisPool
	RetryHandler     asynq.RetryDelayFunc
}