Documentation ¶
Index ¶
- Constants
- Variables
- func RegisterDCRRatesServer(s *grpc.Server, srv DCRRatesServer)
- type DCRRatesClient
- type DCRRatesServer
- type DCRRates_SubscribeExchangesClient
- type DCRRates_SubscribeExchangesServer
- type ExchangeRateUpdate
- func (*ExchangeRateUpdate) Descriptor() ([]byte, []int)
- func (m *ExchangeRateUpdate) GetBaseVolume() float64
- func (m *ExchangeRateUpdate) GetCandlesticks() []*ExchangeRateUpdate_Candlesticks
- func (m *ExchangeRateUpdate) GetChange() float64
- func (m *ExchangeRateUpdate) GetDepth() *ExchangeRateUpdate_DepthData
- func (m *ExchangeRateUpdate) GetIndices() map[string]float64
- func (m *ExchangeRateUpdate) GetPrice() float64
- func (m *ExchangeRateUpdate) GetStamp() int64
- func (m *ExchangeRateUpdate) GetToken() string
- func (m *ExchangeRateUpdate) GetVolume() float64
- func (*ExchangeRateUpdate) ProtoMessage()
- func (m *ExchangeRateUpdate) Reset()
- func (m *ExchangeRateUpdate) String() string
- func (m *ExchangeRateUpdate) XXX_DiscardUnknown()
- func (m *ExchangeRateUpdate) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *ExchangeRateUpdate) XXX_Merge(src proto.Message)
- func (m *ExchangeRateUpdate) XXX_Size() int
- func (m *ExchangeRateUpdate) XXX_Unmarshal(b []byte) error
- type ExchangeRateUpdate_Candlestick
- func (*ExchangeRateUpdate_Candlestick) Descriptor() ([]byte, []int)
- func (m *ExchangeRateUpdate_Candlestick) GetClose() float64
- func (m *ExchangeRateUpdate_Candlestick) GetHigh() float64
- func (m *ExchangeRateUpdate_Candlestick) GetLow() float64
- func (m *ExchangeRateUpdate_Candlestick) GetOpen() float64
- func (m *ExchangeRateUpdate_Candlestick) GetStart() int64
- func (m *ExchangeRateUpdate_Candlestick) GetVolume() float64
- func (*ExchangeRateUpdate_Candlestick) ProtoMessage()
- func (m *ExchangeRateUpdate_Candlestick) Reset()
- func (m *ExchangeRateUpdate_Candlestick) String() string
- func (m *ExchangeRateUpdate_Candlestick) XXX_DiscardUnknown()
- func (m *ExchangeRateUpdate_Candlestick) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *ExchangeRateUpdate_Candlestick) XXX_Merge(src proto.Message)
- func (m *ExchangeRateUpdate_Candlestick) XXX_Size() int
- func (m *ExchangeRateUpdate_Candlestick) XXX_Unmarshal(b []byte) error
- type ExchangeRateUpdate_Candlesticks
- func (*ExchangeRateUpdate_Candlesticks) Descriptor() ([]byte, []int)
- func (m *ExchangeRateUpdate_Candlesticks) GetBin() string
- func (m *ExchangeRateUpdate_Candlesticks) GetSticks() []*ExchangeRateUpdate_Candlestick
- func (*ExchangeRateUpdate_Candlesticks) ProtoMessage()
- func (m *ExchangeRateUpdate_Candlesticks) Reset()
- func (m *ExchangeRateUpdate_Candlesticks) String() string
- func (m *ExchangeRateUpdate_Candlesticks) XXX_DiscardUnknown()
- func (m *ExchangeRateUpdate_Candlesticks) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *ExchangeRateUpdate_Candlesticks) XXX_Merge(src proto.Message)
- func (m *ExchangeRateUpdate_Candlesticks) XXX_Size() int
- func (m *ExchangeRateUpdate_Candlesticks) XXX_Unmarshal(b []byte) error
- type ExchangeRateUpdate_DepthData
- func (*ExchangeRateUpdate_DepthData) Descriptor() ([]byte, []int)
- func (m *ExchangeRateUpdate_DepthData) GetAsks() []*ExchangeRateUpdate_DepthPoint
- func (m *ExchangeRateUpdate_DepthData) GetBids() []*ExchangeRateUpdate_DepthPoint
- func (m *ExchangeRateUpdate_DepthData) GetTime() int64
- func (*ExchangeRateUpdate_DepthData) ProtoMessage()
- func (m *ExchangeRateUpdate_DepthData) Reset()
- func (m *ExchangeRateUpdate_DepthData) String() string
- func (m *ExchangeRateUpdate_DepthData) XXX_DiscardUnknown()
- func (m *ExchangeRateUpdate_DepthData) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *ExchangeRateUpdate_DepthData) XXX_Merge(src proto.Message)
- func (m *ExchangeRateUpdate_DepthData) XXX_Size() int
- func (m *ExchangeRateUpdate_DepthData) XXX_Unmarshal(b []byte) error
- type ExchangeRateUpdate_DepthPoint
- func (*ExchangeRateUpdate_DepthPoint) Descriptor() ([]byte, []int)
- func (m *ExchangeRateUpdate_DepthPoint) GetPrice() float64
- func (m *ExchangeRateUpdate_DepthPoint) GetQuantity() float64
- func (*ExchangeRateUpdate_DepthPoint) ProtoMessage()
- func (m *ExchangeRateUpdate_DepthPoint) Reset()
- func (m *ExchangeRateUpdate_DepthPoint) String() string
- func (m *ExchangeRateUpdate_DepthPoint) XXX_DiscardUnknown()
- func (m *ExchangeRateUpdate_DepthPoint) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *ExchangeRateUpdate_DepthPoint) XXX_Merge(src proto.Message)
- func (m *ExchangeRateUpdate_DepthPoint) XXX_Size() int
- func (m *ExchangeRateUpdate_DepthPoint) XXX_Unmarshal(b []byte) error
- type ExchangeSubscription
- func (*ExchangeSubscription) Descriptor() ([]byte, []int)
- func (m *ExchangeSubscription) GetBtcIndex() string
- func (m *ExchangeSubscription) GetExchanges() []string
- func (*ExchangeSubscription) ProtoMessage()
- func (m *ExchangeSubscription) Reset()
- func (m *ExchangeSubscription) String() string
- func (m *ExchangeSubscription) XXX_DiscardUnknown()
- func (m *ExchangeSubscription) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *ExchangeSubscription) XXX_Merge(src proto.Message)
- func (m *ExchangeSubscription) XXX_Size() int
- func (m *ExchangeSubscription) XXX_Unmarshal(b []byte) error
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 (m *ExchangeRateUpdate) GetDepth() *ExchangeRateUpdate_DepthData
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 (m *ExchangeRateUpdate_Candlestick) GetClose() float64
func (*ExchangeRateUpdate_Candlestick) GetHigh ¶
func (m *ExchangeRateUpdate_Candlestick) GetHigh() float64
func (*ExchangeRateUpdate_Candlestick) GetLow ¶
func (m *ExchangeRateUpdate_Candlestick) GetLow() float64
func (*ExchangeRateUpdate_Candlestick) GetOpen ¶
func (m *ExchangeRateUpdate_Candlestick) GetOpen() float64
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 (m *ExchangeRateUpdate_Candlestick) String() 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 (m *ExchangeRateUpdate_Candlesticks) GetBin() string
func (*ExchangeRateUpdate_Candlesticks) GetSticks ¶
func (m *ExchangeRateUpdate_Candlesticks) GetSticks() []*ExchangeRateUpdate_Candlestick
func (*ExchangeRateUpdate_Candlesticks) ProtoMessage ¶
func (*ExchangeRateUpdate_Candlesticks) ProtoMessage()
func (*ExchangeRateUpdate_Candlesticks) Reset ¶
func (m *ExchangeRateUpdate_Candlesticks) Reset()
func (*ExchangeRateUpdate_Candlesticks) String ¶
func (m *ExchangeRateUpdate_Candlesticks) String() 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 (m *ExchangeRateUpdate_DepthData) GetAsks() []*ExchangeRateUpdate_DepthPoint
func (*ExchangeRateUpdate_DepthData) GetBids ¶
func (m *ExchangeRateUpdate_DepthData) GetBids() []*ExchangeRateUpdate_DepthPoint
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 (m *ExchangeRateUpdate_DepthData) String() 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 (m *ExchangeRateUpdate_DepthPoint) String() 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
Click to show internal directories.
Click to hide internal directories.