Documentation
¶
Index ¶
- Constants
- Variables
- func CreateLedgerEntryTime(vegaTime time.Time, seqNum int) time.Time
- func DeserializeSigners(data Signers) []*types.Signer
- func NanosToPostgresTimestamp(nanos int64) time.Time
- func NodeFromValidatorUpdateEvent(evt eventspb.ValidatorUpdate, txHash TxHash, vegaTime time.Time) (Node, ValidatorUpdateAux, error)
- func RankingScoreFromRankingEvent(evt eventspb.ValidatorRankingEvent, txHash TxHash, vegaTime time.Time) (RankingScore, RankingScoreAux, error)
- func ReverseSlice[T any](input []T) (reversed []T)
- func RewardScoreFromScoreEvent(evt eventspb.ValidatorScoreEvent, txHash TxHash, vegaTime time.Time) (RewardScore, RewardScoreAux, error)
- type Account
- type AccountBalance
- func (ab AccountBalance) Cursor() *Cursor
- func (ab AccountBalance) Equal(other AccountBalance) bool
- func (ab AccountBalance) Key() AccountBalanceKey
- func (ab *AccountBalance) ToProto() *v2.AccountBalance
- func (ab AccountBalance) ToProtoEdge(_ ...any) (*v2.AccountEdge, error)
- func (ab AccountBalance) ToRow() []interface{}
- type AccountBalanceKey
- type AccountCursor
- type AccountField
- type AccountFilter
- type AccountID
- type AccountSource
- type AggregatedBalance
- type AggregatedBalanceCursor
- type AggregatedLedgerEntriesCursor
- type AggregatedLedgerEntry
- type Asset
- type AssetCursor
- type AssetID
- type AssetStatus
- type AuctionDuration
- type Balance
- type BalanceKey
- type BeginBlockEvent
- type Block
- type Candle
- type CandleCursor
- type Chain
- type Checkpoint
- type CheckpointCursor
- type CloseOnLimitOperation
- type Condition
- type CoreSnapshotData
- type CoreSnapshotDataCursor
- type Cursor
- type CursorPagination
- type Data
- type DataSourceDefinition
- type DataSourceDefinitionExternal
- type DataSourceDefinitionInternal
- type DataSourceSpec
- type DataSourceSpecConfiguration
- type DataSourceSpecCursor
- type DataSourceSpecRaw
- type DataSourceSpecStatus
- type DateRange
- type Delegation
- type DelegationCursor
- type Deposit
- type DepositCursor
- type DepositID
- type DepositStatus
- type ERC20MultiSigSignerAddedEvent
- type ERC20MultiSigSignerEvent
- type ERC20MultiSigSignerEventCursor
- type ERC20MultiSigSignerEventID
- type ERC20MultiSigSignerEventType
- type ERC20MultiSigSignerRemovedEvent
- type Epoch
- type EpochData
- type EpochRewardSummary
- type EpochRewardSummaryCursor
- type EthereumAddress
- func (addr *EthereumAddress) Bytes() ([]byte, error)
- func (addr *EthereumAddress) DecodeBinary(ci *pgtype.ConnInfo, src []byte) error
- func (addr EthereumAddress) EncodeBinary(ci *pgtype.ConnInfo, buf []byte) ([]byte, error)
- func (addr *EthereumAddress) Error() error
- func (addr *EthereumAddress) String() string
- type EthereumKeyRotation
- type EthereumKeyRotationCursor
- type ExternalData
- type ExternalDataCursor
- type ExternalDataSourceSpec
- type FeeFactors
- type Fees
- type Filter
- type ID
- type KeyRotation
- type KeyRotationCursor
- type LedgerEntry
- type LedgerEntryField
- type LedgerEntryFilter
- type LedgerMovementType
- type LiquidityMonitoringParameters
- type LiquidityOrderReference
- type LiquidityProviderFeeShare
- type LiquidityProvision
- func (lp LiquidityProvision) Cursor() *Cursor
- func (lp LiquidityProvision) Key() LiquidityProvisionKey
- func (lp *LiquidityProvision) ToProto() *vega.LiquidityProvision
- func (lp LiquidityProvision) ToProtoEdge(_ ...any) (*v2.LiquidityProvisionsEdge, error)
- func (lp LiquidityProvision) ToRow() []interface{}
- type LiquidityProvisionCursor
- type LiquidityProvisionID
- type LiquidityProvisionKey
- type LiquidityProvisionStatus
- type MarginCursor
- type MarginLevels
- func (ml MarginLevels) Cursor() *Cursor
- func (ml MarginLevels) Key() MarginLevelsKey
- func (ml *MarginLevels) ToProto(ctx context.Context, accountSource AccountSource) (*vega.MarginLevels, error)
- func (ml MarginLevels) ToProtoEdge(input ...any) (*v2.MarginEdge, error)
- func (ml MarginLevels) ToRow() []interface{}
- type MarginLevelsKey
- type Market
- type MarketCursor
- type MarketData
- type MarketDataCursor
- type MarketDepth
- type MarketID
- type MarketState
- type MarketTimestamps
- type MarketTradingMode
- type NetworkLimits
- type NetworkParameter
- type NetworkParameterCursor
- type Node
- type NodeCursor
- type NodeData
- type NodeID
- type NodeSet
- type NodeSignature
- type NodeSignatureCursor
- type NodeSignatureID
- type NodeSignatureKind
- type NodeStatus
- type OffsetPagination
- type OracleData
- type OracleDataCursor
- type OracleSpec
- type OracleSpecStatus
- type Order
- type OrderCursor
- type OrderError
- type OrderFilter
- type OrderID
- type OrderKey
- type OrderStatus
- type OrderTimeInForce
- type OrderType
- type PageInfo
- type PagedEntity
- type Pagination
- type Party
- type PartyID
- type PeggedReference
- type Position
- func (p *Position) AverageEntryPriceUint() *num.Uint
- func (p Position) Cursor() *Cursor
- func (p Position) Equal(q Position) bool
- func (p Position) Key() PositionKey
- func (p *Position) ToProto() *vega.Position
- func (p Position) ToProtoEdge(_ ...any) (*v2.PositionEdge, error)
- func (p Position) ToRow() []interface{}
- func (p *Position) UpdateWithLossSocialization(e lossSocialization)
- func (p *Position) UpdateWithPositionSettlement(e positionSettlement)
- func (p *Position) UpdateWithSettleDistressed(e settleDistressed)
- func (p *Position) UpdateWithSettleMarket(e settleMarket)
- type PositionCursor
- type PositionKey
- type PriceLevel
- type PriceMonitoringBound
- type PriceMonitoringParameters
- type PriceMonitoringSettings
- type PriceMonitoringTrigger
- type Property
- type PropertyKey
- type Proposal
- type ProposalCursor
- type ProposalError
- type ProposalID
- type ProposalRationale
- type ProposalState
- type ProposalTerms
- type ProposalType
- type ProtocolUpgradeProposal
- type ProtocolUpgradeProposalCursor
- type ProtocolUpgradeProposalStatus
- type RankingScore
- type RankingScoreAux
- type Reward
- type RewardCursor
- type RewardScore
- type RewardScoreAux
- type RewardSummary
- type RiskFactor
- type Side
- type Signer
- type Signers
- type SpecID
- type StakeLinking
- type StakeLinkingCursor
- type StakeLinkingID
- type StakeLinkingStatus
- type StakeLinkingType
- type TargetStakeParameters
- type TendermintPublicKey
- func (pk *TendermintPublicKey) Bytes() ([]byte, error)
- func (pk *TendermintPublicKey) DecodeBinary(ci *pgtype.ConnInfo, src []byte) error
- func (pk TendermintPublicKey) EncodeBinary(ci *pgtype.ConnInfo, buf []byte) ([]byte, error)
- func (pk *TendermintPublicKey) Error() error
- func (pk *TendermintPublicKey) String() string
- type TimeUpdateEvent
- type TradableInstrument
- type Trade
- type TradeCursor
- type TradeID
- type TradeType
- type Transfer
- type TransferCursor
- type TransferID
- type TransferStatus
- type TransferType
- type TxHash
- type ValidatorNodeStatus
- type ValidatorUpdateAux
- type VegaPublicKey
- type Vote
- type VoteCursor
- type VoteValue
- type WithdrawExt
- type Withdrawal
- type WithdrawalCursor
- type WithdrawalID
- type WithdrawalStatus
Constants ¶
const ( AccountFieldUnspecified = iota AccountFieldID AccountFieldPartyID AccountFieldAssetID AccountFieldMarketID AccountFieldType )
const ( OneOffStr = "OneOff" RecurringStr = "Recurring" UnknownStr = "Unknown" )
const ( TransferStatusUnspecified = TransferStatus(eventspb.Transfer_STATUS_UNSPECIFIED) TransferStatusPending = TransferStatus(eventspb.Transfer_STATUS_PENDING) TransferStatusDone = TransferStatus(eventspb.Transfer_STATUS_DONE) TransferStatusRejected = TransferStatus(eventspb.Transfer_STATUS_REJECTED) TransferStatusStopped = TransferStatus(eventspb.Transfer_STATUS_STOPPED) TransferStatusCancelled = TransferStatus(eventspb.Transfer_STATUS_CANCELLED) )
const ( AssetStatusUnspecified = AssetStatus(vega.Asset_STATUS_UNSPECIFIED) AssetStatusProposed = AssetStatus(vega.Asset_STATUS_PROPOSED) AssetStatusRejected = AssetStatus(vega.Asset_STATUS_REJECTED) AssetStatusPendingListing = AssetStatus(vega.Asset_STATUS_PENDING_LISTING) AssetStatusEnabled = AssetStatus(vega.Asset_STATUS_ENABLED) )
const ( MarketTradingModeUnspecified = MarketTradingMode(vega.Market_TRADING_MODE_UNSPECIFIED) MarketTradingModeContinuous = MarketTradingMode(vega.Market_TRADING_MODE_CONTINUOUS) MarketTradingModeBatchAuction = MarketTradingMode(vega.Market_TRADING_MODE_BATCH_AUCTION) MarketTradingModeOpeningAuction = MarketTradingMode(vega.Market_TRADING_MODE_OPENING_AUCTION) MarketTradingModeMonitoringAuction = MarketTradingMode(vega.Market_TRADING_MODE_MONITORING_AUCTION) MarketTradingModeNoTrading = MarketTradingMode(vega.Market_TRADING_MODE_NO_TRADING) )
const ( MarketStateUnspecified = MarketState(vega.Market_STATE_UNSPECIFIED) MarketStateProposed = MarketState(vega.Market_STATE_PROPOSED) MarketStateRejected = MarketState(vega.Market_STATE_REJECTED) MarketStatePending = MarketState(vega.Market_STATE_PENDING) MarketStateCancelled = MarketState(vega.Market_STATE_CANCELLED) MarketStateActive = MarketState(vega.Market_STATE_ACTIVE) MarketStateSuspended = MarketState(vega.Market_STATE_SUSPENDED) MarketStateClosed = MarketState(vega.Market_STATE_CLOSED) MarketStateTradingTerminated = MarketState(vega.Market_STATE_TRADING_TERMINATED) MarketStateSettled = MarketState(vega.Market_STATE_SETTLED) )
const ( DepositStatusUnspecified = DepositStatus(vega.Deposit_STATUS_UNSPECIFIED) DepositStatusOpen = DepositStatus(vega.Deposit_STATUS_OPEN) DepositStatusCancelled = DepositStatus(vega.Deposit_STATUS_CANCELLED) DepositStatusFinalized = DepositStatus(vega.Deposit_STATUS_FINALIZED) )
const ( WithdrawalStatusUnspecified = WithdrawalStatus(vega.Withdrawal_STATUS_UNSPECIFIED) WithdrawalStatusOpen = WithdrawalStatus(vega.Withdrawal_STATUS_OPEN) WithdrawalStatusRejected = WithdrawalStatus(vega.Withdrawal_STATUS_REJECTED) WithdrawalStatusFinalized = WithdrawalStatus(vega.Withdrawal_STATUS_FINALIZED) )
const ( ProposalStateUnspecified = ProposalState(vega.Proposal_STATE_UNSPECIFIED) ProposalStateFailed = ProposalState(vega.Proposal_STATE_FAILED) ProposalStateOpen = ProposalState(vega.Proposal_STATE_OPEN) ProposalStatePassed = ProposalState(vega.Proposal_STATE_PASSED) ProposalStateRejected = ProposalState(vega.Proposal_STATE_REJECTED) ProposalStateDeclined = ProposalState(vega.Proposal_STATE_DECLINED) ProposalStateEnacted = ProposalState(vega.Proposal_STATE_ENACTED) ProposalStateWaitingForNodeVote = ProposalState(vega.Proposal_STATE_WAITING_FOR_NODE_VOTE) )
const ( ProposalErrorUnspecified = ProposalError(vega.ProposalError_PROPOSAL_ERROR_UNSPECIFIED) ProposalErrorCloseTimeTooSoon = ProposalError(vega.ProposalError_PROPOSAL_ERROR_CLOSE_TIME_TOO_SOON) ProposalErrorCloseTimeTooLate = ProposalError(vega.ProposalError_PROPOSAL_ERROR_CLOSE_TIME_TOO_LATE) ProposalErrorEnactTimeTooSoon = ProposalError(vega.ProposalError_PROPOSAL_ERROR_ENACT_TIME_TOO_SOON) ProposalErrorEnactTimeTooLate = ProposalError(vega.ProposalError_PROPOSAL_ERROR_ENACT_TIME_TOO_LATE) ProposalErrorInsufficientTokens = ProposalError(vega.ProposalError_PROPOSAL_ERROR_INSUFFICIENT_TOKENS) ProposalErrorInvalidInstrumentSecurity = ProposalError(vega.ProposalError_PROPOSAL_ERROR_INVALID_INSTRUMENT_SECURITY) ProposalErrorNoProduct = ProposalError(vega.ProposalError_PROPOSAL_ERROR_NO_PRODUCT) ProposalErrorUnsupportedProduct = ProposalError(vega.ProposalError_PROPOSAL_ERROR_UNSUPPORTED_PRODUCT) ProposalErrorNoTradingMode = ProposalError(vega.ProposalError_PROPOSAL_ERROR_NO_TRADING_MODE) ProposalErrorUnsupportedTradingMode = ProposalError(vega.ProposalError_PROPOSAL_ERROR_UNSUPPORTED_TRADING_MODE) ProposalErrorNodeValidationFailed = ProposalError(vega.ProposalError_PROPOSAL_ERROR_NODE_VALIDATION_FAILED) ProposalErrorMissingBuiltinAssetField = ProposalError(vega.ProposalError_PROPOSAL_ERROR_MISSING_BUILTIN_ASSET_FIELD) ProposalErrorMissingErc20ContractAddress = ProposalError(vega.ProposalError_PROPOSAL_ERROR_MISSING_ERC20_CONTRACT_ADDRESS) ProposalErrorInvalidAsset = ProposalError(vega.ProposalError_PROPOSAL_ERROR_INVALID_ASSET) ProposalErrorIncompatibleTimestamps = ProposalError(vega.ProposalError_PROPOSAL_ERROR_INCOMPATIBLE_TIMESTAMPS) ProposalErrorNoRiskParameters = ProposalError(vega.ProposalError_PROPOSAL_ERROR_NO_RISK_PARAMETERS) ProposalErrorNetworkParameterInvalidKey = ProposalError(vega.ProposalError_PROPOSAL_ERROR_NETWORK_PARAMETER_INVALID_KEY) ProposalErrorNetworkParameterInvalidValue = ProposalError(vega.ProposalError_PROPOSAL_ERROR_NETWORK_PARAMETER_INVALID_VALUE) ProposalErrorNetworkParameterValidationFailed = ProposalError(vega.ProposalError_PROPOSAL_ERROR_NETWORK_PARAMETER_VALIDATION_FAILED) ProposalErrorOpeningAuctionDurationTooSmall = ProposalError(vega.ProposalError_PROPOSAL_ERROR_OPENING_AUCTION_DURATION_TOO_SMALL) ProposalErrorOpeningAuctionDurationTooLarge = ProposalError(vega.ProposalError_PROPOSAL_ERROR_OPENING_AUCTION_DURATION_TOO_LARGE) ProposalErrorCouldNotInstantiateMarket = ProposalError(vega.ProposalError_PROPOSAL_ERROR_COULD_NOT_INSTANTIATE_MARKET) ProposalErrorInvalidFutureProduct = ProposalError(vega.ProposalError_PROPOSAL_ERROR_INVALID_FUTURE_PRODUCT) ProposalErrorInvalidRiskParameter = ProposalError(vega.ProposalError_PROPOSAL_ERROR_INVALID_RISK_PARAMETER) ProposalErrorMajorityThresholdNotReached = ProposalError(vega.ProposalError_PROPOSAL_ERROR_MAJORITY_THRESHOLD_NOT_REACHED) ProposalErrorParticipationThresholdNotReached = ProposalError(vega.ProposalError_PROPOSAL_ERROR_PARTICIPATION_THRESHOLD_NOT_REACHED) ProposalErrorInvalidAssetDetails = ProposalError(vega.ProposalError_PROPOSAL_ERROR_INVALID_ASSET_DETAILS) ProposalErrorUnknownType = ProposalError(vega.ProposalError_PROPOSAL_ERROR_UNKNOWN_TYPE) ProposalErrorUnknownRiskParameterType = ProposalError(vega.ProposalError_PROPOSAL_ERROR_UNKNOWN_RISK_PARAMETER_TYPE) ProposalErrorInvalidFreeform = ProposalError(vega.ProposalError_PROPOSAL_ERROR_INVALID_FREEFORM) ProposalErrorInvalidMarket = ProposalError(vega.ProposalError_PROPOSAL_ERROR_INVALID_MARKET) ProposalErrorTooManyMarketDecimalPlaces = ProposalError(vega.ProposalError_PROPOSAL_ERROR_TOO_MANY_MARKET_DECIMAL_PLACES) ProposalErrorTooManyPriceMonitoringTriggers = ProposalError(vega.ProposalError_PROPOSAL_ERROR_TOO_MANY_PRICE_MONITORING_TRIGGERS) ProposalErrorERC20AddressAlreadyInUse = ProposalError(vega.ProposalError_PROPOSAL_ERROR_ERC20_ADDRESS_ALREADY_IN_USE) )
const ( VoteValueUnspecified = VoteValue(vega.Vote_VALUE_UNSPECIFIED) VoteValueNo = VoteValue(vega.Vote_VALUE_NO) VoteValueYes = VoteValue(vega.Vote_VALUE_YES) )
const ( NodeSignatureKindUnspecified = NodeSignatureKind(commandspb.NodeSignatureKind_NODE_SIGNATURE_KIND_UNSPECIFIED) NodeSignatureKindAsset = NodeSignatureKind(commandspb.NodeSignatureKind_NODE_SIGNATURE_KIND_ASSET_NEW) NodeSignatureKindAssetUpdate = NodeSignatureKind(commandspb.NodeSignatureKind_NODE_SIGNATURE_KIND_ASSET_UPDATE) NodeSignatureKindAssetWithdrawal = NodeSignatureKind(commandspb.NodeSignatureKind_NODE_SIGNATURE_KIND_ASSET_WITHDRAWAL) NodeSignatureKindMultisigSignerAdded = NodeSignatureKind(commandspb.NodeSignatureKind_NODE_SIGNATURE_KIND_ERC20_MULTISIG_SIGNER_ADDED) NodeSignatureKindMultisigSignerRemove = NodeSignatureKind(commandspb.NodeSignatureKind_NODE_SIGNATURE_KIND_ERC20_MULTISIG_SIGNER_REMOVED) )
const ( OracleSpecUnspecified = DataSourceSpecStatus(vegapb.DataSourceSpec_STATUS_UNSPECIFIED) OracleSpecActive = DataSourceSpecStatus(vegapb.DataSourceSpec_STATUS_ACTIVE) OracleSpecDeactivated = DataSourceSpecStatus(vegapb.DataSourceSpec_STATUS_DEACTIVATED) )
const ( LiquidityProvisionStatusUnspecified = LiquidityProvisionStatus(vega.LiquidityProvision_STATUS_UNSPECIFIED) LiquidityProvisionStatusActive = LiquidityProvisionStatus(vega.LiquidityProvision_STATUS_ACTIVE) LiquidityProvisionStatusStopped = LiquidityProvisionStatus(vega.LiquidityProvision_STATUS_STOPPED) LiquidityProvisionStatusCancelled = LiquidityProvisionStatus(vega.LiquidityProvision_STATUS_CANCELLED) LiquidityProvisionStatusRejected = LiquidityProvisionStatus(vega.LiquidityProvision_STATUS_REJECTED) LiquidityProvisionStatusUndeployed = LiquidityProvisionStatus(vega.LiquidityProvision_STATUS_UNDEPLOYED) LiquidityProvisionStatusPending = LiquidityProvisionStatus(vega.LiquidityProvision_STATUS_PENDING) )
const ( StakeLinkingStatusUnspecified = StakeLinkingStatus(eventspb.StakeLinking_STATUS_UNSPECIFIED) StakeLinkingStatusPending = StakeLinkingStatus(eventspb.StakeLinking_STATUS_PENDING) StakeLinkingStatusAccepted = StakeLinkingStatus(eventspb.StakeLinking_STATUS_ACCEPTED) StakeLinkingStatusRejected = StakeLinkingStatus(eventspb.StakeLinking_STATUS_REJECTED) )
const ( StakeLinkingTypeUnspecified = StakeLinkingType(eventspb.StakeLinking_TYPE_UNSPECIFIED) StakeLinkingTypeLink = StakeLinkingType(eventspb.StakeLinking_TYPE_LINK) StakeLinkingTypeUnlink = StakeLinkingType(eventspb.StakeLinking_TYPE_UNLINK) )
const ( NodeStatusUnspecified = NodeStatus(vega.NodeStatus_NODE_STATUS_UNSPECIFIED) NodeStatusValidator = NodeStatus(vega.NodeStatus_NODE_STATUS_VALIDATOR) NodeStatusNonValidator = NodeStatus(vega.NodeStatus_NODE_STATUS_NON_VALIDATOR) )
const ( ValidatorNodeStatusUnspecified = ValidatorNodeStatus(vega.ValidatorNodeStatus_VALIDATOR_NODE_STATUS_UNSPECIFIED) ValidatorNodeStatusTendermint = ValidatorNodeStatus(vega.ValidatorNodeStatus_VALIDATOR_NODE_STATUS_TENDERMINT) ValidatorNodeStatusErsatz = ValidatorNodeStatus(vega.ValidatorNodeStatus_VALIDATOR_NODE_STATUS_ERSATZ) ValidatorNodeStatusPending = ValidatorNodeStatus(vega.ValidatorNodeStatus_VALIDATOR_NODE_STATUS_PENDING) )
const ( // Default value, always invalid. LedgerMovementTypeUnspecified = LedgerMovementType(vega.TransferType_TRANSFER_TYPE_UNSPECIFIED) // Loss. LedgerMovementTypeLoss = LedgerMovementType(vega.TransferType_TRANSFER_TYPE_LOSS) // Win. LedgerMovementTypeWin = LedgerMovementType(vega.TransferType_TRANSFER_TYPE_WIN) // Mark to market loss. LedgerMovementTypeMTMLoss = LedgerMovementType(vega.TransferType_TRANSFER_TYPE_MTM_LOSS) // Mark to market win. LedgerMovementTypeMTMWin = LedgerMovementType(vega.TransferType_TRANSFER_TYPE_MTM_WIN) // Margin too low. LedgerMovementTypeMarginLow = LedgerMovementType(vega.TransferType_TRANSFER_TYPE_MARGIN_LOW) // Margin too high. LedgerMovementTypeMarginHigh = LedgerMovementType(vega.TransferType_TRANSFER_TYPE_MARGIN_HIGH) // Margin was confiscated. LedgerMovementTypeMarginConfiscated = LedgerMovementType(vega.TransferType_TRANSFER_TYPE_MARGIN_CONFISCATED) // Pay maker fee. LedgerMovementTypeMakerFeePay = LedgerMovementType(vega.TransferType_TRANSFER_TYPE_MAKER_FEE_PAY) // Receive maker fee. LedgerMovementTypeMakerFeeReceive = LedgerMovementType(vega.TransferType_TRANSFER_TYPE_MAKER_FEE_RECEIVE) // Pay infrastructure fee. LedgerMovementTypeInfrastructureFeePay = LedgerMovementType(vega.TransferType_TRANSFER_TYPE_INFRASTRUCTURE_FEE_PAY) // Receive infrastructure fee. LedgerMovementTypeInfrastructureFeeDistribute = LedgerMovementType(vega.TransferType_TRANSFER_TYPE_INFRASTRUCTURE_FEE_DISTRIBUTE) // Pay liquidity fee. LedgerMovementTypeLiquidityFeePay = LedgerMovementType(vega.TransferType_TRANSFER_TYPE_LIQUIDITY_FEE_PAY) // Receive liquidity fee. LedgerMovementTypeLiquidityFeeDistribute = LedgerMovementType(vega.TransferType_TRANSFER_TYPE_LIQUIDITY_FEE_DISTRIBUTE) // Bond too low. LedgerMovementTypeBondLow = LedgerMovementType(vega.TransferType_TRANSFER_TYPE_BOND_LOW) // Bond too high. LedgerMovementTypeBondHigh = LedgerMovementType(vega.TransferType_TRANSFER_TYPE_BOND_HIGH) // Actual withdraw from system. LedgerMovementTypeWithdraw = LedgerMovementType(vega.TransferType_TRANSFER_TYPE_WITHDRAW) // Deposit funds. LedgerMovementTypeDeposit = LedgerMovementType(vega.TransferType_TRANSFER_TYPE_DEPOSIT) // Bond slashing. LedgerMovementTypeBondSlashing = LedgerMovementType(vega.TransferType_TRANSFER_TYPE_BOND_SLASHING) // Reward payout. LedgerMovementTypeRewardPayout = LedgerMovementType(vega.TransferType_TRANSFER_TYPE_REWARD_PAYOUT) LedgerMovementTypeTransferFundsSend = LedgerMovementType(vega.TransferType_TRANSFER_TYPE_TRANSFER_FUNDS_SEND) LedgerMovementTypeTransferFundsDistribute = LedgerMovementType(vega.TransferType_TRANSFER_TYPE_TRANSFER_FUNDS_DISTRIBUTE) LedgerMovementTypeClearAccount = LedgerMovementType(vega.TransferType_TRANSFER_TYPE_CLEAR_ACCOUNT) )
const ( LedgerEntryFieldUnspecified = iota LedgerEntryFieldTransferType )
Variables ¶
var ( ErrInvalidID = errors.New("not a valid hex id (or well known exception)") ErrNotFound = errors.New("no resource corresponding to this id") )
var ( ProposalTypeNewMarket = ProposalType(v2.ListGovernanceDataRequest_TYPE_NEW_MARKET) ProposalTypeNewAsset = ProposalType(v2.ListGovernanceDataRequest_TYPE_NEW_ASSET) ProposalTypeUpdateAsset = ProposalType(v2.ListGovernanceDataRequest_TYPE_UPDATE_ASSET) ProposalTypeUpdateMarket = ProposalType(v2.ListGovernanceDataRequest_TYPE_UPDATE_MARKET) ProposalTypeUpdateNetworkParameter = ProposalType(v2.ListGovernanceDataRequest_TYPE_NETWORK_PARAMETERS) ProposalTypeNewFreeform = ProposalType(v2.ListGovernanceDataRequest_TYPE_NEW_FREE_FORM) )
var BalanceColumns = []string{"account_id", "tx_hash", "vega_time", "balance"}
var ErrChainAlreadySet = errors.New("chain already set")
var ErrMarketDataIntegerOverflow = errors.New("integer overflow encountered when converting market data for persistence")
var LedgerEntryColumns = []string{
"ledger_entry_time",
"account_from_id", "account_to_id", "quantity",
"tx_hash", "vega_time", "transfer_time", "type",
}
var LiquidityProvisionColumns = []string{
"id", "party_id", "created_at", "updated_at", "market_id",
"commitment_amount", "fee", "sells", "buys", "version",
"status", "reference", "tx_hash", "vega_time",
}
var MarginLevelsColumns = []string{
"account_id", "timestamp", "maintenance_margin",
"search_level", "initial_margin", "collateral_release_level", "tx_hash", "vega_time",
}
var OrderColumns = []string{
"id", "market_id", "party_id", "side", "price",
"size", "remaining", "time_in_force", "type", "status",
"reference", "reason", "version", "pegged_offset", "batch_id",
"pegged_reference", "lp_id", "created_at", "updated_at", "expires_at",
"tx_hash", "vega_time", "seq_num",
}
var PositionColumns = []string{
"market_id", "party_id", "open_volume", "realised_pnl", "unrealised_pnl",
"average_entry_price", "average_entry_market_price", "loss", "adjustment", "tx_hash", "vega_time",
}
var ValidatorStatusRanking = map[ValidatorNodeStatus]int{ ValidatorNodeStatusUnspecified: 0, ValidatorNodeStatusPending: 1, ValidatorNodeStatusErsatz: 2, ValidatorNodeStatusTendermint: 3, }
ValidatorStatusRanking so we know which direction was a promotion and which was a demotion.
Functions ¶
func CreateLedgerEntryTime ¶ added in v0.57.0
func DeserializeSigners ¶ added in v0.61.0
func NanosToPostgresTimestamp ¶
NanosToPostgresTimestamp postgres stores timestamps in microsecond resolution.
func NodeFromValidatorUpdateEvent ¶
func NodeFromValidatorUpdateEvent(evt eventspb.ValidatorUpdate, txHash TxHash, vegaTime time.Time) (Node, ValidatorUpdateAux, error)
func RankingScoreFromRankingEvent ¶
func RankingScoreFromRankingEvent(evt eventspb.ValidatorRankingEvent, txHash TxHash, vegaTime time.Time) (RankingScore, RankingScoreAux, error)
func ReverseSlice ¶
func ReverseSlice[T any](input []T) (reversed []T)
func RewardScoreFromScoreEvent ¶
func RewardScoreFromScoreEvent(evt eventspb.ValidatorScoreEvent, txHash TxHash, vegaTime time.Time) (RewardScore, RewardScoreAux, error)
Types ¶
type Account ¶
type Account struct { ID AccountID PartyID PartyID AssetID AssetID MarketID MarketID Type vega.AccountType TxHash TxHash VegaTime time.Time }
func AccountProtoFromDetails ¶ added in v0.56.0
func AccountProtoFromDetails(ad *vega.AccountDetails, txHash TxHash) (Account, error)
func GetAccountFromMarginLevel ¶
func GetAccountFromMarginLevel(ctx context.Context, margin *vega.MarginLevels, accountSource AccountSource, txHash TxHash, vegaTime time.Time) (Account, error)
type AccountBalance ¶
func (AccountBalance) Cursor ¶
func (ab AccountBalance) Cursor() *Cursor
func (AccountBalance) Equal ¶
func (ab AccountBalance) Equal(other AccountBalance) bool
func (AccountBalance) Key ¶
func (ab AccountBalance) Key() AccountBalanceKey
func (*AccountBalance) ToProto ¶
func (ab *AccountBalance) ToProto() *v2.AccountBalance
func (AccountBalance) ToProtoEdge ¶
func (ab AccountBalance) ToProtoEdge(_ ...any) (*v2.AccountEdge, error)
func (AccountBalance) ToRow ¶
func (ab AccountBalance) ToRow() []interface{}
type AccountBalanceKey ¶
type AccountCursor ¶
type AccountCursor struct {
AccountID AccountID `json:"account_id"`
}
func (*AccountCursor) Parse ¶
func (ac *AccountCursor) Parse(cursorString string) error
func (AccountCursor) String ¶
func (ac AccountCursor) String() string
type AccountField ¶
type AccountField int64
AccountField is an enumeration of the properties of an account which can be used for grouping and sorting.
func AccountFieldFromProto ¶
func AccountFieldFromProto(field v2.AccountField) (AccountField, error)
func (AccountField) String ¶
func (s AccountField) String() string
type AccountFilter ¶
type AccountFilter struct { AssetID AssetID PartyIDs []PartyID AccountTypes []types.AccountType MarketIDs []MarketID }
func AccountFilterFromProto ¶
func AccountFilterFromProto(pbFilter *v2.AccountFilter) (AccountFilter, error)
type AccountSource ¶
type AggregatedBalance ¶
type AggregatedBalance struct { VegaTime time.Time Balance decimal.Decimal AccountID *AccountID PartyID *PartyID AssetID *AssetID MarketID *MarketID Type *types.AccountType }
AggregatedBalance represents the the summed balance of a bunch of accounts at a given time. VegaTime and Balance will always be set. The others will be nil unless when querying, you requested grouping by one of the corresponding fields.
func AggregatedBalanceScan ¶ added in v0.58.0
func AggregatedBalanceScan(fields []AccountField, rows interface { Next() bool Values() ([]any, error) }, ) ([]AggregatedBalance, error)
NewAggregatedBalanceFromValues returns a new AggregatedBalance from a list of values as returned from pgx.rows.values(). - vegaTime is assumed to be first - then any extra fields listed in 'fields' in order (usually as as result of grouping) - then finally the balance itself.
func (AggregatedBalance) Cursor ¶ added in v0.55.0
func (balance AggregatedBalance) Cursor() *Cursor
func (*AggregatedBalance) ToProto ¶
func (balance *AggregatedBalance) ToProto() *v2.AggregatedBalance
func (AggregatedBalance) ToProtoEdge ¶ added in v0.55.0
func (balance AggregatedBalance) ToProtoEdge(_ ...any) (*v2.AggregatedBalanceEdge, error)
type AggregatedBalanceCursor ¶ added in v0.55.0
type AggregatedBalanceCursor struct { VegaTime time.Time `json:"vega_time"` AccountID *AccountID PartyID *PartyID AssetID *AssetID MarketID *MarketID Type *types.AccountType }
func (*AggregatedBalanceCursor) Parse ¶ added in v0.55.0
func (c *AggregatedBalanceCursor) Parse(cursorString string) error
func (AggregatedBalanceCursor) String ¶ added in v0.55.0
func (c AggregatedBalanceCursor) String() string
type AggregatedLedgerEntriesCursor ¶ added in v0.58.0
func (*AggregatedLedgerEntriesCursor) Parse ¶ added in v0.58.0
func (c *AggregatedLedgerEntriesCursor) Parse(cursorString string) error
func (AggregatedLedgerEntriesCursor) String ¶ added in v0.58.0
func (c AggregatedLedgerEntriesCursor) String() string
type AggregatedLedgerEntry ¶ added in v0.63.0
type AggregatedLedgerEntry struct { VegaTime time.Time Quantity decimal.Decimal TransferType *LedgerMovementType AssetID *AssetID SenderPartyID *PartyID ReceiverPartyID *PartyID SenderMarketID *MarketID ReceiverMarketID *MarketID SenderAccountType *types.AccountType ReceiverAccountType *types.AccountType }
AggregatedLedgerEntry represents the the summed amount of ledger entries for a set of accounts within a given time range. VegaTime and Quantity will always be set. The others will be nil unless when querying grouping by one of the corresponding fields is requested.
func (AggregatedLedgerEntry) Cursor ¶ added in v0.63.0
func (ledgerEntries AggregatedLedgerEntry) Cursor() *Cursor
func (*AggregatedLedgerEntry) ToProto ¶ added in v0.63.0
func (ledgerEntries *AggregatedLedgerEntry) ToProto() *v2.AggregatedLedgerEntry
func (AggregatedLedgerEntry) ToProtoEdge ¶ added in v0.63.0
func (ledgerEntries AggregatedLedgerEntry) ToProtoEdge(_ ...any) (*v2.AggregatedLedgerEntriesEdge, error)
type Asset ¶
type AssetCursor ¶
type AssetCursor struct {
ID AssetID `json:"id"`
}
func (*AssetCursor) Parse ¶
func (ac *AssetCursor) Parse(cursorString string) error
func (AssetCursor) String ¶
func (ac AssetCursor) String() string
type AssetStatus ¶
type AssetStatus vega.Asset_Status
func (*AssetStatus) DecodeText ¶
func (m *AssetStatus) DecodeText(_ *pgtype.ConnInfo, src []byte) error
func (AssetStatus) EncodeText ¶
type AuctionDuration ¶
type Balance ¶
type Balance struct { AccountID AccountID TxHash TxHash VegaTime time.Time Balance decimal.Decimal }
func (Balance) Key ¶
func (b Balance) Key() BalanceKey
type BalanceKey ¶
type BeginBlockEvent ¶ added in v0.58.0
type BeginBlockEvent interface { events.Event BeginBlock() eventspb.BeginBlock }
type Block ¶
func BlockFromBeginBlock ¶ added in v0.58.0
func BlockFromBeginBlock(b BeginBlockEvent) (*Block, error)
func BlockFromTimeUpdate ¶
func BlockFromTimeUpdate(te TimeUpdateEvent) (*Block, error)
type Candle ¶
type Candle struct { PeriodStart time.Time LastUpdateInPeriod time.Time Open decimal.Decimal Close decimal.Decimal High decimal.Decimal Low decimal.Decimal Volume uint64 }
func (Candle) ToProtoEdge ¶
func (c Candle) ToProtoEdge(_ ...any) (*v2.CandleEdge, error)
func (*Candle) ToV1CandleProto ¶
func (*Candle) ToV2CandleProto ¶
type CandleCursor ¶
func (*CandleCursor) Parse ¶
func (c *CandleCursor) Parse(cursorString string) error
func (CandleCursor) String ¶
func (c CandleCursor) String() string
type Checkpoint ¶
type Checkpoint struct { Hash string BlockHash string BlockHeight int64 TxHash TxHash VegaTime time.Time SeqNum uint64 }
func CheckpointFromProto ¶
func CheckpointFromProto(cpe *eventspb.CheckpointEvent, txHash TxHash) (Checkpoint, error)
func (Checkpoint) Cursor ¶
func (cp Checkpoint) Cursor() *Cursor
func (*Checkpoint) ToProto ¶
func (cp *Checkpoint) ToProto() *v2.Checkpoint
func (Checkpoint) ToProtoEdge ¶
func (cp Checkpoint) ToProtoEdge(_ ...any) (*v2.CheckpointEdge, error)
type CheckpointCursor ¶
type CheckpointCursor struct {
BlockHeight int64 `json:"blockHeight"`
}
func (*CheckpointCursor) Parse ¶
func (cp *CheckpointCursor) Parse(cursorString string) error
func (CheckpointCursor) String ¶
func (cp CheckpointCursor) String() string
type CloseOnLimitOperation ¶ added in v0.58.0
type CloseOnLimitOperation bool
CloseOnLimitOperation is the type that is used for opening and closing the set of output items under some operation. Intended for generic use.
type Condition ¶
type Condition struct { Operator v1.Condition_Operator Value string }
type CoreSnapshotData ¶ added in v0.65.0
type CoreSnapshotData struct { BlockHeight uint64 BlockHash string VegaCoreVersion string TxHash TxHash VegaTime time.Time }
func CoreSnapshotDataFromProto ¶ added in v0.65.0
func CoreSnapshotDataFromProto(s *eventspb.CoreSnapshotData, txHash TxHash, vegaTime time.Time) CoreSnapshotData
func (CoreSnapshotData) Cursor ¶ added in v0.65.0
func (s CoreSnapshotData) Cursor() *Cursor
func (*CoreSnapshotData) ToProto ¶ added in v0.65.0
func (s *CoreSnapshotData) ToProto() *eventspb.CoreSnapshotData
func (CoreSnapshotData) ToProtoEdge ¶ added in v0.65.0
func (s CoreSnapshotData) ToProtoEdge(_ ...any) (*v2.CoreSnapshotEdge, error)
type CoreSnapshotDataCursor ¶ added in v0.65.0
type CoreSnapshotDataCursor struct { VegaTime time.Time BlockHeight uint64 BlockHash string VegaCoreVersion string }
func (*CoreSnapshotDataCursor) Parse ¶ added in v0.65.0
func (sc *CoreSnapshotDataCursor) Parse(cursorString string) error
func (CoreSnapshotDataCursor) String ¶ added in v0.65.0
func (sc CoreSnapshotDataCursor) String() string
type CursorPagination ¶
type CursorPagination struct { Pagination Forward *offset Backward *offset NewestFirst bool }
func CursorPaginationFromProto ¶
func CursorPaginationFromProto(cp *v2.Pagination) (CursorPagination, error)
func DefaultCursorPagination ¶
func DefaultCursorPagination(newestFirst bool) CursorPagination
func NewCursorPagination ¶
func (CursorPagination) HasBackward ¶
func (p CursorPagination) HasBackward() bool
func (CursorPagination) HasForward ¶
func (p CursorPagination) HasForward() bool
type DataSourceDefinition ¶ added in v0.62.0
type DataSourceDefinition struct { Type int External *DataSourceDefinitionExternal Internal *DataSourceDefinitionInternal }
func (*DataSourceDefinition) GetFilters ¶ added in v0.62.0
func (s *DataSourceDefinition) GetFilters() []*v1.Filter
func (*DataSourceDefinition) GetSigners ¶ added in v0.62.0
func (s *DataSourceDefinition) GetSigners() []*v1.Signer
type DataSourceDefinitionExternal ¶ added in v0.62.0
type DataSourceDefinitionInternal ¶ added in v0.62.0
type DataSourceSpec ¶ added in v0.61.0
type DataSourceSpec struct { ID SpecID CreatedAt time.Time UpdatedAt time.Time Data *DataSourceDefinition Status DataSourceSpecStatus TxHash TxHash VegaTime time.Time }
func DataSourceSpecFromProto ¶ added in v0.61.0
func DataSourceSpecFromProto(spec *vegapb.DataSourceSpec, txHash TxHash, vegaTime time.Time) (*DataSourceSpec, error)
func (DataSourceSpec) Cursor ¶ added in v0.61.0
func (ds DataSourceSpec) Cursor() *Cursor
func (*DataSourceSpec) ToOracleProto ¶ added in v0.61.0
func (ds *DataSourceSpec) ToOracleProto() *vegapb.OracleSpec
func (DataSourceSpec) ToOracleProtoEdge ¶ added in v0.61.0
func (ds DataSourceSpec) ToOracleProtoEdge(_ ...any) (*v2.OracleSpecEdge, error)
func (*DataSourceSpec) ToProto ¶ added in v0.61.0
func (ds *DataSourceSpec) ToProto() *vegapb.DataSourceSpec
type DataSourceSpecConfiguration ¶ added in v0.61.0
type DataSourceSpecCursor ¶ added in v0.61.0
func (*DataSourceSpecCursor) Parse ¶ added in v0.61.0
func (ds *DataSourceSpecCursor) Parse(cursorString string) error
func (DataSourceSpecCursor) String ¶ added in v0.61.0
func (ds DataSourceSpecCursor) String() string
type DataSourceSpecRaw ¶ added in v0.61.0
type DataSourceSpecStatus ¶ added in v0.61.0
type DataSourceSpecStatus vegapb.DataSourceSpec_Status
func (*DataSourceSpecStatus) DecodeText ¶ added in v0.61.0
func (s *DataSourceSpecStatus) DecodeText(_ *pgtype.ConnInfo, src []byte) error
func (DataSourceSpecStatus) EncodeText ¶ added in v0.61.0
type DateRange ¶ added in v0.55.0
func DateRangeFromProto ¶ added in v0.55.0
type Delegation ¶
type Delegation struct { PartyID PartyID `json:"party_id"` NodeID NodeID `json:"node_id"` EpochID int64 `json:"epoch_id"` Amount decimal.Decimal `json:"amount"` TxHash TxHash VegaTime time.Time SeqNum uint64 }
func DelegationFromEventProto ¶
func DelegationFromEventProto(pd *eventspb.DelegationBalanceEvent, txHash TxHash) (Delegation, error)
func DelegationFromProto ¶
func DelegationFromProto(pd *vega.Delegation, txHash TxHash) (Delegation, error)
func (Delegation) Cursor ¶
func (d Delegation) Cursor() *Cursor
func (Delegation) String ¶
func (d Delegation) String() string
func (*Delegation) ToProto ¶
func (d *Delegation) ToProto() *vega.Delegation
func (Delegation) ToProtoEdge ¶
func (d Delegation) ToProtoEdge(_ ...any) (*v2.DelegationEdge, error)
type DelegationCursor ¶
type DelegationCursor struct { VegaTime time.Time `json:"vegaTime"` PartyID PartyID `json:"partyId"` NodeID NodeID `json:"nodeId"` EpochID int64 `json:"epochId"` }
func (*DelegationCursor) Parse ¶
func (c *DelegationCursor) Parse(cursorString string) error
func (DelegationCursor) String ¶
func (c DelegationCursor) String() string
type Deposit ¶
type Deposit struct { ID DepositID Status DepositStatus PartyID PartyID Asset AssetID Amount decimal.Decimal ForeignTxHash string CreditedTimestamp time.Time CreatedTimestamp time.Time TxHash TxHash VegaTime time.Time }
func DepositFromProto ¶
func (Deposit) ToProtoEdge ¶
func (d Deposit) ToProtoEdge(_ ...any) (*v2.DepositEdge, error)
type DepositCursor ¶
func (*DepositCursor) Parse ¶
func (dc *DepositCursor) Parse(cursorString string) error
func (DepositCursor) String ¶
func (dc DepositCursor) String() string
type DepositStatus ¶
type DepositStatus vega.Deposit_Status
func (*DepositStatus) DecodeText ¶
func (s *DepositStatus) DecodeText(_ *pgtype.ConnInfo, src []byte) error
func (DepositStatus) EncodeText ¶
type ERC20MultiSigSignerAddedEvent ¶
type ERC20MultiSigSignerAddedEvent struct {
ERC20MultiSigSignerEvent
}
func (ERC20MultiSigSignerAddedEvent) Cursor ¶
func (e ERC20MultiSigSignerAddedEvent) Cursor() *Cursor
func (ERC20MultiSigSignerAddedEvent) ToProto ¶
func (e ERC20MultiSigSignerAddedEvent) ToProto() *eventspb.ERC20MultiSigSignerAdded
func (ERC20MultiSigSignerAddedEvent) ToProtoEdge ¶
func (e ERC20MultiSigSignerAddedEvent) ToProtoEdge(_ ...any) (*v2.ERC20MultiSigSignerAddedEdge, error)
type ERC20MultiSigSignerEvent ¶
type ERC20MultiSigSignerEvent struct { ID ERC20MultiSigSignerEventID ValidatorID NodeID SignerChange EthereumAddress Submitter EthereumAddress Nonce string TxHash TxHash VegaTime time.Time EpochID int64 Event ERC20MultiSigSignerEventType }
func ERC20MultiSigSignerEventFromAddedProto ¶
func ERC20MultiSigSignerEventFromAddedProto(e *eventspb.ERC20MultiSigSignerAdded, txHash TxHash) (*ERC20MultiSigSignerEvent, error)
func ERC20MultiSigSignerEventFromRemovedProto ¶
func ERC20MultiSigSignerEventFromRemovedProto(e *eventspb.ERC20MultiSigSignerRemoved, txHash TxHash) ([]*ERC20MultiSigSignerEvent, error)
func (ERC20MultiSigSignerEvent) Cursor ¶
func (e ERC20MultiSigSignerEvent) Cursor() *Cursor
type ERC20MultiSigSignerEventCursor ¶
type ERC20MultiSigSignerEventCursor struct { VegaTime time.Time `json:"vega_time"` ID ERC20MultiSigSignerEventID `json:"id"` }
func (*ERC20MultiSigSignerEventCursor) Parse ¶
func (c *ERC20MultiSigSignerEventCursor) Parse(cursorString string) error
func (ERC20MultiSigSignerEventCursor) String ¶
func (c ERC20MultiSigSignerEventCursor) String() string
type ERC20MultiSigSignerEventID ¶
type ERC20MultiSigSignerEventID = ID[_ERC20MultiSigSignerEvent]
type ERC20MultiSigSignerEventType ¶
type ERC20MultiSigSignerEventType string
const ( ERC20MultiSigSignerEventTypeAdded ERC20MultiSigSignerEventType = "SIGNER_ADDED" ERC20MultiSigSignerEventTypeRemoved ERC20MultiSigSignerEventType = "SIGNER_REMOVED" )
type ERC20MultiSigSignerRemovedEvent ¶
type ERC20MultiSigSignerRemovedEvent struct {
ERC20MultiSigSignerEvent
}
func (ERC20MultiSigSignerRemovedEvent) Cursor ¶
func (e ERC20MultiSigSignerRemovedEvent) Cursor() *Cursor
func (ERC20MultiSigSignerRemovedEvent) ToProto ¶
func (e ERC20MultiSigSignerRemovedEvent) ToProto() *eventspb.ERC20MultiSigSignerRemoved
func (ERC20MultiSigSignerRemovedEvent) ToProtoEdge ¶
func (e ERC20MultiSigSignerRemovedEvent) ToProtoEdge(_ ...any) (*v2.ERC20MultiSigSignerRemovedEdge, error)
type Epoch ¶
type Epoch struct { ID int64 StartTime time.Time ExpireTime time.Time EndTime *time.Time TxHash TxHash VegaTime time.Time }
func EpochFromProto ¶
func EpochFromProto(ee eventspb.EpochEvent, txHash TxHash) Epoch
type EpochRewardSummary ¶ added in v0.65.0
type EpochRewardSummary struct { AssetID AssetID MarketID MarketID RewardType string EpochID uint64 Amount num.Decimal }
func (EpochRewardSummary) Cursor ¶ added in v0.65.0
func (r EpochRewardSummary) Cursor() *Cursor
func (*EpochRewardSummary) ToProto ¶ added in v0.65.0
func (r *EpochRewardSummary) ToProto() *vega.EpochRewardSummary
func (EpochRewardSummary) ToProtoEdge ¶ added in v0.65.0
func (r EpochRewardSummary) ToProtoEdge(_ ...any) (*v2.EpochRewardSummaryEdge, error)
type EpochRewardSummaryCursor ¶ added in v0.65.0
type EpochRewardSummaryCursor struct { EpochID uint64 `json:"epoch_id"` AssetID string `json:"asset_id"` MarketID string `json:"market_id"` RewardType string `json:"reward_type"` Amount string `json:"amount"` }
func (*EpochRewardSummaryCursor) Parse ¶ added in v0.65.0
func (rc *EpochRewardSummaryCursor) Parse(cursorString string) error
func (EpochRewardSummaryCursor) String ¶ added in v0.65.0
func (rc EpochRewardSummaryCursor) String() string
type EthereumAddress ¶
type EthereumAddress string
func (*EthereumAddress) Bytes ¶
func (addr *EthereumAddress) Bytes() ([]byte, error)
func (*EthereumAddress) DecodeBinary ¶
func (addr *EthereumAddress) DecodeBinary(ci *pgtype.ConnInfo, src []byte) error
func (EthereumAddress) EncodeBinary ¶
func (*EthereumAddress) Error ¶
func (addr *EthereumAddress) Error() error
func (*EthereumAddress) String ¶
func (addr *EthereumAddress) String() string
type EthereumKeyRotation ¶
type EthereumKeyRotation struct { NodeID NodeID OldAddress EthereumAddress NewAddress EthereumAddress BlockHeight uint64 TxHash TxHash VegaTime time.Time SeqNum uint64 }
func EthereumKeyRotationFromProto ¶
func EthereumKeyRotationFromProto(kr *eventspb.EthereumKeyRotation, txHash TxHash, vegaTime time.Time, seqNum uint64, ) (EthereumKeyRotation, error)
func (EthereumKeyRotation) Cursor ¶
func (kr EthereumKeyRotation) Cursor() *Cursor
func (EthereumKeyRotation) ToProto ¶
func (kr EthereumKeyRotation) ToProto() *eventspb.EthereumKeyRotation
func (EthereumKeyRotation) ToProtoEdge ¶
func (kr EthereumKeyRotation) ToProtoEdge(_ ...any) (*v2.EthereumKeyRotationEdge, error)
type EthereumKeyRotationCursor ¶
type EthereumKeyRotationCursor struct { VegaTime time.Time `json:"vegaTime"` NodeID NodeID `json:"nodeID"` OldAddress EthereumAddress `json:"oldAddress"` NewAddress EthereumAddress `json:"newAddress"` }
func (*EthereumKeyRotationCursor) Parse ¶
func (ec *EthereumKeyRotationCursor) Parse(cursorString string) error
func (EthereumKeyRotationCursor) String ¶
func (ec EthereumKeyRotationCursor) String() string
type ExternalData ¶ added in v0.61.0
type ExternalData struct {
Data *Data
}
func ExternalDataFromProto ¶ added in v0.61.0
func ExternalDataFromProto(data *datapb.ExternalData, txHash TxHash, vegaTime time.Time, seqNum uint64) (*ExternalData, error)
func (ExternalData) Cursor ¶ added in v0.61.0
func (od ExternalData) Cursor() *Cursor
func (ExternalData) ToOracleProto ¶ added in v0.61.0
func (od ExternalData) ToOracleProto() *vegapb.OracleData
func (ExternalData) ToOracleProtoEdge ¶ added in v0.61.0
func (od ExternalData) ToOracleProtoEdge(_ ...any) (*v2.OracleDataEdge, error)
func (*ExternalData) ToProto ¶ added in v0.61.0
func (od *ExternalData) ToProto() *datapb.ExternalData
type ExternalDataCursor ¶ added in v0.61.0
type ExternalDataCursor struct { VegaTime time.Time `json:"vegaTime"` Signers Signers `json:"signers"` }
func (*ExternalDataCursor) Parse ¶ added in v0.61.0
func (c *ExternalDataCursor) Parse(cursorString string) error
func (ExternalDataCursor) String ¶ added in v0.61.0
func (c ExternalDataCursor) String() string
type ExternalDataSourceSpec ¶ added in v0.61.0
type ExternalDataSourceSpec struct {
Spec *DataSourceSpec
}
func ExternalDataSourceSpecFromProto ¶ added in v0.61.0
func ExternalDataSourceSpecFromProto(spec *vegapb.ExternalDataSourceSpec, txHash TxHash, vegaTime time.Time) (*ExternalDataSourceSpec, error)
func (*ExternalDataSourceSpec) ToProto ¶ added in v0.61.0
func (s *ExternalDataSourceSpec) ToProto() *vegapb.ExternalDataSourceSpec
type FeeFactors ¶
type Fees ¶
type Fees struct {
Factors *FeeFactors `json:"factors,omitempty"`
}
type Filter ¶
type Filter struct { Key PropertyKey `json:"key"` Conditions []Condition `json:"conditions"` }
func FiltersFromProto ¶ added in v0.61.0
type ID ¶
func (ID[T]) EncodeBinary ¶
type KeyRotation ¶
type KeyRotation struct { NodeID NodeID OldPubKey VegaPublicKey NewPubKey VegaPublicKey BlockHeight uint64 TxHash TxHash VegaTime time.Time }
func KeyRotationFromProto ¶
func KeyRotationFromProto(kr *eventspb.KeyRotation, txHash TxHash, vegaTime time.Time) (*KeyRotation, error)
func (KeyRotation) Cursor ¶
func (kr KeyRotation) Cursor() *Cursor
func (*KeyRotation) ToProto ¶
func (kr *KeyRotation) ToProto() *eventspb.KeyRotation
func (KeyRotation) ToProtoEdge ¶
func (kr KeyRotation) ToProtoEdge(_ ...any) (*v2.KeyRotationEdge, error)
type KeyRotationCursor ¶
type KeyRotationCursor struct { VegaTime time.Time `json:"vega_time"` NodeID NodeID `json:"node_id"` OldPubKey VegaPublicKey `json:"old_pub_key"` NewPubKey VegaPublicKey `json:"new_pub_key"` }
func (*KeyRotationCursor) Parse ¶
func (c *KeyRotationCursor) Parse(cursorString string) error
func (KeyRotationCursor) String ¶
func (c KeyRotationCursor) String() string
type LedgerEntry ¶
type LedgerEntry struct { LedgerEntryTime time.Time AccountFromID AccountID AccountToID AccountID Quantity decimal.Decimal TxHash TxHash VegaTime time.Time TransferTime time.Time Type LedgerMovementType }
func (LedgerEntry) ToRow ¶
func (le LedgerEntry) ToRow() []any
type LedgerEntryField ¶ added in v0.58.0
type LedgerEntryField int64
LedgerEntryField is an enumeration of the properties of a ledger entry which can be used for grouping and sorting.
func LedgerEntryFieldFromProto ¶ added in v0.58.0
func LedgerEntryFieldFromProto(field v2.LedgerEntryField) (LedgerEntryField, error)
func (LedgerEntryField) String ¶ added in v0.58.0
func (s LedgerEntryField) String() string
type LedgerEntryFilter ¶ added in v0.58.0
type LedgerEntryFilter struct { // CloseOnAccountFilters is used to open/close the output set of entries under the AccountFrom/AccountTo values. // If true -> the output set will contain entries which sending and receiving accounts // all match the criteria given in the `AccountFilter` type. // Otherwise will contain entries that have a match the settings in both accounts (sending or receiving) or in one of them. CloseOnAccountFilters CloseOnLimitOperation // SenderAccountFilter is a filter which is used to request properties for AccountFrom field. SenderAccountFilter AccountFilter // ReceiverAccountFilter is a filter which is used to request properties for AccountTo field. ReceiverAccountFilter AccountFilter // Filter on LedgerMovementType TransferTypes []LedgerMovementType }
Settings for receiving closed/open sets on different parts of the outputs of LedgerEntries. Any kind of relation between the data types on logical and practical level in the set is the `limit operation`. We close or not the set of output items on the limit operation via the `CloseOnOperation` set values.
func LedgerEntryFilterFromProto ¶ added in v0.58.0
func LedgerEntryFilterFromProto(pbFilter *v2.LedgerEntryFilter) (*LedgerEntryFilter, error)
type LedgerMovementType ¶ added in v0.56.0
type LedgerMovementType vega.TransferType
func (*LedgerMovementType) DecodeText ¶ added in v0.56.0
func (l *LedgerMovementType) DecodeText(_ *pgtype.ConnInfo, src []byte) error
func (LedgerMovementType) EncodeText ¶ added in v0.56.0
type LiquidityMonitoringParameters ¶
type LiquidityMonitoringParameters struct { TargetStakeParameters *TargetStakeParameters `json:"targetStakeParameters,omitempty"` TriggeringRatio float64 `json:"triggeringRatio,omitempty"` AuctionExtension int64 `json:"auctionExtension,omitempty"` }
func (LiquidityMonitoringParameters) ToProto ¶
func (lmp LiquidityMonitoringParameters) ToProto() *vega.LiquidityMonitoringParameters
type LiquidityOrderReference ¶
type LiquidityOrderReference struct {
*vega.LiquidityOrderReference
}
func (*LiquidityOrderReference) DecodeBinary ¶
func (l *LiquidityOrderReference) DecodeBinary(_ *pgtype.ConnInfo, src []byte) error
func (LiquidityOrderReference) EncodeBinary ¶
type LiquidityProviderFeeShare ¶
type LiquidityProviderFeeShare struct {}
func (LiquidityProviderFeeShare) Equals ¶
func (fee LiquidityProviderFeeShare) Equals(other LiquidityProviderFeeShare) bool
type LiquidityProvision ¶
type LiquidityProvision struct { ID LiquidityProvisionID PartyID PartyID CreatedAt time.Time UpdatedAt time.Time MarketID MarketID CommitmentAmount decimal.Decimal Fee decimal.Decimal Sells []LiquidityOrderReference Buys []LiquidityOrderReference Version int64 Status LiquidityProvisionStatus Reference string TxHash TxHash VegaTime time.Time }
func LiquidityProvisionFromProto ¶
func LiquidityProvisionFromProto(lpProto *vega.LiquidityProvision, txHash TxHash, vegaTime time.Time) (LiquidityProvision, error)
func (LiquidityProvision) Cursor ¶
func (lp LiquidityProvision) Cursor() *Cursor
func (LiquidityProvision) Key ¶
func (lp LiquidityProvision) Key() LiquidityProvisionKey
func (*LiquidityProvision) ToProto ¶
func (lp *LiquidityProvision) ToProto() *vega.LiquidityProvision
func (LiquidityProvision) ToProtoEdge ¶
func (lp LiquidityProvision) ToProtoEdge(_ ...any) (*v2.LiquidityProvisionsEdge, error)
func (LiquidityProvision) ToRow ¶
func (lp LiquidityProvision) ToRow() []interface{}
type LiquidityProvisionCursor ¶
type LiquidityProvisionCursor struct { VegaTime time.Time `json:"vegaTime"` ID LiquidityProvisionID `json:"id"` }
func (*LiquidityProvisionCursor) Parse ¶
func (lc *LiquidityProvisionCursor) Parse(cursorString string) error
func (LiquidityProvisionCursor) String ¶
func (lc LiquidityProvisionCursor) String() string
type LiquidityProvisionID ¶
type LiquidityProvisionID = ID[_LiquidityProvision]
type LiquidityProvisionKey ¶
type LiquidityProvisionKey struct { ID LiquidityProvisionID VegaTime time.Time }
type LiquidityProvisionStatus ¶
type LiquidityProvisionStatus vega.LiquidityProvision_Status
func (*LiquidityProvisionStatus) DecodeText ¶
func (s *LiquidityProvisionStatus) DecodeText(_ *pgtype.ConnInfo, src []byte) error
func (LiquidityProvisionStatus) EncodeText ¶
type MarginCursor ¶
func (*MarginCursor) Parse ¶
func (mc *MarginCursor) Parse(cursorString string) error
func (MarginCursor) String ¶
func (mc MarginCursor) String() string
type MarginLevels ¶
type MarginLevels struct { AccountID AccountID MaintenanceMargin decimal.Decimal SearchLevel decimal.Decimal InitialMargin decimal.Decimal CollateralReleaseLevel decimal.Decimal Timestamp time.Time TxHash TxHash VegaTime time.Time }
func MarginLevelsFromProto ¶
func MarginLevelsFromProto(ctx context.Context, margin *vega.MarginLevels, accountSource AccountSource, txHash TxHash, vegaTime time.Time) (MarginLevels, error)
func (MarginLevels) Cursor ¶
func (ml MarginLevels) Cursor() *Cursor
func (MarginLevels) Key ¶
func (ml MarginLevels) Key() MarginLevelsKey
func (*MarginLevels) ToProto ¶
func (ml *MarginLevels) ToProto(ctx context.Context, accountSource AccountSource) (*vega.MarginLevels, error)
func (MarginLevels) ToProtoEdge ¶
func (ml MarginLevels) ToProtoEdge(input ...any) (*v2.MarginEdge, error)
func (MarginLevels) ToRow ¶
func (ml MarginLevels) ToRow() []interface{}
type MarginLevelsKey ¶
type Market ¶
type Market struct { ID MarketID TxHash TxHash VegaTime time.Time InstrumentID string TradableInstrument TradableInstrument DecimalPlaces int Fees Fees OpeningAuction AuctionDuration PriceMonitoringSettings PriceMonitoringSettings LiquidityMonitoringParameters LiquidityMonitoringParameters TradingMode MarketTradingMode State MarketState MarketTimestamps MarketTimestamps PositionDecimalPlaces int LpPriceRange string }
func NewMarketFromProto ¶
func (Market) ToProtoEdge ¶
func (m Market) ToProtoEdge(_ ...any) (*v2.MarketEdge, error)
type MarketCursor ¶
func (*MarketCursor) Parse ¶
func (mc *MarketCursor) Parse(cursorString string) error
func (MarketCursor) String ¶
func (mc MarketCursor) String() string
type MarketData ¶
type MarketData struct { // Mark price, as an integer, for example `123456` is a correctly // formatted price of `1.23456` assuming market configured to 5 decimal places MarkPrice decimal.Decimal // Highest price level on an order book for buy orders, as an integer, for example `123456` is a correctly // formatted price of `1.23456` assuming market configured to 5 decimal places BestBidPrice decimal.Decimal // Aggregated volume being bid at the best bid price BestBidVolume uint64 // Aggregated volume being bid at the best bid price BestOfferPrice decimal.Decimal // Aggregated volume being offered at the best offer price, as an integer, for example `123456` is a correctly // formatted price of `1.23456` assuming market configured to 5 decimal places BestOfferVolume uint64 // Highest price on the order book for buy orders not including pegged orders BestStaticBidPrice decimal.Decimal // Total volume at the best static bid price excluding pegged orders BestStaticBidVolume uint64 // Lowest price on the order book for sell orders not including pegged orders BestStaticOfferPrice decimal.Decimal // Total volume at the best static offer price excluding pegged orders BestStaticOfferVolume uint64 // Arithmetic average of the best bid price and best offer price, as an integer, for example `123456` is a correctly // formatted price of `1.23456` assuming market configured to 5 decimal places MidPrice decimal.Decimal // Arithmetic average of the best static bid price and best static offer price StaticMidPrice decimal.Decimal // Market identifier for the data Market MarketID // The sum of the size of all positions greater than 0 on the market OpenInterest uint64 // Time in seconds until the end of the auction (0 if currently not in auction period) AuctionEnd int64 // Time until next auction (used in FBA's) - currently always 0 AuctionStart int64 // Indicative price (zero if not in auction) IndicativePrice decimal.Decimal // Indicative volume (zero if not in auction) IndicativeVolume uint64 // The current trading mode for the market MarketTradingMode string // The current trading mode for the market MarketState string // When a market is in an auction trading mode, this field indicates what triggered the auction AuctionTrigger string // When a market auction is extended, this field indicates what caused the extension ExtensionTrigger string // Targeted stake for the given market TargetStake decimal.Decimal // Available stake for the given market SuppliedStake decimal.Decimal // One or more price monitoring bounds for the current timestamp PriceMonitoringBounds []*PriceMonitoringBound // the market value proxy MarketValueProxy string LiquidityProviderFeeShares []*LiquidityProviderFeeShare // A synthetic time created which is the sum of vega_time + (seq num * Microsecond) SyntheticTime time.Time // Transaction which caused this update TxHash TxHash // Vega Block time at which the data was received from Vega Node VegaTime time.Time // SeqNum is the order in which the market data was received in the block SeqNum uint64 // NextMarkToMarket is the next timestamp when the market wil be marked to market NextMarkToMarket time.Time }
MarketData represents a market data record that is stored in the SQL database.
func MarketDataFromProto ¶
func MarketDataFromProto(data *types.MarketData, txHash TxHash) (*MarketData, error)
func (MarketData) Cursor ¶
func (md MarketData) Cursor() *Cursor
func (MarketData) Equal ¶
func (md MarketData) Equal(other MarketData) bool
func (MarketData) ToProto ¶
func (md MarketData) ToProto() *types.MarketData
func (MarketData) ToProtoEdge ¶
func (md MarketData) ToProtoEdge(_ ...any) (*v2.MarketDataEdge, error)
type MarketDataCursor ¶
func (*MarketDataCursor) Parse ¶
func (c *MarketDataCursor) Parse(cursorString string) error
func (MarketDataCursor) String ¶
func (c MarketDataCursor) String() string
type MarketDepth ¶
type MarketDepth struct { // Which market is this for MarketID string // All of the orders in the order book LiveOrders map[string]*types.Order // Just the buy side of the book BuySide []*PriceLevel // Just the sell side of the book SellSide []*PriceLevel // All price levels that have changed in the last update Changes []*PriceLevel // Sequence number is an increment-only value to identify a state // of the market depth in time. Used when trying to match updates // to a snapshot dump SequenceNumber uint64 // PreviousSequenceNumber is the sequence number of the last published update. 'Changes' include // updates from all events with a sequence number > PreviousSequenceNumber and <= SequenceNumber PreviousSequenceNumber uint64 }
func (*MarketDepth) AddOrderUpdate ¶
func (md *MarketDepth) AddOrderUpdate(order *types.Order)
func (*MarketDepth) GetPriceLevel ¶
func (md *MarketDepth) GetPriceLevel(side types.Side, price *num.Uint) *PriceLevel
func (*MarketDepth) ToProto ¶
func (md *MarketDepth) ToProto(limit uint64) *vega.MarketDepth
type MarketState ¶
type MarketState vega.Market_State
func (*MarketState) DecodeText ¶
func (s *MarketState) DecodeText(_ *pgtype.ConnInfo, src []byte) error
func (MarketState) EncodeText ¶
type MarketTimestamps ¶
type MarketTimestamps struct { Proposed int64 `json:"proposed,omitempty"` Pending int64 `json:"pending,omitempty"` Open int64 `json:"open,omitempty"` Close int64 `json:"close,omitempty"` }
func (MarketTimestamps) ToProto ¶
func (mt MarketTimestamps) ToProto() *vega.MarketTimestamps
type MarketTradingMode ¶
type MarketTradingMode vega.Market_TradingMode
func (*MarketTradingMode) DecodeText ¶
func (m *MarketTradingMode) DecodeText(_ *pgtype.ConnInfo, src []byte) error
func (MarketTradingMode) EncodeText ¶
type NetworkLimits ¶
type NetworkLimits struct { TxHash TxHash VegaTime time.Time CanProposeMarket bool CanProposeAsset bool BootstrapFinished bool ProposeMarketEnabled bool ProposeAssetEnabled bool BootstrapBlockCount int32 GenesisLoaded bool ProposeMarketEnabledFrom time.Time ProposeAssetEnabledFrom time.Time }
func NetworkLimitsFromProto ¶
func NetworkLimitsFromProto(vn *vega.NetworkLimits, txHash TxHash) NetworkLimits
func (*NetworkLimits) ToProto ¶
func (nl *NetworkLimits) ToProto() *vega.NetworkLimits
type NetworkParameter ¶
func NetworkParameterFromProto ¶
func NetworkParameterFromProto(pnp *vega.NetworkParameter, txHash TxHash) (NetworkParameter, error)
func (NetworkParameter) Cursor ¶
func (np NetworkParameter) Cursor() *Cursor
func (*NetworkParameter) ToProto ¶
func (np *NetworkParameter) ToProto() *vega.NetworkParameter
func (NetworkParameter) ToProtoEdge ¶
func (np NetworkParameter) ToProtoEdge(_ ...any) (*v2.NetworkParameterEdge, error)
type NetworkParameterCursor ¶
type NetworkParameterCursor struct {
Key string
}
func (*NetworkParameterCursor) Parse ¶
func (c *NetworkParameterCursor) Parse(cursorString string) error
type Node ¶
type Node struct { ID NodeID PubKey VegaPublicKey `db:"vega_pub_key"` TmPubKey TendermintPublicKey `db:"tendermint_pub_key"` EthereumAddress EthereumAddress InfoURL string Location string StakedByOperator decimal.Decimal StakedByDelegates decimal.Decimal StakedTotal decimal.Decimal MaxIntendedStake decimal.Decimal PendingStake decimal.Decimal EpochData EpochData Status NodeStatus Delegations []Delegation `json:""` RewardScore *RewardScore `json:""` RankingScore *RankingScore `json:""` Name string AvatarURL string TxHash TxHash VegaTime time.Time }
func NodeFromProto ¶
type NodeCursor ¶
type NodeCursor struct {
ID NodeID `json:"id"`
}
func (*NodeCursor) Parse ¶
func (nc *NodeCursor) Parse(cursorString string) error
func (NodeCursor) String ¶
func (nc NodeCursor) String() string
type NodeData ¶
type NodeSet ¶ added in v0.63.0
type NodeSignature ¶
type NodeSignature struct { ResourceID NodeSignatureID Sig []byte Kind NodeSignatureKind TxHash TxHash VegaTime time.Time }
func NodeSignatureFromProto ¶
func NodeSignatureFromProto(ns *commandspb.NodeSignature, txHash TxHash, vegaTime time.Time) (*NodeSignature, error)
func (NodeSignature) Cursor ¶
func (w NodeSignature) Cursor() *Cursor
func (NodeSignature) ToProto ¶
func (w NodeSignature) ToProto() *commandspb.NodeSignature
func (NodeSignature) ToProtoEdge ¶
func (w NodeSignature) ToProtoEdge(_ ...any) (*v2.NodeSignatureEdge, error)
type NodeSignatureCursor ¶
type NodeSignatureCursor struct { ResourceID NodeSignatureID `json:"resource_id"` Sig []byte `json:"sig"` }
func (*NodeSignatureCursor) Parse ¶
func (c *NodeSignatureCursor) Parse(cursorString string) error
func (NodeSignatureCursor) String ¶
func (c NodeSignatureCursor) String() string
type NodeSignatureID ¶
type NodeSignatureID = ID[_NodeSignature]
type NodeSignatureKind ¶
type NodeSignatureKind commandspb.NodeSignatureKind
func (*NodeSignatureKind) DecodeText ¶
func (s *NodeSignatureKind) DecodeText(_ *pgtype.ConnInfo, src []byte) error
func (NodeSignatureKind) EncodeText ¶
type NodeStatus ¶
type NodeStatus vega.NodeStatus
func (*NodeStatus) DecodeText ¶
func (ns *NodeStatus) DecodeText(_ *pgtype.ConnInfo, src []byte) error
func (NodeStatus) EncodeText ¶
type OffsetPagination ¶
type OffsetPagination struct { Pagination Skip uint64 Limit uint64 Descending bool }
func OffsetPaginationFromProto ¶
func OffsetPaginationFromProto(pp *v2.OffsetPagination) OffsetPagination
type OracleData ¶
type OracleData struct {
ExternalData *ExternalData
}
func OracleDataFromProto ¶
func OracleDataFromProto(data *vegapb.OracleData, txHash TxHash, vegaTime time.Time, seqNum uint64) (*OracleData, error)
func (OracleData) Cursor ¶
func (od OracleData) Cursor() *Cursor
func (*OracleData) ToProto ¶
func (od *OracleData) ToProto() *vegapb.OracleData
func (OracleData) ToProtoEdge ¶
func (od OracleData) ToProtoEdge(_ ...any) (*v2.OracleDataEdge, error)
type OracleDataCursor ¶
type OracleDataCursor = ExternalDataCursor
type OracleSpec ¶
type OracleSpec struct {
ExternalDataSourceSpec *ExternalDataSourceSpec
}
func OracleSpecFromProto ¶
func OracleSpecFromProto(spec *vegapb.OracleSpec, txHash TxHash, vegaTime time.Time) (*OracleSpec, error)
func (OracleSpec) Cursor ¶
func (os OracleSpec) Cursor() *Cursor
func (*OracleSpec) ToProto ¶
func (os *OracleSpec) ToProto() *vegapb.OracleSpec
func (OracleSpec) ToProtoEdge ¶
func (os OracleSpec) ToProtoEdge(_ ...any) (*v2.OracleSpecEdge, error)
type OracleSpecStatus ¶
type OracleSpecStatus = DataSourceSpecStatus
type Order ¶
type Order struct { ID OrderID MarketID MarketID PartyID PartyID Side Side Price decimal.Decimal Size int64 Remaining int64 TimeInForce OrderTimeInForce Type OrderType Status OrderStatus Reference string Reason OrderError Version int32 PeggedOffset decimal.Decimal BatchID int32 PeggedReference PeggedReference LpID []byte CreatedAt time.Time UpdatedAt time.Time ExpiresAt time.Time TxHash TxHash VegaTime time.Time SeqNum uint64 }
func OrderFromProto ¶
type OrderCursor ¶
func (*OrderCursor) Parse ¶
func (oc *OrderCursor) Parse(cursorString string) error
func (OrderCursor) String ¶
func (oc OrderCursor) String() string
type OrderError ¶
type OrderError = vega.OrderError
const ( // Default value, no error reported. OrderErrorUnspecified OrderError = vega.OrderError_ORDER_ERROR_UNSPECIFIED // Order was submitted for a market that does not exist. OrderErrorInvalidMarketID OrderError = vega.OrderError_ORDER_ERROR_INVALID_MARKET_ID // Order was submitted with an invalid identifier. OrderErrorInvalidOrderID OrderError = vega.OrderError_ORDER_ERROR_INVALID_ORDER_ID // Order was amended with a sequence number that was not previous version + 1. OrderErrorOutOfSequence OrderError = vega.OrderError_ORDER_ERROR_OUT_OF_SEQUENCE // Order was amended with an invalid remaining size (e.g. remaining greater than total size). OrderErrorInvalidRemainingSize OrderError = vega.OrderError_ORDER_ERROR_INVALID_REMAINING_SIZE // Node was unable to get Vega (blockchain) time. OrderErrorTimeFailure OrderError = vega.OrderError_ORDER_ERROR_TIME_FAILURE // Failed to remove an order from the book. OrderErrorRemovalFailure OrderError = vega.OrderError_ORDER_ERROR_REMOVAL_FAILURE // An order with `TimeInForce.TIME_IN_FORCE_GTT` was submitted or amended // with an expiration that was badly formatted or otherwise invalid. OrderErrorInvalidExpirationDatetime OrderError = vega.OrderError_ORDER_ERROR_INVALID_EXPIRATION_DATETIME // Order was submitted or amended with an invalid reference field. OrderErrorInvalidOrderReference OrderError = vega.OrderError_ORDER_ERROR_INVALID_ORDER_REFERENCE // Order amend was submitted for an order field that cannot not be amended (e.g. order identifier). OrderErrorEditNotAllowed OrderError = vega.OrderError_ORDER_ERROR_EDIT_NOT_ALLOWED // Amend failure because amend details do not match original order. OrderErrorAmendFailure OrderError = vega.OrderError_ORDER_ERROR_AMEND_FAILURE // Order not found in an order book or store. OrderErrorNotFound OrderError = vega.OrderError_ORDER_ERROR_NOT_FOUND // Order was submitted with an invalid or missing party identifier. OrderErrorInvalidParty OrderError = vega.OrderError_ORDER_ERROR_INVALID_PARTY_ID // Order was submitted for a market that has closed. OrderErrorMarketClosed OrderError = vega.OrderError_ORDER_ERROR_MARKET_CLOSED // Order was submitted, but the party did not have enough collateral to cover the order. OrderErrorMarginCheckFailed OrderError = vega.OrderError_ORDER_ERROR_MARGIN_CHECK_FAILED // Order was submitted, but the party did not have an account for this asset. OrderErrorMissingGeneralAccount OrderError = vega.OrderError_ORDER_ERROR_MISSING_GENERAL_ACCOUNT // Unspecified internal error. OrderErrorInternalError OrderError = vega.OrderError_ORDER_ERROR_INTERNAL_ERROR // Order was submitted with an invalid or missing size (e.g. 0). OrderErrorInvalidSize OrderError = vega.OrderError_ORDER_ERROR_INVALID_SIZE // Order was submitted with an invalid persistence for its type. OrderErrorInvalidPersistance OrderError = vega.OrderError_ORDER_ERROR_INVALID_PERSISTENCE // Order was submitted with an invalid type field. OrderErrorInvalidType OrderError = vega.OrderError_ORDER_ERROR_INVALID_TYPE // Order was stopped as it would have traded with another order submitted from the same party. OrderErrorSelfTrading OrderError = vega.OrderError_ORDER_ERROR_SELF_TRADING // Order was submitted, but the party did not have enough collateral to cover the fees for the order. OrderErrorInsufficientFundsToPayFees OrderError = vega.OrderError_ORDER_ERROR_INSUFFICIENT_FUNDS_TO_PAY_FEES // Order was submitted with an incorrect or invalid market type. OrderErrorIncorrectMarketType OrderError = vega.OrderError_ORDER_ERROR_INCORRECT_MARKET_TYPE // Order was submitted with invalid time in force. OrderErrorInvalidTimeInForce OrderError = vega.OrderError_ORDER_ERROR_INVALID_TIME_IN_FORCE // A GFN order has got to the market when it is in auction mode. OrderErrorCannotSendGFNOrderDuringAnAuction OrderError = vega.OrderError_ORDER_ERROR_CANNOT_SEND_GFN_ORDER_DURING_AN_AUCTION // A GFA order has got to the market when it is in continuous trading mode. OrderErrorCannotSendGFAOrderDuringContinuousTrading OrderError = vega.OrderError_ORDER_ERROR_CANNOT_SEND_GFA_ORDER_DURING_CONTINUOUS_TRADING // Attempt to amend order to GTT without ExpiryAt. OrderErrorCannotAmendToGTTWithoutExpiryAt OrderError = vega.OrderError_ORDER_ERROR_CANNOT_AMEND_TO_GTT_WITHOUT_EXPIRYAT // Attempt to amend ExpiryAt to a value before CreatedAt. OrderErrorExpiryAtBeforeCreatedAt OrderError = vega.OrderError_ORDER_ERROR_EXPIRYAT_BEFORE_CREATEDAT // Attempt to amend to GTC without an ExpiryAt value. OrderErrorCannotHaveGTCAndExpiryAt OrderError = vega.OrderError_ORDER_ERROR_CANNOT_HAVE_GTC_AND_EXPIRYAT // Amending to FOK or IOC is invalid. OrderErrorCannotAmendToFOKOrIOC OrderError = vega.OrderError_ORDER_ERROR_CANNOT_AMEND_TO_FOK_OR_IOC // Amending to GFA or GFN is invalid. OrderErrorCannotAmendToGFAOrGFN OrderError = vega.OrderError_ORDER_ERROR_CANNOT_AMEND_TO_GFA_OR_GFN // Amending from GFA or GFN is invalid. OrderErrorCannotAmendFromGFAOrGFN OrderError = vega.OrderError_ORDER_ERROR_CANNOT_AMEND_FROM_GFA_OR_GFN // IOC orders are not allowed during auction. OrderErrorCannotSendIOCOrderDuringAuction OrderError = vega.OrderError_ORDER_ERROR_CANNOT_SEND_IOC_ORDER_DURING_AUCTION // FOK orders are not allowed during auction. OrderErrorCannotSendFOKOrderDurinAuction OrderError = vega.OrderError_ORDER_ERROR_CANNOT_SEND_FOK_ORDER_DURING_AUCTION // Pegged orders must be LIMIT orders. OrderErrorMustBeLimitOrder OrderError = vega.OrderError_ORDER_ERROR_MUST_BE_LIMIT_ORDER // Pegged orders can only have TIF GTC or GTT. OrderErrorMustBeGTTOrGTC OrderError = vega.OrderError_ORDER_ERROR_MUST_BE_GTT_OR_GTC // Pegged order must have a reference price. OrderErrorWithoutReferencePrice OrderError = vega.OrderError_ORDER_ERROR_WITHOUT_REFERENCE_PRICE // Buy pegged order cannot reference best ask price. OrderErrorBuyCannotReferenceBestAskPrice OrderError = vega.OrderError_ORDER_ERROR_BUY_CANNOT_REFERENCE_BEST_ASK_PRICE // Pegged order offset must be >= 0. OrderErrorOffsetMustBeGreaterOrEqualToZero OrderError = vega.OrderError_ORDER_ERROR_OFFSET_MUST_BE_GREATER_OR_EQUAL_TO_ZERO // Sell pegged order cannot reference best bid price. OrderErrorSellCannotReferenceBestBidPrice OrderError = vega.OrderError_ORDER_ERROR_SELL_CANNOT_REFERENCE_BEST_BID_PRICE // Pegged order offset must be > zero. OrderErrorOffsetMustBeGreaterThanZero OrderError = vega.OrderError_ORDER_ERROR_OFFSET_MUST_BE_GREATER_THAN_ZERO // The party has an insufficient balance, or does not have // a general account to submit the order (no deposits made // for the required asset). OrderErrorInsufficientAssetBalance OrderError = vega.OrderError_ORDER_ERROR_INSUFFICIENT_ASSET_BALANCE // Cannot amend a non pegged orders details. OrderErrorCannotAmendPeggedOrderDetailsOnNonPeggedOrder OrderError = vega.OrderError_ORDER_ERROR_CANNOT_AMEND_PEGGED_ORDER_DETAILS_ON_NON_PEGGED_ORDER // We are unable to re-price a pegged order because a market price is unavailable. OrderErrorUnableToRepricePeggedOrder OrderError = vega.OrderError_ORDER_ERROR_UNABLE_TO_REPRICE_PEGGED_ORDER // It is not possible to amend the price of an existing pegged order. OrderErrorUnableToAmendPriceOnPeggedOrder OrderError = vega.OrderError_ORDER_ERROR_UNABLE_TO_AMEND_PRICE_ON_PEGGED_ORDER // An FOK, IOC, or GFN order was rejected because it resulted in trades outside the price bounds. OrderErrorNonPersistentOrderOutOfPriceBounds OrderError = vega.OrderError_ORDER_ERROR_NON_PERSISTENT_ORDER_OUT_OF_PRICE_BOUNDS )
type OrderFilter ¶ added in v0.63.0
type OrderFilter struct { Statuses []vega.Order_Status Types []vega.Order_Type TimeInForces []vega.Order_TimeInForce ExcludeLiquidity bool }
type OrderStatus ¶
type OrderStatus = vega.Order_Status
const ( // Default value, always invalid. OrderStatusUnspecified OrderStatus = vega.Order_STATUS_UNSPECIFIED // Used for active unfilled or partially filled orders. OrderStatusActive OrderStatus = vega.Order_STATUS_ACTIVE // Used for expired GTT orders. OrderStatusExpired OrderStatus = vega.Order_STATUS_EXPIRED // Used for orders cancelled by the party that created the order. OrderStatusCancelled OrderStatus = vega.Order_STATUS_CANCELLED // Used for unfilled FOK or IOC orders, and for orders that were stopped by the network. OrderStatusStopped OrderStatus = vega.Order_STATUS_STOPPED // Used for closed fully filled orders. OrderStatusFilled OrderStatus = vega.Order_STATUS_FILLED // Used for orders when not enough collateral was available to fill the margin requirements. OrderStatusRejected OrderStatus = vega.Order_STATUS_REJECTED // Used for closed partially filled IOC orders. OrderStatusPartiallyFilled OrderStatus = vega.Order_STATUS_PARTIALLY_FILLED // Order has been removed from the order book and has been parked, this applies to pegged orders only. OrderStatusParked OrderStatus = vega.Order_STATUS_PARKED )
type OrderTimeInForce ¶
type OrderTimeInForce = vega.Order_TimeInForce
const ( // Default value for TimeInForce, can be valid for an amend. OrderTimeInForceUnspecified OrderTimeInForce = vega.Order_TIME_IN_FORCE_UNSPECIFIED // Good until cancelled. OrderTimeInForceGTC OrderTimeInForce = vega.Order_TIME_IN_FORCE_GTC // Good until specified time. OrderTimeInForceGTT OrderTimeInForce = vega.Order_TIME_IN_FORCE_GTT // Immediate or cancel. OrderTimeInForceIOC OrderTimeInForce = vega.Order_TIME_IN_FORCE_IOC // Fill or kill. OrderTimeInForceFOK OrderTimeInForce = vega.Order_TIME_IN_FORCE_FOK // Good for auction. OrderTimeInForceGFA OrderTimeInForce = vega.Order_TIME_IN_FORCE_GFA // Good for normal. OrderTimeInForceGFN OrderTimeInForce = vega.Order_TIME_IN_FORCE_GFN )
type OrderType ¶
type OrderType = vega.Order_Type
const ( // Default value, always invalid. OrderTypeUnspecified OrderType = vega.Order_TYPE_UNSPECIFIED // Used for Limit orders. OrderTypeLimit OrderType = vega.Order_TYPE_LIMIT // Used for Market orders. OrderTypeMarket OrderType = vega.Order_TYPE_MARKET // Used for orders where the initiating party is the network (with distressed traders). OrderTypeNetwork OrderType = vega.Order_TYPE_NETWORK )
type PageInfo ¶
func PageEntities ¶
func PageEntities[T proto.Message, U PagedEntity[T]](items []U, pagination CursorPagination) ([]U, PageInfo)
type PagedEntity ¶
type PagedEntity[T proto.Message] interface { Market | Party | Trade | Order | MarginLevels | MarketData | Reward | Candle | Deposit | Withdrawal | Asset | OracleSpec | OracleData | Position | LiquidityProvision | Vote | Transfer | AccountBalance | Proposal | Delegation | Node | NetworkParameter | Checkpoint | StakeLinking | NodeSignature | KeyRotation | ERC20MultiSigSignerAddedEvent | ERC20MultiSigSignerRemovedEvent | EthereumKeyRotation | AggregatedBalance | AggregatedLedgerEntry | ProtocolUpgradeProposal | CoreSnapshotData | EpochRewardSummary // ToProtoEdge may need some optional arguments in order to generate the proto, for example margin levels // requires an account source. This is not ideal, but we can come back to this later if a better solution can be found. ToProtoEdge(...any) (T, error) Cursor() *Cursor }
type Pagination ¶
type Pagination interface{}
type Party ¶
type PeggedReference ¶
type PeggedReference = vega.PeggedReference
const ( // Default value for PeggedReference, no reference given. PeggedReferenceUnspecified PeggedReference = vega.PeggedReference_PEGGED_REFERENCE_UNSPECIFIED // Mid price reference. PeggedReferenceMid PeggedReference = vega.PeggedReference_PEGGED_REFERENCE_MID // Best bid price reference. PeggedReferenceBestBid PeggedReference = vega.PeggedReference_PEGGED_REFERENCE_BEST_BID // Best ask price reference. PeggedReferenceBestAsk PeggedReference = vega.PeggedReference_PEGGED_REFERENCE_BEST_ASK )
type Position ¶
type Position struct { MarketID MarketID PartyID PartyID OpenVolume int64 RealisedPnl decimal.Decimal UnrealisedPnl decimal.Decimal AverageEntryPrice decimal.Decimal AverageEntryMarketPrice decimal.Decimal Loss decimal.Decimal // what the party lost because of loss socialization Adjustment decimal.Decimal // what a party was missing which triggered loss socialization TxHash TxHash VegaTime time.Time }
func NewEmptyPosition ¶
func (*Position) AverageEntryPriceUint ¶
func (Position) Key ¶
func (p Position) Key() PositionKey
func (Position) ToProtoEdge ¶
func (p Position) ToProtoEdge(_ ...any) (*v2.PositionEdge, error)
func (*Position) UpdateWithLossSocialization ¶
func (p *Position) UpdateWithLossSocialization(e lossSocialization)
func (*Position) UpdateWithPositionSettlement ¶
func (p *Position) UpdateWithPositionSettlement(e positionSettlement)
func (*Position) UpdateWithSettleDistressed ¶ added in v0.56.0
func (p *Position) UpdateWithSettleDistressed(e settleDistressed)
func (*Position) UpdateWithSettleMarket ¶ added in v0.56.0
func (p *Position) UpdateWithSettleMarket(e settleMarket)
type PositionCursor ¶
type PositionCursor struct { VegaTime time.Time `json:"vega_time"` PartyID PartyID `json:"party_id"` MarketID MarketID `json:"market_id"` }
func (*PositionCursor) Parse ¶
func (rc *PositionCursor) Parse(cursorString string) error
func (PositionCursor) String ¶
func (rc PositionCursor) String() string
type PriceLevel ¶
type PriceMonitoringBound ¶
type PriceMonitoringBound struct { MinValidPrice *num.Uint `json:"minValidPrice"` MaxValidPrice *num.Uint `json:"maxValidPrice"` Trigger PriceMonitoringTrigger `json:"trigger"` ReferencePrice *num.Uint `json:"referencePrice"` }
func (PriceMonitoringBound) Equals ¶
func (bound PriceMonitoringBound) Equals(other PriceMonitoringBound) bool
type PriceMonitoringParameters ¶
type PriceMonitoringParameters struct {
Triggers []*PriceMonitoringTrigger `json:"triggers,omitempty"`
}
type PriceMonitoringSettings ¶
type PriceMonitoringSettings struct {
Parameters *PriceMonitoringParameters `json:"priceMonitoringParameters,omitempty"`
}
func (PriceMonitoringSettings) ToProto ¶
func (s PriceMonitoringSettings) ToProto() *vega.PriceMonitoringSettings
type PriceMonitoringTrigger ¶
type PriceMonitoringTrigger struct { Horizon uint64 `json:"horizon"` Probability decimal.Decimal `json:"probability"` AuctionExtension uint64 `json:"auctionExtension"` }
func (PriceMonitoringTrigger) Equals ¶
func (trigger PriceMonitoringTrigger) Equals(other PriceMonitoringTrigger) bool
func (PriceMonitoringTrigger) ToProto ¶
func (trigger PriceMonitoringTrigger) ToProto() *types.PriceMonitoringTrigger
type PropertyKey ¶
type PropertyKey struct { Name string `json:"name"` Type v1.PropertyKey_Type }
type Proposal ¶
type Proposal struct { ID ProposalID Reference string PartyID PartyID State ProposalState Rationale ProposalRationale Terms ProposalTerms Reason ProposalError ErrorDetails string ProposalTime time.Time VegaTime time.Time RequiredMajority num.Decimal RequiredParticipation num.Decimal RequiredLPMajority *num.Decimal RequiredLPParticipation *num.Decimal TxHash TxHash }
func (Proposal) ToProtoEdge ¶
func (p Proposal) ToProtoEdge(_ ...any) (*v2.GovernanceDataEdge, error)
type ProposalCursor ¶
type ProposalCursor struct { State ProposalState `json:"state"` VegaTime time.Time `json:"vega_time"` ID ProposalID `json:"id"` }
func (*ProposalCursor) Parse ¶
func (pc *ProposalCursor) Parse(cursorString string) error
func (ProposalCursor) String ¶
func (pc ProposalCursor) String() string
type ProposalError ¶
type ProposalError vega.ProposalError
func (*ProposalError) DecodeText ¶
func (s *ProposalError) DecodeText(_ *pgtype.ConnInfo, src []byte) error
func (ProposalError) EncodeText ¶
type ProposalID ¶
type ProposalID = ID[_Proposal]
type ProposalRationale ¶
type ProposalRationale struct {
*vega.ProposalRationale
}
func (ProposalRationale) MarshalJSON ¶
func (pt ProposalRationale) MarshalJSON() ([]byte, error)
func (*ProposalRationale) UnmarshalJSON ¶
func (pt *ProposalRationale) UnmarshalJSON(b []byte) error
type ProposalState ¶
type ProposalState vega.Proposal_State
func (*ProposalState) DecodeText ¶
func (s *ProposalState) DecodeText(_ *pgtype.ConnInfo, src []byte) error
func (ProposalState) EncodeText ¶
type ProposalTerms ¶
type ProposalTerms struct {
*vega.ProposalTerms
}
func (ProposalTerms) MarshalJSON ¶
func (pt ProposalTerms) MarshalJSON() ([]byte, error)
func (*ProposalTerms) UnmarshalJSON ¶
func (pt *ProposalTerms) UnmarshalJSON(b []byte) error
type ProposalType ¶
type ProposalType v2.ListGovernanceDataRequest_Type
func (*ProposalType) String ¶ added in v0.58.0
func (p *ProposalType) String() string
type ProtocolUpgradeProposal ¶ added in v0.61.0
type ProtocolUpgradeProposal struct { UpgradeBlockHeight uint64 VegaReleaseTag string Approvers []string Status ProtocolUpgradeProposalStatus TxHash TxHash VegaTime time.Time }
func ProtocolUpgradeProposalFromProto ¶ added in v0.61.0
func ProtocolUpgradeProposalFromProto(p *eventspb.ProtocolUpgradeEvent, txHash TxHash, vegaTime time.Time) ProtocolUpgradeProposal
func (ProtocolUpgradeProposal) Cursor ¶ added in v0.61.0
func (p ProtocolUpgradeProposal) Cursor() *Cursor
func (*ProtocolUpgradeProposal) ToProto ¶ added in v0.61.0
func (p *ProtocolUpgradeProposal) ToProto() *eventspb.ProtocolUpgradeEvent
func (ProtocolUpgradeProposal) ToProtoEdge ¶ added in v0.61.0
func (p ProtocolUpgradeProposal) ToProtoEdge(_ ...any) (*v2.ProtocolUpgradeProposalEdge, error)
type ProtocolUpgradeProposalCursor ¶ added in v0.61.0
type ProtocolUpgradeProposalCursor struct { VegaTime time.Time UpgradeBlockHeight uint64 VegaReleaseTag string }
func (*ProtocolUpgradeProposalCursor) Parse ¶ added in v0.61.0
func (pc *ProtocolUpgradeProposalCursor) Parse(cursorString string) error
func (ProtocolUpgradeProposalCursor) String ¶ added in v0.61.0
func (pc ProtocolUpgradeProposalCursor) String() string
type ProtocolUpgradeProposalStatus ¶ added in v0.61.0
type ProtocolUpgradeProposalStatus eventspb.ProtocolUpgradeProposalStatus
func (*ProtocolUpgradeProposalStatus) DecodeText ¶ added in v0.61.0
func (ps *ProtocolUpgradeProposalStatus) DecodeText(_ *pgtype.ConnInfo, src []byte) error
func (ProtocolUpgradeProposalStatus) EncodeText ¶ added in v0.61.0
type RankingScore ¶
type RankingScore struct { StakeScore decimal.Decimal `json:"stake_score"` PerformanceScore decimal.Decimal `json:"performance_score"` PreviousStatus ValidatorNodeStatus `json:"previous_status,string"` Status ValidatorNodeStatus `json:",string"` VotingPower uint32 `json:"voting_power"` RankingScore decimal.Decimal `json:"ranking_score"` TxHash TxHash `json:"tx_hash"` VegaTime time.Time `json:"vega_time"` EpochSeq uint64 }
func (*RankingScore) ToProto ¶
func (rs *RankingScore) ToProto() *vega.RankingScore
type RankingScoreAux ¶
type Reward ¶
type Reward struct { PartyID PartyID AssetID AssetID MarketID MarketID EpochID int64 Amount decimal.Decimal PercentOfTotal float64 RewardType string Timestamp time.Time TxHash TxHash VegaTime time.Time SeqNum uint64 }
func RewardFromProto ¶
func (Reward) ToProtoEdge ¶
func (r Reward) ToProtoEdge(_ ...any) (*v2.RewardEdge, error)
type RewardCursor ¶
type RewardCursor struct { PartyID string `json:"party_id"` AssetID string `json:"asset_id"` EpochID int64 `json:"epoch_id"` }
func (*RewardCursor) Parse ¶
func (rc *RewardCursor) Parse(cursorString string) error
func (RewardCursor) String ¶
func (rc RewardCursor) String() string
type RewardScore ¶
type RewardScore struct { RawValidatorScore decimal.Decimal `json:"raw_validator_score"` PerformanceScore decimal.Decimal `json:"performance_score"` MultisigScore decimal.Decimal `json:"multisig_score"` ValidatorScore decimal.Decimal `json:"validator_score"` NormalisedScore decimal.Decimal `json:"normalised_score"` ValidatorNodeStatus ValidatorNodeStatus `json:"validator_node_status,string"` TxHash TxHash `json:"tx_hash"` VegaTime time.Time `json:"vega_time"` EpochSeq uint64 }
func (*RewardScore) ToProto ¶
func (rs *RewardScore) ToProto() *vega.RewardScore
type RewardScoreAux ¶
type RewardSummary ¶
func (*RewardSummary) ToProto ¶
func (r *RewardSummary) ToProto() *vega.RewardSummary
type RiskFactor ¶
type RiskFactor struct { MarketID MarketID Short decimal.Decimal Long decimal.Decimal TxHash TxHash VegaTime time.Time }
func RiskFactorFromProto ¶
func RiskFactorFromProto(factor *vega.RiskFactor, txHash TxHash, vegaTime time.Time) (*RiskFactor, error)
func (*RiskFactor) ToProto ¶
func (rf *RiskFactor) ToProto() *vega.RiskFactor
type Side ¶
const ( // Default value, always invalid. SideUnspecified Side = vega.Side_SIDE_UNSPECIFIED // Buy order. SideBuy Side = vega.Side_SIDE_BUY // Sell order. SideSell Side = vega.Side_SIDE_SELL )
type StakeLinking ¶
type StakeLinking struct { ID StakeLinkingID StakeLinkingType StakeLinkingType EthereumTimestamp time.Time PartyID PartyID Amount decimal.Decimal StakeLinkingStatus StakeLinkingStatus FinalizedAt time.Time ForeignTxHash string ForeignBlockHeight int64 ForeignBlockTime int64 LogIndex int64 EthereumAddress string TxHash TxHash VegaTime time.Time }
func StakeLinkingFromProto ¶
func StakeLinkingFromProto(stake *eventspb.StakeLinking, txHash TxHash, vegaTime time.Time) (*StakeLinking, error)
func (StakeLinking) Cursor ¶
func (s StakeLinking) Cursor() *Cursor
func (*StakeLinking) ToProto ¶
func (s *StakeLinking) ToProto() *eventspb.StakeLinking
func (StakeLinking) ToProtoEdge ¶
func (s StakeLinking) ToProtoEdge(_ ...any) (*v2.StakeLinkingEdge, error)
type StakeLinkingCursor ¶
type StakeLinkingCursor struct { VegaTime time.Time `json:"vegaTime"` ID StakeLinkingID `json:"id"` }
func (*StakeLinkingCursor) Parse ¶
func (s *StakeLinkingCursor) Parse(cursorString string) error
func (StakeLinkingCursor) String ¶
func (s StakeLinkingCursor) String() string
type StakeLinkingID ¶
type StakeLinkingID = ID[_StakeLinking]
type StakeLinkingStatus ¶
type StakeLinkingStatus eventspb.StakeLinking_Status
func (*StakeLinkingStatus) DecodeText ¶
func (s *StakeLinkingStatus) DecodeText(_ *pgtype.ConnInfo, src []byte) error
func (StakeLinkingStatus) EncodeText ¶
type StakeLinkingType ¶
type StakeLinkingType eventspb.StakeLinking_Type
func (*StakeLinkingType) DecodeText ¶
func (s *StakeLinkingType) DecodeText(_ *pgtype.ConnInfo, src []byte) error
func (StakeLinkingType) EncodeText ¶
type TargetStakeParameters ¶
type TargetStakeParameters struct { TimeWindow int64 `json:"timeWindow,omitempty"` ScalingFactors float64 `json:"scalingFactor,omitempty"` }
func (TargetStakeParameters) ToProto ¶
func (tsp TargetStakeParameters) ToProto() *vega.TargetStakeParameters
type TendermintPublicKey ¶
type TendermintPublicKey string
func (*TendermintPublicKey) Bytes ¶
func (pk *TendermintPublicKey) Bytes() ([]byte, error)
func (*TendermintPublicKey) DecodeBinary ¶
func (pk *TendermintPublicKey) DecodeBinary(ci *pgtype.ConnInfo, src []byte) error
func (TendermintPublicKey) EncodeBinary ¶
func (*TendermintPublicKey) Error ¶
func (pk *TendermintPublicKey) Error() error
func (*TendermintPublicKey) String ¶
func (pk *TendermintPublicKey) String() string
type TradableInstrument ¶
type TradableInstrument struct {
*vega.TradableInstrument
}
func (TradableInstrument) MarshalJSON ¶
func (ti TradableInstrument) MarshalJSON() ([]byte, error)
func (TradableInstrument) ToProto ¶
func (ti TradableInstrument) ToProto() *vega.TradableInstrument
func (*TradableInstrument) UnmarshalJSON ¶
func (ti *TradableInstrument) UnmarshalJSON(data []byte) error
type Trade ¶
type Trade struct { SyntheticTime time.Time TxHash TxHash VegaTime time.Time SeqNum uint64 ID TradeID MarketID MarketID Price decimal.Decimal Size uint64 Buyer PartyID Seller PartyID Aggressor Side BuyOrder OrderID SellOrder OrderID Type TradeType BuyerMakerFee decimal.Decimal BuyerInfrastructureFee decimal.Decimal BuyerLiquidityFee decimal.Decimal SellerMakerFee decimal.Decimal SellerInfrastructureFee decimal.Decimal SellerLiquidityFee decimal.Decimal BuyerAuctionBatch uint64 SellerAuctionBatch uint64 }
func TradeFromProto ¶
type TradeCursor ¶
func (*TradeCursor) Parse ¶
func (c *TradeCursor) Parse(cursorString string) error
func (TradeCursor) String ¶
func (c TradeCursor) String() string
type TradeType ¶
type TradeType = vega.Trade_Type
const ( // Default value, always invalid. TradeTypeUnspecified TradeType = vega.Trade_TYPE_UNSPECIFIED // Normal trading between two parties. TradeTypeDefault TradeType = vega.Trade_TYPE_DEFAULT // Trading initiated by the network with another party on the book, // which helps to zero-out the positions of one or more distressed parties. TradeTypeNetworkCloseOutGood TradeType = vega.Trade_TYPE_NETWORK_CLOSE_OUT_GOOD // Trading initiated by the network with another party off the book, // with a distressed party in order to zero-out the position of the party. TradeTypeNetworkCloseOutBad TradeType = vega.Trade_TYPE_NETWORK_CLOSE_OUT_BAD )
type Transfer ¶
type Transfer struct { ID TransferID TxHash TxHash VegaTime time.Time FromAccountID AccountID ToAccountID AccountID AssetID AssetID Amount decimal.Decimal Reference string Status TransferStatus TransferType TransferType DeliverOn *time.Time StartEpoch *uint64 EndEpoch *uint64 Factor *decimal.Decimal DispatchMetric *vega.DispatchMetric DispatchMetricAsset *string DispatchMarkets []string Reason *string }
func TransferFromProto ¶
func (Transfer) ToProtoEdge ¶
func (t Transfer) ToProtoEdge(input ...any) (*v2.TransferEdge, error)
type TransferCursor ¶
type TransferCursor struct { VegaTime time.Time `json:"vegaTime"` ID TransferID `json:"id"` }
func (*TransferCursor) Parse ¶
func (tc *TransferCursor) Parse(cursorString string) error
func (TransferCursor) String ¶
func (tc TransferCursor) String() string
type TransferID ¶
type TransferID = ID[_Transfer]
type TransferStatus ¶
type TransferStatus eventspb.Transfer_Status
func (*TransferStatus) DecodeText ¶
func (m *TransferStatus) DecodeText(_ *pgtype.ConnInfo, src []byte) error
func (TransferStatus) EncodeText ¶
type TransferType ¶
type TransferType int
const ( Unknown TransferType = iota OneOff Recurring )
func (*TransferType) DecodeText ¶
func (m *TransferType) DecodeText(_ *pgtype.ConnInfo, src []byte) error
func (TransferType) EncodeText ¶
type TxHash ¶ added in v0.55.0
type TxHash string
func (*TxHash) DecodeBinary ¶ added in v0.55.0
func (TxHash) EncodeBinary ¶ added in v0.55.0
type ValidatorNodeStatus ¶
type ValidatorNodeStatus vega.ValidatorNodeStatus
func ValidatorNodeStatusFromString ¶
func ValidatorNodeStatusFromString(status string) ValidatorNodeStatus
func (*ValidatorNodeStatus) DecodeText ¶
func (ns *ValidatorNodeStatus) DecodeText(_ *pgtype.ConnInfo, src []byte) error
func (ValidatorNodeStatus) EncodeText ¶
func (*ValidatorNodeStatus) UnmarshalJSON ¶
func (ns *ValidatorNodeStatus) UnmarshalJSON(src []byte) error
type ValidatorUpdateAux ¶
type VegaPublicKey ¶
type VegaPublicKey string
func (*VegaPublicKey) Bytes ¶
func (pk *VegaPublicKey) Bytes() ([]byte, error)
func (*VegaPublicKey) DecodeBinary ¶
func (pk *VegaPublicKey) DecodeBinary(ci *pgtype.ConnInfo, src []byte) error
func (VegaPublicKey) EncodeBinary ¶
func (*VegaPublicKey) Error ¶
func (pk *VegaPublicKey) Error() error
func (*VegaPublicKey) String ¶
func (pk *VegaPublicKey) String() string
type Vote ¶
type VoteCursor ¶
func (*VoteCursor) Parse ¶
func (vc *VoteCursor) Parse(cursorString string) error
func (VoteCursor) String ¶
func (vc VoteCursor) String() string
type VoteValue ¶
type VoteValue vega.Vote_Value
type WithdrawExt ¶
type WithdrawExt struct {
*vega.WithdrawExt
}
func (WithdrawExt) MarshalJSON ¶
func (we WithdrawExt) MarshalJSON() ([]byte, error)
func (*WithdrawExt) UnmarshalJSON ¶
func (we *WithdrawExt) UnmarshalJSON(b []byte) error
type Withdrawal ¶
type Withdrawal struct { ID WithdrawalID PartyID PartyID Amount decimal.Decimal Asset AssetID Status WithdrawalStatus Ref string Expiry time.Time ForeignTxHash string CreatedTimestamp time.Time WithdrawnTimestamp time.Time Ext WithdrawExt TxHash TxHash VegaTime time.Time }
func WithdrawalFromProto ¶
func WithdrawalFromProto(withdrawal *vega.Withdrawal, txHash TxHash, vegaTime time.Time) (*Withdrawal, error)
func (Withdrawal) Cursor ¶
func (w Withdrawal) Cursor() *Cursor
func (Withdrawal) ToProto ¶
func (w Withdrawal) ToProto() *vega.Withdrawal
func (Withdrawal) ToProtoEdge ¶
func (w Withdrawal) ToProtoEdge(_ ...any) (*v2.WithdrawalEdge, error)
type WithdrawalCursor ¶
type WithdrawalCursor struct { VegaTime time.Time `json:"vegaTime"` ID WithdrawalID `json:"id"` }
func (*WithdrawalCursor) Parse ¶
func (wc *WithdrawalCursor) Parse(cursorString string) error
func (WithdrawalCursor) String ¶
func (wc WithdrawalCursor) String() string
type WithdrawalID ¶
type WithdrawalID = ID[_Withdrawal]
type WithdrawalStatus ¶
type WithdrawalStatus vega.Withdrawal_Status
func (*WithdrawalStatus) DecodeText ¶
func (s *WithdrawalStatus) DecodeText(_ *pgtype.ConnInfo, src []byte) error
func (WithdrawalStatus) EncodeText ¶
Source Files
¶
- account.go
- account_balance.go
- account_field.go
- account_filter.go
- aggregated_balance.go
- aggregated_ledgerentries.go
- asset.go
- balance.go
- begin_block.go
- block.go
- candle.go
- chain.go
- checkpoint.go
- data.go
- data_source.go
- data_spec.go
- date_range.go
- delegation.go
- deposit.go
- entities.go
- enums.go
- epoch.go
- epoch_reward_summary.go
- erc20_multisig_event.go
- ethereum_key_rotation.go
- id.go
- key_rotation.go
- ledgerentry.go
- ledgerentry_field.go
- ledgerentry_filter.go
- liquidity_provision.go
- margin_levels.go
- market.go
- market_depth.go
- marketdata.go
- network_limits.go
- network_parameter.go
- node.go
- node_signature.go
- oracle_data.go
- oracle_spec.go
- order.go
- order_filter.go
- pagination.go
- party.go
- position.go
- proposal.go
- protocol_upgrade_proposal.go
- reward.go
- reward_summary.go
- risk_factors.go
- snapshot_data.go
- stake_linking.go
- tradable_instrument.go
- trade.go
- transfer.go
- utils.go
- vote.go
- withdrawal.go