rpc

Documentation

Index

• Variables
• func Sort[C any](ctx context.Context, clients *Clients[C], sortValueFetch SortValueFetcher[C], ...) error
• func WithClients[C any, V any](clients *Clients[C], f func(context.Context, C) (v V, err error)) (v V, err error)
• type Clients
  • func NewClients[C any](maxBlockFetchDuration time.Duration, rollingStrategy RollingStrategy[C], ...) *Clients[C]
  • func (c *Clients[C]) Add(client C)
  • func (c *Clients[C]) StartSorting(ctx context.Context, direction SortDirection, ...)
• type RollingStrategy
• type RollingStrategyAlwaysUseFirst
  • func NewRollingStrategyAlwaysUseFirst[C any]() *RollingStrategyAlwaysUseFirst[C]
• type SortDirection
• type SortValueFetcher
• type StickyRollingStrategy
  • func NewStickyRollingStrategy[C any]() *StickyRollingStrategy[C]

Variables

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

Functions

func Sort

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

func WithClients

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

Types

type Clients

type Clients[C any] struct {
	// contains filtered or unexported fields
}

func NewClients

func NewClients[C any](maxBlockFetchDuration time.Duration, rollingStrategy RollingStrategy[C], logger *zap.Logger) *Clients[C]

func (*Clients[C]) Add

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

func (*Clients[C]) StartSorting

func (c *Clients[C]) StartSorting(ctx context.Context, direction SortDirection, sortValueFetcher SortValueFetcher[C], every time.Duration)

type RollingStrategy

type RollingStrategy[C any] interface {
	// contains filtered or unexported methods
}

type RollingStrategyAlwaysUseFirst

type RollingStrategyAlwaysUseFirst[C any] struct {
	// contains filtered or unexported fields
}

func NewRollingStrategyAlwaysUseFirst

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

type SortDirection

type SortDirection int

const (
	SortDirectionAscending SortDirection = iota
	SortDirectionDescending
)

type SortValueFetcher

type SortValueFetcher[C any] interface {
	FetchSortValue(ctx context.Context, client C) (sortValue uint64, err error)
}

type StickyRollingStrategy

type StickyRollingStrategy[C any] struct {
	// contains filtered or unexported fields
}

func NewStickyRollingStrategy

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