depth

Documentation

Index

• type Buffer
  • 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)
• type SnapshotFetcher
• type Update

Types

type Buffer

type Buffer struct {
	// contains filtered or unexported fields
}

func NewBuffer

func NewBuffer(fetcher SnapshotFetcher) *Buffer

func (*Buffer) AddUpdate

func (b *Buffer) AddUpdate(o types.SliceOrderBook, firstUpdateID int64, finalArgs ...int64) error

AddUpdate adds the update to the buffer or push the update to the subscriber

func (*Buffer) EmitPush

func (b *Buffer) EmitPush(update Update)

func (*Buffer) EmitReady

func (b *Buffer) EmitReady(snapshot types.SliceOrderBook, updates []Update)

func (*Buffer) EmitReset

func (b *Buffer) EmitReset()

func (*Buffer) OnPush

func (b *Buffer) OnPush(cb func(update Update))

func (*Buffer) OnReady

func (b *Buffer) OnReady(cb func(snapshot types.SliceOrderBook, updates []Update))

func (*Buffer) OnReset

func (b *Buffer) OnReset(cb func())

func (*Buffer) Reset

func (b *Buffer) Reset()

func (*Buffer) SetBufferingPeriod

func (b *Buffer) SetBufferingPeriod(d time.Duration)

type SnapshotFetcher

type SnapshotFetcher func() (snapshot types.SliceOrderBook, finalUpdateID int64, err error)

type Update

type Update struct {
	FirstUpdateID, FinalUpdateID int64

	// Object is the update object
	Object types.SliceOrderBook
}