events

Documentation

Index

• func Dequeue[T any, E swarm.EventKind[T]](q swarm.Broker, category ...string) (<-chan *E, chan<- *E)
• func Enqueue[T any, E swarm.EventKind[T]](q swarm.Broker, category ...string) (chan<- *E, <-chan *E)
• type Queue
  • func New[T any, E swarm.EventKind[T]](q swarm.Broker, category ...string) Queue[T, E]

Functions

func Dequeue

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

Dequeue ...

func Enqueue

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

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

Types

type Queue

type Queue[T any, E swarm.EventKind[T]] interface {
	Enqueue(*E) error
}

func New

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