grpc

Documentation

Overview

Package grpc is a generated protocol buffer package.

It is generated from these files:

grpc/cryptotrader.proto

It has these top-level messages:

UpdateTickerReport
EnabledExchangeCurrencies
AllEnabledExchangeCurrencies
SpecificTicker

Index

• func RegisterGoCryptoTraderServiceServer(s *grpc1.Server, srv GoCryptoTraderServiceServer)
• type AllEnabledExchangeCurrencies
  • func (*AllEnabledExchangeCurrencies) Descriptor() ([]byte, []int)
  • func (m *AllEnabledExchangeCurrencies) GetExchangeCurrencies() []*EnabledExchangeCurrencies
  • func (*AllEnabledExchangeCurrencies) ProtoMessage()
  • func (m *AllEnabledExchangeCurrencies) Reset()
  • func (cs *AllEnabledExchangeCurrencies) StoreInInflux(ctx InfluxContext) error
  • func (m *AllEnabledExchangeCurrencies) String() string
• type EnabledExchangeCurrencies
  • func (*EnabledExchangeCurrencies) Descriptor() ([]byte, []int)
  • func (m *EnabledExchangeCurrencies) GetExchangeName() string
  • func (m *EnabledExchangeCurrencies) GetExchangeValues() []*ticker.Price
  • func (*EnabledExchangeCurrencies) ProtoMessage()
  • func (m *EnabledExchangeCurrencies) Reset()
  • func (m *EnabledExchangeCurrencies) String() string
• type GoCryptoTraderServiceClient
  • func NewGoCryptoTraderServiceClient(cc *grpc1.ClientConn) GoCryptoTraderServiceClient
• type GoCryptoTraderServiceServer
• type GoCryptoTraderService_UpdateTickerClient
• type GoCryptoTraderService_UpdateTickerServer
• type InfluxContext
• type SpecificTicker
  • func (*SpecificTicker) Descriptor() ([]byte, []int)
  • func (m *SpecificTicker) GetAssetType() string
  • func (m *SpecificTicker) GetCurrency() string
  • func (m *SpecificTicker) GetExchangeName() string
  • func (*SpecificTicker) ProtoMessage()
  • func (m *SpecificTicker) Reset()
  • func (m *SpecificTicker) String() string
• type UpdateTickerReport
  • func (*UpdateTickerReport) Descriptor() ([]byte, []int)
  • func (m *UpdateTickerReport) GetAssetType() string
  • func (m *UpdateTickerReport) GetExchangeName() string
  • func (m *UpdateTickerReport) GetPrice() *ticker.Price
  • func (*UpdateTickerReport) ProtoMessage()
  • func (m *UpdateTickerReport) Reset()
  • func (rep *UpdateTickerReport) StoreInInflux(ctx InfluxContext) error
  • func (m *UpdateTickerReport) String() string

Functions

func RegisterGoCryptoTraderServiceServer

func RegisterGoCryptoTraderServiceServer(s *grpc1.Server, srv GoCryptoTraderServiceServer)

Types

type AllEnabledExchangeCurrencies

type AllEnabledExchangeCurrencies struct {
	ExchangeCurrencies []*EnabledExchangeCurrencies `protobuf:"bytes,1,rep,name=ExchangeCurrencies" json:"ExchangeCurrencies,omitempty"`
}

func (*AllEnabledExchangeCurrencies) Descriptor

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

func (*AllEnabledExchangeCurrencies) GetExchangeCurrencies

func (m *AllEnabledExchangeCurrencies) GetExchangeCurrencies() []*EnabledExchangeCurrencies

func (*AllEnabledExchangeCurrencies) ProtoMessage

func (*AllEnabledExchangeCurrencies) ProtoMessage()

func (*AllEnabledExchangeCurrencies) Reset

func (m *AllEnabledExchangeCurrencies) Reset()

func (*AllEnabledExchangeCurrencies) StoreInInflux

func (cs *AllEnabledExchangeCurrencies) StoreInInflux(ctx InfluxContext) error

func (*AllEnabledExchangeCurrencies) String

func (m *AllEnabledExchangeCurrencies) String() string

type EnabledExchangeCurrencies

type EnabledExchangeCurrencies struct {
	ExchangeName   string          `protobuf:"bytes,1,opt,name=ExchangeName" json:"ExchangeName,omitempty"`
	ExchangeValues []*ticker.Price `protobuf:"bytes,2,rep,name=ExchangeValues" json:"ExchangeValues,omitempty"`
}

func (*EnabledExchangeCurrencies) Descriptor

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

func (*EnabledExchangeCurrencies) GetExchangeName

func (m *EnabledExchangeCurrencies) GetExchangeName() string

func (*EnabledExchangeCurrencies) GetExchangeValues

func (m *EnabledExchangeCurrencies) GetExchangeValues() []*ticker.Price

func (*EnabledExchangeCurrencies) ProtoMessage

func (*EnabledExchangeCurrencies) ProtoMessage()

func (*EnabledExchangeCurrencies) Reset

func (m *EnabledExchangeCurrencies) Reset()

func (*EnabledExchangeCurrencies) String

func (m *EnabledExchangeCurrencies) String() string

type GoCryptoTraderServiceClient

type GoCryptoTraderServiceClient interface {
	GetTickers(ctx context.Context, in *google_protobuf.Empty, opts ...grpc1.CallOption) (*AllEnabledExchangeCurrencies, error)
	GetTicker(ctx context.Context, in *SpecificTicker, opts ...grpc1.CallOption) (*ticker.Price, error)
	UpdateTicker(ctx context.Context, in *google_protobuf.Empty, opts ...grpc1.CallOption) (GoCryptoTraderService_UpdateTickerClient, error)
}

func NewGoCryptoTraderServiceClient

func NewGoCryptoTraderServiceClient(cc *grpc1.ClientConn) GoCryptoTraderServiceClient

type GoCryptoTraderServiceServer

type GoCryptoTraderServiceServer interface {
	GetTickers(context.Context, *google_protobuf.Empty) (*AllEnabledExchangeCurrencies, error)
	GetTicker(context.Context, *SpecificTicker) (*ticker.Price, error)
	UpdateTicker(*google_protobuf.Empty, GoCryptoTraderService_UpdateTickerServer) error
}

type GoCryptoTraderService_UpdateTickerClient

type GoCryptoTraderService_UpdateTickerClient interface {
	Recv() (*UpdateTickerReport, error)
	grpc1.ClientStream
}

type GoCryptoTraderService_UpdateTickerServer

type GoCryptoTraderService_UpdateTickerServer interface {
	Send(*UpdateTickerReport) error
	grpc1.ServerStream
}

type InfluxContext

type InfluxContext interface {
	GetBpCfg() ic.BatchPointsConfig
	Write(ic.BatchPoints) error
}

type SpecificTicker

type SpecificTicker struct {
	Currency     string `protobuf:"bytes,1,opt,name=Currency" json:"Currency,omitempty"`
	ExchangeName string `protobuf:"bytes,2,opt,name=ExchangeName" json:"ExchangeName,omitempty"`
	AssetType    string `protobuf:"bytes,3,opt,name=AssetType" json:"AssetType,omitempty"`
}

func (*SpecificTicker) Descriptor

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

func (*SpecificTicker) GetAssetType

func (m *SpecificTicker) GetAssetType() string

func (*SpecificTicker) GetCurrency

func (m *SpecificTicker) GetCurrency() string

func (*SpecificTicker) GetExchangeName

func (m *SpecificTicker) GetExchangeName() string

func (*SpecificTicker) ProtoMessage

func (*SpecificTicker) ProtoMessage()

func (*SpecificTicker) Reset

func (m *SpecificTicker) Reset()

func (*SpecificTicker) String

func (m *SpecificTicker) String() string

type UpdateTickerReport

type UpdateTickerReport struct {
	Price        *ticker.Price `protobuf:"bytes,1,opt,name=Price" json:"Price,omitempty"`
	ExchangeName string        `protobuf:"bytes,2,opt,name=ExchangeName" json:"ExchangeName,omitempty"`
	AssetType    string        `protobuf:"bytes,3,opt,name=AssetType" json:"AssetType,omitempty"`
}

func (*UpdateTickerReport) Descriptor

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

func (*UpdateTickerReport) GetAssetType

func (m *UpdateTickerReport) GetAssetType() string

func (*UpdateTickerReport) GetExchangeName

func (m *UpdateTickerReport) GetExchangeName() string

func (*UpdateTickerReport) GetPrice

func (m *UpdateTickerReport) GetPrice() *ticker.Price

func (*UpdateTickerReport) ProtoMessage

func (*UpdateTickerReport) ProtoMessage()

func (*UpdateTickerReport) Reset

func (m *UpdateTickerReport) Reset()

func (*UpdateTickerReport) StoreInInflux

func (rep *UpdateTickerReport) StoreInInflux(ctx InfluxContext) error

func (*UpdateTickerReport) String

func (m *UpdateTickerReport) String() string