Documentation
¶
Index ¶
- func NewAsyncMonHandler(redisClientOpt asynq.RedisClientOpt) *asynqmon.HTTPHandler
- func NewAsynqClient(redisClientOpt asynq.RedisClientOpt) *asynq.Client
- func NewAsynqInspector(redisClientOpt asynq.RedisClientOpt) *asynq.Inspector
- func NewAsynqScheduler(redisClientOpt asynq.RedisClientOpt, logger *zap.Logger) (scheduler *asynq.Scheduler, err error)
- func NewAsynqServer(redisClientOpt asynq.RedisClientOpt, logger *zap.Logger) *asynq.Server
- func NewAsynqServerMux() (mux *asynq.ServeMux, err error)
- func NewAsynqServerWithShutdownTimeout(redisClientOpt asynq.RedisClientOpt, logger *zap.Logger, ...) *asynq.Server
- func NewZapAsynqLogger(logger *zap.Logger) asynq.Logger
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewAsyncMonHandler ¶
func NewAsyncMonHandler(redisClientOpt asynq.RedisClientOpt) *asynqmon.HTTPHandler
func NewAsynqClient ¶
func NewAsynqClient(redisClientOpt asynq.RedisClientOpt) *asynq.Client
func NewAsynqInspector ¶
func NewAsynqInspector(redisClientOpt asynq.RedisClientOpt) *asynq.Inspector
func NewAsynqScheduler ¶
func NewAsynqServer ¶
func NewAsynqServerMux ¶
func NewAsynqServerWithShutdownTimeout ¶
func NewAsynqServerWithShutdownTimeout(redisClientOpt asynq.RedisClientOpt, logger *zap.Logger, shutdownTimeout time.Duration) *asynq.Server
NewAsynqServerWithShutdownTimeout is for services with long-running tasks that need a longer drain window. Most services should use NewAsynqServer.
Types ¶
This section is empty.
Source Files
Click to show internal directories.
Click to hide internal directories.