api

package
v0.78.6 Latest Latest
Warning

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

 Go to latest Published: Sep 17, 2024 License: AGPL-3.0 Imports: 60 Imported by: 0

README

Conventions Followed in datanode/api Code Implementation

Errors

For all types of errors that are handled in the datanode/api scope, please use errors part of the package. Example:

return nil, apiError(codes.InvalidArgument, ErrMalformedRequest)

The purpose is to have a common way of handling error reporting outside of the core component and keep them clean and simple. Some gradual refactoring work on places where the above is not yet applied is welcomed, though as a friendly and respectful reminder - please consider not breaking the current state.

Documentation

Overview

Package api contains code for running the gRPC server.

In order to add a new gRPC endpoint, add proto content (rpc call, request and response messages), then add the endpoint function implementation in `api/somefile.go`. Example: 

func (s *tradingService) SomeNewEndpoint(
    ctx context.Context, req *protoapi.SomeNewEndpointRequest,
) (*protoapi.SomeNewEndpointResponse, error) {
    /* Implementation goes here */
    return &protoapi.SomeNewEndpointResponse{/* ... */}, nil
}

Add a test for the newly created endpoint in `api/trading_test.go`.

Index

Constants

This section is empty.

Variables

View Source 
var (
	// ErrNoTrustedProxy indactes a forwarded request that did not pass through a trusted proxy.
	ErrNoTrustedProxy = errors.New("forwarded requests need to pass through a trusted proxy")
	// ErrChannelClosed signals that the channel streaming data is closed.
	ErrChannelClosed = errors.New("channel closed")
	// ErrNotAValidVegaID signals an invalid id.
	ErrNotAValidVegaID = newInvalidArgumentError("not a valid vega id")
	// ErrMissingResourceID signals to the caller that the request expected a
	// resource id but the field is missing or empty.
	ErrMissingResourceID = newInvalidArgumentError("missing resource ID")
	// ErrEmptyMissingMarketID signals to the caller that the request expected a
	// market id but the field is missing or empty.
	ErrEmptyMissingMarketID = newInvalidArgumentError("empty or missing market ID")
	// ErrInvalidMarketID signals to the caller that the request expected a
	// market id but the field is not in the right format.
	ErrInvalidMarketID = newInvalidArgumentError("invalid market ID")
	// ErrMissingPrice signals to the caller that the request expected a price.
	ErrMissingPrice = newInvalidArgumentError("missing price")
	// ErrInvalidOrderPrice signals to the caller that the request expected a valid price.
	ErrInvalidOrderPrice = newInvalidArgumentError("invalid order price")
	// ErrInvalidOrderSize signals to the caller that the request expected a valid size.
	ErrInvalidOrderSize = newInvalidArgumentError("invalid order size")
	// ErrServerShutdown signals to the client that the server  is shutting down.
	ErrServerShutdown = errors.New("server shutdown")
	// ErrStreamClosed signals to the users that the grpc stream is closing.
	ErrStreamClosed = errors.New("stream closed")
	// ErrStreamInternal signals to the users that the grpc stream has an internal problem.
	ErrStreamInternal = errors.New("internal stream failure")
	// ErrNotMapped is when an error cannot be found in the current error map/lookup table.
	ErrNotMapped = errors.New("error not found in error lookup table")
	// ErrMissingPartyID signals that the payload is expected to contain a party id.
	ErrMissingPartyID = newInvalidArgumentError("missing party id")
	// ErrInvalidPartyID signals that the given party id is not a valid ID.
	ErrInvalidPartyID = newInvalidArgumentError("invalid party id")
	// ErrInvalidPagination signals that the pagination is invalid.
	ErrInvalidPagination = newInvalidArgumentError("invalid pagination")
	// ErrInvalidCandleID signals an invalid candle ID submitted.
	ErrInvalidCandleID = newInvalidArgumentError("invalid candle id")
	// ErrInvalidCandleTimestampsRange signals an impossible range with the candle timestamps.
	ErrInvalidCandleTimestampsRange = newInvalidArgumentError("invalid candle timestamps range")
	// ErrInvalidFilter signals that the filter is invalid.
	ErrInvalidFilter = newInvalidArgumentError("invalid filter")
	// ErrMalformedRequest signals that the request was malformed.
	ErrMalformedRequest = newInvalidArgumentError("malformed request")
	// ErrMissingOrderID signals that an order ID was required but not specified.
	ErrMissingOrderID = newInvalidArgumentError("missing orderID parameter")
	// ErrInvalidOrderID signals that an order ID provided was not a valid ID.
	ErrInvalidOrderID = newInvalidArgumentError("invalid orderID parameter")
	// ErrMissingCandleID returned if candle with this id is missing.
	ErrMissingCandleID = newInvalidArgumentError("candle id is a required parameter")
	// ErrMissingProposalID returned if proposal with this id is missing.
	ErrMissingProposalID = newInvalidArgumentError("proposal id is a required parameter")
	// ErrMissingProposalIDAndPartyID returned if proposal id and party id is missing.
	ErrMissingProposalIDAndPartyID = newInvalidArgumentError("missing proposal id and party id")
	// ErrMissingProposalIDOrPartyID returned if proposal id and party id is missing.
	ErrMissingProposalIDOrPartyID = newInvalidArgumentError("missing proposal id or party id")
	// ErrMissingProposalIDOrReference returned if proposal id or reference is missing.
	ErrMissingProposalIDOrReference = newInvalidArgumentError("missing proposal ID or reference")
	// ErrInvalidProposalID returned if proposal id is invalid.
	ErrInvalidProposalID = newInvalidArgumentError("invalid proposal id")
	// ErrMissingWithdrawalID is returned when the withdrawal ID is missing from the request.
	ErrMissingWithdrawalID = newInvalidArgumentError("missing withdrawal ID")
	// ErrInvalidWithdrawalID is returned when the withdrawal ID is not a valid vega ID.
	ErrInvalidWithdrawalID = newInvalidArgumentError("invalid withdrawal ID")
	// ErrMissingOracleSpecID is returned when the ID is missing from the request.
	ErrMissingOracleSpecID = newInvalidArgumentError("missing oracle spec ID")
	// ErrInvalidOracleSpecID is returned when the ID is not a valid ID.
	ErrInvalidOracleSpecID = newInvalidArgumentError("invalid oracle spec ID")
	// ErrMissingDepositID is returned when the deposit ID is missing from the request.
	ErrMissingDepositID = newInvalidArgumentError("missing deposit ID")
	// ErrMissingAssetID is returned when the Asset ID is missing from the request.
	ErrMissingAssetID = newInvalidArgumentError("missing asset ID")
	// ErrInvalidAssetID is returned when the Asset ID is not a valid ID.
	ErrInvalidAssetID = newInvalidArgumentError("invalid asset ID")
	// ErrMissingNodeID is returned when the node ID is missing from the request.
	ErrMissingNodeID = newInvalidArgumentError("missing node id")
	// ErrNegativeOrderVersion is returned when a request is made for an
	// order with a negative version.
	ErrNegativeOrderVersion = newInvalidArgumentError("negative order version")
	// ErrLastPaginationNotSupported is returned when last pagination is not supported.
	ErrLastPaginationNotSupported = newInvalidArgumentError("'last' pagination is not supported")
	// ErrMissingMarginFactor is returned when isolated margin mode is specified, but margin factor is not supplied.
	ErrMissingMarginFactor = newInvalidArgumentError("missing margin factor")
	// ErrInvalidGameID is returned when the game ID is not a valid ID.
	ErrInvalidGameID = newInvalidArgumentError("invalid game ID")

	// ErrOracleServiceSpecID is returned when there was no data found for the given ID.
	ErrOracleServiceGetSpec = errors.New("failed to retrieve data for oracle spec")
	// ErrERC20InvalidTokenContractAddress is returned when the ERC20 token contract address is invalid.
	ErrERC20InvalidTokenContractAddress = errors.New("invalid erc20 token contract address")
	ErrSendingGRPCHeader                = errors.New("failed to send header")
	ErrEstimateFee                      = errors.New("failed to estimate fee")
	ErrEstimateMargin                   = errors.New("failed to estimate margin")
	// OrderService...
	ErrOrderServiceGetOrders        = errors.New("failed to get orders")
	ErrOrderServiceGetVersions      = errors.New("failed to get order versions")
	ErrOrderNotFound                = errors.New("order not found")
	ErrOrderServiceGetByMarket      = errors.New("failed to get orders for market")
	ErrOrderServiceGetByMarketAndID = errors.New("failed to get orders for market and ID")
	ErrOrderServiceGetByParty       = errors.New("failed to get orders for party")
	ErrOrderServiceGetByReference   = errors.New("failed to get orders for reference")
	ErrOrderServiceGetByTxHash      = errors.New("failed to get orders for tx hash")
	ErrMissingOrderIDParameter      = errors.New("missing orderID parameter")
	// NodeService...
	ErrNodeServiceGetNodes    = errors.New("failed to get nodes")
	ErrNodeServiceGetNodeData = errors.New("failed to get node data")
	ErrNodeServiceGetByTxHash = errors.New("failed to get nodes for tx hash")
	// TradeService...
	ErrTradeServiceGetByParty          = errors.New("failed to get trades for party")
	ErrTradeServiceGetByMarket         = errors.New("failed to get trades for market")
	ErrTradeServiceList                = errors.New("failed to list trades")
	ErrTradeServiceGetPositionsByParty = errors.New("failed to get positions for party")
	ErrTradeServiceGetByOrderID        = errors.New("failed to get trades for order ID")
	ErrTradeServiceGetByTxHash         = errors.New("failed to get trades for tx hash")
	// MarketService...
	ErrMarketServiceGetByID              = errors.New("failed to get market for ID")
	ErrMarketServiceGetAllPaged          = errors.New("failed to get all markets paged")
	ErrMarketServiceGetMarketData        = errors.New("failed to get market data")
	ErrMarketServiceGetMarketDataHistory = errors.New("failed to get market data history")
	ErrMarketServiceGetMarkets           = errors.New("failed to get markets")
	ErrMarketServiceGetByTxHash          = errors.New("failed to get orders for tx hash")
	ErrMarketServiceGetDepth             = errors.New("failed to get market depth")
	// AccountService...
	ErrAccountServiceListAccounts        = errors.New("failed to get accounts")
	ErrFailedToSendSnapshot              = errors.New("failed to send accounts snapshot")
	ErrAccountServiceGetBalances         = errors.New("failed to get balances")
	ErrAccountServiceGetByTxHash         = errors.New("failed to get accounts for tx hash")
	ErrAccountServiceGetBalancesByTxHash = errors.New("failed to get balances for tx hash")
	// DelegationService...
	ErrDelegationServiceGet = errors.New("failed to get delegation")
	// SummaryService...
	ErrSummaryServiceGet = errors.New("failed to get summary")
	// WithdrawalService...
	ErrWithdrawalServiceGet = errors.New("failed to get withdrawal")
	// PositionService...
	ErrPositionServiceGetByParty   = errors.New("failed to get positions for party")
	ErrPositionServiceSendSnapshot = errors.New("failed to send positions snapshot")
	// RiskService...
	ErrRiskServiceGetMarginLevelsByID = errors.New("failed to get margin levels")
	ErrInvalidOrderSide               = newInvalidArgumentError("invalid order side")
	// RiskFactorService...
	ErrRiskFactorServiceGet = errors.New("failed to get risk factor")
	// GovernanceService...
	ErrGovernanceServiceGet          = errors.New("failed to get proposal")
	ErrGovernanceServiceGetProposals = errors.New("failed to get proposals")
	ErrGovernanceServiceGetVotes     = errors.New("failed to get votes")
	// CandleService...
	ErrCandleServiceGetCandleData       = errors.New("failed to get candle data")
	ErrCandleServiceSubscribeToCandles  = errors.New("failed to subscribe to candle data")
	ErrCandleServiceGetCandlesForMarket = errors.New("failed to get candles for market")
	// PartyService...
	ErrPartyServiceGetAll       = errors.New("failed to get parties")
	ErrPartyServiceListProfiles = errors.New("failed to get parties' profiles")
	ErrPartyServiceGetByID      = errors.New("failed to get party for ID")
	ErrPartyServiceGetByTxHash  = errors.New("failed to get parties for tx hash")
	// NotaryService...
	ErrNotaryServiceGetByResourceID = errors.New("failed to get notary for resource ID")
	// OracleSpecService...
	// ErrOracleSpecServiceGet is returned when there was no data found for the given ID.
	ErrOracleSpecServiceGet = errors.New("failed retrieve data for oracle spec")
	// ErrOracleSpecServiceGetAll is returned when there was no data found for the given ID.
	ErrOracleSpecServiceGetAll = errors.New("failed retrieve data for oracle specs")
	// OracleDataService...
	// ErrOracleDataServiceGet is returned when there was no data found for the given ID.
	ErrOracleDataServiceGet = errors.New("failed retrieve data for oracle data")
	// AssetService...
	ErrAssetServiceGetAll            = errors.New("failed to get assets")
	ErrAssetServiceGetByID           = errors.New("failed to get asset for ID")
	ErrScalingPriceFromMarketToAsset = errors.New("failed to scale price from market to asset")
	// DepositService...
	ErrDepositServiceGet = errors.New("failed to get deposit")
	// TransferService...
	ErrTransferServiceGet            = errors.New("failed to get transfer")
	ErrTransferServiceGetFeeDiscount = errors.New("failed to get current transfer fee discount")
	ErrMissingTransferID             = errors.New("missing transfer id")
	// NetworkLimits...
	ErrGetNetworkLimits = errors.New("failed to get network limits")
	// ErrGetNetworkParameters is returned when the network parameters cannot be retrieved.
	ErrGetNetworkParameters = errors.New("failed to get network parameters")
	// Network History...
	ErrGetConnectedPeerAddresses = errors.New("failed to get connected peer addresses")
	// TimeService...
	ErrTimeServiceGetTimeNow = errors.New("failed to get time now")
	// Blockchain...
	ErrBlockchainBacklogLength = errors.New("failed to get backlog length from blockchain")
	ErrBlockchainNetworkInfo   = errors.New("failed to get network info from blockchain")
	ErrBlockchainGenesisTime   = errors.New("failed to get genesis time from blockchain")
	ErrBlockchainChainID       = errors.New("failed to get chain ID from blockchain")
	// Rewards.
	ErrGetRewards         = errors.New("failed to get rewards")
	ErrRewardsGetByTxHash = errors.New("failed to get rewards for tx hash")
	// Network History.
	ErrGetActivePeerAddresses              = errors.New("failed to get active peer addresses")
	ErrGetMostRecentHistorySegment         = errors.New("failed to get most recent history segment")
	ErrListAllNetworkHistorySegment        = errors.New("failed to list all history segments")
	ErrFetchNetworkHistorySegment          = errors.New("failed to fetch segment")
	ErrNetworkHistoryNotEnabled            = errors.New("network history not enabled")
	ErrCopyHistorySegmentToFile            = errors.New("failed to copy history segment to file")
	ErrGetIpfsAddress                      = errors.New("failed to get node's ipfs address")
	ErrNetworkHistoryNoTableName           = errors.New("no table name for network history supplied")
	ErrNetworkHistoryGetContiguousSegments = newInvalidArgumentError("could not to get contiguous history segments")
	ErrNetworkHistoryOpeningSegment        = errors.New("failed to open network history segment file")
	ErrNetworkHistoryExtractingSegment     = errors.New("failed to extract data from network history segment file")
	ErrNetworkHistoryCreatingZipFile       = errors.New("failed to create zip file writer for network history segment")
	ErrNetworkHistoryServiceNotInitialised = errors.New("network history service not initialised")

	// ErrGetEpoch is returned when the epoch cannot be retrieved.
	ErrGetEpoch     = errors.New("failed to get epoch")
	ErrEpochIDParse = newInvalidArgumentError("failed to parse epoch id")
	// LedgerService...
	ErrLedgerServiceGet    = errors.New("failed to query ledger entries")
	ErrLedgerServiceExport = errors.New("failed to export ledger entries")
	// MultiSigService...
	ErrMultiSigServiceGetAdded   = errors.New("failed to get added multisig events")
	ErrMultiSigServiceGetRemoved = errors.New("failed to get removed multisig events")
	// LiquidityProvisionService...
	ErrLiquidityProvisionServiceGet          = errors.New("failed to get liquidity provision")
	ErrLiquidityProvisionServiceGetProviders = errors.New("failed to get liquidity providers")
	// CheckpointService...
	ErrCheckpointServiceGet = errors.New("failed to get checkpoint")
	// StakeLinkingService...
	ErrStakeLinkingServiceGet = errors.New("failed to get stake linking")
	// CoreSnapshotService...
	ErrCoreSnapshotServiceListSnapshots = errors.New("failed to list core snapshots")
	// ProtocolUpgradeService...
	ErrProtocolUpgradeServiceListProposals = errors.New("failed to list protocol upgrade proposals")
	// KeyRotationService...
	ErrKeyRotationServiceGetPerNode = errors.New("failed to get key rotations for node")
	ErrKeyRotationServiceGetAll     = errors.New("failed to get all key rotations")
	// EthereumKeyRotationService...
	ErrEthereumKeyRotationServiceGetPerNode = errors.New("failed to get ethereum key rotations for node")
	ErrEthereumKeyRotationServiceGetAll     = errors.New("failed to get all ethereum key rotations")
	// BlockService...
	ErrBlockServiceGetLast = errors.New("failed to get last block")
	// Positions...
	ErrPositionsGetByTxHash           = errors.New("failed to get positions for tx hash")
	ErrPositionsInvalidAccountBalance = newInvalidArgumentError("invalid account balance")
	// Ledger entries...
	ErrLedgerEntriesGetByTxHash = errors.New("failed to get ledger entries for tx hash")
	// Transfers...
	ErrTransfersGetByTxHash = errors.New("failed to get transfers for tx hash")
	// Votes...
	ErrVotesGetByTxHash = errors.New("failed to get votes for tx hash")
	// ERC20MultiSigSignerEvents...
	ErrERC20MultiSigSignerAddedEventGetByTxHash   = errors.New("failed to get ERC20 multisig signer add events for tx hash")
	ErrERC20MultiSigSignerRemovedEventGetByTxHash = errors.New("failed to get ERC20 multisig signer removed events for tx hash")
	// Oracles...
	ErrOracleSpecGetByTxHash = errors.New("failed to get oracle spec for tx hash")
	ErrOracleDataGetByTxHash = errors.New("failed to get oracle data for tx hash")
	// Deposits...
	ErrDepositsGetByTxHash = errors.New("failed to get deposits for tx hash")
	// Withdrawals...
	ErrWithdrawalsGetByTxHash = errors.New("failed to get withdrawals for tx hash")
	// Assets...
	ErrAssetsGetByTxHash = errors.New("failed to get assets for tx hash")
	// Liquidity provision...
	ErrLiquidityProvisionGetByTxHash = errors.New("failed to get liquidity provision for tx hash")
	// Proposals...
	ErrProposalsGetByTxHash = errors.New("failed to get proposals for tx hash")
	// Delegations...
	ErrDelegationsGetByTxHash = errors.New("failed to get delegations for tx hash")
	// Signatures...
	ErrSignaturesGetByTxHash = errors.New("failed to get signatures for tx hash")
	// NetworkParamaters...
	ErrNetworkParametersGetByTxHash = errors.New("failed to get network parameters for tx hash")
	ErrNetworkParameterNotFound     = errors.New("network parameter not found")

	// KeyRotations...
	ErrKeyRotationsGetByTxHash = errors.New("failed to get key rotations for tx hash")
	// EthereumKeyRotations...
	ErrEthereumKeyRotationsGetByTxHash = errors.New("failed to get ethereum key rotations for tx hash")
	// ProtocolUpgradeProposals...
	ErrProtocolUpgradeProposalsGetByTxHash = errors.New("failed to get protocol upgrade proposals for tx hash")
	// MarginLevels...
	ErrMarginLevelsGetByTxHash = errors.New("failed to get margin levels for tx hash")

	// TxHashes...
	ErrMissingEmptyTxHash = newInvalidArgumentError("missing or empty transaction hash")
	ErrInvalidTxHash      = newInvalidArgumentError("not a valid transaction hash")

	// Funding Periods.
	ErrListFundingPeriod           = errors.New("failed to get funding periods")
	ErrListFundingPeriodDataPoints = errors.New("failed to get funding period data points")

	// Referral Programs.
	ErrGetCurrentReferralProgram = errors.New("failed to get current referral program")
	ErrGetReferralSetStats       = errors.New("failed to get referral set stats")

	// Fees stats.
	ErrGetFeesStats         = errors.New("failed to get current fees stats")
	ErrFeesStatsRequest     = errors.New("marketID or assetID must be provided")
	ErrGetFeesStatsForParty = errors.New("failed to get current fees stats for party")

	// Teams.
	ErrListTeams              = errors.New("failed to list teams")
	ErrListTeamReferees       = errors.New("failed to list team referees")
	ErrListTeamStatistics     = errors.New("failed to list team statistics")
	ErrListTeamRefereeHistory = errors.New("failed to list team referee history")

	// Volume discount Programs.
	ErrGetCurrentVolumeDiscountProgram = errors.New("failed to get current volume discount program")
	ErrGetVolumeDiscountStats          = errors.New("failed to get volume discount stats")
	ErrGetVolumeRebateStats            = errors.New("failed to get volume rebate stats")

	// Paid liquidity fees.
	ErrListPaidLiquidityFees = errors.New("failed to list paid liquidity fees")
	// List Games.
	ErrListGames = errors.New("failed to list games")

	// Transfer fee estimates.
	ErrInvalidTransferAmount = newInvalidArgumentError("invalid transfer amount")

	ErrListPartyMarginModes = errors.New("failed to list parties margin modes")
	// ErrGetTimeWeightedNotionalPosition is returned when the time weighted notional position cannot be retrieved.
	ErrGetTimeWeightedNotionalPosition = errors.New("failed to get time weighted notional position")

	ErrDateRangeValidationFailed = newInvalidArgumentError("invalid date range")

	ErrListAMMPools                     = errors.New("failed to list AMM pools")
	ErrCannotFilterByStatusWhenLiveOnly = newInvalidArgumentError("status filter and live-only cannot both be set")

	// Amm bounds estimates.
	ErrInvalidBasePrice            = newInvalidArgumentError("invalid base price")
	ErrInvalidUpperPrice           = newInvalidArgumentError("invalid upper price")
	ErrInvalidLowerPrice           = newInvalidArgumentError("invalid lower price")
	ErrInvalidLeverageAtLowerPrice = newInvalidArgumentError("invalid leverage at lower price")
	ErrInvalidLeverageAtUpperPrice = newInvalidArgumentError("invalid leverage at upper price")
	ErrInvalidCommitmentAmount     = newInvalidArgumentError("invalid commitment amount")
	ErrEstimateAMMBounds           = errors.New("failed to estimate AMM bounds")
)

API Errors and descriptions.

View Source 
var FormatE = formatE

FormatE exports the formatE function (primarily for testing).

Functions

func ErrorMap 

func ErrorMap() map[string]int32

ErrorMap returns a map of error to code, which is a mapping between API errors and Vega API specific numeric codes.

Types

type AMMService added in v0.77.0 

type AMMService interface {
	GetSubKeysForParties(ctx context.Context, partyIDs []string, marketIDs []string) ([]string, error)
	ListAll(ctx context.Context, liveOnly bool, pagination entities.CursorPagination) ([]entities.AMMPool, entities.PageInfo, error)
	ListByMarket(ctx context.Context, marketID string, liveOnly bool, pagination entities.CursorPagination) ([]entities.AMMPool, entities.PageInfo, error)
	ListByParty(ctx context.Context, partyID string, liveOnly bool, pagination entities.CursorPagination) ([]entities.AMMPool, entities.PageInfo, error)
	ListByPool(ctx context.Context, poolID string, liveOnly bool, pagination entities.CursorPagination) ([]entities.AMMPool, entities.PageInfo, error)
	ListByStatus(ctx context.Context, status entities.AMMStatus, pagination entities.CursorPagination) ([]entities.AMMPool, entities.PageInfo, error)
	ListBySubAccount(ctx context.Context, ammPartyID string, liveOnly bool, pagination entities.CursorPagination) ([]entities.AMMPool, entities.PageInfo, error)
	ListByPartyMarketStatus(ctx context.Context, party, market *string, status *entities.AMMStatus, liveOnly bool, pagination entities.CursorPagination) ([]entities.AMMPool, entities.PageInfo, error)
}

type AssetService added in v0.74.0 

type AssetService interface {
	GetByID(ctx context.Context, id string) (entities.Asset, error)
	GetByTxHash(ctx context.Context, txHash entities.TxHash) ([]entities.Asset, error)
	GetAll(ctx context.Context) ([]entities.Asset, error)
	GetAllWithCursorPagination(ctx context.Context, pagination entities.CursorPagination) ([]entities.Asset, entities.PageInfo, error)
}

Asset service ...

type BlockService added in v0.56.0 

type BlockService interface {
	GetLastBlock(ctx context.Context) (entities.Block, error)
}

BlockService ...

type Config 

type Config struct {
	Level                    encoding.LogLevel `long:"log-level"`
	Timeout                  encoding.Duration `long:"timeout"`
	Port                     int               `long:"port"`
	WebUIPort                int               `long:"web-ui-port"`
	WebUIEnabled             encoding.Bool     `long:"web-ui-enabled"`
	Reflection               encoding.Bool     `long:"reflection"`
	IP                       string            `long:"ip"`
	StreamRetries            int               `long:"stream-retries"`
	CoreNodeIP               string            `long:"core-node-ip"`
	CoreNodeGRPCPort         int               `long:"core-node-grpc-port"`
	RateLimit                ratelimit.Config  `group:"rate-limits"`
	MaxSubscriptionPerClient uint32            `long:"max-subscription-per-client"`
	MaxMsgSize               int               `long:"max-msg-size"`
}

Config represents the configuration of the api package.

func NewDefaultConfig 

func NewDefaultConfig() Config

NewDefaultConfig creates an instance of the package specific configuration, given a pointer to a logger instance to be used for logging within the package.

type CoreServiceClient 

type CoreServiceClient interface {
	protoapi.CoreServiceClient
}

CoreServiceClient ...

type EpochService added in v0.78.0 

type EpochService interface {
	GetCurrent(ctx context.Context) (entities.Epoch, error)
	GetByBlock(ctx context.Context, height uint64) (entities.Epoch, error)
	Get(ctx context.Context, ID uint64) (entities.Epoch, error)
	GetAll(ctx context.Context) ([]entities.Epoch, error)
}

EpochService

type EventService 

type EventService interface {
	ObserveEvents(ctx context.Context, retries int, eTypes []events.Type, batchSize int, filters ...subscribers.EventFilter) (<-chan []*eventspb.BusEvent, chan<- int)
}

EventService ...

type GRPCServer 

type GRPCServer struct {
	Config

	AssetService AssetService

	FeesStatsService *service.FeesStats
	// contains filtered or unexported fields
}

GRPCServer represent the grpc api provided by the vega node.

func NewGRPCServer 

func NewGRPCServer(
	log *logging.Logger,
	config Config,
	coreServiceClient CoreServiceClient,
	eventService *subscribers.Service,
	orderService *service.Order,
	networkLimitsService *service.NetworkLimits,
	marketDataService *service.MarketData,
	tradeService *service.Trade,
	assetService *service.Asset,
	accountService *service.Account,
	rewardService *service.Reward,
	marketsService *service.Markets,
	delegationService *service.Delegation,
	epochService *service.Epoch,
	depositService *service.Deposit,
	withdrawalService *service.Withdrawal,
	governanceService *service.Governance,
	riskFactorService *service.RiskFactor,
	riskService *service.Risk,
	networkParameterService *service.NetworkParameter,
	blockService BlockService,
	checkpointService *service.Checkpoint,
	partyService *service.Party,
	candleService *candlesv2.Svc,
	oracleSpecService *service.OracleSpec,
	oracleDataService *service.OracleData,
	liquidityProvisionService *service.LiquidityProvision,
	positionService *service.Position,
	transferService *service.Transfer,
	stakeLinkingService *service.StakeLinking,
	notaryService *service.Notary,
	multiSigService *service.MultiSig,
	keyRotationService *service.KeyRotations,
	ethereumKeyRotationService *service.EthereumKeyRotation,
	nodeService *service.Node,
	marketDepthService *service.MarketDepth,
	ledgerService *service.Ledger,
	protocolUpgradeService *service.ProtocolUpgrade,
	networkHistoryService NetworkHistoryService,
	coreSnapshotService *service.SnapshotData,
	stopOrderService *service.StopOrders,
	fundingPeriodService *service.FundingPeriods,
	partyActivityStreak *service.PartyActivityStreak,
	referralProgramService *service.ReferralPrograms,
	referralSetsService *service.ReferralSets,
	teamsService *service.Teams,
	vestingStatsService *service.VestingStats,
	FeesStatsService *service.FeesStats,
	fundingPaymentService *service.FundingPayment,
	volumeDiscountStatsService *service.VolumeDiscountStats,
	volumeDiscountProgramService *service.VolumeDiscountPrograms,
	paidLiquidityFeesStatsService *service.PaidLiquidityFeesStats,
	partyLockedBalances *service.PartyLockedBalances,
	partyVestingBalances *service.PartyVestingBalances,
	transactionResults *service.TransactionResults,
	gameService *service.Games,
	marginModesService *service.MarginModes,
	timeWeightedNotionalPositionService *service.TimeWeightedNotionalPosition,
	gameScoreService *service.GameScore,
	ammPoolService *service.AMMPools,
	volumeRebateStatsService *service.VolumeRebateStats,
	volumeRebateProgramsService *service.VolumeRebatePrograms,
) *GRPCServer

NewGRPCServer create a new instance of the GPRC api for the vega node.

func (*GRPCServer) ReloadConf 

func (g *GRPCServer) ReloadConf(cfg Config)

ReloadConf update the internal configuration of the GRPC server.

func (*GRPCServer) Start 

func (g *GRPCServer) Start(ctx context.Context, lis net.Listener) error

Start starts the grpc server. Uses default TCP listener if no provided.

type MarketDataService added in v0.74.0 

type MarketDataService interface {
	GetMarketDataByID(ctx context.Context, marketID string) (entities.MarketData, error)
	GetMarketsData(ctx context.Context) ([]entities.MarketData, error)
	GetHistoricMarketData(ctx context.Context, marketID string, start, end *time.Time, pagination entities.Pagination) ([]entities.MarketData, entities.PageInfo, error)
	ObserveMarketData(ctx context.Context, retries int, marketID []string) (<-chan []*entities.MarketData, uint64)
}

MarketDataService ...

type MarketsService added in v0.74.0 

type MarketsService interface {
	GetByID(ctx context.Context, marketID string) (entities.Market, error)
	GetByTxHash(ctx context.Context, txHash entities.TxHash) ([]entities.Market, error)
	GetAllPaged(ctx context.Context, marketID string, pagination entities.CursorPagination, includeSettled bool) ([]entities.Market, entities.PageInfo, error)
	ListSuccessorMarkets(ctx context.Context, marketID string, childrenOnly bool, pagination entities.CursorPagination) ([]entities.SuccessorMarket, entities.PageInfo, error)
}

MarketsService ...

type NetworkHistoryService added in v0.67.0 

type NetworkHistoryService interface {
	GetHighestBlockHeightHistorySegment() (segment.Full, error)
	ListAllHistorySegments() (segment.Segments[segment.Full], error)
	FetchHistorySegment(ctx context.Context, historySegmentID string) (segment.Full, error)
	GetActivePeerIPAddresses() []string
	CopyHistorySegmentToFile(ctx context.Context, historySegmentID string, outFile string) error
	GetHistorySegmentReader(ctx context.Context, historySegmentID string) (io.ReadSeekCloser, int64, error)
	GetSwarmKeySeed() string
	GetConnectedPeerAddresses() ([]string, error)
	GetIpfsAddress() (string, error)
	GetSwarmKey() string
	GetBootstrapPeers() []string
}

NetworkHistoryService ...

it would be nice to use go:generate go run github.com/golang/mock/mockgen -destination mocks/networkhistory_service_mock.go -package mocks code.vegaprotocol.io/vega/datanode/api NetworkHistoryService however it currently can't handle generic arguments and the generated code is not compilable without a bit of manual tweaking.

type PartyStatsSvc added in v0.78.0 

type PartyStatsSvc interface {
	GetPartyStats(ctx context.Context, partyID string, marketIDs []string) (*v2.GetPartyDiscountStatsResponse, error)
}

type ReferralSetService added in v0.78.0 

type ReferralSetService interface {
	GetReferralSetStats(ctx context.Context, setID *entities.ReferralSetID, atEpoch *uint64, referee *entities.PartyID, pagination entities.CursorPagination) ([]entities.FlattenReferralSetStats, entities.PageInfo, error)
	ListReferralSets(ctx context.Context, referralSetID *entities.ReferralSetID, referrer, referee *entities.PartyID, pagination entities.CursorPagination) ([]entities.ReferralSet, entities.PageInfo, error)
	ListReferralSetReferees(ctx context.Context, referralSetID *entities.ReferralSetID, referrer, referee *entities.PartyID, pagination entities.CursorPagination, aggregationEpochs uint32) ([]entities.ReferralSetRefereeStats, entities.PageInfo, error)
}

type RiskFactorService added in v0.74.0 

type RiskFactorService interface {
	GetMarketRiskFactors(ctx context.Context, marketID string) (entities.RiskFactor, error)
}

RiskFactorService ...

type TradingDataServiceV2 added in v0.71.0 

type TradingDataServiceV2 struct {
	v2.UnimplementedTradingDataServiceServer

	MarketDataService MarketDataService

	AssetService AssetService

	MarketsService MarketsService

	AccountService *service.Account
	RewardService  *service.Reward

	EpochService      EpochService
	RiskFactorService RiskFactorService

	NetworkHistoryService NetworkHistoryService

	ReferralSetsService ReferralSetService

	VolumeDiscountStatsService VolumeDiscountService

	AMMPoolService AMMService
	// contains filtered or unexported fields
}

func (*TradingDataServiceV2) EstimateAMMBounds added in v0.77.0 

func (t *TradingDataServiceV2) EstimateAMMBounds(ctx context.Context, req *v2.EstimateAMMBoundsRequest) (*v2.EstimateAMMBoundsResponse, error)

func (*TradingDataServiceV2) EstimateFee added in v0.71.0 

func (t *TradingDataServiceV2) EstimateFee(ctx context.Context, req *v2.EstimateFeeRequest) (*v2.EstimateFeeResponse, error)

EstimateFee estimates the fee for a given market, price and size.

func (*TradingDataServiceV2) EstimateMargin added in v0.71.0 

func (t *TradingDataServiceV2) EstimateMargin(ctx context.Context, req *v2.EstimateMarginRequest) (*v2.EstimateMarginResponse, error)

EstimateMargin estimates the margin required for a given order.

func (*TradingDataServiceV2) EstimatePosition added in v0.71.0 

func (t *TradingDataServiceV2) EstimatePosition(ctx context.Context, req *v2.EstimatePositionRequest) (*v2.EstimatePositionResponse, error)

func (*TradingDataServiceV2) EstimateTransferFee added in v0.74.0 

func (t *TradingDataServiceV2) EstimateTransferFee(ctx context.Context, req *v2.EstimateTransferFeeRequest) (
	*v2.EstimateTransferFeeResponse, error,
)

func (*TradingDataServiceV2) ExportLedgerEntries added in v0.71.0 

func (t *TradingDataServiceV2) ExportLedgerEntries(req *v2.ExportLedgerEntriesRequest, stream v2.TradingDataService_ExportLedgerEntriesServer) error

ExportLedgerEntries returns a list of ledger entries matching the request.

func (*TradingDataServiceV2) ExportNetworkHistory added in v0.71.0 

func (t *TradingDataServiceV2) ExportNetworkHistory(req *v2.ExportNetworkHistoryRequest, stream v2.TradingDataService_ExportNetworkHistoryServer) error

-- NetworkHistory --.

func (*TradingDataServiceV2) GetActiveNetworkHistoryPeerAddresses added in v0.71.0 

func (t *TradingDataServiceV2) GetActiveNetworkHistoryPeerAddresses(context.Context, *v2.GetActiveNetworkHistoryPeerAddressesRequest) (*v2.GetActiveNetworkHistoryPeerAddressesResponse, error)

GetActiveNetworkHistoryPeerAddresses returns the active network history peer addresses.

func (*TradingDataServiceV2) GetAsset added in v0.71.0 

func (t *TradingDataServiceV2) GetAsset(ctx context.Context, req *v2.GetAssetRequest) (*v2.GetAssetResponse, error)

GetAsset gets an asset by ID.

func (*TradingDataServiceV2) GetCurrentReferralProgram added in v0.73.0 

func (t *TradingDataServiceV2) GetCurrentReferralProgram(ctx context.Context, _ *v2.GetCurrentReferralProgramRequest) (
	*v2.GetCurrentReferralProgramResponse, error,
)

func (*TradingDataServiceV2) GetCurrentVolumeDiscountProgram added in v0.73.0 

func (t *TradingDataServiceV2) GetCurrentVolumeDiscountProgram(ctx context.Context, _ *v2.GetCurrentVolumeDiscountProgramRequest) (
	*v2.GetCurrentVolumeDiscountProgramResponse, error,
)

func (*TradingDataServiceV2) GetCurrentVolumeRebateProgram added in v0.77.8 

func (t *TradingDataServiceV2) GetCurrentVolumeRebateProgram(ctx context.Context, _ *v2.GetCurrentVolumeRebateProgramRequest) (
	*v2.GetCurrentVolumeRebateProgramResponse, error,
)

func (*TradingDataServiceV2) GetDeposit added in v0.71.0 

func (t *TradingDataServiceV2) GetDeposit(ctx context.Context, req *v2.GetDepositRequest) (*v2.GetDepositResponse, error)

GetDeposit gets a deposit by ID.

func (*TradingDataServiceV2) GetERC20ListAssetBundle added in v0.71.0 

func (t *TradingDataServiceV2) GetERC20ListAssetBundle(ctx context.Context, req *v2.GetERC20ListAssetBundleRequest) (*v2.GetERC20ListAssetBundleResponse, error)

func (*TradingDataServiceV2) GetERC20SetAssetLimitsBundle added in v0.71.0 

func (t *TradingDataServiceV2) GetERC20SetAssetLimitsBundle(ctx context.Context, req *v2.GetERC20SetAssetLimitsBundleRequest) (*v2.GetERC20SetAssetLimitsBundleResponse, error)

GetERC20SetAssetLimitsBundle returns the signature bundle needed to update the asset limits on the ERC20 contract.

func (*TradingDataServiceV2) GetERC20WithdrawalApproval added in v0.71.0 

func (t *TradingDataServiceV2) GetERC20WithdrawalApproval(ctx context.Context, req *v2.GetERC20WithdrawalApprovalRequest) (*v2.GetERC20WithdrawalApprovalResponse, error)

GetERC20WithdrawalApproval returns the signature bundle needed to approve a withdrawal on the ERC20 contract.

func (*TradingDataServiceV2) GetEpoch added in v0.71.0 

func (t *TradingDataServiceV2) GetEpoch(ctx context.Context, req *v2.GetEpochRequest) (*v2.GetEpochResponse, error)

GetEpoch retrieves data for a specific epoch, if id omitted it gets the current epoch.

func (*TradingDataServiceV2) GetFeesStats added in v0.73.0 

func (t *TradingDataServiceV2) GetFeesStats(ctx context.Context, req *v2.GetFeesStatsRequest) (*v2.GetFeesStatsResponse, error)

func (*TradingDataServiceV2) GetFeesStatsForParty added in v0.73.0 

func (t *TradingDataServiceV2) GetFeesStatsForParty(ctx context.Context, req *v2.GetFeesStatsForPartyRequest) (*v2.GetFeesStatsForPartyResponse, error)

func (*TradingDataServiceV2) GetGovernanceData added in v0.71.0 

func (t *TradingDataServiceV2) GetGovernanceData(ctx context.Context, req *v2.GetGovernanceDataRequest) (*v2.GetGovernanceDataResponse, error)

GetGovernanceData gets governance data.

func (*TradingDataServiceV2) GetLastTrade added in v0.71.0 

func (t *TradingDataServiceV2) GetLastTrade(ctx context.Context, req *v2.GetLastTradeRequest) (*v2.GetLastTradeResponse, error)

GetLastTrade returns the last trade for a given market.

func (*TradingDataServiceV2) GetLatestMarketData added in v0.71.0 

func (t *TradingDataServiceV2) GetLatestMarketData(ctx context.Context, req *v2.GetLatestMarketDataRequest) (*v2.GetLatestMarketDataResponse, error)

GetLatestMarketData returns the latest market data for a given market.

func (*TradingDataServiceV2) GetLatestMarketDepth added in v0.71.0 

func (t *TradingDataServiceV2) GetLatestMarketDepth(ctx context.Context, req *v2.GetLatestMarketDepthRequest) (*v2.GetLatestMarketDepthResponse, error)

GetLatestMarketDepth returns the latest market depth for a given market.

func (*TradingDataServiceV2) GetMarket added in v0.71.0 

func (t *TradingDataServiceV2) GetMarket(ctx context.Context, req *v2.GetMarketRequest) (*v2.GetMarketResponse, error)

GetMarket returns a market by its ID.

func (*TradingDataServiceV2) GetMarketDataHistoryByID added in v0.71.0 

func (t *TradingDataServiceV2) GetMarketDataHistoryByID(ctx context.Context, req *v2.GetMarketDataHistoryByIDRequest) (*v2.GetMarketDataHistoryByIDResponse, error)

GetMarketDataHistoryByID returns the market data history for a given market.

func (*TradingDataServiceV2) GetMostRecentNetworkHistorySegment added in v0.71.0 

func (t *TradingDataServiceV2) GetMostRecentNetworkHistorySegment(context.Context, *v2.GetMostRecentNetworkHistorySegmentRequest) (*v2.GetMostRecentNetworkHistorySegmentResponse, error)

GetMostRecentNetworkHistorySegment returns the most recent network history segment.

func (*TradingDataServiceV2) GetNetworkData added in v0.71.0 

func (t *TradingDataServiceV2) GetNetworkData(ctx context.Context, _ *v2.GetNetworkDataRequest) (*v2.GetNetworkDataResponse, error)

GetNetworkData retrieve network data regarding the nodes of the network.

func (*TradingDataServiceV2) GetNetworkHistoryBootstrapPeers added in v0.71.3 

func (t *TradingDataServiceV2) GetNetworkHistoryBootstrapPeers(context.Context, *v2.GetNetworkHistoryBootstrapPeersRequest) (*v2.GetNetworkHistoryBootstrapPeersResponse, error)

NetworkHistoryBootstrapPeers returns the network history bootstrap peers.

func (*TradingDataServiceV2) GetNetworkHistoryStatus added in v0.71.3 

func (t *TradingDataServiceV2) GetNetworkHistoryStatus(context.Context, *v2.GetNetworkHistoryStatusRequest) (*v2.GetNetworkHistoryStatusResponse, error)

NetworkHistoryStatus returns the network history status.

func (*TradingDataServiceV2) GetNetworkLimits added in v0.71.0 

func (t *TradingDataServiceV2) GetNetworkLimits(ctx context.Context, _ *v2.GetNetworkLimitsRequest) (*v2.GetNetworkLimitsResponse, error)

GetNetworkLimits returns the latest network limits.

func (*TradingDataServiceV2) GetNetworkParameter added in v0.71.0 

func (t *TradingDataServiceV2) GetNetworkParameter(ctx context.Context, req *v2.GetNetworkParameterRequest) (*v2.GetNetworkParameterResponse, error)

GetNetworkParameter returns a network parameter by key.

func (*TradingDataServiceV2) GetNode added in v0.71.0 

func (t *TradingDataServiceV2) GetNode(ctx context.Context, req *v2.GetNodeRequest) (*v2.GetNodeResponse, error)

GetNode retrieves information about a given node.

func (*TradingDataServiceV2) GetOracleSpec added in v0.71.0 

func (t *TradingDataServiceV2) GetOracleSpec(ctx context.Context, req *v2.GetOracleSpecRequest) (*v2.GetOracleSpecResponse, error)

GetOracleSpec gets an oracle spec by ID.

func (*TradingDataServiceV2) GetOrder added in v0.71.0 

func (t *TradingDataServiceV2) GetOrder(ctx context.Context, req *v2.GetOrderRequest) (*v2.GetOrderResponse, error)

GetOrder gets an order by ID.

func (*TradingDataServiceV2) GetParty added in v0.71.0 

func (t *TradingDataServiceV2) GetParty(ctx context.Context, req *v2.GetPartyRequest) (*v2.GetPartyResponse, error)

GetParty returns a Party by ID.

func (*TradingDataServiceV2) GetPartyActivityStreak added in v0.73.0 

func (t *TradingDataServiceV2) GetPartyActivityStreak(ctx context.Context, req *v2.GetPartyActivityStreakRequest) (*v2.GetPartyActivityStreakResponse, error)

func (*TradingDataServiceV2) GetPartyDiscountStats added in v0.78.0 

func (t *TradingDataServiceV2) GetPartyDiscountStats(ctx context.Context, req *v2.GetPartyDiscountStatsRequest) (*v2.GetPartyDiscountStatsResponse, error)

GetPartyDiscountStats this is just passing the call through to the service.

func (*TradingDataServiceV2) GetPartyVestingStats added in v0.73.0 

func (t *TradingDataServiceV2) GetPartyVestingStats(
	ctx context.Context,
	req *v2.GetPartyVestingStatsRequest,
) (*v2.GetPartyVestingStatsResponse, error)

func (*TradingDataServiceV2) GetProtocolUpgradeStatus added in v0.71.0 

func (t *TradingDataServiceV2) GetProtocolUpgradeStatus(context.Context, *v2.GetProtocolUpgradeStatusRequest) (*v2.GetProtocolUpgradeStatusResponse, error)

GetProtocolUpgradeStatus returns the status of the protocol upgrade process.

func (*TradingDataServiceV2) GetReferralSetStats added in v0.73.0 

func (t *TradingDataServiceV2) GetReferralSetStats(ctx context.Context, req *v2.GetReferralSetStatsRequest) (
	*v2.GetReferralSetStatsResponse, error,
)

func (*TradingDataServiceV2) GetRiskFactors added in v0.71.0 

func (t *TradingDataServiceV2) GetRiskFactors(ctx context.Context, req *v2.GetRiskFactorsRequest) (*v2.GetRiskFactorsResponse, error)

GetRiskFactors returns the risk factors for a given market.

func (*TradingDataServiceV2) GetStake added in v0.71.0 

func (t *TradingDataServiceV2) GetStake(ctx context.Context, req *v2.GetStakeRequest) (*v2.GetStakeResponse, error)

GetStake returns the stake for a party and the linkings to that stake.

func (*TradingDataServiceV2) GetStopOrder added in v0.72.0 

func (t *TradingDataServiceV2) GetStopOrder(ctx context.Context, req *v2.GetStopOrderRequest) (*v2.GetStopOrderResponse, error)

func (*TradingDataServiceV2) GetTimeWeightedNotionalPosition added in v0.75.0 

func (t *TradingDataServiceV2) GetTimeWeightedNotionalPosition(ctx context.Context, req *v2.GetTimeWeightedNotionalPositionRequest) (*v2.GetTimeWeightedNotionalPositionResponse, error)

func (*TradingDataServiceV2) GetTotalTransferFeeDiscount added in v0.74.0 

func (t *TradingDataServiceV2) GetTotalTransferFeeDiscount(ctx context.Context, req *v2.GetTotalTransferFeeDiscountRequest) (
	*v2.GetTotalTransferFeeDiscountResponse, error,
)

func (*TradingDataServiceV2) GetTransfer added in v0.73.0 

func (t *TradingDataServiceV2) GetTransfer(ctx context.Context, req *v2.GetTransferRequest) (*v2.GetTransferResponse, error)

func (*TradingDataServiceV2) GetVegaTime added in v0.71.0 

func (t *TradingDataServiceV2) GetVegaTime(ctx context.Context, _ *v2.GetVegaTimeRequest) (*v2.GetVegaTimeResponse, error)

GetVegaTime returns the current vega time.

func (*TradingDataServiceV2) GetVestingBalancesSummary added in v0.73.0 

func (t *TradingDataServiceV2) GetVestingBalancesSummary(
	ctx context.Context,
	req *v2.GetVestingBalancesSummaryRequest,
) (*v2.GetVestingBalancesSummaryResponse, error)

func (*TradingDataServiceV2) GetVolumeDiscountStats added in v0.73.0 

func (t *TradingDataServiceV2) GetVolumeDiscountStats(ctx context.Context, req *v2.GetVolumeDiscountStatsRequest) (
	*v2.GetVolumeDiscountStatsResponse, error,
)

func (*TradingDataServiceV2) GetVolumeRebateStats added in v0.77.8 

func (t *TradingDataServiceV2) GetVolumeRebateStats(ctx context.Context, req *v2.GetVolumeRebateStatsRequest) (
	*v2.GetVolumeRebateStatsResponse, error,
)

func (*TradingDataServiceV2) GetWithdrawal added in v0.71.0 

func (t *TradingDataServiceV2) GetWithdrawal(ctx context.Context, req *v2.GetWithdrawalRequest) (*v2.GetWithdrawalResponse, error)

GetWithdrawal gets a withdrawal by ID.

func (*TradingDataServiceV2) Info added in v0.71.0 

func (t *TradingDataServiceV2) Info(_ context.Context, _ *v2.InfoRequest) (*v2.InfoResponse, error)

Info returns the version and commit hash of the trading data service.

func (*TradingDataServiceV2) ListAMMs added in v0.77.0 

func (t *TradingDataServiceV2) ListAMMs(ctx context.Context, req *v2.ListAMMsRequest) (*v2.ListAMMsResponse, error)

func (*TradingDataServiceV2) ListAccounts added in v0.71.0 

func (t *TradingDataServiceV2) ListAccounts(ctx context.Context, req *v2.ListAccountsRequest) (*v2.ListAccountsResponse, error)

ListAccounts lists accounts matching the request.

func (*TradingDataServiceV2) ListAllLiquidityProvisions added in v0.73.0 

func (t *TradingDataServiceV2) ListAllLiquidityProvisions(ctx context.Context, req *v2.ListAllLiquidityProvisionsRequest) (*v2.ListAllLiquidityProvisionsResponse, error)

ListAllLiquidityProvisions gets a list of liquidity provisions for a given market. This is similar to the list liquidity provisions API but returns a current and pending liquidity provision in the event a provision has been updated by the provider but the updated provision will not be active until the next epoch.

func (*TradingDataServiceV2) ListAllNetworkHistorySegments added in v0.71.0 

func (t *TradingDataServiceV2) ListAllNetworkHistorySegments(context.Context, *v2.ListAllNetworkHistorySegmentsRequest) (*v2.ListAllNetworkHistorySegmentsResponse, error)

ListAllNetworkHistorySegments returns all network history segments.

func (*TradingDataServiceV2) ListAllPositions added in v0.71.0 

func (t *TradingDataServiceV2) ListAllPositions(ctx context.Context, req *v2.ListAllPositionsRequest) (*v2.ListAllPositionsResponse, error)

ListAllPositions lists all positions.

func (*TradingDataServiceV2) ListAssets added in v0.71.0 

func (t *TradingDataServiceV2) ListAssets(ctx context.Context, req *v2.ListAssetsRequest) (*v2.ListAssetsResponse, error)

ListAssets gets all assets. If an asset ID is provided, it will return a single asset.

func (*TradingDataServiceV2) ListBalanceChanges added in v0.71.0 

func (t *TradingDataServiceV2) ListBalanceChanges(ctx context.Context, req *v2.ListBalanceChangesRequest) (*v2.ListBalanceChangesResponse, error)

ListBalanceChanges returns a list of balance changes matching the request.

func (*TradingDataServiceV2) ListCandleData added in v0.71.0 

func (t *TradingDataServiceV2) ListCandleData(ctx context.Context, req *v2.ListCandleDataRequest) (*v2.ListCandleDataResponse, error)

ListCandleData for a given market, time range and interval. Interval must be a valid postgres interval value.

func (*TradingDataServiceV2) ListCandleIntervals added in v0.71.0 

func (t *TradingDataServiceV2) ListCandleIntervals(ctx context.Context, req *v2.ListCandleIntervalsRequest) (*v2.ListCandleIntervalsResponse, error)

ListCandleIntervals gets all available intervals for a given market along with the corresponding candle id.

func (*TradingDataServiceV2) ListCheckpoints added in v0.71.0 

func (t *TradingDataServiceV2) ListCheckpoints(ctx context.Context, req *v2.ListCheckpointsRequest) (*v2.ListCheckpointsResponse, error)

ListCheckpoints returns a list of checkpoints.

func (*TradingDataServiceV2) ListCoreSnapshots added in v0.71.0 

func (t *TradingDataServiceV2) ListCoreSnapshots(ctx context.Context, req *v2.ListCoreSnapshotsRequest) (*v2.ListCoreSnapshotsResponse, error)

ListCoreSnapshots returns a list of core snapshots.

func (*TradingDataServiceV2) ListDelegations added in v0.71.0 

func (t *TradingDataServiceV2) ListDelegations(ctx context.Context, req *v2.ListDelegationsRequest) (*v2.ListDelegationsResponse, error)

ListDelegations returns a list of delegations using cursor pagination.

func (*TradingDataServiceV2) ListDeposits added in v0.71.0 

func (t *TradingDataServiceV2) ListDeposits(ctx context.Context, req *v2.ListDepositsRequest) (*v2.ListDepositsResponse, error)

ListDeposits gets deposits for a party.

func (*TradingDataServiceV2) ListERC20MultiSigSignerAddedBundles added in v0.71.0 

func (t *TradingDataServiceV2) ListERC20MultiSigSignerAddedBundles(ctx context.Context, req *v2.ListERC20MultiSigSignerAddedBundlesRequest) (*v2.ListERC20MultiSigSignerAddedBundlesResponse, error)

ListERC20MultiSigSignerAddedBundles returns the signature bundles needed to add a new validator to the multisig control ERC20 contract.

func (*TradingDataServiceV2) ListERC20MultiSigSignerRemovedBundles added in v0.71.0 

func (t *TradingDataServiceV2) ListERC20MultiSigSignerRemovedBundles(ctx context.Context, req *v2.ListERC20MultiSigSignerRemovedBundlesRequest) (*v2.ListERC20MultiSigSignerRemovedBundlesResponse, error)

ListERC20MultiSigSignerRemovedBundles returns the signature bundles needed to add a new validator to the multisig control ERC20 contract.

func (*TradingDataServiceV2) ListEntities added in v0.71.0 

func (t *TradingDataServiceV2) ListEntities(ctx context.Context, req *v2.ListEntitiesRequest) (*v2.ListEntitiesResponse, error)

func (*TradingDataServiceV2) ListEpochRewardSummaries added in v0.71.0 

func (t *TradingDataServiceV2) ListEpochRewardSummaries(ctx context.Context, req *v2.ListEpochRewardSummariesRequest) (*v2.ListEpochRewardSummariesResponse, error)

ListEpochRewardSummaries gets reward summaries for epoch range.

func (*TradingDataServiceV2) ListEthereumKeyRotations added in v0.71.0 

func (t *TradingDataServiceV2) ListEthereumKeyRotations(ctx context.Context, req *v2.ListEthereumKeyRotationsRequest) (*v2.ListEthereumKeyRotationsResponse, error)

ListEthereumKeyRotations returns a list of Ethereum key rotations.

func (*TradingDataServiceV2) ListFundingPayments added in v0.73.0 

func (t *TradingDataServiceV2) ListFundingPayments(ctx context.Context, req *v2.ListFundingPaymentsRequest) (*v2.ListFundingPaymentsResponse, error)

func (*TradingDataServiceV2) ListFundingPeriodDataPoints added in v0.73.0 

func (t *TradingDataServiceV2) ListFundingPeriodDataPoints(ctx context.Context, req *v2.ListFundingPeriodDataPointsRequest) (
	*v2.ListFundingPeriodDataPointsResponse, error,
)

func (*TradingDataServiceV2) ListFundingPeriods added in v0.73.0 

func (t *TradingDataServiceV2) ListFundingPeriods(ctx context.Context, req *v2.ListFundingPeriodsRequest) (*v2.ListFundingPeriodsResponse, error)

func (*TradingDataServiceV2) ListGamePartyScores added in v0.77.0 

func (t *TradingDataServiceV2) ListGamePartyScores(ctx context.Context, req *v2.ListGamePartyScoresRequest) (*v2.ListGamePartyScoresResponse, error)

func (*TradingDataServiceV2) ListGameTeamScores added in v0.77.0 

func (t *TradingDataServiceV2) ListGameTeamScores(ctx context.Context, req *v2.ListGameTeamScoresRequest) (*v2.ListGameTeamScoresResponse, error)

func (*TradingDataServiceV2) ListGames added in v0.74.0 

func (t *TradingDataServiceV2) ListGames(ctx context.Context, req *v2.ListGamesRequest) (*v2.ListGamesResponse, error)

func (*TradingDataServiceV2) ListGovernanceData added in v0.71.0 

func (t *TradingDataServiceV2) ListGovernanceData(ctx context.Context, req *v2.ListGovernanceDataRequest) (*v2.ListGovernanceDataResponse, error)

ListGovernanceData lists governance data using cursor pagination.

func (*TradingDataServiceV2) ListKeyRotations added in v0.71.0 

func (t *TradingDataServiceV2) ListKeyRotations(ctx context.Context, req *v2.ListKeyRotationsRequest) (*v2.ListKeyRotationsResponse, error)

ListKeyRotations returns a list of key rotations for a given node.

func (*TradingDataServiceV2) ListLatestMarketData added in v0.71.0 

func (t *TradingDataServiceV2) ListLatestMarketData(ctx context.Context, _ *v2.ListLatestMarketDataRequest) (*v2.ListLatestMarketDataResponse, error)

ListLatestMarketData returns the latest market data for every market.

func (*TradingDataServiceV2) ListLedgerEntries added in v0.71.0 

func (t *TradingDataServiceV2) ListLedgerEntries(ctx context.Context, req *v2.ListLedgerEntriesRequest) (*v2.ListLedgerEntriesResponse, error)

ListLedgerEntries returns a list of ledger entries matching the request.

func (*TradingDataServiceV2) ListLiquidityProviders added in v0.73.0 

func (t *TradingDataServiceV2) ListLiquidityProviders(ctx context.Context, req *v2.ListLiquidityProvidersRequest) (
	*v2.ListLiquidityProvidersResponse, error,
)

func (*TradingDataServiceV2) ListLiquidityProvisions added in v0.71.0 

func (t *TradingDataServiceV2) ListLiquidityProvisions(ctx context.Context, req *v2.ListLiquidityProvisionsRequest) (*v2.ListLiquidityProvisionsResponse, error)

ListLiquidityProvisions gets all liquidity provisions.

func (*TradingDataServiceV2) ListMarginLevels added in v0.71.0 

func (t *TradingDataServiceV2) ListMarginLevels(ctx context.Context, req *v2.ListMarginLevelsRequest) (*v2.ListMarginLevelsResponse, error)

ListMarginLevels lists MarginLevels.

func (*TradingDataServiceV2) ListMarkets added in v0.71.0 

func (t *TradingDataServiceV2) ListMarkets(ctx context.Context, req *v2.ListMarketsRequest) (*v2.ListMarketsResponse, error)

ListMarkets lists all markets.

func (*TradingDataServiceV2) ListNetworkParameters added in v0.71.0 

func (t *TradingDataServiceV2) ListNetworkParameters(ctx context.Context, req *v2.ListNetworkParametersRequest) (*v2.ListNetworkParametersResponse, error)

ListNetworkParameters returns a list of network parameters.

func (*TradingDataServiceV2) ListNodeSignatures added in v0.71.0 

func (t *TradingDataServiceV2) ListNodeSignatures(ctx context.Context, req *v2.ListNodeSignaturesRequest) (*v2.ListNodeSignaturesResponse, error)

ListNodeSignatures returns the signatures for a given node.

func (*TradingDataServiceV2) ListNodes added in v0.71.0 

func (t *TradingDataServiceV2) ListNodes(ctx context.Context, req *v2.ListNodesRequest) (*v2.ListNodesResponse, error)

ListNodes returns information about the nodes on the network.

func (*TradingDataServiceV2) ListOracleData added in v0.71.0 

func (t *TradingDataServiceV2) ListOracleData(ctx context.Context, req *v2.ListOracleDataRequest) (*v2.ListOracleDataResponse, error)

ListOracleData gets all oracle data.

func (*TradingDataServiceV2) ListOracleSpecs added in v0.71.0 

func (t *TradingDataServiceV2) ListOracleSpecs(ctx context.Context, req *v2.ListOracleSpecsRequest) (*v2.ListOracleSpecsResponse, error)

ListOracleSpecs gets all oracle specs.

func (*TradingDataServiceV2) ListOrderVersions added in v0.71.0 

func (t *TradingDataServiceV2) ListOrderVersions(ctx context.Context, req *v2.ListOrderVersionsRequest) (*v2.ListOrderVersionsResponse, error)

ListOrderVersions lists order versions using cursor pagination.

func (*TradingDataServiceV2) ListOrders added in v0.71.0 

func (t *TradingDataServiceV2) ListOrders(ctx context.Context, req *v2.ListOrdersRequest) (*v2.ListOrdersResponse, error)

ListOrders lists orders using cursor pagination.

func (*TradingDataServiceV2) ListPaidLiquidityFees added in v0.73.0 

func (t *TradingDataServiceV2) ListPaidLiquidityFees(ctx context.Context, req *v2.ListPaidLiquidityFeesRequest) (
	*v2.ListPaidLiquidityFeesResponse, error,
)

func (*TradingDataServiceV2) ListParties added in v0.71.0 

func (t *TradingDataServiceV2) ListParties(ctx context.Context, req *v2.ListPartiesRequest) (*v2.ListPartiesResponse, error)

ListParties lists Parties.

func (*TradingDataServiceV2) ListPartiesProfiles added in v0.74.0 

func (t *TradingDataServiceV2) ListPartiesProfiles(ctx context.Context, req *v2.ListPartiesProfilesRequest) (*v2.ListPartiesProfilesResponse, error)

func (*TradingDataServiceV2) ListPartyMarginModes added in v0.74.0 

func (t *TradingDataServiceV2) ListPartyMarginModes(ctx context.Context, req *v2.ListPartyMarginModesRequest) (*v2.ListPartyMarginModesResponse, error)

func (*TradingDataServiceV2) ListPositions deprecated added in v0.71.0 

func (t *TradingDataServiceV2) ListPositions(ctx context.Context, req *v2.ListPositionsRequest) (*v2.ListPositionsResponse, error)

List all Positions.

Deprecated: Use ListAllPositions instead.

func (*TradingDataServiceV2) ListProtocolUpgradeProposals added in v0.71.0 

func (t *TradingDataServiceV2) ListProtocolUpgradeProposals(ctx context.Context, req *v2.ListProtocolUpgradeProposalsRequest) (*v2.ListProtocolUpgradeProposalsResponse, error)

ListProtocolUpgradeProposals returns a list of protocol upgrade proposals.

func (*TradingDataServiceV2) ListReferralSetReferees added in v0.73.0 

func (t *TradingDataServiceV2) ListReferralSetReferees(ctx context.Context, req *v2.ListReferralSetRefereesRequest) (
	*v2.ListReferralSetRefereesResponse, error,
)

func (*TradingDataServiceV2) ListReferralSets added in v0.73.0 

func (t *TradingDataServiceV2) ListReferralSets(ctx context.Context, req *v2.ListReferralSetsRequest) (
	*v2.ListReferralSetsResponse, error,
)

func (*TradingDataServiceV2) ListRewardSummaries added in v0.71.0 

func (t *TradingDataServiceV2) ListRewardSummaries(ctx context.Context, req *v2.ListRewardSummariesRequest) (*v2.ListRewardSummariesResponse, error)

ListRewardSummaries gets reward summaries.

func (*TradingDataServiceV2) ListRewards added in v0.71.0 

func (t *TradingDataServiceV2) ListRewards(ctx context.Context, req *v2.ListRewardsRequest) (*v2.ListRewardsResponse, error)

ListRewards lists Rewards.

func (*TradingDataServiceV2) ListStopOrders added in v0.72.0 

func (t *TradingDataServiceV2) ListStopOrders(ctx context.Context, req *v2.ListStopOrdersRequest) (*v2.ListStopOrdersResponse, error)

func (*TradingDataServiceV2) ListSuccessorMarkets added in v0.72.0 

func (t *TradingDataServiceV2) ListSuccessorMarkets(ctx context.Context, req *v2.ListSuccessorMarketsRequest) (*v2.ListSuccessorMarketsResponse, error)

ListSuccessorMarkets returns the successor chain for a given market.

func (*TradingDataServiceV2) ListTeamMembersStatistics added in v0.74.0 

func (t *TradingDataServiceV2) ListTeamMembersStatistics(ctx context.Context, req *v2.ListTeamMembersStatisticsRequest) (*v2.ListTeamMembersStatisticsResponse, error)

func (*TradingDataServiceV2) ListTeamRefereeHistory added in v0.73.0 

func (t *TradingDataServiceV2) ListTeamRefereeHistory(ctx context.Context, req *v2.ListTeamRefereeHistoryRequest) (*v2.ListTeamRefereeHistoryResponse, error)

func (*TradingDataServiceV2) ListTeamReferees added in v0.73.0 

func (t *TradingDataServiceV2) ListTeamReferees(ctx context.Context, req *v2.ListTeamRefereesRequest) (*v2.ListTeamRefereesResponse, error)

func (*TradingDataServiceV2) ListTeams added in v0.73.0 

func (t *TradingDataServiceV2) ListTeams(ctx context.Context, req *v2.ListTeamsRequest) (*v2.ListTeamsResponse, error)

func (*TradingDataServiceV2) ListTeamsStatistics added in v0.74.0 

func (t *TradingDataServiceV2) ListTeamsStatistics(ctx context.Context, req *v2.ListTeamsStatisticsRequest) (*v2.ListTeamsStatisticsResponse, error)

func (*TradingDataServiceV2) ListTrades added in v0.71.0 

func (t *TradingDataServiceV2) ListTrades(ctx context.Context, req *v2.ListTradesRequest) (*v2.ListTradesResponse, error)

ListTrades lists trades by using a cursor based pagination model.

func (*TradingDataServiceV2) ListTransfers added in v0.71.0 

func (t *TradingDataServiceV2) ListTransfers(ctx context.Context, req *v2.ListTransfersRequest) (*v2.ListTransfersResponse, error)

ListTransfers lists transfers using cursor pagination. If a pubkey is provided, it will list transfers for that pubkey.

func (*TradingDataServiceV2) ListVotes added in v0.71.0 

func (t *TradingDataServiceV2) ListVotes(ctx context.Context, req *v2.ListVotesRequest) (*v2.ListVotesResponse, error)

ListVotes gets all Votes.

func (*TradingDataServiceV2) ListWithdrawals added in v0.71.0 

func (t *TradingDataServiceV2) ListWithdrawals(ctx context.Context, req *v2.ListWithdrawalsRequest) (*v2.ListWithdrawalsResponse, error)

ListWithdrawals gets withdrawals for a party.

func (*TradingDataServiceV2) ObserveAccounts added in v0.71.0 

func (t *TradingDataServiceV2) ObserveAccounts(req *v2.ObserveAccountsRequest, srv v2.TradingDataService_ObserveAccountsServer) error

ObserveAccounts streams account balances matching the request.

func (*TradingDataServiceV2) ObserveCandleData added in v0.71.0 

func (t *TradingDataServiceV2) ObserveCandleData(req *v2.ObserveCandleDataRequest, srv v2.TradingDataService_ObserveCandleDataServer) error

ObserveCandleData subscribes to candle updates for a given market and interval. Interval must be a valid postgres interval value.

func (*TradingDataServiceV2) ObserveEventBus added in v0.71.0 

func (t *TradingDataServiceV2) ObserveEventBus(stream v2.TradingDataService_ObserveEventBusServer) error

ObserveEventBus subscribes to a stream of events.

func (*TradingDataServiceV2) ObserveGovernance added in v0.71.0 

func (t *TradingDataServiceV2) ObserveGovernance(req *v2.ObserveGovernanceRequest, stream v2.TradingDataService_ObserveGovernanceServer) error

ObserveGovernance streams governance updates to the client.

func (*TradingDataServiceV2) ObserveLedgerMovements added in v0.71.0 

func (t *TradingDataServiceV2) ObserveLedgerMovements(_ *v2.ObserveLedgerMovementsRequest, srv v2.TradingDataService_ObserveLedgerMovementsServer) error

ObserveLedgerMovements subscribes to a stream of ledger movements.

func (*TradingDataServiceV2) ObserveLiquidityProvisions added in v0.71.0 

func (t *TradingDataServiceV2) ObserveLiquidityProvisions(req *v2.ObserveLiquidityProvisionsRequest, srv v2.TradingDataService_ObserveLiquidityProvisionsServer) error

ObserveLiquidityProvisions subscribes to liquidity provisions.

func (*TradingDataServiceV2) ObserveMarginLevels added in v0.71.0 

func (t *TradingDataServiceV2) ObserveMarginLevels(req *v2.ObserveMarginLevelsRequest, srv v2.TradingDataService_ObserveMarginLevelsServer) error

ObserveMarginLevels subscribes to a stream of Margin Levels.

func (*TradingDataServiceV2) ObserveMarketsData added in v0.71.0 

func (t *TradingDataServiceV2) ObserveMarketsData(req *v2.ObserveMarketsDataRequest, srv v2.TradingDataService_ObserveMarketsDataServer) error

ObserveMarketsData subscribes to market data updates.

func (*TradingDataServiceV2) ObserveMarketsDepth added in v0.71.0 

func (t *TradingDataServiceV2) ObserveMarketsDepth(req *v2.ObserveMarketsDepthRequest, srv v2.TradingDataService_ObserveMarketsDepthServer) error

ObserveMarketsDepth subscribes to market depth updates.

func (*TradingDataServiceV2) ObserveMarketsDepthUpdates added in v0.71.0 

func (t *TradingDataServiceV2) ObserveMarketsDepthUpdates(req *v2.ObserveMarketsDepthUpdatesRequest, srv v2.TradingDataService_ObserveMarketsDepthUpdatesServer) error

ObserveMarketsDepthUpdates subscribes to market depth updates.

func (*TradingDataServiceV2) ObserveOrders added in v0.71.0 

func (t *TradingDataServiceV2) ObserveOrders(req *v2.ObserveOrdersRequest, srv v2.TradingDataService_ObserveOrdersServer) error

ObserveOrders subscribes to a stream of orders.

func (*TradingDataServiceV2) ObservePositions added in v0.71.0 

func (t *TradingDataServiceV2) ObservePositions(req *v2.ObservePositionsRequest, srv v2.TradingDataService_ObservePositionsServer) error

ObservePositions subscribes to a stream of Positions.

func (*TradingDataServiceV2) ObserveTrades added in v0.71.0 

func (t *TradingDataServiceV2) ObserveTrades(req *v2.ObserveTradesRequest, srv v2.TradingDataService_ObserveTradesServer) error

ObserveTrades opens a subscription to the Trades service.

func (*TradingDataServiceV2) ObserveTransactionResults added in v0.74.0 

func (t *TradingDataServiceV2) ObserveTransactionResults(req *v2.ObserveTransactionResultsRequest, srv v2.TradingDataService_ObserveTransactionResultsServer) error

ObserveTransactionResults opens a subscription to the transaction results.

func (*TradingDataServiceV2) ObserveVotes added in v0.71.0 

func (t *TradingDataServiceV2) ObserveVotes(req *v2.ObserveVotesRequest, stream v2.TradingDataService_ObserveVotesServer) error

ObserveVotes streams votes for a given party or proposal.

func (*TradingDataServiceV2) Ping added in v0.71.0 

func (t *TradingDataServiceV2) Ping(context.Context, *v2.PingRequest) (*v2.PingResponse, error)

Ping returns a ping response.

func (*TradingDataServiceV2) SetLogger added in v0.77.0 

func (t *TradingDataServiceV2) SetLogger(l *logging.Logger)

type VegaIDsSlice added in v0.71.0 

type VegaIDsSlice []string

func NewVegaIDSlice added in v0.75.0 

func NewVegaIDSlice(input ...string) VegaIDsSlice

func (VegaIDsSlice) Ensure added in v0.71.0 

func (s VegaIDsSlice) Ensure() error

type VolumeDiscountService added in v0.78.0 

type VolumeDiscountService interface {
	Stats(ctx context.Context, atEpoch *uint64, partyID *string, pagination entities.CursorPagination) ([]entities.FlattenVolumeDiscountStats, entities.PageInfo, error)
}

VolumeDiscountService ...

Source Files

View all Source files

Directories

Path Synopsis
Package mocks is a generated GoMock package.
 Package mocks is a generated GoMock package.

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.