queue

package
v1.0.0-...-a0f063d Latest Latest
Warning

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

Go to latest
Published: Nov 9, 2023 License: MIT Imports: 3 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func Dispatch

func Dispatch(name string, args ...any) error

Dispatch invoke a job asynchronous

func DispatchSync

func DispatchSync(name string, args ...any) error

DispatchSync invoke a job synchronous

func Job

func Job[T queue.Argument | any](job queue.IJob, args ...T) queue.IProducer

func JobByName

func JobByName[T queue.Argument | any](name string, args ...T) queue.IProducer

func Register

func Register(jobs ...queue.IJob) queue.IJobMap

func RegisterWithName

func RegisterWithName(name string, jobFunc queue.JobFunc) queue.IJobMap

RegisterWithName job-func map

func Registers

func Registers(jobMap map[string]queue.JobFunc) queue.IJobMap

func RunServe

func RunServe(connectionName string, queueName string, concurrentCount int) error

RunServe run a queue server

Types

This section is empty.

Jump to

Keyboard shortcuts

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