queue

Documentation

Index

• func Dequeue[T any](q swarm.Queue, category ...string) (<-chan *swarm.Msg[T], chan<- *swarm.Msg[T])
• func DequeueBytes(q swarm.Queue, cat string) (<-chan *swarm.Msg[[]byte], chan<- *swarm.Msg[[]byte])
• func Enqueue[T any](q swarm.Queue, category ...string) (chan<- T, <-chan T)
• func EnqueueBytes(q swarm.Queue, cat string) (chan<- []byte, <-chan []byte)
• 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 DequeueBytes

func DequeueBytes(q swarm.Queue, cat string) (<-chan *swarm.Msg[[]byte], chan<- *swarm.Msg[[]byte])

DequeueBytes creates channels to receive binary messages 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 EnqueueBytes

func EnqueueBytes(q swarm.Queue, cat string) (chan<- []byte, <-chan []byte)

EnqueueBytes creates channels to enqueue binary messages and receive dead-letters

func EnqueueSync

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

EnqueueSync synchronously enqueue message