worker

package
v1.3.1 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jan 6, 2026 License: GPL-3.0 Imports: 13 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	QueueCritical = "critical"
	QueueDefault  = "default"
)
View Source 
const TaskDelayDeleteCache = "task:delay_delete_cache"
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 NewLogger 

func NewLogger() *Logger

func (*Logger) Debug 

func (logger *Logger) Debug(args ...interface{})

func (*Logger) Error 

func (logger *Logger) Error(args ...interface{})

func (*Logger) Fatal 

func (logger *Logger) Fatal(args ...interface{})

func (*Logger) Info 

func (logger *Logger) Info(args ...interface{})

func (*Logger) Print 

func (logger *Logger) Print(level zerolog.Level, args ...interface{})

func (*Logger) Printf 

func (logger *Logger) Printf(ctx context.Context, format string, v ...interface{})

func (*Logger) Warn 

func (logger *Logger) Warn(args ...interface{})

type PayloadDelayDeleteCache added in v1.3.0 

type PayloadDelayDeleteCache struct {
	Keys []string `json:"keys"`
}

type PayloadSendVerifyEmail 

type PayloadSendVerifyEmail struct {
	UserID uuid.UUID `json:"user_id"`
}

type RedisTaskDistributor 

type RedisTaskDistributor struct {
	// contains filtered or unexported fields
}

func (*RedisTaskDistributor) DistributeTaskDelayDeleteCache added in v1.3.0 

func (distributor *RedisTaskDistributor) DistributeTaskDelayDeleteCache(ctx context.Context, payload *PayloadDelayDeleteCache, opts ...asynq.Option) error

func (*RedisTaskDistributor) DistributeTaskDelayDeleteCacheDefault added in v1.3.0 

func (distributor *RedisTaskDistributor) DistributeTaskDelayDeleteCacheDefault(ctx context.Context, keys ...string) error

DistributeTaskDelayDeleteCacheDefault 使用默认配置分发缓存删除任务 默认配置：MaxRetry=3, Timeout=3s, Queue=critical

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) ProcessTaskDelayDeleteCache added in v1.3.0 

func (processor *RedisTaskProcessor) ProcessTaskDelayDeleteCache(ctx context.Context, task *asynq.Task) error

func (*RedisTaskProcessor) ProcessTaskSendVerifyEmail 

func (processor *RedisTaskProcessor) ProcessTaskSendVerifyEmail(ctx context.Context, task *asynq.Task) error

func (*RedisTaskProcessor) Shutdown 

func (processor *RedisTaskProcessor) Shutdown()

func (*RedisTaskProcessor) Start 

func (processor *RedisTaskProcessor) Start() error

type TaskDistributor 

type TaskDistributor interface {
	DistributeTaskSendVerifyEmail(
		ctx context.Context,
		payload *PayloadSendVerifyEmail,
		opts ...asynq.Option,
	) error
	DistributeTaskDelayDeleteCache(ctx context.Context, payload *PayloadDelayDeleteCache, opts ...asynq.Option) error
	// DistributeTaskDelayDeleteCacheDefault 使用默认配置分发缓存删除任务
	DistributeTaskDelayDeleteCacheDefault(ctx context.Context, keys ...string) error
}

func NewRedisTaskDistributor 

func NewRedisTaskDistributor(redisOpt asynq.RedisClientOpt) TaskDistributor

type TaskProcessor 

type TaskProcessor interface {
	Start() error
	Shutdown()
	ProcessTaskSendVerifyEmail(ctx context.Context, task *asynq.Task) error
	ProcessTaskDelayDeleteCache(ctx context.Context, task *asynq.Task) error
}

func NewRedisTaskProcessor 

func NewRedisTaskProcessor(redisOpt asynq.RedisClientOpt, store db.Store, cache cache.Cache, mailer mail.EmailSender) TaskProcessor

Source Files

View all Source files

Directories

Path Synopsis
Package mockwk is a generated GoMock package.
 Package mockwk is a generated GoMock package.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.