task

package

v1.41.0 Latest Latest Go to latest Published: Apr 28, 2026 License: MIT Imports: 13 Imported by: 0

Details

This section is empty.

View Source

var (
	Registry = make(map[string][]*Task)
)

func Func(name string, fn interface{}) *delay.Function

Creates a new delay.Func which will call our fn with context.Context, etc.

func Names() []string

Returns a slice of task names

func Register(name string, tasks ...*Task) int

Register a new task in task registry

func Run(ctx *gin.Context, name string, args ...interface{})

Run task(s) associated with a given name

func SetupRoutes(router router.Router)

Setup handlers for HTTP registered tasks

func Unregister(name string)

Remove tasks registered under a given name.

type Delay struct {
	Function *delay.Function
	Name     string
}

Details about a Task's delay function, if created with special task.Func helper

type Task struct {
	Name     string
	Number   int
	Value    reflect.Value
	Function interface{}
	Delay    *Delay
}

A Task which can be invoked later by name or HTTP handler

func New(name string, fn interface{}) *Task

Create a new task and register it