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 Enqueuer
  • func New(q swarm.Broker, category string) Enqueuer

Functions

func Dequeue

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

Dequeue bytes

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 Enqueuer

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

func New

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