bytes

Documentation

Index

• func Dequeue(q swarm.Broker, cat string) (<-chan *swarm.Msg[[]byte], chan<- *swarm.Msg[[]byte])
• func Enqueue(q swarm.Broker, cat string) (chan<- []byte, <-chan []byte)
• type Queue
  • func New(q swarm.Broker, category string) Queue

Functions

func Dequeue

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

Dequeue ...

func Enqueue

func Enqueue(q swarm.Broker, cat string) (chan<- []byte, <-chan []byte)

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

Types

type Queue

type Queue interface {
	Enqueue([]byte) error
}

func New

func New(q swarm.Broker, category string) Queue