v2

package
v0.49.0 Latest Latest
Warning

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

 Go to latest Published: Feb 28, 2022 License: MIT Imports: 10 Imported by: 6

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	AccountField_name = map[int32]string{
		0: "ACCOUNT_FIELD_UNSPECIFIED",
		1: "ACCOUNT_FIELD_ID",
		2: "ACCOUNT_FIELD_PARTY_ID",
		3: "ACCOUNT_FIELD_ASSET_ID",
		4: "ACCOUNT_FIELD_MARKET_ID",
		5: "ACCOUNT_FIELD_TYPE",
	}
	AccountField_value = map[string]int32{
		"ACCOUNT_FIELD_UNSPECIFIED": 0,
		"ACCOUNT_FIELD_ID":          1,
		"ACCOUNT_FIELD_PARTY_ID":    2,
		"ACCOUNT_FIELD_ASSET_ID":    3,
		"ACCOUNT_FIELD_MARKET_ID":   4,
		"ACCOUNT_FIELD_TYPE":        5,
	}
)

Enum value maps for AccountField.

View Source 
var File_data_node_api_v2_trading_data_proto protoreflect.FileDescriptor
View Source 
var TradingDataService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "datanode.api.v2.TradingDataService",
	HandlerType: (*TradingDataServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "OrderByMarketAndID",
			Handler:    _TradingDataService_OrderByMarketAndID_Handler,
		},
		{
			MethodName: "OrderByReference",
			Handler:    _TradingDataService_OrderByReference_Handler,
		},
		{
			MethodName: "OrdersByMarket",
			Handler:    _TradingDataService_OrdersByMarket_Handler,
		},
		{
			MethodName: "OrdersByParty",
			Handler:    _TradingDataService_OrdersByParty_Handler,
		},
		{
			MethodName: "OrderByID",
			Handler:    _TradingDataService_OrderByID_Handler,
		},
		{
			MethodName: "OrderVersionsByID",
			Handler:    _TradingDataService_OrderVersionsByID_Handler,
		},
		{
			MethodName: "QueryBalanceHistory",
			Handler:    _TradingDataService_QueryBalanceHistory_Handler,
		},
		{
			MethodName: "GetMarketDataHistoryByID",
			Handler:    _TradingDataService_GetMarketDataHistoryByID_Handler,
		},
		{
			MethodName: "GetNetworkLimits",
			Handler:    _TradingDataService_GetNetworkLimits_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "data-node/api/v2/trading_data.proto",
}

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

Functions

func RegisterTradingDataServiceServer 

func RegisterTradingDataServiceServer(s grpc.ServiceRegistrar, srv TradingDataServiceServer)

Types

type AccountField 

type AccountField int32

A list of the properties of an account, used for grouping 

const (
	AccountField_ACCOUNT_FIELD_UNSPECIFIED AccountField = 0
	AccountField_ACCOUNT_FIELD_ID          AccountField = 1
	AccountField_ACCOUNT_FIELD_PARTY_ID    AccountField = 2
	AccountField_ACCOUNT_FIELD_ASSET_ID    AccountField = 3
	AccountField_ACCOUNT_FIELD_MARKET_ID   AccountField = 4
	AccountField_ACCOUNT_FIELD_TYPE        AccountField = 5
)

func (AccountField) Descriptor 

func (AccountField) Descriptor() protoreflect.EnumDescriptor

func (AccountField) Enum 

func (x AccountField) Enum() *AccountField

func (AccountField) EnumDescriptor deprecated 

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

Deprecated: Use AccountField.Descriptor instead.

func (AccountField) Number 

func (x AccountField) Number() protoreflect.EnumNumber

func (AccountField) String 

func (x AccountField) String() string

func (AccountField) Type 

func (AccountField) Type() protoreflect.EnumType

type AccountFilter 

type AccountFilter struct {

	// Restrict accounts to those holding balances in this asset ID
	AssetId string `protobuf:"bytes,1,opt,name=asset_id,json=assetId,proto3" json:"asset_id,omitempty"`
	// Restrict accounts to those owned by the parties in this list (pass an empty list for no filter)
	PartyIds []string `protobuf:"bytes,2,rep,name=party_ids,json=partyIds,proto3" json:"party_ids,omitempty"`
	// Restrict accounts to those connected to the marketsin this list (pass an empty list for no filter)
	MarketIds []string `protobuf:"bytes,3,rep,name=market_ids,json=marketIds,proto3" json:"market_ids,omitempty"`
	// Restrict accounts to those connected to any of the types in this list (pass an empty list for no filter)
	AccountTypes []vega.AccountType `` /* 127-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*AccountFilter) Descriptor deprecated 

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

Deprecated: Use AccountFilter.ProtoReflect.Descriptor instead.

func (*AccountFilter) GetAccountTypes 

func (x *AccountFilter) GetAccountTypes() []vega.AccountType

func (*AccountFilter) GetAssetId 

func (x *AccountFilter) GetAssetId() string

func (*AccountFilter) GetMarketIds 

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

func (*AccountFilter) GetPartyIds 

func (x *AccountFilter) GetPartyIds() []string

func (*AccountFilter) ProtoMessage 

func (*AccountFilter) ProtoMessage()

func (*AccountFilter) ProtoReflect 

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

func (*AccountFilter) Reset 

func (x *AccountFilter) Reset()

func (*AccountFilter) String 

func (x *AccountFilter) String() string

type AggregatedBalance 

type AggregatedBalance struct {

	// Timestamp to of block the balance is referring to, in nanoseconds since the epoch
	Timestamp int64 `protobuf:"varint,1,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// The balance of the set of requested accounts at the time above
	Balance string `protobuf:"bytes,2,opt,name=balance,proto3" json:"balance,omitempty"`
	// If grouping by account ID, the account ID
	AccountId *string `protobuf:"bytes,3,opt,name=account_id,json=accountId,proto3,oneof" json:"account_id,omitempty"`
	// If grouping by party, the party ID
	PartyId *string `protobuf:"bytes,4,opt,name=party_id,json=partyId,proto3,oneof" json:"party_id,omitempty"`
	// If grouping by asset, the asset ID
	AssetId *string `protobuf:"bytes,5,opt,name=asset_id,json=assetId,proto3,oneof" json:"asset_id,omitempty"`
	// If grouping by market, the market ID
	MarketId *string `protobuf:"bytes,6,opt,name=market_id,json=marketId,proto3,oneof" json:"market_id,omitempty"`
	// If grouping by account type, the account type
	AccountType vega.AccountType `protobuf:"varint,7,opt,name=account_type,json=accountType,proto3,enum=vega.AccountType" json:"account_type,omitempty"`
	// contains filtered or unexported fields
}

func (*AggregatedBalance) Descriptor deprecated 

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

Deprecated: Use AggregatedBalance.ProtoReflect.Descriptor instead.

func (*AggregatedBalance) GetAccountId 

func (x *AggregatedBalance) GetAccountId() string

func (*AggregatedBalance) GetAccountType 

func (x *AggregatedBalance) GetAccountType() vega.AccountType

func (*AggregatedBalance) GetAssetId 

func (x *AggregatedBalance) GetAssetId() string

func (*AggregatedBalance) GetBalance 

func (x *AggregatedBalance) GetBalance() string

func (*AggregatedBalance) GetMarketId 

func (x *AggregatedBalance) GetMarketId() string

func (*AggregatedBalance) GetPartyId 

func (x *AggregatedBalance) GetPartyId() string

func (*AggregatedBalance) GetTimestamp 

func (x *AggregatedBalance) GetTimestamp() int64

func (*AggregatedBalance) ProtoMessage 

func (*AggregatedBalance) ProtoMessage()

func (*AggregatedBalance) ProtoReflect 

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

func (*AggregatedBalance) Reset 

func (x *AggregatedBalance) Reset()

func (*AggregatedBalance) String 

func (x *AggregatedBalance) String() string

type GetMarketDataHistoryByIDRequest 

type GetMarketDataHistoryByIDRequest struct {

	// Market identifier, required field
	MarketId string `protobuf:"bytes,1,opt,name=market_id,json=marketId,proto3" json:"market_id,omitempty"`
	// Optional Unix time in nanoseconds
	StartTimestamp *int64 `protobuf:"varint,2,opt,name=start_timestamp,json=startTimestamp,proto3,oneof" json:"start_timestamp,omitempty"`
	// Optional Unix time in nanoseconds
	EndTimestamp *int64 `protobuf:"varint,3,opt,name=end_timestamp,json=endTimestamp,proto3,oneof" json:"end_timestamp,omitempty"`
	// Optional pagination control
	Pagination *Pagination `protobuf:"bytes,4,opt,name=pagination,proto3,oneof" json:"pagination,omitempty"`
	// contains filtered or unexported fields
}

Request for Market Data History

func (*GetMarketDataHistoryByIDRequest) Descriptor deprecated 

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

Deprecated: Use GetMarketDataHistoryByIDRequest.ProtoReflect.Descriptor instead.

func (*GetMarketDataHistoryByIDRequest) GetEndTimestamp 

func (x *GetMarketDataHistoryByIDRequest) GetEndTimestamp() int64

func (*GetMarketDataHistoryByIDRequest) GetMarketId 

func (x *GetMarketDataHistoryByIDRequest) GetMarketId() string

func (*GetMarketDataHistoryByIDRequest) GetPagination 

func (x *GetMarketDataHistoryByIDRequest) GetPagination() *Pagination

func (*GetMarketDataHistoryByIDRequest) GetStartTimestamp 

func (x *GetMarketDataHistoryByIDRequest) GetStartTimestamp() int64

func (*GetMarketDataHistoryByIDRequest) ProtoMessage 

func (*GetMarketDataHistoryByIDRequest) ProtoMessage()

func (*GetMarketDataHistoryByIDRequest) ProtoReflect 

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

func (*GetMarketDataHistoryByIDRequest) Reset 

func (x *GetMarketDataHistoryByIDRequest) Reset()

func (*GetMarketDataHistoryByIDRequest) String 

func (x *GetMarketDataHistoryByIDRequest) String() string

type GetMarketDataHistoryByIDResponse 

type GetMarketDataHistoryByIDResponse struct {
	MarketData []*vega.MarketData `protobuf:"bytes,1,rep,name=market_data,json=marketData,proto3" json:"market_data,omitempty"`
	// contains filtered or unexported fields
}

Response for Market Data History

func (*GetMarketDataHistoryByIDResponse) Descriptor deprecated 

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

Deprecated: Use GetMarketDataHistoryByIDResponse.ProtoReflect.Descriptor instead.

func (*GetMarketDataHistoryByIDResponse) GetMarketData 

func (x *GetMarketDataHistoryByIDResponse) GetMarketData() []*vega.MarketData

func (*GetMarketDataHistoryByIDResponse) ProtoMessage 

func (*GetMarketDataHistoryByIDResponse) ProtoMessage()

func (*GetMarketDataHistoryByIDResponse) ProtoReflect 

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

func (*GetMarketDataHistoryByIDResponse) Reset 

func (x *GetMarketDataHistoryByIDResponse) Reset()

func (*GetMarketDataHistoryByIDResponse) String 

func (x *GetMarketDataHistoryByIDResponse) String() string

type GetNetworkLimitsRequest 

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

Request for the current network limits

func (*GetNetworkLimitsRequest) Descriptor deprecated 

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

Deprecated: Use GetNetworkLimitsRequest.ProtoReflect.Descriptor instead.

func (*GetNetworkLimitsRequest) ProtoMessage 

func (*GetNetworkLimitsRequest) ProtoMessage()

func (*GetNetworkLimitsRequest) ProtoReflect 

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

func (*GetNetworkLimitsRequest) Reset 

func (x *GetNetworkLimitsRequest) Reset()

func (*GetNetworkLimitsRequest) String 

func (x *GetNetworkLimitsRequest) String() string

type GetNetworkLimitsResponse 

type GetNetworkLimitsResponse struct {
	Limits *vega.NetworkLimits `protobuf:"bytes,1,opt,name=limits,proto3" json:"limits,omitempty"`
	// contains filtered or unexported fields
}

Response for the current network limits

func (*GetNetworkLimitsResponse) Descriptor deprecated 

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

Deprecated: Use GetNetworkLimitsResponse.ProtoReflect.Descriptor instead.

func (*GetNetworkLimitsResponse) GetLimits 

func (x *GetNetworkLimitsResponse) GetLimits() *vega.NetworkLimits

func (*GetNetworkLimitsResponse) ProtoMessage 

func (*GetNetworkLimitsResponse) ProtoMessage()

func (*GetNetworkLimitsResponse) ProtoReflect 

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

func (*GetNetworkLimitsResponse) Reset 

func (x *GetNetworkLimitsResponse) Reset()

func (*GetNetworkLimitsResponse) String 

func (x *GetNetworkLimitsResponse) String() string

type OrderByIDRequest 

type OrderByIDRequest struct {

	// Order identifier, required field
	OrderId string `protobuf:"bytes,1,opt,name=order_id,json=orderId,proto3" json:"order_id,omitempty"`
	// Version of the order:
	// - Set `version` to 0 for most recent version of the order
	// - Set `1` for original version of the order
	// - Set `2` for first amendment, `3` for second amendment, etc
	Version uint64 `protobuf:"varint,2,opt,name=version,proto3" json:"version,omitempty"`
	// contains filtered or unexported fields
}

Request for an order with the specified order identifier Optionally, return a specific version of the order with the `version` field

func (*OrderByIDRequest) Descriptor deprecated 

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

Deprecated: Use OrderByIDRequest.ProtoReflect.Descriptor instead.

func (*OrderByIDRequest) GetOrderId 

func (x *OrderByIDRequest) GetOrderId() string

func (*OrderByIDRequest) GetVersion 

func (x *OrderByIDRequest) GetVersion() uint64

func (*OrderByIDRequest) ProtoMessage 

func (*OrderByIDRequest) ProtoMessage()

func (*OrderByIDRequest) ProtoReflect 

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

func (*OrderByIDRequest) Reset 

func (x *OrderByIDRequest) Reset()

func (*OrderByIDRequest) String 

func (x *OrderByIDRequest) String() string

type OrderByIDResponse 

type OrderByIDResponse struct {
	Order *vega.Order `protobuf:"bytes,1,opt,name=order,proto3" json:"order,omitempty"`
	// contains filtered or unexported fields
}

func (*OrderByIDResponse) Descriptor deprecated 

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

Deprecated: Use OrderByIDResponse.ProtoReflect.Descriptor instead.

func (*OrderByIDResponse) GetOrder 

func (x *OrderByIDResponse) GetOrder() *vega.Order

func (*OrderByIDResponse) ProtoMessage 

func (*OrderByIDResponse) ProtoMessage()

func (*OrderByIDResponse) ProtoReflect 

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

func (*OrderByIDResponse) Reset 

func (x *OrderByIDResponse) Reset()

func (*OrderByIDResponse) String 

func (x *OrderByIDResponse) String() string

type OrderByMarketAndIDRequest 

type OrderByMarketAndIDRequest struct {

	// Market identifier, required field
	MarketId string `protobuf:"bytes,1,opt,name=market_id,json=marketId,proto3" json:"market_id,omitempty"`
	// Order identifier, required field
	OrderId string `protobuf:"bytes,2,opt,name=order_id,json=orderId,proto3" json:"order_id,omitempty"`
	// contains filtered or unexported fields
}

Request for an order on a market given an order identifier

func (*OrderByMarketAndIDRequest) Descriptor deprecated 

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

Deprecated: Use OrderByMarketAndIDRequest.ProtoReflect.Descriptor instead.

func (*OrderByMarketAndIDRequest) GetMarketId 

func (x *OrderByMarketAndIDRequest) GetMarketId() string

func (*OrderByMarketAndIDRequest) GetOrderId 

func (x *OrderByMarketAndIDRequest) GetOrderId() string

func (*OrderByMarketAndIDRequest) ProtoMessage 

func (*OrderByMarketAndIDRequest) ProtoMessage()

func (*OrderByMarketAndIDRequest) ProtoReflect 

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

func (*OrderByMarketAndIDRequest) Reset 

func (x *OrderByMarketAndIDRequest) Reset()

func (*OrderByMarketAndIDRequest) String 

func (x *OrderByMarketAndIDRequest) String() string

type OrderByMarketAndIDResponse 

type OrderByMarketAndIDResponse struct {

	// An order, if found
	Order *vega.Order `protobuf:"bytes,1,opt,name=order,proto3" json:"order,omitempty"`
	// contains filtered or unexported fields
}

Response for an order on a market given an order identifier

func (*OrderByMarketAndIDResponse) Descriptor deprecated 

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

Deprecated: Use OrderByMarketAndIDResponse.ProtoReflect.Descriptor instead.

func (*OrderByMarketAndIDResponse) GetOrder 

func (x *OrderByMarketAndIDResponse) GetOrder() *vega.Order

func (*OrderByMarketAndIDResponse) ProtoMessage 

func (*OrderByMarketAndIDResponse) ProtoMessage()

func (*OrderByMarketAndIDResponse) ProtoReflect 

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

func (*OrderByMarketAndIDResponse) Reset 

func (x *OrderByMarketAndIDResponse) Reset()

func (*OrderByMarketAndIDResponse) String 

func (x *OrderByMarketAndIDResponse) String() string

type OrderByReferenceRequest 

type OrderByReferenceRequest struct {

	// Unique reference, required field
	Reference string `protobuf:"bytes,1,opt,name=reference,proto3" json:"reference,omitempty"`
	// contains filtered or unexported fields
}

Request for an order given an order reference

func (*OrderByReferenceRequest) Descriptor deprecated 

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

Deprecated: Use OrderByReferenceRequest.ProtoReflect.Descriptor instead.

func (*OrderByReferenceRequest) GetReference 

func (x *OrderByReferenceRequest) GetReference() string

func (*OrderByReferenceRequest) ProtoMessage 

func (*OrderByReferenceRequest) ProtoMessage()

func (*OrderByReferenceRequest) ProtoReflect 

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

func (*OrderByReferenceRequest) Reset 

func (x *OrderByReferenceRequest) Reset()

func (*OrderByReferenceRequest) String 

func (x *OrderByReferenceRequest) String() string

type OrderByReferenceResponse 

type OrderByReferenceResponse struct {

	// An order, if found
	Order *vega.Order `protobuf:"bytes,1,opt,name=order,proto3" json:"order,omitempty"`
	// contains filtered or unexported fields
}

Response for an order given an order reference

func (*OrderByReferenceResponse) Descriptor deprecated 

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

Deprecated: Use OrderByReferenceResponse.ProtoReflect.Descriptor instead.

func (*OrderByReferenceResponse) GetOrder 

func (x *OrderByReferenceResponse) GetOrder() *vega.Order

func (*OrderByReferenceResponse) ProtoMessage 

func (*OrderByReferenceResponse) ProtoMessage()

func (*OrderByReferenceResponse) ProtoReflect 

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

func (*OrderByReferenceResponse) Reset 

func (x *OrderByReferenceResponse) Reset()

func (*OrderByReferenceResponse) String 

func (x *OrderByReferenceResponse) String() string

type OrderVersionsByIDRequest 

type OrderVersionsByIDRequest struct {

	// Order identifier, required field
	OrderId string `protobuf:"bytes,1,opt,name=order_id,json=orderId,proto3" json:"order_id,omitempty"`
	// Pagination controls
	Pagination *Pagination `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"`
	// contains filtered or unexported fields
}

Request for a list of all versions of an order given the specified order identifier

func (*OrderVersionsByIDRequest) Descriptor deprecated 

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

Deprecated: Use OrderVersionsByIDRequest.ProtoReflect.Descriptor instead.

func (*OrderVersionsByIDRequest) GetOrderId 

func (x *OrderVersionsByIDRequest) GetOrderId() string

func (*OrderVersionsByIDRequest) GetPagination 

func (x *OrderVersionsByIDRequest) GetPagination() *Pagination

func (*OrderVersionsByIDRequest) ProtoMessage 

func (*OrderVersionsByIDRequest) ProtoMessage()

func (*OrderVersionsByIDRequest) ProtoReflect 

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

func (*OrderVersionsByIDRequest) Reset 

func (x *OrderVersionsByIDRequest) Reset()

func (*OrderVersionsByIDRequest) String 

func (x *OrderVersionsByIDRequest) String() string

type OrderVersionsByIDResponse 

type OrderVersionsByIDResponse struct {

	// A list of 0 or more orders (list will contain the same order but with different versions, if it has been amended)
	Orders []*vega.Order `protobuf:"bytes,1,rep,name=orders,proto3" json:"orders,omitempty"`
	// contains filtered or unexported fields
}

Response to a request for a list of all versions of an order

func (*OrderVersionsByIDResponse) Descriptor deprecated 

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

Deprecated: Use OrderVersionsByIDResponse.ProtoReflect.Descriptor instead.

func (*OrderVersionsByIDResponse) GetOrders 

func (x *OrderVersionsByIDResponse) GetOrders() []*vega.Order

func (*OrderVersionsByIDResponse) ProtoMessage 

func (*OrderVersionsByIDResponse) ProtoMessage()

func (*OrderVersionsByIDResponse) ProtoReflect 

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

func (*OrderVersionsByIDResponse) Reset 

func (x *OrderVersionsByIDResponse) Reset()

func (*OrderVersionsByIDResponse) String 

func (x *OrderVersionsByIDResponse) String() string

type OrdersByMarketRequest 

type OrdersByMarketRequest struct {

	// Market identifier, required field
	MarketId string `protobuf:"bytes,1,opt,name=market_id,json=marketId,proto3" json:"market_id,omitempty"`
	// Optional pagination controls
	Pagination *Pagination `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"`
	// contains filtered or unexported fields
}

Request for a list of orders for a market

func (*OrdersByMarketRequest) Descriptor deprecated 

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

Deprecated: Use OrdersByMarketRequest.ProtoReflect.Descriptor instead.

func (*OrdersByMarketRequest) GetMarketId 

func (x *OrdersByMarketRequest) GetMarketId() string

func (*OrdersByMarketRequest) GetPagination 

func (x *OrdersByMarketRequest) GetPagination() *Pagination

func (*OrdersByMarketRequest) ProtoMessage 

func (*OrdersByMarketRequest) ProtoMessage()

func (*OrdersByMarketRequest) ProtoReflect 

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

func (*OrdersByMarketRequest) Reset 

func (x *OrdersByMarketRequest) Reset()

func (*OrdersByMarketRequest) String 

func (x *OrdersByMarketRequest) String() string

type OrdersByMarketResponse 

type OrdersByMarketResponse struct {

	// A list of 0 or more orders
	Orders []*vega.Order `protobuf:"bytes,1,rep,name=orders,proto3" json:"orders,omitempty"`
	// contains filtered or unexported fields
}

Response for a list of orders for a market

func (*OrdersByMarketResponse) Descriptor deprecated 

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

Deprecated: Use OrdersByMarketResponse.ProtoReflect.Descriptor instead.

func (*OrdersByMarketResponse) GetOrders 

func (x *OrdersByMarketResponse) GetOrders() []*vega.Order

func (*OrdersByMarketResponse) ProtoMessage 

func (*OrdersByMarketResponse) ProtoMessage()

func (*OrdersByMarketResponse) ProtoReflect 

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

func (*OrdersByMarketResponse) Reset 

func (x *OrdersByMarketResponse) Reset()

func (*OrdersByMarketResponse) String 

func (x *OrdersByMarketResponse) String() string

type OrdersByPartyRequest 

type OrdersByPartyRequest struct {

	// Party identifier, required field
	PartyId string `protobuf:"bytes,1,opt,name=party_id,json=partyId,proto3" json:"party_id,omitempty"`
	// Pagination controls
	Pagination *Pagination `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"`
	// contains filtered or unexported fields
}

Request for a list of orders for a party

func (*OrdersByPartyRequest) Descriptor deprecated 

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

Deprecated: Use OrdersByPartyRequest.ProtoReflect.Descriptor instead.

func (*OrdersByPartyRequest) GetPagination 

func (x *OrdersByPartyRequest) GetPagination() *Pagination

func (*OrdersByPartyRequest) GetPartyId 

func (x *OrdersByPartyRequest) GetPartyId() string

func (*OrdersByPartyRequest) ProtoMessage 

func (*OrdersByPartyRequest) ProtoMessage()

func (*OrdersByPartyRequest) ProtoReflect 

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

func (*OrdersByPartyRequest) Reset 

func (x *OrdersByPartyRequest) Reset()

func (*OrdersByPartyRequest) String 

func (x *OrdersByPartyRequest) String() string

type OrdersByPartyResponse 

type OrdersByPartyResponse struct {

	// A list of 0 or more orders
	Orders []*vega.Order `protobuf:"bytes,1,rep,name=orders,proto3" json:"orders,omitempty"`
	// contains filtered or unexported fields
}

Response for a list of orders for a party

func (*OrdersByPartyResponse) Descriptor deprecated 

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

Deprecated: Use OrdersByPartyResponse.ProtoReflect.Descriptor instead.

func (*OrdersByPartyResponse) GetOrders 

func (x *OrdersByPartyResponse) GetOrders() []*vega.Order

func (*OrdersByPartyResponse) ProtoMessage 

func (*OrdersByPartyResponse) ProtoMessage()

func (*OrdersByPartyResponse) ProtoReflect 

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

func (*OrdersByPartyResponse) Reset 

func (x *OrdersByPartyResponse) Reset()

func (*OrdersByPartyResponse) String 

func (x *OrdersByPartyResponse) String() string

type Pagination 

type Pagination struct {

	// Skip the number of records specified, default is 0
	Skip uint64 `protobuf:"varint,1,opt,name=skip,proto3" json:"skip,omitempty"`
	// Limit the number of returned records to the value specified, default is 50
	Limit uint64 `protobuf:"varint,2,opt,name=limit,proto3" json:"limit,omitempty"`
	// Descending reverses the order of the records returned,
	// default is true, if false the results will be returned in ascending order
	Descending bool `protobuf:"varint,3,opt,name=descending,proto3" json:"descending,omitempty"`
	// contains filtered or unexported fields
}

Pagination controls

func (*Pagination) Descriptor deprecated 

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

Deprecated: Use Pagination.ProtoReflect.Descriptor instead.

func (*Pagination) GetDescending 

func (x *Pagination) GetDescending() bool

func (*Pagination) GetLimit 

func (x *Pagination) GetLimit() uint64

func (*Pagination) GetSkip 

func (x *Pagination) GetSkip() uint64

func (*Pagination) ProtoMessage 

func (*Pagination) ProtoMessage()

func (*Pagination) ProtoReflect 

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

func (*Pagination) Reset 

func (x *Pagination) Reset()

func (*Pagination) String 

func (x *Pagination) String() string

type QueryBalanceHistoryRequest 

type QueryBalanceHistoryRequest struct {

	// Limit the accounts considered according to the filter supplied
	Filter *AccountFilter `protobuf:"bytes,1,opt,name=filter,proto3" json:"filter,omitempty"`
	// By default the net balances of all the accounts specified by the filter are returned.
	// If a list if fields is given in group_by, split out those balances by the supplied crietera.
	GroupBy []AccountField `protobuf:"varint,2,rep,packed,name=group_by,json=groupBy,proto3,enum=datanode.api.v2.AccountField" json:"group_by,omitempty"`
	// contains filtered or unexported fields
}

func (*QueryBalanceHistoryRequest) Descriptor deprecated 

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

Deprecated: Use QueryBalanceHistoryRequest.ProtoReflect.Descriptor instead.

func (*QueryBalanceHistoryRequest) GetFilter 

func (x *QueryBalanceHistoryRequest) GetFilter() *AccountFilter

func (*QueryBalanceHistoryRequest) GetGroupBy 

func (x *QueryBalanceHistoryRequest) GetGroupBy() []AccountField

func (*QueryBalanceHistoryRequest) ProtoMessage 

func (*QueryBalanceHistoryRequest) ProtoMessage()

func (*QueryBalanceHistoryRequest) ProtoReflect 

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

func (*QueryBalanceHistoryRequest) Reset 

func (x *QueryBalanceHistoryRequest) Reset()

func (*QueryBalanceHistoryRequest) String 

func (x *QueryBalanceHistoryRequest) String() string

type QueryBalanceHistoryResponse 

type QueryBalanceHistoryResponse struct {
	Balances []*AggregatedBalance `protobuf:"bytes,1,rep,name=balances,proto3" json:"balances,omitempty"`
	// contains filtered or unexported fields
}

func (*QueryBalanceHistoryResponse) Descriptor deprecated 

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

Deprecated: Use QueryBalanceHistoryResponse.ProtoReflect.Descriptor instead.

func (*QueryBalanceHistoryResponse) GetBalances 

func (x *QueryBalanceHistoryResponse) GetBalances() []*AggregatedBalance

func (*QueryBalanceHistoryResponse) ProtoMessage 

func (*QueryBalanceHistoryResponse) ProtoMessage()

func (*QueryBalanceHistoryResponse) ProtoReflect 

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

func (*QueryBalanceHistoryResponse) Reset 

func (x *QueryBalanceHistoryResponse) Reset()

func (*QueryBalanceHistoryResponse) String 

func (x *QueryBalanceHistoryResponse) String() string

type TradingDataServiceClient 

type TradingDataServiceClient interface {
	// Get an Order by Market and Order ID
	// TODO: Is this needed? Isn't ID sufficiently unique?
	OrderByMarketAndID(ctx context.Context, in *OrderByMarketAndIDRequest, opts ...grpc.CallOption) (*OrderByMarketAndIDResponse, error)
	// Get an Order by Pending Order reference (UUID)
	// TODO: References are not enforced to be unique, this should return a list
	OrderByReference(ctx context.Context, in *OrderByReferenceRequest, opts ...grpc.CallOption) (*OrderByReferenceResponse, error)
	// Get a list of Orders by Market
	OrdersByMarket(ctx context.Context, in *OrdersByMarketRequest, opts ...grpc.CallOption) (*OrdersByMarketResponse, error)
	// Get a list of Orders by Party
	OrdersByParty(ctx context.Context, in *OrdersByPartyRequest, opts ...grpc.CallOption) (*OrdersByPartyResponse, error)
	// Get a specific order by order ID
	OrderByID(ctx context.Context, in *OrderByIDRequest, opts ...grpc.CallOption) (*OrderByIDResponse, error)
	// Get all versions of the order by its orderID
	OrderVersionsByID(ctx context.Context, in *OrderVersionsByIDRequest, opts ...grpc.CallOption) (*OrderVersionsByIDResponse, error)
	// Get an aggregated list of the changes in balances in a set of accounts over time
	QueryBalanceHistory(ctx context.Context, in *QueryBalanceHistoryRequest, opts ...grpc.CallOption) (*QueryBalanceHistoryResponse, error)
	// Get Market Data History for a Market ID between given dates
	GetMarketDataHistoryByID(ctx context.Context, in *GetMarketDataHistoryByIDRequest, opts ...grpc.CallOption) (*GetMarketDataHistoryByIDResponse, error)
	// Get the current network limits (is bootstrapping finished, are proposals enabled etc..)
	GetNetworkLimits(ctx context.Context, in *GetNetworkLimitsRequest, opts ...grpc.CallOption) (*GetNetworkLimitsResponse, error)
}

TradingDataServiceClient is the client API for TradingDataService 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 NewTradingDataServiceClient 

func NewTradingDataServiceClient(cc grpc.ClientConnInterface) TradingDataServiceClient

type TradingDataServiceServer 

type TradingDataServiceServer interface {
	// Get an Order by Market and Order ID
	// TODO: Is this needed? Isn't ID sufficiently unique?
	OrderByMarketAndID(context.Context, *OrderByMarketAndIDRequest) (*OrderByMarketAndIDResponse, error)
	// Get an Order by Pending Order reference (UUID)
	// TODO: References are not enforced to be unique, this should return a list
	OrderByReference(context.Context, *OrderByReferenceRequest) (*OrderByReferenceResponse, error)
	// Get a list of Orders by Market
	OrdersByMarket(context.Context, *OrdersByMarketRequest) (*OrdersByMarketResponse, error)
	// Get a list of Orders by Party
	OrdersByParty(context.Context, *OrdersByPartyRequest) (*OrdersByPartyResponse, error)
	// Get a specific order by order ID
	OrderByID(context.Context, *OrderByIDRequest) (*OrderByIDResponse, error)
	// Get all versions of the order by its orderID
	OrderVersionsByID(context.Context, *OrderVersionsByIDRequest) (*OrderVersionsByIDResponse, error)
	// Get an aggregated list of the changes in balances in a set of accounts over time
	QueryBalanceHistory(context.Context, *QueryBalanceHistoryRequest) (*QueryBalanceHistoryResponse, error)
	// Get Market Data History for a Market ID between given dates
	GetMarketDataHistoryByID(context.Context, *GetMarketDataHistoryByIDRequest) (*GetMarketDataHistoryByIDResponse, error)
	// Get the current network limits (is bootstrapping finished, are proposals enabled etc..)
	GetNetworkLimits(context.Context, *GetNetworkLimitsRequest) (*GetNetworkLimitsResponse, error)
	// contains filtered or unexported methods
}

TradingDataServiceServer is the server API for TradingDataService service. All implementations must embed UnimplementedTradingDataServiceServer for forward compatibility

type UnimplementedTradingDataServiceServer 

type UnimplementedTradingDataServiceServer struct {
}

UnimplementedTradingDataServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedTradingDataServiceServer) GetMarketDataHistoryByID 

func (UnimplementedTradingDataServiceServer) GetMarketDataHistoryByID(context.Context, *GetMarketDataHistoryByIDRequest) (*GetMarketDataHistoryByIDResponse, error)

func (UnimplementedTradingDataServiceServer) GetNetworkLimits 

func (UnimplementedTradingDataServiceServer) GetNetworkLimits(context.Context, *GetNetworkLimitsRequest) (*GetNetworkLimitsResponse, error)

func (UnimplementedTradingDataServiceServer) OrderByID 

func (UnimplementedTradingDataServiceServer) OrderByID(context.Context, *OrderByIDRequest) (*OrderByIDResponse, error)

func (UnimplementedTradingDataServiceServer) OrderByMarketAndID 

func (UnimplementedTradingDataServiceServer) OrderByMarketAndID(context.Context, *OrderByMarketAndIDRequest) (*OrderByMarketAndIDResponse, error)

func (UnimplementedTradingDataServiceServer) OrderByReference 

func (UnimplementedTradingDataServiceServer) OrderByReference(context.Context, *OrderByReferenceRequest) (*OrderByReferenceResponse, error)

func (UnimplementedTradingDataServiceServer) OrderVersionsByID 

func (UnimplementedTradingDataServiceServer) OrderVersionsByID(context.Context, *OrderVersionsByIDRequest) (*OrderVersionsByIDResponse, error)

func (UnimplementedTradingDataServiceServer) OrdersByMarket 

func (UnimplementedTradingDataServiceServer) OrdersByMarket(context.Context, *OrdersByMarketRequest) (*OrdersByMarketResponse, error)

func (UnimplementedTradingDataServiceServer) OrdersByParty 

func (UnimplementedTradingDataServiceServer) OrdersByParty(context.Context, *OrdersByPartyRequest) (*OrdersByPartyResponse, error)

func (UnimplementedTradingDataServiceServer) QueryBalanceHistory 

func (UnimplementedTradingDataServiceServer) QueryBalanceHistory(context.Context, *QueryBalanceHistoryRequest) (*QueryBalanceHistoryResponse, error)

type UnsafeTradingDataServiceServer 

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

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