aggtrade

Documentation

Index

• type AggTrade
  • func (a *AggTrade) Equal(than btree.Item) bool
  • func (a *AggTrade) Less(than btree.Item) bool
• type AggTrades
  • func New(stop chan struct{}, symbol string, ...) *AggTrades
  • func (at *AggTrades) Ascend(iter func(btree.Item) bool)
  • func (at *AggTrades) Delete(id int64)
  • func (at *AggTrades) Descend(iter func(btree.Item) bool)
  • func (at *AggTrades) Get(id int64) btree.Item
  • func (at *AggTrades) IsStreamStarted() bool
  • func (a *AggTrades) Len() int
  • func (at *AggTrades) Lock()
  • func (at *AggTrades) MarkStreamAsStarted()
  • func (at *AggTrades) MarkStreamAsStopped()
  • func (at *AggTrades) ResetEvent(err error)
  • func (at *AggTrades) Set(val btree.Item)
  • func (at *AggTrades) StreamStart() (err error)
  • func (at *AggTrades) StreamStop() (err error)
  • func (at *AggTrades) Symbol() string
  • func (at *AggTrades) Unlock()
  • func (at *AggTrades) Update(val btree.Item)

Types

type AggTrade

type AggTrade struct {
	AggTradeID       int64  `json:"a"`
	Price            string `json:"p"`
	Quantity         string `json:"q"`
	FirstTradeID     int64  `json:"f"`
	LastTradeID      int64  `json:"l"`
	Timestamp        int64  `json:"T"`
	IsBuyerMaker     bool   `json:"m"`
	IsBestPriceMatch bool   `json:"M"`
}

func (*AggTrade) Equal

func (a *AggTrade) Equal(than btree.Item) bool

func (*AggTrade) Less

func (a *AggTrade) Less(than btree.Item) bool

type AggTrades

type AggTrades struct {
	Init types.InitFunction
	// contains filtered or unexported fields
}

func New

func New(
	stop chan struct{},
	symbol string,
	startTradeStream func(*AggTrades) types.StreamFunction,
	initCreator func(*AggTrades) types.InitFunction) *AggTrades

func (*AggTrades) Ascend

func (at *AggTrades) Ascend(iter func(btree.Item) bool)

Ascend implements trades.Trades.

func (*AggTrades) Delete

func (at *AggTrades) Delete(id int64)

func (*AggTrades) Descend

func (at *AggTrades) Descend(iter func(btree.Item) bool)

Descend implements trades.Trades.

func (*AggTrades) Get

func (at *AggTrades) Get(id int64) btree.Item

Get implements trades.Trades.

func (*AggTrades) IsStreamStarted

func (at *AggTrades) IsStreamStarted() bool

func (*AggTrades) Len

func (a *AggTrades) Len() int

func (*AggTrades) Lock

func (at *AggTrades) Lock()

Lock implements trades.Trades.

func (*AggTrades) MarkStreamAsStarted

func (at *AggTrades) MarkStreamAsStarted()

func (*AggTrades) MarkStreamAsStopped

func (at *AggTrades) MarkStreamAsStopped()

func (*AggTrades) ResetEvent

func (at *AggTrades) ResetEvent(err error)

func (*AggTrades) Set

func (at *AggTrades) Set(val btree.Item)

Set implements trades.Trades.

func (*AggTrades) StreamStart

func (at *AggTrades) StreamStart() (err error)

func (*AggTrades) StreamStop

func (at *AggTrades) StreamStop() (err error)

func (*AggTrades) Symbol

func (at *AggTrades) Symbol() string

func (*AggTrades) Unlock

func (at *AggTrades) Unlock()

Unlock implements trades.Trades.

func (*AggTrades) Update

func (at *AggTrades) Update(val btree.Item)

Update implements trades.Trades.