injective_spot_exchange_rpcpb

package
v1.37.3 Latest Latest
Warning

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

 Go to latest Published: Apr 5, 2022 License: MIT Imports: 15 Imported by: 13

Documentation

Overview

Package injective_spot_exchange_rpcpb is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

This section is empty.

Variables

View Source 
var File_injective_spot_exchange_rpc_proto protoreflect.FileDescriptor
View Source 
var InjectiveSpotExchangeRPC_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "injective_spot_exchange_rpc.InjectiveSpotExchangeRPC",
	HandlerType: (*InjectiveSpotExchangeRPCServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Markets",
			Handler:    _InjectiveSpotExchangeRPC_Markets_Handler,
		},
		{
			MethodName: "Market",
			Handler:    _InjectiveSpotExchangeRPC_Market_Handler,
		},
		{
			MethodName: "Orderbook",
			Handler:    _InjectiveSpotExchangeRPC_Orderbook_Handler,
		},
		{
			MethodName: "Orderbooks",
			Handler:    _InjectiveSpotExchangeRPC_Orderbooks_Handler,
		},
		{
			MethodName: "Orders",
			Handler:    _InjectiveSpotExchangeRPC_Orders_Handler,
		},
		{
			MethodName: "Trades",
			Handler:    _InjectiveSpotExchangeRPC_Trades_Handler,
		},
		{
			MethodName: "SubaccountOrdersList",
			Handler:    _InjectiveSpotExchangeRPC_SubaccountOrdersList_Handler,
		},
		{
			MethodName: "SubaccountTradesList",
			Handler:    _InjectiveSpotExchangeRPC_SubaccountTradesList_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "StreamMarkets",
			Handler:       _InjectiveSpotExchangeRPC_StreamMarkets_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "StreamOrderbook",
			Handler:       _InjectiveSpotExchangeRPC_StreamOrderbook_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "StreamOrders",
			Handler:       _InjectiveSpotExchangeRPC_StreamOrders_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "StreamTrades",
			Handler:       _InjectiveSpotExchangeRPC_StreamTrades_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "injective_spot_exchange_rpc.proto",
}

InjectiveSpotExchangeRPC_ServiceDesc is the grpc.ServiceDesc for InjectiveSpotExchangeRPC service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterInjectiveSpotExchangeRPCHandler added in v1.32.1 

func RegisterInjectiveSpotExchangeRPCHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterInjectiveSpotExchangeRPCHandler registers the http handlers for service InjectiveSpotExchangeRPC to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterInjectiveSpotExchangeRPCHandlerClient added in v1.32.1 

func RegisterInjectiveSpotExchangeRPCHandlerClient(ctx context.Context, mux *runtime.ServeMux, client InjectiveSpotExchangeRPCClient) error

RegisterInjectiveSpotExchangeRPCHandlerClient registers the http handlers for service InjectiveSpotExchangeRPC to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "InjectiveSpotExchangeRPCClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "InjectiveSpotExchangeRPCClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "InjectiveSpotExchangeRPCClient" to call the correct interceptors.

func RegisterInjectiveSpotExchangeRPCHandlerFromEndpoint added in v1.32.1 

func RegisterInjectiveSpotExchangeRPCHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterInjectiveSpotExchangeRPCHandlerFromEndpoint is same as RegisterInjectiveSpotExchangeRPCHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterInjectiveSpotExchangeRPCHandlerServer added in v1.32.1 

func RegisterInjectiveSpotExchangeRPCHandlerServer(ctx context.Context, mux *runtime.ServeMux, server InjectiveSpotExchangeRPCServer) error

RegisterInjectiveSpotExchangeRPCHandlerServer registers the http handlers for service InjectiveSpotExchangeRPC to "mux". UnaryRPC :call InjectiveSpotExchangeRPCServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterInjectiveSpotExchangeRPCHandlerFromEndpoint instead.

func RegisterInjectiveSpotExchangeRPCServer 

func RegisterInjectiveSpotExchangeRPCServer(s grpc.ServiceRegistrar, srv InjectiveSpotExchangeRPCServer)

Types

type InjectiveSpotExchangeRPCClient 

type InjectiveSpotExchangeRPCClient interface {
	// Get a list of Spot Markets
	Markets(ctx context.Context, in *MarketsRequest, opts ...grpc.CallOption) (*MarketsResponse, error)
	// Get details of a single spot market
	Market(ctx context.Context, in *MarketRequest, opts ...grpc.CallOption) (*MarketResponse, error)
	// Stream live updates of selected spot markets
	StreamMarkets(ctx context.Context, in *StreamMarketsRequest, opts ...grpc.CallOption) (InjectiveSpotExchangeRPC_StreamMarketsClient, error)
	// Orderbook of a Spot Market
	Orderbook(ctx context.Context, in *OrderbookRequest, opts ...grpc.CallOption) (*OrderbookResponse, error)
	// Orderbook of Spot Markets
	Orderbooks(ctx context.Context, in *OrderbooksRequest, opts ...grpc.CallOption) (*OrderbooksResponse, error)
	// Stream live updates of selected spot market orderbook
	StreamOrderbook(ctx context.Context, in *StreamOrderbookRequest, opts ...grpc.CallOption) (InjectiveSpotExchangeRPC_StreamOrderbookClient, error)
	// Orders of a Spot Market
	Orders(ctx context.Context, in *OrdersRequest, opts ...grpc.CallOption) (*OrdersResponse, error)
	// Stream updates to individual orders of a Spot Market
	StreamOrders(ctx context.Context, in *StreamOrdersRequest, opts ...grpc.CallOption) (InjectiveSpotExchangeRPC_StreamOrdersClient, error)
	// Trades of a Spot Market
	Trades(ctx context.Context, in *TradesRequest, opts ...grpc.CallOption) (*TradesResponse, error)
	// Stream newly executed trades from Spot Market
	StreamTrades(ctx context.Context, in *StreamTradesRequest, opts ...grpc.CallOption) (InjectiveSpotExchangeRPC_StreamTradesClient, error)
	// List orders posted from this subaccount
	SubaccountOrdersList(ctx context.Context, in *SubaccountOrdersListRequest, opts ...grpc.CallOption) (*SubaccountOrdersListResponse, error)
	// List trades executed by this subaccount
	SubaccountTradesList(ctx context.Context, in *SubaccountTradesListRequest, opts ...grpc.CallOption) (*SubaccountTradesListResponse, error)
}

InjectiveSpotExchangeRPCClient is the client API for InjectiveSpotExchangeRPC service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewInjectiveSpotExchangeRPCClient 

func NewInjectiveSpotExchangeRPCClient(cc grpc.ClientConnInterface) InjectiveSpotExchangeRPCClient

type InjectiveSpotExchangeRPCServer 

type InjectiveSpotExchangeRPCServer interface {
	// Get a list of Spot Markets
	Markets(context.Context, *MarketsRequest) (*MarketsResponse, error)
	// Get details of a single spot market
	Market(context.Context, *MarketRequest) (*MarketResponse, error)
	// Stream live updates of selected spot markets
	StreamMarkets(*StreamMarketsRequest, InjectiveSpotExchangeRPC_StreamMarketsServer) error
	// Orderbook of a Spot Market
	Orderbook(context.Context, *OrderbookRequest) (*OrderbookResponse, error)
	// Orderbook of Spot Markets
	Orderbooks(context.Context, *OrderbooksRequest) (*OrderbooksResponse, error)
	// Stream live updates of selected spot market orderbook
	StreamOrderbook(*StreamOrderbookRequest, InjectiveSpotExchangeRPC_StreamOrderbookServer) error
	// Orders of a Spot Market
	Orders(context.Context, *OrdersRequest) (*OrdersResponse, error)
	// Stream updates to individual orders of a Spot Market
	StreamOrders(*StreamOrdersRequest, InjectiveSpotExchangeRPC_StreamOrdersServer) error
	// Trades of a Spot Market
	Trades(context.Context, *TradesRequest) (*TradesResponse, error)
	// Stream newly executed trades from Spot Market
	StreamTrades(*StreamTradesRequest, InjectiveSpotExchangeRPC_StreamTradesServer) error
	// List orders posted from this subaccount
	SubaccountOrdersList(context.Context, *SubaccountOrdersListRequest) (*SubaccountOrdersListResponse, error)
	// List trades executed by this subaccount
	SubaccountTradesList(context.Context, *SubaccountTradesListRequest) (*SubaccountTradesListResponse, error)
	// contains filtered or unexported methods
}

InjectiveSpotExchangeRPCServer is the server API for InjectiveSpotExchangeRPC service. All implementations must embed UnimplementedInjectiveSpotExchangeRPCServer for forward compatibility

type InjectiveSpotExchangeRPC_StreamMarketsClient 

type InjectiveSpotExchangeRPC_StreamMarketsClient interface {
	Recv() (*StreamMarketsResponse, error)
	grpc.ClientStream
}

type InjectiveSpotExchangeRPC_StreamMarketsServer 

type InjectiveSpotExchangeRPC_StreamMarketsServer interface {
	Send(*StreamMarketsResponse) error
	grpc.ServerStream
}

type InjectiveSpotExchangeRPC_StreamOrderbookClient 

type InjectiveSpotExchangeRPC_StreamOrderbookClient interface {
	Recv() (*StreamOrderbookResponse, error)
	grpc.ClientStream
}

type InjectiveSpotExchangeRPC_StreamOrderbookServer 

type InjectiveSpotExchangeRPC_StreamOrderbookServer interface {
	Send(*StreamOrderbookResponse) error
	grpc.ServerStream
}

type InjectiveSpotExchangeRPC_StreamOrdersClient 

type InjectiveSpotExchangeRPC_StreamOrdersClient interface {
	Recv() (*StreamOrdersResponse, error)
	grpc.ClientStream
}

type InjectiveSpotExchangeRPC_StreamOrdersServer 

type InjectiveSpotExchangeRPC_StreamOrdersServer interface {
	Send(*StreamOrdersResponse) error
	grpc.ServerStream
}

type InjectiveSpotExchangeRPC_StreamTradesClient 

type InjectiveSpotExchangeRPC_StreamTradesClient interface {
	Recv() (*StreamTradesResponse, error)
	grpc.ClientStream
}

type InjectiveSpotExchangeRPC_StreamTradesServer 

type InjectiveSpotExchangeRPC_StreamTradesServer interface {
	Send(*StreamTradesResponse) error
	grpc.ServerStream
}

type MarketRequest 

type MarketRequest struct {

	// MarketId of the market we want to fetch
	MarketId string `protobuf:"bytes,1,opt,name=market_id,json=marketId,proto3" json:"market_id,omitempty"`
	// contains filtered or unexported fields
}

func (*MarketRequest) Descriptor deprecated 

func (*MarketRequest) Descriptor() ([]byte, []int)

Deprecated: Use MarketRequest.ProtoReflect.Descriptor instead.

func (*MarketRequest) GetMarketId 

func (x *MarketRequest) GetMarketId() string

func (*MarketRequest) ProtoMessage 

func (*MarketRequest) ProtoMessage()

func (*MarketRequest) ProtoReflect 

func (x *MarketRequest) ProtoReflect() protoreflect.Message

func (*MarketRequest) Reset 

func (x *MarketRequest) Reset()

func (*MarketRequest) String 

func (x *MarketRequest) String() string

type MarketResponse 

type MarketResponse struct {

	// Info about particular spot market
	Market *SpotMarketInfo `protobuf:"bytes,1,opt,name=market,proto3" json:"market,omitempty"`
	// contains filtered or unexported fields
}

func (*MarketResponse) Descriptor deprecated 

func (*MarketResponse) Descriptor() ([]byte, []int)

Deprecated: Use MarketResponse.ProtoReflect.Descriptor instead.

func (*MarketResponse) GetMarket 

func (x *MarketResponse) GetMarket() *SpotMarketInfo

func (*MarketResponse) ProtoMessage 

func (*MarketResponse) ProtoMessage()

func (*MarketResponse) ProtoReflect 

func (x *MarketResponse) ProtoReflect() protoreflect.Message

func (*MarketResponse) Reset 

func (x *MarketResponse) Reset()

func (*MarketResponse) String 

func (x *MarketResponse) String() string

type MarketsRequest 

type MarketsRequest struct {

	// Filter by market status
	MarketStatus string `protobuf:"bytes,1,opt,name=market_status,json=marketStatus,proto3" json:"market_status,omitempty"`
	// Filter by the Coin denomination of the base currency
	BaseDenom string `protobuf:"bytes,2,opt,name=base_denom,json=baseDenom,proto3" json:"base_denom,omitempty"`
	// Filter by the Coin denomination of the quote currency
	QuoteDenom string `protobuf:"bytes,3,opt,name=quote_denom,json=quoteDenom,proto3" json:"quote_denom,omitempty"`
	// contains filtered or unexported fields
}

func (*MarketsRequest) Descriptor deprecated 

func (*MarketsRequest) Descriptor() ([]byte, []int)

Deprecated: Use MarketsRequest.ProtoReflect.Descriptor instead.

func (*MarketsRequest) GetBaseDenom 

func (x *MarketsRequest) GetBaseDenom() string

func (*MarketsRequest) GetMarketStatus 

func (x *MarketsRequest) GetMarketStatus() string

func (*MarketsRequest) GetQuoteDenom 

func (x *MarketsRequest) GetQuoteDenom() string

func (*MarketsRequest) ProtoMessage 

func (*MarketsRequest) ProtoMessage()

func (*MarketsRequest) ProtoReflect 

func (x *MarketsRequest) ProtoReflect() protoreflect.Message

func (*MarketsRequest) Reset 

func (x *MarketsRequest) Reset()

func (*MarketsRequest) String 

func (x *MarketsRequest) String() string

type MarketsResponse 

type MarketsResponse struct {

	// Spot Markets list
	Markets []*SpotMarketInfo `protobuf:"bytes,1,rep,name=markets,proto3" json:"markets,omitempty"`
	// contains filtered or unexported fields
}

func (*MarketsResponse) Descriptor deprecated 

func (*MarketsResponse) Descriptor() ([]byte, []int)

Deprecated: Use MarketsResponse.ProtoReflect.Descriptor instead.

func (*MarketsResponse) GetMarkets 

func (x *MarketsResponse) GetMarkets() []*SpotMarketInfo

func (*MarketsResponse) ProtoMessage 

func (*MarketsResponse) ProtoMessage()

func (*MarketsResponse) ProtoReflect 

func (x *MarketsResponse) ProtoReflect() protoreflect.Message

func (*MarketsResponse) Reset 

func (x *MarketsResponse) Reset()

func (*MarketsResponse) String 

func (x *MarketsResponse) String() string

type OrderbookRequest 

type OrderbookRequest struct {

	// MarketId of the market's orderbook we want to fetch
	MarketId string `protobuf:"bytes,1,opt,name=market_id,json=marketId,proto3" json:"market_id,omitempty"`
	// contains filtered or unexported fields
}

func (*OrderbookRequest) Descriptor deprecated 

func (*OrderbookRequest) Descriptor() ([]byte, []int)

Deprecated: Use OrderbookRequest.ProtoReflect.Descriptor instead.

func (*OrderbookRequest) GetMarketId 

func (x *OrderbookRequest) GetMarketId() string

func (*OrderbookRequest) ProtoMessage 

func (*OrderbookRequest) ProtoMessage()

func (*OrderbookRequest) ProtoReflect 

func (x *OrderbookRequest) ProtoReflect() protoreflect.Message

func (*OrderbookRequest) Reset 

func (x *OrderbookRequest) Reset()

func (*OrderbookRequest) String 

func (x *OrderbookRequest) String() string

type OrderbookResponse 

type OrderbookResponse struct {

	// Orderbook of a particular spot market
	Orderbook *SpotLimitOrderbook `protobuf:"bytes,1,opt,name=orderbook,proto3" json:"orderbook,omitempty"`
	// contains filtered or unexported fields
}

func (*OrderbookResponse) Descriptor deprecated 

func (*OrderbookResponse) Descriptor() ([]byte, []int)

Deprecated: Use OrderbookResponse.ProtoReflect.Descriptor instead.

func (*OrderbookResponse) GetOrderbook 

func (x *OrderbookResponse) GetOrderbook() *SpotLimitOrderbook

func (*OrderbookResponse) ProtoMessage 

func (*OrderbookResponse) ProtoMessage()

func (*OrderbookResponse) ProtoReflect 

func (x *OrderbookResponse) ProtoReflect() protoreflect.Message

func (*OrderbookResponse) Reset 

func (x *OrderbookResponse) Reset()

func (*OrderbookResponse) String 

func (x *OrderbookResponse) String() string

type OrderbooksRequest added in v1.34.0 

type OrderbooksRequest struct {

	// MarketIds of the markets
	MarketIds []string `protobuf:"bytes,1,rep,name=market_ids,json=marketIds,proto3" json:"market_ids,omitempty"`
	// contains filtered or unexported fields
}

func (*OrderbooksRequest) Descriptor deprecated added in v1.34.0 

func (*OrderbooksRequest) Descriptor() ([]byte, []int)

Deprecated: Use OrderbooksRequest.ProtoReflect.Descriptor instead.

func (*OrderbooksRequest) GetMarketIds added in v1.34.0 

func (x *OrderbooksRequest) GetMarketIds() []string

func (*OrderbooksRequest) ProtoMessage added in v1.34.0 

func (*OrderbooksRequest) ProtoMessage()

func (*OrderbooksRequest) ProtoReflect added in v1.34.0 

func (x *OrderbooksRequest) ProtoReflect() protoreflect.Message

func (*OrderbooksRequest) Reset added in v1.34.0 

func (x *OrderbooksRequest) Reset()

func (*OrderbooksRequest) String added in v1.34.0 

func (x *OrderbooksRequest) String() string

type OrderbooksResponse added in v1.34.0 

type OrderbooksResponse struct {
	Orderbooks []*SingleSpotLimitOrderbook `protobuf:"bytes,1,rep,name=orderbooks,proto3" json:"orderbooks,omitempty"`
	// contains filtered or unexported fields
}

func (*OrderbooksResponse) Descriptor deprecated added in v1.34.0 

func (*OrderbooksResponse) Descriptor() ([]byte, []int)

Deprecated: Use OrderbooksResponse.ProtoReflect.Descriptor instead.

func (*OrderbooksResponse) GetOrderbooks added in v1.34.0 

func (x *OrderbooksResponse) GetOrderbooks() []*SingleSpotLimitOrderbook

func (*OrderbooksResponse) ProtoMessage added in v1.34.0 

func (*OrderbooksResponse) ProtoMessage()

func (*OrderbooksResponse) ProtoReflect added in v1.34.0 

func (x *OrderbooksResponse) ProtoReflect() protoreflect.Message

func (*OrderbooksResponse) Reset added in v1.34.0 

func (x *OrderbooksResponse) Reset()

func (*OrderbooksResponse) String added in v1.34.0 

func (x *OrderbooksResponse) String() string

type OrdersRequest 

type OrdersRequest struct {

	// MarketId of the market's orderbook we want to fetch
	MarketId string `protobuf:"bytes,1,opt,name=market_id,json=marketId,proto3" json:"market_id,omitempty"`
	// Look for specific order side
	OrderSide string `protobuf:"bytes,2,opt,name=order_side,json=orderSide,proto3" json:"order_side,omitempty"`
	// Look for specific subaccountId of an order
	SubaccountId string `protobuf:"bytes,3,opt,name=subaccount_id,json=subaccountId,proto3" json:"subaccount_id,omitempty"`
	// contains filtered or unexported fields
}

func (*OrdersRequest) Descriptor deprecated 

func (*OrdersRequest) Descriptor() ([]byte, []int)

Deprecated: Use OrdersRequest.ProtoReflect.Descriptor instead.

func (*OrdersRequest) GetMarketId 

func (x *OrdersRequest) GetMarketId() string

func (*OrdersRequest) GetOrderSide added in v1.23.6 

func (x *OrdersRequest) GetOrderSide() string

func (*OrdersRequest) GetSubaccountId 

func (x *OrdersRequest) GetSubaccountId() string

func (*OrdersRequest) ProtoMessage 

func (*OrdersRequest) ProtoMessage()

func (*OrdersRequest) ProtoReflect 

func (x *OrdersRequest) ProtoReflect() protoreflect.Message

func (*OrdersRequest) Reset 

func (x *OrdersRequest) Reset()

func (*OrdersRequest) String 

func (x *OrdersRequest) String() string

type OrdersResponse 

type OrdersResponse struct {

	// List of spot market orders
	Orders []*SpotLimitOrder `protobuf:"bytes,1,rep,name=orders,proto3" json:"orders,omitempty"`
	// contains filtered or unexported fields
}

func (*OrdersResponse) Descriptor deprecated 

func (*OrdersResponse) Descriptor() ([]byte, []int)

Deprecated: Use OrdersResponse.ProtoReflect.Descriptor instead.

func (*OrdersResponse) GetOrders 

func (x *OrdersResponse) GetOrders() []*SpotLimitOrder

func (*OrdersResponse) ProtoMessage 

func (*OrdersResponse) ProtoMessage()

func (*OrdersResponse) ProtoReflect 

func (x *OrdersResponse) ProtoReflect() protoreflect.Message

func (*OrdersResponse) Reset 

func (x *OrdersResponse) Reset()

func (*OrdersResponse) String 

func (x *OrdersResponse) String() string

type PriceLevel 

type PriceLevel struct {

	// Price number of the price level.
	Price string `protobuf:"bytes,1,opt,name=price,proto3" json:"price,omitempty"`
	// Quantity of the price level.
	Quantity string `protobuf:"bytes,2,opt,name=quantity,proto3" json:"quantity,omitempty"`
	// Price level last updated timestamp in UNIX millis.
	Timestamp int64 `protobuf:"zigzag64,3,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// contains filtered or unexported fields
}

func (*PriceLevel) Descriptor deprecated 

func (*PriceLevel) Descriptor() ([]byte, []int)

Deprecated: Use PriceLevel.ProtoReflect.Descriptor instead.

func (*PriceLevel) GetPrice 

func (x *PriceLevel) GetPrice() string

func (*PriceLevel) GetQuantity 

func (x *PriceLevel) GetQuantity() string

func (*PriceLevel) GetTimestamp 

func (x *PriceLevel) GetTimestamp() int64

func (*PriceLevel) ProtoMessage 

func (*PriceLevel) ProtoMessage()

func (*PriceLevel) ProtoReflect 

func (x *PriceLevel) ProtoReflect() protoreflect.Message

func (*PriceLevel) Reset 

func (x *PriceLevel) Reset()

func (*PriceLevel) String 

func (x *PriceLevel) String() string

type SingleSpotLimitOrderbook added in v1.34.0 

type SingleSpotLimitOrderbook struct {

	// market's ID
	MarketId string `protobuf:"bytes,1,opt,name=market_id,json=marketId,proto3" json:"market_id,omitempty"`
	// Orderbook of the market
	Orderbook *SpotLimitOrderbook `protobuf:"bytes,2,opt,name=orderbook,proto3" json:"orderbook,omitempty"`
	// contains filtered or unexported fields
}

func (*SingleSpotLimitOrderbook) Descriptor deprecated added in v1.34.0 

func (*SingleSpotLimitOrderbook) Descriptor() ([]byte, []int)

Deprecated: Use SingleSpotLimitOrderbook.ProtoReflect.Descriptor instead.

func (*SingleSpotLimitOrderbook) GetMarketId added in v1.34.0 

func (x *SingleSpotLimitOrderbook) GetMarketId() string

func (*SingleSpotLimitOrderbook) GetOrderbook added in v1.34.0 

func (x *SingleSpotLimitOrderbook) GetOrderbook() *SpotLimitOrderbook

func (*SingleSpotLimitOrderbook) ProtoMessage added in v1.34.0 

func (*SingleSpotLimitOrderbook) ProtoMessage()

func (*SingleSpotLimitOrderbook) ProtoReflect added in v1.34.0 

func (x *SingleSpotLimitOrderbook) ProtoReflect() protoreflect.Message

func (*SingleSpotLimitOrderbook) Reset added in v1.34.0 

func (x *SingleSpotLimitOrderbook) Reset()

func (*SingleSpotLimitOrderbook) String added in v1.34.0 

func (x *SingleSpotLimitOrderbook) String() string

type SpotLimitOrder 

type SpotLimitOrder struct {

	// Hash of the order
	OrderHash string `protobuf:"bytes,1,opt,name=order_hash,json=orderHash,proto3" json:"order_hash,omitempty"`
	// The side of the order
	OrderSide string `protobuf:"bytes,2,opt,name=order_side,json=orderSide,proto3" json:"order_side,omitempty"`
	// Spot Market ID is keccak265(baseDenom + quoteDenom)
	MarketId string `protobuf:"bytes,3,opt,name=market_id,json=marketId,proto3" json:"market_id,omitempty"`
	// The subaccountId that this order belongs to
	SubaccountId string `protobuf:"bytes,4,opt,name=subaccount_id,json=subaccountId,proto3" json:"subaccount_id,omitempty"`
	// Price of the order
	Price string `protobuf:"bytes,5,opt,name=price,proto3" json:"price,omitempty"`
	// Quantity of the order
	Quantity string `protobuf:"bytes,6,opt,name=quantity,proto3" json:"quantity,omitempty"`
	// The amount of the quantity remaining unfilled
	UnfilledQuantity string `protobuf:"bytes,7,opt,name=unfilled_quantity,json=unfilledQuantity,proto3" json:"unfilled_quantity,omitempty"`
	// Trigger price is the trigger price used by stop/take orders. 0 if the
	// trigger price is not set.
	TriggerPrice string `protobuf:"bytes,8,opt,name=trigger_price,json=triggerPrice,proto3" json:"trigger_price,omitempty"`
	// Fee recipient address
	FeeRecipient string `protobuf:"bytes,9,opt,name=fee_recipient,json=feeRecipient,proto3" json:"fee_recipient,omitempty"`
	// Order state
	State string `protobuf:"bytes,10,opt,name=state,proto3" json:"state,omitempty"`
	// Order committed timestamp in UNIX millis.
	CreatedAt int64 `protobuf:"zigzag64,11,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	// Order updated timestamp in UNIX millis.
	UpdatedAt int64 `protobuf:"zigzag64,12,opt,name=updated_at,json=updatedAt,proto3" json:"updated_at,omitempty"`
	// contains filtered or unexported fields
}

func (*SpotLimitOrder) Descriptor deprecated 

func (*SpotLimitOrder) Descriptor() ([]byte, []int)

Deprecated: Use SpotLimitOrder.ProtoReflect.Descriptor instead.

func (*SpotLimitOrder) GetCreatedAt 

func (x *SpotLimitOrder) GetCreatedAt() int64

func (*SpotLimitOrder) GetFeeRecipient 

func (x *SpotLimitOrder) GetFeeRecipient() string

func (*SpotLimitOrder) GetMarketId 

func (x *SpotLimitOrder) GetMarketId() string

func (*SpotLimitOrder) GetOrderHash 

func (x *SpotLimitOrder) GetOrderHash() string

func (*SpotLimitOrder) GetOrderSide added in v1.23.6 

func (x *SpotLimitOrder) GetOrderSide() string

func (*SpotLimitOrder) GetPrice 

func (x *SpotLimitOrder) GetPrice() string

func (*SpotLimitOrder) GetQuantity 

func (x *SpotLimitOrder) GetQuantity() string

func (*SpotLimitOrder) GetState 

func (x *SpotLimitOrder) GetState() string

func (*SpotLimitOrder) GetSubaccountId 

func (x *SpotLimitOrder) GetSubaccountId() string

func (*SpotLimitOrder) GetTriggerPrice 

func (x *SpotLimitOrder) GetTriggerPrice() string

func (*SpotLimitOrder) GetUnfilledQuantity 

func (x *SpotLimitOrder) GetUnfilledQuantity() string

func (*SpotLimitOrder) GetUpdatedAt 

func (x *SpotLimitOrder) GetUpdatedAt() int64

func (*SpotLimitOrder) ProtoMessage 

func (*SpotLimitOrder) ProtoMessage()

func (*SpotLimitOrder) ProtoReflect 

func (x *SpotLimitOrder) ProtoReflect() protoreflect.Message

func (*SpotLimitOrder) Reset 

func (x *SpotLimitOrder) Reset()

func (*SpotLimitOrder) String 

func (x *SpotLimitOrder) String() string

type SpotLimitOrderbook 

type SpotLimitOrderbook struct {

	// Array of price levels for buys
	Buys []*PriceLevel `protobuf:"bytes,1,rep,name=buys,proto3" json:"buys,omitempty"`
	// Array of price levels for sells
	Sells []*PriceLevel `protobuf:"bytes,2,rep,name=sells,proto3" json:"sells,omitempty"`
	// contains filtered or unexported fields
}

func (*SpotLimitOrderbook) Descriptor deprecated 

func (*SpotLimitOrderbook) Descriptor() ([]byte, []int)

Deprecated: Use SpotLimitOrderbook.ProtoReflect.Descriptor instead.

func (*SpotLimitOrderbook) GetBuys 

func (x *SpotLimitOrderbook) GetBuys() []*PriceLevel

func (*SpotLimitOrderbook) GetSells 

func (x *SpotLimitOrderbook) GetSells() []*PriceLevel

func (*SpotLimitOrderbook) ProtoMessage 

func (*SpotLimitOrderbook) ProtoMessage()

func (*SpotLimitOrderbook) ProtoReflect 

func (x *SpotLimitOrderbook) ProtoReflect() protoreflect.Message

func (*SpotLimitOrderbook) Reset 

func (x *SpotLimitOrderbook) Reset()

func (*SpotLimitOrderbook) String 

func (x *SpotLimitOrderbook) String() string

type SpotMarketInfo 

type SpotMarketInfo struct {

	// SpotMarket ID is keccak265(baseDenom || quoteDenom)
	MarketId string `protobuf:"bytes,1,opt,name=market_id,json=marketId,proto3" json:"market_id,omitempty"`
	// The status of the market
	MarketStatus string `protobuf:"bytes,2,opt,name=market_status,json=marketStatus,proto3" json:"market_status,omitempty"`
	// A name of the pair in format AAA/BBB, where AAA is base asset, BBB is quote
	// asset.
	Ticker string `protobuf:"bytes,3,opt,name=ticker,proto3" json:"ticker,omitempty"`
	// Coin denom used for the base asset.
	BaseDenom string `protobuf:"bytes,4,opt,name=base_denom,json=baseDenom,proto3" json:"base_denom,omitempty"`
	// Token metadata for base asset, only for Ethereum-based assets
	BaseTokenMeta *TokenMeta `protobuf:"bytes,5,opt,name=base_token_meta,json=baseTokenMeta,proto3" json:"base_token_meta,omitempty"`
	// Coin denom used for the quote asset.
	QuoteDenom string `protobuf:"bytes,6,opt,name=quote_denom,json=quoteDenom,proto3" json:"quote_denom,omitempty"`
	// Token metadata for quote asset, only for Ethereum-based assets
	QuoteTokenMeta *TokenMeta `protobuf:"bytes,7,opt,name=quote_token_meta,json=quoteTokenMeta,proto3" json:"quote_token_meta,omitempty"`
	// Defines the fee percentage makers pay when trading (in quote asset)
	MakerFeeRate string `protobuf:"bytes,8,opt,name=maker_fee_rate,json=makerFeeRate,proto3" json:"maker_fee_rate,omitempty"`
	// Defines the fee percentage takers pay when trading (in quote asset)
	TakerFeeRate string `protobuf:"bytes,9,opt,name=taker_fee_rate,json=takerFeeRate,proto3" json:"taker_fee_rate,omitempty"`
	// Percentage of the transaction fee shared with the service provider
	ServiceProviderFee string `protobuf:"bytes,10,opt,name=service_provider_fee,json=serviceProviderFee,proto3" json:"service_provider_fee,omitempty"`
	// Defines the minimum required tick size for the order's price
	MinPriceTickSize string `protobuf:"bytes,11,opt,name=min_price_tick_size,json=minPriceTickSize,proto3" json:"min_price_tick_size,omitempty"`
	// Defines the minimum required tick size for the order's quantity
	MinQuantityTickSize string `protobuf:"bytes,12,opt,name=min_quantity_tick_size,json=minQuantityTickSize,proto3" json:"min_quantity_tick_size,omitempty"`
	// contains filtered or unexported fields
}

func (*SpotMarketInfo) Descriptor deprecated 

func (*SpotMarketInfo) Descriptor() ([]byte, []int)

Deprecated: Use SpotMarketInfo.ProtoReflect.Descriptor instead.

func (*SpotMarketInfo) GetBaseDenom 

func (x *SpotMarketInfo) GetBaseDenom() string

func (*SpotMarketInfo) GetBaseTokenMeta 

func (x *SpotMarketInfo) GetBaseTokenMeta() *TokenMeta

func (*SpotMarketInfo) GetMakerFeeRate 

func (x *SpotMarketInfo) GetMakerFeeRate() string

func (*SpotMarketInfo) GetMarketId 

func (x *SpotMarketInfo) GetMarketId() string

func (*SpotMarketInfo) GetMarketStatus 

func (x *SpotMarketInfo) GetMarketStatus() string

func (*SpotMarketInfo) GetMinPriceTickSize 

func (x *SpotMarketInfo) GetMinPriceTickSize() string

func (*SpotMarketInfo) GetMinQuantityTickSize 

func (x *SpotMarketInfo) GetMinQuantityTickSize() string

func (*SpotMarketInfo) GetQuoteDenom 

func (x *SpotMarketInfo) GetQuoteDenom() string

func (*SpotMarketInfo) GetQuoteTokenMeta 

func (x *SpotMarketInfo) GetQuoteTokenMeta() *TokenMeta

func (*SpotMarketInfo) GetServiceProviderFee 

func (x *SpotMarketInfo) GetServiceProviderFee() string

func (*SpotMarketInfo) GetTakerFeeRate 

func (x *SpotMarketInfo) GetTakerFeeRate() string

func (*SpotMarketInfo) GetTicker 

func (x *SpotMarketInfo) GetTicker() string

func (*SpotMarketInfo) ProtoMessage 

func (*SpotMarketInfo) ProtoMessage()

func (*SpotMarketInfo) ProtoReflect 

func (x *SpotMarketInfo) ProtoReflect() protoreflect.Message

func (*SpotMarketInfo) Reset 

func (x *SpotMarketInfo) Reset()

func (*SpotMarketInfo) String 

func (x *SpotMarketInfo) String() string

type SpotTrade 

type SpotTrade struct {

	// Maker order hash.
	OrderHash string `protobuf:"bytes,1,opt,name=order_hash,json=orderHash,proto3" json:"order_hash,omitempty"`
	// The subaccountId that executed the trade
	SubaccountId string `protobuf:"bytes,2,opt,name=subaccount_id,json=subaccountId,proto3" json:"subaccount_id,omitempty"`
	// The ID of the market that this trade is in
	MarketId string `protobuf:"bytes,3,opt,name=market_id,json=marketId,proto3" json:"market_id,omitempty"`
	// The execution type of the trade
	TradeExecutionType string `protobuf:"bytes,4,opt,name=trade_execution_type,json=tradeExecutionType,proto3" json:"trade_execution_type,omitempty"`
	// The direction the trade
	TradeDirection string `protobuf:"bytes,5,opt,name=trade_direction,json=tradeDirection,proto3" json:"trade_direction,omitempty"`
	// Price level at which trade has been executed
	Price *PriceLevel `protobuf:"bytes,6,opt,name=price,proto3" json:"price,omitempty"`
	// The fee associated with the trade (quote asset denom)
	Fee string `protobuf:"bytes,7,opt,name=fee,proto3" json:"fee,omitempty"`
	// Timestamp of trade execution in UNIX millis
	ExecutedAt int64 `protobuf:"zigzag64,8,opt,name=executed_at,json=executedAt,proto3" json:"executed_at,omitempty"`
	// Fee recipient address
	FeeRecipient string `protobuf:"bytes,9,opt,name=fee_recipient,json=feeRecipient,proto3" json:"fee_recipient,omitempty"`
	// contains filtered or unexported fields
}

func (*SpotTrade) Descriptor deprecated 

func (*SpotTrade) Descriptor() ([]byte, []int)

Deprecated: Use SpotTrade.ProtoReflect.Descriptor instead.

func (*SpotTrade) GetExecutedAt 

func (x *SpotTrade) GetExecutedAt() int64

func (*SpotTrade) GetFee 

func (x *SpotTrade) GetFee() string

func (*SpotTrade) GetFeeRecipient added in v1.32.0 

func (x *SpotTrade) GetFeeRecipient() string

func (*SpotTrade) GetMarketId 

func (x *SpotTrade) GetMarketId() string

func (*SpotTrade) GetOrderHash 

func (x *SpotTrade) GetOrderHash() string

func (*SpotTrade) GetPrice 

func (x *SpotTrade) GetPrice() *PriceLevel

func (*SpotTrade) GetSubaccountId 

func (x *SpotTrade) GetSubaccountId() string

func (*SpotTrade) GetTradeDirection 

func (x *SpotTrade) GetTradeDirection() string

func (*SpotTrade) GetTradeExecutionType 

func (x *SpotTrade) GetTradeExecutionType() string

func (*SpotTrade) ProtoMessage 

func (*SpotTrade) ProtoMessage()

func (*SpotTrade) ProtoReflect 

func (x *SpotTrade) ProtoReflect() protoreflect.Message

func (*SpotTrade) Reset 

func (x *SpotTrade) Reset()

func (*SpotTrade) String 

func (x *SpotTrade) String() string

type StreamMarketsRequest 

type StreamMarketsRequest struct {

	// List of market IDs for updates streaming, empty means 'ALL' spot markets
	MarketIds []string `protobuf:"bytes,1,rep,name=market_ids,json=marketIds,proto3" json:"market_ids,omitempty"`
	// contains filtered or unexported fields
}

func (*StreamMarketsRequest) Descriptor deprecated 

func (*StreamMarketsRequest) Descriptor() ([]byte, []int)

Deprecated: Use StreamMarketsRequest.ProtoReflect.Descriptor instead.

func (*StreamMarketsRequest) GetMarketIds 

func (x *StreamMarketsRequest) GetMarketIds() []string

func (*StreamMarketsRequest) ProtoMessage 

func (*StreamMarketsRequest) ProtoMessage()

func (*StreamMarketsRequest) ProtoReflect 

func (x *StreamMarketsRequest) ProtoReflect() protoreflect.Message

func (*StreamMarketsRequest) Reset 

func (x *StreamMarketsRequest) Reset()

func (*StreamMarketsRequest) String 

func (x *StreamMarketsRequest) String() string

type StreamMarketsResponse 

type StreamMarketsResponse struct {

	// Info about particular spot market
	Market *SpotMarketInfo `protobuf:"bytes,1,opt,name=market,proto3" json:"market,omitempty"`
	// Update type
	OperationType string `protobuf:"bytes,2,opt,name=operation_type,json=operationType,proto3" json:"operation_type,omitempty"`
	// Operation timestamp in UNIX millis.
	Timestamp int64 `protobuf:"zigzag64,3,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// contains filtered or unexported fields
}

func (*StreamMarketsResponse) Descriptor deprecated 

func (*StreamMarketsResponse) Descriptor() ([]byte, []int)

Deprecated: Use StreamMarketsResponse.ProtoReflect.Descriptor instead.

func (*StreamMarketsResponse) GetMarket 

func (x *StreamMarketsResponse) GetMarket() *SpotMarketInfo

func (*StreamMarketsResponse) GetOperationType 

func (x *StreamMarketsResponse) GetOperationType() string

func (*StreamMarketsResponse) GetTimestamp 

func (x *StreamMarketsResponse) GetTimestamp() int64

func (*StreamMarketsResponse) ProtoMessage 

func (*StreamMarketsResponse) ProtoMessage()

func (*StreamMarketsResponse) ProtoReflect 

func (x *StreamMarketsResponse) ProtoReflect() protoreflect.Message

func (*StreamMarketsResponse) Reset 

func (x *StreamMarketsResponse) Reset()

func (*StreamMarketsResponse) String 

func (x *StreamMarketsResponse) String() string

type StreamOrderbookRequest 

type StreamOrderbookRequest struct {

	// List of market IDs for orderbook streaming, empty means 'ALL' spot markets
	MarketIds []string `protobuf:"bytes,1,rep,name=market_ids,json=marketIds,proto3" json:"market_ids,omitempty"`
	// contains filtered or unexported fields
}

func (*StreamOrderbookRequest) Descriptor deprecated 

func (*StreamOrderbookRequest) Descriptor() ([]byte, []int)

Deprecated: Use StreamOrderbookRequest.ProtoReflect.Descriptor instead.

func (*StreamOrderbookRequest) GetMarketIds added in v1.27.5 

func (x *StreamOrderbookRequest) GetMarketIds() []string

func (*StreamOrderbookRequest) ProtoMessage 

func (*StreamOrderbookRequest) ProtoMessage()

func (*StreamOrderbookRequest) ProtoReflect 

func (x *StreamOrderbookRequest) ProtoReflect() protoreflect.Message

func (*StreamOrderbookRequest) Reset 

func (x *StreamOrderbookRequest) Reset()

func (*StreamOrderbookRequest) String 

func (x *StreamOrderbookRequest) String() string

type StreamOrderbookResponse 

type StreamOrderbookResponse struct {

	// Orderbook of a Spot Market
	Orderbook *SpotLimitOrderbook `protobuf:"bytes,1,opt,name=orderbook,proto3" json:"orderbook,omitempty"`
	// Order update type
	OperationType string `protobuf:"bytes,2,opt,name=operation_type,json=operationType,proto3" json:"operation_type,omitempty"`
	// Operation timestamp in UNIX millis.
	Timestamp int64 `protobuf:"zigzag64,3,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// MarketId of the market's orderbook
	MarketId string `protobuf:"bytes,4,opt,name=market_id,json=marketId,proto3" json:"market_id,omitempty"`
	// contains filtered or unexported fields
}

func (*StreamOrderbookResponse) Descriptor deprecated 

func (*StreamOrderbookResponse) Descriptor() ([]byte, []int)

Deprecated: Use StreamOrderbookResponse.ProtoReflect.Descriptor instead.

func (*StreamOrderbookResponse) GetMarketId added in v1.27.5 

func (x *StreamOrderbookResponse) GetMarketId() string

func (*StreamOrderbookResponse) GetOperationType 

func (x *StreamOrderbookResponse) GetOperationType() string

func (*StreamOrderbookResponse) GetOrderbook 

func (x *StreamOrderbookResponse) GetOrderbook() *SpotLimitOrderbook

func (*StreamOrderbookResponse) GetTimestamp 

func (x *StreamOrderbookResponse) GetTimestamp() int64

func (*StreamOrderbookResponse) ProtoMessage 

func (*StreamOrderbookResponse) ProtoMessage()

func (*StreamOrderbookResponse) ProtoReflect 

func (x *StreamOrderbookResponse) ProtoReflect() protoreflect.Message

func (*StreamOrderbookResponse) Reset 

func (x *StreamOrderbookResponse) Reset()

func (*StreamOrderbookResponse) String 

func (x *StreamOrderbookResponse) String() string

type StreamOrdersRequest 

type StreamOrdersRequest struct {

	// MarketId of the market's orderbook we want to fetch
	MarketId string `protobuf:"bytes,1,opt,name=market_id,json=marketId,proto3" json:"market_id,omitempty"`
	// Look for specific order side
	OrderSide string `protobuf:"bytes,2,opt,name=order_side,json=orderSide,proto3" json:"order_side,omitempty"`
	// Look for specific subaccountId of an order
	SubaccountId string `protobuf:"bytes,3,opt,name=subaccount_id,json=subaccountId,proto3" json:"subaccount_id,omitempty"`
	// contains filtered or unexported fields
}

func (*StreamOrdersRequest) Descriptor deprecated 

func (*StreamOrdersRequest) Descriptor() ([]byte, []int)

Deprecated: Use StreamOrdersRequest.ProtoReflect.Descriptor instead.

func (*StreamOrdersRequest) GetMarketId 

func (x *StreamOrdersRequest) GetMarketId() string

func (*StreamOrdersRequest) GetOrderSide added in v1.23.6 

func (x *StreamOrdersRequest) GetOrderSide() string

func (*StreamOrdersRequest) GetSubaccountId 

func (x *StreamOrdersRequest) GetSubaccountId() string

func (*StreamOrdersRequest) ProtoMessage 

func (*StreamOrdersRequest) ProtoMessage()

func (*StreamOrdersRequest) ProtoReflect 

func (x *StreamOrdersRequest) ProtoReflect() protoreflect.Message

func (*StreamOrdersRequest) Reset 

func (x *StreamOrdersRequest) Reset()

func (*StreamOrdersRequest) String 

func (x *StreamOrdersRequest) String() string

type StreamOrdersResponse 

type StreamOrdersResponse struct {

	// Updated market order
	Order *SpotLimitOrder `protobuf:"bytes,1,opt,name=order,proto3" json:"order,omitempty"`
	// Order update type
	OperationType string `protobuf:"bytes,2,opt,name=operation_type,json=operationType,proto3" json:"operation_type,omitempty"`
	// Operation timestamp in UNIX millis.
	Timestamp int64 `protobuf:"zigzag64,3,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// contains filtered or unexported fields
}

func (*StreamOrdersResponse) Descriptor deprecated 

func (*StreamOrdersResponse) Descriptor() ([]byte, []int)

Deprecated: Use StreamOrdersResponse.ProtoReflect.Descriptor instead.

func (*StreamOrdersResponse) GetOperationType 

func (x *StreamOrdersResponse) GetOperationType() string

func (*StreamOrdersResponse) GetOrder 

func (x *StreamOrdersResponse) GetOrder() *SpotLimitOrder

func (*StreamOrdersResponse) GetTimestamp 

func (x *StreamOrdersResponse) GetTimestamp() int64

func (*StreamOrdersResponse) ProtoMessage 

func (*StreamOrdersResponse) ProtoMessage()

func (*StreamOrdersResponse) ProtoReflect 

func (x *StreamOrdersResponse) ProtoReflect() protoreflect.Message

func (*StreamOrdersResponse) Reset 

func (x *StreamOrdersResponse) Reset()

func (*StreamOrdersResponse) String 

func (x *StreamOrdersResponse) String() string

type StreamTradesRequest 

type StreamTradesRequest struct {

	// MarketId of the market's orderbook we want to fetch
	MarketId string `protobuf:"bytes,1,opt,name=market_id,json=marketId,proto3" json:"market_id,omitempty"`
	// Filter by execution side of the trade
	ExecutionSide string `protobuf:"bytes,2,opt,name=execution_side,json=executionSide,proto3" json:"execution_side,omitempty"`
	// Filter by direction the trade
	Direction string `protobuf:"bytes,3,opt,name=direction,proto3" json:"direction,omitempty"`
	// SubaccountId of the trader we want to get the trades from
	SubaccountId string `protobuf:"bytes,4,opt,name=subaccount_id,json=subaccountId,proto3" json:"subaccount_id,omitempty"`
	// Skip will skip the first n item from the item result
	Skip uint64 `protobuf:"varint,5,opt,name=skip,proto3" json:"skip,omitempty"`
	// Limit is used to specify the maximum number of items to be returned.
	Limit int32 `protobuf:"zigzag32,6,opt,name=limit,proto3" json:"limit,omitempty"`
	// The starting timestamp in UNIX milliseconds that the trades must be equal or
	// older than
	StartTime int64 `protobuf:"zigzag64,7,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"`
	// The ending timestamp in UNIX milliseconds that the trades must be equal or
	// younger than
	EndTime int64 `protobuf:"zigzag64,8,opt,name=end_time,json=endTime,proto3" json:"end_time,omitempty"`
	// MarketIds of the markets of which we want to get trades
	MarketIds []string `protobuf:"bytes,9,rep,name=market_ids,json=marketIds,proto3" json:"market_ids,omitempty"`
	// Subaccount ids of traders we want to get trades
	SubaccountIds []string `protobuf:"bytes,10,rep,name=subaccount_ids,json=subaccountIds,proto3" json:"subaccount_ids,omitempty"`
	// contains filtered or unexported fields
}

func (*StreamTradesRequest) Descriptor deprecated 

func (*StreamTradesRequest) Descriptor() ([]byte, []int)

Deprecated: Use StreamTradesRequest.ProtoReflect.Descriptor instead.

func (*StreamTradesRequest) GetDirection 

func (x *StreamTradesRequest) GetDirection() string

func (*StreamTradesRequest) GetEndTime added in v1.32.1 

func (x *StreamTradesRequest) GetEndTime() int64

func (*StreamTradesRequest) GetExecutionSide 

func (x *StreamTradesRequest) GetExecutionSide() string

func (*StreamTradesRequest) GetLimit added in v1.27.5 

func (x *StreamTradesRequest) GetLimit() int32

func (*StreamTradesRequest) GetMarketId 

func (x *StreamTradesRequest) GetMarketId() string

func (*StreamTradesRequest) GetMarketIds added in v1.34.0 

func (x *StreamTradesRequest) GetMarketIds() []string

func (*StreamTradesRequest) GetSkip added in v1.27.5 

func (x *StreamTradesRequest) GetSkip() uint64

func (*StreamTradesRequest) GetStartTime added in v1.32.1 

func (x *StreamTradesRequest) GetStartTime() int64

func (*StreamTradesRequest) GetSubaccountId 

func (x *StreamTradesRequest) GetSubaccountId() string

func (*StreamTradesRequest) GetSubaccountIds added in v1.34.0 

func (x *StreamTradesRequest) GetSubaccountIds() []string

func (*StreamTradesRequest) ProtoMessage 

func (*StreamTradesRequest) ProtoMessage()

func (*StreamTradesRequest) ProtoReflect 

func (x *StreamTradesRequest) ProtoReflect() protoreflect.Message

func (*StreamTradesRequest) Reset 

func (x *StreamTradesRequest) Reset()

func (*StreamTradesRequest) String 

func (x *StreamTradesRequest) String() string

type StreamTradesResponse 

type StreamTradesResponse struct {

	// New spot market trade
	Trade *SpotTrade `protobuf:"bytes,1,opt,name=trade,proto3" json:"trade,omitempty"`
	// Executed trades update type
	OperationType string `protobuf:"bytes,2,opt,name=operation_type,json=operationType,proto3" json:"operation_type,omitempty"`
	// Operation timestamp in UNIX millis.
	Timestamp int64 `protobuf:"zigzag64,3,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// contains filtered or unexported fields
}

func (*StreamTradesResponse) Descriptor deprecated 

func (*StreamTradesResponse) Descriptor() ([]byte, []int)

Deprecated: Use StreamTradesResponse.ProtoReflect.Descriptor instead.

func (*StreamTradesResponse) GetOperationType 

func (x *StreamTradesResponse) GetOperationType() string

func (*StreamTradesResponse) GetTimestamp 

func (x *StreamTradesResponse) GetTimestamp() int64

func (*StreamTradesResponse) GetTrade 

func (x *StreamTradesResponse) GetTrade() *SpotTrade

func (*StreamTradesResponse) ProtoMessage 

func (*StreamTradesResponse) ProtoMessage()

func (*StreamTradesResponse) ProtoReflect 

func (x *StreamTradesResponse) ProtoReflect() protoreflect.Message

func (*StreamTradesResponse) Reset 

func (x *StreamTradesResponse) Reset()

func (*StreamTradesResponse) String 

func (x *StreamTradesResponse) String() string

type SubaccountOrdersListRequest 

type SubaccountOrdersListRequest struct {

	// subaccount ID to filter orders for specific subaccount
	SubaccountId string `protobuf:"bytes,1,opt,name=subaccount_id,json=subaccountId,proto3" json:"subaccount_id,omitempty"`
	// Market ID to filter orders for specific market
	MarketId string `protobuf:"bytes,2,opt,name=market_id,json=marketId,proto3" json:"market_id,omitempty"`
	// contains filtered or unexported fields
}

func (*SubaccountOrdersListRequest) Descriptor deprecated 

func (*SubaccountOrdersListRequest) Descriptor() ([]byte, []int)

Deprecated: Use SubaccountOrdersListRequest.ProtoReflect.Descriptor instead.

func (*SubaccountOrdersListRequest) GetMarketId 

func (x *SubaccountOrdersListRequest) GetMarketId() string

func (*SubaccountOrdersListRequest) GetSubaccountId 

func (x *SubaccountOrdersListRequest) GetSubaccountId() string

func (*SubaccountOrdersListRequest) ProtoMessage 

func (*SubaccountOrdersListRequest) ProtoMessage()

func (*SubaccountOrdersListRequest) ProtoReflect 

func (x *SubaccountOrdersListRequest) ProtoReflect() protoreflect.Message

func (*SubaccountOrdersListRequest) Reset 

func (x *SubaccountOrdersListRequest) Reset()

func (*SubaccountOrdersListRequest) String 

func (x *SubaccountOrdersListRequest) String() string

type SubaccountOrdersListResponse 

type SubaccountOrdersListResponse struct {

	// List of spot orders
	Orders []*SpotLimitOrder `protobuf:"bytes,1,rep,name=orders,proto3" json:"orders,omitempty"`
	// contains filtered or unexported fields
}

func (*SubaccountOrdersListResponse) Descriptor deprecated 

func (*SubaccountOrdersListResponse) Descriptor() ([]byte, []int)

Deprecated: Use SubaccountOrdersListResponse.ProtoReflect.Descriptor instead.

func (*SubaccountOrdersListResponse) GetOrders 

func (x *SubaccountOrdersListResponse) GetOrders() []*SpotLimitOrder

func (*SubaccountOrdersListResponse) ProtoMessage 

func (*SubaccountOrdersListResponse) ProtoMessage()

func (*SubaccountOrdersListResponse) ProtoReflect 

func (x *SubaccountOrdersListResponse) ProtoReflect() protoreflect.Message

func (*SubaccountOrdersListResponse) Reset 

func (x *SubaccountOrdersListResponse) Reset()

func (*SubaccountOrdersListResponse) String 

func (x *SubaccountOrdersListResponse) String() string

type SubaccountTradesListRequest 

type SubaccountTradesListRequest struct {

	// SubaccountId of the trader we want to get the trades from
	SubaccountId string `protobuf:"bytes,1,opt,name=subaccount_id,json=subaccountId,proto3" json:"subaccount_id,omitempty"`
	// Filter trades by market ID
	MarketId string `protobuf:"bytes,2,opt,name=market_id,json=marketId,proto3" json:"market_id,omitempty"`
	// Filter by execution type of trades
	ExecutionType string `protobuf:"bytes,3,opt,name=execution_type,json=executionType,proto3" json:"execution_type,omitempty"`
	// Filter by direction trades
	Direction string `protobuf:"bytes,4,opt,name=direction,proto3" json:"direction,omitempty"`
	// contains filtered or unexported fields
}

func (*SubaccountTradesListRequest) Descriptor deprecated 

func (*SubaccountTradesListRequest) Descriptor() ([]byte, []int)

Deprecated: Use SubaccountTradesListRequest.ProtoReflect.Descriptor instead.

func (*SubaccountTradesListRequest) GetDirection 

func (x *SubaccountTradesListRequest) GetDirection() string

func (*SubaccountTradesListRequest) GetExecutionType 

func (x *SubaccountTradesListRequest) GetExecutionType() string

func (*SubaccountTradesListRequest) GetMarketId 

func (x *SubaccountTradesListRequest) GetMarketId() string

func (*SubaccountTradesListRequest) GetSubaccountId 

func (x *SubaccountTradesListRequest) GetSubaccountId() string

func (*SubaccountTradesListRequest) ProtoMessage 

func (*SubaccountTradesListRequest) ProtoMessage()

func (*SubaccountTradesListRequest) ProtoReflect 

func (x *SubaccountTradesListRequest) ProtoReflect() protoreflect.Message

func (*SubaccountTradesListRequest) Reset 

func (x *SubaccountTradesListRequest) Reset()

func (*SubaccountTradesListRequest) String 

func (x *SubaccountTradesListRequest) String() string

type SubaccountTradesListResponse 

type SubaccountTradesListResponse struct {

	// List of spot market trades
	Trades []*SpotTrade `protobuf:"bytes,1,rep,name=trades,proto3" json:"trades,omitempty"`
	// contains filtered or unexported fields
}

func (*SubaccountTradesListResponse) Descriptor deprecated 

func (*SubaccountTradesListResponse) Descriptor() ([]byte, []int)

Deprecated: Use SubaccountTradesListResponse.ProtoReflect.Descriptor instead.

func (*SubaccountTradesListResponse) GetTrades 

func (x *SubaccountTradesListResponse) GetTrades() []*SpotTrade

func (*SubaccountTradesListResponse) ProtoMessage 

func (*SubaccountTradesListResponse) ProtoMessage()

func (*SubaccountTradesListResponse) ProtoReflect 

func (x *SubaccountTradesListResponse) ProtoReflect() protoreflect.Message

func (*SubaccountTradesListResponse) Reset 

func (x *SubaccountTradesListResponse) Reset()

func (*SubaccountTradesListResponse) String 

func (x *SubaccountTradesListResponse) String() string

type TokenMeta 

type TokenMeta struct {

	// Token full name
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Token Ethereum contract address
	Address string `protobuf:"bytes,2,opt,name=address,proto3" json:"address,omitempty"`
	// Token symbol short name
	Symbol string `protobuf:"bytes,3,opt,name=symbol,proto3" json:"symbol,omitempty"`
	Logo string `protobuf:"bytes,4,opt,name=logo,proto3" json:"logo,omitempty"`
	// Token decimals
	Decimals int32 `protobuf:"zigzag32,5,opt,name=decimals,proto3" json:"decimals,omitempty"`
	// Token metadata fetched timestamp in UNIX millis.
	UpdatedAt int64 `protobuf:"zigzag64,6,opt,name=updated_at,json=updatedAt,proto3" json:"updated_at,omitempty"`
	// contains filtered or unexported fields
}

func (*TokenMeta) Descriptor deprecated 

func (*TokenMeta) Descriptor() ([]byte, []int)

Deprecated: Use TokenMeta.ProtoReflect.Descriptor instead.

func (*TokenMeta) GetAddress 

func (x *TokenMeta) GetAddress() string

func (*TokenMeta) GetDecimals 

func (x *TokenMeta) GetDecimals() int32
func (x *TokenMeta) GetLogo() string

func (*TokenMeta) GetName 

func (x *TokenMeta) GetName() string

func (*TokenMeta) GetSymbol 

func (x *TokenMeta) GetSymbol() string

func (*TokenMeta) GetUpdatedAt 

func (x *TokenMeta) GetUpdatedAt() int64

func (*TokenMeta) ProtoMessage 

func (*TokenMeta) ProtoMessage()

func (*TokenMeta) ProtoReflect 

func (x *TokenMeta) ProtoReflect() protoreflect.Message

func (*TokenMeta) Reset 

func (x *TokenMeta) Reset()

func (*TokenMeta) String 

func (x *TokenMeta) String() string

type TradesRequest 

type TradesRequest struct {

	// MarketId of the market's orderbook we want to fetch
	MarketId string `protobuf:"bytes,1,opt,name=market_id,json=marketId,proto3" json:"market_id,omitempty"`
	// Filter by execution side of the trade
	ExecutionSide string `protobuf:"bytes,2,opt,name=execution_side,json=executionSide,proto3" json:"execution_side,omitempty"`
	// Filter by direction the trade
	Direction string `protobuf:"bytes,3,opt,name=direction,proto3" json:"direction,omitempty"`
	// SubaccountId of the trader we want to get the trades from
	SubaccountId string `protobuf:"bytes,4,opt,name=subaccount_id,json=subaccountId,proto3" json:"subaccount_id,omitempty"`
	// Skip will skip the first n item from the item result
	Skip uint64 `protobuf:"varint,5,opt,name=skip,proto3" json:"skip,omitempty"`
	// Limit is used to specify the maximum number of items to be returned.
	Limit int32 `protobuf:"zigzag32,6,opt,name=limit,proto3" json:"limit,omitempty"`
	// The starting timestamp in UNIX milliseconds that the trades must be equal or
	// older than
	StartTime int64 `protobuf:"zigzag64,7,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"`
	// The ending timestamp in UNIX milliseconds that the trades must be equal or
	// younger than
	EndTime int64 `protobuf:"zigzag64,8,opt,name=end_time,json=endTime,proto3" json:"end_time,omitempty"`
	// MarketIds of the markets of which we want to get trades
	MarketIds []string `protobuf:"bytes,9,rep,name=market_ids,json=marketIds,proto3" json:"market_ids,omitempty"`
	// Subaccount ids of traders we want to get trades
	SubaccountIds []string `protobuf:"bytes,10,rep,name=subaccount_ids,json=subaccountIds,proto3" json:"subaccount_ids,omitempty"`
	// contains filtered or unexported fields
}

func (*TradesRequest) Descriptor deprecated 

func (*TradesRequest) Descriptor() ([]byte, []int)

Deprecated: Use TradesRequest.ProtoReflect.Descriptor instead.

func (*TradesRequest) GetDirection 

func (x *TradesRequest) GetDirection() string

func (*TradesRequest) GetEndTime added in v1.32.1 

func (x *TradesRequest) GetEndTime() int64

func (*TradesRequest) GetExecutionSide 

func (x *TradesRequest) GetExecutionSide() string

func (*TradesRequest) GetLimit added in v1.27.5 

func (x *TradesRequest) GetLimit() int32

func (*TradesRequest) GetMarketId 

func (x *TradesRequest) GetMarketId() string

func (*TradesRequest) GetMarketIds added in v1.34.0 

func (x *TradesRequest) GetMarketIds() []string

func (*TradesRequest) GetSkip added in v1.27.5 

func (x *TradesRequest) GetSkip() uint64

func (*TradesRequest) GetStartTime added in v1.32.1 

func (x *TradesRequest) GetStartTime() int64

func (*TradesRequest) GetSubaccountId 

func (x *TradesRequest) GetSubaccountId() string

func (*TradesRequest) GetSubaccountIds added in v1.34.0 

func (x *TradesRequest) GetSubaccountIds() []string

func (*TradesRequest) ProtoMessage 

func (*TradesRequest) ProtoMessage()

func (*TradesRequest) ProtoReflect 

func (x *TradesRequest) ProtoReflect() protoreflect.Message

func (*TradesRequest) Reset 

func (x *TradesRequest) Reset()

func (*TradesRequest) String 

func (x *TradesRequest) String() string

type TradesResponse 

type TradesResponse struct {

	// Trades of a Spot Market
	Trades []*SpotTrade `protobuf:"bytes,1,rep,name=trades,proto3" json:"trades,omitempty"`
	// contains filtered or unexported fields
}

func (*TradesResponse) Descriptor deprecated 

func (*TradesResponse) Descriptor() ([]byte, []int)

Deprecated: Use TradesResponse.ProtoReflect.Descriptor instead.

func (*TradesResponse) GetTrades 

func (x *TradesResponse) GetTrades() []*SpotTrade

func (*TradesResponse) ProtoMessage 

func (*TradesResponse) ProtoMessage()

func (*TradesResponse) ProtoReflect 

func (x *TradesResponse) ProtoReflect() protoreflect.Message

func (*TradesResponse) Reset 

func (x *TradesResponse) Reset()

func (*TradesResponse) String 

func (x *TradesResponse) String() string

type UnimplementedInjectiveSpotExchangeRPCServer 

type UnimplementedInjectiveSpotExchangeRPCServer struct {
}

UnimplementedInjectiveSpotExchangeRPCServer must be embedded to have forward compatible implementations.

func (UnimplementedInjectiveSpotExchangeRPCServer) Market 

func (UnimplementedInjectiveSpotExchangeRPCServer) Market(context.Context, *MarketRequest) (*MarketResponse, error)

func (UnimplementedInjectiveSpotExchangeRPCServer) Markets 

func (UnimplementedInjectiveSpotExchangeRPCServer) Markets(context.Context, *MarketsRequest) (*MarketsResponse, error)

func (UnimplementedInjectiveSpotExchangeRPCServer) Orderbook 

func (UnimplementedInjectiveSpotExchangeRPCServer) Orderbook(context.Context, *OrderbookRequest) (*OrderbookResponse, error)

func (UnimplementedInjectiveSpotExchangeRPCServer) Orderbooks added in v1.34.0 

func (UnimplementedInjectiveSpotExchangeRPCServer) Orderbooks(context.Context, *OrderbooksRequest) (*OrderbooksResponse, error)

func (UnimplementedInjectiveSpotExchangeRPCServer) Orders 

func (UnimplementedInjectiveSpotExchangeRPCServer) Orders(context.Context, *OrdersRequest) (*OrdersResponse, error)

func (UnimplementedInjectiveSpotExchangeRPCServer) StreamMarkets 

func (UnimplementedInjectiveSpotExchangeRPCServer) StreamMarkets(*StreamMarketsRequest, InjectiveSpotExchangeRPC_StreamMarketsServer) error

func (UnimplementedInjectiveSpotExchangeRPCServer) StreamOrderbook 

func (UnimplementedInjectiveSpotExchangeRPCServer) StreamOrderbook(*StreamOrderbookRequest, InjectiveSpotExchangeRPC_StreamOrderbookServer) error

func (UnimplementedInjectiveSpotExchangeRPCServer) StreamOrders 

func (UnimplementedInjectiveSpotExchangeRPCServer) StreamOrders(*StreamOrdersRequest, InjectiveSpotExchangeRPC_StreamOrdersServer) error

func (UnimplementedInjectiveSpotExchangeRPCServer) StreamTrades 

func (UnimplementedInjectiveSpotExchangeRPCServer) StreamTrades(*StreamTradesRequest, InjectiveSpotExchangeRPC_StreamTradesServer) error

func (UnimplementedInjectiveSpotExchangeRPCServer) SubaccountOrdersList 

func (UnimplementedInjectiveSpotExchangeRPCServer) SubaccountOrdersList(context.Context, *SubaccountOrdersListRequest) (*SubaccountOrdersListResponse, error)

func (UnimplementedInjectiveSpotExchangeRPCServer) SubaccountTradesList 

func (UnimplementedInjectiveSpotExchangeRPCServer) SubaccountTradesList(context.Context, *SubaccountTradesListRequest) (*SubaccountTradesListResponse, error)

func (UnimplementedInjectiveSpotExchangeRPCServer) Trades 

func (UnimplementedInjectiveSpotExchangeRPCServer) Trades(context.Context, *TradesRequest) (*TradesResponse, error)

type UnsafeInjectiveSpotExchangeRPCServer 

type UnsafeInjectiveSpotExchangeRPCServer interface {
	// contains filtered or unexported methods
}

UnsafeInjectiveSpotExchangeRPCServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to InjectiveSpotExchangeRPCServer will result in compilation errors.

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.