queue

Documentation

Index

• func Dequeue[T any](q swarm.Broker, category ...string) (<-chan *swarm.Msg[T], chan<- *swarm.Msg[T])
• func Enqueue[T any](q swarm.Broker, category ...string) (chan<- T, <-chan T)
• func Must(broker swarm.Broker, err error) swarm.Broker
• type Queue
  • func New[T any](q swarm.Broker, category ...string) Queue[T]

Functions

func Dequeue

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

Dequeue ...

func Enqueue

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

Enqueue creates pair of channels to send messages and dead-letter queue

func Must

func Must(broker swarm.Broker, err error) swarm.Broker

Types

type Queue

type Queue[T any] interface {
	Enqueue(T) error
}

func New

func New[T any](q swarm.Broker, category ...string) Queue[T]