dcrrates

package module
v8.0.17 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jun 23, 2022 License: ISC Imports: 6 Imported by: 1

Documentation

Index

Constants

View Source
const (
	DefaultKeyName  = "rpc.key"
	DefaultCertName = "rpc.cert"
)

Default TLS configuration.

Variables

View Source
var (
	// DefaultAppDirectory is the default location of the dcrrates application
	// data folder.
	DefaultAppDirectory = dcrutil.AppDataDir("dcrrates", false)
)

Functions

func RegisterDCRRatesServer

func RegisterDCRRatesServer(s *grpc.Server, srv DCRRatesServer)

Types

type DCRRatesClient

type DCRRatesClient interface {
	SubscribeExchanges(ctx context.Context, in *ExchangeSubscription, opts ...grpc.CallOption) (DCRRates_SubscribeExchangesClient, error)
}

DCRRatesClient is the client API for DCRRates service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewDCRRatesClient

func NewDCRRatesClient(cc *grpc.ClientConn) DCRRatesClient

type DCRRatesServer

type DCRRatesServer interface {
	SubscribeExchanges(*ExchangeSubscription, DCRRates_SubscribeExchangesServer) error
}

DCRRatesServer is the server API for DCRRates service.

type DCRRates_SubscribeExchangesClient

type DCRRates_SubscribeExchangesClient interface {
	Recv() (*ExchangeRateUpdate, error)
	grpc.ClientStream
}

type DCRRates_SubscribeExchangesServer

type DCRRates_SubscribeExchangesServer interface {
	Send(*ExchangeRateUpdate) error
	grpc.ServerStream
}

type ExchangeRateUpdate

type ExchangeRateUpdate struct {
	Token                string                             `protobuf:"bytes,1,opt,name=token,proto3" json:"token,omitempty"`
	Price                float64                            `protobuf:"fixed64,2,opt,name=price,proto3" json:"price,omitempty"`
	BaseVolume           float64                            `protobuf:"fixed64,3,opt,name=baseVolume,proto3" json:"baseVolume,omitempty"`
	Volume               float64                            `protobuf:"fixed64,4,opt,name=volume,proto3" json:"volume,omitempty"`
	Change               float64                            `protobuf:"fixed64,5,opt,name=change,proto3" json:"change,omitempty"`
	Stamp                int64                              `protobuf:"varint,6,opt,name=stamp,proto3" json:"stamp,omitempty"`
	Indices              map[string]float64                 `` /* 157-byte string literal not displayed */
	Depth                *ExchangeRateUpdate_DepthData      `protobuf:"bytes,8,opt,name=depth,proto3" json:"depth,omitempty"`
	Candlesticks         []*ExchangeRateUpdate_Candlesticks `protobuf:"bytes,9,rep,name=candlesticks,proto3" json:"candlesticks,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                           `json:"-"`
	XXX_unrecognized     []byte                             `json:"-"`
	XXX_sizecache        int32                              `json:"-"`
}

func (*ExchangeRateUpdate) Descriptor

func (*ExchangeRateUpdate) Descriptor() ([]byte, []int)

func (*ExchangeRateUpdate) GetBaseVolume

func (m *ExchangeRateUpdate) GetBaseVolume() float64

func (*ExchangeRateUpdate) GetCandlesticks

func (m *ExchangeRateUpdate) GetCandlesticks() []*ExchangeRateUpdate_Candlesticks

func (*ExchangeRateUpdate) GetChange

func (m *ExchangeRateUpdate) GetChange() float64

func (*ExchangeRateUpdate) GetDepth

func (*ExchangeRateUpdate) GetIndices

func (m *ExchangeRateUpdate) GetIndices() map[string]float64

func (*ExchangeRateUpdate) GetPrice

func (m *ExchangeRateUpdate) GetPrice() float64

func (*ExchangeRateUpdate) GetStamp

func (m *ExchangeRateUpdate) GetStamp() int64

func (*ExchangeRateUpdate) GetToken

func (m *ExchangeRateUpdate) GetToken() string

func (*ExchangeRateUpdate) GetVolume

func (m *ExchangeRateUpdate) GetVolume() float64

func (*ExchangeRateUpdate) ProtoMessage

func (*ExchangeRateUpdate) ProtoMessage()

func (*ExchangeRateUpdate) Reset

func (m *ExchangeRateUpdate) Reset()

func (*ExchangeRateUpdate) String

func (m *ExchangeRateUpdate) String() string

func (*ExchangeRateUpdate) XXX_DiscardUnknown

func (m *ExchangeRateUpdate) XXX_DiscardUnknown()

func (*ExchangeRateUpdate) XXX_Marshal

func (m *ExchangeRateUpdate) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ExchangeRateUpdate) XXX_Merge

func (dst *ExchangeRateUpdate) XXX_Merge(src proto.Message)

func (*ExchangeRateUpdate) XXX_Size

func (m *ExchangeRateUpdate) XXX_Size() int

func (*ExchangeRateUpdate) XXX_Unmarshal

func (m *ExchangeRateUpdate) XXX_Unmarshal(b []byte) error

type ExchangeRateUpdate_Candlestick

type ExchangeRateUpdate_Candlestick struct {
	High                 float64  `protobuf:"fixed64,1,opt,name=high,proto3" json:"high,omitempty"`
	Low                  float64  `protobuf:"fixed64,2,opt,name=low,proto3" json:"low,omitempty"`
	Open                 float64  `protobuf:"fixed64,3,opt,name=open,proto3" json:"open,omitempty"`
	Close                float64  `protobuf:"fixed64,4,opt,name=close,proto3" json:"close,omitempty"`
	Volume               float64  `protobuf:"fixed64,5,opt,name=volume,proto3" json:"volume,omitempty"`
	Start                int64    `protobuf:"varint,6,opt,name=start,proto3" json:"start,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ExchangeRateUpdate_Candlestick) Descriptor

func (*ExchangeRateUpdate_Candlestick) Descriptor() ([]byte, []int)

func (*ExchangeRateUpdate_Candlestick) GetClose

func (*ExchangeRateUpdate_Candlestick) GetHigh

func (*ExchangeRateUpdate_Candlestick) GetLow

func (*ExchangeRateUpdate_Candlestick) GetOpen

func (*ExchangeRateUpdate_Candlestick) GetStart

func (m *ExchangeRateUpdate_Candlestick) GetStart() int64

func (*ExchangeRateUpdate_Candlestick) GetVolume

func (m *ExchangeRateUpdate_Candlestick) GetVolume() float64

func (*ExchangeRateUpdate_Candlestick) ProtoMessage

func (*ExchangeRateUpdate_Candlestick) ProtoMessage()

func (*ExchangeRateUpdate_Candlestick) Reset

func (m *ExchangeRateUpdate_Candlestick) Reset()

func (*ExchangeRateUpdate_Candlestick) String

func (*ExchangeRateUpdate_Candlestick) XXX_DiscardUnknown

func (m *ExchangeRateUpdate_Candlestick) XXX_DiscardUnknown()

func (*ExchangeRateUpdate_Candlestick) XXX_Marshal

func (m *ExchangeRateUpdate_Candlestick) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ExchangeRateUpdate_Candlestick) XXX_Merge

func (dst *ExchangeRateUpdate_Candlestick) XXX_Merge(src proto.Message)

func (*ExchangeRateUpdate_Candlestick) XXX_Size

func (m *ExchangeRateUpdate_Candlestick) XXX_Size() int

func (*ExchangeRateUpdate_Candlestick) XXX_Unmarshal

func (m *ExchangeRateUpdate_Candlestick) XXX_Unmarshal(b []byte) error

type ExchangeRateUpdate_Candlesticks

type ExchangeRateUpdate_Candlesticks struct {
	Bin                  string                            `protobuf:"bytes,1,opt,name=bin,proto3" json:"bin,omitempty"`
	Sticks               []*ExchangeRateUpdate_Candlestick `protobuf:"bytes,2,rep,name=sticks,proto3" json:"sticks,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                          `json:"-"`
	XXX_unrecognized     []byte                            `json:"-"`
	XXX_sizecache        int32                             `json:"-"`
}

func (*ExchangeRateUpdate_Candlesticks) Descriptor

func (*ExchangeRateUpdate_Candlesticks) Descriptor() ([]byte, []int)

func (*ExchangeRateUpdate_Candlesticks) GetBin

func (*ExchangeRateUpdate_Candlesticks) GetSticks

func (*ExchangeRateUpdate_Candlesticks) ProtoMessage

func (*ExchangeRateUpdate_Candlesticks) ProtoMessage()

func (*ExchangeRateUpdate_Candlesticks) Reset

func (*ExchangeRateUpdate_Candlesticks) String

func (*ExchangeRateUpdate_Candlesticks) XXX_DiscardUnknown

func (m *ExchangeRateUpdate_Candlesticks) XXX_DiscardUnknown()

func (*ExchangeRateUpdate_Candlesticks) XXX_Marshal

func (m *ExchangeRateUpdate_Candlesticks) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ExchangeRateUpdate_Candlesticks) XXX_Merge

func (dst *ExchangeRateUpdate_Candlesticks) XXX_Merge(src proto.Message)

func (*ExchangeRateUpdate_Candlesticks) XXX_Size

func (m *ExchangeRateUpdate_Candlesticks) XXX_Size() int

func (*ExchangeRateUpdate_Candlesticks) XXX_Unmarshal

func (m *ExchangeRateUpdate_Candlesticks) XXX_Unmarshal(b []byte) error

type ExchangeRateUpdate_DepthData

type ExchangeRateUpdate_DepthData struct {
	Time                 int64                            `protobuf:"varint,1,opt,name=time,proto3" json:"time,omitempty"`
	Bids                 []*ExchangeRateUpdate_DepthPoint `protobuf:"bytes,2,rep,name=bids,proto3" json:"bids,omitempty"`
	Asks                 []*ExchangeRateUpdate_DepthPoint `protobuf:"bytes,3,rep,name=asks,proto3" json:"asks,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                         `json:"-"`
	XXX_unrecognized     []byte                           `json:"-"`
	XXX_sizecache        int32                            `json:"-"`
}

func (*ExchangeRateUpdate_DepthData) Descriptor

func (*ExchangeRateUpdate_DepthData) Descriptor() ([]byte, []int)

func (*ExchangeRateUpdate_DepthData) GetAsks

func (*ExchangeRateUpdate_DepthData) GetBids

func (*ExchangeRateUpdate_DepthData) GetTime

func (m *ExchangeRateUpdate_DepthData) GetTime() int64

func (*ExchangeRateUpdate_DepthData) ProtoMessage

func (*ExchangeRateUpdate_DepthData) ProtoMessage()

func (*ExchangeRateUpdate_DepthData) Reset

func (m *ExchangeRateUpdate_DepthData) Reset()

func (*ExchangeRateUpdate_DepthData) String

func (*ExchangeRateUpdate_DepthData) XXX_DiscardUnknown

func (m *ExchangeRateUpdate_DepthData) XXX_DiscardUnknown()

func (*ExchangeRateUpdate_DepthData) XXX_Marshal

func (m *ExchangeRateUpdate_DepthData) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ExchangeRateUpdate_DepthData) XXX_Merge

func (dst *ExchangeRateUpdate_DepthData) XXX_Merge(src proto.Message)

func (*ExchangeRateUpdate_DepthData) XXX_Size

func (m *ExchangeRateUpdate_DepthData) XXX_Size() int

func (*ExchangeRateUpdate_DepthData) XXX_Unmarshal

func (m *ExchangeRateUpdate_DepthData) XXX_Unmarshal(b []byte) error

type ExchangeRateUpdate_DepthPoint

type ExchangeRateUpdate_DepthPoint struct {
	Quantity             float64  `protobuf:"fixed64,1,opt,name=quantity,proto3" json:"quantity,omitempty"`
	Price                float64  `protobuf:"fixed64,2,opt,name=price,proto3" json:"price,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ExchangeRateUpdate_DepthPoint) Descriptor

func (*ExchangeRateUpdate_DepthPoint) Descriptor() ([]byte, []int)

func (*ExchangeRateUpdate_DepthPoint) GetPrice

func (m *ExchangeRateUpdate_DepthPoint) GetPrice() float64

func (*ExchangeRateUpdate_DepthPoint) GetQuantity

func (m *ExchangeRateUpdate_DepthPoint) GetQuantity() float64

func (*ExchangeRateUpdate_DepthPoint) ProtoMessage

func (*ExchangeRateUpdate_DepthPoint) ProtoMessage()

func (*ExchangeRateUpdate_DepthPoint) Reset

func (m *ExchangeRateUpdate_DepthPoint) Reset()

func (*ExchangeRateUpdate_DepthPoint) String

func (*ExchangeRateUpdate_DepthPoint) XXX_DiscardUnknown

func (m *ExchangeRateUpdate_DepthPoint) XXX_DiscardUnknown()

func (*ExchangeRateUpdate_DepthPoint) XXX_Marshal

func (m *ExchangeRateUpdate_DepthPoint) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ExchangeRateUpdate_DepthPoint) XXX_Merge

func (dst *ExchangeRateUpdate_DepthPoint) XXX_Merge(src proto.Message)

func (*ExchangeRateUpdate_DepthPoint) XXX_Size

func (m *ExchangeRateUpdate_DepthPoint) XXX_Size() int

func (*ExchangeRateUpdate_DepthPoint) XXX_Unmarshal

func (m *ExchangeRateUpdate_DepthPoint) XXX_Unmarshal(b []byte) error

type ExchangeSubscription

type ExchangeSubscription struct {
	BtcIndex             string   `protobuf:"bytes,1,opt,name=btcIndex,proto3" json:"btcIndex,omitempty"`
	Exchanges            []string `protobuf:"bytes,2,rep,name=exchanges,proto3" json:"exchanges,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ExchangeSubscription) Descriptor

func (*ExchangeSubscription) Descriptor() ([]byte, []int)

func (*ExchangeSubscription) GetBtcIndex

func (m *ExchangeSubscription) GetBtcIndex() string

func (*ExchangeSubscription) GetExchanges

func (m *ExchangeSubscription) GetExchanges() []string

func (*ExchangeSubscription) ProtoMessage

func (*ExchangeSubscription) ProtoMessage()

func (*ExchangeSubscription) Reset

func (m *ExchangeSubscription) Reset()

func (*ExchangeSubscription) String

func (m *ExchangeSubscription) String() string

func (*ExchangeSubscription) XXX_DiscardUnknown

func (m *ExchangeSubscription) XXX_DiscardUnknown()

func (*ExchangeSubscription) XXX_Marshal

func (m *ExchangeSubscription) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ExchangeSubscription) XXX_Merge

func (dst *ExchangeSubscription) XXX_Merge(src proto.Message)

func (*ExchangeSubscription) XXX_Size

func (m *ExchangeSubscription) XXX_Size() int

func (*ExchangeSubscription) XXX_Unmarshal

func (m *ExchangeSubscription) XXX_Unmarshal(b []byte) error

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL