Enum value maps for StreamTradesResponseV1_TradeSide.
var (
StreamTradesResponseV1_TradeSide_name = map[string{
0: "UNKNOWN",
1: "BUY",
2: "SELL",
}
StreamTradesResponseV1_TradeSide_value = map[int32{
"UNKNOWN": 0,
"BUY": 1,
"SELL": 2,
}
)
var File_sdk_stream_trades_v1_request_proto FileDescriptor
var File_sdk_stream_trades_v1_response_proto FileDescriptor
StreamTradesRequestV1
type StreamTradesRequestV1 struct {
// InstrumentCriteria is instrument exchange, class and code, wildcard (*) can be used.
InstrumentCriteria *core.InstrumentCriteria `protobuf:"bytes,1,opt,name=instrument_criteria,json=instrumentCriteria,proto3" json:"instrument_criteria,omitempty"`
// contains filtered or unexported fields
}
func (*StreamTradesRequestV1) Descriptor() ([]int)
Deprecated: Use StreamTradesRequestV1.ProtoReflect.Descriptor instead.
func (x *StreamTradesRequestV1) GetInstrumentCriteria() *core.InstrumentCriteria
func (*StreamTradesRequestV1) ProtoMessage()
func (x *StreamTradesRequestV1) ProtoReflect() Message
func (x *StreamTradesRequestV1) Reset()
func (x *StreamTradesRequestV1) String() string
StreamTradesResponseV1
type StreamTradesResponseV1 struct {
// Additionnal properties, specific to the exchange.
AdditionalProperties map[string `protobuf:"bytes,1,rep,name=additional_properties,json=additionalProperties,proto3" json:"additional_properties,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"`
// Amount / quantity of asset bought or sold, displayed in base currency.
Amount float64 `protobuf:"fixed64,2,opt,name=amount,proto3" json:"amount,omitempty"`
// Instrument class, empty when instrument not mapped.
Class string `protobuf:"bytes,3,opt,name=class,proto3" json:"class,omitempty"`
// Instrument code, empty when instrument not mapped.
Code string `protobuf:"bytes,4,opt,name=code,proto3" json:"code,omitempty"`
// Instrument exchange code, for example "cbse" (Coinbase).
Exchange string `protobuf:"bytes,5,opt,name=exchange,proto3" json:"exchange,omitempty"`
// Sequence ID for event. Sortable in lexicographic order.
SequenceId string `protobuf:"bytes,6,opt,name=sequence_id,json=sequenceId,proto3" json:"sequence_id,omitempty"`
// Trade ID, empty string when not present.
Id string `protobuf:"bytes,7,opt,name=id,proto3" json:"id,omitempty"`
// Price for the trade.
Price float64 `protobuf:"fixed64,8,opt,name=price,proto3" json:"price,omitempty"`
// Trade side.
Side StreamTradesResponseV1_TradeSide `protobuf:"varint,9,opt,name=side,proto3,enum=kaikosdk.StreamTradesResponseV1_TradeSide" json:"side,omitempty"`
// Timestamp of trade, when provided by the exchange.
TsExchange *core.TimestampValue `protobuf:"bytes,10,opt,name=ts_exchange,json=tsExchange,proto3" json:"ts_exchange,omitempty"`
// Timestamp of collection (event entered Kaiko's infrastructure), before nomalization.
TsCollection *core.TimestampValue `protobuf:"bytes,11,opt,name=ts_collection,json=tsCollection,proto3" json:"ts_collection,omitempty"`
// Event generation timestamp (event created by Kaiko), after normalization.
TsEvent *Timestamp `protobuf:"bytes,12,opt,name=ts_event,json=tsEvent,proto3" json:"ts_event,omitempty"`
// contains filtered or unexported fields
}
func (*StreamTradesResponseV1) Descriptor() ([]int)
Deprecated: Use StreamTradesResponseV1.ProtoReflect.Descriptor instead.
func (x *StreamTradesResponseV1) GetAdditionalProperties() map[string
func (x *StreamTradesResponseV1) GetAmount() float64
func (x *StreamTradesResponseV1) GetClass() string
func (x *StreamTradesResponseV1) GetCode() string
func (x *StreamTradesResponseV1) GetExchange() string
func (x *StreamTradesResponseV1) GetId() string
func (x *StreamTradesResponseV1) GetPrice() float64
func (x *StreamTradesResponseV1) GetSequenceId() string
func (x *StreamTradesResponseV1) GetSide() StreamTradesResponseV1_TradeSide
func (x *StreamTradesResponseV1) GetTsCollection() *core.TimestampValue
func (x *StreamTradesResponseV1) GetTsEvent() *Timestamp
func (x *StreamTradesResponseV1) GetTsExchange() *core.TimestampValue
func (*StreamTradesResponseV1) ProtoMessage()
func (x *StreamTradesResponseV1) ProtoReflect() Message
func (x *StreamTradesResponseV1) Reset()
func (x *StreamTradesResponseV1) String() string
Side
type StreamTradesResponseV1_TradeSide int32
const (
// Unknown side (not specified).
StreamTradesResponseV1_UNKNOWN StreamTradesResponseV1_TradeSide = 0
// Buy side.
StreamTradesResponseV1_BUY StreamTradesResponseV1_TradeSide = 1
// Sell side.
StreamTradesResponseV1_SELL StreamTradesResponseV1_TradeSide = 2
)
func (StreamTradesResponseV1_TradeSide) Descriptor() EnumDescriptor
func (x StreamTradesResponseV1_TradeSide) Enum() *StreamTradesResponseV1_TradeSide
func (StreamTradesResponseV1_TradeSide) EnumDescriptor() ([]int)
Deprecated: Use StreamTradesResponseV1_TradeSide.Descriptor instead.
func (x StreamTradesResponseV1_TradeSide) Number() EnumNumber
func (x StreamTradesResponseV1_TradeSide) String() string
func (StreamTradesResponseV1_TradeSide) Type() EnumType