Documentation
¶
Index ¶
- Constants
- type Logger
- func (logger *Logger) Debug(args ...interface{})
- func (logger *Logger) Error(args ...interface{})
- func (logger *Logger) Fatal(args ...interface{})
- func (logger *Logger) Info(args ...interface{})
- func (logger *Logger) Print(level zerolog.Level, args ...interface{})
- func (logger *Logger) Warn(args ...interface{})
- type PayloadSendVerifyEmail
- type RedisTaskDistributor
- type RedisTaskProcessor
- type TaskDistributor
- type TaskProcessor
Constants ¶
View Source
const ( QueueCritical = "critical" QueueDefault = "default" )
View Source
const TaskSendVerifyEmail = "task:send_verify_email"
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Logger ¶
type Logger struct{}
func (*Logger) Debug ¶
func (logger *Logger) Debug(args ...interface{})
Debug logs a message at Debug level.
func (*Logger) Error ¶
func (logger *Logger) Error(args ...interface{})
Error logs a message at Error level.
func (*Logger) Fatal ¶
func (logger *Logger) Fatal(args ...interface{})
Fatal loga uma mensagem nível Fatal e o processo encerrará com status definido para 1
func (*Logger) Info ¶
func (logger *Logger) Info(args ...interface{})
Info logs a message at Info level.
type PayloadSendVerifyEmail ¶
type PayloadSendVerifyEmail struct {
Username string `json:"username"`
}
type RedisTaskDistributor ¶
type RedisTaskDistributor struct {
// contains filtered or unexported fields
}
func (*RedisTaskDistributor) DistributeTaskSendVerifyEmail ¶
func (distributor *RedisTaskDistributor) DistributeTaskSendVerifyEmail( ctx context.Context, payload *PayloadSendVerifyEmail, opts ...asynq.Option) error
type RedisTaskProcessor ¶
type RedisTaskProcessor struct {
// contains filtered or unexported fields
}
func (*RedisTaskProcessor) ProcessTaskSendVerifyEmail ¶
func (*RedisTaskProcessor) Start ¶
func (processor *RedisTaskProcessor) Start() error
type TaskDistributor ¶
type TaskDistributor interface {
DistributeTaskSendVerifyEmail(
ctx context.Context,
payload *PayloadSendVerifyEmail,
opts ...asynq.Option) error
}
func NewRedisTaskDistributor ¶
func NewRedisTaskDistributor(redisOpt asynq.RedisClientOpt) TaskDistributor
NewRedisTaskDistributor retorna uma interface, pois é preciso forçar a struct RedisTaskDistributor a implementar a interface TaskDistributor. Se não forem implementadas todas as funções requisitadas pela interface, o compilador irá alertar um erro.
type TaskProcessor ¶
type TaskProcessor interface {
Start() error
ProcessTaskSendVerifyEmail(ctx context.Context, task *asynq.Task) error
}
func NewRedisTaskProcessor ¶
func NewRedisTaskProcessor(redisOpt asynq.RedisClientOpt, store db.Store) TaskProcessor
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.