Enum value maps for StreamIndexCommodity.
var (
StreamIndexCommodity_name = map[string{
0: "SIC_UNKNOWN",
1: "SIC_REAL_TIME",
2: "SIC_DAILY_FIXING",
}
StreamIndexCommodity_value = map[int32{
"SIC_UNKNOWN": 0,
"SIC_REAL_TIME": 1,
"SIC_DAILY_FIXING": 2,
}
)
var File_sdk_stream_index_v1_commodity_proto FileDescriptor
var File_sdk_stream_index_v1_request_proto FileDescriptor
var File_sdk_stream_index_v1_response_proto FileDescriptor
StreamIndexCommodity allows selecting kind of index update wanted.
type StreamIndexCommodity int32
const (
// Unknown commodity.
StreamIndexCommodity_SIC_UNKNOWN StreamIndexCommodity = 0
// REAL_TIME commodity.
StreamIndexCommodity_SIC_REAL_TIME StreamIndexCommodity = 1
// DAILY_FIXING commodity.
StreamIndexCommodity_SIC_DAILY_FIXING StreamIndexCommodity = 2
)
func (StreamIndexCommodity) Descriptor() EnumDescriptor
func (x StreamIndexCommodity) Enum() *StreamIndexCommodity
func (StreamIndexCommodity) EnumDescriptor() ([]int)
Deprecated: Use StreamIndexCommodity.Descriptor instead.
func (x StreamIndexCommodity) Number() EnumNumber
func (x StreamIndexCommodity) String() string
func (StreamIndexCommodity) Type() EnumType
StreamIndexServiceRequestV1
type StreamIndexServiceRequestV1 struct {
// Index code.
IndexCode string `protobuf:"bytes,1,opt,name=index_code,json=indexCode,proto3" json:"index_code,omitempty"`
// Enum indicating type of feed.
Commodities []StreamIndexCommodity `protobuf:"varint,2,rep,packed,name=commodities,proto3,enum=kaikosdk.StreamIndexCommodity" json:"commodities,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 (*StreamIndexServiceRequestV1) Descriptor() ([]int)
Deprecated: Use StreamIndexServiceRequestV1.ProtoReflect.Descriptor instead.
func (x *StreamIndexServiceRequestV1) GetCommodities() []StreamIndexCommodity
func (x *StreamIndexServiceRequestV1) GetIndexCode() string
func (x *StreamIndexServiceRequestV1) GetInterval() *core.DataInterval
func (*StreamIndexServiceRequestV1) ProtoMessage()
func (x *StreamIndexServiceRequestV1) ProtoReflect() Message
func (x *StreamIndexServiceRequestV1) Reset()
func (x *StreamIndexServiceRequestV1) String() string
StreamIndexServiceResponseBaseAsset is base asset involved in computation.
type StreamIndexServiceResponseBaseAsset struct {
// Asset.
Asset string `protobuf:"bytes,1,opt,name=asset,proto3" json:"asset,omitempty"`
// Weight.
Weight float64 `protobuf:"fixed64,2,opt,name=weight,proto3" json:"weight,omitempty"`
// contains filtered or unexported fields
}
func (*StreamIndexServiceResponseBaseAsset) Descriptor() ([]int)
Deprecated: Use StreamIndexServiceResponseBaseAsset.ProtoReflect.Descriptor instead.
func (x *StreamIndexServiceResponseBaseAsset) GetAsset() string
func (x *StreamIndexServiceResponseBaseAsset) GetWeight() float64
func (*StreamIndexServiceResponseBaseAsset) ProtoMessage()
func (x *StreamIndexServiceResponseBaseAsset) ProtoReflect() Message
func (x *StreamIndexServiceResponseBaseAsset) Reset()
func (x *StreamIndexServiceResponseBaseAsset) String() string
StreamIndexServiceResponseInstruments is computation result by instruments.
type StreamIndexServiceResponseInstruments struct {
// Partition.
Partition string `protobuf:"bytes,1,opt,name=partition,proto3" json:"partition,omitempty"`
// Price.
Price float64 `protobuf:"fixed64,2,opt,name=price,proto3" json:"price,omitempty"`
// Volume.
Volume float64 `protobuf:"fixed64,3,opt,name=volume,proto3" json:"volume,omitempty"`
// Count.
Count uint64 `protobuf:"varint,4,opt,name=count,proto3" json:"count,omitempty"`
// Underlying trade for the partition.
UnderlyingTrade *StreamIndexServiceUnderlyingTrade `protobuf:"bytes,5,opt,name=underlying_trade,json=underlyingTrade,proto3" json:"underlying_trade,omitempty"`
// contains filtered or unexported fields
}
func (*StreamIndexServiceResponseInstruments) Descriptor() ([]int)
Deprecated: Use StreamIndexServiceResponseInstruments.ProtoReflect.Descriptor instead.
func (x *StreamIndexServiceResponseInstruments) GetCount() uint64
func (x *StreamIndexServiceResponseInstruments) GetPartition() string
func (x *StreamIndexServiceResponseInstruments) GetPrice() float64
func (x *StreamIndexServiceResponseInstruments) GetUnderlyingTrade() *StreamIndexServiceUnderlyingTrade
func (x *StreamIndexServiceResponseInstruments) GetVolume() float64
func (*StreamIndexServiceResponseInstruments) ProtoMessage()
func (x *StreamIndexServiceResponseInstruments) ProtoReflect() Message
func (x *StreamIndexServiceResponseInstruments) Reset()
func (x *StreamIndexServiceResponseInstruments) String() string
StreamIndexServiceResponsePairs is computation result by pairs.
type StreamIndexServiceResponsePairs struct {
// Pair.
Pair string `protobuf:"bytes,1,opt,name=pair,proto3" json:"pair,omitempty"`
// Weight (for multiple assets indices).
Weight float64 `protobuf:"fixed64,2,opt,name=weight,proto3" json:"weight,omitempty"`
// Detailed computation by instruments.
Instruments []*StreamIndexServiceResponseInstruments `protobuf:"bytes,3,rep,name=instruments,proto3" json:"instruments,omitempty"`
// contains filtered or unexported fields
}
func (*StreamIndexServiceResponsePairs) Descriptor() ([]int)
Deprecated: Use StreamIndexServiceResponsePairs.ProtoReflect.Descriptor instead.
func (x *StreamIndexServiceResponsePairs) GetInstruments() []*StreamIndexServiceResponseInstruments
func (x *StreamIndexServiceResponsePairs) GetPair() string
func (x *StreamIndexServiceResponsePairs) GetWeight() float64
func (*StreamIndexServiceResponsePairs) ProtoMessage()
func (x *StreamIndexServiceResponsePairs) ProtoReflect() Message
func (x *StreamIndexServiceResponsePairs) Reset()
func (x *StreamIndexServiceResponsePairs) String() string
StreamIndexServiceResponsePercentage is computation result by percentage.
type StreamIndexServiceResponsePercentage struct {
// Percentage.
Percentage float64 `protobuf:"fixed64,1,opt,name=percentage,proto3" json:"percentage,omitempty"`
// Price computed for the whole percentage.
Price float64 `protobuf:"fixed64,2,opt,name=price,proto3" json:"price,omitempty"`
// Detailed computation by pairs.
Pairs []*StreamIndexServiceResponsePairs `protobuf:"bytes,3,rep,name=pairs,proto3" json:"pairs,omitempty"`
// contains filtered or unexported fields
}
func (*StreamIndexServiceResponsePercentage) Descriptor() ([]int)
Deprecated: Use StreamIndexServiceResponsePercentage.ProtoReflect.Descriptor instead.
func (x *StreamIndexServiceResponsePercentage) GetPairs() []*StreamIndexServiceResponsePairs
func (x *StreamIndexServiceResponsePercentage) GetPercentage() float64
func (x *StreamIndexServiceResponsePercentage) GetPrice() float64
func (*StreamIndexServiceResponsePercentage) ProtoMessage()
func (x *StreamIndexServiceResponsePercentage) ProtoReflect() Message
func (x *StreamIndexServiceResponsePercentage) Reset()
func (x *StreamIndexServiceResponsePercentage) String() string
StreamIndexServiceResponseV1
type StreamIndexServiceResponseV1 struct {
// Index code.
IndexCode string `protobuf:"bytes,1,opt,name=index_code,json=indexCode,proto3" json:"index_code,omitempty"`
// Event type.
Commodity StreamIndexCommodity `protobuf:"varint,2,opt,name=commodity,proto3,enum=kaikosdk.StreamIndexCommodity" json:"commodity,omitempty"`
// Data interval.
Interval *core.DataInterval `protobuf:"bytes,3,opt,name=interval,proto3" json:"interval,omitempty"`
// Quote.
Quote string `protobuf:"bytes,4,opt,name=quote,proto3" json:"quote,omitempty"`
// Bases.
Bases []*StreamIndexServiceResponseBaseAsset `protobuf:"bytes,5,rep,name=bases,proto3" json:"bases,omitempty"`
// Exchanges.
Exchanges []string `protobuf:"bytes,6,rep,name=exchanges,proto3" json:"exchanges,omitempty"`
// Detailed computation by percentage.
Percentages []*StreamIndexServiceResponsePercentage `protobuf:"bytes,7,rep,name=percentages,proto3" json:"percentages,omitempty"`
// Event generation timestamp (event created by Kaiko), after normalization.
TsEvent *Timestamp `protobuf:"bytes,8,opt,name=ts_event,json=tsEvent,proto3" json:"ts_event,omitempty"`
// Sequence ID for event. Sortable in lexicographic order.
SequenceId string `protobuf:"bytes,9,opt,name=sequence_id,json=sequenceId,proto3" json:"sequence_id,omitempty"`
// Last internal ingest date used for computation. Useful for replication purposes.
LastIngestTime *Timestamp `protobuf:"bytes,10,opt,name=last_ingest_time,json=lastIngestTime,proto3" json:"last_ingest_time,omitempty"`
// contains filtered or unexported fields
}
func (*StreamIndexServiceResponseV1) Descriptor() ([]int)
Deprecated: Use StreamIndexServiceResponseV1.ProtoReflect.Descriptor instead.
func (x *StreamIndexServiceResponseV1) GetBases() []*StreamIndexServiceResponseBaseAsset
func (x *StreamIndexServiceResponseV1) GetCommodity() StreamIndexCommodity
func (x *StreamIndexServiceResponseV1) GetExchanges() []string
func (x *StreamIndexServiceResponseV1) GetIndexCode() string
func (x *StreamIndexServiceResponseV1) GetInterval() *core.DataInterval
func (x *StreamIndexServiceResponseV1) GetLastIngestTime() *Timestamp
func (x *StreamIndexServiceResponseV1) GetPercentages() []*StreamIndexServiceResponsePercentage
func (x *StreamIndexServiceResponseV1) GetQuote() string
func (x *StreamIndexServiceResponseV1) GetSequenceId() string
func (x *StreamIndexServiceResponseV1) GetTsEvent() *Timestamp
func (*StreamIndexServiceResponseV1) ProtoMessage()
func (x *StreamIndexServiceResponseV1) ProtoReflect() Message
func (x *StreamIndexServiceResponseV1) Reset()
func (x *StreamIndexServiceResponseV1) String() string
StreamIndexServiceUnderlyingTrade is underlying trade information for a partition.
type StreamIndexServiceUnderlyingTrade struct {
// Amount / quantity of asset bought or sold, displayed in base currency.
Volume float64 `protobuf:"fixed64,1,opt,name=volume,proto3" json:"volume,omitempty"`
// Instrument exchange code, for example "cbse" (Coinbase).
Exchange string `protobuf:"bytes,2,opt,name=exchange,proto3" json:"exchange,omitempty"`
// Trade ID, empty string when not present.
Id string `protobuf:"bytes,3,opt,name=id,proto3" json:"id,omitempty"`
// Date of trade.
Datetime *Timestamp `protobuf:"bytes,4,opt,name=datetime,proto3" json:"datetime,omitempty"`
// contains filtered or unexported fields
}
func (*StreamIndexServiceUnderlyingTrade) Descriptor() ([]int)
Deprecated: Use StreamIndexServiceUnderlyingTrade.ProtoReflect.Descriptor instead.
func (x *StreamIndexServiceUnderlyingTrade) GetDatetime() *Timestamp
func (x *StreamIndexServiceUnderlyingTrade) GetExchange() string
func (x *StreamIndexServiceUnderlyingTrade) GetId() string
func (x *StreamIndexServiceUnderlyingTrade) GetVolume() float64
func (*StreamIndexServiceUnderlyingTrade) ProtoMessage()
func (x *StreamIndexServiceUnderlyingTrade) ProtoReflect() Message
func (x *StreamIndexServiceUnderlyingTrade) Reset()
func (x *StreamIndexServiceUnderlyingTrade) String() string