Versions in this module Expand all Collapse all v0 v0.6.0 Nov 27, 2021 Changes in this version + var FetchPolicies = []FetchPolicy + type Barrel struct + BatchId string + D []byte + MouldId string + Time int64 + func FromBytes(b []byte) (barrel Barrel, err error) + func NewBarrel(mouldId, batchId string, d []byte) Barrel + func (z Barrel) BarrelBatch() string + func (z Barrel) ToBytes() (d []byte) + type Bundle interface + Close func() + Complete func(b Barrel) + Enqueue func(b Barrel) + Fetch func() (b Barrel, found bool) + Preserve func() (session Session, err error) + Size func() (total int) + SizeInProgress func() int + func NewSimple(logger esl.Logger, policy FetchPolicy, progress eq_progress.Progress, ...) Bundle + func RestoreSimple(logger esl.Logger, policy FetchPolicy, progress eq_progress.Progress, ...) (b Bundle, err error) + type FetchPolicy string + const FetchBalance + const FetchRandom + const FetchSequential + type OnCompleteHandler func(batchId string, completed, total int) + type Session struct + InProgress eq_pipe.SessionId + Pipes map[string]eq_pipe.SessionId
Go to main page