Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type FileWorkerConfig ¶
type RedisWorkerConfig ¶
type TaskMessage ¶
type TaskMessage struct {
ID string
TypeName string
FileName string
Queue string
Payload []byte
Retried int
CreatedAt time.Time
UpdatedAt *time.Time
}
func NewQueue ¶
func NewQueue(typeName string) TaskMessage
func (*TaskMessage) SetPayload ¶
func (q *TaskMessage) SetPayload(payload []byte)
func (*TaskMessage) SetQueue ¶
func (q *TaskMessage) SetQueue(queue string)
Click to show internal directories.
Click to hide internal directories.