ProtobufMarkets

package
v1.0.2 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Aug 20, 2019 License: BSD-2-Clause Imports: 5 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthAsset = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowAsset   = fmt.Errorf("proto: integer overflow")
)
View Source 
var (
	ErrInvalidLengthIndex = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowIndex   = fmt.Errorf("proto: integer overflow")
)
View Source 
var (
	ErrInvalidLengthMarket = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowMarket   = fmt.Errorf("proto: integer overflow")
)
View Source 
var (
	ErrInvalidLengthPair = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowPair   = fmt.Errorf("proto: integer overflow")
)

Functions

This section is empty.

Types

type AssetUSDVolumeUpdate 

type AssetUSDVolumeUpdate struct {
	Volume               string   `protobuf:"bytes,1,opt,name=volume,proto3" json:"volume,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*AssetUSDVolumeUpdate) Descriptor 

func (*AssetUSDVolumeUpdate) Descriptor() ([]byte, []int)

func (*AssetUSDVolumeUpdate) GetVolume 

func (m *AssetUSDVolumeUpdate) GetVolume() string

func (*AssetUSDVolumeUpdate) Marshal 

func (m *AssetUSDVolumeUpdate) Marshal() (dAtA []byte, err error)

func (*AssetUSDVolumeUpdate) MarshalTo 

func (m *AssetUSDVolumeUpdate) MarshalTo(dAtA []byte) (int, error)

func (*AssetUSDVolumeUpdate) ProtoMessage 

func (*AssetUSDVolumeUpdate) ProtoMessage()

func (*AssetUSDVolumeUpdate) Reset 

func (m *AssetUSDVolumeUpdate) Reset()

func (*AssetUSDVolumeUpdate) Size 

func (m *AssetUSDVolumeUpdate) Size() (n int)

func (*AssetUSDVolumeUpdate) String 

func (m *AssetUSDVolumeUpdate) String() string

func (*AssetUSDVolumeUpdate) Unmarshal 

func (m *AssetUSDVolumeUpdate) Unmarshal(dAtA []byte) error

func (*AssetUSDVolumeUpdate) XXX_DiscardUnknown 

func (m *AssetUSDVolumeUpdate) XXX_DiscardUnknown()

func (*AssetUSDVolumeUpdate) XXX_Marshal 

func (m *AssetUSDVolumeUpdate) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*AssetUSDVolumeUpdate) XXX_Merge 

func (dst *AssetUSDVolumeUpdate) XXX_Merge(src proto.Message)

func (*AssetUSDVolumeUpdate) XXX_Size 

func (m *AssetUSDVolumeUpdate) XXX_Size() int

func (*AssetUSDVolumeUpdate) XXX_Unmarshal 

func (m *AssetUSDVolumeUpdate) XXX_Unmarshal(b []byte) error

type AssetUpdateMessage 

type AssetUpdateMessage struct {
	Asset int32 `protobuf:"varint,1,opt,name=asset,proto3" json:"asset,omitempty"`
	// Types that are valid to be assigned to Update:
	//	*AssetUpdateMessage_UsdVolumeUpdate
	Update               isAssetUpdateMessage_Update `protobuf_oneof:"Update"`
	XXX_NoUnkeyedLiteral struct{}                    `json:"-"`
	XXX_unrecognized     []byte                      `json:"-"`
	XXX_sizecache        int32                       `json:"-"`
}

func (*AssetUpdateMessage) Descriptor 

func (*AssetUpdateMessage) Descriptor() ([]byte, []int)

func (*AssetUpdateMessage) GetAsset 

func (m *AssetUpdateMessage) GetAsset() int32

func (*AssetUpdateMessage) GetUpdate 

func (m *AssetUpdateMessage) GetUpdate() isAssetUpdateMessage_Update

func (*AssetUpdateMessage) GetUsdVolumeUpdate 

func (m *AssetUpdateMessage) GetUsdVolumeUpdate() *AssetUSDVolumeUpdate

func (*AssetUpdateMessage) Marshal 

func (m *AssetUpdateMessage) Marshal() (dAtA []byte, err error)

func (*AssetUpdateMessage) MarshalTo 

func (m *AssetUpdateMessage) MarshalTo(dAtA []byte) (int, error)

func (*AssetUpdateMessage) ProtoMessage 

func (*AssetUpdateMessage) ProtoMessage()

func (*AssetUpdateMessage) Reset 

func (m *AssetUpdateMessage) Reset()

func (*AssetUpdateMessage) Size 

func (m *AssetUpdateMessage) Size() (n int)

func (*AssetUpdateMessage) String 

func (m *AssetUpdateMessage) String() string

func (*AssetUpdateMessage) Unmarshal 

func (m *AssetUpdateMessage) Unmarshal(dAtA []byte) error

func (*AssetUpdateMessage) XXX_DiscardUnknown 

func (m *AssetUpdateMessage) XXX_DiscardUnknown()

func (*AssetUpdateMessage) XXX_Marshal 

func (m *AssetUpdateMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*AssetUpdateMessage) XXX_Merge 

func (dst *AssetUpdateMessage) XXX_Merge(src proto.Message)

func (*AssetUpdateMessage) XXX_OneofFuncs 

func (*AssetUpdateMessage) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})

XXX_OneofFuncs is for the internal use of the proto package.

func (*AssetUpdateMessage) XXX_Size 

func (m *AssetUpdateMessage) XXX_Size() int

func (*AssetUpdateMessage) XXX_Unmarshal 

func (m *AssetUpdateMessage) XXX_Unmarshal(b []byte) error

type AssetUpdateMessage_UsdVolumeUpdate 

type AssetUpdateMessage_UsdVolumeUpdate struct {
	UsdVolumeUpdate *AssetUSDVolumeUpdate `protobuf:"bytes,2,opt,name=usdVolumeUpdate,proto3,oneof"`
}

func (*AssetUpdateMessage_UsdVolumeUpdate) MarshalTo 

func (m *AssetUpdateMessage_UsdVolumeUpdate) MarshalTo(dAtA []byte) (int, error)

func (*AssetUpdateMessage_UsdVolumeUpdate) Size 

func (m *AssetUpdateMessage_UsdVolumeUpdate) Size() (n int)

type Index 

type Index struct {
	Id                   uint64   `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	Symbol               string   `protobuf:"bytes,2,opt,name=symbol,proto3" json:"symbol,omitempty"`
	IndexType            string   `protobuf:"bytes,3,opt,name=indexType,proto3" json:"indexType,omitempty"`
	CwIndex              bool     `protobuf:"varint,4,opt,name=cwIndex,proto3" json:"cwIndex,omitempty"`
	ExchangeId           uint64   `protobuf:"varint,5,opt,name=exchangeId,proto3" json:"exchangeId,omitempty"`
	InstrumentId         uint64   `protobuf:"varint,6,opt,name=instrumentId,proto3" json:"instrumentId,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Index represents a index metric which may be produced on cryptowatch or belong to an exchange

func (*Index) Descriptor 

func (*Index) Descriptor() ([]byte, []int)

func (*Index) GetCwIndex 

func (m *Index) GetCwIndex() bool

func (*Index) GetExchangeId 

func (m *Index) GetExchangeId() uint64

func (*Index) GetId 

func (m *Index) GetId() uint64

func (*Index) GetIndexType 

func (m *Index) GetIndexType() string

func (*Index) GetInstrumentId 

func (m *Index) GetInstrumentId() uint64

func (*Index) GetSymbol 

func (m *Index) GetSymbol() string

func (*Index) Marshal 

func (m *Index) Marshal() (dAtA []byte, err error)

func (*Index) MarshalTo 

func (m *Index) MarshalTo(dAtA []byte) (int, error)

func (*Index) ProtoMessage 

func (*Index) ProtoMessage()

func (*Index) Reset 

func (m *Index) Reset()

func (*Index) Size 

func (m *Index) Size() (n int)

func (*Index) String 

func (m *Index) String() string

func (*Index) Unmarshal 

func (m *Index) Unmarshal(dAtA []byte) error

func (*Index) XXX_DiscardUnknown 

func (m *Index) XXX_DiscardUnknown()

func (*Index) XXX_Marshal 

func (m *Index) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Index) XXX_Merge 

func (dst *Index) XXX_Merge(src proto.Message)

func (*Index) XXX_Size 

func (m *Index) XXX_Size() int

func (*Index) XXX_Unmarshal 

func (m *Index) XXX_Unmarshal(b []byte) error

type IndexUpdateMessage 

type IndexUpdateMessage struct {
	Index *Index `protobuf:"bytes,1,opt,name=index,proto3" json:"index,omitempty"`
	// Types that are valid to be assigned to Update:
	//	*IndexUpdateMessage_TickerUpdate
	//	*IndexUpdateMessage_IntervalsUpdate
	//	*IndexUpdateMessage_SummaryUpdate
	//	*IndexUpdateMessage_SparklineUpdate
	Update               isIndexUpdateMessage_Update `protobuf_oneof:"Update"`
	XXX_NoUnkeyedLiteral struct{}                    `json:"-"`
	XXX_unrecognized     []byte                      `json:"-"`
	XXX_sizecache        int32                       `json:"-"`
}

func (*IndexUpdateMessage) Descriptor 

func (*IndexUpdateMessage) Descriptor() ([]byte, []int)

func (*IndexUpdateMessage) GetIndex 

func (m *IndexUpdateMessage) GetIndex() *Index

func (*IndexUpdateMessage) GetIntervalsUpdate 

func (m *IndexUpdateMessage) GetIntervalsUpdate() *IntervalsUpdate

func (*IndexUpdateMessage) GetSparklineUpdate 

func (m *IndexUpdateMessage) GetSparklineUpdate() *SparklineUpdate

func (*IndexUpdateMessage) GetSummaryUpdate 

func (m *IndexUpdateMessage) GetSummaryUpdate() *SummaryUpdate

func (*IndexUpdateMessage) GetTickerUpdate 

func (m *IndexUpdateMessage) GetTickerUpdate() *TickerUpdate

func (*IndexUpdateMessage) GetUpdate 

func (m *IndexUpdateMessage) GetUpdate() isIndexUpdateMessage_Update

func (*IndexUpdateMessage) Marshal 

func (m *IndexUpdateMessage) Marshal() (dAtA []byte, err error)

func (*IndexUpdateMessage) MarshalTo 

func (m *IndexUpdateMessage) MarshalTo(dAtA []byte) (int, error)

func (*IndexUpdateMessage) ProtoMessage 

func (*IndexUpdateMessage) ProtoMessage()

func (*IndexUpdateMessage) Reset 

func (m *IndexUpdateMessage) Reset()

func (*IndexUpdateMessage) Size 

func (m *IndexUpdateMessage) Size() (n int)

func (*IndexUpdateMessage) String 

func (m *IndexUpdateMessage) String() string

func (*IndexUpdateMessage) Unmarshal 

func (m *IndexUpdateMessage) Unmarshal(dAtA []byte) error

func (*IndexUpdateMessage) XXX_DiscardUnknown 

func (m *IndexUpdateMessage) XXX_DiscardUnknown()

func (*IndexUpdateMessage) XXX_Marshal 

func (m *IndexUpdateMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*IndexUpdateMessage) XXX_Merge 

func (dst *IndexUpdateMessage) XXX_Merge(src proto.Message)

func (*IndexUpdateMessage) XXX_OneofFuncs 

func (*IndexUpdateMessage) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})

XXX_OneofFuncs is for the internal use of the proto package.

func (*IndexUpdateMessage) XXX_Size 

func (m *IndexUpdateMessage) XXX_Size() int

func (*IndexUpdateMessage) XXX_Unmarshal 

func (m *IndexUpdateMessage) XXX_Unmarshal(b []byte) error

type IndexUpdateMessage_IntervalsUpdate 

type IndexUpdateMessage_IntervalsUpdate struct {
	IntervalsUpdate *IntervalsUpdate `protobuf:"bytes,3,opt,name=intervalsUpdate,proto3,oneof"`
}

func (*IndexUpdateMessage_IntervalsUpdate) MarshalTo 

func (m *IndexUpdateMessage_IntervalsUpdate) MarshalTo(dAtA []byte) (int, error)

func (*IndexUpdateMessage_IntervalsUpdate) Size 

func (m *IndexUpdateMessage_IntervalsUpdate) Size() (n int)

type IndexUpdateMessage_SparklineUpdate 

type IndexUpdateMessage_SparklineUpdate struct {
	SparklineUpdate *SparklineUpdate `protobuf:"bytes,5,opt,name=sparklineUpdate,proto3,oneof"`
}

func (*IndexUpdateMessage_SparklineUpdate) MarshalTo 

func (m *IndexUpdateMessage_SparklineUpdate) MarshalTo(dAtA []byte) (int, error)

func (*IndexUpdateMessage_SparklineUpdate) Size 

func (m *IndexUpdateMessage_SparklineUpdate) Size() (n int)

type IndexUpdateMessage_SummaryUpdate 

type IndexUpdateMessage_SummaryUpdate struct {
	SummaryUpdate *SummaryUpdate `protobuf:"bytes,4,opt,name=summaryUpdate,proto3,oneof"`
}

func (*IndexUpdateMessage_SummaryUpdate) MarshalTo 

func (m *IndexUpdateMessage_SummaryUpdate) MarshalTo(dAtA []byte) (int, error)

func (*IndexUpdateMessage_SummaryUpdate) Size 

func (m *IndexUpdateMessage_SummaryUpdate) Size() (n int)

type IndexUpdateMessage_TickerUpdate 

type IndexUpdateMessage_TickerUpdate struct {
	TickerUpdate *TickerUpdate `protobuf:"bytes,2,opt,name=tickerUpdate,proto3,oneof"`
}

func (*IndexUpdateMessage_TickerUpdate) MarshalTo 

func (m *IndexUpdateMessage_TickerUpdate) MarshalTo(dAtA []byte) (int, error)

func (*IndexUpdateMessage_TickerUpdate) Size 

func (m *IndexUpdateMessage_TickerUpdate) Size() (n int)

type Interval 

type Interval struct {
	Closetime      int64          `protobuf:"varint,1,opt,name=closetime,proto3" json:"closetime,omitempty"`
	Period         int32          `protobuf:"varint,4,opt,name=period,proto3" json:"period,omitempty"`
	Ohlc           *Interval_OHLC `protobuf:"bytes,2,opt,name=ohlc,proto3" json:"ohlc,omitempty"`
	VolumeBaseStr  string         `protobuf:"bytes,6,opt,name=volumeBaseStr,proto3" json:"volumeBaseStr,omitempty"`
	VolumeQuoteStr string         `protobuf:"bytes,7,opt,name=volumeQuoteStr,proto3" json:"volumeQuoteStr,omitempty"`
	// Deprecated
	VolumeBase           float32  `protobuf:"fixed32,3,opt,name=volumeBase,proto3" json:"volumeBase,omitempty"`
	VolumeQuote          float32  `protobuf:"fixed32,5,opt,name=volumeQuote,proto3" json:"volumeQuote,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Interval represents a single OHLC candle.

func (*Interval) Descriptor 

func (*Interval) Descriptor() ([]byte, []int)

func (*Interval) GetClosetime 

func (m *Interval) GetClosetime() int64

func (*Interval) GetOhlc 

func (m *Interval) GetOhlc() *Interval_OHLC

func (*Interval) GetPeriod 

func (m *Interval) GetPeriod() int32

func (*Interval) GetVolumeBase 

func (m *Interval) GetVolumeBase() float32

func (*Interval) GetVolumeBaseStr 

func (m *Interval) GetVolumeBaseStr() string

func (*Interval) GetVolumeQuote 

func (m *Interval) GetVolumeQuote() float32

func (*Interval) GetVolumeQuoteStr 

func (m *Interval) GetVolumeQuoteStr() string

func (*Interval) Marshal 

func (m *Interval) Marshal() (dAtA []byte, err error)

func (*Interval) MarshalTo 

func (m *Interval) MarshalTo(dAtA []byte) (int, error)

func (*Interval) ProtoMessage 

func (*Interval) ProtoMessage()

func (*Interval) Reset 

func (m *Interval) Reset()

func (*Interval) Size 

func (m *Interval) Size() (n int)

func (*Interval) String 

func (m *Interval) String() string

func (*Interval) Unmarshal 

func (m *Interval) Unmarshal(dAtA []byte) error

func (*Interval) XXX_DiscardUnknown 

func (m *Interval) XXX_DiscardUnknown()

func (*Interval) XXX_Marshal 

func (m *Interval) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Interval) XXX_Merge 

func (dst *Interval) XXX_Merge(src proto.Message)

func (*Interval) XXX_Size 

func (m *Interval) XXX_Size() int

func (*Interval) XXX_Unmarshal 

func (m *Interval) XXX_Unmarshal(b []byte) error

type Interval_OHLC 

type Interval_OHLC struct {
	OpenStr  string `protobuf:"bytes,5,opt,name=openStr,proto3" json:"openStr,omitempty"`
	HighStr  string `protobuf:"bytes,6,opt,name=highStr,proto3" json:"highStr,omitempty"`
	LowStr   string `protobuf:"bytes,7,opt,name=lowStr,proto3" json:"lowStr,omitempty"`
	CloseStr string `protobuf:"bytes,8,opt,name=closeStr,proto3" json:"closeStr,omitempty"`
	// Deprecated
	Open                 float32  `protobuf:"fixed32,1,opt,name=open,proto3" json:"open,omitempty"`
	High                 float32  `protobuf:"fixed32,2,opt,name=high,proto3" json:"high,omitempty"`
	Low                  float32  `protobuf:"fixed32,3,opt,name=low,proto3" json:"low,omitempty"`
	Close                float32  `protobuf:"fixed32,4,opt,name=close,proto3" json:"close,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Interval_OHLC) Descriptor 

func (*Interval_OHLC) Descriptor() ([]byte, []int)

func (*Interval_OHLC) GetClose 

func (m *Interval_OHLC) GetClose() float32

func (*Interval_OHLC) GetCloseStr 

func (m *Interval_OHLC) GetCloseStr() string

func (*Interval_OHLC) GetHigh 

func (m *Interval_OHLC) GetHigh() float32

func (*Interval_OHLC) GetHighStr 

func (m *Interval_OHLC) GetHighStr() string

func (*Interval_OHLC) GetLow 

func (m *Interval_OHLC) GetLow() float32

func (*Interval_OHLC) GetLowStr 

func (m *Interval_OHLC) GetLowStr() string

func (*Interval_OHLC) GetOpen 

func (m *Interval_OHLC) GetOpen() float32

func (*Interval_OHLC) GetOpenStr 

func (m *Interval_OHLC) GetOpenStr() string

func (*Interval_OHLC) Marshal 

func (m *Interval_OHLC) Marshal() (dAtA []byte, err error)

func (*Interval_OHLC) MarshalTo 

func (m *Interval_OHLC) MarshalTo(dAtA []byte) (int, error)

func (*Interval_OHLC) ProtoMessage 

func (*Interval_OHLC) ProtoMessage()

func (*Interval_OHLC) Reset 

func (m *Interval_OHLC) Reset()

func (*Interval_OHLC) Size 

func (m *Interval_OHLC) Size() (n int)

func (*Interval_OHLC) String 

func (m *Interval_OHLC) String() string

func (*Interval_OHLC) Unmarshal 

func (m *Interval_OHLC) Unmarshal(dAtA []byte) error

func (*Interval_OHLC) XXX_DiscardUnknown 

func (m *Interval_OHLC) XXX_DiscardUnknown()

func (*Interval_OHLC) XXX_Marshal 

func (m *Interval_OHLC) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Interval_OHLC) XXX_Merge 

func (dst *Interval_OHLC) XXX_Merge(src proto.Message)

func (*Interval_OHLC) XXX_Size 

func (m *Interval_OHLC) XXX_Size() int

func (*Interval_OHLC) XXX_Unmarshal 

func (m *Interval_OHLC) XXX_Unmarshal(b []byte) error

type IntervalsUpdate 

type IntervalsUpdate struct {
	Intervals            []*Interval `protobuf:"bytes,1,rep,name=intervals,proto3" json:"intervals,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

IntervalsUpdate represents a set of new Intervals (OHLC candles)

func (*IntervalsUpdate) Descriptor 

func (*IntervalsUpdate) Descriptor() ([]byte, []int)

func (*IntervalsUpdate) GetIntervals 

func (m *IntervalsUpdate) GetIntervals() []*Interval

func (*IntervalsUpdate) Marshal 

func (m *IntervalsUpdate) Marshal() (dAtA []byte, err error)

func (*IntervalsUpdate) MarshalTo 

func (m *IntervalsUpdate) MarshalTo(dAtA []byte) (int, error)

func (*IntervalsUpdate) ProtoMessage 

func (*IntervalsUpdate) ProtoMessage()

func (*IntervalsUpdate) Reset 

func (m *IntervalsUpdate) Reset()

func (*IntervalsUpdate) Size 

func (m *IntervalsUpdate) Size() (n int)

func (*IntervalsUpdate) String 

func (m *IntervalsUpdate) String() string

func (*IntervalsUpdate) Unmarshal 

func (m *IntervalsUpdate) Unmarshal(dAtA []byte) error

func (*IntervalsUpdate) XXX_DiscardUnknown 

func (m *IntervalsUpdate) XXX_DiscardUnknown()

func (*IntervalsUpdate) XXX_Marshal 

func (m *IntervalsUpdate) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*IntervalsUpdate) XXX_Merge 

func (dst *IntervalsUpdate) XXX_Merge(src proto.Message)

func (*IntervalsUpdate) XXX_Size 

func (m *IntervalsUpdate) XXX_Size() int

func (*IntervalsUpdate) XXX_Unmarshal 

func (m *IntervalsUpdate) XXX_Unmarshal(b []byte) error

type Market 

type Market struct {
	// Prefer integer ids to string slugs (far fewer bytes)
	ExchangeId     uint64 `protobuf:"varint,3,opt,name=exchangeId,proto3" json:"exchangeId,omitempty"`
	CurrencyPairId uint64 `protobuf:"varint,4,opt,name=currencyPairId,proto3" json:"currencyPairId,omitempty"`
	// New IDs from SQL; TODO remove 1,2,3,4 when migrationt o 5,6 is complete
	MarketId uint64 `protobuf:"varint,5,opt,name=marketId,proto3" json:"marketId,omitempty"`
	// Deprecated
	Exchange             string   `protobuf:"bytes,1,opt,name=exchange,proto3" json:"exchange,omitempty"`
	CurrencyPair         string   `protobuf:"bytes,2,opt,name=currencyPair,proto3" json:"currencyPair,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Market represents a currency pair on a particular exchange.

func (*Market) Descriptor 

func (*Market) Descriptor() ([]byte, []int)

func (*Market) GetCurrencyPair 

func (m *Market) GetCurrencyPair() string

func (*Market) GetCurrencyPairId 

func (m *Market) GetCurrencyPairId() uint64

func (*Market) GetExchange 

func (m *Market) GetExchange() string

func (*Market) GetExchangeId 

func (m *Market) GetExchangeId() uint64

func (*Market) GetMarketId 

func (m *Market) GetMarketId() uint64

func (*Market) Marshal 

func (m *Market) Marshal() (dAtA []byte, err error)

func (*Market) MarshalTo 

func (m *Market) MarshalTo(dAtA []byte) (int, error)

func (*Market) ProtoMessage 

func (*Market) ProtoMessage()

func (*Market) Reset 

func (m *Market) Reset()

func (*Market) Size 

func (m *Market) Size() (n int)

func (*Market) String 

func (m *Market) String() string

func (*Market) Unmarshal 

func (m *Market) Unmarshal(dAtA []byte) error

func (*Market) XXX_DiscardUnknown 

func (m *Market) XXX_DiscardUnknown()

func (*Market) XXX_Marshal 

func (m *Market) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Market) XXX_Merge 

func (dst *Market) XXX_Merge(src proto.Message)

func (*Market) XXX_Size 

func (m *Market) XXX_Size() int

func (*Market) XXX_Unmarshal 

func (m *Market) XXX_Unmarshal(b []byte) error

type MarketUpdateMessage 

type MarketUpdateMessage struct {
	Market *Market `protobuf:"bytes,9,opt,name=market,proto3" json:"market,omitempty"`
	// Types that are valid to be assigned to Update:
	//	*MarketUpdateMessage_OrderBookUpdate
	//	*MarketUpdateMessage_OrderBookDeltaUpdate
	//	*MarketUpdateMessage_OrderBookSpreadUpdate
	//	*MarketUpdateMessage_OrderBookLiquidityUpdate
	//	*MarketUpdateMessage_TradesUpdate
	//	*MarketUpdateMessage_IntervalsUpdate
	//	*MarketUpdateMessage_SummaryUpdate
	//	*MarketUpdateMessage_SparklineUpdate
	Update               isMarketUpdateMessage_Update `protobuf_oneof:"Update"`
	XXX_NoUnkeyedLiteral struct{}                     `json:"-"`
	XXX_unrecognized     []byte                       `json:"-"`
	XXX_sizecache        int32                        `json:"-"`
}

MarketUpdateMessage is the primary message for market updates; it wraps all other more specific update types.

func (*MarketUpdateMessage) Descriptor 

func (*MarketUpdateMessage) Descriptor() ([]byte, []int)

func (*MarketUpdateMessage) GetIntervalsUpdate 

func (m *MarketUpdateMessage) GetIntervalsUpdate() *IntervalsUpdate

func (*MarketUpdateMessage) GetMarket 

func (m *MarketUpdateMessage) GetMarket() *Market

func (*MarketUpdateMessage) GetOrderBookDeltaUpdate 

func (m *MarketUpdateMessage) GetOrderBookDeltaUpdate() *OrderBookDeltaUpdate

func (*MarketUpdateMessage) GetOrderBookLiquidityUpdate 

func (m *MarketUpdateMessage) GetOrderBookLiquidityUpdate() *OrderBookLiquidityUpdate

func (*MarketUpdateMessage) GetOrderBookSpreadUpdate 

func (m *MarketUpdateMessage) GetOrderBookSpreadUpdate() *OrderBookSpreadUpdate

func (*MarketUpdateMessage) GetOrderBookUpdate 

func (m *MarketUpdateMessage) GetOrderBookUpdate() *OrderBookUpdate

func (*MarketUpdateMessage) GetSparklineUpdate 

func (m *MarketUpdateMessage) GetSparklineUpdate() *SparklineUpdate

func (*MarketUpdateMessage) GetSummaryUpdate 

func (m *MarketUpdateMessage) GetSummaryUpdate() *SummaryUpdate

func (*MarketUpdateMessage) GetTradesUpdate 

func (m *MarketUpdateMessage) GetTradesUpdate() *TradesUpdate

func (*MarketUpdateMessage) GetUpdate 

func (m *MarketUpdateMessage) GetUpdate() isMarketUpdateMessage_Update

func (*MarketUpdateMessage) Marshal 

func (m *MarketUpdateMessage) Marshal() (dAtA []byte, err error)

func (*MarketUpdateMessage) MarshalTo 

func (m *MarketUpdateMessage) MarshalTo(dAtA []byte) (int, error)

func (*MarketUpdateMessage) ProtoMessage 

func (*MarketUpdateMessage) ProtoMessage()

func (*MarketUpdateMessage) Reset 

func (m *MarketUpdateMessage) Reset()

func (*MarketUpdateMessage) Size 

func (m *MarketUpdateMessage) Size() (n int)

func (*MarketUpdateMessage) String 

func (m *MarketUpdateMessage) String() string

func (*MarketUpdateMessage) Unmarshal 

func (m *MarketUpdateMessage) Unmarshal(dAtA []byte) error

func (*MarketUpdateMessage) XXX_DiscardUnknown 

func (m *MarketUpdateMessage) XXX_DiscardUnknown()

func (*MarketUpdateMessage) XXX_Marshal 

func (m *MarketUpdateMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MarketUpdateMessage) XXX_Merge 

func (dst *MarketUpdateMessage) XXX_Merge(src proto.Message)

func (*MarketUpdateMessage) XXX_OneofFuncs 

func (*MarketUpdateMessage) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})

XXX_OneofFuncs is for the internal use of the proto package.

func (*MarketUpdateMessage) XXX_Size 

func (m *MarketUpdateMessage) XXX_Size() int

func (*MarketUpdateMessage) XXX_Unmarshal 

func (m *MarketUpdateMessage) XXX_Unmarshal(b []byte) error

type MarketUpdateMessage_IntervalsUpdate 

type MarketUpdateMessage_IntervalsUpdate struct {
	IntervalsUpdate *IntervalsUpdate `protobuf:"bytes,5,opt,name=intervalsUpdate,proto3,oneof"`
}

func (*MarketUpdateMessage_IntervalsUpdate) MarshalTo 

func (m *MarketUpdateMessage_IntervalsUpdate) MarshalTo(dAtA []byte) (int, error)

func (*MarketUpdateMessage_IntervalsUpdate) Size 

func (m *MarketUpdateMessage_IntervalsUpdate) Size() (n int)

type MarketUpdateMessage_OrderBookDeltaUpdate 

type MarketUpdateMessage_OrderBookDeltaUpdate struct {
	OrderBookDeltaUpdate *OrderBookDeltaUpdate `protobuf:"bytes,3,opt,name=orderBookDeltaUpdate,proto3,oneof"`
}

func (*MarketUpdateMessage_OrderBookDeltaUpdate) MarshalTo 

func (m *MarketUpdateMessage_OrderBookDeltaUpdate) MarshalTo(dAtA []byte) (int, error)

func (*MarketUpdateMessage_OrderBookDeltaUpdate) Size 

func (m *MarketUpdateMessage_OrderBookDeltaUpdate) Size() (n int)

type MarketUpdateMessage_OrderBookLiquidityUpdate 

type MarketUpdateMessage_OrderBookLiquidityUpdate struct {
	OrderBookLiquidityUpdate *OrderBookLiquidityUpdate `protobuf:"bytes,12,opt,name=orderBookLiquidityUpdate,proto3,oneof"`
}

func (*MarketUpdateMessage_OrderBookLiquidityUpdate) MarshalTo 

func (m *MarketUpdateMessage_OrderBookLiquidityUpdate) MarshalTo(dAtA []byte) (int, error)

func (*MarketUpdateMessage_OrderBookLiquidityUpdate) Size 

func (m *MarketUpdateMessage_OrderBookLiquidityUpdate) Size() (n int)

type MarketUpdateMessage_OrderBookSpreadUpdate 

type MarketUpdateMessage_OrderBookSpreadUpdate struct {
	OrderBookSpreadUpdate *OrderBookSpreadUpdate `protobuf:"bytes,11,opt,name=orderBookSpreadUpdate,proto3,oneof"`
}

func (*MarketUpdateMessage_OrderBookSpreadUpdate) MarshalTo 

func (m *MarketUpdateMessage_OrderBookSpreadUpdate) MarshalTo(dAtA []byte) (int, error)

func (*MarketUpdateMessage_OrderBookSpreadUpdate) Size 

func (m *MarketUpdateMessage_OrderBookSpreadUpdate) Size() (n int)

type MarketUpdateMessage_OrderBookUpdate 

type MarketUpdateMessage_OrderBookUpdate struct {
	OrderBookUpdate *OrderBookUpdate `protobuf:"bytes,2,opt,name=orderBookUpdate,proto3,oneof"`
}

func (*MarketUpdateMessage_OrderBookUpdate) MarshalTo 

func (m *MarketUpdateMessage_OrderBookUpdate) MarshalTo(dAtA []byte) (int, error)

func (*MarketUpdateMessage_OrderBookUpdate) Size 

func (m *MarketUpdateMessage_OrderBookUpdate) Size() (n int)

type MarketUpdateMessage_SparklineUpdate 

type MarketUpdateMessage_SparklineUpdate struct {
	SparklineUpdate *SparklineUpdate `protobuf:"bytes,7,opt,name=sparklineUpdate,proto3,oneof"`
}

func (*MarketUpdateMessage_SparklineUpdate) MarshalTo 

func (m *MarketUpdateMessage_SparklineUpdate) MarshalTo(dAtA []byte) (int, error)

func (*MarketUpdateMessage_SparklineUpdate) Size 

func (m *MarketUpdateMessage_SparklineUpdate) Size() (n int)

type MarketUpdateMessage_SummaryUpdate 

type MarketUpdateMessage_SummaryUpdate struct {
	SummaryUpdate *SummaryUpdate `protobuf:"bytes,6,opt,name=summaryUpdate,proto3,oneof"`
}

func (*MarketUpdateMessage_SummaryUpdate) MarshalTo 

func (m *MarketUpdateMessage_SummaryUpdate) MarshalTo(dAtA []byte) (int, error)

func (*MarketUpdateMessage_SummaryUpdate) Size 

func (m *MarketUpdateMessage_SummaryUpdate) Size() (n int)

type MarketUpdateMessage_TradesUpdate 

type MarketUpdateMessage_TradesUpdate struct {
	TradesUpdate *TradesUpdate `protobuf:"bytes,4,opt,name=tradesUpdate,proto3,oneof"`
}

func (*MarketUpdateMessage_TradesUpdate) MarshalTo 

func (m *MarketUpdateMessage_TradesUpdate) MarshalTo(dAtA []byte) (int, error)

func (*MarketUpdateMessage_TradesUpdate) Size 

func (m *MarketUpdateMessage_TradesUpdate) Size() (n int)

type Order 

type Order struct {
	PriceStr  string `protobuf:"bytes,3,opt,name=priceStr,proto3" json:"priceStr,omitempty"`
	AmountStr string `protobuf:"bytes,4,opt,name=amountStr,proto3" json:"amountStr,omitempty"`
	// Deprecated
	Price                float32  `protobuf:"fixed32,1,opt,name=price,proto3" json:"price,omitempty"`
	Amount               float32  `protobuf:"fixed32,2,opt,name=amount,proto3" json:"amount,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Order represents an ask or a bid.

func (*Order) Descriptor 

func (*Order) Descriptor() ([]byte, []int)

func (*Order) GetAmount 

func (m *Order) GetAmount() float32

func (*Order) GetAmountStr 

func (m *Order) GetAmountStr() string

func (*Order) GetPrice 

func (m *Order) GetPrice() float32

func (*Order) GetPriceStr 

func (m *Order) GetPriceStr() string

func (*Order) Marshal 

func (m *Order) Marshal() (dAtA []byte, err error)

func (*Order) MarshalTo 

func (m *Order) MarshalTo(dAtA []byte) (int, error)

func (*Order) ProtoMessage 

func (*Order) ProtoMessage()

func (*Order) Reset 

func (m *Order) Reset()

func (*Order) Size 

func (m *Order) Size() (n int)

func (*Order) String 

func (m *Order) String() string

func (*Order) Unmarshal 

func (m *Order) Unmarshal(dAtA []byte) error

func (*Order) XXX_DiscardUnknown 

func (m *Order) XXX_DiscardUnknown()

func (*Order) XXX_Marshal 

func (m *Order) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Order) XXX_Merge 

func (dst *Order) XXX_Merge(src proto.Message)

func (*Order) XXX_Size 

func (m *Order) XXX_Size() int

func (*Order) XXX_Unmarshal 

func (m *Order) XXX_Unmarshal(b []byte) error

type OrderBookDeltaUpdate 

type OrderBookDeltaUpdate struct {
	// Aggregation modulus is a value which all bids and asks in this particular
	// OrderBookUpdate are divisible by. E.g. could be 1 (no aggregation), 5, 10,
	// 50, 100, etc. Exact possible values are set for each market individually.
	AggregationModulus    float32 `protobuf:"fixed32,3,opt,name=aggregationModulus,proto3" json:"aggregationModulus,omitempty"`
	AggregationModulusStr string  `protobuf:"bytes,4,opt,name=aggregationModulusStr,proto3" json:"aggregationModulusStr,omitempty"`
	SeqNum                int32   `protobuf:"varint,5,opt,name=seqNum,proto3" json:"seqNum,omitempty"`
	// Deltas for bids
	Bids *OrderBookDeltaUpdate_OrderDeltas `protobuf:"bytes,1,opt,name=bids,proto3" json:"bids,omitempty"`
	// Deltas for asks
	Asks                 *OrderBookDeltaUpdate_OrderDeltas `protobuf:"bytes,2,opt,name=asks,proto3" json:"asks,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                          `json:"-"`
	XXX_unrecognized     []byte                            `json:"-"`
	XXX_sizecache        int32                             `json:"-"`
}

OrderBookDeltaUpdate represents a delta which needs to be applied to the local order book.

func (*OrderBookDeltaUpdate) Descriptor 

func (*OrderBookDeltaUpdate) Descriptor() ([]byte, []int)

func (*OrderBookDeltaUpdate) GetAggregationModulus 

func (m *OrderBookDeltaUpdate) GetAggregationModulus() float32

func (*OrderBookDeltaUpdate) GetAggregationModulusStr 

func (m *OrderBookDeltaUpdate) GetAggregationModulusStr() string

func (*OrderBookDeltaUpdate) GetAsks 

func (m *OrderBookDeltaUpdate) GetAsks() *OrderBookDeltaUpdate_OrderDeltas

func (*OrderBookDeltaUpdate) GetBids 

func (m *OrderBookDeltaUpdate) GetBids() *OrderBookDeltaUpdate_OrderDeltas

func (*OrderBookDeltaUpdate) GetSeqNum 

func (m *OrderBookDeltaUpdate) GetSeqNum() int32

func (*OrderBookDeltaUpdate) Marshal 

func (m *OrderBookDeltaUpdate) Marshal() (dAtA []byte, err error)

func (*OrderBookDeltaUpdate) MarshalTo 

func (m *OrderBookDeltaUpdate) MarshalTo(dAtA []byte) (int, error)

func (*OrderBookDeltaUpdate) ProtoMessage 

func (*OrderBookDeltaUpdate) ProtoMessage()

func (*OrderBookDeltaUpdate) Reset 

func (m *OrderBookDeltaUpdate) Reset()

func (*OrderBookDeltaUpdate) Size 

func (m *OrderBookDeltaUpdate) Size() (n int)

func (*OrderBookDeltaUpdate) String 

func (m *OrderBookDeltaUpdate) String() string

func (*OrderBookDeltaUpdate) Unmarshal 

func (m *OrderBookDeltaUpdate) Unmarshal(dAtA []byte) error

func (*OrderBookDeltaUpdate) XXX_DiscardUnknown 

func (m *OrderBookDeltaUpdate) XXX_DiscardUnknown()

func (*OrderBookDeltaUpdate) XXX_Marshal 

func (m *OrderBookDeltaUpdate) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*OrderBookDeltaUpdate) XXX_Merge 

func (dst *OrderBookDeltaUpdate) XXX_Merge(src proto.Message)

func (*OrderBookDeltaUpdate) XXX_Size 

func (m *OrderBookDeltaUpdate) XXX_Size() int

func (*OrderBookDeltaUpdate) XXX_Unmarshal 

func (m *OrderBookDeltaUpdate) XXX_Unmarshal(b []byte) error

type OrderBookDeltaUpdate_OrderDeltas 

type OrderBookDeltaUpdate_OrderDeltas struct {
	// Either add a new order at a particular price, or replace existing one
	// (with the new amount)
	Set []*Order `protobuf:"bytes,1,rep,name=set,proto3" json:"set,omitempty"`
	// TODO: I see we don't really use deltas, and just use set?
	Delta []*Order `protobuf:"bytes,2,rep,name=delta,proto3" json:"delta,omitempty"`
	// Remove order at a particular price
	Remove               []float32 `protobuf:"fixed32,3,rep,name=remove,proto3" json:"remove,omitempty"`
	RemoveStr            []string  `protobuf:"bytes,4,rep,name=removeStr,proto3" json:"removeStr,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*OrderBookDeltaUpdate_OrderDeltas) Descriptor 

func (*OrderBookDeltaUpdate_OrderDeltas) Descriptor() ([]byte, []int)

func (*OrderBookDeltaUpdate_OrderDeltas) GetDelta 

func (m *OrderBookDeltaUpdate_OrderDeltas) GetDelta() []*Order

func (*OrderBookDeltaUpdate_OrderDeltas) GetRemove 

func (m *OrderBookDeltaUpdate_OrderDeltas) GetRemove() []float32

func (*OrderBookDeltaUpdate_OrderDeltas) GetRemoveStr 

func (m *OrderBookDeltaUpdate_OrderDeltas) GetRemoveStr() []string

func (*OrderBookDeltaUpdate_OrderDeltas) GetSet 

func (m *OrderBookDeltaUpdate_OrderDeltas) GetSet() []*Order

func (*OrderBookDeltaUpdate_OrderDeltas) Marshal 

func (m *OrderBookDeltaUpdate_OrderDeltas) Marshal() (dAtA []byte, err error)

func (*OrderBookDeltaUpdate_OrderDeltas) MarshalTo 

func (m *OrderBookDeltaUpdate_OrderDeltas) MarshalTo(dAtA []byte) (int, error)

func (*OrderBookDeltaUpdate_OrderDeltas) ProtoMessage 

func (*OrderBookDeltaUpdate_OrderDeltas) ProtoMessage()

func (*OrderBookDeltaUpdate_OrderDeltas) Reset 

func (m *OrderBookDeltaUpdate_OrderDeltas) Reset()

func (*OrderBookDeltaUpdate_OrderDeltas) Size 

func (m *OrderBookDeltaUpdate_OrderDeltas) Size() (n int)

func (*OrderBookDeltaUpdate_OrderDeltas) String 

func (m *OrderBookDeltaUpdate_OrderDeltas) String() string

func (*OrderBookDeltaUpdate_OrderDeltas) Unmarshal 

func (m *OrderBookDeltaUpdate_OrderDeltas) Unmarshal(dAtA []byte) error

func (*OrderBookDeltaUpdate_OrderDeltas) XXX_DiscardUnknown 

func (m *OrderBookDeltaUpdate_OrderDeltas) XXX_DiscardUnknown()

func (*OrderBookDeltaUpdate_OrderDeltas) XXX_Marshal 

func (m *OrderBookDeltaUpdate_OrderDeltas) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*OrderBookDeltaUpdate_OrderDeltas) XXX_Merge 

func (dst *OrderBookDeltaUpdate_OrderDeltas) XXX_Merge(src proto.Message)

func (*OrderBookDeltaUpdate_OrderDeltas) XXX_Size 

func (m *OrderBookDeltaUpdate_OrderDeltas) XXX_Size() int

func (*OrderBookDeltaUpdate_OrderDeltas) XXX_Unmarshal 

func (m *OrderBookDeltaUpdate_OrderDeltas) XXX_Unmarshal(b []byte) error

type OrderBookLiquidityUpdate 

type OrderBookLiquidityUpdate struct {
	Timestamp            int64                                                  `protobuf:"varint,1,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	Bid                  *OrderBookLiquidityUpdate_OrderBookLiquidityUpdateSide `protobuf:"bytes,2,opt,name=bid,proto3" json:"bid,omitempty"`
	Ask                  *OrderBookLiquidityUpdate_OrderBookLiquidityUpdateSide `protobuf:"bytes,3,opt,name=ask,proto3" json:"ask,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                                               `json:"-"`
	XXX_unrecognized     []byte                                                 `json:"-"`
	XXX_sizecache        int32                                                  `json:"-"`
}

OrderBookLiquidityUpdate represents sums for various bips in the book

func (*OrderBookLiquidityUpdate) Descriptor 

func (*OrderBookLiquidityUpdate) Descriptor() ([]byte, []int)

func (*OrderBookLiquidityUpdate) GetAsk 

func (m *OrderBookLiquidityUpdate) GetAsk() *OrderBookLiquidityUpdate_OrderBookLiquidityUpdateSide

func (*OrderBookLiquidityUpdate) GetBid 

func (m *OrderBookLiquidityUpdate) GetBid() *OrderBookLiquidityUpdate_OrderBookLiquidityUpdateSide

func (*OrderBookLiquidityUpdate) GetTimestamp 

func (m *OrderBookLiquidityUpdate) GetTimestamp() int64

func (*OrderBookLiquidityUpdate) Marshal 

func (m *OrderBookLiquidityUpdate) Marshal() (dAtA []byte, err error)

func (*OrderBookLiquidityUpdate) MarshalTo 

func (m *OrderBookLiquidityUpdate) MarshalTo(dAtA []byte) (int, error)

func (*OrderBookLiquidityUpdate) ProtoMessage 

func (*OrderBookLiquidityUpdate) ProtoMessage()

func (*OrderBookLiquidityUpdate) Reset 

func (m *OrderBookLiquidityUpdate) Reset()

func (*OrderBookLiquidityUpdate) Size 

func (m *OrderBookLiquidityUpdate) Size() (n int)

func (*OrderBookLiquidityUpdate) String 

func (m *OrderBookLiquidityUpdate) String() string

func (*OrderBookLiquidityUpdate) Unmarshal 

func (m *OrderBookLiquidityUpdate) Unmarshal(dAtA []byte) error

func (*OrderBookLiquidityUpdate) XXX_DiscardUnknown 

func (m *OrderBookLiquidityUpdate) XXX_DiscardUnknown()

func (*OrderBookLiquidityUpdate) XXX_Marshal 

func (m *OrderBookLiquidityUpdate) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*OrderBookLiquidityUpdate) XXX_Merge 

func (dst *OrderBookLiquidityUpdate) XXX_Merge(src proto.Message)

func (*OrderBookLiquidityUpdate) XXX_Size 

func (m *OrderBookLiquidityUpdate) XXX_Size() int

func (*OrderBookLiquidityUpdate) XXX_Unmarshal 

func (m *OrderBookLiquidityUpdate) XXX_Unmarshal(b []byte) error

type OrderBookLiquidityUpdate_OrderBookLiquiditySums 

type OrderBookLiquidityUpdate_OrderBookLiquiditySums struct {
	TotalBase            string   `protobuf:"bytes,1,opt,name=totalBase,proto3" json:"totalBase,omitempty"`
	TotalQuote           string   `protobuf:"bytes,2,opt,name=totalQuote,proto3" json:"totalQuote,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*OrderBookLiquidityUpdate_OrderBookLiquiditySums) Descriptor 

func (*OrderBookLiquidityUpdate_OrderBookLiquiditySums) Descriptor() ([]byte, []int)

func (*OrderBookLiquidityUpdate_OrderBookLiquiditySums) GetTotalBase 

func (m *OrderBookLiquidityUpdate_OrderBookLiquiditySums) GetTotalBase() string

func (*OrderBookLiquidityUpdate_OrderBookLiquiditySums) GetTotalQuote 

func (m *OrderBookLiquidityUpdate_OrderBookLiquiditySums) GetTotalQuote() string

func (*OrderBookLiquidityUpdate_OrderBookLiquiditySums) Marshal 

func (m *OrderBookLiquidityUpdate_OrderBookLiquiditySums) Marshal() (dAtA []byte, err error)

func (*OrderBookLiquidityUpdate_OrderBookLiquiditySums) MarshalTo 

func (m *OrderBookLiquidityUpdate_OrderBookLiquiditySums) MarshalTo(dAtA []byte) (int, error)

func (*OrderBookLiquidityUpdate_OrderBookLiquiditySums) ProtoMessage 

func (*OrderBookLiquidityUpdate_OrderBookLiquiditySums) ProtoMessage()

func (*OrderBookLiquidityUpdate_OrderBookLiquiditySums) Reset 

func (m *OrderBookLiquidityUpdate_OrderBookLiquiditySums) Reset()

func (*OrderBookLiquidityUpdate_OrderBookLiquiditySums) Size 

func (m *OrderBookLiquidityUpdate_OrderBookLiquiditySums) Size() (n int)

func (*OrderBookLiquidityUpdate_OrderBookLiquiditySums) String 

func (m *OrderBookLiquidityUpdate_OrderBookLiquiditySums) String() string

func (*OrderBookLiquidityUpdate_OrderBookLiquiditySums) Unmarshal 

func (m *OrderBookLiquidityUpdate_OrderBookLiquiditySums) Unmarshal(dAtA []byte) error

func (*OrderBookLiquidityUpdate_OrderBookLiquiditySums) XXX_DiscardUnknown 

func (m *OrderBookLiquidityUpdate_OrderBookLiquiditySums) XXX_DiscardUnknown()

func (*OrderBookLiquidityUpdate_OrderBookLiquiditySums) XXX_Marshal 

func (m *OrderBookLiquidityUpdate_OrderBookLiquiditySums) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*OrderBookLiquidityUpdate_OrderBookLiquiditySums) XXX_Merge 

func (dst *OrderBookLiquidityUpdate_OrderBookLiquiditySums) XXX_Merge(src proto.Message)

func (*OrderBookLiquidityUpdate_OrderBookLiquiditySums) XXX_Size 

func (m *OrderBookLiquidityUpdate_OrderBookLiquiditySums) XXX_Size() int

func (*OrderBookLiquidityUpdate_OrderBookLiquiditySums) XXX_Unmarshal 

func (m *OrderBookLiquidityUpdate_OrderBookLiquiditySums) XXX_Unmarshal(b []byte) error

type OrderBookLiquidityUpdate_OrderBookLiquidityUpdateSide 

type OrderBookLiquidityUpdate_OrderBookLiquidityUpdateSide struct {
	Bip25                *OrderBookLiquidityUpdate_OrderBookLiquiditySums `protobuf:"bytes,1,opt,name=bip25,proto3" json:"bip25,omitempty"`
	Bip50                *OrderBookLiquidityUpdate_OrderBookLiquiditySums `protobuf:"bytes,2,opt,name=bip50,proto3" json:"bip50,omitempty"`
	Bip75                *OrderBookLiquidityUpdate_OrderBookLiquiditySums `protobuf:"bytes,3,opt,name=bip75,proto3" json:"bip75,omitempty"`
	Bip100               *OrderBookLiquidityUpdate_OrderBookLiquiditySums `protobuf:"bytes,4,opt,name=bip100,proto3" json:"bip100,omitempty"`
	Bip150               *OrderBookLiquidityUpdate_OrderBookLiquiditySums `protobuf:"bytes,5,opt,name=bip150,proto3" json:"bip150,omitempty"`
	Bip200               *OrderBookLiquidityUpdate_OrderBookLiquiditySums `protobuf:"bytes,6,opt,name=bip200,proto3" json:"bip200,omitempty"`
	Bip250               *OrderBookLiquidityUpdate_OrderBookLiquiditySums `protobuf:"bytes,7,opt,name=bip250,proto3" json:"bip250,omitempty"`
	Bip300               *OrderBookLiquidityUpdate_OrderBookLiquiditySums `protobuf:"bytes,8,opt,name=bip300,proto3" json:"bip300,omitempty"`
	Bip400               *OrderBookLiquidityUpdate_OrderBookLiquiditySums `protobuf:"bytes,9,opt,name=bip400,proto3" json:"bip400,omitempty"`
	Bip500               *OrderBookLiquidityUpdate_OrderBookLiquiditySums `protobuf:"bytes,10,opt,name=bip500,proto3" json:"bip500,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                                         `json:"-"`
	XXX_unrecognized     []byte                                           `json:"-"`
	XXX_sizecache        int32                                            `json:"-"`
}

func (*OrderBookLiquidityUpdate_OrderBookLiquidityUpdateSide) Descriptor 

func (*OrderBookLiquidityUpdate_OrderBookLiquidityUpdateSide) Descriptor() ([]byte, []int)

func (*OrderBookLiquidityUpdate_OrderBookLiquidityUpdateSide) GetBip100 

func (m *OrderBookLiquidityUpdate_OrderBookLiquidityUpdateSide) GetBip100() *OrderBookLiquidityUpdate_OrderBookLiquiditySums

func (*OrderBookLiquidityUpdate_OrderBookLiquidityUpdateSide) GetBip150 

func (m *OrderBookLiquidityUpdate_OrderBookLiquidityUpdateSide) GetBip150() *OrderBookLiquidityUpdate_OrderBookLiquiditySums

func (*OrderBookLiquidityUpdate_OrderBookLiquidityUpdateSide) GetBip200 

func (m *OrderBookLiquidityUpdate_OrderBookLiquidityUpdateSide) GetBip200() *OrderBookLiquidityUpdate_OrderBookLiquiditySums

func (*OrderBookLiquidityUpdate_OrderBookLiquidityUpdateSide) GetBip25 

func (m *OrderBookLiquidityUpdate_OrderBookLiquidityUpdateSide) GetBip25() *OrderBookLiquidityUpdate_OrderBookLiquiditySums

func (*OrderBookLiquidityUpdate_OrderBookLiquidityUpdateSide) GetBip250 

func (m *OrderBookLiquidityUpdate_OrderBookLiquidityUpdateSide) GetBip250() *OrderBookLiquidityUpdate_OrderBookLiquiditySums

func (*OrderBookLiquidityUpdate_OrderBookLiquidityUpdateSide) GetBip300 

func (m *OrderBookLiquidityUpdate_OrderBookLiquidityUpdateSide) GetBip300() *OrderBookLiquidityUpdate_OrderBookLiquiditySums

func (*OrderBookLiquidityUpdate_OrderBookLiquidityUpdateSide) GetBip400 

func (m *OrderBookLiquidityUpdate_OrderBookLiquidityUpdateSide) GetBip400() *OrderBookLiquidityUpdate_OrderBookLiquiditySums

func (*OrderBookLiquidityUpdate_OrderBookLiquidityUpdateSide) GetBip50 

func (m *OrderBookLiquidityUpdate_OrderBookLiquidityUpdateSide) GetBip50() *OrderBookLiquidityUpdate_OrderBookLiquiditySums

func (*OrderBookLiquidityUpdate_OrderBookLiquidityUpdateSide) GetBip500 

func (m *OrderBookLiquidityUpdate_OrderBookLiquidityUpdateSide) GetBip500() *OrderBookLiquidityUpdate_OrderBookLiquiditySums

func (*OrderBookLiquidityUpdate_OrderBookLiquidityUpdateSide) GetBip75 

func (m *OrderBookLiquidityUpdate_OrderBookLiquidityUpdateSide) GetBip75() *OrderBookLiquidityUpdate_OrderBookLiquiditySums

func (*OrderBookLiquidityUpdate_OrderBookLiquidityUpdateSide) Marshal 

func (m *OrderBookLiquidityUpdate_OrderBookLiquidityUpdateSide) Marshal() (dAtA []byte, err error)

func (*OrderBookLiquidityUpdate_OrderBookLiquidityUpdateSide) MarshalTo 

func (m *OrderBookLiquidityUpdate_OrderBookLiquidityUpdateSide) MarshalTo(dAtA []byte) (int, error)

func (*OrderBookLiquidityUpdate_OrderBookLiquidityUpdateSide) ProtoMessage 

func (*OrderBookLiquidityUpdate_OrderBookLiquidityUpdateSide) ProtoMessage()

func (*OrderBookLiquidityUpdate_OrderBookLiquidityUpdateSide) Reset 

func (m *OrderBookLiquidityUpdate_OrderBookLiquidityUpdateSide) Reset()

func (*OrderBookLiquidityUpdate_OrderBookLiquidityUpdateSide) Size 

func (m *OrderBookLiquidityUpdate_OrderBookLiquidityUpdateSide) Size() (n int)

func (*OrderBookLiquidityUpdate_OrderBookLiquidityUpdateSide) String 

func (m *OrderBookLiquidityUpdate_OrderBookLiquidityUpdateSide) String() string

func (*OrderBookLiquidityUpdate_OrderBookLiquidityUpdateSide) Unmarshal 

func (m *OrderBookLiquidityUpdate_OrderBookLiquidityUpdateSide) Unmarshal(dAtA []byte) error

func (*OrderBookLiquidityUpdate_OrderBookLiquidityUpdateSide) XXX_DiscardUnknown 

func (m *OrderBookLiquidityUpdate_OrderBookLiquidityUpdateSide) XXX_DiscardUnknown()

func (*OrderBookLiquidityUpdate_OrderBookLiquidityUpdateSide) XXX_Marshal 

func (m *OrderBookLiquidityUpdate_OrderBookLiquidityUpdateSide) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*OrderBookLiquidityUpdate_OrderBookLiquidityUpdateSide) XXX_Merge 

func (dst *OrderBookLiquidityUpdate_OrderBookLiquidityUpdateSide) XXX_Merge(src proto.Message)

func (*OrderBookLiquidityUpdate_OrderBookLiquidityUpdateSide) XXX_Size 

func (m *OrderBookLiquidityUpdate_OrderBookLiquidityUpdateSide) XXX_Size() int

func (*OrderBookLiquidityUpdate_OrderBookLiquidityUpdateSide) XXX_Unmarshal 

func (m *OrderBookLiquidityUpdate_OrderBookLiquidityUpdateSide) XXX_Unmarshal(b []byte) error

type OrderBookSpreadUpdate 

type OrderBookSpreadUpdate struct {
	Timestamp            int64    `protobuf:"varint,1,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	Bid                  *Order   `protobuf:"bytes,2,opt,name=bid,proto3" json:"bid,omitempty"`
	Ask                  *Order   `protobuf:"bytes,3,opt,name=ask,proto3" json:"ask,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

OrderBookSpreadUpdate represents only the best bid & ask

func (*OrderBookSpreadUpdate) Descriptor 

func (*OrderBookSpreadUpdate) Descriptor() ([]byte, []int)

func (*OrderBookSpreadUpdate) GetAsk 

func (m *OrderBookSpreadUpdate) GetAsk() *Order

func (*OrderBookSpreadUpdate) GetBid 

func (m *OrderBookSpreadUpdate) GetBid() *Order

func (*OrderBookSpreadUpdate) GetTimestamp 

func (m *OrderBookSpreadUpdate) GetTimestamp() int64

func (*OrderBookSpreadUpdate) Marshal 

func (m *OrderBookSpreadUpdate) Marshal() (dAtA []byte, err error)

func (*OrderBookSpreadUpdate) MarshalTo 

func (m *OrderBookSpreadUpdate) MarshalTo(dAtA []byte) (int, error)

func (*OrderBookSpreadUpdate) ProtoMessage 

func (*OrderBookSpreadUpdate) ProtoMessage()

func (*OrderBookSpreadUpdate) Reset 

func (m *OrderBookSpreadUpdate) Reset()

func (*OrderBookSpreadUpdate) Size 

func (m *OrderBookSpreadUpdate) Size() (n int)

func (*OrderBookSpreadUpdate) String 

func (m *OrderBookSpreadUpdate) String() string

func (*OrderBookSpreadUpdate) Unmarshal 

func (m *OrderBookSpreadUpdate) Unmarshal(dAtA []byte) error

func (*OrderBookSpreadUpdate) XXX_DiscardUnknown 

func (m *OrderBookSpreadUpdate) XXX_DiscardUnknown()

func (*OrderBookSpreadUpdate) XXX_Marshal 

func (m *OrderBookSpreadUpdate) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*OrderBookSpreadUpdate) XXX_Merge 

func (dst *OrderBookSpreadUpdate) XXX_Merge(src proto.Message)

func (*OrderBookSpreadUpdate) XXX_Size 

func (m *OrderBookSpreadUpdate) XXX_Size() int

func (*OrderBookSpreadUpdate) XXX_Unmarshal 

func (m *OrderBookSpreadUpdate) XXX_Unmarshal(b []byte) error

type OrderBookUpdate 

type OrderBookUpdate struct {
	// Aggregation modulus is a value which all bids and asks in this particular
	// OrderBookUpdate are divisible by. E.g. could be 1 (no aggregation), 5, 10,
	// 50, 100, etc. Exact possible values are set for each market individually.
	AggregationModulusStr string   `protobuf:"bytes,4,opt,name=aggregationModulusStr,proto3" json:"aggregationModulusStr,omitempty"`
	SeqNum                int32    `protobuf:"varint,5,opt,name=seqNum,proto3" json:"seqNum,omitempty"`
	Bids                  []*Order `protobuf:"bytes,1,rep,name=bids,proto3" json:"bids,omitempty"`
	Asks                  []*Order `protobuf:"bytes,2,rep,name=asks,proto3" json:"asks,omitempty"`
	// Deprecated
	AggregationModulus   float32  `protobuf:"fixed32,3,opt,name=aggregationModulus,proto3" json:"aggregationModulus,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

OrderBookUpdate represents a snapshot of the order book: a set of asks and bids for the particular aggregation modulus.

func (*OrderBookUpdate) Descriptor 

func (*OrderBookUpdate) Descriptor() ([]byte, []int)

func (*OrderBookUpdate) GetAggregationModulus 

func (m *OrderBookUpdate) GetAggregationModulus() float32

func (*OrderBookUpdate) GetAggregationModulusStr 

func (m *OrderBookUpdate) GetAggregationModulusStr() string

func (*OrderBookUpdate) GetAsks 

func (m *OrderBookUpdate) GetAsks() []*Order

func (*OrderBookUpdate) GetBids 

func (m *OrderBookUpdate) GetBids() []*Order

func (*OrderBookUpdate) GetSeqNum 

func (m *OrderBookUpdate) GetSeqNum() int32

func (*OrderBookUpdate) Marshal 

func (m *OrderBookUpdate) Marshal() (dAtA []byte, err error)

func (*OrderBookUpdate) MarshalTo 

func (m *OrderBookUpdate) MarshalTo(dAtA []byte) (int, error)

func (*OrderBookUpdate) ProtoMessage 

func (*OrderBookUpdate) ProtoMessage()

func (*OrderBookUpdate) Reset 

func (m *OrderBookUpdate) Reset()

func (*OrderBookUpdate) Size 

func (m *OrderBookUpdate) Size() (n int)

func (*OrderBookUpdate) String 

func (m *OrderBookUpdate) String() string

func (*OrderBookUpdate) Unmarshal 

func (m *OrderBookUpdate) Unmarshal(dAtA []byte) error

func (*OrderBookUpdate) XXX_DiscardUnknown 

func (m *OrderBookUpdate) XXX_DiscardUnknown()

func (*OrderBookUpdate) XXX_Marshal 

func (m *OrderBookUpdate) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*OrderBookUpdate) XXX_Merge 

func (dst *OrderBookUpdate) XXX_Merge(src proto.Message)

func (*OrderBookUpdate) XXX_Size 

func (m *OrderBookUpdate) XXX_Size() int

func (*OrderBookUpdate) XXX_Unmarshal 

func (m *OrderBookUpdate) XXX_Unmarshal(b []byte) error

type PairPerformanceUpdate 

type PairPerformanceUpdate struct {
	Window               string   `protobuf:"bytes,1,opt,name=window,proto3" json:"window,omitempty"`
	Performance          float64  `protobuf:"fixed64,2,opt,name=performance,proto3" json:"performance,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PairPerformanceUpdate) Descriptor 

func (*PairPerformanceUpdate) Descriptor() ([]byte, []int)

func (*PairPerformanceUpdate) GetPerformance 

func (m *PairPerformanceUpdate) GetPerformance() float64

func (*PairPerformanceUpdate) GetWindow 

func (m *PairPerformanceUpdate) GetWindow() string

func (*PairPerformanceUpdate) Marshal 

func (m *PairPerformanceUpdate) Marshal() (dAtA []byte, err error)

func (*PairPerformanceUpdate) MarshalTo 

func (m *PairPerformanceUpdate) MarshalTo(dAtA []byte) (int, error)

func (*PairPerformanceUpdate) ProtoMessage 

func (*PairPerformanceUpdate) ProtoMessage()

func (*PairPerformanceUpdate) Reset 

func (m *PairPerformanceUpdate) Reset()

func (*PairPerformanceUpdate) Size 

func (m *PairPerformanceUpdate) Size() (n int)

func (*PairPerformanceUpdate) String 

func (m *PairPerformanceUpdate) String() string

func (*PairPerformanceUpdate) Unmarshal 

func (m *PairPerformanceUpdate) Unmarshal(dAtA []byte) error

func (*PairPerformanceUpdate) XXX_DiscardUnknown 

func (m *PairPerformanceUpdate) XXX_DiscardUnknown()

func (*PairPerformanceUpdate) XXX_Marshal 

func (m *PairPerformanceUpdate) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PairPerformanceUpdate) XXX_Merge 

func (dst *PairPerformanceUpdate) XXX_Merge(src proto.Message)

func (*PairPerformanceUpdate) XXX_Size 

func (m *PairPerformanceUpdate) XXX_Size() int

func (*PairPerformanceUpdate) XXX_Unmarshal 

func (m *PairPerformanceUpdate) XXX_Unmarshal(b []byte) error

type PairTrendlineUpdate 

type PairTrendlineUpdate struct {
	Window               string   `protobuf:"bytes,1,opt,name=window,proto3" json:"window,omitempty"`
	Time                 int64    `protobuf:"varint,2,opt,name=time,proto3" json:"time,omitempty"`
	Price                string   `protobuf:"bytes,3,opt,name=price,proto3" json:"price,omitempty"`
	Volume               string   `protobuf:"bytes,4,opt,name=volume,proto3" json:"volume,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PairTrendlineUpdate) Descriptor 

func (*PairTrendlineUpdate) Descriptor() ([]byte, []int)

func (*PairTrendlineUpdate) GetPrice 

func (m *PairTrendlineUpdate) GetPrice() string

func (*PairTrendlineUpdate) GetTime 

func (m *PairTrendlineUpdate) GetTime() int64

func (*PairTrendlineUpdate) GetVolume 

func (m *PairTrendlineUpdate) GetVolume() string

func (*PairTrendlineUpdate) GetWindow 

func (m *PairTrendlineUpdate) GetWindow() string

func (*PairTrendlineUpdate) Marshal 

func (m *PairTrendlineUpdate) Marshal() (dAtA []byte, err error)

func (*PairTrendlineUpdate) MarshalTo 

func (m *PairTrendlineUpdate) MarshalTo(dAtA []byte) (int, error)

func (*PairTrendlineUpdate) ProtoMessage 

func (*PairTrendlineUpdate) ProtoMessage()

func (*PairTrendlineUpdate) Reset 

func (m *PairTrendlineUpdate) Reset()

func (*PairTrendlineUpdate) Size 

func (m *PairTrendlineUpdate) Size() (n int)

func (*PairTrendlineUpdate) String 

func (m *PairTrendlineUpdate) String() string

func (*PairTrendlineUpdate) Unmarshal 

func (m *PairTrendlineUpdate) Unmarshal(dAtA []byte) error

func (*PairTrendlineUpdate) XXX_DiscardUnknown 

func (m *PairTrendlineUpdate) XXX_DiscardUnknown()

func (*PairTrendlineUpdate) XXX_Marshal 

func (m *PairTrendlineUpdate) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PairTrendlineUpdate) XXX_Merge 

func (dst *PairTrendlineUpdate) XXX_Merge(src proto.Message)

func (*PairTrendlineUpdate) XXX_Size 

func (m *PairTrendlineUpdate) XXX_Size() int

func (*PairTrendlineUpdate) XXX_Unmarshal 

func (m *PairTrendlineUpdate) XXX_Unmarshal(b []byte) error

type PairUpdateMessage 

type PairUpdateMessage struct {
	Pair uint64 `protobuf:"varint,1,opt,name=pair,proto3" json:"pair,omitempty"`
	// Types that are valid to be assigned to Update:
	//	*PairUpdateMessage_VwapUpdate
	//	*PairUpdateMessage_PerformanceUpdate
	//	*PairUpdateMessage_TrendlineUpdate
	Update               isPairUpdateMessage_Update `protobuf_oneof:"Update"`
	XXX_NoUnkeyedLiteral struct{}                   `json:"-"`
	XXX_unrecognized     []byte                     `json:"-"`
	XXX_sizecache        int32                      `json:"-"`
}

func (*PairUpdateMessage) Descriptor 

func (*PairUpdateMessage) Descriptor() ([]byte, []int)

func (*PairUpdateMessage) GetPair 

func (m *PairUpdateMessage) GetPair() uint64

func (*PairUpdateMessage) GetPerformanceUpdate 

func (m *PairUpdateMessage) GetPerformanceUpdate() *PairPerformanceUpdate

func (*PairUpdateMessage) GetTrendlineUpdate 

func (m *PairUpdateMessage) GetTrendlineUpdate() *PairTrendlineUpdate

func (*PairUpdateMessage) GetUpdate 

func (m *PairUpdateMessage) GetUpdate() isPairUpdateMessage_Update

func (*PairUpdateMessage) GetVwapUpdate 

func (m *PairUpdateMessage) GetVwapUpdate() *PairVwapUpdate

func (*PairUpdateMessage) Marshal 

func (m *PairUpdateMessage) Marshal() (dAtA []byte, err error)

func (*PairUpdateMessage) MarshalTo 

func (m *PairUpdateMessage) MarshalTo(dAtA []byte) (int, error)

func (*PairUpdateMessage) ProtoMessage 

func (*PairUpdateMessage) ProtoMessage()

func (*PairUpdateMessage) Reset 

func (m *PairUpdateMessage) Reset()

func (*PairUpdateMessage) Size 

func (m *PairUpdateMessage) Size() (n int)

func (*PairUpdateMessage) String 

func (m *PairUpdateMessage) String() string

func (*PairUpdateMessage) Unmarshal 

func (m *PairUpdateMessage) Unmarshal(dAtA []byte) error

func (*PairUpdateMessage) XXX_DiscardUnknown 

func (m *PairUpdateMessage) XXX_DiscardUnknown()

func (*PairUpdateMessage) XXX_Marshal 

func (m *PairUpdateMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PairUpdateMessage) XXX_Merge 

func (dst *PairUpdateMessage) XXX_Merge(src proto.Message)

func (*PairUpdateMessage) XXX_OneofFuncs 

func (*PairUpdateMessage) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})

XXX_OneofFuncs is for the internal use of the proto package.

func (*PairUpdateMessage) XXX_Size 

func (m *PairUpdateMessage) XXX_Size() int

func (*PairUpdateMessage) XXX_Unmarshal 

func (m *PairUpdateMessage) XXX_Unmarshal(b []byte) error

type PairUpdateMessage_PerformanceUpdate 

type PairUpdateMessage_PerformanceUpdate struct {
	PerformanceUpdate *PairPerformanceUpdate `protobuf:"bytes,3,opt,name=performanceUpdate,proto3,oneof"`
}

func (*PairUpdateMessage_PerformanceUpdate) MarshalTo 

func (m *PairUpdateMessage_PerformanceUpdate) MarshalTo(dAtA []byte) (int, error)

func (*PairUpdateMessage_PerformanceUpdate) Size 

func (m *PairUpdateMessage_PerformanceUpdate) Size() (n int)

type PairUpdateMessage_TrendlineUpdate 

type PairUpdateMessage_TrendlineUpdate struct {
	TrendlineUpdate *PairTrendlineUpdate `protobuf:"bytes,4,opt,name=trendlineUpdate,proto3,oneof"`
}

func (*PairUpdateMessage_TrendlineUpdate) MarshalTo 

func (m *PairUpdateMessage_TrendlineUpdate) MarshalTo(dAtA []byte) (int, error)

func (*PairUpdateMessage_TrendlineUpdate) Size 

func (m *PairUpdateMessage_TrendlineUpdate) Size() (n int)

type PairUpdateMessage_VwapUpdate 

type PairUpdateMessage_VwapUpdate struct {
	VwapUpdate *PairVwapUpdate `protobuf:"bytes,2,opt,name=vwapUpdate,proto3,oneof"`
}

func (*PairUpdateMessage_VwapUpdate) MarshalTo 

func (m *PairUpdateMessage_VwapUpdate) MarshalTo(dAtA []byte) (int, error)

func (*PairUpdateMessage_VwapUpdate) Size 

func (m *PairUpdateMessage_VwapUpdate) Size() (n int)

type PairVwapUpdate 

type PairVwapUpdate struct {
	Vwap                 float64  `protobuf:"fixed64,1,opt,name=vwap,proto3" json:"vwap,omitempty"`
	Timestamp            int64    `protobuf:"varint,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PairVwapUpdate) Descriptor 

func (*PairVwapUpdate) Descriptor() ([]byte, []int)

func (*PairVwapUpdate) GetTimestamp 

func (m *PairVwapUpdate) GetTimestamp() int64

func (*PairVwapUpdate) GetVwap 

func (m *PairVwapUpdate) GetVwap() float64

func (*PairVwapUpdate) Marshal 

func (m *PairVwapUpdate) Marshal() (dAtA []byte, err error)

func (*PairVwapUpdate) MarshalTo 

func (m *PairVwapUpdate) MarshalTo(dAtA []byte) (int, error)

func (*PairVwapUpdate) ProtoMessage 

func (*PairVwapUpdate) ProtoMessage()

func (*PairVwapUpdate) Reset 

func (m *PairVwapUpdate) Reset()

func (*PairVwapUpdate) Size 

func (m *PairVwapUpdate) Size() (n int)

func (*PairVwapUpdate) String 

func (m *PairVwapUpdate) String() string

func (*PairVwapUpdate) Unmarshal 

func (m *PairVwapUpdate) Unmarshal(dAtA []byte) error

func (*PairVwapUpdate) XXX_DiscardUnknown 

func (m *PairVwapUpdate) XXX_DiscardUnknown()

func (*PairVwapUpdate) XXX_Marshal 

func (m *PairVwapUpdate) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PairVwapUpdate) XXX_Merge 

func (dst *PairVwapUpdate) XXX_Merge(src proto.Message)

func (*PairVwapUpdate) XXX_Size 

func (m *PairVwapUpdate) XXX_Size() int

func (*PairVwapUpdate) XXX_Unmarshal 

func (m *PairVwapUpdate) XXX_Unmarshal(b []byte) error

type SparklineUpdate 

type SparklineUpdate struct {
	Time                 int64    `protobuf:"varint,2,opt,name=time,proto3" json:"time,omitempty"`
	Price                float32  `protobuf:"fixed32,3,opt,name=price,proto3" json:"price,omitempty"`
	PriceStr             string   `protobuf:"bytes,4,opt,name=priceStr,proto3" json:"priceStr,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SparklineUpdate) Descriptor 

func (*SparklineUpdate) Descriptor() ([]byte, []int)

func (*SparklineUpdate) GetPrice 

func (m *SparklineUpdate) GetPrice() float32

func (*SparklineUpdate) GetPriceStr 

func (m *SparklineUpdate) GetPriceStr() string

func (*SparklineUpdate) GetTime 

func (m *SparklineUpdate) GetTime() int64

func (*SparklineUpdate) Marshal 

func (m *SparklineUpdate) Marshal() (dAtA []byte, err error)

func (*SparklineUpdate) MarshalTo 

func (m *SparklineUpdate) MarshalTo(dAtA []byte) (int, error)

func (*SparklineUpdate) ProtoMessage 

func (*SparklineUpdate) ProtoMessage()

func (*SparklineUpdate) Reset 

func (m *SparklineUpdate) Reset()

func (*SparklineUpdate) Size 

func (m *SparklineUpdate) Size() (n int)

func (*SparklineUpdate) String 

func (m *SparklineUpdate) String() string

func (*SparklineUpdate) Unmarshal 

func (m *SparklineUpdate) Unmarshal(dAtA []byte) error

func (*SparklineUpdate) XXX_DiscardUnknown 

func (m *SparklineUpdate) XXX_DiscardUnknown()

func (*SparklineUpdate) XXX_Marshal 

func (m *SparklineUpdate) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SparklineUpdate) XXX_Merge 

func (dst *SparklineUpdate) XXX_Merge(src proto.Message)

func (*SparklineUpdate) XXX_Size 

func (m *SparklineUpdate) XXX_Size() int

func (*SparklineUpdate) XXX_Unmarshal 

func (m *SparklineUpdate) XXX_Unmarshal(b []byte) error

type SummaryUpdate 

type SummaryUpdate struct {
	LastStr           string `protobuf:"bytes,10,opt,name=lastStr,proto3" json:"lastStr,omitempty"`
	HighStr           string `protobuf:"bytes,11,opt,name=highStr,proto3" json:"highStr,omitempty"`
	LowStr            string `protobuf:"bytes,12,opt,name=lowStr,proto3" json:"lowStr,omitempty"`
	VolumeBaseStr     string `protobuf:"bytes,13,opt,name=volumeBaseStr,proto3" json:"volumeBaseStr,omitempty"`
	VolumeQuoteStr    string `protobuf:"bytes,14,opt,name=volumeQuoteStr,proto3" json:"volumeQuoteStr,omitempty"`
	ChangeAbsoluteStr string `protobuf:"bytes,15,opt,name=changeAbsoluteStr,proto3" json:"changeAbsoluteStr,omitempty"`
	ChangePercentStr  string `protobuf:"bytes,16,opt,name=changePercentStr,proto3" json:"changePercentStr,omitempty"`
	NumTrades         int32  `protobuf:"varint,8,opt,name=numTrades,proto3" json:"numTrades,omitempty"`
	// Deprecated
	Last                 float32  `protobuf:"fixed32,2,opt,name=last,proto3" json:"last,omitempty"`
	High                 float32  `protobuf:"fixed32,3,opt,name=high,proto3" json:"high,omitempty"`
	Low                  float32  `protobuf:"fixed32,4,opt,name=low,proto3" json:"low,omitempty"`
	VolumeBase           float32  `protobuf:"fixed32,5,opt,name=volumeBase,proto3" json:"volumeBase,omitempty"`
	VolumeQuote          float32  `protobuf:"fixed32,9,opt,name=volumeQuote,proto3" json:"volumeQuote,omitempty"`
	ChangeAbsolute       float32  `protobuf:"fixed32,6,opt,name=changeAbsolute,proto3" json:"changeAbsolute,omitempty"`
	ChangePercent        float32  `protobuf:"fixed32,7,opt,name=changePercent,proto3" json:"changePercent,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

SummaryUpdate is a market summary update

func (*SummaryUpdate) Descriptor 

func (*SummaryUpdate) Descriptor() ([]byte, []int)

func (*SummaryUpdate) GetChangeAbsolute 

func (m *SummaryUpdate) GetChangeAbsolute() float32

func (*SummaryUpdate) GetChangeAbsoluteStr 

func (m *SummaryUpdate) GetChangeAbsoluteStr() string

func (*SummaryUpdate) GetChangePercent 

func (m *SummaryUpdate) GetChangePercent() float32

func (*SummaryUpdate) GetChangePercentStr 

func (m *SummaryUpdate) GetChangePercentStr() string

func (*SummaryUpdate) GetHigh 

func (m *SummaryUpdate) GetHigh() float32

func (*SummaryUpdate) GetHighStr 

func (m *SummaryUpdate) GetHighStr() string

func (*SummaryUpdate) GetLast 

func (m *SummaryUpdate) GetLast() float32

func (*SummaryUpdate) GetLastStr 

func (m *SummaryUpdate) GetLastStr() string

func (*SummaryUpdate) GetLow 

func (m *SummaryUpdate) GetLow() float32

func (*SummaryUpdate) GetLowStr 

func (m *SummaryUpdate) GetLowStr() string

func (*SummaryUpdate) GetNumTrades 

func (m *SummaryUpdate) GetNumTrades() int32

func (*SummaryUpdate) GetVolumeBase 

func (m *SummaryUpdate) GetVolumeBase() float32

func (*SummaryUpdate) GetVolumeBaseStr 

func (m *SummaryUpdate) GetVolumeBaseStr() string

func (*SummaryUpdate) GetVolumeQuote 

func (m *SummaryUpdate) GetVolumeQuote() float32

func (*SummaryUpdate) GetVolumeQuoteStr 

func (m *SummaryUpdate) GetVolumeQuoteStr() string

func (*SummaryUpdate) Marshal 

func (m *SummaryUpdate) Marshal() (dAtA []byte, err error)

func (*SummaryUpdate) MarshalTo 

func (m *SummaryUpdate) MarshalTo(dAtA []byte) (int, error)

func (*SummaryUpdate) ProtoMessage 

func (*SummaryUpdate) ProtoMessage()

func (*SummaryUpdate) Reset 

func (m *SummaryUpdate) Reset()

func (*SummaryUpdate) Size 

func (m *SummaryUpdate) Size() (n int)

func (*SummaryUpdate) String 

func (m *SummaryUpdate) String() string

func (*SummaryUpdate) Unmarshal 

func (m *SummaryUpdate) Unmarshal(dAtA []byte) error

func (*SummaryUpdate) XXX_DiscardUnknown 

func (m *SummaryUpdate) XXX_DiscardUnknown()

func (*SummaryUpdate) XXX_Marshal 

func (m *SummaryUpdate) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SummaryUpdate) XXX_Merge 

func (dst *SummaryUpdate) XXX_Merge(src proto.Message)

func (*SummaryUpdate) XXX_Size 

func (m *SummaryUpdate) XXX_Size() int

func (*SummaryUpdate) XXX_Unmarshal 

func (m *SummaryUpdate) XXX_Unmarshal(b []byte) error

type Ticker 

type Ticker struct {
	Value     string `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	Timestamp int64  `protobuf:"varint,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// Just to keep consistency with Trade
	// this will also be called timestampNano
	TimestampNano        int64    `protobuf:"varint,3,opt,name=timestampNano,proto3" json:"timestampNano,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Ticker is just a single update instance in TickerUpdate

func (*Ticker) Descriptor 

func (*Ticker) Descriptor() ([]byte, []int)

func (*Ticker) GetTimestamp 

func (m *Ticker) GetTimestamp() int64

func (*Ticker) GetTimestampNano 

func (m *Ticker) GetTimestampNano() int64

func (*Ticker) GetValue 

func (m *Ticker) GetValue() string

func (*Ticker) Marshal 

func (m *Ticker) Marshal() (dAtA []byte, err error)

func (*Ticker) MarshalTo 

func (m *Ticker) MarshalTo(dAtA []byte) (int, error)

func (*Ticker) ProtoMessage 

func (*Ticker) ProtoMessage()

func (*Ticker) Reset 

func (m *Ticker) Reset()

func (*Ticker) Size 

func (m *Ticker) Size() (n int)

func (*Ticker) String 

func (m *Ticker) String() string

func (*Ticker) Unmarshal 

func (m *Ticker) Unmarshal(dAtA []byte) error

func (*Ticker) XXX_DiscardUnknown 

func (m *Ticker) XXX_DiscardUnknown()

func (*Ticker) XXX_Marshal 

func (m *Ticker) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Ticker) XXX_Merge 

func (dst *Ticker) XXX_Merge(src proto.Message)

func (*Ticker) XXX_Size 

func (m *Ticker) XXX_Size() int

func (*Ticker) XXX_Unmarshal 

func (m *Ticker) XXX_Unmarshal(b []byte) error

type TickerUpdate 

type TickerUpdate struct {
	Tickers              []*Ticker `protobuf:"bytes,1,rep,name=tickers,proto3" json:"tickers,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

TickerUpdate is just a single ticker message

func (*TickerUpdate) Descriptor 

func (*TickerUpdate) Descriptor() ([]byte, []int)

func (*TickerUpdate) GetTickers 

func (m *TickerUpdate) GetTickers() []*Ticker

func (*TickerUpdate) Marshal 

func (m *TickerUpdate) Marshal() (dAtA []byte, err error)

func (*TickerUpdate) MarshalTo 

func (m *TickerUpdate) MarshalTo(dAtA []byte) (int, error)

func (*TickerUpdate) ProtoMessage 

func (*TickerUpdate) ProtoMessage()

func (*TickerUpdate) Reset 

func (m *TickerUpdate) Reset()

func (*TickerUpdate) Size 

func (m *TickerUpdate) Size() (n int)

func (*TickerUpdate) String 

func (m *TickerUpdate) String() string

func (*TickerUpdate) Unmarshal 

func (m *TickerUpdate) Unmarshal(dAtA []byte) error

func (*TickerUpdate) XXX_DiscardUnknown 

func (m *TickerUpdate) XXX_DiscardUnknown()

func (*TickerUpdate) XXX_Marshal 

func (m *TickerUpdate) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TickerUpdate) XXX_Merge 

func (dst *TickerUpdate) XXX_Merge(src proto.Message)

func (*TickerUpdate) XXX_Size 

func (m *TickerUpdate) XXX_Size() int

func (*TickerUpdate) XXX_Unmarshal 

func (m *TickerUpdate) XXX_Unmarshal(b []byte) error

type Trade 

type Trade struct {
	// Exchange-specific ID
	ExternalId      string `protobuf:"bytes,11,opt,name=externalId,proto3" json:"externalId,omitempty"`
	Timestamp       int64  `protobuf:"varint,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	TimestampMillis int64  `protobuf:"varint,5,opt,name=timestampMillis,proto3" json:"timestampMillis,omitempty"`
	TimestampNano   int64  `protobuf:"varint,10,opt,name=timestampNano,proto3" json:"timestampNano,omitempty"`
	PriceStr        string `protobuf:"bytes,8,opt,name=priceStr,proto3" json:"priceStr,omitempty"`
	AmountStr       string `protobuf:"bytes,9,opt,name=amountStr,proto3" json:"amountStr,omitempty"`
	// Deprecated
	Price                float32  `protobuf:"fixed32,3,opt,name=price,proto3" json:"price,omitempty"`
	Amount               float32  `protobuf:"fixed32,4,opt,name=amount,proto3" json:"amount,omitempty"`
	PriceDouble          float64  `protobuf:"fixed64,6,opt,name=priceDouble,proto3" json:"priceDouble,omitempty"`
	AmountDouble         float64  `protobuf:"fixed64,7,opt,name=amountDouble,proto3" json:"amountDouble,omitempty"`
	Id                   int64    `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Trade is a single trade in TradesUpdate

func (*Trade) Descriptor 

func (*Trade) Descriptor() ([]byte, []int)

func (*Trade) GetAmount 

func (m *Trade) GetAmount() float32

func (*Trade) GetAmountDouble 

func (m *Trade) GetAmountDouble() float64

func (*Trade) GetAmountStr 

func (m *Trade) GetAmountStr() string

func (*Trade) GetExternalId 

func (m *Trade) GetExternalId() string

func (*Trade) GetId 

func (m *Trade) GetId() int64

func (*Trade) GetPrice 

func (m *Trade) GetPrice() float32

func (*Trade) GetPriceDouble 

func (m *Trade) GetPriceDouble() float64

func (*Trade) GetPriceStr 

func (m *Trade) GetPriceStr() string

func (*Trade) GetTimestamp 

func (m *Trade) GetTimestamp() int64

func (*Trade) GetTimestampMillis 

func (m *Trade) GetTimestampMillis() int64

func (*Trade) GetTimestampNano 

func (m *Trade) GetTimestampNano() int64

func (*Trade) Marshal 

func (m *Trade) Marshal() (dAtA []byte, err error)

func (*Trade) MarshalTo 

func (m *Trade) MarshalTo(dAtA []byte) (int, error)

func (*Trade) ProtoMessage 

func (*Trade) ProtoMessage()

func (*Trade) Reset 

func (m *Trade) Reset()

func (*Trade) Size 

func (m *Trade) Size() (n int)

func (*Trade) String 

func (m *Trade) String() string

func (*Trade) Unmarshal 

func (m *Trade) Unmarshal(dAtA []byte) error

func (*Trade) XXX_DiscardUnknown 

func (m *Trade) XXX_DiscardUnknown()

func (*Trade) XXX_Marshal 

func (m *Trade) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Trade) XXX_Merge 

func (dst *Trade) XXX_Merge(src proto.Message)

func (*Trade) XXX_Size 

func (m *Trade) XXX_Size() int

func (*Trade) XXX_Unmarshal 

func (m *Trade) XXX_Unmarshal(b []byte) error

type TradesUpdate 

type TradesUpdate struct {
	Trades               []*Trade `protobuf:"bytes,1,rep,name=trades,proto3" json:"trades,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

TradesUpdate represents a set of new trades.

func (*TradesUpdate) Descriptor 

func (*TradesUpdate) Descriptor() ([]byte, []int)

func (*TradesUpdate) GetTrades 

func (m *TradesUpdate) GetTrades() []*Trade

func (*TradesUpdate) Marshal 

func (m *TradesUpdate) Marshal() (dAtA []byte, err error)

func (*TradesUpdate) MarshalTo 

func (m *TradesUpdate) MarshalTo(dAtA []byte) (int, error)

func (*TradesUpdate) ProtoMessage 

func (*TradesUpdate) ProtoMessage()

func (*TradesUpdate) Reset 

func (m *TradesUpdate) Reset()

func (*TradesUpdate) Size 

func (m *TradesUpdate) Size() (n int)

func (*TradesUpdate) String 

func (m *TradesUpdate) String() string

func (*TradesUpdate) Unmarshal 

func (m *TradesUpdate) Unmarshal(dAtA []byte) error

func (*TradesUpdate) XXX_DiscardUnknown 

func (m *TradesUpdate) XXX_DiscardUnknown()

func (*TradesUpdate) XXX_Marshal 

func (m *TradesUpdate) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TradesUpdate) XXX_Merge 

func (dst *TradesUpdate) XXX_Merge(src proto.Message)

func (*TradesUpdate) XXX_Size 

func (m *TradesUpdate) XXX_Size() int

func (*TradesUpdate) XXX_Unmarshal 

func (m *TradesUpdate) XXX_Unmarshal(b []byte) error

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.