task

Documentation

Index

• func NewClient(url string, pwd string, db int) *asynq.Client
• func NewHandler() *asynq.ServeMux
• func RegisterTask(handler *asynq.ServeMux, l logger.Interface, ...)
• type IExecuteTask
  • func GetSayHelloExecutor(c *asynq.Client) IExecuteTask[*SayHelloPayload]
• type SayHelloExecutor
  • func (s *SayHelloExecutor) ExecuteTask(pl *SayHelloPayload) error
• type SayHelloPayload
• type Server
  • func NewServer(handler asynq.Handler, url string, pwd string, db int) *Server
  • func (s *Server) Run() error
• type TaskHandler

Functions

func NewClient

func NewClient(url string, pwd string, db int) *asynq.Client

func NewHandler

func NewHandler() *asynq.ServeMux

func RegisterTask

func RegisterTask(handler *asynq.ServeMux, l logger.Interface, txtGenerator webapi.IDummyTextGenerator)

Types

type IExecuteTask

type IExecuteTask[T any] interface {
	ExecuteTask(T) error
}

func GetSayHelloExecutor

func GetSayHelloExecutor(c *asynq.Client) IExecuteTask[*SayHelloPayload]

type SayHelloExecutor

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

func (*SayHelloExecutor) ExecuteTask

func (s *SayHelloExecutor) ExecuteTask(pl *SayHelloPayload) error

type SayHelloPayload

type SayHelloPayload struct {
	Message string
}

type Server

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

func NewServer

func NewServer(handler asynq.Handler, url string, pwd string, db int) *Server

func (*Server) Run

func (s *Server) Run() error

type TaskHandler

type TaskHandler = func(context.Context, *asynq.Task) error