orderbooks

package
v0.1.0 Latest Latest
Warning

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

 Go to latest Published: Aug 29, 2021 License: GPL-3.0 Imports: 11 Imported by: 0

Documentation

Index

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) Descriptor() ([]byte, []int)

func (*EmptyMsg) Marshal 

func (m *EmptyMsg) Marshal() (dAtA []byte, err error)

func (*EmptyMsg) MarshalTo 

func (m *EmptyMsg) MarshalTo(dAtA []byte) (int, error)

func (*EmptyMsg) MarshalToSizedBuffer 

func (m *EmptyMsg) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*EmptyMsg) ProtoMessage 

func (*EmptyMsg) ProtoMessage()

func (*EmptyMsg) Reset 

func (m *EmptyMsg) Reset()

func (*EmptyMsg) Size 

func (m *EmptyMsg) Size() (n int)

func (*EmptyMsg) String 

func (m *EmptyMsg) String() string

func (*EmptyMsg) Unmarshal 

func (m *EmptyMsg) Unmarshal(dAtA []byte) error

func (*EmptyMsg) XXX_DiscardUnknown 

func (m *EmptyMsg) XXX_DiscardUnknown()

func (*EmptyMsg) XXX_Marshal 

func (m *EmptyMsg) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*EmptyMsg) XXX_Merge 

func (m *EmptyMsg) XXX_Merge(src proto.Message)

func (*EmptyMsg) XXX_Size 

func (m *EmptyMsg) XXX_Size() int

func (*EmptyMsg) XXX_Unmarshal 

func (m *EmptyMsg) XXX_Unmarshal(b []byte) error

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) Descriptor() ([]byte, []int)

func (*Event) GetAmount 

func (m *Event) GetAmount() float32

func (*Event) GetEventType 

func (m *Event) GetEventType() EventType

func (*Event) GetOrderSide 

func (m *Event) GetOrderSide() OrderSide

func (*Event) GetPrice 

func (m *Event) GetPrice() float32

func (*Event) GetTimestamp 

func (m *Event) GetTimestamp() int64

func (*Event) Marshal 

func (m *Event) Marshal() (dAtA []byte, err error)

func (*Event) MarshalTo 

func (m *Event) MarshalTo(dAtA []byte) (int, error)

func (*Event) MarshalToSizedBuffer 

func (m *Event) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Event) ProtoMessage 

func (*Event) ProtoMessage()

func (*Event) Reset 

func (m *Event) Reset()

func (*Event) Size 

func (m *Event) Size() (n int)

func (*Event) String 

func (m *Event) String() string

func (*Event) Unmarshal 

func (m *Event) Unmarshal(dAtA []byte) error

func (*Event) XXX_DiscardUnknown 

func (m *Event) XXX_DiscardUnknown()

func (*Event) XXX_Marshal 

func (m *Event) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Event) XXX_Merge 

func (m *Event) XXX_Merge(src proto.Message)

func (*Event) XXX_Size 

func (m *Event) XXX_Size() int

func (*Event) XXX_Unmarshal 

func (m *Event) XXX_Unmarshal(b []byte) error

type EventType 

type EventType int32
const (
	EventType_INIT   EventType = 0
	EventType_ADD    EventType = 1
	EventType_CHANGE EventType = 2
	EventType_REMOVE EventType = 3
)

func (EventType) EnumDescriptor 

func (EventType) EnumDescriptor() ([]byte, []int)

func (EventType) String 

func (x EventType) String() string

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) MarshalTo 

func (m *EventsQueryMsg) MarshalTo(dAtA []byte) (int, 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) MarshalTo 

func (m *ExchangeMsg) MarshalTo(dAtA []byte) (int, 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 OrderSide 

type OrderSide int32
const (
	OrderSide_BID OrderSide = 0
	OrderSide_ASK OrderSide = 1
)

func (OrderSide) EnumDescriptor 

func (OrderSide) EnumDescriptor() ([]byte, []int)

func (OrderSide) String 

func (x OrderSide) String() string

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) Descriptor() ([]byte, []int)

func (*PairMsg) GetBase 

func (m *PairMsg) GetBase() string

func (*PairMsg) GetDateEnd 

func (m *PairMsg) GetDateEnd() *types.Timestamp

func (*PairMsg) GetDateStart 

func (m *PairMsg) GetDateStart() *types.Timestamp

func (*PairMsg) GetQuote 

func (m *PairMsg) GetQuote() string

func (*PairMsg) Marshal 

func (m *PairMsg) Marshal() (dAtA []byte, err error)

func (*PairMsg) MarshalTo 

func (m *PairMsg) MarshalTo(dAtA []byte) (int, error)

func (*PairMsg) MarshalToSizedBuffer 

func (m *PairMsg) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*PairMsg) ProtoMessage 

func (*PairMsg) ProtoMessage()

func (*PairMsg) Reset 

func (m *PairMsg) Reset()

func (*PairMsg) Size 

func (m *PairMsg) Size() (n int)

func (*PairMsg) String 

func (m *PairMsg) String() string

func (*PairMsg) Unmarshal 

func (m *PairMsg) Unmarshal(dAtA []byte) error

func (*PairMsg) XXX_DiscardUnknown 

func (m *PairMsg) XXX_DiscardUnknown()

func (*PairMsg) XXX_Marshal 

func (m *PairMsg) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PairMsg) XXX_Merge 

func (m *PairMsg) XXX_Merge(src proto.Message)

func (*PairMsg) XXX_Size 

func (m *PairMsg) XXX_Size() int

func (*PairMsg) XXX_Unmarshal 

func (m *PairMsg) XXX_Unmarshal(b []byte) error

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) MarshalTo 

func (m *SnapshotMsg) MarshalTo(dAtA []byte) (int, 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

Source Files

View all Source files

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.