...

Package aggregates_direct_exchange_rate_v2

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

Overview ▾

Index ▾

Variables
type StreamAggregatesDirectExchangeRateV2RequestV1
    func (*StreamAggregatesDirectExchangeRateV2RequestV1) Descriptor() ([]byte, []int)
    func (x *StreamAggregatesDirectExchangeRateV2RequestV1) GetAssets() *core.Assets
    func (x *StreamAggregatesDirectExchangeRateV2RequestV1) GetExcludeExchanges() []string
    func (x *StreamAggregatesDirectExchangeRateV2RequestV1) GetIncludeExchanges() []string
    func (x *StreamAggregatesDirectExchangeRateV2RequestV1) GetUpdateFrequency() *duration.Duration
    func (x *StreamAggregatesDirectExchangeRateV2RequestV1) GetWindow() *duration.Duration
    func (*StreamAggregatesDirectExchangeRateV2RequestV1) ProtoMessage()
    func (x *StreamAggregatesDirectExchangeRateV2RequestV1) ProtoReflect() protoreflect.Message
    func (x *StreamAggregatesDirectExchangeRateV2RequestV1) Reset()
    func (x *StreamAggregatesDirectExchangeRateV2RequestV1) String() string
type StreamAggregatesDirectExchangeRateV2ResponseV1
    func (*StreamAggregatesDirectExchangeRateV2ResponseV1) Descriptor() ([]byte, []int)
    func (x *StreamAggregatesDirectExchangeRateV2ResponseV1) GetAssets() *core.Assets
    func (x *StreamAggregatesDirectExchangeRateV2ResponseV1) GetNoTrade() bool
    func (x *StreamAggregatesDirectExchangeRateV2ResponseV1) GetPrice() float64
    func (x *StreamAggregatesDirectExchangeRateV2ResponseV1) GetTimestamp() *timestamp.Timestamp
    func (x *StreamAggregatesDirectExchangeRateV2ResponseV1) GetWindow() *core.Window
    func (*StreamAggregatesDirectExchangeRateV2ResponseV1) ProtoMessage()
    func (x *StreamAggregatesDirectExchangeRateV2ResponseV1) ProtoReflect() protoreflect.Message
    func (x *StreamAggregatesDirectExchangeRateV2ResponseV1) Reset()
    func (x *StreamAggregatesDirectExchangeRateV2ResponseV1) String() string

Package files

request.pb.go response.pb.go

Variables

var File_sdk_stream_aggregates_direct_exchange_rate_v2_request_proto FileDescriptor
var File_sdk_stream_aggregates_direct_exchange_rate_v2_response_proto FileDescriptor

type StreamAggregatesDirectExchangeRateV2RequestV1

StreamAggregatesDirectExchangeRateV1RequestV1

type StreamAggregatesDirectExchangeRateV2RequestV1 struct {

    // base/quote assets.
    Assets *core.Assets `protobuf:"bytes,1,opt,name=assets,proto3" json:"assets,omitempty"`
    // Sliding Window duration (duration string, ex: 1m).
    Window *Duration `protobuf:"bytes,2,opt,name=window,proto3" json:"window,omitempty"`
    // list of exchange code to include.
    IncludeExchanges []string `protobuf:"bytes,3,rep,name=include_exchanges,json=includeExchanges,proto3" json:"include_exchanges,omitempty"`
    // list of exchange code to exclude.
    ExcludeExchanges []string `protobuf:"bytes,4,rep,name=exclude_exchanges,json=excludeExchanges,proto3" json:"exclude_exchanges,omitempty"`
    // Update frequency (duration string, ex: 1m).
    UpdateFrequency *Duration `protobuf:"bytes,5,opt,name=update_frequency,json=updateFrequency,proto3" json:"update_frequency,omitempty"`
    // contains filtered or unexported fields
}

func (*StreamAggregatesDirectExchangeRateV2RequestV1) Descriptor

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

Deprecated: Use StreamAggregatesDirectExchangeRateV2RequestV1.ProtoReflect.Descriptor instead.

func (*StreamAggregatesDirectExchangeRateV2RequestV1) GetAssets

func (x *StreamAggregatesDirectExchangeRateV2RequestV1) GetAssets() *core.Assets

func (*StreamAggregatesDirectExchangeRateV2RequestV1) GetExcludeExchanges

func (x *StreamAggregatesDirectExchangeRateV2RequestV1) GetExcludeExchanges() []string

func (*StreamAggregatesDirectExchangeRateV2RequestV1) GetIncludeExchanges

func (x *StreamAggregatesDirectExchangeRateV2RequestV1) GetIncludeExchanges() []string

func (*StreamAggregatesDirectExchangeRateV2RequestV1) GetUpdateFrequency

func (x *StreamAggregatesDirectExchangeRateV2RequestV1) GetUpdateFrequency() *Duration

func (*StreamAggregatesDirectExchangeRateV2RequestV1) GetWindow

func (x *StreamAggregatesDirectExchangeRateV2RequestV1) GetWindow() *Duration

func (*StreamAggregatesDirectExchangeRateV2RequestV1) ProtoMessage

func (*StreamAggregatesDirectExchangeRateV2RequestV1) ProtoMessage()

func (*StreamAggregatesDirectExchangeRateV2RequestV1) ProtoReflect

func (x *StreamAggregatesDirectExchangeRateV2RequestV1) ProtoReflect() Message

func (*StreamAggregatesDirectExchangeRateV2RequestV1) Reset

func (x *StreamAggregatesDirectExchangeRateV2RequestV1) Reset()

func (*StreamAggregatesDirectExchangeRateV2RequestV1) String

func (x *StreamAggregatesDirectExchangeRateV2RequestV1) String() string

type StreamAggregatesDirectExchangeRateV2ResponseV1

StreamAggregatesDirectExchangeRateV2ResponseV1

type StreamAggregatesDirectExchangeRateV2ResponseV1 struct {

    // Sliding Window (duration string, ex: 1m).
    Assets *core.Assets `protobuf:"bytes,1,opt,name=assets,proto3" json:"assets,omitempty"`
    // Price for the trade.
    Price float64 `protobuf:"fixed64,2,opt,name=price,proto3" json:"price,omitempty"`
    // Timestamp of event.
    Timestamp *Timestamp `protobuf:"bytes,3,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
    // Window information.
    Window *core.Window `protobuf:"bytes,4,opt,name=window,proto3" json:"window,omitempty"`
    // NoTrade: no trade happened during the window.
    NoTrade bool `protobuf:"varint,5,opt,name=no_trade,json=noTrade,proto3" json:"no_trade,omitempty"`
    // contains filtered or unexported fields
}

func (*StreamAggregatesDirectExchangeRateV2ResponseV1) Descriptor

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

Deprecated: Use StreamAggregatesDirectExchangeRateV2ResponseV1.ProtoReflect.Descriptor instead.

func (*StreamAggregatesDirectExchangeRateV2ResponseV1) GetAssets

func (x *StreamAggregatesDirectExchangeRateV2ResponseV1) GetAssets() *core.Assets

func (*StreamAggregatesDirectExchangeRateV2ResponseV1) GetNoTrade

func (x *StreamAggregatesDirectExchangeRateV2ResponseV1) GetNoTrade() bool

func (*StreamAggregatesDirectExchangeRateV2ResponseV1) GetPrice

func (x *StreamAggregatesDirectExchangeRateV2ResponseV1) GetPrice() float64

func (*StreamAggregatesDirectExchangeRateV2ResponseV1) GetTimestamp

func (x *StreamAggregatesDirectExchangeRateV2ResponseV1) GetTimestamp() *Timestamp

func (*StreamAggregatesDirectExchangeRateV2ResponseV1) GetWindow

func (x *StreamAggregatesDirectExchangeRateV2ResponseV1) GetWindow() *core.Window

func (*StreamAggregatesDirectExchangeRateV2ResponseV1) ProtoMessage

func (*StreamAggregatesDirectExchangeRateV2ResponseV1) ProtoMessage()

func (*StreamAggregatesDirectExchangeRateV2ResponseV1) ProtoReflect

func (x *StreamAggregatesDirectExchangeRateV2ResponseV1) ProtoReflect() Message

func (*StreamAggregatesDirectExchangeRateV2ResponseV1) Reset

func (x *StreamAggregatesDirectExchangeRateV2ResponseV1) Reset()

func (*StreamAggregatesDirectExchangeRateV2ResponseV1) String

func (x *StreamAggregatesDirectExchangeRateV2ResponseV1) String() string