redis

Documentation

Index

• Constants
• type Server
  • func NewServer(redisOpt asynq.RedisClientOpt, asyncCfg asynq.Config) *Server
  • func (s *Server) RegisterHandler(pattern string, handler func(context.Context, *asynq.Task) error)
  • func (s *Server) Start(ctx context.Context) error
  • func (s *Server) Stop(ctx context.Context) error
• type ServerOption
  • func WithAddress(addr string) ServerOption

Constants

const (
	// QueueCritical queue priority
	QueueCritical = "critical"
	QueueDefault  = "default"
	QueueLow      = "low"
)

Types

type Server

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

Server async server

func NewServer

func NewServer(redisOpt asynq.RedisClientOpt, asyncCfg asynq.Config) *Server

NewServer new async server

func (*Server) RegisterHandler

func (s *Server) RegisterHandler(pattern string, handler func(context.Context, *asynq.Task) error)

RegisterHandler register handler

func (*Server) Start

func (s *Server) Start(ctx context.Context) error

Start async server

func (*Server) Stop

func (s *Server) Stop(ctx context.Context) error

Stop async server

type ServerOption

type ServerOption func(o *Server)

ServerOption is cron server option.

func WithAddress

func WithAddress(addr string) ServerOption

WithAddress with server address.