...

Package aggregates_ohlcv_v1

import "github.com/kaikodata/kaiko-go-sdk/stream/aggregates_ohlcv_v1"
Overview
Index

Overview ▾

Index ▾

Variables
type StreamAggregatesOHLCVRequestV1
    func (*StreamAggregatesOHLCVRequestV1) Descriptor() ([]byte, []int)
    func (x *StreamAggregatesOHLCVRequestV1) GetAggregate() string
    func (x *StreamAggregatesOHLCVRequestV1) GetInstrumentCriteria() *core.InstrumentCriteria
    func (*StreamAggregatesOHLCVRequestV1) ProtoMessage()
    func (x *StreamAggregatesOHLCVRequestV1) ProtoReflect() protoreflect.Message
    func (x *StreamAggregatesOHLCVRequestV1) Reset()
    func (x *StreamAggregatesOHLCVRequestV1) String() string
type StreamAggregatesOHLCVResponseV1
    func (*StreamAggregatesOHLCVResponseV1) Descriptor() ([]byte, []int)
    func (x *StreamAggregatesOHLCVResponseV1) GetAggregate() string
    func (x *StreamAggregatesOHLCVResponseV1) GetClass() string
    func (x *StreamAggregatesOHLCVResponseV1) GetClose() string
    func (x *StreamAggregatesOHLCVResponseV1) GetCode() string
    func (x *StreamAggregatesOHLCVResponseV1) GetExchange() string
    func (x *StreamAggregatesOHLCVResponseV1) GetHigh() string
    func (x *StreamAggregatesOHLCVResponseV1) GetLow() string
    func (x *StreamAggregatesOHLCVResponseV1) GetOpen() string
    func (x *StreamAggregatesOHLCVResponseV1) GetSequenceId() string
    func (x *StreamAggregatesOHLCVResponseV1) GetTimestamp() *timestamp.Timestamp
    func (x *StreamAggregatesOHLCVResponseV1) GetUid() string
    func (x *StreamAggregatesOHLCVResponseV1) GetVolume() string
    func (*StreamAggregatesOHLCVResponseV1) ProtoMessage()
    func (x *StreamAggregatesOHLCVResponseV1) ProtoReflect() protoreflect.Message
    func (x *StreamAggregatesOHLCVResponseV1) Reset()
    func (x *StreamAggregatesOHLCVResponseV1) String() string

Package files

request.pb.go response.pb.go

Variables

var File_sdk_stream_aggregates_ohlcv_v1_request_proto FileDescriptor
var File_sdk_stream_aggregates_ohlcv_v1_response_proto FileDescriptor

type StreamAggregatesOHLCVRequestV1

StreamAggregatesOHLCVRequestV1

type StreamAggregatesOHLCVRequestV1 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"`
    // Aggregate value (1s, 1m, 1h).
    Aggregate string `protobuf:"bytes,2,opt,name=aggregate,proto3" json:"aggregate,omitempty"`
    // contains filtered or unexported fields
}

func (*StreamAggregatesOHLCVRequestV1) Descriptor

func (*StreamAggregatesOHLCVRequestV1) Descriptor() ([]int)

Deprecated: Use StreamAggregatesOHLCVRequestV1.ProtoReflect.Descriptor instead.

func (*StreamAggregatesOHLCVRequestV1) GetAggregate

func (x *StreamAggregatesOHLCVRequestV1) GetAggregate() string

func (*StreamAggregatesOHLCVRequestV1) GetInstrumentCriteria

func (x *StreamAggregatesOHLCVRequestV1) GetInstrumentCriteria() *core.InstrumentCriteria

func (*StreamAggregatesOHLCVRequestV1) ProtoMessage

func (*StreamAggregatesOHLCVRequestV1) ProtoMessage()

func (*StreamAggregatesOHLCVRequestV1) ProtoReflect

func (x *StreamAggregatesOHLCVRequestV1) ProtoReflect() Message

func (*StreamAggregatesOHLCVRequestV1) Reset

func (x *StreamAggregatesOHLCVRequestV1) Reset()

func (*StreamAggregatesOHLCVRequestV1) String

func (x *StreamAggregatesOHLCVRequestV1) String() string

type StreamAggregatesOHLCVResponseV1

StreamAggregatesOHLCVResponseV1

type StreamAggregatesOHLCVResponseV1 struct {

    // Aggregate (interval).
    Aggregate string `protobuf:"bytes,1,opt,name=aggregate,proto3" json:"aggregate,omitempty"`
    // Instrument class.
    Class string `protobuf:"bytes,2,opt,name=class,proto3" json:"class,omitempty"`
    // Close value of OHLCV.
    Close string `protobuf:"bytes,3,opt,name=close,proto3" json:"close,omitempty"`
    // Instrument exchange.
    Exchange string `protobuf:"bytes,4,opt,name=exchange,proto3" json:"exchange,omitempty"`
    // High value of OHLCV.
    High string `protobuf:"bytes,5,opt,name=high,proto3" json:"high,omitempty"`
    // Low value of OHLCV.
    Low string `protobuf:"bytes,6,opt,name=low,proto3" json:"low,omitempty"`
    // Open value of OHLCV.
    Open string `protobuf:"bytes,7,opt,name=open,proto3" json:"open,omitempty"`
    // Sequence ID for event. Sortable in lexicographic order.
    SequenceId string `protobuf:"bytes,8,opt,name=sequence_id,json=sequenceId,proto3" json:"sequence_id,omitempty"`
    // Instrument code.
    Code string `protobuf:"bytes,9,opt,name=code,proto3" json:"code,omitempty"`
    // Timestamp of event.
    Timestamp *Timestamp `protobuf:"bytes,10,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
    // UID is timestamp truncated to interval of OHLCV.
    Uid string `protobuf:"bytes,11,opt,name=uid,proto3" json:"uid,omitempty"`
    // Volume of OHLCV.
    Volume string `protobuf:"bytes,12,opt,name=volume,proto3" json:"volume,omitempty"`
    // contains filtered or unexported fields
}

func (*StreamAggregatesOHLCVResponseV1) Descriptor

func (*StreamAggregatesOHLCVResponseV1) Descriptor() ([]int)

Deprecated: Use StreamAggregatesOHLCVResponseV1.ProtoReflect.Descriptor instead.

func (*StreamAggregatesOHLCVResponseV1) GetAggregate

func (x *StreamAggregatesOHLCVResponseV1) GetAggregate() string

func (*StreamAggregatesOHLCVResponseV1) GetClass

func (x *StreamAggregatesOHLCVResponseV1) GetClass() string

func (*StreamAggregatesOHLCVResponseV1) GetClose

func (x *StreamAggregatesOHLCVResponseV1) GetClose() string

func (*StreamAggregatesOHLCVResponseV1) GetCode

func (x *StreamAggregatesOHLCVResponseV1) GetCode() string

func (*StreamAggregatesOHLCVResponseV1) GetExchange

func (x *StreamAggregatesOHLCVResponseV1) GetExchange() string

func (*StreamAggregatesOHLCVResponseV1) GetHigh

func (x *StreamAggregatesOHLCVResponseV1) GetHigh() string

func (*StreamAggregatesOHLCVResponseV1) GetLow

func (x *StreamAggregatesOHLCVResponseV1) GetLow() string

func (*StreamAggregatesOHLCVResponseV1) GetOpen

func (x *StreamAggregatesOHLCVResponseV1) GetOpen() string

func (*StreamAggregatesOHLCVResponseV1) GetSequenceId

func (x *StreamAggregatesOHLCVResponseV1) GetSequenceId() string

func (*StreamAggregatesOHLCVResponseV1) GetTimestamp

func (x *StreamAggregatesOHLCVResponseV1) GetTimestamp() *Timestamp

func (*StreamAggregatesOHLCVResponseV1) GetUid

func (x *StreamAggregatesOHLCVResponseV1) GetUid() string

func (*StreamAggregatesOHLCVResponseV1) GetVolume

func (x *StreamAggregatesOHLCVResponseV1) GetVolume() string

func (*StreamAggregatesOHLCVResponseV1) ProtoMessage

func (*StreamAggregatesOHLCVResponseV1) ProtoMessage()

func (*StreamAggregatesOHLCVResponseV1) ProtoReflect

func (x *StreamAggregatesOHLCVResponseV1) ProtoReflect() Message

func (*StreamAggregatesOHLCVResponseV1) Reset

func (x *StreamAggregatesOHLCVResponseV1) Reset()

func (*StreamAggregatesOHLCVResponseV1) String

func (x *StreamAggregatesOHLCVResponseV1) String() string