bitumrates

package module
v0.0.0-...-1112063 Latest Latest
Warning

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

 Go to latest Published: Jun 16, 2019 License: ISC Imports: 6 Imported by: 2

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 bitumrates application
	// data folder.
	DefaultAppDirectory = bitumutil.AppDataDir("bitumrates", false)
)

Functions

func RegisterBITUMRatesServer 

func RegisterBITUMRatesServer(s *grpc.Server, srv BITUMRatesServer)

Types

type BITUMRatesClient 

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

BITUMRatesClient is the client API for BITUMRates service.

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

func NewBITUMRatesClient 

func NewBITUMRatesClient(cc *grpc.ClientConn) BITUMRatesClient

type BITUMRatesServer 

type BITUMRatesServer interface {
	SubscribeExchanges(*ExchangeSubscription, BITUMRates_SubscribeExchangesServer) error
}

BITUMRatesServer is the server API for BITUMRates service.

type BITUMRates_SubscribeExchangesClient 

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

type BITUMRates_SubscribeExchangesServer 

type BITUMRates_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

Source Files

View all Source files

Directories

Path Synopsis
rateserver module

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.