Documentation ¶
Index ¶
- Variables
- func RegisterOrderBooksServer(s *grpc.Server, srv OrderBooksServer)
- type EmptyMsg
- func (*EmptyMsg) Descriptor() ([]byte, []int)
- func (m *EmptyMsg) Marshal() (dAtA []byte, err error)
- func (m *EmptyMsg) MarshalTo(dAtA []byte) (int, error)
- func (m *EmptyMsg) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*EmptyMsg) ProtoMessage()
- func (m *EmptyMsg) Reset()
- func (m *EmptyMsg) Size() (n int)
- func (m *EmptyMsg) String() string
- func (m *EmptyMsg) Unmarshal(dAtA []byte) error
- func (m *EmptyMsg) XXX_DiscardUnknown()
- func (m *EmptyMsg) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *EmptyMsg) XXX_Merge(src proto.Message)
- func (m *EmptyMsg) XXX_Size() int
- func (m *EmptyMsg) XXX_Unmarshal(b []byte) error
- type Event
- func (*Event) Descriptor() ([]byte, []int)
- func (m *Event) GetAmount() float32
- func (m *Event) GetEventType() EventType
- func (m *Event) GetOrderSide() OrderSide
- func (m *Event) GetPrice() float32
- func (m *Event) GetTimestamp() int64
- func (m *Event) Marshal() (dAtA []byte, err error)
- func (m *Event) MarshalTo(dAtA []byte) (int, error)
- func (m *Event) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Event) ProtoMessage()
- func (m *Event) Reset()
- func (m *Event) Size() (n int)
- func (m *Event) String() string
- func (m *Event) Unmarshal(dAtA []byte) error
- func (m *Event) XXX_DiscardUnknown()
- func (m *Event) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Event) XXX_Merge(src proto.Message)
- func (m *Event) XXX_Size() int
- func (m *Event) XXX_Unmarshal(b []byte) error
- type EventType
- type EventsQueryMsg
- func (*EventsQueryMsg) Descriptor() ([]byte, []int)
- func (m *EventsQueryMsg) GetDateEnd() *types.Timestamp
- func (m *EventsQueryMsg) GetDateStart() *types.Timestamp
- func (m *EventsQueryMsg) GetExchange() string
- func (m *EventsQueryMsg) GetInterval() string
- func (m *EventsQueryMsg) GetPair() string
- func (m *EventsQueryMsg) GetSnapshotInterval() isEventsQueryMsg_SnapshotInterval
- func (m *EventsQueryMsg) GetSnapshotSize() int64
- func (m *EventsQueryMsg) GetTicks() int64
- func (m *EventsQueryMsg) Marshal() (dAtA []byte, err error)
- func (m *EventsQueryMsg) MarshalTo(dAtA []byte) (int, error)
- func (m *EventsQueryMsg) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*EventsQueryMsg) ProtoMessage()
- func (m *EventsQueryMsg) Reset()
- func (m *EventsQueryMsg) Size() (n int)
- func (m *EventsQueryMsg) String() string
- func (m *EventsQueryMsg) Unmarshal(dAtA []byte) error
- func (m *EventsQueryMsg) XXX_DiscardUnknown()
- func (m *EventsQueryMsg) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *EventsQueryMsg) XXX_Merge(src proto.Message)
- func (*EventsQueryMsg) XXX_OneofWrappers() []interface{}
- func (m *EventsQueryMsg) XXX_Size() int
- func (m *EventsQueryMsg) XXX_Unmarshal(b []byte) error
- type EventsQueryMsg_Interval
- type EventsQueryMsg_Ticks
- type ExchangeMsg
- func (*ExchangeMsg) Descriptor() ([]byte, []int)
- func (m *ExchangeMsg) GetDateEnd() *types.Timestamp
- func (m *ExchangeMsg) GetDateStart() *types.Timestamp
- func (m *ExchangeMsg) GetId() string
- func (m *ExchangeMsg) GetName() string
- func (m *ExchangeMsg) GetPairs() []*PairMsg
- func (m *ExchangeMsg) Marshal() (dAtA []byte, err error)
- func (m *ExchangeMsg) MarshalTo(dAtA []byte) (int, error)
- func (m *ExchangeMsg) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ExchangeMsg) ProtoMessage()
- func (m *ExchangeMsg) Reset()
- func (m *ExchangeMsg) Size() (n int)
- func (m *ExchangeMsg) String() string
- func (m *ExchangeMsg) Unmarshal(dAtA []byte) error
- func (m *ExchangeMsg) XXX_DiscardUnknown()
- func (m *ExchangeMsg) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ExchangeMsg) XXX_Merge(src proto.Message)
- func (m *ExchangeMsg) XXX_Size() int
- func (m *ExchangeMsg) XXX_Unmarshal(b []byte) error
- type GetExchangesResponseMsg
- func (*GetExchangesResponseMsg) Descriptor() ([]byte, []int)
- func (m *GetExchangesResponseMsg) GetCount() uint32
- func (m *GetExchangesResponseMsg) GetExchanges() []*ExchangeMsg
- func (m *GetExchangesResponseMsg) Marshal() (dAtA []byte, err error)
- func (m *GetExchangesResponseMsg) MarshalTo(dAtA []byte) (int, error)
- func (m *GetExchangesResponseMsg) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*GetExchangesResponseMsg) ProtoMessage()
- func (m *GetExchangesResponseMsg) Reset()
- func (m *GetExchangesResponseMsg) Size() (n int)
- func (m *GetExchangesResponseMsg) String() string
- func (m *GetExchangesResponseMsg) Unmarshal(dAtA []byte) error
- func (m *GetExchangesResponseMsg) XXX_DiscardUnknown()
- func (m *GetExchangesResponseMsg) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetExchangesResponseMsg) XXX_Merge(src proto.Message)
- func (m *GetExchangesResponseMsg) XXX_Size() int
- func (m *GetExchangesResponseMsg) XXX_Unmarshal(b []byte) error
- type OrderBooksClient
- type OrderBooksServer
- type OrderBooks_GetCachedDataClient
- type OrderBooks_GetCachedDataServer
- type OrderBooks_GetLiveDataClient
- type OrderBooks_GetLiveDataServer
- type OrderBooks_QueryEventsClient
- type OrderBooks_QueryEventsServer
- type OrderSide
- type PairMsg
- func (*PairMsg) Descriptor() ([]byte, []int)
- func (m *PairMsg) GetBase() string
- func (m *PairMsg) GetDateEnd() *types.Timestamp
- func (m *PairMsg) GetDateStart() *types.Timestamp
- func (m *PairMsg) GetQuote() string
- func (m *PairMsg) Marshal() (dAtA []byte, err error)
- func (m *PairMsg) MarshalTo(dAtA []byte) (int, error)
- func (m *PairMsg) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*PairMsg) ProtoMessage()
- func (m *PairMsg) Reset()
- func (m *PairMsg) Size() (n int)
- func (m *PairMsg) String() string
- func (m *PairMsg) Unmarshal(dAtA []byte) error
- func (m *PairMsg) XXX_DiscardUnknown()
- func (m *PairMsg) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *PairMsg) XXX_Merge(src proto.Message)
- func (m *PairMsg) XXX_Size() int
- func (m *PairMsg) XXX_Unmarshal(b []byte) error
- type SnapshotMode
- type SnapshotMsg
- func (*SnapshotMsg) Descriptor() ([]byte, []int)
- func (m *SnapshotMsg) GetCounter() int64
- func (m *SnapshotMsg) GetEvents() []*Event
- func (m *SnapshotMsg) GetExchange() string
- func (m *SnapshotMsg) GetOrders() []*Event
- func (m *SnapshotMsg) GetPair() string
- func (m *SnapshotMsg) GetSessionId() int64
- func (m *SnapshotMsg) GetTimestamp() *types.Timestamp
- func (m *SnapshotMsg) Marshal() (dAtA []byte, err error)
- func (m *SnapshotMsg) MarshalTo(dAtA []byte) (int, error)
- func (m *SnapshotMsg) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*SnapshotMsg) ProtoMessage()
- func (m *SnapshotMsg) Reset()
- func (m *SnapshotMsg) Size() (n int)
- func (m *SnapshotMsg) String() string
- func (m *SnapshotMsg) Unmarshal(dAtA []byte) error
- func (m *SnapshotMsg) XXX_DiscardUnknown()
- func (m *SnapshotMsg) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *SnapshotMsg) XXX_Merge(src proto.Message)
- func (m *SnapshotMsg) XXX_Size() int
- func (m *SnapshotMsg) XXX_Unmarshal(b []byte) error
- type UnimplementedOrderBooksServer
- func (*UnimplementedOrderBooksServer) GetCachedData(req *EventsQueryMsg, srv OrderBooks_GetCachedDataServer) error
- func (*UnimplementedOrderBooksServer) GetExchanges(ctx context.Context, req *EmptyMsg) (*GetExchangesResponseMsg, error)
- func (*UnimplementedOrderBooksServer) GetLiveData(req *EventsQueryMsg, srv OrderBooks_GetLiveDataServer) error
- func (*UnimplementedOrderBooksServer) QueryEvents(req *EventsQueryMsg, srv OrderBooks_QueryEventsServer) error
Constants ¶
This section is empty.
Variables ¶
View Source
var ( ErrInvalidLengthOrderbooks = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowOrderbooks = fmt.Errorf("proto: integer overflow") ErrUnexpectedEndOfGroupOrderbooks = fmt.Errorf("proto: unexpected end of group") )
View Source
var EventType_name = map[int32]string{
0: "INIT",
1: "ADD",
2: "CHANGE",
3: "REMOVE",
}
View Source
var EventType_value = map[string]int32{
"INIT": 0,
"ADD": 1,
"CHANGE": 2,
"REMOVE": 3,
}
View Source
var OrderSide_name = map[int32]string{
0: "BID",
1: "ASK",
}
View Source
var OrderSide_value = map[string]int32{
"BID": 0,
"ASK": 1,
}
View Source
var SnapshotMode_name = map[int32]string{
0: "TIME",
1: "TICKS",
}
View Source
var SnapshotMode_value = map[string]int32{
"TIME": 0,
"TICKS": 1,
}
Functions ¶
func RegisterOrderBooksServer ¶
func RegisterOrderBooksServer(s *grpc.Server, srv OrderBooksServer)
Types ¶
type EmptyMsg ¶
type EmptyMsg struct { XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*EmptyMsg) Descriptor ¶
func (*EmptyMsg) MarshalToSizedBuffer ¶
func (*EmptyMsg) ProtoMessage ¶
func (*EmptyMsg) ProtoMessage()
func (*EmptyMsg) XXX_DiscardUnknown ¶
func (m *EmptyMsg) XXX_DiscardUnknown()
func (*EmptyMsg) XXX_Marshal ¶
func (*EmptyMsg) XXX_Unmarshal ¶
type Event ¶
type Event struct { Timestamp int64 `protobuf:"varint,1,opt,name=timestamp,proto3" json:"timestamp,omitempty"` OrderSide OrderSide `protobuf:"varint,2,opt,name=order_side,json=orderSide,proto3,enum=orderbooks.OrderSide" json:"order_side,omitempty"` Amount float32 `protobuf:"fixed32,3,opt,name=amount,proto3" json:"amount,omitempty"` Price float32 `protobuf:"fixed32,4,opt,name=price,proto3" json:"price,omitempty"` EventType EventType `protobuf:"varint,5,opt,name=event_type,json=eventType,proto3,enum=orderbooks.EventType" json:"event_type,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*Event) Descriptor ¶
func (*Event) GetEventType ¶
func (*Event) GetOrderSide ¶
func (*Event) GetTimestamp ¶
func (*Event) ProtoMessage ¶
func (*Event) ProtoMessage()
func (*Event) XXX_DiscardUnknown ¶
func (m *Event) XXX_DiscardUnknown()
func (*Event) XXX_Marshal ¶
func (*Event) XXX_Unmarshal ¶
type EventsQueryMsg ¶
type EventsQueryMsg struct { Exchange string `protobuf:"bytes,1,opt,name=exchange,proto3" json:"exchange,omitempty"` DateStart *types.Timestamp `protobuf:"bytes,2,opt,name=date_start,json=dateStart,proto3" json:"date_start,omitempty"` DateEnd *types.Timestamp `protobuf:"bytes,3,opt,name=date_end,json=dateEnd,proto3" json:"date_end,omitempty"` Pair string `protobuf:"bytes,4,opt,name=pair,proto3" json:"pair,omitempty"` // Types that are valid to be assigned to SnapshotInterval: // *EventsQueryMsg_Interval // *EventsQueryMsg_Ticks SnapshotInterval isEventsQueryMsg_SnapshotInterval `protobuf_oneof:"snapshot_interval"` SnapshotSize int64 `protobuf:"varint,6,opt,name=snapshot_size,json=snapshotSize,proto3" json:"snapshot_size,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*EventsQueryMsg) Descriptor ¶
func (*EventsQueryMsg) Descriptor() ([]byte, []int)
func (*EventsQueryMsg) GetDateEnd ¶
func (m *EventsQueryMsg) GetDateEnd() *types.Timestamp
func (*EventsQueryMsg) GetDateStart ¶
func (m *EventsQueryMsg) GetDateStart() *types.Timestamp
func (*EventsQueryMsg) GetExchange ¶
func (m *EventsQueryMsg) GetExchange() string
func (*EventsQueryMsg) GetInterval ¶
func (m *EventsQueryMsg) GetInterval() string
func (*EventsQueryMsg) GetPair ¶
func (m *EventsQueryMsg) GetPair() string
func (*EventsQueryMsg) GetSnapshotInterval ¶
func (m *EventsQueryMsg) GetSnapshotInterval() isEventsQueryMsg_SnapshotInterval
func (*EventsQueryMsg) GetSnapshotSize ¶
func (m *EventsQueryMsg) GetSnapshotSize() int64
func (*EventsQueryMsg) GetTicks ¶
func (m *EventsQueryMsg) GetTicks() int64
func (*EventsQueryMsg) Marshal ¶
func (m *EventsQueryMsg) Marshal() (dAtA []byte, err error)
func (*EventsQueryMsg) MarshalToSizedBuffer ¶
func (m *EventsQueryMsg) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*EventsQueryMsg) ProtoMessage ¶
func (*EventsQueryMsg) ProtoMessage()
func (*EventsQueryMsg) Reset ¶
func (m *EventsQueryMsg) Reset()
func (*EventsQueryMsg) Size ¶
func (m *EventsQueryMsg) Size() (n int)
func (*EventsQueryMsg) String ¶
func (m *EventsQueryMsg) String() string
func (*EventsQueryMsg) Unmarshal ¶
func (m *EventsQueryMsg) Unmarshal(dAtA []byte) error
func (*EventsQueryMsg) XXX_DiscardUnknown ¶
func (m *EventsQueryMsg) XXX_DiscardUnknown()
func (*EventsQueryMsg) XXX_Marshal ¶
func (m *EventsQueryMsg) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*EventsQueryMsg) XXX_Merge ¶
func (m *EventsQueryMsg) XXX_Merge(src proto.Message)
func (*EventsQueryMsg) XXX_OneofWrappers ¶
func (*EventsQueryMsg) XXX_OneofWrappers() []interface{}
XXX_OneofWrappers is for the internal use of the proto package.
func (*EventsQueryMsg) XXX_Size ¶
func (m *EventsQueryMsg) XXX_Size() int
func (*EventsQueryMsg) XXX_Unmarshal ¶
func (m *EventsQueryMsg) XXX_Unmarshal(b []byte) error
type EventsQueryMsg_Interval ¶
type EventsQueryMsg_Interval struct {
Interval string `protobuf:"bytes,5,opt,name=interval,proto3,oneof" json:"interval,omitempty"`
}
func (*EventsQueryMsg_Interval) MarshalTo ¶
func (m *EventsQueryMsg_Interval) MarshalTo(dAtA []byte) (int, error)
func (*EventsQueryMsg_Interval) MarshalToSizedBuffer ¶
func (m *EventsQueryMsg_Interval) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*EventsQueryMsg_Interval) Size ¶
func (m *EventsQueryMsg_Interval) Size() (n int)
type EventsQueryMsg_Ticks ¶
type EventsQueryMsg_Ticks struct {
Ticks int64 `protobuf:"varint,7,opt,name=ticks,proto3,oneof" json:"ticks,omitempty"`
}
func (*EventsQueryMsg_Ticks) MarshalTo ¶
func (m *EventsQueryMsg_Ticks) MarshalTo(dAtA []byte) (int, error)
func (*EventsQueryMsg_Ticks) MarshalToSizedBuffer ¶
func (m *EventsQueryMsg_Ticks) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*EventsQueryMsg_Ticks) Size ¶
func (m *EventsQueryMsg_Ticks) Size() (n int)
type ExchangeMsg ¶
type ExchangeMsg struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"` DateStart *types.Timestamp `protobuf:"bytes,3,opt,name=date_start,json=dateStart,proto3" json:"date_start,omitempty"` DateEnd *types.Timestamp `protobuf:"bytes,4,opt,name=date_end,json=dateEnd,proto3" json:"date_end,omitempty"` Pairs []*PairMsg `protobuf:"bytes,5,rep,name=pairs,proto3" json:"pairs,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ExchangeMsg) Descriptor ¶
func (*ExchangeMsg) Descriptor() ([]byte, []int)
func (*ExchangeMsg) GetDateEnd ¶
func (m *ExchangeMsg) GetDateEnd() *types.Timestamp
func (*ExchangeMsg) GetDateStart ¶
func (m *ExchangeMsg) GetDateStart() *types.Timestamp
func (*ExchangeMsg) GetId ¶
func (m *ExchangeMsg) GetId() string
func (*ExchangeMsg) GetName ¶
func (m *ExchangeMsg) GetName() string
func (*ExchangeMsg) GetPairs ¶
func (m *ExchangeMsg) GetPairs() []*PairMsg
func (*ExchangeMsg) Marshal ¶
func (m *ExchangeMsg) Marshal() (dAtA []byte, err error)
func (*ExchangeMsg) MarshalToSizedBuffer ¶
func (m *ExchangeMsg) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ExchangeMsg) ProtoMessage ¶
func (*ExchangeMsg) ProtoMessage()
func (*ExchangeMsg) Reset ¶
func (m *ExchangeMsg) Reset()
func (*ExchangeMsg) Size ¶
func (m *ExchangeMsg) Size() (n int)
func (*ExchangeMsg) String ¶
func (m *ExchangeMsg) String() string
func (*ExchangeMsg) Unmarshal ¶
func (m *ExchangeMsg) Unmarshal(dAtA []byte) error
func (*ExchangeMsg) XXX_DiscardUnknown ¶
func (m *ExchangeMsg) XXX_DiscardUnknown()
func (*ExchangeMsg) XXX_Marshal ¶
func (m *ExchangeMsg) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ExchangeMsg) XXX_Merge ¶
func (m *ExchangeMsg) XXX_Merge(src proto.Message)
func (*ExchangeMsg) XXX_Size ¶
func (m *ExchangeMsg) XXX_Size() int
func (*ExchangeMsg) XXX_Unmarshal ¶
func (m *ExchangeMsg) XXX_Unmarshal(b []byte) error
type GetExchangesResponseMsg ¶
type GetExchangesResponseMsg struct { Count uint32 `protobuf:"varint,1,opt,name=count,proto3" json:"count,omitempty"` Exchanges []*ExchangeMsg `protobuf:"bytes,2,rep,name=exchanges,proto3" json:"exchanges,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*GetExchangesResponseMsg) Descriptor ¶
func (*GetExchangesResponseMsg) Descriptor() ([]byte, []int)
func (*GetExchangesResponseMsg) GetCount ¶
func (m *GetExchangesResponseMsg) GetCount() uint32
func (*GetExchangesResponseMsg) GetExchanges ¶
func (m *GetExchangesResponseMsg) GetExchanges() []*ExchangeMsg
func (*GetExchangesResponseMsg) Marshal ¶
func (m *GetExchangesResponseMsg) Marshal() (dAtA []byte, err error)
func (*GetExchangesResponseMsg) MarshalTo ¶
func (m *GetExchangesResponseMsg) MarshalTo(dAtA []byte) (int, error)
func (*GetExchangesResponseMsg) MarshalToSizedBuffer ¶
func (m *GetExchangesResponseMsg) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*GetExchangesResponseMsg) ProtoMessage ¶
func (*GetExchangesResponseMsg) ProtoMessage()
func (*GetExchangesResponseMsg) Reset ¶
func (m *GetExchangesResponseMsg) Reset()
func (*GetExchangesResponseMsg) Size ¶
func (m *GetExchangesResponseMsg) Size() (n int)
func (*GetExchangesResponseMsg) String ¶
func (m *GetExchangesResponseMsg) String() string
func (*GetExchangesResponseMsg) Unmarshal ¶
func (m *GetExchangesResponseMsg) Unmarshal(dAtA []byte) error
func (*GetExchangesResponseMsg) XXX_DiscardUnknown ¶
func (m *GetExchangesResponseMsg) XXX_DiscardUnknown()
func (*GetExchangesResponseMsg) XXX_Marshal ¶
func (m *GetExchangesResponseMsg) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GetExchangesResponseMsg) XXX_Merge ¶
func (m *GetExchangesResponseMsg) XXX_Merge(src proto.Message)
func (*GetExchangesResponseMsg) XXX_Size ¶
func (m *GetExchangesResponseMsg) XXX_Size() int
func (*GetExchangesResponseMsg) XXX_Unmarshal ¶
func (m *GetExchangesResponseMsg) XXX_Unmarshal(b []byte) error
type OrderBooksClient ¶
type OrderBooksClient interface { GetExchanges(ctx context.Context, in *EmptyMsg, opts ...grpc.CallOption) (*GetExchangesResponseMsg, error) QueryEvents(ctx context.Context, in *EventsQueryMsg, opts ...grpc.CallOption) (OrderBooks_QueryEventsClient, error) GetLiveData(ctx context.Context, in *EventsQueryMsg, opts ...grpc.CallOption) (OrderBooks_GetLiveDataClient, error) GetCachedData(ctx context.Context, in *EventsQueryMsg, opts ...grpc.CallOption) (OrderBooks_GetCachedDataClient, error) }
OrderBooksClient is the client API for OrderBooks service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewOrderBooksClient ¶
func NewOrderBooksClient(cc *grpc.ClientConn) OrderBooksClient
type OrderBooksServer ¶
type OrderBooksServer interface { GetExchanges(context.Context, *EmptyMsg) (*GetExchangesResponseMsg, error) QueryEvents(*EventsQueryMsg, OrderBooks_QueryEventsServer) error GetLiveData(*EventsQueryMsg, OrderBooks_GetLiveDataServer) error GetCachedData(*EventsQueryMsg, OrderBooks_GetCachedDataServer) error }
OrderBooksServer is the server API for OrderBooks service.
type OrderBooks_GetCachedDataClient ¶
type OrderBooks_GetCachedDataClient interface { Recv() (*SnapshotMsg, error) grpc.ClientStream }
type OrderBooks_GetCachedDataServer ¶
type OrderBooks_GetCachedDataServer interface { Send(*SnapshotMsg) error grpc.ServerStream }
type OrderBooks_GetLiveDataClient ¶
type OrderBooks_GetLiveDataClient interface { Recv() (*SnapshotMsg, error) grpc.ClientStream }
type OrderBooks_GetLiveDataServer ¶
type OrderBooks_GetLiveDataServer interface { Send(*SnapshotMsg) error grpc.ServerStream }
type OrderBooks_QueryEventsClient ¶
type OrderBooks_QueryEventsClient interface { Recv() (*SnapshotMsg, error) grpc.ClientStream }
type OrderBooks_QueryEventsServer ¶
type OrderBooks_QueryEventsServer interface { Send(*SnapshotMsg) error grpc.ServerStream }
type PairMsg ¶
type PairMsg struct { Base string `protobuf:"bytes,1,opt,name=base,proto3" json:"base,omitempty"` Quote string `protobuf:"bytes,2,opt,name=quote,proto3" json:"quote,omitempty"` DateStart *types.Timestamp `protobuf:"bytes,3,opt,name=date_start,json=dateStart,proto3" json:"date_start,omitempty"` DateEnd *types.Timestamp `protobuf:"bytes,4,opt,name=date_end,json=dateEnd,proto3" json:"date_end,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*PairMsg) Descriptor ¶
func (*PairMsg) GetDateEnd ¶
func (*PairMsg) GetDateStart ¶
func (*PairMsg) MarshalToSizedBuffer ¶
func (*PairMsg) ProtoMessage ¶
func (*PairMsg) ProtoMessage()
func (*PairMsg) XXX_DiscardUnknown ¶
func (m *PairMsg) XXX_DiscardUnknown()
func (*PairMsg) XXX_Marshal ¶
func (*PairMsg) XXX_Unmarshal ¶
type SnapshotMode ¶
type SnapshotMode int32
const ( SnapshotMode_TIME SnapshotMode = 0 SnapshotMode_TICKS SnapshotMode = 1 )
func (SnapshotMode) EnumDescriptor ¶
func (SnapshotMode) EnumDescriptor() ([]byte, []int)
func (SnapshotMode) String ¶
func (x SnapshotMode) String() string
type SnapshotMsg ¶
type SnapshotMsg struct { Timestamp *types.Timestamp `protobuf:"bytes,1,opt,name=timestamp,proto3" json:"timestamp,omitempty"` Exchange string `protobuf:"bytes,2,opt,name=exchange,proto3" json:"exchange,omitempty"` Pair string `protobuf:"bytes,3,opt,name=pair,proto3" json:"pair,omitempty"` Orders []*Event `protobuf:"bytes,4,rep,name=orders,proto3" json:"orders,omitempty"` Events []*Event `protobuf:"bytes,5,rep,name=events,proto3" json:"events,omitempty"` SessionId int64 `protobuf:"varint,6,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"` Counter int64 `protobuf:"varint,7,opt,name=counter,proto3" json:"counter,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*SnapshotMsg) Descriptor ¶
func (*SnapshotMsg) Descriptor() ([]byte, []int)
func (*SnapshotMsg) GetCounter ¶
func (m *SnapshotMsg) GetCounter() int64
func (*SnapshotMsg) GetEvents ¶
func (m *SnapshotMsg) GetEvents() []*Event
func (*SnapshotMsg) GetExchange ¶
func (m *SnapshotMsg) GetExchange() string
func (*SnapshotMsg) GetOrders ¶
func (m *SnapshotMsg) GetOrders() []*Event
func (*SnapshotMsg) GetPair ¶
func (m *SnapshotMsg) GetPair() string
func (*SnapshotMsg) GetSessionId ¶
func (m *SnapshotMsg) GetSessionId() int64
func (*SnapshotMsg) GetTimestamp ¶
func (m *SnapshotMsg) GetTimestamp() *types.Timestamp
func (*SnapshotMsg) Marshal ¶
func (m *SnapshotMsg) Marshal() (dAtA []byte, err error)
func (*SnapshotMsg) MarshalToSizedBuffer ¶
func (m *SnapshotMsg) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*SnapshotMsg) ProtoMessage ¶
func (*SnapshotMsg) ProtoMessage()
func (*SnapshotMsg) Reset ¶
func (m *SnapshotMsg) Reset()
func (*SnapshotMsg) Size ¶
func (m *SnapshotMsg) Size() (n int)
func (*SnapshotMsg) String ¶
func (m *SnapshotMsg) String() string
func (*SnapshotMsg) Unmarshal ¶
func (m *SnapshotMsg) Unmarshal(dAtA []byte) error
func (*SnapshotMsg) XXX_DiscardUnknown ¶
func (m *SnapshotMsg) XXX_DiscardUnknown()
func (*SnapshotMsg) XXX_Marshal ¶
func (m *SnapshotMsg) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*SnapshotMsg) XXX_Merge ¶
func (m *SnapshotMsg) XXX_Merge(src proto.Message)
func (*SnapshotMsg) XXX_Size ¶
func (m *SnapshotMsg) XXX_Size() int
func (*SnapshotMsg) XXX_Unmarshal ¶
func (m *SnapshotMsg) XXX_Unmarshal(b []byte) error
type UnimplementedOrderBooksServer ¶
type UnimplementedOrderBooksServer struct { }
UnimplementedOrderBooksServer can be embedded to have forward compatible implementations.
func (*UnimplementedOrderBooksServer) GetCachedData ¶
func (*UnimplementedOrderBooksServer) GetCachedData(req *EventsQueryMsg, srv OrderBooks_GetCachedDataServer) error
func (*UnimplementedOrderBooksServer) GetExchanges ¶
func (*UnimplementedOrderBooksServer) GetExchanges(ctx context.Context, req *EmptyMsg) (*GetExchangesResponseMsg, error)
func (*UnimplementedOrderBooksServer) GetLiveData ¶
func (*UnimplementedOrderBooksServer) GetLiveData(req *EventsQueryMsg, srv OrderBooks_GetLiveDataServer) error
func (*UnimplementedOrderBooksServer) QueryEvents ¶
func (*UnimplementedOrderBooksServer) QueryEvents(req *EventsQueryMsg, srv OrderBooks_QueryEventsServer) error
Click to show internal directories.
Click to hide internal directories.