task

package
v1.20.3 Latest Latest
Warning

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

Go to latest
Published: Sep 19, 2026 License: GPL-3.0 Imports: 15 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func RegisterHandlers

func RegisterHandlers(mux *asynq.ServeMux, deps Dependencies)

Types

type Dependencies

type Dependencies struct {
	Email        email.Dependencies
	SMS          sms.Dependencies
	Order        order.Dependencies
	EventBus     *eventbus.Bus
	Traffic      traffic.Dependencies
	Subscription moduleSubscription.Service
	Store        repository.Store
	ExchangeRate *billing.CurrencyRateCache
}

type Service

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

func NewService

func NewService(redisConfig config.RedisConfig, deps Dependencies) *Service

func (*Service) Start

func (m *Service) Start()

func (*Service) Stop

func (m *Service) Stop()

Directories

Path Synopsis
Package events hosts the queue shells of the domain-event bus: the publish pump moving outbox rows onto the asynq broker, and the delivery worker running subscribers.
Package events hosts the queue shells of the domain-event bus: the publish pump moving outbox rows onto the asynq broker, and the delivery worker running subscribers.
Package order contains task adapters for the billing workflow.
Package order contains task adapters for the billing workflow.

Jump to

Keyboard shortcuts

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