asynq

May 22, 2024

Changes in this version

+ func RegisterSubscriberWithCtx[T any](srv *Server, taskType string, handler func(context.Context, string, *T) error) error

type Server

+ func (s *Server) RegisterSubscriberWithCtx(taskType string, handler func(context.Context, string, MessagePayload) error, ...) error

May 6, 2024

Changes in this version

type Server

+ func (s *Server) NewWaitResultTask(typeName string, msg broker.Any, opts ...asynq.Option) error

Jan 19, 2024

Changes in this version

type ServerOption

+ func WithConfig(c asynq.Config) ServerOption

+ func WithIsFailure(c asynq.Config) ServerOption

Nov 3, 2023

Changes in this version

type Server

+ func (s *Server) QueryPeriodicTaskEntryID(typeName string) string

+ func (s *Server) RemoveAllPeriodicTask()

Oct 24, 2023

Changes in this version

+ func LogDebug(args ...interface{})

+ func LogDebugf(format string, args ...interface{})

+ func LogError(args ...interface{})

+ func LogErrorf(format string, args ...interface{})

+ func LogFatal(args ...interface{})

+ func LogFatalf(format string, args ...interface{})

+ func LogInfo(args ...interface{})

+ func LogInfof(format string, args ...interface{})

+ func LogWarn(args ...interface{})

+ func LogWarnf(format string, args ...interface{})

+ func RegisterSubscriber(srv *Server, taskType string, handler func(string, *T) error) error

+ type Binder func() any

+ type HandlerData struct

+ Binder Binder

+ Handler MessageHandler

+ type MessageHandler func(string, MessagePayload) error

+ type MessageHandlerMap map[string]HandlerData

+ type MessagePayload any

type Server

+ func (s *Server) RegisterSubscriber(taskType string, handler MessageHandler, binder Binder) error

+ func (s *Server) RemovePeriodicTask(entryID string) error

type ServerOption

+ func WithCodec(c string) ServerOption

+ func WithEnableKeepAlive(enable bool) ServerOption

+ func WithRedisPassword(password string) ServerOption

Nov 13, 2022

Changes in this version

+ type Server struct

+ func NewServer(opts ...ServerOption) *Server

+ func (s *Server) Endpoint() (*url.URL, error)

+ func (s *Server) Handle(pattern string, handler asynq.Handler) error

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

+ func (s *Server) Name() string

+ func (s *Server) NewPeriodicTask(cronSpec, typeName string, payload []byte, opts ...asynq.Option) error

+ func (s *Server) NewTask(typeName string, payload []byte, opts ...asynq.Option) error

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

+ func (s *Server) Stop(_ context.Context) error

+ type ServerOption func(o *Server)

+ func WithAddress(addr string) ServerOption

+ func WithConcurrency(concurrency int) ServerOption

+ func WithDelayedTaskCheckInterval(tm time.Duration) ServerOption

+ func WithDialTimeout(timeout time.Duration) ServerOption

+ func WithErrorHandler(fn asynq.ErrorHandler) ServerOption

+ func WithGroupGracePeriod(tm time.Duration) ServerOption

+ func WithGroupMaxDelay(tm time.Duration) ServerOption

+ func WithGroupMaxSize(sz int) ServerOption

+ func WithHealthCheckFunc(fn func(error)) ServerOption

+ func WithHealthCheckInterval(tm time.Duration) ServerOption

+ func WithLocation(loc *time.Location) ServerOption

+ func WithMiddleware(m ...asynq.MiddlewareFunc) ServerOption

+ func WithQueues(queues map[string]int) ServerOption

+ func WithReadTimeout(timeout time.Duration) ServerOption

+ func WithRedisAuth(userName, password string) ServerOption

+ func WithRedisDatabase(db int) ServerOption

+ func WithRedisPoolSize(size int) ServerOption

+ func WithRetryDelayFunc(fn asynq.RetryDelayFunc) ServerOption

+ func WithStrictPriority(val bool) ServerOption

+ func WithTLSConfig(c *tls.Config) ServerOption

+ func WithWriteTimeout(timeout time.Duration) ServerOption