Files
zeekay 6333d3bdb2 chore: clean up repo structure
- Remove misplaced github.com/luxfi/dex/pkg/grpc/pb directory
- Move nginx config into docker/nginx/
- Consolidate configs/ and node-config/ into config/
- Remove old docker-compose.yml files (use compose.yml)
- Remove oracle/ folder (now native in pkg/price/)
- Remove fake examples/performance_demo.go
2025-12-11 18:00:56 -08:00

2406 lines
68 KiB
Go

// Code generated by protoc-gen-go. DO NOT EDIT.
// versions:
// protoc-gen-go v1.36.7
// protoc v5.29.3
// source: proto/lxdex.proto
package pb
import (
protoreflect "google.golang.org/protobuf/reflect/protoreflect"
protoimpl "google.golang.org/protobuf/runtime/protoimpl"
reflect "reflect"
sync "sync"
unsafe "unsafe"
)
const (
// Verify that this generated code is sufficiently up-to-date.
_ = protoimpl.EnforceVersion(20 - protoimpl.MinVersion)
// Verify that runtime/protoimpl is sufficiently up-to-date.
_ = protoimpl.EnforceVersion(protoimpl.MaxVersion - 20)
)
// Common Types
type OrderType int32
const (
OrderType_LIMIT OrderType = 0
OrderType_MARKET OrderType = 1
OrderType_STOP OrderType = 2
OrderType_STOP_LIMIT OrderType = 3
OrderType_ICEBERG OrderType = 4
OrderType_PEG OrderType = 5
)
// Enum value maps for OrderType.
var (
OrderType_name = map[int32]string{
0: "LIMIT",
1: "MARKET",
2: "STOP",
3: "STOP_LIMIT",
4: "ICEBERG",
5: "PEG",
}
OrderType_value = map[string]int32{
"LIMIT": 0,
"MARKET": 1,
"STOP": 2,
"STOP_LIMIT": 3,
"ICEBERG": 4,
"PEG": 5,
}
)
func (x OrderType) Enum() *OrderType {
p := new(OrderType)
*p = x
return p
}
func (x OrderType) String() string {
return protoimpl.X.EnumStringOf(x.Descriptor(), protoreflect.EnumNumber(x))
}
func (OrderType) Descriptor() protoreflect.EnumDescriptor {
return file_proto_lxdex_proto_enumTypes[0].Descriptor()
}
func (OrderType) Type() protoreflect.EnumType {
return &file_proto_lxdex_proto_enumTypes[0]
}
func (x OrderType) Number() protoreflect.EnumNumber {
return protoreflect.EnumNumber(x)
}
// Deprecated: Use OrderType.Descriptor instead.
func (OrderType) EnumDescriptor() ([]byte, []int) {
return file_proto_lxdex_proto_rawDescGZIP(), []int{0}
}
type OrderSide int32
const (
OrderSide_BUY OrderSide = 0
OrderSide_SELL OrderSide = 1
)
// Enum value maps for OrderSide.
var (
OrderSide_name = map[int32]string{
0: "BUY",
1: "SELL",
}
OrderSide_value = map[string]int32{
"BUY": 0,
"SELL": 1,
}
)
func (x OrderSide) Enum() *OrderSide {
p := new(OrderSide)
*p = x
return p
}
func (x OrderSide) String() string {
return protoimpl.X.EnumStringOf(x.Descriptor(), protoreflect.EnumNumber(x))
}
func (OrderSide) Descriptor() protoreflect.EnumDescriptor {
return file_proto_lxdex_proto_enumTypes[1].Descriptor()
}
func (OrderSide) Type() protoreflect.EnumType {
return &file_proto_lxdex_proto_enumTypes[1]
}
func (x OrderSide) Number() protoreflect.EnumNumber {
return protoreflect.EnumNumber(x)
}
// Deprecated: Use OrderSide.Descriptor instead.
func (OrderSide) EnumDescriptor() ([]byte, []int) {
return file_proto_lxdex_proto_rawDescGZIP(), []int{1}
}
type OrderStatus int32
const (
OrderStatus_OPEN OrderStatus = 0
OrderStatus_PARTIAL OrderStatus = 1
OrderStatus_FILLED OrderStatus = 2
OrderStatus_CANCELLED OrderStatus = 3
OrderStatus_REJECTED OrderStatus = 4
)
// Enum value maps for OrderStatus.
var (
OrderStatus_name = map[int32]string{
0: "OPEN",
1: "PARTIAL",
2: "FILLED",
3: "CANCELLED",
4: "REJECTED",
}
OrderStatus_value = map[string]int32{
"OPEN": 0,
"PARTIAL": 1,
"FILLED": 2,
"CANCELLED": 3,
"REJECTED": 4,
}
)
func (x OrderStatus) Enum() *OrderStatus {
p := new(OrderStatus)
*p = x
return p
}
func (x OrderStatus) String() string {
return protoimpl.X.EnumStringOf(x.Descriptor(), protoreflect.EnumNumber(x))
}
func (OrderStatus) Descriptor() protoreflect.EnumDescriptor {
return file_proto_lxdex_proto_enumTypes[2].Descriptor()
}
func (OrderStatus) Type() protoreflect.EnumType {
return &file_proto_lxdex_proto_enumTypes[2]
}
func (x OrderStatus) Number() protoreflect.EnumNumber {
return protoreflect.EnumNumber(x)
}
// Deprecated: Use OrderStatus.Descriptor instead.
func (OrderStatus) EnumDescriptor() ([]byte, []int) {
return file_proto_lxdex_proto_rawDescGZIP(), []int{2}
}
type TimeInForce int32
const (
TimeInForce_GTC TimeInForce = 0 // Good Till Cancelled
TimeInForce_IOC TimeInForce = 1 // Immediate Or Cancel
TimeInForce_FOK TimeInForce = 2 // Fill Or Kill
TimeInForce_DAY TimeInForce = 3 // Day Order
)
// Enum value maps for TimeInForce.
var (
TimeInForce_name = map[int32]string{
0: "GTC",
1: "IOC",
2: "FOK",
3: "DAY",
}
TimeInForce_value = map[string]int32{
"GTC": 0,
"IOC": 1,
"FOK": 2,
"DAY": 3,
}
)
func (x TimeInForce) Enum() *TimeInForce {
p := new(TimeInForce)
*p = x
return p
}
func (x TimeInForce) String() string {
return protoimpl.X.EnumStringOf(x.Descriptor(), protoreflect.EnumNumber(x))
}
func (TimeInForce) Descriptor() protoreflect.EnumDescriptor {
return file_proto_lxdex_proto_enumTypes[3].Descriptor()
}
func (TimeInForce) Type() protoreflect.EnumType {
return &file_proto_lxdex_proto_enumTypes[3]
}
func (x TimeInForce) Number() protoreflect.EnumNumber {
return protoreflect.EnumNumber(x)
}
// Deprecated: Use TimeInForce.Descriptor instead.
func (TimeInForce) EnumDescriptor() ([]byte, []int) {
return file_proto_lxdex_proto_rawDescGZIP(), []int{3}
}
// Messages
type Order struct {
state protoimpl.MessageState `protogen:"open.v1"`
OrderId uint64 `protobuf:"varint,1,opt,name=order_id,json=orderId,proto3" json:"order_id,omitempty"`
Symbol string `protobuf:"bytes,2,opt,name=symbol,proto3" json:"symbol,omitempty"`
Type OrderType `protobuf:"varint,3,opt,name=type,proto3,enum=lxdex.OrderType" json:"type,omitempty"`
Side OrderSide `protobuf:"varint,4,opt,name=side,proto3,enum=lxdex.OrderSide" json:"side,omitempty"`
Price float64 `protobuf:"fixed64,5,opt,name=price,proto3" json:"price,omitempty"`
Size float64 `protobuf:"fixed64,6,opt,name=size,proto3" json:"size,omitempty"`
Filled float64 `protobuf:"fixed64,7,opt,name=filled,proto3" json:"filled,omitempty"`
Remaining float64 `protobuf:"fixed64,8,opt,name=remaining,proto3" json:"remaining,omitempty"`
Status OrderStatus `protobuf:"varint,9,opt,name=status,proto3,enum=lxdex.OrderStatus" json:"status,omitempty"`
UserId string `protobuf:"bytes,10,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"`
ClientId string `protobuf:"bytes,11,opt,name=client_id,json=clientId,proto3" json:"client_id,omitempty"`
Timestamp int64 `protobuf:"varint,12,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
TimeInForce TimeInForce `protobuf:"varint,13,opt,name=time_in_force,json=timeInForce,proto3,enum=lxdex.TimeInForce" json:"time_in_force,omitempty"`
PostOnly bool `protobuf:"varint,14,opt,name=post_only,json=postOnly,proto3" json:"post_only,omitempty"`
ReduceOnly bool `protobuf:"varint,15,opt,name=reduce_only,json=reduceOnly,proto3" json:"reduce_only,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *Order) Reset() {
*x = Order{}
mi := &file_proto_lxdex_proto_msgTypes[0]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *Order) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*Order) ProtoMessage() {}
func (x *Order) ProtoReflect() protoreflect.Message {
mi := &file_proto_lxdex_proto_msgTypes[0]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use Order.ProtoReflect.Descriptor instead.
func (*Order) Descriptor() ([]byte, []int) {
return file_proto_lxdex_proto_rawDescGZIP(), []int{0}
}
func (x *Order) GetOrderId() uint64 {
if x != nil {
return x.OrderId
}
return 0
}
func (x *Order) GetSymbol() string {
if x != nil {
return x.Symbol
}
return ""
}
func (x *Order) GetType() OrderType {
if x != nil {
return x.Type
}
return OrderType_LIMIT
}
func (x *Order) GetSide() OrderSide {
if x != nil {
return x.Side
}
return OrderSide_BUY
}
func (x *Order) GetPrice() float64 {
if x != nil {
return x.Price
}
return 0
}
func (x *Order) GetSize() float64 {
if x != nil {
return x.Size
}
return 0
}
func (x *Order) GetFilled() float64 {
if x != nil {
return x.Filled
}
return 0
}
func (x *Order) GetRemaining() float64 {
if x != nil {
return x.Remaining
}
return 0
}
func (x *Order) GetStatus() OrderStatus {
if x != nil {
return x.Status
}
return OrderStatus_OPEN
}
func (x *Order) GetUserId() string {
if x != nil {
return x.UserId
}
return ""
}
func (x *Order) GetClientId() string {
if x != nil {
return x.ClientId
}
return ""
}
func (x *Order) GetTimestamp() int64 {
if x != nil {
return x.Timestamp
}
return 0
}
func (x *Order) GetTimeInForce() TimeInForce {
if x != nil {
return x.TimeInForce
}
return TimeInForce_GTC
}
func (x *Order) GetPostOnly() bool {
if x != nil {
return x.PostOnly
}
return false
}
func (x *Order) GetReduceOnly() bool {
if x != nil {
return x.ReduceOnly
}
return false
}
type PlaceOrderRequest struct {
state protoimpl.MessageState `protogen:"open.v1"`
Symbol string `protobuf:"bytes,1,opt,name=symbol,proto3" json:"symbol,omitempty"`
Type OrderType `protobuf:"varint,2,opt,name=type,proto3,enum=lxdex.OrderType" json:"type,omitempty"`
Side OrderSide `protobuf:"varint,3,opt,name=side,proto3,enum=lxdex.OrderSide" json:"side,omitempty"`
Price float64 `protobuf:"fixed64,4,opt,name=price,proto3" json:"price,omitempty"`
Size float64 `protobuf:"fixed64,5,opt,name=size,proto3" json:"size,omitempty"`
UserId string `protobuf:"bytes,6,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"`
ClientId string `protobuf:"bytes,7,opt,name=client_id,json=clientId,proto3" json:"client_id,omitempty"`
TimeInForce TimeInForce `protobuf:"varint,8,opt,name=time_in_force,json=timeInForce,proto3,enum=lxdex.TimeInForce" json:"time_in_force,omitempty"`
PostOnly bool `protobuf:"varint,9,opt,name=post_only,json=postOnly,proto3" json:"post_only,omitempty"`
ReduceOnly bool `protobuf:"varint,10,opt,name=reduce_only,json=reduceOnly,proto3" json:"reduce_only,omitempty"`
StopPrice float64 `protobuf:"fixed64,11,opt,name=stop_price,json=stopPrice,proto3" json:"stop_price,omitempty"`
LimitPrice float64 `protobuf:"fixed64,12,opt,name=limit_price,json=limitPrice,proto3" json:"limit_price,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *PlaceOrderRequest) Reset() {
*x = PlaceOrderRequest{}
mi := &file_proto_lxdex_proto_msgTypes[1]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *PlaceOrderRequest) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*PlaceOrderRequest) ProtoMessage() {}
func (x *PlaceOrderRequest) ProtoReflect() protoreflect.Message {
mi := &file_proto_lxdex_proto_msgTypes[1]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use PlaceOrderRequest.ProtoReflect.Descriptor instead.
func (*PlaceOrderRequest) Descriptor() ([]byte, []int) {
return file_proto_lxdex_proto_rawDescGZIP(), []int{1}
}
func (x *PlaceOrderRequest) GetSymbol() string {
if x != nil {
return x.Symbol
}
return ""
}
func (x *PlaceOrderRequest) GetType() OrderType {
if x != nil {
return x.Type
}
return OrderType_LIMIT
}
func (x *PlaceOrderRequest) GetSide() OrderSide {
if x != nil {
return x.Side
}
return OrderSide_BUY
}
func (x *PlaceOrderRequest) GetPrice() float64 {
if x != nil {
return x.Price
}
return 0
}
func (x *PlaceOrderRequest) GetSize() float64 {
if x != nil {
return x.Size
}
return 0
}
func (x *PlaceOrderRequest) GetUserId() string {
if x != nil {
return x.UserId
}
return ""
}
func (x *PlaceOrderRequest) GetClientId() string {
if x != nil {
return x.ClientId
}
return ""
}
func (x *PlaceOrderRequest) GetTimeInForce() TimeInForce {
if x != nil {
return x.TimeInForce
}
return TimeInForce_GTC
}
func (x *PlaceOrderRequest) GetPostOnly() bool {
if x != nil {
return x.PostOnly
}
return false
}
func (x *PlaceOrderRequest) GetReduceOnly() bool {
if x != nil {
return x.ReduceOnly
}
return false
}
func (x *PlaceOrderRequest) GetStopPrice() float64 {
if x != nil {
return x.StopPrice
}
return 0
}
func (x *PlaceOrderRequest) GetLimitPrice() float64 {
if x != nil {
return x.LimitPrice
}
return 0
}
type PlaceOrderResponse struct {
state protoimpl.MessageState `protogen:"open.v1"`
OrderId uint64 `protobuf:"varint,1,opt,name=order_id,json=orderId,proto3" json:"order_id,omitempty"`
Status OrderStatus `protobuf:"varint,2,opt,name=status,proto3,enum=lxdex.OrderStatus" json:"status,omitempty"`
Message string `protobuf:"bytes,3,opt,name=message,proto3" json:"message,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *PlaceOrderResponse) Reset() {
*x = PlaceOrderResponse{}
mi := &file_proto_lxdex_proto_msgTypes[2]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *PlaceOrderResponse) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*PlaceOrderResponse) ProtoMessage() {}
func (x *PlaceOrderResponse) ProtoReflect() protoreflect.Message {
mi := &file_proto_lxdex_proto_msgTypes[2]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use PlaceOrderResponse.ProtoReflect.Descriptor instead.
func (*PlaceOrderResponse) Descriptor() ([]byte, []int) {
return file_proto_lxdex_proto_rawDescGZIP(), []int{2}
}
func (x *PlaceOrderResponse) GetOrderId() uint64 {
if x != nil {
return x.OrderId
}
return 0
}
func (x *PlaceOrderResponse) GetStatus() OrderStatus {
if x != nil {
return x.Status
}
return OrderStatus_OPEN
}
func (x *PlaceOrderResponse) GetMessage() string {
if x != nil {
return x.Message
}
return ""
}
type CancelOrderRequest struct {
state protoimpl.MessageState `protogen:"open.v1"`
OrderId uint64 `protobuf:"varint,1,opt,name=order_id,json=orderId,proto3" json:"order_id,omitempty"`
UserId string `protobuf:"bytes,2,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *CancelOrderRequest) Reset() {
*x = CancelOrderRequest{}
mi := &file_proto_lxdex_proto_msgTypes[3]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *CancelOrderRequest) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*CancelOrderRequest) ProtoMessage() {}
func (x *CancelOrderRequest) ProtoReflect() protoreflect.Message {
mi := &file_proto_lxdex_proto_msgTypes[3]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use CancelOrderRequest.ProtoReflect.Descriptor instead.
func (*CancelOrderRequest) Descriptor() ([]byte, []int) {
return file_proto_lxdex_proto_rawDescGZIP(), []int{3}
}
func (x *CancelOrderRequest) GetOrderId() uint64 {
if x != nil {
return x.OrderId
}
return 0
}
func (x *CancelOrderRequest) GetUserId() string {
if x != nil {
return x.UserId
}
return ""
}
type CancelOrderResponse struct {
state protoimpl.MessageState `protogen:"open.v1"`
Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *CancelOrderResponse) Reset() {
*x = CancelOrderResponse{}
mi := &file_proto_lxdex_proto_msgTypes[4]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *CancelOrderResponse) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*CancelOrderResponse) ProtoMessage() {}
func (x *CancelOrderResponse) ProtoReflect() protoreflect.Message {
mi := &file_proto_lxdex_proto_msgTypes[4]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use CancelOrderResponse.ProtoReflect.Descriptor instead.
func (*CancelOrderResponse) Descriptor() ([]byte, []int) {
return file_proto_lxdex_proto_rawDescGZIP(), []int{4}
}
func (x *CancelOrderResponse) GetSuccess() bool {
if x != nil {
return x.Success
}
return false
}
func (x *CancelOrderResponse) GetMessage() string {
if x != nil {
return x.Message
}
return ""
}
type GetOrderRequest struct {
state protoimpl.MessageState `protogen:"open.v1"`
OrderId uint64 `protobuf:"varint,1,opt,name=order_id,json=orderId,proto3" json:"order_id,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *GetOrderRequest) Reset() {
*x = GetOrderRequest{}
mi := &file_proto_lxdex_proto_msgTypes[5]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *GetOrderRequest) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*GetOrderRequest) ProtoMessage() {}
func (x *GetOrderRequest) ProtoReflect() protoreflect.Message {
mi := &file_proto_lxdex_proto_msgTypes[5]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use GetOrderRequest.ProtoReflect.Descriptor instead.
func (*GetOrderRequest) Descriptor() ([]byte, []int) {
return file_proto_lxdex_proto_rawDescGZIP(), []int{5}
}
func (x *GetOrderRequest) GetOrderId() uint64 {
if x != nil {
return x.OrderId
}
return 0
}
type GetOrdersRequest struct {
state protoimpl.MessageState `protogen:"open.v1"`
UserId string `protobuf:"bytes,1,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"`
Symbol string `protobuf:"bytes,2,opt,name=symbol,proto3" json:"symbol,omitempty"`
Status OrderStatus `protobuf:"varint,3,opt,name=status,proto3,enum=lxdex.OrderStatus" json:"status,omitempty"`
Limit int32 `protobuf:"varint,4,opt,name=limit,proto3" json:"limit,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *GetOrdersRequest) Reset() {
*x = GetOrdersRequest{}
mi := &file_proto_lxdex_proto_msgTypes[6]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *GetOrdersRequest) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*GetOrdersRequest) ProtoMessage() {}
func (x *GetOrdersRequest) ProtoReflect() protoreflect.Message {
mi := &file_proto_lxdex_proto_msgTypes[6]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use GetOrdersRequest.ProtoReflect.Descriptor instead.
func (*GetOrdersRequest) Descriptor() ([]byte, []int) {
return file_proto_lxdex_proto_rawDescGZIP(), []int{6}
}
func (x *GetOrdersRequest) GetUserId() string {
if x != nil {
return x.UserId
}
return ""
}
func (x *GetOrdersRequest) GetSymbol() string {
if x != nil {
return x.Symbol
}
return ""
}
func (x *GetOrdersRequest) GetStatus() OrderStatus {
if x != nil {
return x.Status
}
return OrderStatus_OPEN
}
func (x *GetOrdersRequest) GetLimit() int32 {
if x != nil {
return x.Limit
}
return 0
}
type GetOrdersResponse struct {
state protoimpl.MessageState `protogen:"open.v1"`
Orders []*Order `protobuf:"bytes,1,rep,name=orders,proto3" json:"orders,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *GetOrdersResponse) Reset() {
*x = GetOrdersResponse{}
mi := &file_proto_lxdex_proto_msgTypes[7]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *GetOrdersResponse) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*GetOrdersResponse) ProtoMessage() {}
func (x *GetOrdersResponse) ProtoReflect() protoreflect.Message {
mi := &file_proto_lxdex_proto_msgTypes[7]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use GetOrdersResponse.ProtoReflect.Descriptor instead.
func (*GetOrdersResponse) Descriptor() ([]byte, []int) {
return file_proto_lxdex_proto_rawDescGZIP(), []int{7}
}
func (x *GetOrdersResponse) GetOrders() []*Order {
if x != nil {
return x.Orders
}
return nil
}
type OrderBook struct {
state protoimpl.MessageState `protogen:"open.v1"`
Symbol string `protobuf:"bytes,1,opt,name=symbol,proto3" json:"symbol,omitempty"`
Bids []*PriceLevel `protobuf:"bytes,2,rep,name=bids,proto3" json:"bids,omitempty"`
Asks []*PriceLevel `protobuf:"bytes,3,rep,name=asks,proto3" json:"asks,omitempty"`
Timestamp int64 `protobuf:"varint,4,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *OrderBook) Reset() {
*x = OrderBook{}
mi := &file_proto_lxdex_proto_msgTypes[8]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *OrderBook) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*OrderBook) ProtoMessage() {}
func (x *OrderBook) ProtoReflect() protoreflect.Message {
mi := &file_proto_lxdex_proto_msgTypes[8]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use OrderBook.ProtoReflect.Descriptor instead.
func (*OrderBook) Descriptor() ([]byte, []int) {
return file_proto_lxdex_proto_rawDescGZIP(), []int{8}
}
func (x *OrderBook) GetSymbol() string {
if x != nil {
return x.Symbol
}
return ""
}
func (x *OrderBook) GetBids() []*PriceLevel {
if x != nil {
return x.Bids
}
return nil
}
func (x *OrderBook) GetAsks() []*PriceLevel {
if x != nil {
return x.Asks
}
return nil
}
func (x *OrderBook) GetTimestamp() int64 {
if x != nil {
return x.Timestamp
}
return 0
}
type PriceLevel struct {
state protoimpl.MessageState `protogen:"open.v1"`
Price float64 `protobuf:"fixed64,1,opt,name=price,proto3" json:"price,omitempty"`
Size float64 `protobuf:"fixed64,2,opt,name=size,proto3" json:"size,omitempty"`
Count int32 `protobuf:"varint,3,opt,name=count,proto3" json:"count,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *PriceLevel) Reset() {
*x = PriceLevel{}
mi := &file_proto_lxdex_proto_msgTypes[9]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *PriceLevel) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*PriceLevel) ProtoMessage() {}
func (x *PriceLevel) ProtoReflect() protoreflect.Message {
mi := &file_proto_lxdex_proto_msgTypes[9]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use PriceLevel.ProtoReflect.Descriptor instead.
func (*PriceLevel) Descriptor() ([]byte, []int) {
return file_proto_lxdex_proto_rawDescGZIP(), []int{9}
}
func (x *PriceLevel) GetPrice() float64 {
if x != nil {
return x.Price
}
return 0
}
func (x *PriceLevel) GetSize() float64 {
if x != nil {
return x.Size
}
return 0
}
func (x *PriceLevel) GetCount() int32 {
if x != nil {
return x.Count
}
return 0
}
type OrderBookUpdate struct {
state protoimpl.MessageState `protogen:"open.v1"`
Symbol string `protobuf:"bytes,1,opt,name=symbol,proto3" json:"symbol,omitempty"`
BidUpdates []*PriceLevel `protobuf:"bytes,2,rep,name=bid_updates,json=bidUpdates,proto3" json:"bid_updates,omitempty"`
AskUpdates []*PriceLevel `protobuf:"bytes,3,rep,name=ask_updates,json=askUpdates,proto3" json:"ask_updates,omitempty"`
Timestamp int64 `protobuf:"varint,4,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *OrderBookUpdate) Reset() {
*x = OrderBookUpdate{}
mi := &file_proto_lxdex_proto_msgTypes[10]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *OrderBookUpdate) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*OrderBookUpdate) ProtoMessage() {}
func (x *OrderBookUpdate) ProtoReflect() protoreflect.Message {
mi := &file_proto_lxdex_proto_msgTypes[10]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use OrderBookUpdate.ProtoReflect.Descriptor instead.
func (*OrderBookUpdate) Descriptor() ([]byte, []int) {
return file_proto_lxdex_proto_rawDescGZIP(), []int{10}
}
func (x *OrderBookUpdate) GetSymbol() string {
if x != nil {
return x.Symbol
}
return ""
}
func (x *OrderBookUpdate) GetBidUpdates() []*PriceLevel {
if x != nil {
return x.BidUpdates
}
return nil
}
func (x *OrderBookUpdate) GetAskUpdates() []*PriceLevel {
if x != nil {
return x.AskUpdates
}
return nil
}
func (x *OrderBookUpdate) GetTimestamp() int64 {
if x != nil {
return x.Timestamp
}
return 0
}
type GetOrderBookRequest struct {
state protoimpl.MessageState `protogen:"open.v1"`
Symbol string `protobuf:"bytes,1,opt,name=symbol,proto3" json:"symbol,omitempty"`
Depth int32 `protobuf:"varint,2,opt,name=depth,proto3" json:"depth,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *GetOrderBookRequest) Reset() {
*x = GetOrderBookRequest{}
mi := &file_proto_lxdex_proto_msgTypes[11]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *GetOrderBookRequest) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*GetOrderBookRequest) ProtoMessage() {}
func (x *GetOrderBookRequest) ProtoReflect() protoreflect.Message {
mi := &file_proto_lxdex_proto_msgTypes[11]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use GetOrderBookRequest.ProtoReflect.Descriptor instead.
func (*GetOrderBookRequest) Descriptor() ([]byte, []int) {
return file_proto_lxdex_proto_rawDescGZIP(), []int{11}
}
func (x *GetOrderBookRequest) GetSymbol() string {
if x != nil {
return x.Symbol
}
return ""
}
func (x *GetOrderBookRequest) GetDepth() int32 {
if x != nil {
return x.Depth
}
return 0
}
type StreamOrderBookRequest struct {
state protoimpl.MessageState `protogen:"open.v1"`
Symbol string `protobuf:"bytes,1,opt,name=symbol,proto3" json:"symbol,omitempty"`
Depth int32 `protobuf:"varint,2,opt,name=depth,proto3" json:"depth,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *StreamOrderBookRequest) Reset() {
*x = StreamOrderBookRequest{}
mi := &file_proto_lxdex_proto_msgTypes[12]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *StreamOrderBookRequest) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*StreamOrderBookRequest) ProtoMessage() {}
func (x *StreamOrderBookRequest) ProtoReflect() protoreflect.Message {
mi := &file_proto_lxdex_proto_msgTypes[12]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use StreamOrderBookRequest.ProtoReflect.Descriptor instead.
func (*StreamOrderBookRequest) Descriptor() ([]byte, []int) {
return file_proto_lxdex_proto_rawDescGZIP(), []int{12}
}
func (x *StreamOrderBookRequest) GetSymbol() string {
if x != nil {
return x.Symbol
}
return ""
}
func (x *StreamOrderBookRequest) GetDepth() int32 {
if x != nil {
return x.Depth
}
return 0
}
type Trade struct {
state protoimpl.MessageState `protogen:"open.v1"`
TradeId uint64 `protobuf:"varint,1,opt,name=trade_id,json=tradeId,proto3" json:"trade_id,omitempty"`
Symbol string `protobuf:"bytes,2,opt,name=symbol,proto3" json:"symbol,omitempty"`
Price float64 `protobuf:"fixed64,3,opt,name=price,proto3" json:"price,omitempty"`
Size float64 `protobuf:"fixed64,4,opt,name=size,proto3" json:"size,omitempty"`
Side OrderSide `protobuf:"varint,5,opt,name=side,proto3,enum=lxdex.OrderSide" json:"side,omitempty"`
BuyOrderId uint64 `protobuf:"varint,6,opt,name=buy_order_id,json=buyOrderId,proto3" json:"buy_order_id,omitempty"`
SellOrderId uint64 `protobuf:"varint,7,opt,name=sell_order_id,json=sellOrderId,proto3" json:"sell_order_id,omitempty"`
BuyerId string `protobuf:"bytes,8,opt,name=buyer_id,json=buyerId,proto3" json:"buyer_id,omitempty"`
SellerId string `protobuf:"bytes,9,opt,name=seller_id,json=sellerId,proto3" json:"seller_id,omitempty"`
Timestamp int64 `protobuf:"varint,10,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *Trade) Reset() {
*x = Trade{}
mi := &file_proto_lxdex_proto_msgTypes[13]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *Trade) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*Trade) ProtoMessage() {}
func (x *Trade) ProtoReflect() protoreflect.Message {
mi := &file_proto_lxdex_proto_msgTypes[13]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use Trade.ProtoReflect.Descriptor instead.
func (*Trade) Descriptor() ([]byte, []int) {
return file_proto_lxdex_proto_rawDescGZIP(), []int{13}
}
func (x *Trade) GetTradeId() uint64 {
if x != nil {
return x.TradeId
}
return 0
}
func (x *Trade) GetSymbol() string {
if x != nil {
return x.Symbol
}
return ""
}
func (x *Trade) GetPrice() float64 {
if x != nil {
return x.Price
}
return 0
}
func (x *Trade) GetSize() float64 {
if x != nil {
return x.Size
}
return 0
}
func (x *Trade) GetSide() OrderSide {
if x != nil {
return x.Side
}
return OrderSide_BUY
}
func (x *Trade) GetBuyOrderId() uint64 {
if x != nil {
return x.BuyOrderId
}
return 0
}
func (x *Trade) GetSellOrderId() uint64 {
if x != nil {
return x.SellOrderId
}
return 0
}
func (x *Trade) GetBuyerId() string {
if x != nil {
return x.BuyerId
}
return ""
}
func (x *Trade) GetSellerId() string {
if x != nil {
return x.SellerId
}
return ""
}
func (x *Trade) GetTimestamp() int64 {
if x != nil {
return x.Timestamp
}
return 0
}
type GetTradesRequest struct {
state protoimpl.MessageState `protogen:"open.v1"`
Symbol string `protobuf:"bytes,1,opt,name=symbol,proto3" json:"symbol,omitempty"`
Limit int32 `protobuf:"varint,2,opt,name=limit,proto3" json:"limit,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *GetTradesRequest) Reset() {
*x = GetTradesRequest{}
mi := &file_proto_lxdex_proto_msgTypes[14]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *GetTradesRequest) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*GetTradesRequest) ProtoMessage() {}
func (x *GetTradesRequest) ProtoReflect() protoreflect.Message {
mi := &file_proto_lxdex_proto_msgTypes[14]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use GetTradesRequest.ProtoReflect.Descriptor instead.
func (*GetTradesRequest) Descriptor() ([]byte, []int) {
return file_proto_lxdex_proto_rawDescGZIP(), []int{14}
}
func (x *GetTradesRequest) GetSymbol() string {
if x != nil {
return x.Symbol
}
return ""
}
func (x *GetTradesRequest) GetLimit() int32 {
if x != nil {
return x.Limit
}
return 0
}
type GetTradesResponse struct {
state protoimpl.MessageState `protogen:"open.v1"`
Trades []*Trade `protobuf:"bytes,1,rep,name=trades,proto3" json:"trades,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *GetTradesResponse) Reset() {
*x = GetTradesResponse{}
mi := &file_proto_lxdex_proto_msgTypes[15]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *GetTradesResponse) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*GetTradesResponse) ProtoMessage() {}
func (x *GetTradesResponse) ProtoReflect() protoreflect.Message {
mi := &file_proto_lxdex_proto_msgTypes[15]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use GetTradesResponse.ProtoReflect.Descriptor instead.
func (*GetTradesResponse) Descriptor() ([]byte, []int) {
return file_proto_lxdex_proto_rawDescGZIP(), []int{15}
}
func (x *GetTradesResponse) GetTrades() []*Trade {
if x != nil {
return x.Trades
}
return nil
}
type StreamTradesRequest struct {
state protoimpl.MessageState `protogen:"open.v1"`
Symbol string `protobuf:"bytes,1,opt,name=symbol,proto3" json:"symbol,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *StreamTradesRequest) Reset() {
*x = StreamTradesRequest{}
mi := &file_proto_lxdex_proto_msgTypes[16]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *StreamTradesRequest) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*StreamTradesRequest) ProtoMessage() {}
func (x *StreamTradesRequest) ProtoReflect() protoreflect.Message {
mi := &file_proto_lxdex_proto_msgTypes[16]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use StreamTradesRequest.ProtoReflect.Descriptor instead.
func (*StreamTradesRequest) Descriptor() ([]byte, []int) {
return file_proto_lxdex_proto_rawDescGZIP(), []int{16}
}
func (x *StreamTradesRequest) GetSymbol() string {
if x != nil {
return x.Symbol
}
return ""
}
type Balance struct {
state protoimpl.MessageState `protogen:"open.v1"`
Asset string `protobuf:"bytes,1,opt,name=asset,proto3" json:"asset,omitempty"`
Available float64 `protobuf:"fixed64,2,opt,name=available,proto3" json:"available,omitempty"`
Locked float64 `protobuf:"fixed64,3,opt,name=locked,proto3" json:"locked,omitempty"`
Total float64 `protobuf:"fixed64,4,opt,name=total,proto3" json:"total,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *Balance) Reset() {
*x = Balance{}
mi := &file_proto_lxdex_proto_msgTypes[17]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *Balance) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*Balance) ProtoMessage() {}
func (x *Balance) ProtoReflect() protoreflect.Message {
mi := &file_proto_lxdex_proto_msgTypes[17]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use Balance.ProtoReflect.Descriptor instead.
func (*Balance) Descriptor() ([]byte, []int) {
return file_proto_lxdex_proto_rawDescGZIP(), []int{17}
}
func (x *Balance) GetAsset() string {
if x != nil {
return x.Asset
}
return ""
}
func (x *Balance) GetAvailable() float64 {
if x != nil {
return x.Available
}
return 0
}
func (x *Balance) GetLocked() float64 {
if x != nil {
return x.Locked
}
return 0
}
func (x *Balance) GetTotal() float64 {
if x != nil {
return x.Total
}
return 0
}
type GetBalanceRequest struct {
state protoimpl.MessageState `protogen:"open.v1"`
UserId string `protobuf:"bytes,1,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"`
Asset string `protobuf:"bytes,2,opt,name=asset,proto3" json:"asset,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *GetBalanceRequest) Reset() {
*x = GetBalanceRequest{}
mi := &file_proto_lxdex_proto_msgTypes[18]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *GetBalanceRequest) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*GetBalanceRequest) ProtoMessage() {}
func (x *GetBalanceRequest) ProtoReflect() protoreflect.Message {
mi := &file_proto_lxdex_proto_msgTypes[18]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use GetBalanceRequest.ProtoReflect.Descriptor instead.
func (*GetBalanceRequest) Descriptor() ([]byte, []int) {
return file_proto_lxdex_proto_rawDescGZIP(), []int{18}
}
func (x *GetBalanceRequest) GetUserId() string {
if x != nil {
return x.UserId
}
return ""
}
func (x *GetBalanceRequest) GetAsset() string {
if x != nil {
return x.Asset
}
return ""
}
type Position struct {
state protoimpl.MessageState `protogen:"open.v1"`
Symbol string `protobuf:"bytes,1,opt,name=symbol,proto3" json:"symbol,omitempty"`
Size float64 `protobuf:"fixed64,2,opt,name=size,proto3" json:"size,omitempty"`
EntryPrice float64 `protobuf:"fixed64,3,opt,name=entry_price,json=entryPrice,proto3" json:"entry_price,omitempty"`
MarkPrice float64 `protobuf:"fixed64,4,opt,name=mark_price,json=markPrice,proto3" json:"mark_price,omitempty"`
Pnl float64 `protobuf:"fixed64,5,opt,name=pnl,proto3" json:"pnl,omitempty"`
Margin float64 `protobuf:"fixed64,6,opt,name=margin,proto3" json:"margin,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *Position) Reset() {
*x = Position{}
mi := &file_proto_lxdex_proto_msgTypes[19]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *Position) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*Position) ProtoMessage() {}
func (x *Position) ProtoReflect() protoreflect.Message {
mi := &file_proto_lxdex_proto_msgTypes[19]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use Position.ProtoReflect.Descriptor instead.
func (*Position) Descriptor() ([]byte, []int) {
return file_proto_lxdex_proto_rawDescGZIP(), []int{19}
}
func (x *Position) GetSymbol() string {
if x != nil {
return x.Symbol
}
return ""
}
func (x *Position) GetSize() float64 {
if x != nil {
return x.Size
}
return 0
}
func (x *Position) GetEntryPrice() float64 {
if x != nil {
return x.EntryPrice
}
return 0
}
func (x *Position) GetMarkPrice() float64 {
if x != nil {
return x.MarkPrice
}
return 0
}
func (x *Position) GetPnl() float64 {
if x != nil {
return x.Pnl
}
return 0
}
func (x *Position) GetMargin() float64 {
if x != nil {
return x.Margin
}
return 0
}
type GetPositionsRequest struct {
state protoimpl.MessageState `protogen:"open.v1"`
UserId string `protobuf:"bytes,1,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *GetPositionsRequest) Reset() {
*x = GetPositionsRequest{}
mi := &file_proto_lxdex_proto_msgTypes[20]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *GetPositionsRequest) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*GetPositionsRequest) ProtoMessage() {}
func (x *GetPositionsRequest) ProtoReflect() protoreflect.Message {
mi := &file_proto_lxdex_proto_msgTypes[20]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use GetPositionsRequest.ProtoReflect.Descriptor instead.
func (*GetPositionsRequest) Descriptor() ([]byte, []int) {
return file_proto_lxdex_proto_rawDescGZIP(), []int{20}
}
func (x *GetPositionsRequest) GetUserId() string {
if x != nil {
return x.UserId
}
return ""
}
type GetPositionsResponse struct {
state protoimpl.MessageState `protogen:"open.v1"`
Positions []*Position `protobuf:"bytes,1,rep,name=positions,proto3" json:"positions,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *GetPositionsResponse) Reset() {
*x = GetPositionsResponse{}
mi := &file_proto_lxdex_proto_msgTypes[21]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *GetPositionsResponse) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*GetPositionsResponse) ProtoMessage() {}
func (x *GetPositionsResponse) ProtoReflect() protoreflect.Message {
mi := &file_proto_lxdex_proto_msgTypes[21]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use GetPositionsResponse.ProtoReflect.Descriptor instead.
func (*GetPositionsResponse) Descriptor() ([]byte, []int) {
return file_proto_lxdex_proto_rawDescGZIP(), []int{21}
}
func (x *GetPositionsResponse) GetPositions() []*Position {
if x != nil {
return x.Positions
}
return nil
}
type NodeInfo struct {
state protoimpl.MessageState `protogen:"open.v1"`
NodeId string `protobuf:"bytes,1,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
Version string `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"`
Network string `protobuf:"bytes,3,opt,name=network,proto3" json:"network,omitempty"`
BlockHeight uint64 `protobuf:"varint,4,opt,name=block_height,json=blockHeight,proto3" json:"block_height,omitempty"`
OrderCount uint64 `protobuf:"varint,5,opt,name=order_count,json=orderCount,proto3" json:"order_count,omitempty"`
TradeCount uint64 `protobuf:"varint,6,opt,name=trade_count,json=tradeCount,proto3" json:"trade_count,omitempty"`
Uptime int64 `protobuf:"varint,7,opt,name=uptime,proto3" json:"uptime,omitempty"`
Syncing bool `protobuf:"varint,8,opt,name=syncing,proto3" json:"syncing,omitempty"`
SupportedMarkets []string `protobuf:"bytes,9,rep,name=supported_markets,json=supportedMarkets,proto3" json:"supported_markets,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *NodeInfo) Reset() {
*x = NodeInfo{}
mi := &file_proto_lxdex_proto_msgTypes[22]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *NodeInfo) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*NodeInfo) ProtoMessage() {}
func (x *NodeInfo) ProtoReflect() protoreflect.Message {
mi := &file_proto_lxdex_proto_msgTypes[22]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use NodeInfo.ProtoReflect.Descriptor instead.
func (*NodeInfo) Descriptor() ([]byte, []int) {
return file_proto_lxdex_proto_rawDescGZIP(), []int{22}
}
func (x *NodeInfo) GetNodeId() string {
if x != nil {
return x.NodeId
}
return ""
}
func (x *NodeInfo) GetVersion() string {
if x != nil {
return x.Version
}
return ""
}
func (x *NodeInfo) GetNetwork() string {
if x != nil {
return x.Network
}
return ""
}
func (x *NodeInfo) GetBlockHeight() uint64 {
if x != nil {
return x.BlockHeight
}
return 0
}
func (x *NodeInfo) GetOrderCount() uint64 {
if x != nil {
return x.OrderCount
}
return 0
}
func (x *NodeInfo) GetTradeCount() uint64 {
if x != nil {
return x.TradeCount
}
return 0
}
func (x *NodeInfo) GetUptime() int64 {
if x != nil {
return x.Uptime
}
return 0
}
func (x *NodeInfo) GetSyncing() bool {
if x != nil {
return x.Syncing
}
return false
}
func (x *NodeInfo) GetSupportedMarkets() []string {
if x != nil {
return x.SupportedMarkets
}
return nil
}
type GetNodeInfoRequest struct {
state protoimpl.MessageState `protogen:"open.v1"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *GetNodeInfoRequest) Reset() {
*x = GetNodeInfoRequest{}
mi := &file_proto_lxdex_proto_msgTypes[23]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *GetNodeInfoRequest) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*GetNodeInfoRequest) ProtoMessage() {}
func (x *GetNodeInfoRequest) ProtoReflect() protoreflect.Message {
mi := &file_proto_lxdex_proto_msgTypes[23]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use GetNodeInfoRequest.ProtoReflect.Descriptor instead.
func (*GetNodeInfoRequest) Descriptor() ([]byte, []int) {
return file_proto_lxdex_proto_rawDescGZIP(), []int{23}
}
type Peer struct {
state protoimpl.MessageState `protogen:"open.v1"`
PeerId string `protobuf:"bytes,1,opt,name=peer_id,json=peerId,proto3" json:"peer_id,omitempty"`
Address string `protobuf:"bytes,2,opt,name=address,proto3" json:"address,omitempty"`
ConnectedAt int64 `protobuf:"varint,3,opt,name=connected_at,json=connectedAt,proto3" json:"connected_at,omitempty"`
BytesSent uint64 `protobuf:"varint,4,opt,name=bytes_sent,json=bytesSent,proto3" json:"bytes_sent,omitempty"`
BytesReceived uint64 `protobuf:"varint,5,opt,name=bytes_received,json=bytesReceived,proto3" json:"bytes_received,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *Peer) Reset() {
*x = Peer{}
mi := &file_proto_lxdex_proto_msgTypes[24]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *Peer) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*Peer) ProtoMessage() {}
func (x *Peer) ProtoReflect() protoreflect.Message {
mi := &file_proto_lxdex_proto_msgTypes[24]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use Peer.ProtoReflect.Descriptor instead.
func (*Peer) Descriptor() ([]byte, []int) {
return file_proto_lxdex_proto_rawDescGZIP(), []int{24}
}
func (x *Peer) GetPeerId() string {
if x != nil {
return x.PeerId
}
return ""
}
func (x *Peer) GetAddress() string {
if x != nil {
return x.Address
}
return ""
}
func (x *Peer) GetConnectedAt() int64 {
if x != nil {
return x.ConnectedAt
}
return 0
}
func (x *Peer) GetBytesSent() uint64 {
if x != nil {
return x.BytesSent
}
return 0
}
func (x *Peer) GetBytesReceived() uint64 {
if x != nil {
return x.BytesReceived
}
return 0
}
type GetPeersRequest struct {
state protoimpl.MessageState `protogen:"open.v1"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *GetPeersRequest) Reset() {
*x = GetPeersRequest{}
mi := &file_proto_lxdex_proto_msgTypes[25]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *GetPeersRequest) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*GetPeersRequest) ProtoMessage() {}
func (x *GetPeersRequest) ProtoReflect() protoreflect.Message {
mi := &file_proto_lxdex_proto_msgTypes[25]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use GetPeersRequest.ProtoReflect.Descriptor instead.
func (*GetPeersRequest) Descriptor() ([]byte, []int) {
return file_proto_lxdex_proto_rawDescGZIP(), []int{25}
}
type GetPeersResponse struct {
state protoimpl.MessageState `protogen:"open.v1"`
Peers []*Peer `protobuf:"bytes,1,rep,name=peers,proto3" json:"peers,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *GetPeersResponse) Reset() {
*x = GetPeersResponse{}
mi := &file_proto_lxdex_proto_msgTypes[26]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *GetPeersResponse) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*GetPeersResponse) ProtoMessage() {}
func (x *GetPeersResponse) ProtoReflect() protoreflect.Message {
mi := &file_proto_lxdex_proto_msgTypes[26]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use GetPeersResponse.ProtoReflect.Descriptor instead.
func (*GetPeersResponse) Descriptor() ([]byte, []int) {
return file_proto_lxdex_proto_rawDescGZIP(), []int{26}
}
func (x *GetPeersResponse) GetPeers() []*Peer {
if x != nil {
return x.Peers
}
return nil
}
type PingRequest struct {
state protoimpl.MessageState `protogen:"open.v1"`
Timestamp int64 `protobuf:"varint,1,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *PingRequest) Reset() {
*x = PingRequest{}
mi := &file_proto_lxdex_proto_msgTypes[27]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *PingRequest) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*PingRequest) ProtoMessage() {}
func (x *PingRequest) ProtoReflect() protoreflect.Message {
mi := &file_proto_lxdex_proto_msgTypes[27]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use PingRequest.ProtoReflect.Descriptor instead.
func (*PingRequest) Descriptor() ([]byte, []int) {
return file_proto_lxdex_proto_rawDescGZIP(), []int{27}
}
func (x *PingRequest) GetTimestamp() int64 {
if x != nil {
return x.Timestamp
}
return 0
}
type PingResponse struct {
state protoimpl.MessageState `protogen:"open.v1"`
Timestamp int64 `protobuf:"varint,1,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *PingResponse) Reset() {
*x = PingResponse{}
mi := &file_proto_lxdex_proto_msgTypes[28]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *PingResponse) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*PingResponse) ProtoMessage() {}
func (x *PingResponse) ProtoReflect() protoreflect.Message {
mi := &file_proto_lxdex_proto_msgTypes[28]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use PingResponse.ProtoReflect.Descriptor instead.
func (*PingResponse) Descriptor() ([]byte, []int) {
return file_proto_lxdex_proto_rawDescGZIP(), []int{28}
}
func (x *PingResponse) GetTimestamp() int64 {
if x != nil {
return x.Timestamp
}
return 0
}
func (x *PingResponse) GetMessage() string {
if x != nil {
return x.Message
}
return ""
}
var File_proto_lxdex_proto protoreflect.FileDescriptor
const file_proto_lxdex_proto_rawDesc = "" +
"\n" +
"\x11proto/lxdex.proto\x12\x05lxdex\"\xdc\x03\n" +
"\x05Order\x12\x19\n" +
"\border_id\x18\x01 \x01(\x04R\aorderId\x12\x16\n" +
"\x06symbol\x18\x02 \x01(\tR\x06symbol\x12$\n" +
"\x04type\x18\x03 \x01(\x0e2\x10.lxdex.OrderTypeR\x04type\x12$\n" +
"\x04side\x18\x04 \x01(\x0e2\x10.lxdex.OrderSideR\x04side\x12\x14\n" +
"\x05price\x18\x05 \x01(\x01R\x05price\x12\x12\n" +
"\x04size\x18\x06 \x01(\x01R\x04size\x12\x16\n" +
"\x06filled\x18\a \x01(\x01R\x06filled\x12\x1c\n" +
"\tremaining\x18\b \x01(\x01R\tremaining\x12*\n" +
"\x06status\x18\t \x01(\x0e2\x12.lxdex.OrderStatusR\x06status\x12\x17\n" +
"\auser_id\x18\n" +
" \x01(\tR\x06userId\x12\x1b\n" +
"\tclient_id\x18\v \x01(\tR\bclientId\x12\x1c\n" +
"\ttimestamp\x18\f \x01(\x03R\ttimestamp\x126\n" +
"\rtime_in_force\x18\r \x01(\x0e2\x12.lxdex.TimeInForceR\vtimeInForce\x12\x1b\n" +
"\tpost_only\x18\x0e \x01(\bR\bpostOnly\x12\x1f\n" +
"\vreduce_only\x18\x0f \x01(\bR\n" +
"reduceOnly\"\x8d\x03\n" +
"\x11PlaceOrderRequest\x12\x16\n" +
"\x06symbol\x18\x01 \x01(\tR\x06symbol\x12$\n" +
"\x04type\x18\x02 \x01(\x0e2\x10.lxdex.OrderTypeR\x04type\x12$\n" +
"\x04side\x18\x03 \x01(\x0e2\x10.lxdex.OrderSideR\x04side\x12\x14\n" +
"\x05price\x18\x04 \x01(\x01R\x05price\x12\x12\n" +
"\x04size\x18\x05 \x01(\x01R\x04size\x12\x17\n" +
"\auser_id\x18\x06 \x01(\tR\x06userId\x12\x1b\n" +
"\tclient_id\x18\a \x01(\tR\bclientId\x126\n" +
"\rtime_in_force\x18\b \x01(\x0e2\x12.lxdex.TimeInForceR\vtimeInForce\x12\x1b\n" +
"\tpost_only\x18\t \x01(\bR\bpostOnly\x12\x1f\n" +
"\vreduce_only\x18\n" +
" \x01(\bR\n" +
"reduceOnly\x12\x1d\n" +
"\n" +
"stop_price\x18\v \x01(\x01R\tstopPrice\x12\x1f\n" +
"\vlimit_price\x18\f \x01(\x01R\n" +
"limitPrice\"u\n" +
"\x12PlaceOrderResponse\x12\x19\n" +
"\border_id\x18\x01 \x01(\x04R\aorderId\x12*\n" +
"\x06status\x18\x02 \x01(\x0e2\x12.lxdex.OrderStatusR\x06status\x12\x18\n" +
"\amessage\x18\x03 \x01(\tR\amessage\"H\n" +
"\x12CancelOrderRequest\x12\x19\n" +
"\border_id\x18\x01 \x01(\x04R\aorderId\x12\x17\n" +
"\auser_id\x18\x02 \x01(\tR\x06userId\"I\n" +
"\x13CancelOrderResponse\x12\x18\n" +
"\asuccess\x18\x01 \x01(\bR\asuccess\x12\x18\n" +
"\amessage\x18\x02 \x01(\tR\amessage\",\n" +
"\x0fGetOrderRequest\x12\x19\n" +
"\border_id\x18\x01 \x01(\x04R\aorderId\"\x85\x01\n" +
"\x10GetOrdersRequest\x12\x17\n" +
"\auser_id\x18\x01 \x01(\tR\x06userId\x12\x16\n" +
"\x06symbol\x18\x02 \x01(\tR\x06symbol\x12*\n" +
"\x06status\x18\x03 \x01(\x0e2\x12.lxdex.OrderStatusR\x06status\x12\x14\n" +
"\x05limit\x18\x04 \x01(\x05R\x05limit\"9\n" +
"\x11GetOrdersResponse\x12$\n" +
"\x06orders\x18\x01 \x03(\v2\f.lxdex.OrderR\x06orders\"\x8f\x01\n" +
"\tOrderBook\x12\x16\n" +
"\x06symbol\x18\x01 \x01(\tR\x06symbol\x12%\n" +
"\x04bids\x18\x02 \x03(\v2\x11.lxdex.PriceLevelR\x04bids\x12%\n" +
"\x04asks\x18\x03 \x03(\v2\x11.lxdex.PriceLevelR\x04asks\x12\x1c\n" +
"\ttimestamp\x18\x04 \x01(\x03R\ttimestamp\"L\n" +
"\n" +
"PriceLevel\x12\x14\n" +
"\x05price\x18\x01 \x01(\x01R\x05price\x12\x12\n" +
"\x04size\x18\x02 \x01(\x01R\x04size\x12\x14\n" +
"\x05count\x18\x03 \x01(\x05R\x05count\"\xaf\x01\n" +
"\x0fOrderBookUpdate\x12\x16\n" +
"\x06symbol\x18\x01 \x01(\tR\x06symbol\x122\n" +
"\vbid_updates\x18\x02 \x03(\v2\x11.lxdex.PriceLevelR\n" +
"bidUpdates\x122\n" +
"\vask_updates\x18\x03 \x03(\v2\x11.lxdex.PriceLevelR\n" +
"askUpdates\x12\x1c\n" +
"\ttimestamp\x18\x04 \x01(\x03R\ttimestamp\"C\n" +
"\x13GetOrderBookRequest\x12\x16\n" +
"\x06symbol\x18\x01 \x01(\tR\x06symbol\x12\x14\n" +
"\x05depth\x18\x02 \x01(\x05R\x05depth\"F\n" +
"\x16StreamOrderBookRequest\x12\x16\n" +
"\x06symbol\x18\x01 \x01(\tR\x06symbol\x12\x14\n" +
"\x05depth\x18\x02 \x01(\x05R\x05depth\"\xa6\x02\n" +
"\x05Trade\x12\x19\n" +
"\btrade_id\x18\x01 \x01(\x04R\atradeId\x12\x16\n" +
"\x06symbol\x18\x02 \x01(\tR\x06symbol\x12\x14\n" +
"\x05price\x18\x03 \x01(\x01R\x05price\x12\x12\n" +
"\x04size\x18\x04 \x01(\x01R\x04size\x12$\n" +
"\x04side\x18\x05 \x01(\x0e2\x10.lxdex.OrderSideR\x04side\x12 \n" +
"\fbuy_order_id\x18\x06 \x01(\x04R\n" +
"buyOrderId\x12\"\n" +
"\rsell_order_id\x18\a \x01(\x04R\vsellOrderId\x12\x19\n" +
"\bbuyer_id\x18\b \x01(\tR\abuyerId\x12\x1b\n" +
"\tseller_id\x18\t \x01(\tR\bsellerId\x12\x1c\n" +
"\ttimestamp\x18\n" +
" \x01(\x03R\ttimestamp\"@\n" +
"\x10GetTradesRequest\x12\x16\n" +
"\x06symbol\x18\x01 \x01(\tR\x06symbol\x12\x14\n" +
"\x05limit\x18\x02 \x01(\x05R\x05limit\"9\n" +
"\x11GetTradesResponse\x12$\n" +
"\x06trades\x18\x01 \x03(\v2\f.lxdex.TradeR\x06trades\"-\n" +
"\x13StreamTradesRequest\x12\x16\n" +
"\x06symbol\x18\x01 \x01(\tR\x06symbol\"k\n" +
"\aBalance\x12\x14\n" +
"\x05asset\x18\x01 \x01(\tR\x05asset\x12\x1c\n" +
"\tavailable\x18\x02 \x01(\x01R\tavailable\x12\x16\n" +
"\x06locked\x18\x03 \x01(\x01R\x06locked\x12\x14\n" +
"\x05total\x18\x04 \x01(\x01R\x05total\"B\n" +
"\x11GetBalanceRequest\x12\x17\n" +
"\auser_id\x18\x01 \x01(\tR\x06userId\x12\x14\n" +
"\x05asset\x18\x02 \x01(\tR\x05asset\"\xa0\x01\n" +
"\bPosition\x12\x16\n" +
"\x06symbol\x18\x01 \x01(\tR\x06symbol\x12\x12\n" +
"\x04size\x18\x02 \x01(\x01R\x04size\x12\x1f\n" +
"\ventry_price\x18\x03 \x01(\x01R\n" +
"entryPrice\x12\x1d\n" +
"\n" +
"mark_price\x18\x04 \x01(\x01R\tmarkPrice\x12\x10\n" +
"\x03pnl\x18\x05 \x01(\x01R\x03pnl\x12\x16\n" +
"\x06margin\x18\x06 \x01(\x01R\x06margin\".\n" +
"\x13GetPositionsRequest\x12\x17\n" +
"\auser_id\x18\x01 \x01(\tR\x06userId\"E\n" +
"\x14GetPositionsResponse\x12-\n" +
"\tpositions\x18\x01 \x03(\v2\x0f.lxdex.PositionR\tpositions\"\x9b\x02\n" +
"\bNodeInfo\x12\x17\n" +
"\anode_id\x18\x01 \x01(\tR\x06nodeId\x12\x18\n" +
"\aversion\x18\x02 \x01(\tR\aversion\x12\x18\n" +
"\anetwork\x18\x03 \x01(\tR\anetwork\x12!\n" +
"\fblock_height\x18\x04 \x01(\x04R\vblockHeight\x12\x1f\n" +
"\vorder_count\x18\x05 \x01(\x04R\n" +
"orderCount\x12\x1f\n" +
"\vtrade_count\x18\x06 \x01(\x04R\n" +
"tradeCount\x12\x16\n" +
"\x06uptime\x18\a \x01(\x03R\x06uptime\x12\x18\n" +
"\asyncing\x18\b \x01(\bR\asyncing\x12+\n" +
"\x11supported_markets\x18\t \x03(\tR\x10supportedMarkets\"\x14\n" +
"\x12GetNodeInfoRequest\"\xa2\x01\n" +
"\x04Peer\x12\x17\n" +
"\apeer_id\x18\x01 \x01(\tR\x06peerId\x12\x18\n" +
"\aaddress\x18\x02 \x01(\tR\aaddress\x12!\n" +
"\fconnected_at\x18\x03 \x01(\x03R\vconnectedAt\x12\x1d\n" +
"\n" +
"bytes_sent\x18\x04 \x01(\x04R\tbytesSent\x12%\n" +
"\x0ebytes_received\x18\x05 \x01(\x04R\rbytesReceived\"\x11\n" +
"\x0fGetPeersRequest\"5\n" +
"\x10GetPeersResponse\x12!\n" +
"\x05peers\x18\x01 \x03(\v2\v.lxdex.PeerR\x05peers\"+\n" +
"\vPingRequest\x12\x1c\n" +
"\ttimestamp\x18\x01 \x01(\x03R\ttimestamp\"F\n" +
"\fPingResponse\x12\x1c\n" +
"\ttimestamp\x18\x01 \x01(\x03R\ttimestamp\x12\x18\n" +
"\amessage\x18\x02 \x01(\tR\amessage*R\n" +
"\tOrderType\x12\t\n" +
"\x05LIMIT\x10\x00\x12\n" +
"\n" +
"\x06MARKET\x10\x01\x12\b\n" +
"\x04STOP\x10\x02\x12\x0e\n" +
"\n" +
"STOP_LIMIT\x10\x03\x12\v\n" +
"\aICEBERG\x10\x04\x12\a\n" +
"\x03PEG\x10\x05*\x1e\n" +
"\tOrderSide\x12\a\n" +
"\x03BUY\x10\x00\x12\b\n" +
"\x04SELL\x10\x01*M\n" +
"\vOrderStatus\x12\b\n" +
"\x04OPEN\x10\x00\x12\v\n" +
"\aPARTIAL\x10\x01\x12\n" +
"\n" +
"\x06FILLED\x10\x02\x12\r\n" +
"\tCANCELLED\x10\x03\x12\f\n" +
"\bREJECTED\x10\x04*1\n" +
"\vTimeInForce\x12\a\n" +
"\x03GTC\x10\x00\x12\a\n" +
"\x03IOC\x10\x01\x12\a\n" +
"\x03FOK\x10\x02\x12\a\n" +
"\x03DAY\x10\x032\xb9\x06\n" +
"\fLXDEXService\x12A\n" +
"\n" +
"PlaceOrder\x12\x18.lxdex.PlaceOrderRequest\x1a\x19.lxdex.PlaceOrderResponse\x12D\n" +
"\vCancelOrder\x12\x19.lxdex.CancelOrderRequest\x1a\x1a.lxdex.CancelOrderResponse\x120\n" +
"\bGetOrder\x12\x16.lxdex.GetOrderRequest\x1a\f.lxdex.Order\x12>\n" +
"\tGetOrders\x12\x17.lxdex.GetOrdersRequest\x1a\x18.lxdex.GetOrdersResponse\x12<\n" +
"\fGetOrderBook\x12\x1a.lxdex.GetOrderBookRequest\x1a\x10.lxdex.OrderBook\x12J\n" +
"\x0fStreamOrderBook\x12\x1d.lxdex.StreamOrderBookRequest\x1a\x16.lxdex.OrderBookUpdate0\x01\x12>\n" +
"\tGetTrades\x12\x17.lxdex.GetTradesRequest\x1a\x18.lxdex.GetTradesResponse\x12:\n" +
"\fStreamTrades\x12\x1a.lxdex.StreamTradesRequest\x1a\f.lxdex.Trade0\x01\x126\n" +
"\n" +
"GetBalance\x12\x18.lxdex.GetBalanceRequest\x1a\x0e.lxdex.Balance\x12G\n" +
"\fGetPositions\x12\x1a.lxdex.GetPositionsRequest\x1a\x1b.lxdex.GetPositionsResponse\x129\n" +
"\vGetNodeInfo\x12\x19.lxdex.GetNodeInfoRequest\x1a\x0f.lxdex.NodeInfo\x12;\n" +
"\bGetPeers\x12\x16.lxdex.GetPeersRequest\x1a\x17.lxdex.GetPeersResponse\x12/\n" +
"\x04Ping\x12\x12.lxdex.PingRequest\x1a\x13.lxdex.PingResponseB\"Z github.com/luxfi/dex/pkg/grpc/pbb\x06proto3"
var (
file_proto_lxdex_proto_rawDescOnce sync.Once
file_proto_lxdex_proto_rawDescData []byte
)
func file_proto_lxdex_proto_rawDescGZIP() []byte {
file_proto_lxdex_proto_rawDescOnce.Do(func() {
file_proto_lxdex_proto_rawDescData = protoimpl.X.CompressGZIP(unsafe.Slice(unsafe.StringData(file_proto_lxdex_proto_rawDesc), len(file_proto_lxdex_proto_rawDesc)))
})
return file_proto_lxdex_proto_rawDescData
}
var file_proto_lxdex_proto_enumTypes = make([]protoimpl.EnumInfo, 4)
var file_proto_lxdex_proto_msgTypes = make([]protoimpl.MessageInfo, 29)
var file_proto_lxdex_proto_goTypes = []any{
(OrderType)(0), // 0: lxdex.OrderType
(OrderSide)(0), // 1: lxdex.OrderSide
(OrderStatus)(0), // 2: lxdex.OrderStatus
(TimeInForce)(0), // 3: lxdex.TimeInForce
(*Order)(nil), // 4: lxdex.Order
(*PlaceOrderRequest)(nil), // 5: lxdex.PlaceOrderRequest
(*PlaceOrderResponse)(nil), // 6: lxdex.PlaceOrderResponse
(*CancelOrderRequest)(nil), // 7: lxdex.CancelOrderRequest
(*CancelOrderResponse)(nil), // 8: lxdex.CancelOrderResponse
(*GetOrderRequest)(nil), // 9: lxdex.GetOrderRequest
(*GetOrdersRequest)(nil), // 10: lxdex.GetOrdersRequest
(*GetOrdersResponse)(nil), // 11: lxdex.GetOrdersResponse
(*OrderBook)(nil), // 12: lxdex.OrderBook
(*PriceLevel)(nil), // 13: lxdex.PriceLevel
(*OrderBookUpdate)(nil), // 14: lxdex.OrderBookUpdate
(*GetOrderBookRequest)(nil), // 15: lxdex.GetOrderBookRequest
(*StreamOrderBookRequest)(nil), // 16: lxdex.StreamOrderBookRequest
(*Trade)(nil), // 17: lxdex.Trade
(*GetTradesRequest)(nil), // 18: lxdex.GetTradesRequest
(*GetTradesResponse)(nil), // 19: lxdex.GetTradesResponse
(*StreamTradesRequest)(nil), // 20: lxdex.StreamTradesRequest
(*Balance)(nil), // 21: lxdex.Balance
(*GetBalanceRequest)(nil), // 22: lxdex.GetBalanceRequest
(*Position)(nil), // 23: lxdex.Position
(*GetPositionsRequest)(nil), // 24: lxdex.GetPositionsRequest
(*GetPositionsResponse)(nil), // 25: lxdex.GetPositionsResponse
(*NodeInfo)(nil), // 26: lxdex.NodeInfo
(*GetNodeInfoRequest)(nil), // 27: lxdex.GetNodeInfoRequest
(*Peer)(nil), // 28: lxdex.Peer
(*GetPeersRequest)(nil), // 29: lxdex.GetPeersRequest
(*GetPeersResponse)(nil), // 30: lxdex.GetPeersResponse
(*PingRequest)(nil), // 31: lxdex.PingRequest
(*PingResponse)(nil), // 32: lxdex.PingResponse
}
var file_proto_lxdex_proto_depIdxs = []int32{
0, // 0: lxdex.Order.type:type_name -> lxdex.OrderType
1, // 1: lxdex.Order.side:type_name -> lxdex.OrderSide
2, // 2: lxdex.Order.status:type_name -> lxdex.OrderStatus
3, // 3: lxdex.Order.time_in_force:type_name -> lxdex.TimeInForce
0, // 4: lxdex.PlaceOrderRequest.type:type_name -> lxdex.OrderType
1, // 5: lxdex.PlaceOrderRequest.side:type_name -> lxdex.OrderSide
3, // 6: lxdex.PlaceOrderRequest.time_in_force:type_name -> lxdex.TimeInForce
2, // 7: lxdex.PlaceOrderResponse.status:type_name -> lxdex.OrderStatus
2, // 8: lxdex.GetOrdersRequest.status:type_name -> lxdex.OrderStatus
4, // 9: lxdex.GetOrdersResponse.orders:type_name -> lxdex.Order
13, // 10: lxdex.OrderBook.bids:type_name -> lxdex.PriceLevel
13, // 11: lxdex.OrderBook.asks:type_name -> lxdex.PriceLevel
13, // 12: lxdex.OrderBookUpdate.bid_updates:type_name -> lxdex.PriceLevel
13, // 13: lxdex.OrderBookUpdate.ask_updates:type_name -> lxdex.PriceLevel
1, // 14: lxdex.Trade.side:type_name -> lxdex.OrderSide
17, // 15: lxdex.GetTradesResponse.trades:type_name -> lxdex.Trade
23, // 16: lxdex.GetPositionsResponse.positions:type_name -> lxdex.Position
28, // 17: lxdex.GetPeersResponse.peers:type_name -> lxdex.Peer
5, // 18: lxdex.LXDEXService.PlaceOrder:input_type -> lxdex.PlaceOrderRequest
7, // 19: lxdex.LXDEXService.CancelOrder:input_type -> lxdex.CancelOrderRequest
9, // 20: lxdex.LXDEXService.GetOrder:input_type -> lxdex.GetOrderRequest
10, // 21: lxdex.LXDEXService.GetOrders:input_type -> lxdex.GetOrdersRequest
15, // 22: lxdex.LXDEXService.GetOrderBook:input_type -> lxdex.GetOrderBookRequest
16, // 23: lxdex.LXDEXService.StreamOrderBook:input_type -> lxdex.StreamOrderBookRequest
18, // 24: lxdex.LXDEXService.GetTrades:input_type -> lxdex.GetTradesRequest
20, // 25: lxdex.LXDEXService.StreamTrades:input_type -> lxdex.StreamTradesRequest
22, // 26: lxdex.LXDEXService.GetBalance:input_type -> lxdex.GetBalanceRequest
24, // 27: lxdex.LXDEXService.GetPositions:input_type -> lxdex.GetPositionsRequest
27, // 28: lxdex.LXDEXService.GetNodeInfo:input_type -> lxdex.GetNodeInfoRequest
29, // 29: lxdex.LXDEXService.GetPeers:input_type -> lxdex.GetPeersRequest
31, // 30: lxdex.LXDEXService.Ping:input_type -> lxdex.PingRequest
6, // 31: lxdex.LXDEXService.PlaceOrder:output_type -> lxdex.PlaceOrderResponse
8, // 32: lxdex.LXDEXService.CancelOrder:output_type -> lxdex.CancelOrderResponse
4, // 33: lxdex.LXDEXService.GetOrder:output_type -> lxdex.Order
11, // 34: lxdex.LXDEXService.GetOrders:output_type -> lxdex.GetOrdersResponse
12, // 35: lxdex.LXDEXService.GetOrderBook:output_type -> lxdex.OrderBook
14, // 36: lxdex.LXDEXService.StreamOrderBook:output_type -> lxdex.OrderBookUpdate
19, // 37: lxdex.LXDEXService.GetTrades:output_type -> lxdex.GetTradesResponse
17, // 38: lxdex.LXDEXService.StreamTrades:output_type -> lxdex.Trade
21, // 39: lxdex.LXDEXService.GetBalance:output_type -> lxdex.Balance
25, // 40: lxdex.LXDEXService.GetPositions:output_type -> lxdex.GetPositionsResponse
26, // 41: lxdex.LXDEXService.GetNodeInfo:output_type -> lxdex.NodeInfo
30, // 42: lxdex.LXDEXService.GetPeers:output_type -> lxdex.GetPeersResponse
32, // 43: lxdex.LXDEXService.Ping:output_type -> lxdex.PingResponse
31, // [31:44] is the sub-list for method output_type
18, // [18:31] is the sub-list for method input_type
18, // [18:18] is the sub-list for extension type_name
18, // [18:18] is the sub-list for extension extendee
0, // [0:18] is the sub-list for field type_name
}
func init() { file_proto_lxdex_proto_init() }
func file_proto_lxdex_proto_init() {
if File_proto_lxdex_proto != nil {
return
}
type x struct{}
out := protoimpl.TypeBuilder{
File: protoimpl.DescBuilder{
GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
RawDescriptor: unsafe.Slice(unsafe.StringData(file_proto_lxdex_proto_rawDesc), len(file_proto_lxdex_proto_rawDesc)),
NumEnums: 4,
NumMessages: 29,
NumExtensions: 0,
NumServices: 1,
},
GoTypes: file_proto_lxdex_proto_goTypes,
DependencyIndexes: file_proto_lxdex_proto_depIdxs,
EnumInfos: file_proto_lxdex_proto_enumTypes,
MessageInfos: file_proto_lxdex_proto_msgTypes,
}.Build()
File_proto_lxdex_proto = out.File
file_proto_lxdex_proto_goTypes = nil
file_proto_lxdex_proto_depIdxs = nil
}