Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func RunServer ¶
func RunServer(config AsynqServerConfig, handlers ...AsynqTaskHandler)
Types ¶
type AsynqClient ¶
type AsynqClient struct {
// contains filtered or unexported fields
}
func GetDefaultTaskClient ¶
func GetDefaultTaskClient() *AsynqClient
func (*AsynqClient) EnqueueTask ¶
func (ac *AsynqClient) EnqueueTask(name string, payload interface{}) error
type AsynqServerConfig ¶
type AsynqTaskHandler ¶
type AsynqTaskHandler struct { TaskName string InnerHandler asynq.HandlerFunc }
type AsynqTaskPriority ¶
type AsynqTaskPriority string
const ( AsynqTaskPriorityCritical AsynqTaskPriority = "critical" // Default priority ruled in asynq library AsynqTaskPriorityDefault AsynqTaskPriority = "default" AsynqTaskPriorityLow AsynqTaskPriority = "low" )
Click to show internal directories.
Click to hide internal directories.