swarm

package module

Go to main page

Versions in this module

v0

v0.24.1

Jul 30, 2025

v0.24.0

Jul 17, 2025

Changes in this version

type Event

+ Error error

+ IOContext any

+ func ToEvent[M, T any](bag Bag, evt Event[M, T]) Event[M, T]

type Meta

+ Sink curie.IRI

v0.23.1

Jul 13, 2025

Changes in this version

+ var WithAckCapacity = opts.ForName[Config, int]("CapAck")

+ var WithDeadLetterCapacity = opts.ForName[Config, int]("CapDlq")

+ var WithEmitCapacity = opts.ForName[Config, int]("CapOut")

+ var WithRecvCapacity = opts.ForName[Config, int]("CapRcv")

v0.23.0

Jul 12, 2025

Changes in this version

+ const EnvConfigAgent

+ const EnvConfigRealm

+ var WithAgent = opts.ForName[Config, string]("Agent")

+ var WithRealm = opts.ForName[Config, string]("Realm")

type Config

+ Agent string

+ Realm string

type Meta

+ Realm curie.IRI

v0.22.1

Apr 19, 2025

v0.22.0

Apr 19, 2025

v0.21.0

Mar 15, 2025

Changes in this version

+ const ErrCatUnknown

+ const ErrDecoder

+ const ErrEncoder

+ const ErrRouting

+ type Evt = Msg[Event[M, T]]

v0.20.2

Oct 7, 2024

Changes in this version

type Config

+ PollerPool int

type Option

+ func WithPollerPool(n int) Option

v0.20.1

Sep 30, 2024

Changes in this version

+ const EnvConfigNetworkTimeout

+ const EnvConfigPollFrequency

+ const EnvConfigTimeToFlight

+ func ErrTimeout(op string, timer time.Duration) error

type Bag

+ IOContext any

type Config

+ FailOnUnknownCategory bool

+ PacketCodec Codec

type Msg

+ IOContext any

type Option

+ func WithFailOnUnknownCategory() Option

+ func WithPacketCodec(codec Codec) Option

v0.20.0

Sep 28, 2024

Changes in this version

+ func TypeOf[T any](category ...string) string

type Bag

+ Error error

+ type Codec interface

+ Decode func([]byte) ([]byte, error)

+ Encode func([]byte) ([]byte, error)

type Config

+ CapDlq int

+ Codec Codec

type Event

+ Data *T

+ Meta *M

+ type Meta struct

+ Agent curie.IRI

+ Created time.Time

+ ID string

+ Participant curie.IRI

+ Target curie.IRI

+ Type curie.IRI

type Msg

+ Category string

+ Error error

+ func ToMsg[T any](bag Bag, object T) Msg[T]

v0.16.0

Sep 25, 2024

Changes in this version

+ const Version

v0.15.7

Sep 25, 2024

Changes in this version

+ type CodecPacket struct

+ func NewCodecPacket() CodecPacket

+ func (CodecPacket) Decode(x []byte) ([]byte, error)

+ func (CodecPacket) Encode(x []byte) ([]byte, error)

v0.15.6

Sep 14, 2024

Changes in this version

type Event

+ Target curie.IRI

v0.15.5

Apr 21, 2024

v0.15.4

Apr 10, 2024

v0.15.3

Apr 7, 2024

v0.15.2

Apr 7, 2024

v0.15.1

Mar 23, 2024

v0.15.0

Mar 23, 2024

v0.14.2

Mar 17, 2024

v0.14.1

Mar 17, 2024

v0.14.0

Mar 11, 2024

v0.13.3

Mar 11, 2024

Changes in this version

type Bag

+ Ctx *Context

+ type CodecByte struct

+ func NewCodecByte() CodecByte

+ func (CodecByte) Decode(x []byte) ([]byte, error)

+ func (CodecByte) Encode(x []byte) ([]byte, error)

+ type CodecEvent struct

+ func NewCodecEvent[T any, E EventKind[T]](source, cat string) CodecEvent[T, E]

+ func (c CodecEvent[T, E]) Decode(b []byte) (*E, error)

+ func (c CodecEvent[T, E]) Encode(obj *E) ([]byte, error)

+ type CodecJson struct

+ func NewCodecJson[T any]() CodecJson[T]

+ func (CodecJson[T]) Decode(b []byte) (x T, err error)

+ func (CodecJson[T]) Encode(x T) ([]byte, error)

type Config

+ CapAck int

+ CapDLQ int

+ CapOut int

+ CapRcv int

+ type Context struct

+ Category string

+ Digest string

+ Error error

+ func NewContext(ctx context.Context, cat, digest string) *Context

type Msg

+ Ctx *Context

v0.13.2

Nov 19, 2023

Changes in this version

type Option

+ func WithConfigFromEnv() Option

v0.13.1

Nov 19, 2023

v0.13.0

Nov 18, 2023

Changes in this version

+ const ErrDequeue

+ const ErrEnqueue

+ const ErrServiceIO

+ func LogDeadLetters[T any](out chan<- T, err <-chan T) chan<- T

+ type Digest struct

+ Brief string

+ Error error

type Event

+ func (evt *Event[T]) Fail(err error) *Event[T]

type Option

+ func WithLogStdErr() Option

v0.12.0

Nov 10, 2023

Changes in this version

type Bag

+ Err error

type Event

+ Err error

type Msg

+ Err error

+ func (msg *Msg[T]) Fail(err error) *Msg[T]

v0.11.2

Jul 14, 2023

v0.11.1

Jul 14, 2023

v0.11.0

Dec 3, 2022

Changes in this version

type Config

+ HookCommit func()

type Option

+ func WithHookCommit(hook func()) Option

v0.10.0

Nov 26, 2022

Changes in this version

type Bag

+ Event any

type EvtEnqCh

+ Busy sync.Mutex

type MsgEnqCh

+ Busy sync.Mutex

v0.9.0

Nov 13, 2022

Changes in this version

+ type Broker interface

+ Await func()

+ Close func()

+ Config func() Config

+ DSync func()

+ Dequeue func(string, Channel) Dequeue

+ Enqueue func(string, Channel) Enqueue

+ type Channel interface

+ Close func()

+ Sync func()

+ type Channels struct

+ func NewChannels() *Channels

+ func (chs *Channels) Attach(id string, ch Channel)

+ func (chs *Channels) Close()

+ func (chs *Channels) Length() int

+ func (chs *Channels) Sync()

type Config

+ Backoff Retry

+ DequeueCapacity int

+ EnqueueCapacity int

+ NetworkTimeout time.Duration

+ Policy Policy

+ PollFrequency time.Duration

+ Service any

+ Source string

+ StdErr chan<- error

+ TimeToFlight time.Duration

+ func NewConfig() Config

+ type EvtDeqCh struct

+ Ack chan *E

+ Msg chan *E

+ func NewEvtDeqCh(n int) EvtDeqCh[T, E]

+ func (ch EvtDeqCh[T, E]) Close()

+ func (ch EvtDeqCh[T, E]) Sync()

+ type EvtEnqCh struct

+ Err chan *E

+ Msg chan *E

+ func NewEvtEnqCh(n int) EvtEnqCh[T, E]

+ func (ch EvtEnqCh[T, E]) Close()

+ func (ch EvtEnqCh[T, E]) Sync()

+ type MsgDeqCh struct

+ Ack chan *Msg[T]

+ Msg chan *Msg[T]

+ func NewMsgDeqCh(n int) MsgDeqCh[T]

+ func (ch MsgDeqCh[T]) Close()

+ func (ch MsgDeqCh[T]) Sync()

+ type MsgEnqCh struct

+ Err chan T

+ Msg chan T

+ func NewMsgEnqCh(n int) MsgEnqCh[T]

+ func (ch MsgEnqCh[T]) Close()

+ func (ch MsgEnqCh[T]) Sync()

+ type Option func(conf *Config)

+ func WithNetworkTimeout(t time.Duration) Option

+ func WithPolicyAtLeastOnce(n int) Option

+ func WithPolicyAtMostOnce(n int) Option

+ func WithPollFrequency(t time.Duration) Option

+ func WithRetry(backoff Retry) Option

+ func WithRetryConstant(t time.Duration, n int) Option

+ func WithRetryExponential(t time.Duration, n int, f float64) Option

+ func WithRetryLinear(t time.Duration, n int) Option

+ func WithRetryNo() Option

+ func WithService(service any) Option

+ func WithSource(agent string) Option

+ func WithStdErr(stderr chan<- error) Option

+ func WithTimeToFlight(t time.Duration) Option

type Policy

+ const PolicyAtLeastOnce

+ const PolicyAtMostOnce

+ const PolicyExactlyOnce

+ type Retry interface

+ Retry func(f func() error) error

v0.5.3

Jul 15, 2022

v0.5.2

Jul 7, 2022

v0.5.1

Jul 3, 2022

v0.5.0

Jun 29, 2022

Changes in this version

+ type Event struct

+ Agent curie.IRI

+ Created string

+ Digest string

+ ID string

+ Object T

+ Participant curie.IRI

+ Type curie.IRI

+ func (Event[T]) HKT1(EventType)

+ func (Event[T]) HKT2(T)

+ type EventKind pure.HKT[EventType, A]

+ type EventType any

v0.4.2

Jun 18, 2022

v0.4.1

Jun 18, 2022

v0.4.0

May 14, 2022

Changes in this version

+ type Bag struct

+ Category string

+ Digest string

+ Object []byte

+ Queue string

+ System string

+ type BagStdErr struct

+ StdErr func(error)

+ type Dequeue interface

+ Ack func() chan *Bag

+ Close func() error

+ Deq func() chan *Bag

+ Listen func() error

+ type Enqueue interface

+ Close func() error

+ Enq func() chan *BagStdErr

+ EnqSync func(*Bag) error

+ Listen func() error

type Msg

+ Digest string

+ Object T

+ type Policy struct

+ BackoffIO backoff.Seq

+ PollFrequency time.Duration

+ QueueCapacity int

+ TimeToFlight time.Duration

+ func DefaultPolicy() *Policy

+ func NewPolicy() *Policy

+ func (p *Policy) WithBackoffIO(policy backoff.Seq) *Policy

+ func (p *Policy) WithPollFrequency(t time.Duration) *Policy

+ func (p *Policy) WithQueueCapacity(capacity int) *Policy

+ func (p *Policy) WithTimeToFlight(t time.Duration) *Policy

type Queue

+ Sync func()

type System

+ Close func()

+ Listen func() error

+ Queue func(string, Enqueue, Dequeue, *Policy) Queue

v0.3.2

Sep 28, 2021

Changes in this version

type Queue

+ Wait func()

v0.3.1

Sep 27, 2021

v0.3.0

Sep 18, 2021

Changes in this version

type Queue

+ Sys func() System

v0.2.0

Aug 12, 2021

Changes in this version

+ type Bytes []byte

+ func (b Bytes) Bytes() []byte

+ type Category string

+ type Config func(sys *system)

+ func WithContext(ctx context.Context) Config

+ type Msg interface

+ Bytes func() []byte

+ type Queue interface

+ Recv func(Category) (<-chan Msg, chan<- Msg)

+ Send func(Category) (chan<- Msg, <-chan Msg)

+ func Must(q Queue, err error) Queue

+ type System interface

+ Go func(func(context.Context))

+ ID func() string

+ Stop func()

+ Wait func()

+ func New(id string, opts ...Config) System

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL