Enum value maps for StreamAggregatedPriceResponseV1_EventType.
var (
StreamAggregatedPriceResponseV1_EventType_name = map[string{
0: "UNKNOWN",
1: "BEST_ASK",
2: "BEST_BID",
}
StreamAggregatedPriceResponseV1_EventType_value = map[int32{
"UNKNOWN": 0,
"BEST_ASK": 1,
"BEST_BID": 2,
}
)
var File_sdk_stream_aggregated_price_v1_request_proto FileDescriptor
var File_sdk_stream_aggregated_price_v1_response_proto FileDescriptor
StreamAggregatedPriceRequestV1
type StreamAggregatedPriceRequestV1 struct {
// Instrument class. See https://docs.kaiko.com/?python#instruments.
InstrumentClass string `protobuf:"bytes,1,opt,name=instrument_class,json=instrumentClass,proto3" json:"instrument_class,omitempty"`
// Instrument code. See https://docs.kaiko.com/?python#instruments.
Code string `protobuf:"bytes,2,opt,name=code,proto3" json:"code,omitempty"`
// Data interval. For historical data only.
Interval *core.DataInterval `protobuf:"bytes,3,opt,name=interval,proto3" json:"interval,omitempty"`
// contains filtered or unexported fields
}
func (*StreamAggregatedPriceRequestV1) Descriptor() ([]int)
Deprecated: Use StreamAggregatedPriceRequestV1.ProtoReflect.Descriptor instead.
func (x *StreamAggregatedPriceRequestV1) GetCode() string
func (x *StreamAggregatedPriceRequestV1) GetInstrumentClass() string
func (x *StreamAggregatedPriceRequestV1) GetInterval() *core.DataInterval
func (*StreamAggregatedPriceRequestV1) ProtoMessage()
func (x *StreamAggregatedPriceRequestV1) ProtoReflect() Message
func (x *StreamAggregatedPriceRequestV1) Reset()
func (x *StreamAggregatedPriceRequestV1) String() string
StreamAggregatedPriceResponseV1
type StreamAggregatedPriceResponseV1 struct {
// Aggregate (interval).
Aggregate string `protobuf:"bytes,1,opt,name=aggregate,proto3" json:"aggregate,omitempty"`
// Instrument class. See https://docs.kaiko.com/?python#instruments.
InstrumentClass string `protobuf:"bytes,2,opt,name=instrument_class,json=instrumentClass,proto3" json:"instrument_class,omitempty"`
// Instrument code. See https://docs.kaiko.com/?python#instruments.
Code string `protobuf:"bytes,3,opt,name=code,proto3" json:"code,omitempty"`
// Value is update value (price and volume). Field is absent if the ticker has no update during the aggregate inerval.
Value *StreamAggregatedPriceValue `protobuf:"bytes,4,opt,name=value,proto3" json:"value,omitempty"`
// Event type is ASK or BID.
EventType StreamAggregatedPriceResponseV1_EventType `protobuf:"varint,5,opt,name=event_type,json=eventType,proto3,enum=kaikosdk.StreamAggregatedPriceResponseV1_EventType" json:"event_type,omitempty"`
// Timestamp of event.
TsEvent *Timestamp `protobuf:"bytes,6,opt,name=ts_event,json=tsEvent,proto3" json:"ts_event,omitempty"`
// contains filtered or unexported fields
}
func (*StreamAggregatedPriceResponseV1) Descriptor() ([]int)
Deprecated: Use StreamAggregatedPriceResponseV1.ProtoReflect.Descriptor instead.
func (x *StreamAggregatedPriceResponseV1) GetAggregate() string
func (x *StreamAggregatedPriceResponseV1) GetCode() string
func (x *StreamAggregatedPriceResponseV1) GetEventType() StreamAggregatedPriceResponseV1_EventType
func (x *StreamAggregatedPriceResponseV1) GetInstrumentClass() string
func (x *StreamAggregatedPriceResponseV1) GetTsEvent() *Timestamp
func (x *StreamAggregatedPriceResponseV1) GetValue() *StreamAggregatedPriceValue
func (*StreamAggregatedPriceResponseV1) ProtoMessage()
func (x *StreamAggregatedPriceResponseV1) ProtoReflect() Message
func (x *StreamAggregatedPriceResponseV1) Reset()
func (x *StreamAggregatedPriceResponseV1) String() string
EventType is event category for a value.
type StreamAggregatedPriceResponseV1_EventType int32
const (
// Unknown type.
StreamAggregatedPriceResponseV1_UNKNOWN StreamAggregatedPriceResponseV1_EventType = 0
// BEST_ASK type.
StreamAggregatedPriceResponseV1_BEST_ASK StreamAggregatedPriceResponseV1_EventType = 1
// BEST_BID type.
StreamAggregatedPriceResponseV1_BEST_BID StreamAggregatedPriceResponseV1_EventType = 2
)
func (StreamAggregatedPriceResponseV1_EventType) Descriptor() EnumDescriptor
func (x StreamAggregatedPriceResponseV1_EventType) Enum() *StreamAggregatedPriceResponseV1_EventType
func (StreamAggregatedPriceResponseV1_EventType) EnumDescriptor() ([]int)
Deprecated: Use StreamAggregatedPriceResponseV1_EventType.Descriptor instead.
func (x StreamAggregatedPriceResponseV1_EventType) Number() EnumNumber
func (x StreamAggregatedPriceResponseV1_EventType) String() string
func (StreamAggregatedPriceResponseV1_EventType) Type() EnumType
StreamAggregatedPriceValue is wrapper for update values.
type StreamAggregatedPriceValue struct {
// Price of top of book entry.
Price string `protobuf:"bytes,1,opt,name=price,proto3" json:"price,omitempty"`
// Volume of top of book entry.
Volume string `protobuf:"bytes,2,opt,name=volume,proto3" json:"volume,omitempty"`
// contains filtered or unexported fields
}
func (*StreamAggregatedPriceValue) Descriptor() ([]int)
Deprecated: Use StreamAggregatedPriceValue.ProtoReflect.Descriptor instead.
func (x *StreamAggregatedPriceValue) GetPrice() string
func (x *StreamAggregatedPriceValue) GetVolume() string
func (*StreamAggregatedPriceValue) ProtoMessage()
func (x *StreamAggregatedPriceValue) ProtoReflect() Message
func (x *StreamAggregatedPriceValue) Reset()
func (x *StreamAggregatedPriceValue) String() string