Versions in this module Expand all Collapse all v1 v1.21.0 Feb 1, 2024 Changes in this version + var ErrEmptyPool = fmt.Errorf("pool is empty") + type ParameterPool struct + func NewParameterPool[T any](logger log.StandardLogger, scheduler *Scheduler, persistence Persistence[T], ...) *ParameterPool[T] + func (pp *ParameterPool[T]) GetNow() (*T, error) + func (pp *ParameterPool[T]) ParametersCount() int + type Persisted struct + Data S + ID string + type Persistence interface + Delete func(*Persisted[T]) error + ReadAll func() ([]*Persisted[T], error) + Save func(*T) (*Persisted[T], error) + type Protocol interface + IsExecuting func() bool + type ProtocolLatch struct + func NewProtocolLatch() *ProtocolLatch + func (pl *ProtocolLatch) IsExecuting() bool + func (pl *ProtocolLatch) Lock() + func (pl *ProtocolLatch) Unlock() + type Scheduler struct + func StartScheduler() *Scheduler + func (s *Scheduler) RegisterProtocol(protocol Protocol)