asynq

package

v0.0.8-tcp Latest Latest Go to latest Published: Aug 12, 2024 License: MIT Imports: 6 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/hedon954/go-matcher

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
func NewEmailDeliveryTask(userID int, tmplID string) *asynq.Task
func NewImageResizeTask(src string) *asynq.Task
type EmailDeliveryPayload
type EmailProcessor
- func NewEmailProcessor() *EmailProcessor
- func (processor *EmailProcessor) HandleEmailDeliveryTask(_ context.Context, t *asynq.Task) error
type ImageProcessor
- func NewImageProcessor() *ImageProcessor
- func (processor *ImageProcessor) HandleImageResizeTask(_ context.Context, t *asynq.Task) error
- func (processor *ImageProcessor) ProcessTask(ctx context.Context, t *asynq.Task) error
type ImageResizePayload

Constants ¶

View Source

const (
	TypeEmailDelivery = "email:deliver"
	TypeImageResize   = "image:resize"
)

A list of task types.

Variables ¶

This section is empty.

Functions ¶

func NewEmailDeliveryTask ¶

func NewEmailDeliveryTask(userID int, tmplID string) *asynq.Task

func NewImageResizeTask ¶

func NewImageResizeTask(src string) *asynq.Task

Types ¶

type EmailDeliveryPayload ¶

type EmailDeliveryPayload struct {
	UserID     int
	TemplateID string
}

type EmailProcessor ¶

type EmailProcessor struct {
	FinishTaskCount atomic.Int64
}

EmailProcessor implements asynq.Handler interface.

func NewEmailProcessor ¶

func NewEmailProcessor() *EmailProcessor

func (*EmailProcessor) HandleEmailDeliveryTask ¶

func (processor *EmailProcessor) HandleEmailDeliveryTask(_ context.Context, t *asynq.Task) error

--------------------------------------------------------------- Write a function HandleXXXTask to handle the input task. Note that it satisfies the asynq.HandlerFunc interface.

Handler doesn't need to be a function. You can define a type that satisfies asynq.Handler interface. See examples below. ---------------------------------------------------------------

type ImageProcessor ¶

type ImageProcessor struct {
	FinishTaskCount atomic.Int64
}

ImageProcessor implements asynq.Handler interface.

func NewImageProcessor ¶

func NewImageProcessor() *ImageProcessor

func (*ImageProcessor) HandleImageResizeTask ¶

func (processor *ImageProcessor) HandleImageResizeTask(_ context.Context, t *asynq.Task) error

func (*ImageProcessor) ProcessTask ¶

func (processor *ImageProcessor) ProcessTask(ctx context.Context, t *asynq.Task) error

type ImageResizePayload ¶

type ImageResizePayload struct {
	SourceURL string
}

Source Files ¶

View all Source files

async.go

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL