Versions in this module Expand all Collapse all v1 v1.0.2 Aug 20, 2019 Changes in this version + var ErrIntOverflowAsset = fmt.Errorf("proto: integer overflow") + var ErrIntOverflowIndex = fmt.Errorf("proto: integer overflow") + var ErrIntOverflowMarket = fmt.Errorf("proto: integer overflow") + var ErrIntOverflowPair = fmt.Errorf("proto: integer overflow") + var ErrInvalidLengthAsset = fmt.Errorf("proto: negative length found during unmarshaling") + var ErrInvalidLengthIndex = fmt.Errorf("proto: negative length found during unmarshaling") + var ErrInvalidLengthMarket = fmt.Errorf("proto: negative length found during unmarshaling") + var ErrInvalidLengthPair = fmt.Errorf("proto: negative length found during unmarshaling") + type AssetUSDVolumeUpdate struct + Volume string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*AssetUSDVolumeUpdate) Descriptor() ([]byte, []int) + func (*AssetUSDVolumeUpdate) ProtoMessage() + func (dst *AssetUSDVolumeUpdate) XXX_Merge(src proto.Message) + func (m *AssetUSDVolumeUpdate) GetVolume() string + func (m *AssetUSDVolumeUpdate) Marshal() (dAtA []byte, err error) + func (m *AssetUSDVolumeUpdate) MarshalTo(dAtA []byte) (int, error) + func (m *AssetUSDVolumeUpdate) Reset() + func (m *AssetUSDVolumeUpdate) Size() (n int) + func (m *AssetUSDVolumeUpdate) String() string + func (m *AssetUSDVolumeUpdate) Unmarshal(dAtA []byte) error + func (m *AssetUSDVolumeUpdate) XXX_DiscardUnknown() + func (m *AssetUSDVolumeUpdate) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *AssetUSDVolumeUpdate) XXX_Size() int + func (m *AssetUSDVolumeUpdate) XXX_Unmarshal(b []byte) error + type AssetUpdateMessage struct + Asset int32 + Update isAssetUpdateMessage_Update + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*AssetUpdateMessage) Descriptor() ([]byte, []int) + func (*AssetUpdateMessage) ProtoMessage() + func (*AssetUpdateMessage) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, ...) + func (dst *AssetUpdateMessage) XXX_Merge(src proto.Message) + func (m *AssetUpdateMessage) GetAsset() int32 + func (m *AssetUpdateMessage) GetUpdate() isAssetUpdateMessage_Update + func (m *AssetUpdateMessage) GetUsdVolumeUpdate() *AssetUSDVolumeUpdate + func (m *AssetUpdateMessage) Marshal() (dAtA []byte, err error) + func (m *AssetUpdateMessage) MarshalTo(dAtA []byte) (int, error) + func (m *AssetUpdateMessage) Reset() + func (m *AssetUpdateMessage) Size() (n int) + func (m *AssetUpdateMessage) String() string + func (m *AssetUpdateMessage) Unmarshal(dAtA []byte) error + func (m *AssetUpdateMessage) XXX_DiscardUnknown() + func (m *AssetUpdateMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *AssetUpdateMessage) XXX_Size() int + func (m *AssetUpdateMessage) XXX_Unmarshal(b []byte) error + type AssetUpdateMessage_UsdVolumeUpdate struct + UsdVolumeUpdate *AssetUSDVolumeUpdate + func (m *AssetUpdateMessage_UsdVolumeUpdate) MarshalTo(dAtA []byte) (int, error) + func (m *AssetUpdateMessage_UsdVolumeUpdate) Size() (n int) + type Index struct + CwIndex bool + ExchangeId uint64 + Id uint64 + IndexType string + InstrumentId uint64 + Symbol string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Index) Descriptor() ([]byte, []int) + func (*Index) ProtoMessage() + func (dst *Index) XXX_Merge(src proto.Message) + func (m *Index) GetCwIndex() bool + func (m *Index) GetExchangeId() uint64 + func (m *Index) GetId() uint64 + func (m *Index) GetIndexType() string + func (m *Index) GetInstrumentId() uint64 + func (m *Index) GetSymbol() string + func (m *Index) Marshal() (dAtA []byte, err error) + func (m *Index) MarshalTo(dAtA []byte) (int, error) + func (m *Index) Reset() + func (m *Index) Size() (n int) + func (m *Index) String() string + func (m *Index) Unmarshal(dAtA []byte) error + func (m *Index) XXX_DiscardUnknown() + func (m *Index) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Index) XXX_Size() int + func (m *Index) XXX_Unmarshal(b []byte) error + type IndexUpdateMessage struct + Index *Index + Update isIndexUpdateMessage_Update + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*IndexUpdateMessage) Descriptor() ([]byte, []int) + func (*IndexUpdateMessage) ProtoMessage() + func (*IndexUpdateMessage) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, ...) + func (dst *IndexUpdateMessage) XXX_Merge(src proto.Message) + func (m *IndexUpdateMessage) GetIndex() *Index + func (m *IndexUpdateMessage) GetIntervalsUpdate() *IntervalsUpdate + func (m *IndexUpdateMessage) GetSparklineUpdate() *SparklineUpdate + func (m *IndexUpdateMessage) GetSummaryUpdate() *SummaryUpdate + func (m *IndexUpdateMessage) GetTickerUpdate() *TickerUpdate + func (m *IndexUpdateMessage) GetUpdate() isIndexUpdateMessage_Update + func (m *IndexUpdateMessage) Marshal() (dAtA []byte, err error) + func (m *IndexUpdateMessage) MarshalTo(dAtA []byte) (int, error) + func (m *IndexUpdateMessage) Reset() + func (m *IndexUpdateMessage) Size() (n int) + func (m *IndexUpdateMessage) String() string + func (m *IndexUpdateMessage) Unmarshal(dAtA []byte) error + func (m *IndexUpdateMessage) XXX_DiscardUnknown() + func (m *IndexUpdateMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *IndexUpdateMessage) XXX_Size() int + func (m *IndexUpdateMessage) XXX_Unmarshal(b []byte) error + type IndexUpdateMessage_IntervalsUpdate struct + IntervalsUpdate *IntervalsUpdate + func (m *IndexUpdateMessage_IntervalsUpdate) MarshalTo(dAtA []byte) (int, error) + func (m *IndexUpdateMessage_IntervalsUpdate) Size() (n int) + type IndexUpdateMessage_SparklineUpdate struct + SparklineUpdate *SparklineUpdate + func (m *IndexUpdateMessage_SparklineUpdate) MarshalTo(dAtA []byte) (int, error) + func (m *IndexUpdateMessage_SparklineUpdate) Size() (n int) + type IndexUpdateMessage_SummaryUpdate struct + SummaryUpdate *SummaryUpdate + func (m *IndexUpdateMessage_SummaryUpdate) MarshalTo(dAtA []byte) (int, error) + func (m *IndexUpdateMessage_SummaryUpdate) Size() (n int) + type IndexUpdateMessage_TickerUpdate struct + TickerUpdate *TickerUpdate + func (m *IndexUpdateMessage_TickerUpdate) MarshalTo(dAtA []byte) (int, error) + func (m *IndexUpdateMessage_TickerUpdate) Size() (n int) + type Interval struct + Closetime int64 + Ohlc *Interval_OHLC + Period int32 + VolumeBase float32 + VolumeBaseStr string + VolumeQuote float32 + VolumeQuoteStr string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Interval) Descriptor() ([]byte, []int) + func (*Interval) ProtoMessage() + func (dst *Interval) XXX_Merge(src proto.Message) + func (m *Interval) GetClosetime() int64 + func (m *Interval) GetOhlc() *Interval_OHLC + func (m *Interval) GetPeriod() int32 + func (m *Interval) GetVolumeBase() float32 + func (m *Interval) GetVolumeBaseStr() string + func (m *Interval) GetVolumeQuote() float32 + func (m *Interval) GetVolumeQuoteStr() string + func (m *Interval) Marshal() (dAtA []byte, err error) + func (m *Interval) MarshalTo(dAtA []byte) (int, error) + func (m *Interval) Reset() + func (m *Interval) Size() (n int) + func (m *Interval) String() string + func (m *Interval) Unmarshal(dAtA []byte) error + func (m *Interval) XXX_DiscardUnknown() + func (m *Interval) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Interval) XXX_Size() int + func (m *Interval) XXX_Unmarshal(b []byte) error + type Interval_OHLC struct + Close float32 + CloseStr string + High float32 + HighStr string + Low float32 + LowStr string + Open float32 + OpenStr string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Interval_OHLC) Descriptor() ([]byte, []int) + func (*Interval_OHLC) ProtoMessage() + func (dst *Interval_OHLC) XXX_Merge(src proto.Message) + func (m *Interval_OHLC) GetClose() float32 + func (m *Interval_OHLC) GetCloseStr() string + func (m *Interval_OHLC) GetHigh() float32 + func (m *Interval_OHLC) GetHighStr() string + func (m *Interval_OHLC) GetLow() float32 + func (m *Interval_OHLC) GetLowStr() string + func (m *Interval_OHLC) GetOpen() float32 + func (m *Interval_OHLC) GetOpenStr() string + func (m *Interval_OHLC) Marshal() (dAtA []byte, err error) + func (m *Interval_OHLC) MarshalTo(dAtA []byte) (int, error) + func (m *Interval_OHLC) Reset() + func (m *Interval_OHLC) Size() (n int) + func (m *Interval_OHLC) String() string + func (m *Interval_OHLC) Unmarshal(dAtA []byte) error + func (m *Interval_OHLC) XXX_DiscardUnknown() + func (m *Interval_OHLC) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Interval_OHLC) XXX_Size() int + func (m *Interval_OHLC) XXX_Unmarshal(b []byte) error + type IntervalsUpdate struct + Intervals []*Interval + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*IntervalsUpdate) Descriptor() ([]byte, []int) + func (*IntervalsUpdate) ProtoMessage() + func (dst *IntervalsUpdate) XXX_Merge(src proto.Message) + func (m *IntervalsUpdate) GetIntervals() []*Interval + func (m *IntervalsUpdate) Marshal() (dAtA []byte, err error) + func (m *IntervalsUpdate) MarshalTo(dAtA []byte) (int, error) + func (m *IntervalsUpdate) Reset() + func (m *IntervalsUpdate) Size() (n int) + func (m *IntervalsUpdate) String() string + func (m *IntervalsUpdate) Unmarshal(dAtA []byte) error + func (m *IntervalsUpdate) XXX_DiscardUnknown() + func (m *IntervalsUpdate) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *IntervalsUpdate) XXX_Size() int + func (m *IntervalsUpdate) XXX_Unmarshal(b []byte) error + type Market struct + CurrencyPair string + CurrencyPairId uint64 + Exchange string + ExchangeId uint64 + MarketId uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Market) Descriptor() ([]byte, []int) + func (*Market) ProtoMessage() + func (dst *Market) XXX_Merge(src proto.Message) + func (m *Market) GetCurrencyPair() string + func (m *Market) GetCurrencyPairId() uint64 + func (m *Market) GetExchange() string + func (m *Market) GetExchangeId() uint64 + func (m *Market) GetMarketId() uint64 + func (m *Market) Marshal() (dAtA []byte, err error) + func (m *Market) MarshalTo(dAtA []byte) (int, error) + func (m *Market) Reset() + func (m *Market) Size() (n int) + func (m *Market) String() string + func (m *Market) Unmarshal(dAtA []byte) error + func (m *Market) XXX_DiscardUnknown() + func (m *Market) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Market) XXX_Size() int + func (m *Market) XXX_Unmarshal(b []byte) error + type MarketUpdateMessage struct + Market *Market + Update isMarketUpdateMessage_Update + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*MarketUpdateMessage) Descriptor() ([]byte, []int) + func (*MarketUpdateMessage) ProtoMessage() + func (*MarketUpdateMessage) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, ...) + func (dst *MarketUpdateMessage) XXX_Merge(src proto.Message) + func (m *MarketUpdateMessage) GetIntervalsUpdate() *IntervalsUpdate + func (m *MarketUpdateMessage) GetMarket() *Market + func (m *MarketUpdateMessage) GetOrderBookDeltaUpdate() *OrderBookDeltaUpdate + func (m *MarketUpdateMessage) GetOrderBookLiquidityUpdate() *OrderBookLiquidityUpdate + func (m *MarketUpdateMessage) GetOrderBookSpreadUpdate() *OrderBookSpreadUpdate + func (m *MarketUpdateMessage) GetOrderBookUpdate() *OrderBookUpdate + func (m *MarketUpdateMessage) GetSparklineUpdate() *SparklineUpdate + func (m *MarketUpdateMessage) GetSummaryUpdate() *SummaryUpdate + func (m *MarketUpdateMessage) GetTradesUpdate() *TradesUpdate + func (m *MarketUpdateMessage) GetUpdate() isMarketUpdateMessage_Update + func (m *MarketUpdateMessage) Marshal() (dAtA []byte, err error) + func (m *MarketUpdateMessage) MarshalTo(dAtA []byte) (int, error) + func (m *MarketUpdateMessage) Reset() + func (m *MarketUpdateMessage) Size() (n int) + func (m *MarketUpdateMessage) String() string + func (m *MarketUpdateMessage) Unmarshal(dAtA []byte) error + func (m *MarketUpdateMessage) XXX_DiscardUnknown() + func (m *MarketUpdateMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *MarketUpdateMessage) XXX_Size() int + func (m *MarketUpdateMessage) XXX_Unmarshal(b []byte) error + type MarketUpdateMessage_IntervalsUpdate struct + IntervalsUpdate *IntervalsUpdate + func (m *MarketUpdateMessage_IntervalsUpdate) MarshalTo(dAtA []byte) (int, error) + func (m *MarketUpdateMessage_IntervalsUpdate) Size() (n int) + type MarketUpdateMessage_OrderBookDeltaUpdate struct + OrderBookDeltaUpdate *OrderBookDeltaUpdate + func (m *MarketUpdateMessage_OrderBookDeltaUpdate) MarshalTo(dAtA []byte) (int, error) + func (m *MarketUpdateMessage_OrderBookDeltaUpdate) Size() (n int) + type MarketUpdateMessage_OrderBookLiquidityUpdate struct + OrderBookLiquidityUpdate *OrderBookLiquidityUpdate + func (m *MarketUpdateMessage_OrderBookLiquidityUpdate) MarshalTo(dAtA []byte) (int, error) + func (m *MarketUpdateMessage_OrderBookLiquidityUpdate) Size() (n int) + type MarketUpdateMessage_OrderBookSpreadUpdate struct + OrderBookSpreadUpdate *OrderBookSpreadUpdate + func (m *MarketUpdateMessage_OrderBookSpreadUpdate) MarshalTo(dAtA []byte) (int, error) + func (m *MarketUpdateMessage_OrderBookSpreadUpdate) Size() (n int) + type MarketUpdateMessage_OrderBookUpdate struct + OrderBookUpdate *OrderBookUpdate + func (m *MarketUpdateMessage_OrderBookUpdate) MarshalTo(dAtA []byte) (int, error) + func (m *MarketUpdateMessage_OrderBookUpdate) Size() (n int) + type MarketUpdateMessage_SparklineUpdate struct + SparklineUpdate *SparklineUpdate + func (m *MarketUpdateMessage_SparklineUpdate) MarshalTo(dAtA []byte) (int, error) + func (m *MarketUpdateMessage_SparklineUpdate) Size() (n int) + type MarketUpdateMessage_SummaryUpdate struct + SummaryUpdate *SummaryUpdate + func (m *MarketUpdateMessage_SummaryUpdate) MarshalTo(dAtA []byte) (int, error) + func (m *MarketUpdateMessage_SummaryUpdate) Size() (n int) + type MarketUpdateMessage_TradesUpdate struct + TradesUpdate *TradesUpdate + func (m *MarketUpdateMessage_TradesUpdate) MarshalTo(dAtA []byte) (int, error) + func (m *MarketUpdateMessage_TradesUpdate) Size() (n int) + type Order struct + Amount float32 + AmountStr string + Price float32 + PriceStr string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Order) Descriptor() ([]byte, []int) + func (*Order) ProtoMessage() + func (dst *Order) XXX_Merge(src proto.Message) + func (m *Order) GetAmount() float32 + func (m *Order) GetAmountStr() string + func (m *Order) GetPrice() float32 + func (m *Order) GetPriceStr() string + func (m *Order) Marshal() (dAtA []byte, err error) + func (m *Order) MarshalTo(dAtA []byte) (int, error) + func (m *Order) Reset() + func (m *Order) Size() (n int) + func (m *Order) String() string + func (m *Order) Unmarshal(dAtA []byte) error + func (m *Order) XXX_DiscardUnknown() + func (m *Order) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Order) XXX_Size() int + func (m *Order) XXX_Unmarshal(b []byte) error + type OrderBookDeltaUpdate struct + AggregationModulus float32 + AggregationModulusStr string + Asks *OrderBookDeltaUpdate_OrderDeltas + Bids *OrderBookDeltaUpdate_OrderDeltas + SeqNum int32 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*OrderBookDeltaUpdate) Descriptor() ([]byte, []int) + func (*OrderBookDeltaUpdate) ProtoMessage() + func (dst *OrderBookDeltaUpdate) XXX_Merge(src proto.Message) + func (m *OrderBookDeltaUpdate) GetAggregationModulus() float32 + func (m *OrderBookDeltaUpdate) GetAggregationModulusStr() string + func (m *OrderBookDeltaUpdate) GetAsks() *OrderBookDeltaUpdate_OrderDeltas + func (m *OrderBookDeltaUpdate) GetBids() *OrderBookDeltaUpdate_OrderDeltas + func (m *OrderBookDeltaUpdate) GetSeqNum() int32 + func (m *OrderBookDeltaUpdate) Marshal() (dAtA []byte, err error) + func (m *OrderBookDeltaUpdate) MarshalTo(dAtA []byte) (int, error) + func (m *OrderBookDeltaUpdate) Reset() + func (m *OrderBookDeltaUpdate) Size() (n int) + func (m *OrderBookDeltaUpdate) String() string + func (m *OrderBookDeltaUpdate) Unmarshal(dAtA []byte) error + func (m *OrderBookDeltaUpdate) XXX_DiscardUnknown() + func (m *OrderBookDeltaUpdate) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *OrderBookDeltaUpdate) XXX_Size() int + func (m *OrderBookDeltaUpdate) XXX_Unmarshal(b []byte) error + type OrderBookDeltaUpdate_OrderDeltas struct + Delta []*Order + Remove []float32 + RemoveStr []string + Set []*Order + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*OrderBookDeltaUpdate_OrderDeltas) Descriptor() ([]byte, []int) + func (*OrderBookDeltaUpdate_OrderDeltas) ProtoMessage() + func (dst *OrderBookDeltaUpdate_OrderDeltas) XXX_Merge(src proto.Message) + func (m *OrderBookDeltaUpdate_OrderDeltas) GetDelta() []*Order + func (m *OrderBookDeltaUpdate_OrderDeltas) GetRemove() []float32 + func (m *OrderBookDeltaUpdate_OrderDeltas) GetRemoveStr() []string + func (m *OrderBookDeltaUpdate_OrderDeltas) GetSet() []*Order + func (m *OrderBookDeltaUpdate_OrderDeltas) Marshal() (dAtA []byte, err error) + func (m *OrderBookDeltaUpdate_OrderDeltas) MarshalTo(dAtA []byte) (int, error) + func (m *OrderBookDeltaUpdate_OrderDeltas) Reset() + func (m *OrderBookDeltaUpdate_OrderDeltas) Size() (n int) + func (m *OrderBookDeltaUpdate_OrderDeltas) String() string + func (m *OrderBookDeltaUpdate_OrderDeltas) Unmarshal(dAtA []byte) error + func (m *OrderBookDeltaUpdate_OrderDeltas) XXX_DiscardUnknown() + func (m *OrderBookDeltaUpdate_OrderDeltas) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *OrderBookDeltaUpdate_OrderDeltas) XXX_Size() int + func (m *OrderBookDeltaUpdate_OrderDeltas) XXX_Unmarshal(b []byte) error + type OrderBookLiquidityUpdate struct + Ask *OrderBookLiquidityUpdate_OrderBookLiquidityUpdateSide + Bid *OrderBookLiquidityUpdate_OrderBookLiquidityUpdateSide + Timestamp int64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*OrderBookLiquidityUpdate) Descriptor() ([]byte, []int) + func (*OrderBookLiquidityUpdate) ProtoMessage() + func (dst *OrderBookLiquidityUpdate) XXX_Merge(src proto.Message) + func (m *OrderBookLiquidityUpdate) GetAsk() *OrderBookLiquidityUpdate_OrderBookLiquidityUpdateSide + func (m *OrderBookLiquidityUpdate) GetBid() *OrderBookLiquidityUpdate_OrderBookLiquidityUpdateSide + func (m *OrderBookLiquidityUpdate) GetTimestamp() int64 + func (m *OrderBookLiquidityUpdate) Marshal() (dAtA []byte, err error) + func (m *OrderBookLiquidityUpdate) MarshalTo(dAtA []byte) (int, error) + func (m *OrderBookLiquidityUpdate) Reset() + func (m *OrderBookLiquidityUpdate) Size() (n int) + func (m *OrderBookLiquidityUpdate) String() string + func (m *OrderBookLiquidityUpdate) Unmarshal(dAtA []byte) error + func (m *OrderBookLiquidityUpdate) XXX_DiscardUnknown() + func (m *OrderBookLiquidityUpdate) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *OrderBookLiquidityUpdate) XXX_Size() int + func (m *OrderBookLiquidityUpdate) XXX_Unmarshal(b []byte) error + type OrderBookLiquidityUpdate_OrderBookLiquiditySums struct + TotalBase string + TotalQuote string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*OrderBookLiquidityUpdate_OrderBookLiquiditySums) Descriptor() ([]byte, []int) + func (*OrderBookLiquidityUpdate_OrderBookLiquiditySums) ProtoMessage() + func (dst *OrderBookLiquidityUpdate_OrderBookLiquiditySums) XXX_Merge(src proto.Message) + func (m *OrderBookLiquidityUpdate_OrderBookLiquiditySums) GetTotalBase() string + func (m *OrderBookLiquidityUpdate_OrderBookLiquiditySums) GetTotalQuote() string + func (m *OrderBookLiquidityUpdate_OrderBookLiquiditySums) Marshal() (dAtA []byte, err error) + func (m *OrderBookLiquidityUpdate_OrderBookLiquiditySums) MarshalTo(dAtA []byte) (int, error) + func (m *OrderBookLiquidityUpdate_OrderBookLiquiditySums) Reset() + func (m *OrderBookLiquidityUpdate_OrderBookLiquiditySums) Size() (n int) + func (m *OrderBookLiquidityUpdate_OrderBookLiquiditySums) String() string + func (m *OrderBookLiquidityUpdate_OrderBookLiquiditySums) Unmarshal(dAtA []byte) error + func (m *OrderBookLiquidityUpdate_OrderBookLiquiditySums) XXX_DiscardUnknown() + func (m *OrderBookLiquidityUpdate_OrderBookLiquiditySums) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *OrderBookLiquidityUpdate_OrderBookLiquiditySums) XXX_Size() int + func (m *OrderBookLiquidityUpdate_OrderBookLiquiditySums) XXX_Unmarshal(b []byte) error + type OrderBookLiquidityUpdate_OrderBookLiquidityUpdateSide struct + Bip100 *OrderBookLiquidityUpdate_OrderBookLiquiditySums + Bip150 *OrderBookLiquidityUpdate_OrderBookLiquiditySums + Bip200 *OrderBookLiquidityUpdate_OrderBookLiquiditySums + Bip25 *OrderBookLiquidityUpdate_OrderBookLiquiditySums + Bip250 *OrderBookLiquidityUpdate_OrderBookLiquiditySums + Bip300 *OrderBookLiquidityUpdate_OrderBookLiquiditySums + Bip400 *OrderBookLiquidityUpdate_OrderBookLiquiditySums + Bip50 *OrderBookLiquidityUpdate_OrderBookLiquiditySums + Bip500 *OrderBookLiquidityUpdate_OrderBookLiquiditySums + Bip75 *OrderBookLiquidityUpdate_OrderBookLiquiditySums + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*OrderBookLiquidityUpdate_OrderBookLiquidityUpdateSide) Descriptor() ([]byte, []int) + func (*OrderBookLiquidityUpdate_OrderBookLiquidityUpdateSide) ProtoMessage() + func (dst *OrderBookLiquidityUpdate_OrderBookLiquidityUpdateSide) XXX_Merge(src proto.Message) + func (m *OrderBookLiquidityUpdate_OrderBookLiquidityUpdateSide) GetBip100() *OrderBookLiquidityUpdate_OrderBookLiquiditySums + func (m *OrderBookLiquidityUpdate_OrderBookLiquidityUpdateSide) GetBip150() *OrderBookLiquidityUpdate_OrderBookLiquiditySums + func (m *OrderBookLiquidityUpdate_OrderBookLiquidityUpdateSide) GetBip200() *OrderBookLiquidityUpdate_OrderBookLiquiditySums + func (m *OrderBookLiquidityUpdate_OrderBookLiquidityUpdateSide) GetBip25() *OrderBookLiquidityUpdate_OrderBookLiquiditySums + func (m *OrderBookLiquidityUpdate_OrderBookLiquidityUpdateSide) GetBip250() *OrderBookLiquidityUpdate_OrderBookLiquiditySums + func (m *OrderBookLiquidityUpdate_OrderBookLiquidityUpdateSide) GetBip300() *OrderBookLiquidityUpdate_OrderBookLiquiditySums + func (m *OrderBookLiquidityUpdate_OrderBookLiquidityUpdateSide) GetBip400() *OrderBookLiquidityUpdate_OrderBookLiquiditySums + func (m *OrderBookLiquidityUpdate_OrderBookLiquidityUpdateSide) GetBip50() *OrderBookLiquidityUpdate_OrderBookLiquiditySums + func (m *OrderBookLiquidityUpdate_OrderBookLiquidityUpdateSide) GetBip500() *OrderBookLiquidityUpdate_OrderBookLiquiditySums + func (m *OrderBookLiquidityUpdate_OrderBookLiquidityUpdateSide) GetBip75() *OrderBookLiquidityUpdate_OrderBookLiquiditySums + func (m *OrderBookLiquidityUpdate_OrderBookLiquidityUpdateSide) Marshal() (dAtA []byte, err error) + func (m *OrderBookLiquidityUpdate_OrderBookLiquidityUpdateSide) MarshalTo(dAtA []byte) (int, error) + func (m *OrderBookLiquidityUpdate_OrderBookLiquidityUpdateSide) Reset() + func (m *OrderBookLiquidityUpdate_OrderBookLiquidityUpdateSide) Size() (n int) + func (m *OrderBookLiquidityUpdate_OrderBookLiquidityUpdateSide) String() string + func (m *OrderBookLiquidityUpdate_OrderBookLiquidityUpdateSide) Unmarshal(dAtA []byte) error + func (m *OrderBookLiquidityUpdate_OrderBookLiquidityUpdateSide) XXX_DiscardUnknown() + func (m *OrderBookLiquidityUpdate_OrderBookLiquidityUpdateSide) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *OrderBookLiquidityUpdate_OrderBookLiquidityUpdateSide) XXX_Size() int + func (m *OrderBookLiquidityUpdate_OrderBookLiquidityUpdateSide) XXX_Unmarshal(b []byte) error + type OrderBookSpreadUpdate struct + Ask *Order + Bid *Order + Timestamp int64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*OrderBookSpreadUpdate) Descriptor() ([]byte, []int) + func (*OrderBookSpreadUpdate) ProtoMessage() + func (dst *OrderBookSpreadUpdate) XXX_Merge(src proto.Message) + func (m *OrderBookSpreadUpdate) GetAsk() *Order + func (m *OrderBookSpreadUpdate) GetBid() *Order + func (m *OrderBookSpreadUpdate) GetTimestamp() int64 + func (m *OrderBookSpreadUpdate) Marshal() (dAtA []byte, err error) + func (m *OrderBookSpreadUpdate) MarshalTo(dAtA []byte) (int, error) + func (m *OrderBookSpreadUpdate) Reset() + func (m *OrderBookSpreadUpdate) Size() (n int) + func (m *OrderBookSpreadUpdate) String() string + func (m *OrderBookSpreadUpdate) Unmarshal(dAtA []byte) error + func (m *OrderBookSpreadUpdate) XXX_DiscardUnknown() + func (m *OrderBookSpreadUpdate) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *OrderBookSpreadUpdate) XXX_Size() int + func (m *OrderBookSpreadUpdate) XXX_Unmarshal(b []byte) error + type OrderBookUpdate struct + AggregationModulus float32 + AggregationModulusStr string + Asks []*Order + Bids []*Order + SeqNum int32 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*OrderBookUpdate) Descriptor() ([]byte, []int) + func (*OrderBookUpdate) ProtoMessage() + func (dst *OrderBookUpdate) XXX_Merge(src proto.Message) + func (m *OrderBookUpdate) GetAggregationModulus() float32 + func (m *OrderBookUpdate) GetAggregationModulusStr() string + func (m *OrderBookUpdate) GetAsks() []*Order + func (m *OrderBookUpdate) GetBids() []*Order + func (m *OrderBookUpdate) GetSeqNum() int32 + func (m *OrderBookUpdate) Marshal() (dAtA []byte, err error) + func (m *OrderBookUpdate) MarshalTo(dAtA []byte) (int, error) + func (m *OrderBookUpdate) Reset() + func (m *OrderBookUpdate) Size() (n int) + func (m *OrderBookUpdate) String() string + func (m *OrderBookUpdate) Unmarshal(dAtA []byte) error + func (m *OrderBookUpdate) XXX_DiscardUnknown() + func (m *OrderBookUpdate) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *OrderBookUpdate) XXX_Size() int + func (m *OrderBookUpdate) XXX_Unmarshal(b []byte) error + type PairPerformanceUpdate struct + Performance float64 + Window string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*PairPerformanceUpdate) Descriptor() ([]byte, []int) + func (*PairPerformanceUpdate) ProtoMessage() + func (dst *PairPerformanceUpdate) XXX_Merge(src proto.Message) + func (m *PairPerformanceUpdate) GetPerformance() float64 + func (m *PairPerformanceUpdate) GetWindow() string + func (m *PairPerformanceUpdate) Marshal() (dAtA []byte, err error) + func (m *PairPerformanceUpdate) MarshalTo(dAtA []byte) (int, error) + func (m *PairPerformanceUpdate) Reset() + func (m *PairPerformanceUpdate) Size() (n int) + func (m *PairPerformanceUpdate) String() string + func (m *PairPerformanceUpdate) Unmarshal(dAtA []byte) error + func (m *PairPerformanceUpdate) XXX_DiscardUnknown() + func (m *PairPerformanceUpdate) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *PairPerformanceUpdate) XXX_Size() int + func (m *PairPerformanceUpdate) XXX_Unmarshal(b []byte) error + type PairTrendlineUpdate struct + Price string + Time int64 + Volume string + Window string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*PairTrendlineUpdate) Descriptor() ([]byte, []int) + func (*PairTrendlineUpdate) ProtoMessage() + func (dst *PairTrendlineUpdate) XXX_Merge(src proto.Message) + func (m *PairTrendlineUpdate) GetPrice() string + func (m *PairTrendlineUpdate) GetTime() int64 + func (m *PairTrendlineUpdate) GetVolume() string + func (m *PairTrendlineUpdate) GetWindow() string + func (m *PairTrendlineUpdate) Marshal() (dAtA []byte, err error) + func (m *PairTrendlineUpdate) MarshalTo(dAtA []byte) (int, error) + func (m *PairTrendlineUpdate) Reset() + func (m *PairTrendlineUpdate) Size() (n int) + func (m *PairTrendlineUpdate) String() string + func (m *PairTrendlineUpdate) Unmarshal(dAtA []byte) error + func (m *PairTrendlineUpdate) XXX_DiscardUnknown() + func (m *PairTrendlineUpdate) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *PairTrendlineUpdate) XXX_Size() int + func (m *PairTrendlineUpdate) XXX_Unmarshal(b []byte) error + type PairUpdateMessage struct + Pair uint64 + Update isPairUpdateMessage_Update + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*PairUpdateMessage) Descriptor() ([]byte, []int) + func (*PairUpdateMessage) ProtoMessage() + func (*PairUpdateMessage) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, ...) + func (dst *PairUpdateMessage) XXX_Merge(src proto.Message) + func (m *PairUpdateMessage) GetPair() uint64 + func (m *PairUpdateMessage) GetPerformanceUpdate() *PairPerformanceUpdate + func (m *PairUpdateMessage) GetTrendlineUpdate() *PairTrendlineUpdate + func (m *PairUpdateMessage) GetUpdate() isPairUpdateMessage_Update + func (m *PairUpdateMessage) GetVwapUpdate() *PairVwapUpdate + func (m *PairUpdateMessage) Marshal() (dAtA []byte, err error) + func (m *PairUpdateMessage) MarshalTo(dAtA []byte) (int, error) + func (m *PairUpdateMessage) Reset() + func (m *PairUpdateMessage) Size() (n int) + func (m *PairUpdateMessage) String() string + func (m *PairUpdateMessage) Unmarshal(dAtA []byte) error + func (m *PairUpdateMessage) XXX_DiscardUnknown() + func (m *PairUpdateMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *PairUpdateMessage) XXX_Size() int + func (m *PairUpdateMessage) XXX_Unmarshal(b []byte) error + type PairUpdateMessage_PerformanceUpdate struct + PerformanceUpdate *PairPerformanceUpdate + func (m *PairUpdateMessage_PerformanceUpdate) MarshalTo(dAtA []byte) (int, error) + func (m *PairUpdateMessage_PerformanceUpdate) Size() (n int) + type PairUpdateMessage_TrendlineUpdate struct + TrendlineUpdate *PairTrendlineUpdate + func (m *PairUpdateMessage_TrendlineUpdate) MarshalTo(dAtA []byte) (int, error) + func (m *PairUpdateMessage_TrendlineUpdate) Size() (n int) + type PairUpdateMessage_VwapUpdate struct + VwapUpdate *PairVwapUpdate + func (m *PairUpdateMessage_VwapUpdate) MarshalTo(dAtA []byte) (int, error) + func (m *PairUpdateMessage_VwapUpdate) Size() (n int) + type PairVwapUpdate struct + Timestamp int64 + Vwap float64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*PairVwapUpdate) Descriptor() ([]byte, []int) + func (*PairVwapUpdate) ProtoMessage() + func (dst *PairVwapUpdate) XXX_Merge(src proto.Message) + func (m *PairVwapUpdate) GetTimestamp() int64 + func (m *PairVwapUpdate) GetVwap() float64 + func (m *PairVwapUpdate) Marshal() (dAtA []byte, err error) + func (m *PairVwapUpdate) MarshalTo(dAtA []byte) (int, error) + func (m *PairVwapUpdate) Reset() + func (m *PairVwapUpdate) Size() (n int) + func (m *PairVwapUpdate) String() string + func (m *PairVwapUpdate) Unmarshal(dAtA []byte) error + func (m *PairVwapUpdate) XXX_DiscardUnknown() + func (m *PairVwapUpdate) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *PairVwapUpdate) XXX_Size() int + func (m *PairVwapUpdate) XXX_Unmarshal(b []byte) error + type SparklineUpdate struct + Price float32 + PriceStr string + Time int64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*SparklineUpdate) Descriptor() ([]byte, []int) + func (*SparklineUpdate) ProtoMessage() + func (dst *SparklineUpdate) XXX_Merge(src proto.Message) + func (m *SparklineUpdate) GetPrice() float32 + func (m *SparklineUpdate) GetPriceStr() string + func (m *SparklineUpdate) GetTime() int64 + func (m *SparklineUpdate) Marshal() (dAtA []byte, err error) + func (m *SparklineUpdate) MarshalTo(dAtA []byte) (int, error) + func (m *SparklineUpdate) Reset() + func (m *SparklineUpdate) Size() (n int) + func (m *SparklineUpdate) String() string + func (m *SparklineUpdate) Unmarshal(dAtA []byte) error + func (m *SparklineUpdate) XXX_DiscardUnknown() + func (m *SparklineUpdate) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *SparklineUpdate) XXX_Size() int + func (m *SparklineUpdate) XXX_Unmarshal(b []byte) error + type SummaryUpdate struct + ChangeAbsolute float32 + ChangeAbsoluteStr string + ChangePercent float32 + ChangePercentStr string + High float32 + HighStr string + Last float32 + LastStr string + Low float32 + LowStr string + NumTrades int32 + VolumeBase float32 + VolumeBaseStr string + VolumeQuote float32 + VolumeQuoteStr string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*SummaryUpdate) Descriptor() ([]byte, []int) + func (*SummaryUpdate) ProtoMessage() + func (dst *SummaryUpdate) XXX_Merge(src proto.Message) + func (m *SummaryUpdate) GetChangeAbsolute() float32 + func (m *SummaryUpdate) GetChangeAbsoluteStr() string + func (m *SummaryUpdate) GetChangePercent() float32 + func (m *SummaryUpdate) GetChangePercentStr() string + func (m *SummaryUpdate) GetHigh() float32 + func (m *SummaryUpdate) GetHighStr() string + func (m *SummaryUpdate) GetLast() float32 + func (m *SummaryUpdate) GetLastStr() string + func (m *SummaryUpdate) GetLow() float32 + func (m *SummaryUpdate) GetLowStr() string + func (m *SummaryUpdate) GetNumTrades() int32 + func (m *SummaryUpdate) GetVolumeBase() float32 + func (m *SummaryUpdate) GetVolumeBaseStr() string + func (m *SummaryUpdate) GetVolumeQuote() float32 + func (m *SummaryUpdate) GetVolumeQuoteStr() string + func (m *SummaryUpdate) Marshal() (dAtA []byte, err error) + func (m *SummaryUpdate) MarshalTo(dAtA []byte) (int, error) + func (m *SummaryUpdate) Reset() + func (m *SummaryUpdate) Size() (n int) + func (m *SummaryUpdate) String() string + func (m *SummaryUpdate) Unmarshal(dAtA []byte) error + func (m *SummaryUpdate) XXX_DiscardUnknown() + func (m *SummaryUpdate) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *SummaryUpdate) XXX_Size() int + func (m *SummaryUpdate) XXX_Unmarshal(b []byte) error + type Ticker struct + Timestamp int64 + TimestampNano int64 + Value string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Ticker) Descriptor() ([]byte, []int) + func (*Ticker) ProtoMessage() + func (dst *Ticker) XXX_Merge(src proto.Message) + func (m *Ticker) GetTimestamp() int64 + func (m *Ticker) GetTimestampNano() int64 + func (m *Ticker) GetValue() string + func (m *Ticker) Marshal() (dAtA []byte, err error) + func (m *Ticker) MarshalTo(dAtA []byte) (int, error) + func (m *Ticker) Reset() + func (m *Ticker) Size() (n int) + func (m *Ticker) String() string + func (m *Ticker) Unmarshal(dAtA []byte) error + func (m *Ticker) XXX_DiscardUnknown() + func (m *Ticker) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Ticker) XXX_Size() int + func (m *Ticker) XXX_Unmarshal(b []byte) error + type TickerUpdate struct + Tickers []*Ticker + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*TickerUpdate) Descriptor() ([]byte, []int) + func (*TickerUpdate) ProtoMessage() + func (dst *TickerUpdate) XXX_Merge(src proto.Message) + func (m *TickerUpdate) GetTickers() []*Ticker + func (m *TickerUpdate) Marshal() (dAtA []byte, err error) + func (m *TickerUpdate) MarshalTo(dAtA []byte) (int, error) + func (m *TickerUpdate) Reset() + func (m *TickerUpdate) Size() (n int) + func (m *TickerUpdate) String() string + func (m *TickerUpdate) Unmarshal(dAtA []byte) error + func (m *TickerUpdate) XXX_DiscardUnknown() + func (m *TickerUpdate) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *TickerUpdate) XXX_Size() int + func (m *TickerUpdate) XXX_Unmarshal(b []byte) error + type Trade struct + Amount float32 + AmountDouble float64 + AmountStr string + ExternalId string + Id int64 + Price float32 + PriceDouble float64 + PriceStr string + Timestamp int64 + TimestampMillis int64 + TimestampNano int64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Trade) Descriptor() ([]byte, []int) + func (*Trade) ProtoMessage() + func (dst *Trade) XXX_Merge(src proto.Message) + func (m *Trade) GetAmount() float32 + func (m *Trade) GetAmountDouble() float64 + func (m *Trade) GetAmountStr() string + func (m *Trade) GetExternalId() string + func (m *Trade) GetId() int64 + func (m *Trade) GetPrice() float32 + func (m *Trade) GetPriceDouble() float64 + func (m *Trade) GetPriceStr() string + func (m *Trade) GetTimestamp() int64 + func (m *Trade) GetTimestampMillis() int64 + func (m *Trade) GetTimestampNano() int64 + func (m *Trade) Marshal() (dAtA []byte, err error) + func (m *Trade) MarshalTo(dAtA []byte) (int, error) + func (m *Trade) Reset() + func (m *Trade) Size() (n int) + func (m *Trade) String() string + func (m *Trade) Unmarshal(dAtA []byte) error + func (m *Trade) XXX_DiscardUnknown() + func (m *Trade) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Trade) XXX_Size() int + func (m *Trade) XXX_Unmarshal(b []byte) error + type TradesUpdate struct + Trades []*Trade + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*TradesUpdate) Descriptor() ([]byte, []int) + func (*TradesUpdate) ProtoMessage() + func (dst *TradesUpdate) XXX_Merge(src proto.Message) + func (m *TradesUpdate) GetTrades() []*Trade + func (m *TradesUpdate) Marshal() (dAtA []byte, err error) + func (m *TradesUpdate) MarshalTo(dAtA []byte) (int, error) + func (m *TradesUpdate) Reset() + func (m *TradesUpdate) Size() (n int) + func (m *TradesUpdate) String() string + func (m *TradesUpdate) Unmarshal(dAtA []byte) error + func (m *TradesUpdate) XXX_DiscardUnknown() + func (m *TradesUpdate) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *TradesUpdate) XXX_Size() int + func (m *TradesUpdate) XXX_Unmarshal(b []byte) error