queue

Apr 7, 2024

Changes in this version

+ func TypeOf[T any]() string

Mar 11, 2024

Changes in this version

+ type Enqueuer interface

+ Enq func(string, T) error

+ Put func(T) error

Nov 13, 2022

Changes in this version

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

type Queue

+ Enqueue func(T) error

May 14, 2022

Changes in this version

+ func Dequeue(q swarm.Queue) (<-chan *swarm.Msg[T], chan<- *swarm.Msg[T])

+ func DequeueBytes(q swarm.Queue, cat string) (<-chan *swarm.Msg[[]byte], chan<- *swarm.Msg[[]byte])

+ func Enqueue(q swarm.Queue) (chan<- T, <-chan T)

+ func EnqueueBytes(q swarm.Queue, cat string) (chan<- []byte, <-chan []byte)

+ func EnqueueSync(q swarm.Queue, msg T) error

Sep 28, 2021

Changes in this version

type Queue

+ func (q *Queue) Wait()

Sep 18, 2021

Changes in this version

type Queue

+ func (q *Queue) Sys() swarm.System

Aug 12, 2021

Changes in this version

+ type Adapter struct

+ ID string

+ Policy *Policy

+ System swarm.System

+ func Adapt(sys swarm.System, service string, id string) *Adapter

+ func (q *Adapter) ConfIO(f func(msg *Msg) error) chan<- *Bag

+ func (q *Adapter) RecvIO(f func() (*Bag, error)) <-chan *Bag

+ func (q *Adapter) SendIO(f func(msg *Bag) error) chan<- *Bag

+ type Bag struct

+ Category swarm.Category

+ Object swarm.Msg

+ Source string

+ StdErr chan<- swarm.Msg

+ Target string

+ type Msg struct

+ Payload []byte

+ Receipt string

+ func (msg *Msg) Bytes() []byte

+ type Policy struct

+ IO backoff.Seq

+ PollFrequency time.Duration

+ TimeToFlight time.Duration

+ type Queue struct

+ ID string

+ System swarm.System

+ func New(sys swarm.System, id string, recv func() (<-chan *Bag, chan<- *Bag), ...) *Queue

+ func (q *Queue) Recv(cat swarm.Category) (<-chan swarm.Msg, chan<- swarm.Msg)

+ func (q *Queue) Send(cat swarm.Category) (chan<- swarm.Msg, <-chan swarm.Msg)