Versions in this module Expand all Collapse all v0 v0.0.1 May 4, 2024 Changes in this version + type Buffer struct + func NewBuffer(fetcher SnapshotFetcher) *Buffer + func (b *Buffer) AddUpdate(o types.SliceOrderBook, firstUpdateID int64, finalArgs ...int64) error + func (b *Buffer) EmitPush(update Update) + func (b *Buffer) EmitReady(snapshot types.SliceOrderBook, updates []Update) + func (b *Buffer) EmitReset() + func (b *Buffer) OnPush(cb func(update Update)) + func (b *Buffer) OnReady(cb func(snapshot types.SliceOrderBook, updates []Update)) + func (b *Buffer) OnReset(cb func()) + func (b *Buffer) Reset() + func (b *Buffer) SetBufferingPeriod(d time.Duration) + func (b *Buffer) SetUpdateTimeout(d time.Duration) + type SnapshotFetcher func() (snapshot types.SliceOrderBook, finalUpdateID int64, err error) + type Update struct + FinalUpdateID int64 + FirstUpdateID int64 + Object types.SliceOrderBook
Go to main page