Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewAsynqServer ¶
func NewAsynqServer(log *zap.SugaredLogger, conf redis.Conf, scfg AsynqServerConfig) *asynq.Server
Types ¶
type AsynqServerConfig ¶
type AsynqTaskScheduler ¶
type AsynqTaskScheduler struct {
// contains filtered or unexported fields
}
AsynqTaskScheduler https://github.com/hibiken/asynq/wiki/Getting-Started
func NewAsynqTaskScheduler ¶
func NewAsynqTaskScheduler(log *zap.SugaredLogger, client *asynq.Client) *AsynqTaskScheduler
func (AsynqTaskScheduler) Schedule ¶
func (scheduler AsynqTaskScheduler) Schedule(t *AsyncTask) error
Click to show internal directories.
Click to hide internal directories.