rpc

Dec 16, 2024

Changes in this version

+ func Sort[C any](ctx context.Context, clients *Clients[C], sortValueFetch SortValueFetcher[C], ...) error

type Clients

+ func (c *Clients[C]) StartSorting(ctx context.Context, direction SortDirection, ...)

+ type RollingStrategy interface

+ type RollingStrategyAlwaysUseFirst struct

+ func NewRollingStrategyAlwaysUseFirst[C any]() *RollingStrategyAlwaysUseFirst[C]

+ type SortDirection int

+ const SortDirectionAscending

+ const SortDirectionDescending

+ type SortValueFetcher interface

+ FetchSortValue func(ctx context.Context, client C) (sortValue uint64, err error)

+ type StickyRollingStrategy struct

+ func NewStickyRollingStrategy[C any]() *StickyRollingStrategy[C]

Jul 11, 2024

Changes in this version

+ var ErrorNoMoreClient = errors.New("no more clients")

+ func WithClients[C any, V any](clients *Clients[C], f func(C) (v V, err error)) (v V, err error)

+ type Clients struct

+ func NewClients[C any]() *Clients[C]

+ func (c *Clients[C]) Add(client C)

+ func (c *Clients[C]) Next() (client C, err error)