coroutines

Documentation

Index

• func AcquireLock(c gocoro.Coroutine[*t_aio.Submission, *t_aio.Completion, any], ...) (*t_api.Response, error)
• func ClaimTask(c gocoro.Coroutine[*t_aio.Submission, *t_aio.Completion, any], ...) (*t_api.Response, error)
• func CompletePromise(c gocoro.Coroutine[*t_aio.Submission, *t_aio.Completion, any], ...) (*t_api.Response, error)
• func CompleteTask(c gocoro.Coroutine[*t_aio.Submission, *t_aio.Completion, any], ...) (*t_api.Response, error)
• func CreateCallback(c gocoro.Coroutine[*t_aio.Submission, *t_aio.Completion, any], ...) (*t_api.Response, error)
• func CreatePromise(c gocoro.Coroutine[*t_aio.Submission, *t_aio.Completion, any], ...) (*t_api.Response, error)
• func CreatePromiseAndTask(c gocoro.Coroutine[*t_aio.Submission, *t_aio.Completion, any], ...) (*t_api.Response, error)
• func CreateSchedule(c gocoro.Coroutine[*t_aio.Submission, *t_aio.Completion, any], ...) (*t_api.Response, error)
• func CreateSubscription(c gocoro.Coroutine[*t_aio.Submission, *t_aio.Completion, any], ...) (*t_api.Response, error)
• func DeleteSchedule(c gocoro.Coroutine[*t_aio.Submission, *t_aio.Completion, any], ...) (*t_api.Response, error)
• func Echo(c gocoro.Coroutine[*t_aio.Submission, *t_aio.Completion, any], ...) (*t_api.Response, error)
• func EnqueueTasks(config *system.Config, tags map[string]string) gocoro.CoroutineFunc[*t_aio.Submission, *t_aio.Completion, any]
• func HeartbeatLocks(c gocoro.Coroutine[*t_aio.Submission, *t_aio.Completion, any], ...) (*t_api.Response, error)
• func HeartbeatTasks(c gocoro.Coroutine[*t_aio.Submission, *t_aio.Completion, any], ...) (*t_api.Response, error)
• func ReadPromise(c gocoro.Coroutine[*t_aio.Submission, *t_aio.Completion, any], ...) (*t_api.Response, error)
• func ReadSchedule(c gocoro.Coroutine[*t_aio.Submission, *t_aio.Completion, any], ...) (*t_api.Response, error)
• func ReleaseLock(c gocoro.Coroutine[*t_aio.Submission, *t_aio.Completion, any], ...) (*t_api.Response, error)
• func SchedulePromises(config *system.Config, tags map[string]string) gocoro.CoroutineFunc[*t_aio.Submission, *t_aio.Completion, any]
• func SearchPromises(c gocoro.Coroutine[*t_aio.Submission, *t_aio.Completion, any], ...) (*t_api.Response, error)
• func SearchSchedules(c gocoro.Coroutine[*t_aio.Submission, *t_aio.Completion, any], ...) (*t_api.Response, error)
• func TimeoutLocks(config *system.Config, tags map[string]string) gocoro.CoroutineFunc[*t_aio.Submission, *t_aio.Completion, any]
• func TimeoutPromises(config *system.Config, tags map[string]string) gocoro.CoroutineFunc[*t_aio.Submission, *t_aio.Completion, any]
• func TimeoutTasks(config *system.Config, tags map[string]string) gocoro.CoroutineFunc[*t_aio.Submission, *t_aio.Completion, any]

Functions

func AcquireLock

func AcquireLock(c gocoro.Coroutine[*t_aio.Submission, *t_aio.Completion, any], r *t_api.Request) (*t_api.Response, error)

func ClaimTask

func ClaimTask(c gocoro.Coroutine[*t_aio.Submission, *t_aio.Completion, any], r *t_api.Request) (*t_api.Response, error)

func CompletePromise

func CompletePromise(c gocoro.Coroutine[*t_aio.Submission, *t_aio.Completion, any], r *t_api.Request) (*t_api.Response, error)

func CompleteTask

func CompleteTask(c gocoro.Coroutine[*t_aio.Submission, *t_aio.Completion, any], r *t_api.Request) (*t_api.Response, error)

func CreateCallback

func CreateCallback(c gocoro.Coroutine[*t_aio.Submission, *t_aio.Completion, any], r *t_api.Request) (*t_api.Response, error)

func CreatePromise

func CreatePromise(c gocoro.Coroutine[*t_aio.Submission, *t_aio.Completion, any], r *t_api.Request) (*t_api.Response, error)

func CreatePromiseAndTask

func CreatePromiseAndTask(c gocoro.Coroutine[*t_aio.Submission, *t_aio.Completion, any], r *t_api.Request) (*t_api.Response, error)

func CreateSchedule

func CreateSchedule(c gocoro.Coroutine[*t_aio.Submission, *t_aio.Completion, any], r *t_api.Request) (*t_api.Response, error)

func CreateSubscription

func CreateSubscription(c gocoro.Coroutine[*t_aio.Submission, *t_aio.Completion, any], r *t_api.Request) (*t_api.Response, error)

func DeleteSchedule

func DeleteSchedule(c gocoro.Coroutine[*t_aio.Submission, *t_aio.Completion, any], r *t_api.Request) (*t_api.Response, error)

func Echo

func Echo(c gocoro.Coroutine[*t_aio.Submission, *t_aio.Completion, any], r *t_api.Request) (*t_api.Response, error)

func EnqueueTasks

func EnqueueTasks(config *system.Config, tags map[string]string) gocoro.CoroutineFunc[*t_aio.Submission, *t_aio.Completion, any]

func HeartbeatLocks

func HeartbeatLocks(c gocoro.Coroutine[*t_aio.Submission, *t_aio.Completion, any], r *t_api.Request) (*t_api.Response, error)

func HeartbeatTasks

func HeartbeatTasks(c gocoro.Coroutine[*t_aio.Submission, *t_aio.Completion, any], r *t_api.Request) (*t_api.Response, error)

func ReadPromise

func ReadPromise(c gocoro.Coroutine[*t_aio.Submission, *t_aio.Completion, any], r *t_api.Request) (*t_api.Response, error)

func ReadSchedule

func ReadSchedule(c gocoro.Coroutine[*t_aio.Submission, *t_aio.Completion, any], r *t_api.Request) (*t_api.Response, error)

func ReleaseLock

func ReleaseLock(c gocoro.Coroutine[*t_aio.Submission, *t_aio.Completion, any], r *t_api.Request) (*t_api.Response, error)

func SchedulePromises

func SchedulePromises(config *system.Config, tags map[string]string) gocoro.CoroutineFunc[*t_aio.Submission, *t_aio.Completion, any]

func SearchPromises

func SearchPromises(c gocoro.Coroutine[*t_aio.Submission, *t_aio.Completion, any], r *t_api.Request) (*t_api.Response, error)

func SearchSchedules

func SearchSchedules(c gocoro.Coroutine[*t_aio.Submission, *t_aio.Completion, any], r *t_api.Request) (*t_api.Response, error)

func TimeoutLocks

func TimeoutLocks(config *system.Config, tags map[string]string) gocoro.CoroutineFunc[*t_aio.Submission, *t_aio.Completion, any]

func TimeoutPromises

func TimeoutPromises(config *system.Config, tags map[string]string) gocoro.CoroutineFunc[*t_aio.Submission, *t_aio.Completion, any]

func TimeoutTasks

func TimeoutTasks(config *system.Config, tags map[string]string) gocoro.CoroutineFunc[*t_aio.Submission, *t_aio.Completion, any]