Documentation ¶
Index ¶
- func RegisterTopStationsServer(s *grpc.Server, srv TopStationsServer)
- type GetTopStationsRequest
- func (*GetTopStationsRequest) Descriptor() ([]byte, []int)
- func (*GetTopStationsRequest) ProtoMessage()
- func (m *GetTopStationsRequest) Reset()
- func (m *GetTopStationsRequest) String() string
- func (m *GetTopStationsRequest) XXX_DiscardUnknown()
- func (m *GetTopStationsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *GetTopStationsRequest) XXX_Merge(src proto.Message)
- func (m *GetTopStationsRequest) XXX_Size() int
- func (m *GetTopStationsRequest) XXX_Unmarshal(b []byte) error
- type GetTopStationsResponse
- func (*GetTopStationsResponse) Descriptor() ([]byte, []int)
- func (m *GetTopStationsResponse) GetStations() []*StationStats
- func (*GetTopStationsResponse) ProtoMessage()
- func (m *GetTopStationsResponse) Reset()
- func (m *GetTopStationsResponse) String() string
- func (m *GetTopStationsResponse) XXX_DiscardUnknown()
- func (m *GetTopStationsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *GetTopStationsResponse) XXX_Merge(src proto.Message)
- func (m *GetTopStationsResponse) XXX_Size() int
- func (m *GetTopStationsResponse) XXX_Unmarshal(b []byte) error
- type StationStats
- func (*StationStats) Descriptor() ([]byte, []int)
- func (m *StationStats) GetAskVolume() float64
- func (m *StationStats) GetBidVolume() float64
- func (m *StationStats) GetId() int64
- func (m *StationStats) GetTotalOrders() int64
- func (m *StationStats) GetTotalVolume() float64
- func (*StationStats) ProtoMessage()
- func (m *StationStats) Reset()
- func (m *StationStats) String() string
- func (m *StationStats) XXX_DiscardUnknown()
- func (m *StationStats) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *StationStats) XXX_Merge(src proto.Message)
- func (m *StationStats) XXX_Size() int
- func (m *StationStats) XXX_Unmarshal(b []byte) error
- type TopStationsClient
- type TopStationsServer
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func RegisterTopStationsServer ¶
func RegisterTopStationsServer(s *grpc.Server, srv TopStationsServer)
Types ¶
type GetTopStationsRequest ¶
type GetTopStationsRequest struct { XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*GetTopStationsRequest) Descriptor ¶
func (*GetTopStationsRequest) Descriptor() ([]byte, []int)
func (*GetTopStationsRequest) ProtoMessage ¶
func (*GetTopStationsRequest) ProtoMessage()
func (*GetTopStationsRequest) Reset ¶
func (m *GetTopStationsRequest) Reset()
func (*GetTopStationsRequest) String ¶
func (m *GetTopStationsRequest) String() string
func (*GetTopStationsRequest) XXX_DiscardUnknown ¶
func (m *GetTopStationsRequest) XXX_DiscardUnknown()
func (*GetTopStationsRequest) XXX_Marshal ¶
func (m *GetTopStationsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GetTopStationsRequest) XXX_Merge ¶
func (dst *GetTopStationsRequest) XXX_Merge(src proto.Message)
func (*GetTopStationsRequest) XXX_Size ¶
func (m *GetTopStationsRequest) XXX_Size() int
func (*GetTopStationsRequest) XXX_Unmarshal ¶
func (m *GetTopStationsRequest) XXX_Unmarshal(b []byte) error
type GetTopStationsResponse ¶
type GetTopStationsResponse struct { // Station list Stations []*StationStats `protobuf:"bytes,1,rep,name=stations,proto3" json:"stations,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*GetTopStationsResponse) Descriptor ¶
func (*GetTopStationsResponse) Descriptor() ([]byte, []int)
func (*GetTopStationsResponse) GetStations ¶
func (m *GetTopStationsResponse) GetStations() []*StationStats
func (*GetTopStationsResponse) ProtoMessage ¶
func (*GetTopStationsResponse) ProtoMessage()
func (*GetTopStationsResponse) Reset ¶
func (m *GetTopStationsResponse) Reset()
func (*GetTopStationsResponse) String ¶
func (m *GetTopStationsResponse) String() string
func (*GetTopStationsResponse) XXX_DiscardUnknown ¶
func (m *GetTopStationsResponse) XXX_DiscardUnknown()
func (*GetTopStationsResponse) XXX_Marshal ¶
func (m *GetTopStationsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GetTopStationsResponse) XXX_Merge ¶
func (dst *GetTopStationsResponse) XXX_Merge(src proto.Message)
func (*GetTopStationsResponse) XXX_Size ¶
func (m *GetTopStationsResponse) XXX_Size() int
func (*GetTopStationsResponse) XXX_Unmarshal ¶
func (m *GetTopStationsResponse) XXX_Unmarshal(b []byte) error
type StationStats ¶
type StationStats struct { // The station's ID Id int64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"` // The station's ask orders total volume AskVolume float64 `protobuf:"fixed64,2,opt,name=ask_volume,json=askVolume,proto3" json:"ask_volume,omitempty"` // The station's bid orders total volume BidVolume float64 `protobuf:"fixed64,3,opt,name=bid_volume,json=bidVolume,proto3" json:"bid_volume,omitempty"` // The station's orders total volume TotalVolume float64 `protobuf:"fixed64,4,opt,name=total_volume,json=totalVolume,proto3" json:"total_volume,omitempty"` // The station's total number of orders TotalOrders int64 `protobuf:"varint,5,opt,name=total_orders,json=totalOrders,proto3" json:"total_orders,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*StationStats) Descriptor ¶
func (*StationStats) Descriptor() ([]byte, []int)
func (*StationStats) GetAskVolume ¶
func (m *StationStats) GetAskVolume() float64
func (*StationStats) GetBidVolume ¶
func (m *StationStats) GetBidVolume() float64
func (*StationStats) GetId ¶
func (m *StationStats) GetId() int64
func (*StationStats) GetTotalOrders ¶
func (m *StationStats) GetTotalOrders() int64
func (*StationStats) GetTotalVolume ¶
func (m *StationStats) GetTotalVolume() float64
func (*StationStats) ProtoMessage ¶
func (*StationStats) ProtoMessage()
func (*StationStats) Reset ¶
func (m *StationStats) Reset()
func (*StationStats) String ¶
func (m *StationStats) String() string
func (*StationStats) XXX_DiscardUnknown ¶
func (m *StationStats) XXX_DiscardUnknown()
func (*StationStats) XXX_Marshal ¶
func (m *StationStats) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*StationStats) XXX_Merge ¶
func (dst *StationStats) XXX_Merge(src proto.Message)
func (*StationStats) XXX_Size ¶
func (m *StationStats) XXX_Size() int
func (*StationStats) XXX_Unmarshal ¶
func (m *StationStats) XXX_Unmarshal(b []byte) error
type TopStationsClient ¶
type TopStationsClient interface {
GetTopStations(ctx context.Context, in *GetTopStationsRequest, opts ...grpc.CallOption) (*GetTopStationsResponse, error)
}
TopStationsClient is the client API for TopStations service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewTopStationsClient ¶
func NewTopStationsClient(cc *grpc.ClientConn) TopStationsClient
type TopStationsServer ¶
type TopStationsServer interface {
GetTopStations(context.Context, *GetTopStationsRequest) (*GetTopStationsResponse, error)
}
TopStationsServer is the server API for TopStations service.
Click to show internal directories.
Click to hide internal directories.