Documentation ¶
Index ¶
- Constants
- Variables
- func CalculateOpenClosedVolume(currentOpenVolume, tradedVolume int64) (int64, int64)
- func CreateLedgerEntryTime(vegaTime time.Time, seqNum int) time.Time
- func DeserializeSigners(data Signers) []*dstypes.Signer
- func NanosToPostgresTimestamp(nanos int64) time.Time
- func NodeFromValidatorUpdateEvent(evt eventspb.ValidatorUpdate, txHash TxHash, vegaTime time.Time) (Node, ValidatorUpdateAux, error)
- func PackNodeSignatures(signatures []NodeSignature) string
- 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
- func AccountFromProto(va *vega.Account, txHash TxHash) (Account, error)
- func AccountProtoFromDetails(ad *vega.AccountDetails, txHash TxHash) (Account, error)
- func GetAccountFromMarginLevel(ctx context.Context, margin *vega.MarginLevels, accountSource AccountSource, ...) (Account, error)
- func GetAccountFromOrderMarginLevel(ctx context.Context, margin *vega.MarginLevels, accountSource AccountSource, ...) (Account, error)
- 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 BatchProposalTerms
- type BeginBlockEvent
- type Block
- type Candle
- type CandleCursor
- type Chain
- type Checkpoint
- type CheckpointCursor
- type CloseOnLimitOperation
- type CompositePriceConfiguration
- type CompositePriceState
- type Condition
- type CoreSnapshotData
- type CoreSnapshotDataCursor
- type CurrentAndPreviousLiquidityProvisions
- type Cursor
- type CursorOffset
- type CursorPagination
- type Data
- type DataSourceDefinition
- func (s *DataSourceDefinition) GetConditions() []Condition
- func (s *DataSourceDefinition) GetEthOracle() (*EthCallSpec, error)
- func (s *DataSourceDefinition) GetFilters() []Filter
- func (s *DataSourceDefinition) GetInternalTimeTrigger() *DataSourceSpecConfigurationTime
- func (s *DataSourceDefinition) GetOracle() (*DataSourceSpecConfiguration, error)
- func (s *DataSourceDefinition) GetSigners() (Signers, error)
- func (s DataSourceDefinition) MarshalJSON() ([]byte, error)
- func (s *DataSourceDefinition) UnmarshalJSON(b []byte) error
- type DataSourceSpec
- type DataSourceSpecConfiguration
- type DataSourceSpecConfigurationTime
- type DataSourceSpecCursor
- type DataSourceSpecStatus
- type DateRange
- type Delegation
- type DelegationCursor
- type Deposit
- type DepositCursor
- type DepositID
- type DepositStatus
- type DispatchMetric
- type ERC20MultiSigSignerAddedEvent
- func (e ERC20MultiSigSignerAddedEvent) Cursor() *Cursor
- func (e ERC20MultiSigSignerAddedEvent) ToDataNodeApiV2Proto(ctx context.Context, notaryService NotaryService) (*v2.ERC20MultiSigSignerAddedBundle, error)
- func (e ERC20MultiSigSignerAddedEvent) ToProto() *eventspb.ERC20MultiSigSignerAdded
- func (e ERC20MultiSigSignerAddedEvent) ToProtoEdge(_ ...any) (*v2.ERC20MultiSigSignerAddedEdge, error)
- type ERC20MultiSigSignerEvent
- type ERC20MultiSigSignerEventCursor
- type ERC20MultiSigSignerEventID
- type ERC20MultiSigSignerEventType
- type ERC20MultiSigSignerRemovedEvent
- func (e ERC20MultiSigSignerRemovedEvent) Cursor() *Cursor
- func (e ERC20MultiSigSignerRemovedEvent) ToDataNodeApiV2Proto(ctx context.Context, notaryService NotaryService) (*v2.ERC20MultiSigSignerRemovedBundle, error)
- func (e ERC20MultiSigSignerRemovedEvent) ToProto() *eventspb.ERC20MultiSigSignerRemoved
- func (e ERC20MultiSigSignerRemovedEvent) ToProtoEdge(_ ...any) (*v2.ERC20MultiSigSignerRemovedEdge, error)
- type Entities
- type Epoch
- type EpochData
- type EpochRewardSummary
- type EpochRewardSummaryCursor
- type EthCallSpec
- func (es *EthCallSpec) GetAbi() []byte
- func (es *EthCallSpec) GetAddress() string
- func (es *EthCallSpec) GetArgs() []string
- func (es *EthCallSpec) GetFilters() []Filter
- func (es *EthCallSpec) GetMethod() string
- func (es *EthCallSpec) GetNormalisers() []Normaliser
- func (es *EthCallSpec) GetRequiredConfirmations() uint64
- func (es *EthCallSpec) GetTrigger() EthCallTrigger
- type EthCallTrigger
- 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 FeesStats
- type FeesStatsForParty
- type Filter
- type FlattenReferralSetStats
- type FlattenVolumeDiscountStats
- type FundingPayment
- type FundingPaymentCursor
- type FundingPeriod
- type FundingPeriodCursor
- type FundingPeriodDataPoint
- type FundingPeriodDataPointCursor
- type FundingPeriodDataPointSource
- type Game
- type GameCursor
- type GameEntity
- type GameID
- type ID
- type IndividualGameEntity
- type KeyRotation
- type KeyRotationCursor
- type LedgerEntry
- type LedgerEntryField
- type LedgerEntryFilter
- type LedgerMovementType
- type LiquidationStrategy
- type LiquidityFeeSettings
- type LiquidityFeeSettingsMethod
- type LiquidityMonitoringParameters
- type LiquidityOrderReference
- type LiquidityProvider
- type LiquidityProviderCursor
- 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 LiquiditySLAParameters
- 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 MarginMode
- 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 NodeBasic
- type NodeCursor
- type NodeData
- type NodeID
- type NodeSet
- type NodeSignature
- type NodeSignatureCursor
- type NodeSignatureID
- type NodeSignatureKind
- type NodeStatus
- type Normaliser
- type NotaryService
- 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 PaidLiquidityFeesStats
- type PaidLiquidityFeesStatsCursor
- type Party
- type PartyActivityStreak
- type PartyActivityStreakCursor
- type PartyID
- type PartyLockedBalance
- type PartyMarginMode
- type PartyMarginModeCursor
- type PartyProfile
- type PartyProfileCursor
- type PartyVestingBalance
- type PartyVestingStats
- type PeggedReference
- type PerMarketELSWeight
- type Position
- func (p *Position) ApplyFundingPayment(amount *num.Int)
- 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) ToggleDistressedStatus()
- func (p *Position) UpdateOrdersClosed()
- func (p *Position) UpdateWithLossSocialization(e lossSocialization)
- func (p *Position) UpdateWithPositionSettlement(e positionSettlement)
- func (p *Position) UpdateWithSettleDistressed(e settleDistressed)
- func (p *Position) UpdateWithSettleMarket(e settleMarket)
- func (p *Position) UpdateWithTrade(trade vega.Trade, seller bool, pf num.Decimal)
- type PositionCursor
- type PositionKey
- type PositionStatus
- type PriceLevel
- type PriceMonitoringParameters
- type PriceMonitoringSettings
- type PriceMonitoringTrigger
- type ProductData
- type Property
- type PropertyKey
- type Proposal
- type ProposalCursor
- type ProposalError
- type ProposalID
- type ProposalRationale
- type ProposalState
- type ProposalTerms
- type ProposalType
- type ProtoEntity
- type ProtoEnum
- type ProtocolUpgradeProposal
- type ProtocolUpgradeProposalCursor
- type ProtocolUpgradeProposalStatus
- type QuantumRewardsPerEpoch
- type QuantumVolumesPerEpoch
- type RankingScore
- type RankingScoreAux
- type RefereeCursor
- type RefereeHistoryCursor
- type RefereeTeamSwitch
- type ReferralProgram
- type ReferralProgramID
- type ReferralSet
- type ReferralSetCursor
- type ReferralSetID
- type ReferralSetReferee
- type ReferralSetRefereeCursor
- type ReferralSetRefereeStats
- type ReferralSetStats
- type ReferralSetStatsCursor
- type Reward
- type RewardCursor
- type RewardScore
- type RewardScoreAux
- type RewardSummary
- type RewardSummaryFilter
- type RewardTotals
- type RiskFactor
- type Side
- type Signer
- type Signers
- type SpecID
- type StakeLinking
- type StakeLinkingCursor
- type StakeLinkingID
- type StakeLinkingStatus
- type StakeLinkingType
- type StopOrder
- type StopOrderCursor
- type StopOrderExpiryStrategy
- type StopOrderFilter
- type StopOrderID
- type StopOrderKey
- type StopOrderRejectionReason
- type StopOrderStatus
- type StopOrderTriggerDirection
- type SuccessorMarket
- type SuccessorMarketCursor
- type TargetStakeParameters
- type Team
- type TeamCursor
- type TeamGameEntity
- type TeamGameParticipation
- type TeamID
- type TeamMember
- type TeamMemberHistory
- type TeamMemberStatisticsCursor
- type TeamMembersStatistics
- type TeamUpdated
- type TeamsStatistics
- type TeamsStatisticsCursor
- 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 TimeWeightedNotionalPosition
- type TradableInstrument
- type Trade
- type TradeCursor
- type TradeID
- type TradeType
- type Transfer
- type TransferCursor
- type TransferDetails
- type TransferFees
- type TransferFeesDiscount
- type TransferID
- type TransferScope
- type TransferStatus
- type TransferType
- type TxHash
- type ValidatorNodeStatus
- type ValidatorUpdateAux
- type VegaPublicKey
- type VestingStatsUpdated
- type VolumeDiscountProgram
- type VolumeDiscountProgramID
- type VolumeDiscountStats
- type VolumeDiscountStatsCursor
- 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 ( DispatchMetricUnspecified DispatchMetric = DispatchMetric(vega.DispatchMetric_DISPATCH_METRIC_UNSPECIFIED) DispatchMetricMakerFeePaid = DispatchMetric(vega.DispatchMetric_DISPATCH_METRIC_MAKER_FEES_PAID) DispatchMetricMakerFeesReceived = DispatchMetric(vega.DispatchMetric_DISPATCH_METRIC_MAKER_FEES_RECEIVED) DispatchMetricLPFeesReceived = DispatchMetric(vega.DispatchMetric_DISPATCH_METRIC_LP_FEES_RECEIVED) DispatchMetricMarketValue = DispatchMetric(vega.DispatchMetric_DISPATCH_METRIC_MARKET_VALUE) DispatchMetricAveragePosition = DispatchMetric(vega.DispatchMetric_DISPATCH_METRIC_AVERAGE_POSITION) DispatchMetricRelativeReturn = DispatchMetric(vega.DispatchMetric_DISPATCH_METRIC_RELATIVE_RETURN) DispatchMetricReturnVolatility = DispatchMetric(vega.DispatchMetric_DISPATCH_METRIC_RETURN_VOLATILITY) DispatchMetricValidatorRanking = DispatchMetric(vega.DispatchMetric_DISPATCH_METRIC_VALIDATOR_RANKING) )
const ( PositionStatusUnspecified = PositionStatus(vega.PositionStatus_POSITION_STATUS_UNSPECIFIED) PositionStatusOrdersClosed = PositionStatus(vega.PositionStatus_POSITION_STATUS_ORDERS_CLOSED) PositionStatusClosedOut = PositionStatus(vega.PositionStatus_POSITION_STATUS_CLOSED_OUT) PositionStatusDistressed = PositionStatus(vega.PositionStatus_POSITION_STATUS_DISTRESSED) )
const ( OneOffStr = "OneOff" RecurringStr = "Recurring" GovernanceOneOffStr = "GovernanceOneOff" GovernanceRecurringStr = "GovernanceRecurring" 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) MarketTradingModeSuspendedViaGovernance = MarketTradingMode(vega.Market_TRADING_MODE_SUSPENDED_VIA_GOVERNANCE) )
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) MarketStateSuspendedViaGovernance = MarketState(vega.Market_STATE_SUSPENDED_VIA_GOVERNANCE) )
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) DepositStatusDuplicateRejected = DepositStatus(vega.Deposit_STATUS_DUPLICATE_REJECTED) )
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) ProporsalErrorInvalidGovernanceTransfer = ProposalError(vega.ProposalError_PROPOSAL_ERROR_GOVERNANCE_TRANSFER_PROPOSAL_INVALID) ProporsalErrorFailedGovernanceTransfer = ProposalError(vega.ProposalError_PROPOSAL_ERROR_GOVERNANCE_TRANSFER_PROPOSAL_FAILED) ProporsalErrorFailedGovernanceTransferCancel = ProposalError(vega.ProposalError_PROPOSAL_ERROR_GOVERNANCE_CANCEL_TRANSFER_PROPOSAL_INVALID) ProposalErrorInvalidSpot = ProposalError(vega.ProposalError_PROPOSAL_ERROR_INVALID_SPOT) ProposalErrorSpotNotEnabled = ProposalError(vega.ProposalError_PROPOSAL_ERROR_SPOT_PRODUCT_DISABLED) ProposalErrorInvalidSuccessorMarket = ProposalError(vega.ProposalError_PROPOSAL_ERROR_INVALID_SUCCESSOR_MARKET) ProposalErrorInvalidStateUpdate = ProposalError(vega.ProposalError_PROPOSAL_ERROR_INVALID_MARKET_STATE_UPDATE) ProposalErrorInvalidSLAParams = ProposalError(vega.ProposalError_PROPOSAL_ERROR_INVALID_SLA_PARAMS) ProposalErrorMissingSLAParams = ProposalError(vega.ProposalError_PROPOSAL_ERROR_MISSING_SLA_PARAMS) ProposalInvalidPerpetualProduct = ProposalError(vega.ProposalError_PROPOSAL_ERROR_INVALID_PERPETUAL_PRODUCT) ProposalErrorInvalidSizeDecimalPlaces = ProposalError(vega.ProposalError_PROPOSAL_ERROR_INVALID_SIZE_DECIMAL_PLACES) )
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 ( StopOrderExpiryStrategyUnspecified = StopOrderExpiryStrategy(vega.StopOrder_EXPIRY_STRATEGY_UNSPECIFIED) StopOrderExpiryStrategyCancels = StopOrderExpiryStrategy(vega.StopOrder_EXPIRY_STRATEGY_CANCELS) StopOrderExpiryStrategySubmit = StopOrderExpiryStrategy(vega.StopOrder_EXPIRY_STRATEGY_SUBMIT) )
const ( StopOrderTriggerDirectionUnspecified = StopOrderTriggerDirection(vega.StopOrder_TRIGGER_DIRECTION_UNSPECIFIED) StopOrderTriggerDirectionRisesAbove = StopOrderTriggerDirection(vega.StopOrder_TRIGGER_DIRECTION_RISES_ABOVE) StopOrderTriggerDirectionFallsBelow = StopOrderTriggerDirection(vega.StopOrder_TRIGGER_DIRECTION_FALLS_BELOW) )
const ( StopOrderStatusUnspecified = StopOrderStatus(vega.StopOrder_STATUS_UNSPECIFIED) StopOrderStatusPending = StopOrderStatus(vega.StopOrder_STATUS_PENDING) StopOrderStatusCancelled = StopOrderStatus(vega.StopOrder_STATUS_CANCELLED) StopOrderStatusStopped = StopOrderStatus(vega.StopOrder_STATUS_STOPPED) StopOrderStatusTriggered = StopOrderStatus(vega.StopOrder_STATUS_TRIGGERED) StopOrderStatusExpired = StopOrderStatus(vega.StopOrder_STATUS_EXPIRED) StopOrderStatusRejected = StopOrderStatus(vega.StopOrder_STATUS_REJECTED) )
const ( StopOrderRejectionReasonUnspecified = StopOrderRejectionReason(vega.StopOrder_REJECTION_REASON_UNSPECIFIED) StopOrderRejectionReasonTradingNotAllowed = StopOrderRejectionReason(vega.StopOrder_REJECTION_REASON_TRADING_NOT_ALLOWED) StopOrderRejectionReasonExpiryInThePast = StopOrderRejectionReason(vega.StopOrder_REJECTION_REASON_EXPIRY_IN_THE_PAST) StopOrderRejectionReasonMustBeReduceOnly = StopOrderRejectionReason(vega.StopOrder_REJECTION_REASON_MUST_BE_REDUCE_ONLY) StopOrderRejectionReasonMaxStopOrdersPerPartyReached = StopOrderRejectionReason(vega.StopOrder_REJECTION_REASON_MAX_STOP_ORDERS_PER_PARTY_REACHED) StopOrderRejectionReasonNotAllowedWithoutAPosition = StopOrderRejectionReason(vega.StopOrder_REJECTION_REASON_STOP_ORDER_NOT_ALLOWED_WITHOUT_A_POSITION) StopOrderRejectionReasonNotClosingThePosition = StopOrderRejectionReason(vega.StopOrder_REJECTION_REASON_STOP_ORDER_NOT_CLOSING_THE_POSITION) StopOrderRejectionReasonNotAllowedDuringAuction = StopOrderRejectionReason(vega.StopOrder_REJECTION_REASON_STOP_ORDER_NOT_ALLOWED_DURING_OPENING_AUCTION) StopOrderRejectionReasonOCONotAllowedSameExpiryTime = StopOrderRejectionReason(vega.StopOrder_REJECTION_REASON_STOP_ORDER_CANNOT_MATCH_OCO_EXPIRY_TIMES) )
const ( FundingPeriodDataPointSourceUnspecified = FundingPeriodDataPointSource(eventspb.FundingPeriodDataPoint_SOURCE_UNSPECIFIED) FundingPeriodDataPointSourceExternal = FundingPeriodDataPointSource(eventspb.FundingPeriodDataPoint_SOURCE_EXTERNAL) FundingPeriodDataPointSourceInternal = FundingPeriodDataPointSource(eventspb.FundingPeriodDataPoint_SOURCE_INTERNAL) )
const ( LiquidityFeeMethodUnspecified = LiquidityFeeSettingsMethod(vega.LiquidityFeeSettings_METHOD_UNSPECIFIED) LiquidityFeeMethodMarginalCost = LiquidityFeeSettingsMethod(vega.LiquidityFeeSettings_METHOD_MARGINAL_COST) LiquidityFeeMethodWeightedAverage = LiquidityFeeSettingsMethod(vega.LiquidityFeeSettings_METHOD_WEIGHTED_AVERAGE) LiquidityFeeMethodConstant = LiquidityFeeSettingsMethod(vega.LiquidityFeeSettings_METHOD_CONSTANT) )
const ( MarginModeUnspecified = MarginMode(vega.MarginMode_MARGIN_MODE_UNSPECIFIED) MarginModeCrossMargin = MarginMode(vega.MarginMode_MARGIN_MODE_CROSS_MARGIN) MarginModeIsolatedMargin = MarginMode(vega.MarginMode_MARGIN_MODE_ISOLATED_MARGIN) )
const ( LedgerMovementTypeUnspecified = LedgerMovementType(vega.TransferType_TRANSFER_TYPE_UNSPECIFIED) LedgerMovementTypeLoss = LedgerMovementType(vega.TransferType_TRANSFER_TYPE_LOSS) LedgerMovementTypeWin = LedgerMovementType(vega.TransferType_TRANSFER_TYPE_WIN) LedgerMovementTypeMTMLoss = LedgerMovementType(vega.TransferType_TRANSFER_TYPE_MTM_LOSS) LedgerMovementTypeMTMWin = LedgerMovementType(vega.TransferType_TRANSFER_TYPE_MTM_WIN) LedgerMovementTypeMarginLow = LedgerMovementType(vega.TransferType_TRANSFER_TYPE_MARGIN_LOW) LedgerMovementTypeMarginHigh = LedgerMovementType(vega.TransferType_TRANSFER_TYPE_MARGIN_HIGH) LedgerMovementTypeMarginConfiscated = LedgerMovementType(vega.TransferType_TRANSFER_TYPE_MARGIN_CONFISCATED) LedgerMovementTypeMakerFeePay = LedgerMovementType(vega.TransferType_TRANSFER_TYPE_MAKER_FEE_PAY) LedgerMovementTypeMakerFeeReceive = LedgerMovementType(vega.TransferType_TRANSFER_TYPE_MAKER_FEE_RECEIVE) LedgerMovementTypeInfrastructureFeePay = LedgerMovementType(vega.TransferType_TRANSFER_TYPE_INFRASTRUCTURE_FEE_PAY) LedgerMovementTypeInfrastructureFeeDistribute = LedgerMovementType(vega.TransferType_TRANSFER_TYPE_INFRASTRUCTURE_FEE_DISTRIBUTE) LedgerMovementTypeLiquidityFeePay = LedgerMovementType(vega.TransferType_TRANSFER_TYPE_LIQUIDITY_FEE_PAY) LedgerMovementTypeLiquidityFeeDistribute = LedgerMovementType(vega.TransferType_TRANSFER_TYPE_LIQUIDITY_FEE_DISTRIBUTE) LedgerMovementTypeBondLow = LedgerMovementType(vega.TransferType_TRANSFER_TYPE_BOND_LOW) LedgerMovementTypeBondHigh = LedgerMovementType(vega.TransferType_TRANSFER_TYPE_BOND_HIGH) LedgerMovementTypeWithdraw = LedgerMovementType(vega.TransferType_TRANSFER_TYPE_WITHDRAW) LedgerMovementTypeDeposit = LedgerMovementType(vega.TransferType_TRANSFER_TYPE_DEPOSIT) LedgerMovementTypeBondSlashing = LedgerMovementType(vega.TransferType_TRANSFER_TYPE_BOND_SLASHING) 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) LedgerMovementTypePerpFundingWin = LedgerMovementType(vega.TransferType_TRANSFER_TYPE_PERPETUALS_FUNDING_WIN) LedgerMovementTypePerpFundingLoss = LedgerMovementType(vega.TransferType_TRANSFER_TYPE_PERPETUALS_FUNDING_LOSS) LedgerMovementTypeRewardsVested = LedgerMovementType(vega.TransferType_TRANSFER_TYPE_REWARDS_VESTED) )
const ( LedgerEntryFieldUnspecified = iota LedgerEntryFieldTransferType )
const (
DefaultPageSize int32 = 1000
)
Variables ¶
var ( ErrDateRangeIsRequired = errors.New("date range is required") ErrMinimumDate = errors.New("date range start must be after 2020-01-01") ErrEndDateBeforeStart = errors.New("date range start must be before end") ErrDateRangeTooLong = errors.New("date range is too long") )
var ( ErrInvalidID = errors.New("not a valid hex id (or well known exception)") ErrNotFound = errors.New("no resource corresponding to this id") )
var ( ProposalTypeAll = ProposalType(v2.ListGovernanceDataRequest_TYPE_ALL) 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) ProposalTypeNewSpotMarket = ProposalType(v2.ListGovernanceDataRequest_TYPE_NEW_SPOT_MARKET) ProposalTypeUpdateSpotMarket = ProposalType(v2.ListGovernanceDataRequest_TYPE_UPDATE_SPOT_MARKET) ProposalTypeNewTransfer = ProposalType(v2.ListGovernanceDataRequest_TYPE_NEW_TRANSFER) ProposalTypeCancelTransfer = ProposalType(v2.ListGovernanceDataRequest_TYPE_CANCEL_TRANSFER) ProposalTypeUpdateMarketState = ProposalType(v2.ListGovernanceDataRequest_TYPE_UPDATE_MARKET_STATE) ProposalTypeUpdateReferralProgram = ProposalType(v2.ListGovernanceDataRequest_TYPE_UPDATE_REFERRAL_PROGRAM) ProposalTypeUpdateVolumeDiscountProgram = ProposalType(v2.ListGovernanceDataRequest_TYPE_UPDATE_VOLUME_DISCOUNT_PROGRAM) )
var BalanceColumns = []string{"account_id", "tx_hash", "vega_time", "balance"}
var ErrChainAlreadySet = errors.New("chain already set")
var ErrCursorOverflow = errors.Errorf("pagination limit must be in range 0-%d", maxPageSize)
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",
"account_from_balance",
"account_to_balance",
"transfer_id",
}
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", "order_margin_account_id", "timestamp", "maintenance_margin",
"search_level", "initial_margin", "collateral_release_level", "order_margin", "tx_hash",
"vega_time", "margin_mode", "margin_factor",
}
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", "post_only", "reduce_only", "reserved_remaining",
"peak_size", "minimum_visible_size",
}
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", "pending_open_volume",
"pending_realised_pnl", "pending_unrealised_pnl", "pending_average_entry_price", "pending_average_entry_market_price",
"loss_socialisation_amount", "distressed_status",
}
var StopOrderColumns = []string{
"id",
"oco_link_id",
"expires_at",
"expiry_strategy",
"trigger_direction",
"status",
"created_at",
"updated_at",
"order_id",
"trigger_price",
"trigger_percent_offset",
"party_id",
"market_id",
"vega_time",
"seq_num",
"tx_hash",
"submission",
"rejection_reason",
"size_override_setting",
"size_override_value",
}
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 CalculateOpenClosedVolume ¶ added in v0.68.0
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 PackNodeSignatures ¶ added in v0.71.0
func PackNodeSignatures(signatures []NodeSignature) string
packNodeSignatures packs a list signatures into the form form: 0x + sig1 + sig2 + ... + sigN in hex encoded form If the list is empty, return an empty string instead.
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)
func GetAccountFromOrderMarginLevel ¶ added in v0.74.0
func GetAccountFromOrderMarginLevel(ctx context.Context, margin *vega.MarginLevels, accountSource AccountSource, txHash TxHash, vegaTime time.Time) (Account, error)
func (Account) ToAccountDetailsProto ¶ added in v0.71.0
func (a Account) ToAccountDetailsProto() *vega.AccountDetails
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 FromAccountPartyID PartyID ToAccountPartyID PartyID FromAccountMarketID MarketID ToAccountMarketID MarketID FromAccountType types.AccountType ToAccountType types.AccountType FromAccountBalance decimal.Decimal ToAccountBalance decimal.Decimal TransferID TransferID }
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 BatchProposalTerms ¶ added in v0.74.0
type BatchProposalTerms struct {
*vega.BatchProposalTerms
}
func (BatchProposalTerms) MarshalJSON ¶ added in v0.74.0
func (pt BatchProposalTerms) MarshalJSON() ([]byte, error)
func (*BatchProposalTerms) UnmarshalJSON ¶ added in v0.74.0
func (pt *BatchProposalTerms) UnmarshalJSON(b []byte) error
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)
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 Notional 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 CompositePriceConfiguration ¶ added in v0.74.0
type CompositePriceConfiguration struct {
*vega.CompositePriceConfiguration
}
func (CompositePriceConfiguration) MarshalJSON ¶ added in v0.74.0
func (cpc CompositePriceConfiguration) MarshalJSON() ([]byte, error)
func (CompositePriceConfiguration) ToProto ¶ added in v0.74.0
func (cpc CompositePriceConfiguration) ToProto() *vega.CompositePriceConfiguration
func (*CompositePriceConfiguration) UnmarshalJSON ¶ added in v0.74.0
func (cpc *CompositePriceConfiguration) UnmarshalJSON(data []byte) error
type CompositePriceState ¶ added in v0.74.0
type CompositePriceState struct {
*vega.CompositePriceState
}
func (CompositePriceState) MarshalJSON ¶ added in v0.74.0
func (cps CompositePriceState) MarshalJSON() ([]byte, error)
func (CompositePriceState) ToProto ¶ added in v0.74.0
func (p CompositePriceState) ToProto() *vega.CompositePriceState
func (*CompositePriceState) UnmarshalJSON ¶ added in v0.74.0
func (cps *CompositePriceState) UnmarshalJSON(data []byte) error
type Condition ¶
type Condition struct { Operator datapb.Condition_Operator Value string }
func ConditionFromProto ¶ added in v0.72.0
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 CurrentAndPreviousLiquidityProvisions ¶ added in v0.73.0
type CurrentAndPreviousLiquidityProvisions 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 PreviousID LiquidityProvisionID PreviousPartyID PartyID PreviousCreatedAt *time.Time PreviousUpdatedAt *time.Time PreviousMarketID MarketID PreviousCommitmentAmount *decimal.Decimal PreviousFee *decimal.Decimal PreviousSells []LiquidityOrderReference PreviousBuys []LiquidityOrderReference PreviousVersion *int64 PreviousStatus *LiquidityProvisionStatus PreviousReference *string PreviousTxHash TxHash PreviousVegaTime *time.Time }
func (CurrentAndPreviousLiquidityProvisions) Cursor ¶ added in v0.73.0
func (lp CurrentAndPreviousLiquidityProvisions) Cursor() *Cursor
func (CurrentAndPreviousLiquidityProvisions) ToProto ¶ added in v0.73.0
func (lp CurrentAndPreviousLiquidityProvisions) ToProto() *v2.LiquidityProvision
func (CurrentAndPreviousLiquidityProvisions) ToProtoEdge ¶ added in v0.73.0
func (lp CurrentAndPreviousLiquidityProvisions) ToProtoEdge(_ ...any) (*v2.LiquidityProvisionWithPendingEdge, error)
type CursorOffset ¶ added in v0.73.0
func (CursorOffset) HasCursor ¶ added in v0.73.0
func (o CursorOffset) HasCursor() bool
func (CursorOffset) IsSet ¶ added in v0.73.0
func (o CursorOffset) IsSet() bool
type CursorPagination ¶
type CursorPagination struct { Pagination Forward *CursorOffset Backward *CursorOffset 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 {
*vega.DataSourceDefinition
}
func DataSourceDefinitionFromProto ¶ added in v0.72.0
func DataSourceDefinitionFromProto(dsp *vega.DataSourceDefinition) DataSourceDefinition
func (*DataSourceDefinition) GetConditions ¶ added in v0.72.0
func (s *DataSourceDefinition) GetConditions() []Condition
func (*DataSourceDefinition) GetEthOracle ¶ added in v0.73.0
func (s *DataSourceDefinition) GetEthOracle() (*EthCallSpec, error)
func (*DataSourceDefinition) GetFilters ¶ added in v0.62.0
func (s *DataSourceDefinition) GetFilters() []Filter
func (*DataSourceDefinition) GetInternalTimeTrigger ¶ added in v0.72.0
func (s *DataSourceDefinition) GetInternalTimeTrigger() *DataSourceSpecConfigurationTime
func (*DataSourceDefinition) GetOracle ¶ added in v0.72.0
func (s *DataSourceDefinition) GetOracle() (*DataSourceSpecConfiguration, error)
func (*DataSourceDefinition) GetSigners ¶ added in v0.62.0
func (s *DataSourceDefinition) GetSigners() (Signers, error)
func (DataSourceDefinition) MarshalJSON ¶ added in v0.72.0
func (s DataSourceDefinition) MarshalJSON() ([]byte, error)
func (*DataSourceDefinition) UnmarshalJSON ¶ added in v0.72.0
func (s *DataSourceDefinition) UnmarshalJSON(b []byte) error
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(protoSpec *vegapb.DataSourceSpec, txHash TxHash, vegaTime time.Time) *DataSourceSpec
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
DataSourceSpecConfiguration is a simplified version of the oracle content. In the future it is intended to be part of an interface, not a hardcoded objcet.
func (*DataSourceSpecConfiguration) GetFilters ¶ added in v0.72.0
func (ds *DataSourceSpecConfiguration) GetFilters() []Filter
func (*DataSourceSpecConfiguration) GetSigners ¶ added in v0.72.0
func (ds *DataSourceSpecConfiguration) GetSigners() Signers
type DataSourceSpecConfigurationTime ¶ added in v0.72.0
type DataSourceSpecConfigurationTime struct {
Conditions []Condition
}
DataSourceSpecConfigurationTime is a simplified version of the internal time termination data source; only for internal use; New internal types will be created for Cosmic Elevator new internal terminations.
func (*DataSourceSpecConfigurationTime) GetConditions ¶ added in v0.72.0
func (d *DataSourceSpecConfigurationTime) GetConditions() []Condition
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 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 DispatchMetric ¶ added in v0.74.0
type DispatchMetric vega.DispatchMetric
func (*DispatchMetric) DecodeText ¶ added in v0.74.0
func (m *DispatchMetric) DecodeText(_ *pgtype.ConnInfo, src []byte) error
func (DispatchMetric) EncodeText ¶ added in v0.74.0
type ERC20MultiSigSignerAddedEvent ¶
type ERC20MultiSigSignerAddedEvent struct {
ERC20MultiSigSignerEvent
}
func (ERC20MultiSigSignerAddedEvent) Cursor ¶
func (e ERC20MultiSigSignerAddedEvent) Cursor() *Cursor
func (ERC20MultiSigSignerAddedEvent) ToDataNodeApiV2Proto ¶ added in v0.71.0
func (e ERC20MultiSigSignerAddedEvent) ToDataNodeApiV2Proto(ctx context.Context, notaryService NotaryService) (*v2.ERC20MultiSigSignerAddedBundle, error)
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 ChainID string }
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) ToDataNodeApiV2Proto ¶ added in v0.71.0
func (e ERC20MultiSigSignerRemovedEvent) ToDataNodeApiV2Proto(ctx context.Context, notaryService NotaryService) (*v2.ERC20MultiSigSignerRemovedBundle, error)
func (ERC20MultiSigSignerRemovedEvent) ToProto ¶
func (e ERC20MultiSigSignerRemovedEvent) ToProto() *eventspb.ERC20MultiSigSignerRemoved
func (ERC20MultiSigSignerRemovedEvent) ToProtoEdge ¶
func (e ERC20MultiSigSignerRemovedEvent) ToProtoEdge(_ ...any) (*v2.ERC20MultiSigSignerRemovedEdge, error)
type Entities ¶ added in v0.71.0
type Entities interface { Market | Party | Trade | Order | MarketData | Reward | Candle | Deposit | Withdrawal | Asset | OracleSpec | OracleData | Position | LiquidityProvision | Vote | AccountBalance | Proposal | Delegation | Node | NetworkParameter | Checkpoint | StakeLinking | NodeSignature | KeyRotation | ERC20MultiSigSignerAddedEvent | ERC20MultiSigSignerRemovedEvent | EthereumKeyRotation | AggregatedBalance | AggregatedLedgerEntry | ProtocolUpgradeProposal | CoreSnapshotData | EpochRewardSummary | SuccessorMarket | StopOrder | LiquidityProvider | FundingPeriod | FundingPeriodDataPoint | ReferralSet | ReferralSetRefereeStats | FlattenReferralSetStats | Team | TeamMember | TeamMemberHistory | FundingPayment | FlattenVolumeDiscountStats | PaidLiquidityFeesStats | CurrentAndPreviousLiquidityProvisions | TransferDetails | Game | TeamsStatistics | TeamMembersStatistics | PartyMarginMode | PartyProfile }
type Epoch ¶
type Epoch struct { ID int64 StartTime time.Time ExpireTime time.Time EndTime *time.Time TxHash TxHash VegaTime time.Time FirstBlock *int64 LastBlock *int64 }
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 EthCallSpec ¶ added in v0.73.0
type EthCallSpec struct { Address string Abi []byte Method string ArgsJson []string Trigger EthCallTrigger RequiredConfirmations uint64 Filters []Filter Normalisers []Normaliser }
func (*EthCallSpec) GetAbi ¶ added in v0.73.0
func (es *EthCallSpec) GetAbi() []byte
func (*EthCallSpec) GetAddress ¶ added in v0.73.0
func (es *EthCallSpec) GetAddress() string
func (*EthCallSpec) GetArgs ¶ added in v0.73.0
func (es *EthCallSpec) GetArgs() []string
func (*EthCallSpec) GetFilters ¶ added in v0.73.0
func (es *EthCallSpec) GetFilters() []Filter
func (*EthCallSpec) GetMethod ¶ added in v0.73.0
func (es *EthCallSpec) GetMethod() string
func (*EthCallSpec) GetNormalisers ¶ added in v0.73.0
func (es *EthCallSpec) GetNormalisers() []Normaliser
func (*EthCallSpec) GetRequiredConfirmations ¶ added in v0.73.0
func (es *EthCallSpec) GetRequiredConfirmations() uint64
func (*EthCallSpec) GetTrigger ¶ added in v0.73.0
func (es *EthCallSpec) GetTrigger() EthCallTrigger
type EthCallTrigger ¶ added in v0.73.0
type EthCallTrigger struct {
ethcallcommon.Trigger
}
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
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"` LiquidityFeeSettings *LiquidityFeeSettings `json:"liquidityFeeSettings,omitempty"` }
type FeesStats ¶ added in v0.73.0
type FeesStats struct { MarketID MarketID AssetID AssetID EpochSeq uint64 TotalRewardsReceived []*eventspb.PartyAmount ReferrerRewardsGenerated []*eventspb.ReferrerRewardsGenerated RefereesDiscountApplied []*eventspb.PartyAmount VolumeDiscountApplied []*eventspb.PartyAmount TotalMakerFeesReceived []*eventspb.PartyAmount MakerFeesGenerated []*eventspb.MakerFeesGenerated VegaTime time.Time }
func FeesStatsFromProto ¶ added in v0.73.0
type FeesStatsForParty ¶ added in v0.73.0
type Filter ¶
type Filter struct { Key PropertyKey `json:"key"` Conditions []Condition `json:"conditions"` }
func FiltersFromProto ¶ added in v0.61.0
type FlattenReferralSetStats ¶ added in v0.73.0
type FlattenReferralSetStats struct { SetID ReferralSetID AtEpoch uint64 WasEligible bool ReferralSetRunningNotionalTakerVolume string ReferrerTakerVolume string VegaTime time.Time PartyID string DiscountFactor string EpochNotionalTakerVolume string RewardFactor string RewardsMultiplier string RewardsFactorMultiplier string }
func (FlattenReferralSetStats) Cursor ¶ added in v0.73.0
func (s FlattenReferralSetStats) Cursor() *Cursor
func (FlattenReferralSetStats) ToProto ¶ added in v0.73.0
func (s FlattenReferralSetStats) ToProto() *v2.ReferralSetStats
func (FlattenReferralSetStats) ToProtoEdge ¶ added in v0.73.0
func (s FlattenReferralSetStats) ToProtoEdge(_ ...any) (*v2.ReferralSetStatsEdge, error)
type FlattenVolumeDiscountStats ¶ added in v0.73.0
type FlattenVolumeDiscountStats struct { AtEpoch uint64 PartyID string DiscountFactor string RunningVolume string VegaTime time.Time }
func (FlattenVolumeDiscountStats) Cursor ¶ added in v0.73.0
func (s FlattenVolumeDiscountStats) Cursor() *Cursor
func (FlattenVolumeDiscountStats) ToProto ¶ added in v0.73.0
func (s FlattenVolumeDiscountStats) ToProto() *v2.VolumeDiscountStats
func (FlattenVolumeDiscountStats) ToProtoEdge ¶ added in v0.73.0
func (s FlattenVolumeDiscountStats) ToProtoEdge(_ ...any) (*v2.VolumeDiscountStatsEdge, error)
type FundingPayment ¶ added in v0.73.0
type FundingPayment struct { PartyID PartyID MarketID MarketID FundingPeriodSeq uint64 Amount num.Decimal VegaTime time.Time TxHash TxHash }
func NewFundingPaymentsFromProto ¶ added in v0.73.0
func NewFundingPaymentsFromProto( fps *eventspb.FundingPayments, txHash TxHash, vegaTime time.Time, ) ([]*FundingPayment, error)
func (FundingPayment) Cursor ¶ added in v0.73.0
func (fp FundingPayment) Cursor() *Cursor
func (FundingPayment) ToProto ¶ added in v0.73.0
func (fp FundingPayment) ToProto() *v2.FundingPayment
func (FundingPayment) ToProtoEdge ¶ added in v0.73.0
func (fp FundingPayment) ToProtoEdge(_ ...any) (*v2.FundingPaymentEdge, error)
type FundingPaymentCursor ¶ added in v0.73.0
type FundingPaymentCursor struct { VegaTime time.Time `json:"vegaTime"` MarketID MarketID `json:"marketID"` PartyID PartyID `json:"partyID"` }
func (*FundingPaymentCursor) Parse ¶ added in v0.73.0
func (c *FundingPaymentCursor) Parse(cursorString string) error
func (FundingPaymentCursor) String ¶ added in v0.73.0
func (c FundingPaymentCursor) String() string
type FundingPeriod ¶ added in v0.73.0
type FundingPeriod struct { MarketID MarketID FundingPeriodSeq uint64 StartTime time.Time EndTime *time.Time FundingPayment *num.Decimal FundingRate *num.Decimal ExternalTwap *num.Decimal InternalTwap *num.Decimal VegaTime time.Time TxHash TxHash }
func NewFundingPeriodFromProto ¶ added in v0.73.0
func NewFundingPeriodFromProto(fp *events.FundingPeriod, txHash TxHash, vegaTime time.Time) (*FundingPeriod, error)
func (FundingPeriod) Cursor ¶ added in v0.73.0
func (fp FundingPeriod) Cursor() *Cursor
func (FundingPeriod) ToProto ¶ added in v0.73.0
func (fp FundingPeriod) ToProto() *events.FundingPeriod
func (FundingPeriod) ToProtoEdge ¶ added in v0.73.0
func (fp FundingPeriod) ToProtoEdge(_ ...any) (*v2.FundingPeriodEdge, error)
type FundingPeriodCursor ¶ added in v0.73.0
type FundingPeriodCursor struct { // We're using start-time over vega-time for the cursor because the funding period record can be updated // on settlement and the vega time and tx hash will change, but the start time will not. StartTime time.Time `json:"startTime"` MarketID MarketID `json:"marketID"` FundingPeriodSeq uint64 `json:"fundingPeriodSeq"` }
func (*FundingPeriodCursor) Parse ¶ added in v0.73.0
func (c *FundingPeriodCursor) Parse(cursorString string) error
func (FundingPeriodCursor) String ¶ added in v0.73.0
func (c FundingPeriodCursor) String() string
type FundingPeriodDataPoint ¶ added in v0.73.0
type FundingPeriodDataPoint struct { MarketID MarketID FundingPeriodSeq uint64 DataPointType FundingPeriodDataPointSource Price num.Decimal Twap num.Decimal Timestamp time.Time VegaTime time.Time TxHash TxHash }
func NewFundingPeriodDataPointFromProto ¶ added in v0.73.0
func NewFundingPeriodDataPointFromProto(fpdp *events.FundingPeriodDataPoint, txHash TxHash, vegaTime time.Time) (*FundingPeriodDataPoint, error)
func (FundingPeriodDataPoint) Cursor ¶ added in v0.73.0
func (dp FundingPeriodDataPoint) Cursor() *Cursor
func (FundingPeriodDataPoint) ToProto ¶ added in v0.73.0
func (dp FundingPeriodDataPoint) ToProto() *events.FundingPeriodDataPoint
func (FundingPeriodDataPoint) ToProtoEdge ¶ added in v0.73.0
func (dp FundingPeriodDataPoint) ToProtoEdge(_ ...any) (*v2.FundingPeriodDataPointEdge, error)
type FundingPeriodDataPointCursor ¶ added in v0.73.0
type FundingPeriodDataPointCursor struct { // We want to use the timestamp of the data point over the vega time for the cursor because the timestamp represents a // point in time between the start time and end time of the funding period and it is also used for filtering // results when querying via the API. Timestamp time.Time `json:"timestamp"` MarketID MarketID `json:"marketID"` FundingPeriodSeq uint64 `json:"fundingPeriodSeq"` DataPointType FundingPeriodDataPointSource `json:"dataPointType"` }
func (*FundingPeriodDataPointCursor) Parse ¶ added in v0.73.0
func (c *FundingPeriodDataPointCursor) Parse(cursorString string) error
func (FundingPeriodDataPointCursor) String ¶ added in v0.73.0
func (c FundingPeriodDataPointCursor) String() string
type FundingPeriodDataPointSource ¶ added in v0.73.0
type FundingPeriodDataPointSource eventspb.FundingPeriodDataPoint_Source
func (*FundingPeriodDataPointSource) DecodeText ¶ added in v0.73.0
func (s *FundingPeriodDataPointSource) DecodeText(_ *pgtype.ConnInfo, src []byte) error
func (FundingPeriodDataPointSource) EncodeText ¶ added in v0.73.0
type Game ¶ added in v0.74.0
type Game struct { ID GameID Epoch uint64 Participants uint64 Entities []GameEntity RewardAssetID AssetID }
type GameCursor ¶ added in v0.74.0
func (*GameCursor) Parse ¶ added in v0.74.0
func (gc *GameCursor) Parse(cursorString string) error
func (GameCursor) String ¶ added in v0.74.0
func (gc GameCursor) String() string
type GameEntity ¶ added in v0.74.0
type GameEntity interface {
IsGameEntity()
}
type ID ¶
func (ID[T]) EncodeBinary ¶
type IndividualGameEntity ¶ added in v0.74.0
type IndividualGameEntity struct { Individual string Rank uint64 Volume num.Decimal RewardMetric vega.DispatchMetric RewardEarned *num.Uint RewardEarnedQuantum *num.Uint TotalRewardsEarned *num.Uint TotalRewardsEarnedQuantum *num.Uint }
func (*IndividualGameEntity) IsGameEntity ¶ added in v0.74.0
func (*IndividualGameEntity) IsGameEntity()
func (*IndividualGameEntity) ToProto ¶ added in v0.74.0
func (i *IndividualGameEntity) ToProto() *v2.IndividualGameEntity
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 FromAccountID AccountID `db:"account_from_id"` ToAccountID AccountID `db:"account_to_id"` Quantity decimal.Decimal TxHash TxHash VegaTime time.Time TransferTime time.Time Type LedgerMovementType FromAccountBalance decimal.Decimal `db:"account_from_balance"` ToAccountBalance decimal.Decimal `db:"account_to_balance"` TransferID TransferID }
func (LedgerEntry) ToProto ¶ added in v0.71.0
func (le LedgerEntry) ToProto(ctx context.Context, accountSource AccountSource) (*vega.LedgerEntry, error)
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 FromAccount/ToAccount 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 // FromAccountFilter is a filter which is used to request properties for FromAccount field. FromAccountFilter AccountFilter // ToAccountFilter is a filter which is used to request properties for ToAccount field. ToAccountFilter AccountFilter // Filter on LedgerMovementType TransferTypes []LedgerMovementType // Transfer ID to filter by TransferID TransferID }
LedgerEntryFilter 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 LiquidationStrategy ¶ added in v0.74.0
type LiquidationStrategy struct { DisposalTimeStep time.Duration `json:"disposalTimeStep"` DisposalFraction num.Decimal `json:"disposalFraction"` FullDisposalSize uint64 `json:"fullDisposalSize"` MaxFractionConsumed num.Decimal `json:"maxFractionConsumed"` }
func LiquidationStrategyFromProto ¶ added in v0.74.0
func LiquidationStrategyFromProto(ls *vega.LiquidationStrategy) LiquidationStrategy
func (LiquidationStrategy) IntoProto ¶ added in v0.74.0
func (l LiquidationStrategy) IntoProto() *vega.LiquidationStrategy
type LiquidityFeeSettings ¶ added in v0.74.0
type LiquidityFeeSettings struct { Method LiquidityFeeSettingsMethod `json:"makerFee,omitempty"` FeeConstant *string `json:"feeConstant,omitempty"` }
type LiquidityFeeSettingsMethod ¶ added in v0.74.0
type LiquidityFeeSettingsMethod vega.LiquidityFeeSettings_Method
func (*LiquidityFeeSettingsMethod) DecodeText ¶ added in v0.74.0
func (s *LiquidityFeeSettingsMethod) DecodeText(_ *pgtype.ConnInfo, src []byte) error
func (LiquidityFeeSettingsMethod) EncodeText ¶ added in v0.74.0
type LiquidityMonitoringParameters ¶
type LiquidityMonitoringParameters struct {
TargetStakeParameters *TargetStakeParameters `json:"targetStakeParameters,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 LiquidityProvider ¶ added in v0.73.0
type LiquidityProvider struct { PartyID PartyID MarketID MarketID Ordinality int64 SLA *vega.LiquidityProviderSLA }
func (LiquidityProvider) Cursor ¶ added in v0.73.0
func (lp LiquidityProvider) Cursor() *Cursor
func (LiquidityProvider) ToProto ¶ added in v0.73.0
func (lp LiquidityProvider) ToProto() *v2.LiquidityProvider
func (LiquidityProvider) ToProtoEdge ¶ added in v0.73.0
func (lp LiquidityProvider) ToProtoEdge(...any) (*v2.LiquidityProviderEdge, error)
type LiquidityProviderCursor ¶ added in v0.73.0
type LiquidityProviderCursor struct { MarketID MarketID `json:"marketId"` PartyID PartyID `json:"partyId"` Ordinality int64 `json:"ordinality"` }
func (*LiquidityProviderCursor) Parse ¶ added in v0.73.0
func (c *LiquidityProviderCursor) Parse(cursorString string) error
func (LiquidityProviderCursor) String ¶ added in v0.73.0
func (c LiquidityProviderCursor) String() string
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 LiquiditySLAParameters ¶ added in v0.73.0
type LiquiditySLAParameters struct { PriceRange num.Decimal `json:"priceRange,omitempty"` CommitmentMinTimeFraction num.Decimal `json:"commitmentMinTimeFraction,omitempty"` PerformanceHysteresisEpochs uint64 `json:"performanceHysteresisEpochs,omitempty"` SlaCompetitionFactor num.Decimal `json:"slaCompetitionFactor,omitempty"` }
func LiquiditySLAParametersFromProto ¶ added in v0.73.0
func LiquiditySLAParametersFromProto(sla *vega.LiquiditySLAParameters) (LiquiditySLAParameters, error)
func (LiquiditySLAParameters) IntoProto ¶ added in v0.73.0
func (lsp LiquiditySLAParameters) IntoProto() *vega.LiquiditySLAParameters
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 OrderMarginAccountID AccountID MaintenanceMargin decimal.Decimal SearchLevel decimal.Decimal InitialMargin decimal.Decimal CollateralReleaseLevel decimal.Decimal OrderMargin decimal.Decimal Timestamp time.Time TxHash TxHash VegaTime time.Time MarginMode MarginMode MarginFactor decimal.Decimal }
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 MarginMode ¶ added in v0.74.0
type MarginMode vega.MarginMode
func (*MarginMode) DecodeText ¶ added in v0.74.0
func (m *MarginMode) DecodeText(_ *pgtype.ConnInfo, src []byte) error
func (MarginMode) EncodeText ¶ added in v0.74.0
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 LinearSlippageFactor *decimal.Decimal QuadraticSlippageFactor *decimal.Decimal ParentMarketID MarketID InsurancePoolFraction *decimal.Decimal LiquiditySLAParameters LiquiditySLAParameters // Not saved in the market table, but used when retrieving data from the database. // This will be populated when a market has a successor SuccessorMarketID MarketID LiquidationStrategy LiquidationStrategy MarkPriceConfiguration *CompositePriceConfiguration TickSize *decimal.Decimal }
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 num.Decimal // Available stake for the given market SuppliedStake num.Decimal // One or more price monitoring bounds for the current timestamp PriceMonitoringBounds []*types.PriceMonitoringBounds // the market value proxy MarketValueProxy string LiquidityProviderFeeShares []*types.LiquidityProviderFeeShare // the SLA statistics for each liquidity provider LiquidityProviderSLA []*types.LiquidityProviderSLA // 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 will be marked to market NextMarkToMarket time.Time // market growth for the last market window MarketGrowth num.Decimal // Last traded price, as an integer, for example `123456` is a correctly // formatted price of `1.23456` assuming market configured to 5 decimal places LastTradedPrice num.Decimal // Data specific to the product type ProductData *ProductData // NextNetworkCloseout is the time at which the network will attempt its next closeout order. NextNetworkCloseout time.Time // The methodology used for the calculation of the mark price. MarkPriceType string // The internal state of the mark price composite price. MarkPriceState *CompositePriceState }
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 ProposeMarketEnabled bool ProposeAssetEnabled bool 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 Status NodeStatus Name string AvatarURL string TxHash TxHash VegaTime time.Time StakedByOperator decimal.Decimal StakedByDelegates decimal.Decimal StakedTotal decimal.Decimal MaxIntendedStake decimal.Decimal PendingStake decimal.Decimal EpochData EpochData Delegations []Delegation `json:""` RewardScore *RewardScore `json:""` RankingScore *RankingScore `json:""` }
func NodeFromProto ¶
type NodeBasic ¶ added in v0.71.0
type NodeBasic struct { ID NodeID PubKey VegaPublicKey `db:"vega_pub_key"` TmPubKey TendermintPublicKey `db:"tendermint_pub_key"` EthereumAddress EthereumAddress InfoURL string Location string Status NodeStatus Name string AvatarURL string TxHash TxHash VegaTime time.Time }
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 Normaliser ¶ added in v0.73.0
type NotaryService ¶ added in v0.71.0
type NotaryService interface {
GetByResourceID(ctx context.Context, id string, pagination CursorPagination) ([]NodeSignature, PageInfo, error)
}
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
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 PostOnly bool ReduceOnly bool // Iceberg fields ReservedRemaining *int64 PeakSize *int64 MinimumVisibleSize *int64 }
func OrderFromProto ¶
type OrderCursor ¶
type OrderCursor struct { CreatedAt time.Time `json:"createdAt"` ID OrderID `json:"id"` VegaTime time.Time `json:"vegaTime"` }
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 Reference *string DateRange *DateRange ExcludeLiquidity bool LiveOnly bool PartyIDs []string MarketIDs []string }
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 { Entities | Transfer | MarginLevels // 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 PaidLiquidityFeesStats ¶ added in v0.73.0
type PaidLiquidityFeesStats struct { MarketID MarketID AssetID AssetID EpochSeq uint64 TotalFeesPaid string FeesPerParty []*eventspb.PartyAmount VegaTime time.Time }
func PaidLiquidityFeesStatsFromProto ¶ added in v0.73.0
func PaidLiquidityFeesStatsFromProto(proto *eventspb.PaidLiquidityFeesStats, vegaTime time.Time) *PaidLiquidityFeesStats
func (PaidLiquidityFeesStats) Cursor ¶ added in v0.73.0
func (s PaidLiquidityFeesStats) Cursor() *Cursor
func (PaidLiquidityFeesStats) ToProto ¶ added in v0.73.0
func (s PaidLiquidityFeesStats) ToProto() *eventspb.PaidLiquidityFeesStats
func (PaidLiquidityFeesStats) ToProtoEdge ¶ added in v0.73.0
func (s PaidLiquidityFeesStats) ToProtoEdge(_ ...any) (*v2.PaidLiquidityFeesEdge, error)
type PaidLiquidityFeesStatsCursor ¶ added in v0.73.0
func (*PaidLiquidityFeesStatsCursor) Parse ¶ added in v0.73.0
func (c *PaidLiquidityFeesStatsCursor) Parse(cursorString string) error
func (PaidLiquidityFeesStatsCursor) ToString ¶ added in v0.73.0
func (c PaidLiquidityFeesStatsCursor) ToString() string
type Party ¶
type PartyActivityStreak ¶ added in v0.73.0
type PartyActivityStreak struct { PartyID PartyID ActiveFor uint64 InactiveFor uint64 IsActive bool RewardDistributionActivityMultiplier string RewardVestingActivityMultiplier string Epoch uint64 TradedVolume string OpenVolume string VegaTime time.Time TxHash TxHash }
func NewPartyActivityStreakFromProto ¶ added in v0.73.0
func NewPartyActivityStreakFromProto( ev *eventspb.PartyActivityStreak, txHash TxHash, t time.Time, ) *PartyActivityStreak
func (PartyActivityStreak) Cursor ¶ added in v0.73.0
func (pas PartyActivityStreak) Cursor() *Cursor
func (*PartyActivityStreak) Fields ¶ added in v0.73.0
func (pas *PartyActivityStreak) Fields() []interface{}
func (*PartyActivityStreak) ToProto ¶ added in v0.73.0
func (pas *PartyActivityStreak) ToProto() *eventspb.PartyActivityStreak
type PartyActivityStreakCursor ¶ added in v0.73.0
func (*PartyActivityStreakCursor) Parse ¶ added in v0.73.0
func (c *PartyActivityStreakCursor) Parse(cursorString string) error
func (PartyActivityStreakCursor) String ¶ added in v0.73.0
func (c PartyActivityStreakCursor) String() string
type PartyLockedBalance ¶ added in v0.73.0
type PartyLockedBalance struct { PartyID PartyID AssetID AssetID AtEpoch uint64 UntilEpoch uint64 Balance num.Decimal VegaTime time.Time }
func PartyLockedBalanceFromProto ¶ added in v0.73.0
func PartyLockedBalanceFromProto( partyID string, atEpoch uint64, pvb *eventspb.PartyLockedBalance, t time.Time, ) (*PartyLockedBalance, error)
type PartyMarginMode ¶ added in v0.74.0
type PartyMarginMode struct { MarketID MarketID PartyID PartyID MarginMode vega.MarginMode MarginFactor *num.Decimal MinTheoreticalMarginFactor *num.Decimal MaxTheoreticalLeverage *num.Decimal AtEpoch uint64 }
func PartyMarginModeFromProto ¶ added in v0.74.0
func PartyMarginModeFromProto(update *eventspb.PartyMarginModeUpdated) PartyMarginMode
func (PartyMarginMode) Cursor ¶ added in v0.74.0
func (t PartyMarginMode) Cursor() *Cursor
func (PartyMarginMode) ToProto ¶ added in v0.74.0
func (t PartyMarginMode) ToProto() *v2.PartyMarginMode
func (PartyMarginMode) ToProtoEdge ¶ added in v0.74.0
func (t PartyMarginMode) ToProtoEdge(_ ...any) (*v2.PartyMarginModeEdge, error)
type PartyMarginModeCursor ¶ added in v0.74.0
func (*PartyMarginModeCursor) Parse ¶ added in v0.74.0
func (tc *PartyMarginModeCursor) Parse(cursorString string) error
func (PartyMarginModeCursor) String ¶ added in v0.74.0
func (tc PartyMarginModeCursor) String() string
type PartyProfile ¶ added in v0.74.0
func PartyProfileFromProto ¶ added in v0.74.0
func PartyProfileFromProto(t *vegapb.PartyProfile) *PartyProfile
func (PartyProfile) Cursor ¶ added in v0.74.0
func (p PartyProfile) Cursor() *Cursor
func (*PartyProfile) Parse ¶ added in v0.74.0
func (p *PartyProfile) Parse(cursorString string) error
func (PartyProfile) String ¶ added in v0.74.0
func (p PartyProfile) String() string
func (PartyProfile) ToProto ¶ added in v0.74.0
func (p PartyProfile) ToProto() *vegapb.PartyProfile
func (PartyProfile) ToProtoEdge ¶ added in v0.74.0
func (p PartyProfile) ToProtoEdge(_ ...any) (*v2.PartyProfileEdge, error)
type PartyProfileCursor ¶ added in v0.74.0
type PartyProfileCursor struct {
ID PartyID
}
func (*PartyProfileCursor) Parse ¶ added in v0.74.0
func (tc *PartyProfileCursor) Parse(cursorString string) error
func (PartyProfileCursor) String ¶ added in v0.74.0
func (tc PartyProfileCursor) String() string
type PartyVestingBalance ¶ added in v0.73.0
type PartyVestingBalance struct { PartyID PartyID AssetID AssetID AtEpoch uint64 Balance num.Decimal VegaTime time.Time }
func PartyVestingBalanceFromProto ¶ added in v0.73.0
func PartyVestingBalanceFromProto( partyID string, atEpoch uint64, pvb *eventspb.PartyVestingBalance, t time.Time, ) (*PartyVestingBalance, error)
type PartyVestingStats ¶ added in v0.73.0
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 PerMarketELSWeight ¶ added in v0.74.0
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 // keep track of trades that haven't been settled as separate fields // these will be zeroed out once we process settlement events PendingOpenVolume int64 PendingRealisedPnl decimal.Decimal PendingUnrealisedPnl decimal.Decimal PendingAverageEntryPrice decimal.Decimal PendingAverageEntryMarketPrice decimal.Decimal LossSocialisationAmount decimal.Decimal DistressedStatus PositionStatus }
func NewEmptyPosition ¶
func (*Position) ApplyFundingPayment ¶ added in v0.73.0
func (*Position) AverageEntryPriceUint ¶
func (Position) Key ¶
func (p Position) Key() PositionKey
func (Position) ToProtoEdge ¶
func (p Position) ToProtoEdge(_ ...any) (*v2.PositionEdge, error)
func (*Position) ToggleDistressedStatus ¶ added in v0.71.0
func (p *Position) ToggleDistressedStatus()
func (*Position) UpdateOrdersClosed ¶ added in v0.68.0
func (p *Position) UpdateOrdersClosed()
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 PositionStatus ¶ added in v0.68.0
type PositionStatus int32
func (*PositionStatus) DecodeText ¶ added in v0.68.0
func (p *PositionStatus) DecodeText(_ *pgtype.ConnInfo, src []byte) error
func (PositionStatus) EncodeText ¶ added in v0.68.0
type PriceLevel ¶
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 ProductData ¶ added in v0.73.0
type ProductData struct {
*vega.ProductData
}
func (ProductData) MarshalJSON ¶ added in v0.73.0
func (p ProductData) MarshalJSON() ([]byte, error)
func (ProductData) ToProto ¶ added in v0.73.0
func (p ProductData) ToProto() *vega.ProductData
func (*ProductData) UnmarshalJSON ¶ added in v0.73.0
func (p *ProductData) UnmarshalJSON(data []byte) error
type PropertyKey ¶
type PropertyKey struct { Name string `json:"name"` Type datapb.PropertyKey_Type DecimalPlaces *uint64 `json:"number_decimal_places,omitempty"` }
type Proposal ¶
type Proposal struct { ID ProposalID BatchID ProposalID Reference string PartyID PartyID State ProposalState Rationale ProposalRationale Terms ProposalTerms BatchTerms BatchProposalTerms Reason ProposalError ErrorDetails string ProposalTime time.Time VegaTime time.Time RequiredMajority num.Decimal RequiredParticipation num.Decimal RequiredLPMajority *num.Decimal RequiredLPParticipation *num.Decimal TxHash TxHash Proposals []Proposal }
func (Proposal) BelongsToBatch ¶ added in v0.74.0
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 ProtoEntity ¶ added in v0.71.0
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 QuantumRewardsPerEpoch ¶ added in v0.74.0
type QuantumVolumesPerEpoch ¶ added in v0.74.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 RefereeCursor ¶ added in v0.73.0
type RefereeCursor struct {
PartyID PartyID
}
func (*RefereeCursor) Parse ¶ added in v0.73.0
func (rc *RefereeCursor) Parse(cursorString string) error
func (RefereeCursor) String ¶ added in v0.73.0
func (rc RefereeCursor) String() string
type RefereeHistoryCursor ¶ added in v0.73.0
type RefereeHistoryCursor struct {
JoinedAtEpoch uint64
}
func (*RefereeHistoryCursor) Parse ¶ added in v0.73.0
func (rh *RefereeHistoryCursor) Parse(cursorString string) error
func (RefereeHistoryCursor) String ¶ added in v0.73.0
func (rh RefereeHistoryCursor) String() string
type RefereeTeamSwitch ¶ added in v0.73.0
type RefereeTeamSwitch struct { FromTeamID TeamID ToTeamID TeamID PartyID PartyID SwitchedAt time.Time SwitchedAtEpoch uint64 VegaTime time.Time }
func TeamRefereeHistoryFromProto ¶ added in v0.73.0
func TeamRefereeHistoryFromProto(switched *eventspb.RefereeSwitchedTeam, vegaTime time.Time) *RefereeTeamSwitch
type ReferralProgram ¶ added in v0.73.0
type ReferralProgram struct { ID ReferralProgramID Version uint64 BenefitTiers []*vega.BenefitTier EndOfProgramTimestamp time.Time WindowLength uint64 StakingTiers []*vega.StakingTier VegaTime time.Time EndedAt *time.Time SeqNum uint64 }
func ReferralProgramFromProto ¶ added in v0.73.0
func ReferralProgramFromProto(proto *vega.ReferralProgram, vegaTime time.Time, seqNum uint64) *ReferralProgram
func (ReferralProgram) ToProto ¶ added in v0.73.0
func (rp ReferralProgram) ToProto() *v2.ReferralProgram
type ReferralProgramID ¶ added in v0.73.0
type ReferralProgramID = ID[_ReferralProgram]
type ReferralSet ¶ added in v0.73.0
type ReferralSet struct { ID ReferralSetID Referrer PartyID TotalMembers uint64 CreatedAt time.Time UpdatedAt time.Time VegaTime time.Time }
func ReferralSetFromProto ¶ added in v0.73.0
func ReferralSetFromProto(proto *eventspb.ReferralSetCreated, vegaTime time.Time) *ReferralSet
func (ReferralSet) Cursor ¶ added in v0.73.0
func (rs ReferralSet) Cursor() *Cursor
func (ReferralSet) ToProto ¶ added in v0.73.0
func (rs ReferralSet) ToProto() *v2.ReferralSet
func (ReferralSet) ToProtoEdge ¶ added in v0.73.0
func (rs ReferralSet) ToProtoEdge(_ ...any) (*v2.ReferralSetEdge, error)
type ReferralSetCursor ¶ added in v0.73.0
type ReferralSetCursor struct { CreatedAt time.Time ID ReferralSetID }
func (*ReferralSetCursor) Parse ¶ added in v0.73.0
func (c *ReferralSetCursor) Parse(cursorString string) error
func (ReferralSetCursor) ToString ¶ added in v0.73.0
func (c ReferralSetCursor) ToString() string
type ReferralSetID ¶ added in v0.73.0
type ReferralSetID = ID[_ReferralSet]
type ReferralSetReferee ¶ added in v0.73.0
type ReferralSetReferee struct { ReferralSetID ReferralSetID Referee PartyID JoinedAt time.Time AtEpoch uint64 VegaTime time.Time }
func ReferralSetRefereeFromProto ¶ added in v0.73.0
func ReferralSetRefereeFromProto(proto *eventspb.RefereeJoinedReferralSet, vegaTime time.Time) *ReferralSetReferee
func (ReferralSetReferee) Cursor ¶ added in v0.73.0
func (r ReferralSetReferee) Cursor() *Cursor
func (ReferralSetReferee) ToProto ¶ added in v0.73.0
func (r ReferralSetReferee) ToProto() *v2.ReferralSetReferee
func (ReferralSetReferee) ToProtoEdge ¶ added in v0.73.0
func (r ReferralSetReferee) ToProtoEdge(_ ...any) (*v2.ReferralSetRefereeEdge, error)
type ReferralSetRefereeCursor ¶ added in v0.73.0
func (*ReferralSetRefereeCursor) Parse ¶ added in v0.73.0
func (c *ReferralSetRefereeCursor) Parse(cursorString string) error
func (ReferralSetRefereeCursor) ToString ¶ added in v0.73.0
func (c ReferralSetRefereeCursor) ToString() string
type ReferralSetRefereeStats ¶ added in v0.73.0
type ReferralSetRefereeStats struct { ReferralSetReferee PeriodVolume num.Decimal PeriodRewardsPaid num.Decimal }
func (ReferralSetRefereeStats) ToProto ¶ added in v0.73.0
func (r ReferralSetRefereeStats) ToProto() *v2.ReferralSetReferee
func (ReferralSetRefereeStats) ToProtoEdge ¶ added in v0.73.0
func (r ReferralSetRefereeStats) ToProtoEdge(_ ...any) (*v2.ReferralSetRefereeEdge, error)
type ReferralSetStats ¶ added in v0.73.0
type ReferralSetStats struct { SetID ReferralSetID AtEpoch uint64 WasEligible bool ReferralSetRunningNotionalTakerVolume string ReferrerTakerVolume string RefereesStats []*eventspb.RefereeStats VegaTime time.Time RewardFactor string RewardsMultiplier string RewardsFactorMultiplier string }
func ReferralSetStatsFromProto ¶ added in v0.73.0
func ReferralSetStatsFromProto(proto *eventspb.ReferralSetStatsUpdated, vegaTime time.Time) (*ReferralSetStats, error)
type ReferralSetStatsCursor ¶ added in v0.73.0
type ReferralSetStatsCursor struct { VegaTime time.Time AtEpoch uint64 SetID string PartyID string }
func (*ReferralSetStatsCursor) Parse ¶ added in v0.73.0
func (c *ReferralSetStatsCursor) Parse(cursorString string) error
func (ReferralSetStatsCursor) ToString ¶ added in v0.73.0
func (c ReferralSetStatsCursor) ToString() string
type Reward ¶
type Reward struct { PartyID PartyID AssetID AssetID MarketID MarketID EpochID int64 Amount decimal.Decimal QuantumAmount decimal.Decimal PercentOfTotal float64 RewardType string Timestamp time.Time TxHash TxHash VegaTime time.Time SeqNum uint64 LockedUntilEpochID int64 GameID *GameID TeamID *TeamID }
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 RewardSummaryFilter ¶ added in v0.68.0
type RewardSummaryFilter struct { AssetIDs []AssetID MarketIDs []MarketID FromEpoch *uint64 ToEpoch *uint64 }
RewardSummaryFilter is the filter for the reward summary.
func RewardSummaryFilterFromProto ¶ added in v0.68.0
func RewardSummaryFilterFromProto(pb *v2.RewardSummaryFilter) (filter RewardSummaryFilter)
RewardSummaryFilterFromProto converts a protobuf v2.RewardSummaryFilter to an entities.RewardSummaryFilter.
type RewardTotals ¶ added in v0.74.0
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 StopOrder ¶ added in v0.72.0
type StopOrder struct { ID StopOrderID OCOLinkID StopOrderID ExpiresAt *time.Time ExpiryStrategy StopOrderExpiryStrategy TriggerDirection StopOrderTriggerDirection Status StopOrderStatus CreatedAt time.Time UpdatedAt *time.Time OrderID OrderID TriggerPrice *string TriggerPercentOffset *string PartyID PartyID MarketID MarketID VegaTime time.Time SeqNum uint64 TxHash TxHash Submission *commandspb.OrderSubmission RejectionReason StopOrderRejectionReason SizeOverrideSetting int32 SizeOverrideValue *string }
func StopOrderFromProto ¶ added in v0.72.0
func (StopOrder) Key ¶ added in v0.72.0
func (s StopOrder) Key() StopOrderKey
func (StopOrder) ToProto ¶ added in v0.72.0
func (o StopOrder) ToProto() *pbevents.StopOrderEvent
func (StopOrder) ToProtoEdge ¶ added in v0.72.0
func (s StopOrder) ToProtoEdge(_ ...any) (*v2.StopOrderEdge, error)
type StopOrderCursor ¶ added in v0.72.0
type StopOrderCursor struct { CreatedAt time.Time `json:"createdAt"` ID StopOrderID `json:"id"` VegaTime time.Time `json:"vegaTime"` }
func (*StopOrderCursor) Parse ¶ added in v0.72.0
func (c *StopOrderCursor) Parse(cursorString string) error
func (*StopOrderCursor) String ¶ added in v0.72.0
func (c *StopOrderCursor) String() string
type StopOrderExpiryStrategy ¶ added in v0.72.0
type StopOrderExpiryStrategy vega.StopOrder_ExpiryStrategy
func (*StopOrderExpiryStrategy) DecodeText ¶ added in v0.72.0
func (s *StopOrderExpiryStrategy) DecodeText(_ *pgtype.ConnInfo, src []byte) error
func (StopOrderExpiryStrategy) EncodeText ¶ added in v0.72.0
type StopOrderFilter ¶ added in v0.72.0
type StopOrderFilter struct { Statuses []StopOrderStatus ExpiryStrategy []StopOrderExpiryStrategy DateRange *DateRange PartyIDs []string MarketIDs []string LiveOnly bool }
type StopOrderID ¶ added in v0.72.0
type StopOrderID = ID[_StopOrder]
type StopOrderKey ¶ added in v0.72.0
type StopOrderKey struct { ID StopOrderID UpdatedAt time.Time VegaTime time.Time }
type StopOrderRejectionReason ¶ added in v0.73.0
type StopOrderRejectionReason vega.StopOrder_RejectionReason
func (*StopOrderRejectionReason) DecodeText ¶ added in v0.73.0
func (s *StopOrderRejectionReason) DecodeText(_ *pgtype.ConnInfo, src []byte) error
func (StopOrderRejectionReason) EncodeText ¶ added in v0.73.0
type StopOrderStatus ¶ added in v0.72.0
type StopOrderStatus vega.StopOrder_Status
func (*StopOrderStatus) DecodeText ¶ added in v0.72.0
func (s *StopOrderStatus) DecodeText(_ *pgtype.ConnInfo, src []byte) error
func (StopOrderStatus) EncodeText ¶ added in v0.72.0
type StopOrderTriggerDirection ¶ added in v0.72.0
type StopOrderTriggerDirection vega.StopOrder_TriggerDirection
func (*StopOrderTriggerDirection) DecodeText ¶ added in v0.72.0
func (s *StopOrderTriggerDirection) DecodeText(_ *pgtype.ConnInfo, src []byte) error
func (StopOrderTriggerDirection) EncodeText ¶ added in v0.72.0
type SuccessorMarket ¶ added in v0.72.0
func (SuccessorMarket) Cursor ¶ added in v0.72.0
func (s SuccessorMarket) Cursor() *Cursor
func (SuccessorMarket) ToProtoEdge ¶ added in v0.72.0
func (s SuccessorMarket) ToProtoEdge(...any) (*v2.SuccessorMarketEdge, error)
type SuccessorMarketCursor ¶ added in v0.72.0
func (*SuccessorMarketCursor) Parse ¶ added in v0.72.0
func (mc *SuccessorMarketCursor) Parse(cursorString string) error
func (SuccessorMarketCursor) String ¶ added in v0.72.0
func (mc SuccessorMarketCursor) String() string
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 Team ¶ added in v0.73.0
type Team struct { ID TeamID Referrer PartyID Name string TeamURL *string AvatarURL *string Closed bool AllowList []string TotalMembers uint64 CreatedAt time.Time CreatedAtEpoch uint64 VegaTime time.Time }
func TeamCreatedFromProto ¶ added in v0.73.0
func TeamCreatedFromProto(created *eventspb.TeamCreated, vegaTime time.Time) *Team
type TeamCursor ¶ added in v0.73.0
func (*TeamCursor) Parse ¶ added in v0.73.0
func (tc *TeamCursor) Parse(cursorString string) error
func (TeamCursor) String ¶ added in v0.73.0
func (tc TeamCursor) String() string
type TeamGameEntity ¶ added in v0.74.0
type TeamGameEntity struct { Team TeamGameParticipation Rank uint64 Volume num.Decimal RewardMetric vega.DispatchMetric RewardEarned *num.Uint RewardEarnedQuantum *num.Uint TotalRewardsEarned *num.Uint TotalRewardsEarnedQuantum *num.Uint }
func (*TeamGameEntity) IsGameEntity ¶ added in v0.74.0
func (*TeamGameEntity) IsGameEntity()
func (*TeamGameEntity) ToProto ¶ added in v0.74.0
func (t *TeamGameEntity) ToProto() *v2.TeamGameEntity
type TeamGameParticipation ¶ added in v0.74.0
type TeamGameParticipation struct { TeamID TeamID MembersParticipating []*IndividualGameEntity }
func (TeamGameParticipation) ToProto ¶ added in v0.74.0
func (t TeamGameParticipation) ToProto() *v2.TeamGameParticipation
type TeamMember ¶ added in v0.73.0
type TeamMember struct { TeamID TeamID PartyID PartyID JoinedAt time.Time JoinedAtEpoch uint64 VegaTime time.Time }
func TeamRefereeFromProto ¶ added in v0.73.0
func TeamRefereeFromProto(joined *eventspb.RefereeJoinedTeam, vegaTime time.Time) *TeamMember
func (TeamMember) Cursor ¶ added in v0.73.0
func (t TeamMember) Cursor() *Cursor
func (TeamMember) ToProto ¶ added in v0.73.0
func (t TeamMember) ToProto() *v2.TeamReferee
func (TeamMember) ToProtoEdge ¶ added in v0.73.0
func (t TeamMember) ToProtoEdge(_ ...any) (*v2.TeamRefereeEdge, error)
type TeamMemberHistory ¶ added in v0.73.0
func (TeamMemberHistory) Cursor ¶ added in v0.73.0
func (t TeamMemberHistory) Cursor() *Cursor
func (TeamMemberHistory) ToProto ¶ added in v0.73.0
func (t TeamMemberHistory) ToProto() *v2.TeamRefereeHistory
func (TeamMemberHistory) ToProtoEdge ¶ added in v0.73.0
func (t TeamMemberHistory) ToProtoEdge(_ ...any) (*v2.TeamRefereeHistoryEdge, error)
type TeamMemberStatisticsCursor ¶ added in v0.74.0
type TeamMemberStatisticsCursor struct {
ID PartyID
}
func (*TeamMemberStatisticsCursor) Parse ¶ added in v0.74.0
func (c *TeamMemberStatisticsCursor) Parse(cursorString string) error
func (TeamMemberStatisticsCursor) String ¶ added in v0.74.0
func (c TeamMemberStatisticsCursor) String() string
type TeamMembersStatistics ¶ added in v0.74.0
type TeamMembersStatistics struct { PartyID PartyID TotalQuantumVolumes *num.Uint TotalQuantumRewards num.Decimal QuantumRewards []QuantumRewardsPerEpoch QuantumVolumes []QuantumVolumesPerEpoch TotalGamesPlayed uint64 GamesPlayed []GameID }
func (TeamMembersStatistics) Cursor ¶ added in v0.74.0
func (t TeamMembersStatistics) Cursor() *Cursor
func (TeamMembersStatistics) ToProto ¶ added in v0.74.0
func (t TeamMembersStatistics) ToProto() *v2.TeamMemberStatistics
func (TeamMembersStatistics) ToProtoEdge ¶ added in v0.74.0
func (t TeamMembersStatistics) ToProtoEdge(_ ...any) (*v2.TeamMemberStatisticsEdge, error)
type TeamUpdated ¶ added in v0.73.0
type TeamUpdated struct { ID TeamID Name string TeamURL *string AvatarURL *string Closed bool AllowList []string VegaTime time.Time }
func TeamUpdatedFromProto ¶ added in v0.73.0
func TeamUpdatedFromProto(updated *eventspb.TeamUpdated, vegaTime time.Time) *TeamUpdated
type TeamsStatistics ¶ added in v0.74.0
type TeamsStatistics struct { TeamID TeamID TotalQuantumRewards num.Decimal QuantumRewards []QuantumRewardsPerEpoch TotalQuantumVolumes *num.Uint QuantumVolumes []QuantumVolumesPerEpoch TotalGamesPlayed uint64 GamesPlayed []GameID }
func (TeamsStatistics) Cursor ¶ added in v0.74.0
func (t TeamsStatistics) Cursor() *Cursor
func (TeamsStatistics) ToProto ¶ added in v0.74.0
func (t TeamsStatistics) ToProto() *v2.TeamStatistics
func (TeamsStatistics) ToProtoEdge ¶ added in v0.74.0
func (t TeamsStatistics) ToProtoEdge(_ ...any) (*v2.TeamStatisticsEdge, error)
type TeamsStatisticsCursor ¶ added in v0.74.0
type TeamsStatisticsCursor struct {
ID TeamID
}
func (*TeamsStatisticsCursor) Parse ¶ added in v0.74.0
func (c *TeamsStatisticsCursor) Parse(cursorString string) error
func (TeamsStatisticsCursor) String ¶ added in v0.74.0
func (c TeamsStatisticsCursor) String() string
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 TimeWeightedNotionalPosition ¶ added in v0.75.0
type TimeWeightedNotionalPosition struct { EpochSeq uint64 AssetID AssetID PartyID PartyID GameID GameID TimeWeightedNotionalPosition uint64 VegaTime time.Time }
func TimeWeightedNotionalPositionFromProto ¶ added in v0.75.0
func TimeWeightedNotionalPositionFromProto(event *eventspb.TimeWeightedNotionalPositionUpdated, vegaTime time.Time) (*TimeWeightedNotionalPosition, error)
func (*TimeWeightedNotionalPosition) ToProto ¶ added in v0.75.0
func (tw *TimeWeightedNotionalPosition) ToProto() *v2.TimeWeightedNotionalPosition
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 BuyerMakerFeeReferralDiscount decimal.Decimal BuyerMakerFeeVolumeDiscount decimal.Decimal BuyerInfrastructureFeeReferralDiscount decimal.Decimal BuyerInfrastructureFeeVolumeDiscount decimal.Decimal BuyerLiquidityFeeReferralDiscount decimal.Decimal BuyerLiquidityFeeVolumeDiscount decimal.Decimal SellerMakerFeeReferralDiscount decimal.Decimal SellerMakerFeeVolumeDiscount decimal.Decimal SellerInfrastructureFeeReferralDiscount decimal.Decimal SellerInfrastructureFeeVolumeDiscount decimal.Decimal SellerLiquidityFeeReferralDiscount decimal.Decimal SellerLiquidityFeeVolumeDiscount 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 DispatchStrategy *vega.DispatchStrategy Reason *string GameID GameID }
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 TransferDetails ¶ added in v0.73.0
type TransferDetails struct { Transfer Fees []*TransferFees }
func (TransferDetails) ToProtoEdge ¶ added in v0.73.0
func (d TransferDetails) ToProtoEdge(input ...any) (*v2.TransferEdge, error)
type TransferFees ¶ added in v0.73.0
type TransferFees struct { TransferID TransferID EpochSeq uint64 Amount decimal.Decimal DiscountApplied decimal.Decimal VegaTime time.Time }
func TransferFeesFromProto ¶ added in v0.73.0
func TransferFeesFromProto(f *eventspb.TransferFees, vegaTime time.Time) *TransferFees
func (*TransferFees) ToProto ¶ added in v0.73.0
func (f *TransferFees) ToProto() *eventspb.TransferFees
type TransferFeesDiscount ¶ added in v0.74.0
type TransferFeesDiscount struct { PartyID PartyID AssetID AssetID Amount decimal.Decimal EpochSeq uint64 VegaTime time.Time }
func TransferFeesDiscountFromProto ¶ added in v0.74.0
func TransferFeesDiscountFromProto(f *eventspb.TransferFeesDiscount, vegaTime time.Time) *TransferFeesDiscount
func (*TransferFeesDiscount) ToProto ¶ added in v0.74.0
func (f *TransferFeesDiscount) ToProto() *eventspb.TransferFeesDiscount
type TransferID ¶
type TransferID = ID[_Transfer]
type TransferScope ¶ added in v0.74.0
type TransferScope int32
const ( TransferScopeUnspecified TransferScope = 1 TransferScopeIndividual TransferScope = 1 TransferScopeTeam TransferScope = 2 )
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 GovernanceOneOff GovernanceRecurring )
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 VestingStatsUpdated ¶ added in v0.73.0
type VestingStatsUpdated struct { AtEpoch uint64 PartyVestingStats []*PartyVestingStats VegaTime time.Time }
func NewVestingStatsFromProto ¶ added in v0.73.0
func NewVestingStatsFromProto(vestingStatsProto *eventspb.VestingStatsUpdated, vegaTime time.Time) (*VestingStatsUpdated, error)
type VolumeDiscountProgram ¶ added in v0.73.0
type VolumeDiscountProgram struct { ID VolumeDiscountProgramID Version uint64 BenefitTiers []*vega.VolumeBenefitTier EndOfProgramTimestamp time.Time WindowLength uint64 VegaTime time.Time EndedAt *time.Time SeqNum uint64 }
func VolumeDiscountProgramFromProto ¶ added in v0.73.0
func VolumeDiscountProgramFromProto(proto *vega.VolumeDiscountProgram, vegaTime time.Time, seqNum uint64) *VolumeDiscountProgram
func (VolumeDiscountProgram) ToProto ¶ added in v0.73.0
func (rp VolumeDiscountProgram) ToProto() *v2.VolumeDiscountProgram
type VolumeDiscountProgramID ¶ added in v0.73.0
type VolumeDiscountProgramID = ID[_VolumeDiscountProgram]
type VolumeDiscountStats ¶ added in v0.73.0
type VolumeDiscountStats struct { AtEpoch uint64 PartiesVolumeDiscountStats []*eventspb.PartyVolumeDiscountStats VegaTime time.Time }
func NewVolumeDiscountStatsFromProto ¶ added in v0.73.0
func NewVolumeDiscountStatsFromProto(vestingStatsProto *eventspb.VolumeDiscountStatsUpdated, vegaTime time.Time) (*VolumeDiscountStats, error)
type VolumeDiscountStatsCursor ¶ added in v0.73.0
func (*VolumeDiscountStatsCursor) Parse ¶ added in v0.73.0
func (c *VolumeDiscountStatsCursor) Parse(cursorString string) error
func (*VolumeDiscountStatsCursor) ToString ¶ added in v0.73.0
func (c *VolumeDiscountStatsCursor) ToString() 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 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
- activity_streak.go
- aggregated_balance.go
- aggregated_ledgerentries.go
- asset.go
- balance.go
- begin_block.go
- block.go
- candle.go
- chain.go
- checkpoint.go
- composite_price_state.go
- data.go
- data_source_definition.go
- data_source_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
- fees_stats.go
- funding_payment.go
- funding_period.go
- game.go
- id.go
- key_rotation.go
- ledgerentry.go
- ledgerentry_field.go
- ledgerentry_filter.go
- liquidity_provider.go
- liquidity_provision.go
- margin_levels.go
- margin_mode.go
- market.go
- market_depth.go
- marketdata.go
- network_limits.go
- network_parameter.go
- node.go
- node_basic.go
- node_signature.go
- oracle_data.go
- oracle_spec.go
- order.go
- order_filter.go
- pagination.go
- paid_liquidity_fee_stats.go
- party.go
- party_vesting_balances.go
- position.go
- product_data.go
- proposal.go
- protocol_upgrade_proposal.go
- referral_program.go
- referral_set_stats.go
- referral_sets.go
- reward.go
- reward_summary.go
- reward_summary_filter.go
- risk_factors.go
- snapshot_data.go
- stake_linking.go
- stop_orders.go
- successor_markets.go
- teams.go
- time_weighted_notional_position.go
- tradable_instrument.go
- trade.go
- transfer.go
- utils.go
- vesting.go
- volume_discount_program.go
- volume_discount_stats.go
- vote.go
- withdrawal.go