queue

package module

v0.16.1 Latest Latest Go to latest Published: Sep 25, 2024 License: Apache-2.0 Imports: 6 Imported by: 1

Details

View Source

const Version = "queue/v0.16.1"

This section is empty.

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

Dequeue message

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

Create egress and dead-letter queue channels for the category

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

func TypeOf[T any]() string

normalized type name

type Enqueuer[T any] interface {
	Put(T) error
	Enq(string, T) error
}

Enqueue message to the broker synchronously, blocking the routine until message is accepted by the broker.

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

Path	Synopsis
bytes
events