booktickers

Documentation

Index

• type BookTickers
  • func New(stop chan struct{}, degree int, ...) *BookTickers
  • func (btt *BookTickers) Ascend(f func(item btree.Item) bool)
  • func (btt *BookTickers) Descend(f func(item btree.Item) bool)
  • func (btt *BookTickers) Get(symbol string) (item *items_types.BookTicker)
  • func (btt *BookTickers) GetSymbol() string
  • func (bt *BookTickers) IsStreamStarted() bool
  • func (btt *BookTickers) Lock()
  • func (bt *BookTickers) MarkStreamAsStarted()
  • func (bt *BookTickers) MarkStreamAsStopped()
  • func (btt *BookTickers) ResetEvent(err error)
  • func (btt *BookTickers) Set(item *items_types.BookTicker)
  • func (bt *BookTickers) StreamStart(levels int, rate time.Duration, callBack futures.WsBookTickerHandler) (err error)
  • func (bt *BookTickers) StreamStop() (err error)
  • func (btt *BookTickers) TryLock() bool
  • func (btt *BookTickers) Unlock()

Types

type BookTickers

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

func New

func New(
	stop chan struct{},
	degree int,
	startBookTickerStreamCreator func(*BookTickers) types.StreamFunction,
	initCreator func(*BookTickers) types.InitFunction,
	symbols ...string) *BookTickers

func (*BookTickers) Ascend

func (btt *BookTickers) Ascend(f func(item btree.Item) bool)

func (*BookTickers) Descend

func (btt *BookTickers) Descend(f func(item btree.Item) bool)

func (*BookTickers) Get

func (btt *BookTickers) Get(symbol string) (item *items_types.BookTicker)

func (*BookTickers) GetSymbol

func (btt *BookTickers) GetSymbol() string

func (*BookTickers) IsStreamStarted

func (bt *BookTickers) IsStreamStarted() bool

func (*BookTickers) Lock

func (btt *BookTickers) Lock()

func (*BookTickers) MarkStreamAsStarted

func (bt *BookTickers) MarkStreamAsStarted()

func (*BookTickers) MarkStreamAsStopped

func (bt *BookTickers) MarkStreamAsStopped()

func (*BookTickers) ResetEvent

func (btt *BookTickers) ResetEvent(err error)

func (*BookTickers) Set

func (btt *BookTickers) Set(item *items_types.BookTicker)

func (*BookTickers) StreamStart

func (bt *BookTickers) StreamStart(
	levels int,
	rate time.Duration,
	callBack futures.WsBookTickerHandler) (err error)

func (*BookTickers) StreamStop

func (bt *BookTickers) StreamStop() (err error)

func (*BookTickers) TryLock

func (btt *BookTickers) TryLock() bool

func (*BookTickers) Unlock

func (btt *BookTickers) Unlock()