Versions in this module Expand all Collapse all v0 v0.4.1 Jul 4, 2025 Changes in this version + func ApplyGroup[T any](ops []SetOption[T], o *Options[T]) + type Client interface + Close func() (err error) + Done func() <-chan struct{} + Err func() (err error) + Forget func(seq core.Seq) + Has func(seq core.Seq) bool + Send func(cmd core.Cmd[T], results chan<- core.AsyncResult) (seq core.Seq, n int, err error) + SendWithDeadline func(cmd core.Cmd[T], results chan<- core.AsyncResult, deadline time.Time) (seq core.Seq, n int, err error) + type ClientGroup struct + func NewClientGroup[T any](strategy DispatchStrategy[Client[T]]) (group ClientGroup[T]) + func (s ClientGroup[T]) Close() (err error) + func (s ClientGroup[T]) Done() <-chan struct{} + func (s ClientGroup[T]) Err() (err error) + func (s ClientGroup[T]) Forget(seq core.Seq, clientID ClientID) + func (s ClientGroup[T]) Has(seq core.Seq, clientID ClientID) (ok bool) + func (s ClientGroup[T]) Send(cmd core.Cmd[T], results chan<- core.AsyncResult) (seq core.Seq, clientID ClientID, n int, err error) + func (s ClientGroup[T]) SendWithDeadline(cmd core.Cmd[T], results chan<- core.AsyncResult, deadline time.Time) (seq core.Seq, clientID ClientID, n int, err error) + func (s ClientGroup[T]) Size() int + type ClientID int + type DispatchStrategy interface + Next func() (t T, index int64) + Slice func() []T + type DispatchStrategyFactory interface + New func(clients []Client[T]) DispatchStrategy[Client[T]] + type Options struct + ClientOps []cln.SetOption + Factory DispatchStrategyFactory[T] + Reconnect bool + type RoundRobinStrategy struct + func NewRoundRobinStrategy[T any](sl []T) RoundRobinStrategy[T] + func (s RoundRobinStrategy[T]) Next() (t T, index int64) + func (s RoundRobinStrategy[T]) Slice() []T + type RoundRobinStrategyFactory struct + func (RoundRobinStrategyFactory[T]) New(clients []Client[T]) DispatchStrategy[Client[T]] + type SetOption func(o *Options[T]) + func WithClientOps[T any](ops ...cln.SetOption) SetOption[T] + func WithFactory[T any](factory DispatchStrategyFactory[T]) SetOption[T] + func WithReconnect[T any]() SetOption[T]
Go to main page