topStations

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
  • func NewTopStationsClient(cc *grpc.ClientConn) TopStationsClient
• type TopStationsServer

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.