queue

Documentation

Index

• func Dequeue[T any](q swarm.Queue, category ...string) (<-chan *swarm.Msg[T], chan<- *swarm.Msg[T])
• func Enqueue[T any](q swarm.Queue, category ...string) (chan<- T, <-chan T)
• func EnqueueSync[T any](q swarm.Queue, msg T) error

Functions

func Dequeue

func Dequeue[T any](q swarm.Queue, category ...string) (<-chan *swarm.Msg[T], chan<- *swarm.Msg[T])

Dequeue creates channels to receive Golang structs and send acknowledgement

func Enqueue

func Enqueue[T any](q swarm.Queue, category ...string) (chan<- T, <-chan T)

Enqueue creates channels to enqueue Golang structs and receive dead-letters

func EnqueueSync

func EnqueueSync[T any](q swarm.Queue, msg T) error

EnqueueSync synchronously enqueue message