queue

package

v0.0.0-...-4a59535 Latest Latest Go to latest Published: Sep 19, 2024 License: MIT Imports: 6 Imported by: 0

Documentation ¶

Index ¶

Variables
func HookClient(lifecycle fx.Lifecycle, client *asynq.Client)
func HookServer(lifecycle fx.Lifecycle, server *asynq.Server, mux *asynq.ServeMux)
func NewClient(config *redis2.RedisOptions) *asynq.Client
func NewServeMux() *asynq.ServeMux
func NewServer(config *redis2.RedisOptions, logger logger.Logger) *asynq.Server

Constants ¶

This section is empty.

Variables ¶

View Source

var (
	ClientModule    = fx.Module("queue-client", ClientProviders, ClientInvokes)
	ClientProviders = fx.Options(
		fx.Provide(NewServeMux),
		fx.Provide(NewClient),
	)
	ClientInvokes = fx.Options(
		fx.Invoke(HookClient),
	)

	WorkerModule    = fx.Module("queue-worker", ClientModule, WorkerProviders, WorkerInvokes)
	WorkerProviders = fx.Options(
		fx.Provide(NewServer),
	)
	WorkerInvokes = fx.Options(
		fx.Invoke(HookServer),
	)
)

Functions ¶

func HookClient ¶

func HookClient(lifecycle fx.Lifecycle, client *asynq.Client)

func HookServer ¶

func HookServer(lifecycle fx.Lifecycle, server *asynq.Server, mux *asynq.ServeMux)

func NewClient ¶

func NewClient(config *redis2.RedisOptions) *asynq.Client

func NewServeMux ¶

func NewServeMux() *asynq.ServeMux

func NewServer ¶

func NewServer(config *redis2.RedisOptions, logger logger.Logger) *asynq.Server

Types ¶

This section is empty.

Source Files ¶

View all Source files

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