utils

package

v0.1.8 Latest Latest Go to latest Published: Feb 6, 2025 License: Apache-2.0 Imports: 5 Imported by: 0

Details

This section is empty.

This section is empty.

func Enqueue(ctx context.Context, items []TaskConstructor, opts ...asynq.Option) error

Enqueue enqueues the tasks produced by the given task constructors.

func LinkObjects(ctx context.Context, db *bun.DB, items []LinkFunction) error

LinkObjects links objects by using the provided LinkFunction items.

type LinkFunction func(ctx context.Context, db *bun.DB) error

LinkFunction is a function, which establishes relationships between models.

type TaskConstructor func() *asynq.Task

TaskConstructor is a function which creates and returns a new asynq.Task.