injective_trading_rpcpb

package
v1.50.1 Latest Latest
Warning

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

 Go to latest Published: Jan 25, 2024 License: Apache-2.0 Imports: 16 Imported by: 0

Documentation

Overview

Package injective_trading_rpcpb is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Package injective_trading_rpcpb is a generated GoMock package.

Index

Constants

This section is empty.

Variables

View Source 
var File_injective_trading_rpc_proto protoreflect.FileDescriptor
View Source 
var InjectiveTradingRPC_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "injective_trading_rpc.InjectiveTradingRPC",
	HandlerType: (*InjectiveTradingRPCServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "ListTradingStrategies",
			Handler:    _InjectiveTradingRPC_ListTradingStrategies_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "injective_trading_rpc.proto",
}

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

Functions

func RegisterInjectiveTradingRPCHandler 

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

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

func RegisterInjectiveTradingRPCHandlerClient 

func RegisterInjectiveTradingRPCHandlerClient(ctx context.Context, mux *runtime.ServeMux, client InjectiveTradingRPCClient) error

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

func RegisterInjectiveTradingRPCHandlerFromEndpoint 

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

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

func RegisterInjectiveTradingRPCHandlerServer 

func RegisterInjectiveTradingRPCHandlerServer(ctx context.Context, mux *runtime.ServeMux, server InjectiveTradingRPCServer) error

RegisterInjectiveTradingRPCHandlerServer registers the http handlers for service InjectiveTradingRPC to "mux". UnaryRPC :call InjectiveTradingRPCServer 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 RegisterInjectiveTradingRPCHandlerFromEndpoint instead.

func RegisterInjectiveTradingRPCServer 

func RegisterInjectiveTradingRPCServer(s grpc.ServiceRegistrar, srv InjectiveTradingRPCServer)

Types

type InjectiveTradingRPCClient 

type InjectiveTradingRPCClient interface {
	// Lists all trading strategies
	ListTradingStrategies(ctx context.Context, in *ListTradingStrategiesRequest, opts ...grpc.CallOption) (*ListTradingStrategiesResponse, error)
}

InjectiveTradingRPCClient is the client API for InjectiveTradingRPC 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 NewInjectiveTradingRPCClient 

func NewInjectiveTradingRPCClient(cc grpc.ClientConnInterface) InjectiveTradingRPCClient

type InjectiveTradingRPCServer 

type InjectiveTradingRPCServer interface {
	// Lists all trading strategies
	ListTradingStrategies(context.Context, *ListTradingStrategiesRequest) (*ListTradingStrategiesResponse, error)
	// contains filtered or unexported methods
}

InjectiveTradingRPCServer is the server API for InjectiveTradingRPC service. All implementations must embed UnimplementedInjectiveTradingRPCServer for forward compatibility

type ListTradingStrategiesRequest 

type ListTradingStrategiesRequest struct {
	State string `protobuf:"bytes,1,opt,name=state,proto3" json:"state,omitempty"`
	// MarketId of the trading strategy
	MarketId string `protobuf:"bytes,2,opt,name=market_id,json=marketId,proto3" json:"market_id,omitempty"`
	// subaccount ID to filter by
	SubaccountId string `protobuf:"bytes,3,opt,name=subaccount_id,json=subaccountId,proto3" json:"subaccount_id,omitempty"`
	// Account address
	AccountAddress string `protobuf:"bytes,4,opt,name=account_address,json=accountAddress,proto3" json:"account_address,omitempty"`
	// Indicates whether the trading strategy is pending execution
	PendingExecution bool `protobuf:"varint,5,opt,name=pending_execution,json=pendingExecution,proto3" json:"pending_execution,omitempty"`
	// The starting timestamp in UNIX milliseconds for the creation time of the
	// trading strategy
	StartTime int64 `protobuf:"zigzag64,6,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"`
	// The ending timestamp in UNIX milliseconds for the creation time of the
	// trading strategy
	EndTime int64  `protobuf:"zigzag64,7,opt,name=end_time,json=endTime,proto3" json:"end_time,omitempty"`
	Limit   int32  `protobuf:"zigzag32,8,opt,name=limit,proto3" json:"limit,omitempty"`
	Skip    uint64 `protobuf:"varint,9,opt,name=skip,proto3" json:"skip,omitempty"`
	// contains filtered or unexported fields
}

func (*ListTradingStrategiesRequest) Descriptor deprecated 

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

Deprecated: Use ListTradingStrategiesRequest.ProtoReflect.Descriptor instead.

func (*ListTradingStrategiesRequest) GetAccountAddress 

func (x *ListTradingStrategiesRequest) GetAccountAddress() string

func (*ListTradingStrategiesRequest) GetEndTime 

func (x *ListTradingStrategiesRequest) GetEndTime() int64

func (*ListTradingStrategiesRequest) GetLimit 

func (x *ListTradingStrategiesRequest) GetLimit() int32

func (*ListTradingStrategiesRequest) GetMarketId 

func (x *ListTradingStrategiesRequest) GetMarketId() string

func (*ListTradingStrategiesRequest) GetPendingExecution 

func (x *ListTradingStrategiesRequest) GetPendingExecution() bool

func (*ListTradingStrategiesRequest) GetSkip 

func (x *ListTradingStrategiesRequest) GetSkip() uint64

func (*ListTradingStrategiesRequest) GetStartTime 

func (x *ListTradingStrategiesRequest) GetStartTime() int64

func (*ListTradingStrategiesRequest) GetState 

func (x *ListTradingStrategiesRequest) GetState() string

func (*ListTradingStrategiesRequest) GetSubaccountId 

func (x *ListTradingStrategiesRequest) GetSubaccountId() string

func (*ListTradingStrategiesRequest) ProtoMessage 

func (*ListTradingStrategiesRequest) ProtoMessage()

func (*ListTradingStrategiesRequest) ProtoReflect 

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

func (*ListTradingStrategiesRequest) Reset 

func (x *ListTradingStrategiesRequest) Reset()

func (*ListTradingStrategiesRequest) String 

func (x *ListTradingStrategiesRequest) String() string

type ListTradingStrategiesResponse 

type ListTradingStrategiesResponse struct {

	// The trading strategies
	Strategies []*TradingStrategy `protobuf:"bytes,1,rep,name=strategies,proto3" json:"strategies,omitempty"`
	Paging     *Paging            `protobuf:"bytes,2,opt,name=paging,proto3" json:"paging,omitempty"`
	// contains filtered or unexported fields
}

func (*ListTradingStrategiesResponse) Descriptor deprecated 

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

Deprecated: Use ListTradingStrategiesResponse.ProtoReflect.Descriptor instead.

func (*ListTradingStrategiesResponse) GetPaging 

func (x *ListTradingStrategiesResponse) GetPaging() *Paging

func (*ListTradingStrategiesResponse) GetStrategies 

func (x *ListTradingStrategiesResponse) GetStrategies() []*TradingStrategy

func (*ListTradingStrategiesResponse) ProtoMessage 

func (*ListTradingStrategiesResponse) ProtoMessage()

func (*ListTradingStrategiesResponse) ProtoReflect 

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

func (*ListTradingStrategiesResponse) Reset 

func (x *ListTradingStrategiesResponse) Reset()

func (*ListTradingStrategiesResponse) String 

func (x *ListTradingStrategiesResponse) String() string

type MockInjectiveTradingRPCClient 

type MockInjectiveTradingRPCClient struct {
	// contains filtered or unexported fields
}

MockInjectiveTradingRPCClient is a mock of InjectiveTradingRPCClient interface.

func NewMockInjectiveTradingRPCClient 

func NewMockInjectiveTradingRPCClient(ctrl *gomock.Controller) *MockInjectiveTradingRPCClient

NewMockInjectiveTradingRPCClient creates a new mock instance.

func (*MockInjectiveTradingRPCClient) EXPECT 

func (m *MockInjectiveTradingRPCClient) EXPECT() *MockInjectiveTradingRPCClientMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockInjectiveTradingRPCClient) ListTradingStrategies 

func (m *MockInjectiveTradingRPCClient) ListTradingStrategies(ctx context.Context, in *ListTradingStrategiesRequest, opts ...grpc.CallOption) (*ListTradingStrategiesResponse, error)

ListTradingStrategies mocks base method.

type MockInjectiveTradingRPCClientMockRecorder 

type MockInjectiveTradingRPCClientMockRecorder struct {
	// contains filtered or unexported fields
}

MockInjectiveTradingRPCClientMockRecorder is the mock recorder for MockInjectiveTradingRPCClient.

func (*MockInjectiveTradingRPCClientMockRecorder) ListTradingStrategies 

func (mr *MockInjectiveTradingRPCClientMockRecorder) ListTradingStrategies(ctx, in interface{}, opts ...interface{}) *gomock.Call

ListTradingStrategies indicates an expected call of ListTradingStrategies.

type MockInjectiveTradingRPCServer 

type MockInjectiveTradingRPCServer struct {
	// contains filtered or unexported fields
}

MockInjectiveTradingRPCServer is a mock of InjectiveTradingRPCServer interface.

func NewMockInjectiveTradingRPCServer 

func NewMockInjectiveTradingRPCServer(ctrl *gomock.Controller) *MockInjectiveTradingRPCServer

NewMockInjectiveTradingRPCServer creates a new mock instance.

func (*MockInjectiveTradingRPCServer) EXPECT 

func (m *MockInjectiveTradingRPCServer) EXPECT() *MockInjectiveTradingRPCServerMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockInjectiveTradingRPCServer) ListTradingStrategies 

func (m *MockInjectiveTradingRPCServer) ListTradingStrategies(arg0 context.Context, arg1 *ListTradingStrategiesRequest) (*ListTradingStrategiesResponse, error)

ListTradingStrategies mocks base method.

type MockInjectiveTradingRPCServerMockRecorder 

type MockInjectiveTradingRPCServerMockRecorder struct {
	// contains filtered or unexported fields
}

MockInjectiveTradingRPCServerMockRecorder is the mock recorder for MockInjectiveTradingRPCServer.

func (*MockInjectiveTradingRPCServerMockRecorder) ListTradingStrategies 

func (mr *MockInjectiveTradingRPCServerMockRecorder) ListTradingStrategies(arg0, arg1 interface{}) *gomock.Call

ListTradingStrategies indicates an expected call of ListTradingStrategies.

type MockUnsafeInjectiveTradingRPCServer 

type MockUnsafeInjectiveTradingRPCServer struct {
	// contains filtered or unexported fields
}

MockUnsafeInjectiveTradingRPCServer is a mock of UnsafeInjectiveTradingRPCServer interface.

func NewMockUnsafeInjectiveTradingRPCServer 

func NewMockUnsafeInjectiveTradingRPCServer(ctrl *gomock.Controller) *MockUnsafeInjectiveTradingRPCServer

NewMockUnsafeInjectiveTradingRPCServer creates a new mock instance.

func (*MockUnsafeInjectiveTradingRPCServer) EXPECT 

func (m *MockUnsafeInjectiveTradingRPCServer) EXPECT() *MockUnsafeInjectiveTradingRPCServerMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

type MockUnsafeInjectiveTradingRPCServerMockRecorder 

type MockUnsafeInjectiveTradingRPCServerMockRecorder struct {
	// contains filtered or unexported fields
}

MockUnsafeInjectiveTradingRPCServerMockRecorder is the mock recorder for MockUnsafeInjectiveTradingRPCServer.

type Paging 

type Paging struct {

	// total number of txs saved in database
	Total int64 `protobuf:"zigzag64,1,opt,name=total,proto3" json:"total,omitempty"`
	// can be either block height or index num
	From int32 `protobuf:"zigzag32,2,opt,name=from,proto3" json:"from,omitempty"`
	// can be either block height or index num
	To int32 `protobuf:"zigzag32,3,opt,name=to,proto3" json:"to,omitempty"`
	// count entries by subaccount, serving some places on helix
	CountBySubaccount int64 `protobuf:"zigzag64,4,opt,name=count_by_subaccount,json=countBySubaccount,proto3" json:"count_by_subaccount,omitempty"`
	// array of tokens to navigate to the next pages
	Next []string `protobuf:"bytes,5,rep,name=next,proto3" json:"next,omitempty"`
	// contains filtered or unexported fields
}

Paging defines the structure for required params for handling pagination

func (*Paging) Descriptor deprecated 

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

Deprecated: Use Paging.ProtoReflect.Descriptor instead.

func (*Paging) GetCountBySubaccount 

func (x *Paging) GetCountBySubaccount() int64

func (*Paging) GetFrom 

func (x *Paging) GetFrom() int32

func (*Paging) GetNext 

func (x *Paging) GetNext() []string

func (*Paging) GetTo 

func (x *Paging) GetTo() int32

func (*Paging) GetTotal 

func (x *Paging) GetTotal() int64

func (*Paging) ProtoMessage 

func (*Paging) ProtoMessage()

func (*Paging) ProtoReflect 

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

func (*Paging) Reset 

func (x *Paging) Reset()

func (*Paging) String 

func (x *Paging) String() string

type TradingStrategy 

type TradingStrategy struct {
	State string `protobuf:"bytes,1,opt,name=state,proto3" json:"state,omitempty"`
	// MarketId of the trading strategy
	MarketId string `protobuf:"bytes,2,opt,name=market_id,json=marketId,proto3" json:"market_id,omitempty"`
	// subaccount ID of the trading strategy
	SubaccountId string `protobuf:"bytes,3,opt,name=subaccount_id,json=subaccountId,proto3" json:"subaccount_id,omitempty"`
	// Account address
	AccountAddress string `protobuf:"bytes,4,opt,name=account_address,json=accountAddress,proto3" json:"account_address,omitempty"`
	// Contract address
	ContractAddress string `protobuf:"bytes,5,opt,name=contract_address,json=contractAddress,proto3" json:"contract_address,omitempty"`
	// Execution price of the trading strategy
	ExecutionPrice string `protobuf:"bytes,6,opt,name=execution_price,json=executionPrice,proto3" json:"execution_price,omitempty"`
	// Base quantity of the trading strategy
	BaseQuantity string `protobuf:"bytes,7,opt,name=base_quantity,json=baseQuantity,proto3" json:"base_quantity,omitempty"`
	// Quote quantity of the trading strategy
	QuoteQuantity string `protobuf:"bytes,20,opt,name=quote_quantity,json=quoteQuantity,proto3" json:"quote_quantity,omitempty"`
	// Lower bound of the trading strategy
	LowerBound string `protobuf:"bytes,8,opt,name=lower_bound,json=lowerBound,proto3" json:"lower_bound,omitempty"`
	// Upper bound of the trading strategy
	UpperBound string `protobuf:"bytes,9,opt,name=upper_bound,json=upperBound,proto3" json:"upper_bound,omitempty"`
	// Stop loss limit of the trading strategy
	StopLoss string `protobuf:"bytes,10,opt,name=stop_loss,json=stopLoss,proto3" json:"stop_loss,omitempty"`
	// Take profit limit of the trading strategy
	TakeProfit string `protobuf:"bytes,11,opt,name=take_profit,json=takeProfit,proto3" json:"take_profit,omitempty"`
	// Swap fee of the trading strategy
	SwapFee string `protobuf:"bytes,12,opt,name=swap_fee,json=swapFee,proto3" json:"swap_fee,omitempty"`
	// Base deposit at the time of closing the trading strategy
	BaseDeposit string `protobuf:"bytes,17,opt,name=base_deposit,json=baseDeposit,proto3" json:"base_deposit,omitempty"`
	// Quote deposit at the time of closing the trading strategy
	QuoteDeposit string `protobuf:"bytes,18,opt,name=quote_deposit,json=quoteDeposit,proto3" json:"quote_deposit,omitempty"`
	// Market mid price at the time of closing the trading strategy
	MarketMidPrice string `protobuf:"bytes,19,opt,name=market_mid_price,json=marketMidPrice,proto3" json:"market_mid_price,omitempty"`
	// Subscription quote quantity of the trading strategy
	SubscriptionQuoteQuantity string `` /* 139-byte string literal not displayed */
	// Subscription base quantity of the trading strategy
	SubscriptionBaseQuantity string `` /* 136-byte string literal not displayed */
	// Number of grid levels of the trading strategy
	NumberOfGridLevels string `protobuf:"bytes,23,opt,name=number_of_grid_levels,json=numberOfGridLevels,proto3" json:"number_of_grid_levels,omitempty"`
	// Indicates whether the trading strategy should exit with quote only
	ShouldExitWithQuoteOnly bool `` /* 138-byte string literal not displayed */
	// Indicates the reason for stopping the trading strategy
	StopReason string `protobuf:"bytes,25,opt,name=stop_reason,json=stopReason,proto3" json:"stop_reason,omitempty"`
	// Indicates whether the trading strategy is pending execution
	PendingExecution bool `protobuf:"varint,26,opt,name=pending_execution,json=pendingExecution,proto3" json:"pending_execution,omitempty"`
	// Block height when the strategy was created.
	CreatedHeight int64 `protobuf:"zigzag64,13,opt,name=created_height,json=createdHeight,proto3" json:"created_height,omitempty"`
	// Block height when the strategy was removed.
	RemovedHeight int64 `protobuf:"zigzag64,14,opt,name=removed_height,json=removedHeight,proto3" json:"removed_height,omitempty"`
	// UpdatedAt timestamp in UNIX millis.
	CreatedAt int64 `protobuf:"zigzag64,15,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	// UpdatedAt timestamp in UNIX millis.
	UpdatedAt int64 `protobuf:"zigzag64,16,opt,name=updated_at,json=updatedAt,proto3" json:"updated_at,omitempty"`
	// contains filtered or unexported fields
}

func (*TradingStrategy) Descriptor deprecated 

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

Deprecated: Use TradingStrategy.ProtoReflect.Descriptor instead.

func (*TradingStrategy) GetAccountAddress 

func (x *TradingStrategy) GetAccountAddress() string

func (*TradingStrategy) GetBaseDeposit 

func (x *TradingStrategy) GetBaseDeposit() string

func (*TradingStrategy) GetBaseQuantity 

func (x *TradingStrategy) GetBaseQuantity() string

func (*TradingStrategy) GetContractAddress 

func (x *TradingStrategy) GetContractAddress() string

func (*TradingStrategy) GetCreatedAt 

func (x *TradingStrategy) GetCreatedAt() int64

func (*TradingStrategy) GetCreatedHeight 

func (x *TradingStrategy) GetCreatedHeight() int64

func (*TradingStrategy) GetExecutionPrice 

func (x *TradingStrategy) GetExecutionPrice() string

func (*TradingStrategy) GetLowerBound 

func (x *TradingStrategy) GetLowerBound() string

func (*TradingStrategy) GetMarketId 

func (x *TradingStrategy) GetMarketId() string

func (*TradingStrategy) GetMarketMidPrice 

func (x *TradingStrategy) GetMarketMidPrice() string

func (*TradingStrategy) GetNumberOfGridLevels 

func (x *TradingStrategy) GetNumberOfGridLevels() string

func (*TradingStrategy) GetPendingExecution 

func (x *TradingStrategy) GetPendingExecution() bool

func (*TradingStrategy) GetQuoteDeposit 

func (x *TradingStrategy) GetQuoteDeposit() string

func (*TradingStrategy) GetQuoteQuantity 

func (x *TradingStrategy) GetQuoteQuantity() string

func (*TradingStrategy) GetRemovedHeight 

func (x *TradingStrategy) GetRemovedHeight() int64

func (*TradingStrategy) GetShouldExitWithQuoteOnly 

func (x *TradingStrategy) GetShouldExitWithQuoteOnly() bool

func (*TradingStrategy) GetState 

func (x *TradingStrategy) GetState() string

func (*TradingStrategy) GetStopLoss 

func (x *TradingStrategy) GetStopLoss() string

func (*TradingStrategy) GetStopReason 

func (x *TradingStrategy) GetStopReason() string

func (*TradingStrategy) GetSubaccountId 

func (x *TradingStrategy) GetSubaccountId() string

func (*TradingStrategy) GetSubscriptionBaseQuantity 

func (x *TradingStrategy) GetSubscriptionBaseQuantity() string

func (*TradingStrategy) GetSubscriptionQuoteQuantity 

func (x *TradingStrategy) GetSubscriptionQuoteQuantity() string

func (*TradingStrategy) GetSwapFee 

func (x *TradingStrategy) GetSwapFee() string

func (*TradingStrategy) GetTakeProfit 

func (x *TradingStrategy) GetTakeProfit() string

func (*TradingStrategy) GetUpdatedAt 

func (x *TradingStrategy) GetUpdatedAt() int64

func (*TradingStrategy) GetUpperBound 

func (x *TradingStrategy) GetUpperBound() string

func (*TradingStrategy) ProtoMessage 

func (*TradingStrategy) ProtoMessage()

func (*TradingStrategy) ProtoReflect 

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

func (*TradingStrategy) Reset 

func (x *TradingStrategy) Reset()

func (*TradingStrategy) String 

func (x *TradingStrategy) String() string

type UnimplementedInjectiveTradingRPCServer 

type UnimplementedInjectiveTradingRPCServer struct {
}

UnimplementedInjectiveTradingRPCServer must be embedded to have forward compatible implementations.

func (UnimplementedInjectiveTradingRPCServer) ListTradingStrategies 

func (UnimplementedInjectiveTradingRPCServer) ListTradingStrategies(context.Context, *ListTradingStrategiesRequest) (*ListTradingStrategiesResponse, error)

type UnsafeInjectiveTradingRPCServer 

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

UnsafeInjectiveTradingRPCServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to InjectiveTradingRPCServer 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.