entities

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 GameScoresFromProto(gs *eventspb.GameScores, txHash TxHash, vegaTime time.Time, seqNum uint64) ([]GameTeamScore, []GamePartyScore, error)
• 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 AMMPool
  • func AMMPoolFromProto(pool *eventspb.AMM, vegaTime time.Time) (AMMPool, error)
  • func (p AMMPool) Cursor() *Cursor
  • func (p AMMPool) ToProto() *eventspb.AMM
  • func (p AMMPool) ToProtoEdge(_ ...any) (*v2.AMMEdge, error)
• type AMMPoolCursor
  • func (c *AMMPoolCursor) Parse(cursorString string) error
  • func (c AMMPoolCursor) String() string
• type AMMPoolID
• type AMMPoolsFilter
• type AMMStatus
  • func (s *AMMStatus) DecodeText(_ *pgtype.ConnInfo, src []byte) error
  • func (s AMMStatus) EncodeText(_ *pgtype.ConnInfo, buf []byte) ([]byte, error)
  • func (s *AMMStatus) Where(fieldName *string, nextBindVar func(args *[]any, arg any) string, args ...any) (string, []any)
• type AMMStatusReason
  • func (s *AMMStatusReason) DecodeText(_ *pgtype.ConnInfo, src []byte) error
  • func (s AMMStatusReason) EncodeText(_ *pgtype.ConnInfo, buf []byte) ([]byte, 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)
  • func (a Account) String() string
  • func (a Account) ToAccountDetailsProto() *vega.AccountDetails
  • func (a Account) ToProto() *vega.Account
• type AccountBalance
  • func (ab AccountBalance) Cursor() *Cursor
  • func (ab AccountBalance) Equal(other AccountBalance) bool
  • func (ab AccountBalance) Key() AccountBalanceKey
  • func (ab AccountBalance) ToProto() *v2.AccountBalance
  • func (ab AccountBalance) ToProtoEdge(args ...any) (*v2.AccountEdge, error)
  • func (ab AccountBalance) ToProtoWithParent(parentPartyID *string) *v2.AccountBalance
  • func (ab AccountBalance) ToRow() []interface{}
• type AccountBalanceKey
• type AccountCursor
  • func (ac *AccountCursor) Parse(cursorString string) error
  • func (ac AccountCursor) String() string
• type AccountField
  • func AccountFieldFromProto(field v2.AccountField) (AccountField, error)
  • func (s AccountField) String() string
• type AccountFilter
  • func AccountFilterFromProto(pbFilter *v2.AccountFilter) (AccountFilter, error)
• type AccountID
• type AccountSource
• type AggregatedBalance
  • func AggregatedBalanceScan(fields []AccountField, rows interface{ ... }) ([]AggregatedBalance, error)
  • func (balance AggregatedBalance) Cursor() *Cursor
  • func (balance *AggregatedBalance) ToProto() *v2.AggregatedBalance
  • func (balance AggregatedBalance) ToProtoEdge(_ ...any) (*v2.AggregatedBalanceEdge, error)
• type AggregatedBalanceCursor
  • func (c *AggregatedBalanceCursor) Parse(cursorString string) error
  • func (c AggregatedBalanceCursor) String() string
• type AggregatedLedgerEntriesCursor
  • func (c *AggregatedLedgerEntriesCursor) Parse(cursorString string) error
  • func (c AggregatedLedgerEntriesCursor) String() string
• type AggregatedLedgerEntry
  • func (ledgerEntries AggregatedLedgerEntry) Cursor() *Cursor
  • func (ledgerEntries *AggregatedLedgerEntry) ToProto() *v2.AggregatedLedgerEntry
  • func (ledgerEntries AggregatedLedgerEntry) ToProtoEdge(_ ...any) (*v2.AggregatedLedgerEntriesEdge, error)
• type Asset
  • func (a Asset) Cursor() *Cursor
  • func (a Asset) ToProto() *pb.Asset
  • func (a Asset) ToProtoEdge(_ ...any) (*v2.AssetEdge, error)
• type AssetCursor
  • func (ac *AssetCursor) Parse(cursorString string) error
  • func (ac AssetCursor) String() string
• type AssetID
• type AssetStatus
  • func (m *AssetStatus) DecodeText(_ *pgtype.ConnInfo, src []byte) error
  • func (m AssetStatus) EncodeText(_ *pgtype.ConnInfo, buf []byte) ([]byte, error)
• type AuctionDuration
• type Balance
  • func (b Balance) Key() BalanceKey
  • func (b Balance) ToRow() []interface{}
• type BalanceKey
• type BatchProposalTerms
  • func (pt BatchProposalTerms) MarshalJSON() ([]byte, error)
  • func (pt *BatchProposalTerms) UnmarshalJSON(b []byte) error
• type BeginBlockEvent
• type Block
  • func BlockFromBeginBlock(b BeginBlockEvent) (*Block, error)
• type Candle
  • func (c Candle) Cursor() *Cursor
  • func (c Candle) ToProtoEdge(_ ...any) (*v2.CandleEdge, error)
  • func (c *Candle) ToV1CandleProto(interval vega.Interval) (*vega.Candle, error)
  • func (c *Candle) ToV2CandleProto() *v2.Candle
• type CandleCursor
  • func (c *CandleCursor) Parse(cursorString string) error
  • func (c CandleCursor) String() string
• type Chain
• type Checkpoint
  • func CheckpointFromProto(cpe *eventspb.CheckpointEvent, txHash TxHash) (Checkpoint, error)
  • func (cp Checkpoint) Cursor() *Cursor
  • func (cp *Checkpoint) ToProto() *v2.Checkpoint
  • func (cp Checkpoint) ToProtoEdge(_ ...any) (*v2.CheckpointEdge, error)
• type CheckpointCursor
  • func (cp *CheckpointCursor) Parse(cursorString string) error
  • func (cp CheckpointCursor) String() string
• type CloseOnLimitOperation
• type CompositePriceConfiguration
  • func (cpc CompositePriceConfiguration) MarshalJSON() ([]byte, error)
  • func (cpc CompositePriceConfiguration) ToProto() *vega.CompositePriceConfiguration
  • func (cpc *CompositePriceConfiguration) UnmarshalJSON(data []byte) error
• type CompositePriceState
  • func (cps CompositePriceState) MarshalJSON() ([]byte, error)
  • func (p CompositePriceState) ToProto() *vega.CompositePriceState
  • func (cps *CompositePriceState) UnmarshalJSON(data []byte) error
• type Condition
  • func ConditionFromProto(protoCondition *datapb.Condition) Condition
  • func (c Condition) ToProto() *datapb.Condition
• type CoreSnapshotData
  • func CoreSnapshotDataFromProto(s *eventspb.CoreSnapshotData, txHash TxHash, vegaTime time.Time) CoreSnapshotData
  • func (s CoreSnapshotData) Cursor() *Cursor
  • func (s *CoreSnapshotData) ToProto() *eventspb.CoreSnapshotData
  • func (s CoreSnapshotData) ToProtoEdge(_ ...any) (*v2.CoreSnapshotEdge, error)
• type CoreSnapshotDataCursor
  • func (sc *CoreSnapshotDataCursor) Parse(cursorString string) error
  • func (sc CoreSnapshotDataCursor) String() string
• type CurrentAndPreviousLiquidityProvisions
  • func (lp CurrentAndPreviousLiquidityProvisions) Cursor() *Cursor
  • func (lp CurrentAndPreviousLiquidityProvisions) ToProto() *v2.LiquidityProvision
  • func (lp CurrentAndPreviousLiquidityProvisions) ToProtoEdge(_ ...any) (*v2.LiquidityProvisionWithPendingEdge, error)
• type Cursor
  • func NewCursor(cursor string) *Cursor
  • func (c *Cursor) Decode(value string) error
  • func (c *Cursor) Encode() string
  • func (c *Cursor) IsSet() bool
  • func (c *Cursor) Value() string
• type CursorOffset
  • func (o CursorOffset) HasCursor() bool
  • func (o CursorOffset) IsSet() bool
• type CursorPagination
  • func CursorPaginationFromProto(cp *v2.Pagination) (CursorPagination, error)
  • func DefaultCursorPagination(newestFirst bool) CursorPagination
  • func NewCursorPagination(first *int32, after *string, last *int32, before *string, newestFirst bool) (CursorPagination, error)
  • func (p CursorPagination) HasBackward() bool
  • func (p CursorPagination) HasForward() bool
• type Data
• type DataSourceDefinition
  • func DataSourceDefinitionFromProto(dsp *vega.DataSourceDefinition) 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
  • func DataSourceSpecFromProto(protoSpec *vegapb.DataSourceSpec, txHash TxHash, vegaTime time.Time) *DataSourceSpec
  • func (ds DataSourceSpec) Cursor() *Cursor
  • func (ds *DataSourceSpec) ToOracleProto() *vegapb.OracleSpec
  • func (ds DataSourceSpec) ToOracleProtoEdge(_ ...any) (*v2.OracleSpecEdge, error)
  • func (ds *DataSourceSpec) ToProto() *vegapb.DataSourceSpec
• type DataSourceSpecConfiguration
  • func (ds *DataSourceSpecConfiguration) GetFilters() []Filter
  • func (ds *DataSourceSpecConfiguration) GetSigners() Signers
• type DataSourceSpecConfigurationTime
  • func (d *DataSourceSpecConfigurationTime) GetConditions() []Condition
• type DataSourceSpecCursor
  • func (ds *DataSourceSpecCursor) Parse(cursorString string) error
  • func (ds DataSourceSpecCursor) String() string
• type DataSourceSpecStatus
  • func (s *DataSourceSpecStatus) DecodeText(_ *pgtype.ConnInfo, src []byte) error
  • func (s DataSourceSpecStatus) EncodeText(_ *pgtype.ConnInfo, buf []byte) ([]byte, error)
• type DateRange
  • func DateRangeFromProto(dateRangeInput *v2.DateRange) (dateRange DateRange)
  • func (dr DateRange) Validate(required bool) error
• type Delegation
  • func DelegationFromEventProto(pd *eventspb.DelegationBalanceEvent, txHash TxHash) (Delegation, error)
  • func DelegationFromProto(pd *vega.Delegation, txHash TxHash) (Delegation, error)
  • func (d Delegation) Cursor() *Cursor
  • func (d Delegation) String() string
  • func (d Delegation) ToProto() *vega.Delegation
  • func (d Delegation) ToProtoEdge(_ ...any) (*v2.DelegationEdge, error)
• type DelegationCursor
  • func (c *DelegationCursor) Parse(cursorString string) error
  • func (c DelegationCursor) String() string
• type Deposit
  • func DepositFromProto(deposit *vega.Deposit, txHash TxHash, vegaTime time.Time) (*Deposit, error)
  • func (d Deposit) Cursor() *Cursor
  • func (d Deposit) ToProto() *vega.Deposit
  • func (d Deposit) ToProtoEdge(_ ...any) (*v2.DepositEdge, error)
• type DepositCursor
  • func (dc *DepositCursor) Parse(cursorString string) error
  • func (dc DepositCursor) String() string
• type DepositID
• type DepositStatus
  • func (s *DepositStatus) DecodeText(_ *pgtype.ConnInfo, src []byte) error
  • func (s DepositStatus) EncodeText(_ *pgtype.ConnInfo, buf []byte) ([]byte, error)
• type DispatchMetric
  • func (m *DispatchMetric) DecodeText(_ *pgtype.ConnInfo, src []byte) error
  • func (m DispatchMetric) EncodeText(_ *pgtype.ConnInfo, buf []byte) ([]byte, error)
• 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
  • func ERC20MultiSigSignerEventFromAddedProto(e *eventspb.ERC20MultiSigSignerAdded, txHash TxHash) (*ERC20MultiSigSignerEvent, error)
  • func ERC20MultiSigSignerEventFromRemovedProto(e *eventspb.ERC20MultiSigSignerRemoved, txHash TxHash) ([]*ERC20MultiSigSignerEvent, error)
  • func (e ERC20MultiSigSignerEvent) Cursor() *Cursor
• type ERC20MultiSigSignerEventCursor
  • func (c *ERC20MultiSigSignerEventCursor) Parse(cursorString string) error
  • func (c ERC20MultiSigSignerEventCursor) String() string
• 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
  • func EpochFromProto(ee eventspb.EpochEvent, txHash TxHash) Epoch
  • func (e *Epoch) ToProto() *vega.Epoch
• type EpochData
  • func (ed EpochData) MarshalJSON() ([]byte, error)
  • func (ed *EpochData) UnmarshalJSON(b []byte) error
• type EpochRewardSummary
  • func (r EpochRewardSummary) Cursor() *Cursor
  • func (r *EpochRewardSummary) ToProto() *vega.EpochRewardSummary
  • func (r EpochRewardSummary) ToProtoEdge(_ ...any) (*v2.EpochRewardSummaryEdge, error)
• type EpochRewardSummaryCursor
  • func (rc *EpochRewardSummaryCursor) Parse(cursorString string) error
  • func (rc EpochRewardSummaryCursor) String() string
• 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
  • func EthereumKeyRotationFromProto(kr *eventspb.EthereumKeyRotation, txHash TxHash, vegaTime time.Time, ...) (EthereumKeyRotation, error)
  • func (kr EthereumKeyRotation) Cursor() *Cursor
  • func (kr EthereumKeyRotation) ToProto() *eventspb.EthereumKeyRotation
  • func (kr EthereumKeyRotation) ToProtoEdge(_ ...any) (*v2.EthereumKeyRotationEdge, error)
• type EthereumKeyRotationCursor
  • func (ec *EthereumKeyRotationCursor) Parse(cursorString string) error
  • func (ec EthereumKeyRotationCursor) String() string
• type ExternalData
  • func ExternalDataFromProto(data *datapb.ExternalData, txHash TxHash, vegaTime time.Time, seqNum uint64) (*ExternalData, error)
  • func (od ExternalData) Cursor() *Cursor
  • func (od ExternalData) ToOracleProto() *vegapb.OracleData
  • func (od ExternalData) ToOracleProtoEdge(_ ...any) (*v2.OracleDataEdge, error)
  • func (od *ExternalData) ToProto() *datapb.ExternalData
• type ExternalDataCursor
  • func (c *ExternalDataCursor) Parse(cursorString string) error
  • func (c ExternalDataCursor) String() string
• type ExternalDataSourceSpec
  • func ExternalDataSourceSpecFromProto(spec *vegapb.ExternalDataSourceSpec, txHash TxHash, vegaTime time.Time) *ExternalDataSourceSpec
  • func (s *ExternalDataSourceSpec) ToProto() *vegapb.ExternalDataSourceSpec
• type FeeFactors
• type Fees
  • func (f Fees) ToProto() *vega.Fees
• type FeesStats
  • func FeesStatsFromProto(proto *eventspb.FeesStats, vegaTime time.Time) *FeesStats
  • func (stats *FeesStats) ToProto() *eventspb.FeesStats
• type FeesStatsForParty
• type Filter
  • func FiltersFromProto(filters []*datapb.Filter) []Filter
  • func (f Filter) ToProto() *datapb.Filter
• type FlattenReferralSetStats
  • func (s FlattenReferralSetStats) Cursor() *Cursor
  • func (s FlattenReferralSetStats) ToProto() *v2.ReferralSetStats
  • func (s FlattenReferralSetStats) ToProtoEdge(_ ...any) (*v2.ReferralSetStatsEdge, error)
• type FlattenVolumeDiscountStats
  • func (s FlattenVolumeDiscountStats) Cursor() *Cursor
  • func (s FlattenVolumeDiscountStats) ToProto() *v2.VolumeDiscountStats
  • func (s FlattenVolumeDiscountStats) ToProtoEdge(_ ...any) (*v2.VolumeDiscountStatsEdge, error)
• type FundingPayment
  • func NewFundingPaymentsFromProto(fps *eventspb.FundingPayments, txHash TxHash, vegaTime time.Time) ([]*FundingPayment, error)
  • func (fp FundingPayment) Cursor() *Cursor
  • func (fp FundingPayment) ToProto() *v2.FundingPayment
  • func (fp FundingPayment) ToProtoEdge(_ ...any) (*v2.FundingPaymentEdge, error)
• type FundingPaymentCursor
  • func (c *FundingPaymentCursor) Parse(cursorString string) error
  • func (c FundingPaymentCursor) String() string
• type FundingPeriod
  • func NewFundingPeriodFromProto(fp *events.FundingPeriod, txHash TxHash, vegaTime time.Time) (*FundingPeriod, error)
  • func (fp FundingPeriod) Cursor() *Cursor
  • func (fp FundingPeriod) ToProto() *events.FundingPeriod
  • func (fp FundingPeriod) ToProtoEdge(_ ...any) (*v2.FundingPeriodEdge, error)
• type FundingPeriodCursor
  • func (c *FundingPeriodCursor) Parse(cursorString string) error
  • func (c FundingPeriodCursor) String() string
• type FundingPeriodDataPoint
  • func NewFundingPeriodDataPointFromProto(fpdp *events.FundingPeriodDataPoint, txHash TxHash, vegaTime time.Time) (*FundingPeriodDataPoint, error)
  • func (dp FundingPeriodDataPoint) Cursor() *Cursor
  • func (dp FundingPeriodDataPoint) ToProto() *events.FundingPeriodDataPoint
  • func (dp FundingPeriodDataPoint) ToProtoEdge(_ ...any) (*v2.FundingPeriodDataPointEdge, error)
• type FundingPeriodDataPointCursor
  • func (c *FundingPeriodDataPointCursor) Parse(cursorString string) error
  • func (c FundingPeriodDataPointCursor) String() string
• type FundingPeriodDataPointSource
  • func (s *FundingPeriodDataPointSource) DecodeText(_ *pgtype.ConnInfo, src []byte) error
  • func (s FundingPeriodDataPointSource) EncodeText(_ *pgtype.ConnInfo, buf []byte) ([]byte, error)
• type Game
  • func (g Game) Cursor() *Cursor
  • func (g Game) ToProto() *v2.Game
  • func (g Game) ToProtoEdge(_ ...any) (*v2.GameEdge, error)
• type GameCursor
  • func (gc *GameCursor) Parse(cursorString string) error
  • func (gc GameCursor) String() string
• type GameEntity
• type GameID
• type GamePartyScore
  • func (pgs GamePartyScore) Cursor() *Cursor
  • func (pgs GamePartyScore) ToProto() *eventspb.GamePartyScore
  • func (pgs GamePartyScore) ToProtoEdge(_ ...any) (*v2.GamePartyScoresEdge, error)
• type GameTeamScore
  • func (pgs GameTeamScore) Cursor() *Cursor
  • func (pgs GameTeamScore) ToProto() *eventspb.GameTeamScore
  • func (pgs GameTeamScore) ToProtoEdge(_ ...any) (*v2.GameTeamScoresEdge, error)
• type ID
  • func (id *ID[T]) Bytes() ([]byte, error)
  • func (id *ID[T]) DecodeBinary(ci *pgtype.ConnInfo, src []byte) error
  • func (id ID[T]) EncodeBinary(ci *pgtype.ConnInfo, buf []byte) ([]byte, error)
  • func (id *ID[T]) Error() error
  • func (id *ID[T]) SetBytes(src []byte) error
  • func (id *ID[T]) String() string
  • func (id *ID[T]) Where(fieldName *string, nextBindVar func(args *[]any, arg any) string, args ...any) (string, []any)
• type IndividualGameEntity
  • func (*IndividualGameEntity) IsGameEntity()
  • func (i *IndividualGameEntity) ToProto() *v2.IndividualGameEntity
• type KeyRotation
  • func KeyRotationFromProto(kr *eventspb.KeyRotation, txHash TxHash, vegaTime time.Time) (*KeyRotation, error)
  • func (kr KeyRotation) Cursor() *Cursor
  • func (kr KeyRotation) ToProto() *eventspb.KeyRotation
  • func (kr KeyRotation) ToProtoEdge(_ ...any) (*v2.KeyRotationEdge, error)
• type KeyRotationCursor
  • func (c *KeyRotationCursor) Parse(cursorString string) error
  • func (c KeyRotationCursor) String() string
• type LedgerEntry
  • func (le LedgerEntry) ToProto(ctx context.Context, accountSource AccountSource) (*vega.LedgerEntry, error)
  • func (le LedgerEntry) ToRow() []any
• type LedgerEntryField
  • func LedgerEntryFieldFromProto(field v2.LedgerEntryField) (LedgerEntryField, error)
  • func (s LedgerEntryField) String() string
• type LedgerEntryFilter
  • func LedgerEntryFilterFromProto(pbFilter *v2.LedgerEntryFilter) (*LedgerEntryFilter, error)
• type LedgerMovementType
  • func (l *LedgerMovementType) DecodeText(_ *pgtype.ConnInfo, src []byte) error
  • func (l LedgerMovementType) EncodeText(_ *pgtype.ConnInfo, buf []byte) ([]byte, error)
• type LiquidationStrategy
  • func LiquidationStrategyFromProto(ls *vega.LiquidationStrategy) LiquidationStrategy
  • func (l LiquidationStrategy) IntoProto() *vega.LiquidationStrategy
• type LiquidityFeeSettings
• type LiquidityFeeSettingsMethod
  • func (s *LiquidityFeeSettingsMethod) DecodeText(_ *pgtype.ConnInfo, src []byte) error
  • func (s LiquidityFeeSettingsMethod) EncodeText(_ *pgtype.ConnInfo, buf []byte) ([]byte, error)
• type LiquidityMonitoringParameters
  • func (lmp LiquidityMonitoringParameters) ToProto() *vega.LiquidityMonitoringParameters
• type LiquidityOrderReference
  • func (l *LiquidityOrderReference) DecodeBinary(_ *pgtype.ConnInfo, src []byte) error
  • func (l LiquidityOrderReference) EncodeBinary(_ *pgtype.ConnInfo, buf []byte) ([]byte, error)
• type LiquidityProvider
  • func (lp LiquidityProvider) Cursor() *Cursor
  • func (lp LiquidityProvider) ToProto() *v2.LiquidityProvider
  • func (lp LiquidityProvider) ToProtoEdge(...any) (*v2.LiquidityProviderEdge, error)
• type LiquidityProviderCursor
  • func (c *LiquidityProviderCursor) Parse(cursorString string) error
  • func (c LiquidityProviderCursor) String() string
• type LiquidityProvision
  • func LiquidityProvisionFromProto(lpProto *vega.LiquidityProvision, txHash TxHash, vegaTime time.Time) (LiquidityProvision, error)
  • 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
  • func (lc *LiquidityProvisionCursor) Parse(cursorString string) error
  • func (lc LiquidityProvisionCursor) String() string
• type LiquidityProvisionID
• type LiquidityProvisionKey
• type LiquidityProvisionStatus
  • func (s *LiquidityProvisionStatus) DecodeText(_ *pgtype.ConnInfo, src []byte) error
  • func (s LiquidityProvisionStatus) EncodeText(_ *pgtype.ConnInfo, buf []byte) ([]byte, error)
• type LiquiditySLAParameters
  • func LiquiditySLAParametersFromProto(sla *vega.LiquiditySLAParameters) (LiquiditySLAParameters, error)
  • func (lsp LiquiditySLAParameters) IntoProto() *vega.LiquiditySLAParameters
• type MarginCursor
  • func (mc *MarginCursor) Parse(cursorString string) error
  • func (mc MarginCursor) String() string
• type MarginLevels
  • func MarginLevelsFromProto(ctx context.Context, margin *vega.MarginLevels, accountSource AccountSource, ...) (MarginLevels, error)
  • 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
  • func (m *MarginMode) DecodeText(_ *pgtype.ConnInfo, src []byte) error
  • func (m MarginMode) EncodeText(_ *pgtype.ConnInfo, buf []byte) ([]byte, error)
• type Market
  • func NewMarketFromProto(market *vega.Market, txHash TxHash, vegaTime time.Time) (*Market, error)
  • func (m Market) Cursor() *Cursor
  • func (m *Market) HasCap() (cap *vega.FutureCap, hasCap bool)
  • func (m Market) ToProto() *vega.Market
  • func (m Market) ToProtoEdge(_ ...any) (*v2.MarketEdge, error)
• type MarketCursor
  • func (mc *MarketCursor) Parse(cursorString string) error
  • func (mc MarketCursor) String() string
• type MarketData
  • func MarketDataFromProto(data *types.MarketData, txHash TxHash) (*MarketData, error)
  • func (md MarketData) Cursor() *Cursor
  • func (md MarketData) Equal(other MarketData) bool
  • func (md MarketData) ToProto() *types.MarketData
  • func (md MarketData) ToProtoEdge(_ ...any) (*v2.MarketDataEdge, error)
• type MarketDataCursor
  • func (c *MarketDataCursor) Parse(cursorString string) error
  • func (c MarketDataCursor) String() string
• type MarketDepth
  • func (md *MarketDepth) AddAMMOrder(order *types.Order, estimated bool)
  • func (md *MarketDepth) AddOrderUpdate(order *types.Order, estimated bool)
  • func (md *MarketDepth) GetPriceLevel(side types.Side, price *num.Uint) *PriceLevel
  • func (md *MarketDepth) ToProto(limit uint64) *vega.MarketDepth
• type MarketID
  • func NewMarketIDSlice(ids ...string) []MarketID
• type MarketState
  • func (s *MarketState) DecodeText(_ *pgtype.ConnInfo, src []byte) error
  • func (s MarketState) EncodeText(_ *pgtype.ConnInfo, buf []byte) ([]byte, error)
• type MarketTimestamps
  • func (mt MarketTimestamps) ToProto() *vega.MarketTimestamps
• type MarketTradingMode
  • func (m *MarketTradingMode) DecodeText(_ *pgtype.ConnInfo, src []byte) error
  • func (m MarketTradingMode) EncodeText(_ *pgtype.ConnInfo, buf []byte) ([]byte, error)
• type NetworkLimits
  • func NetworkLimitsFromProto(vn *vega.NetworkLimits, txHash TxHash) NetworkLimits
  • func (nl *NetworkLimits) ToProto() *vega.NetworkLimits
• type NetworkParameter
  • func NetworkParameterFromProto(pnp *vega.NetworkParameter, txHash TxHash) (NetworkParameter, error)
  • func (np NetworkParameter) Cursor() *Cursor
  • func (np NetworkParameter) ToProto() *vega.NetworkParameter
  • func (np NetworkParameter) ToProtoEdge(_ ...any) (*v2.NetworkParameterEdge, error)
• type NetworkParameterCursor
  • func (c *NetworkParameterCursor) Parse(cursorString string) error
• type Node
  • func NodeFromProto(node *vega.Node, txHash TxHash, vegaTime time.Time) (Node, error)
  • func (node Node) Cursor() *Cursor
  • func (node *Node) ToProto() *vega.Node
  • func (node Node) ToProtoEdge(_ ...any) (*v2.NodeEdge, error)
• type NodeBasic
  • func (n NodeBasic) ToProto() *v2.NodeBasic
• type NodeCursor
  • func (nc *NodeCursor) Parse(cursorString string) error
  • func (nc NodeCursor) String() string
• type NodeData
  • func (n *NodeData) ToProto() *vega.NodeData
• type NodeID
• type NodeSet
  • func (n *NodeSet) ToProto() *vega.NodeSet
• type NodeSignature
  • func NodeSignatureFromProto(ns *commandspb.NodeSignature, txHash TxHash, vegaTime time.Time) (*NodeSignature, error)
  • func (w NodeSignature) Cursor() *Cursor
  • func (w NodeSignature) ToProto() *commandspb.NodeSignature
  • func (w NodeSignature) ToProtoEdge(_ ...any) (*v2.NodeSignatureEdge, error)
• type NodeSignatureCursor
  • func (c *NodeSignatureCursor) Parse(cursorString string) error
  • func (c NodeSignatureCursor) String() string
• type NodeSignatureID
• type NodeSignatureKind
  • func (s *NodeSignatureKind) DecodeText(_ *pgtype.ConnInfo, src []byte) error
  • func (s NodeSignatureKind) EncodeText(_ *pgtype.ConnInfo, buf []byte) ([]byte, error)
• type NodeStatus
  • func (ns *NodeStatus) DecodeText(_ *pgtype.ConnInfo, src []byte) error
  • func (ns NodeStatus) EncodeText(_ *pgtype.ConnInfo, buf []byte) ([]byte, error)
• type Normaliser
• type NotaryService
• type OracleData
  • func OracleDataFromProto(data *vegapb.OracleData, txHash TxHash, vegaTime time.Time, seqNum uint64) (*OracleData, error)
  • func (od OracleData) Cursor() *Cursor
  • func (od OracleData) ToProto() *vegapb.OracleData
  • func (od OracleData) ToProtoEdge(_ ...any) (*v2.OracleDataEdge, error)
• type OracleDataCursor
• type OracleSpec
  • func OracleSpecFromProto(spec *vegapb.OracleSpec, txHash TxHash, vegaTime time.Time) *OracleSpec
  • func (os OracleSpec) Cursor() *Cursor
  • func (os OracleSpec) ToProto() *vegapb.OracleSpec
  • func (os OracleSpec) ToProtoEdge(_ ...any) (*v2.OracleSpecEdge, error)
• type OracleSpecStatus
• type Order
  • func OrderFromProto(po *vega.Order, seqNum uint64, txHash TxHash) (Order, error)
  • func (o Order) Cursor() *Cursor
  • func (o Order) Key() OrderKey
  • func (o Order) ToProto() *vega.Order
  • func (o Order) ToProtoEdge(_ ...any) (*v2.OrderEdge, error)
  • func (o Order) ToRow() []interface{}
• type OrderCursor
  • func (oc *OrderCursor) Parse(cursorString string) error
  • func (oc OrderCursor) String() string
• type OrderError
• type OrderFilter
• type OrderID
• type OrderKey
• type OrderStatus
• type OrderTimeInForce
• type OrderType
• type PageInfo
  • func PageEntities[T proto.Message, U PagedEntity[T]](items []U, pagination CursorPagination) ([]U, PageInfo)
  • func (p PageInfo) ToProto() *v2.PageInfo
• type PagedEntity
• type Pagination
• type PaidLiquidityFeesStats
  • func PaidLiquidityFeesStatsFromProto(proto *eventspb.PaidLiquidityFeesStats, vegaTime time.Time) *PaidLiquidityFeesStats
  • func (s PaidLiquidityFeesStats) Cursor() *Cursor
  • func (s PaidLiquidityFeesStats) ToProto() *eventspb.PaidLiquidityFeesStats
  • func (s PaidLiquidityFeesStats) ToProtoEdge(_ ...any) (*v2.PaidLiquidityFeesEdge, error)
• type PaidLiquidityFeesStatsCursor
  • func (c *PaidLiquidityFeesStatsCursor) Parse(cursorString string) error
  • func (c PaidLiquidityFeesStatsCursor) ToString() string
• type Party
  • func PartyFromProto(pp *vegapb.Party, txHash TxHash) Party
  • func (p Party) Cursor() *Cursor
  • func (p *Party) Parse(cursorString string) error
  • func (p Party) String() string
  • func (p Party) ToProto() *vegapb.Party
  • func (p Party) ToProtoEdge(_ ...any) (*v2.PartyEdge, error)
• type PartyActivityStreak
  • func NewPartyActivityStreakFromProto(ev *eventspb.PartyActivityStreak, txHash TxHash, t time.Time) *PartyActivityStreak
  • func (pas PartyActivityStreak) Cursor() *Cursor
  • func (pas *PartyActivityStreak) Fields() []interface{}
  • func (pas *PartyActivityStreak) ToProto() *eventspb.PartyActivityStreak
• type PartyActivityStreakCursor
  • func (c *PartyActivityStreakCursor) Parse(cursorString string) error
  • func (c PartyActivityStreakCursor) String() string
• type PartyGameScoreCursor
  • func (pg *PartyGameScoreCursor) Parse(cursorString string) error
  • func (pg PartyGameScoreCursor) String() string
• type PartyID
  • func NewPartyIDSlice(ids ...string) []PartyID
• type PartyLockedBalance
  • func PartyLockedBalanceFromProto(partyID string, atEpoch uint64, pvb *eventspb.PartyLockedBalance, t time.Time) (*PartyLockedBalance, error)
• type PartyMarginMode
  • func PartyMarginModeFromProto(update *eventspb.PartyMarginModeUpdated) PartyMarginMode
  • func (t PartyMarginMode) Cursor() *Cursor
  • func (t PartyMarginMode) ToProto() *v2.PartyMarginMode
  • func (t PartyMarginMode) ToProtoEdge(_ ...any) (*v2.PartyMarginModeEdge, error)
• type PartyMarginModeCursor
  • func (tc *PartyMarginModeCursor) Parse(cursorString string) error
  • func (tc PartyMarginModeCursor) String() string
• type PartyProfile
  • func PartyProfileFromProto(t *vegapb.PartyProfile) *PartyProfile
  • func (p PartyProfile) Cursor() *Cursor
  • func (p *PartyProfile) Parse(cursorString string) error
  • func (p PartyProfile) String() string
  • func (p PartyProfile) ToProto() *vegapb.PartyProfile
  • func (p PartyProfile) ToProtoEdge(_ ...any) (*v2.PartyProfileEdge, error)
• type PartyProfileCursor
  • func (tc *PartyProfileCursor) Parse(cursorString string) error
  • func (tc PartyProfileCursor) String() string
• type PartyVestingBalance
  • func PartyVestingBalanceFromProto(partyID string, atEpoch uint64, pvb *eventspb.PartyVestingBalance, t time.Time) (*PartyVestingBalance, error)
• type PartyVestingStats
• type PeggedReference
• type PerMarketELSWeight
• type Position
  • func NewEmptyPosition(marketID MarketID, partyID PartyID) 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
  • func (rc *PositionCursor) Parse(cursorString string) error
  • func (rc PositionCursor) String() string
• type PositionKey
• type PositionStatus
  • func (p *PositionStatus) DecodeText(_ *pgtype.ConnInfo, src []byte) error
  • func (p PositionStatus) EncodeText(_ *pgtype.ConnInfo, buf []byte) ([]byte, error)
• type PriceLevel
• type PriceMonitoringParameters
• type PriceMonitoringSettings
  • func (s PriceMonitoringSettings) ToProto() *vega.PriceMonitoringSettings
• type PriceMonitoringTrigger
  • func (trigger PriceMonitoringTrigger) Equals(other PriceMonitoringTrigger) bool
  • func (trigger PriceMonitoringTrigger) ToProto() *types.PriceMonitoringTrigger
• type ProductData
  • func (p ProductData) MarshalJSON() ([]byte, error)
  • func (p ProductData) ToProto() *vega.ProductData
  • func (p *ProductData) UnmarshalJSON(data []byte) error
• type Property
• type PropertyKey
• type Proposal
  • func ProposalFromProto(pp *vega.Proposal, txHash TxHash) (Proposal, error)
  • func (p Proposal) BelongsToBatch() bool
  • func (p Proposal) Cursor() *Cursor
  • func (p Proposal) IsBatch() bool
  • func (p Proposal) ToProto() *vega.Proposal
  • func (p Proposal) ToProtoEdge(_ ...any) (*v2.GovernanceDataEdge, error)
• type ProposalCursor
  • func (pc *ProposalCursor) Parse(cursorString string) error
  • func (pc ProposalCursor) String() string
• type ProposalError
  • func (s *ProposalError) DecodeText(_ *pgtype.ConnInfo, src []byte) error
  • func (s ProposalError) EncodeText(_ *pgtype.ConnInfo, buf []byte) ([]byte, error)
• type ProposalID
• type ProposalRationale
  • func (pt ProposalRationale) MarshalJSON() ([]byte, error)
  • func (pt *ProposalRationale) UnmarshalJSON(b []byte) error
• type ProposalState
  • func (s *ProposalState) DecodeText(_ *pgtype.ConnInfo, src []byte) error
  • func (s ProposalState) EncodeText(_ *pgtype.ConnInfo, buf []byte) ([]byte, error)
• type ProposalTerms
  • func (pt ProposalTerms) MarshalJSON() ([]byte, error)
  • func (pt *ProposalTerms) UnmarshalJSON(b []byte) error
• type ProposalType
  • func (p *ProposalType) String() string
• type ProtoEntity
• type ProtoEnum
• type ProtocolUpgradeProposal
  • func ProtocolUpgradeProposalFromProto(p *eventspb.ProtocolUpgradeEvent, txHash TxHash, vegaTime time.Time) ProtocolUpgradeProposal
  • func (p ProtocolUpgradeProposal) Cursor() *Cursor
  • func (p ProtocolUpgradeProposal) ToProto() *eventspb.ProtocolUpgradeEvent
  • func (p ProtocolUpgradeProposal) ToProtoEdge(_ ...any) (*v2.ProtocolUpgradeProposalEdge, error)
• type ProtocolUpgradeProposalCursor
  • func (pc *ProtocolUpgradeProposalCursor) Parse(cursorString string) error
  • func (pc ProtocolUpgradeProposalCursor) String() string
• type ProtocolUpgradeProposalStatus
  • func (ps *ProtocolUpgradeProposalStatus) DecodeText(_ *pgtype.ConnInfo, src []byte) error
  • func (ps ProtocolUpgradeProposalStatus) EncodeText(_ *pgtype.ConnInfo, buf []byte) ([]byte, error)
• type QuantumRewardsPerEpoch
• type QuantumVolumesPerEpoch
• type RankingScore
  • func (rs *RankingScore) ToProto() *vega.RankingScore
• type RankingScoreAux
• type RefereeCursor
  • func (rc *RefereeCursor) Parse(cursorString string) error
  • func (rc RefereeCursor) String() string
• type RefereeHistoryCursor
  • func (rh *RefereeHistoryCursor) Parse(cursorString string) error
  • func (rh RefereeHistoryCursor) String() string
• type RefereeTeamSwitch
  • func TeamRefereeHistoryFromProto(switched *eventspb.RefereeSwitchedTeam, vegaTime time.Time) *RefereeTeamSwitch
• type ReferralProgram
  • func ReferralProgramFromProto(proto *vega.ReferralProgram, vegaTime time.Time, seqNum uint64) *ReferralProgram
  • func (rp ReferralProgram) ToProto() *v2.ReferralProgram
• type ReferralProgramID
• type ReferralSet
  • func ReferralSetFromProto(proto *eventspb.ReferralSetCreated, vegaTime time.Time) *ReferralSet
  • func (rs ReferralSet) Cursor() *Cursor
  • func (rs ReferralSet) ToProto() *v2.ReferralSet
  • func (rs ReferralSet) ToProtoEdge(_ ...any) (*v2.ReferralSetEdge, error)
• type ReferralSetCursor
  • func (c *ReferralSetCursor) Parse(cursorString string) error
  • func (c ReferralSetCursor) ToString() string
• type ReferralSetID
• type ReferralSetReferee
  • func ReferralSetRefereeFromProto(proto *eventspb.RefereeJoinedReferralSet, vegaTime time.Time) *ReferralSetReferee
  • func (r ReferralSetReferee) Cursor() *Cursor
  • func (r ReferralSetReferee) ToProto() *v2.ReferralSetReferee
  • func (r ReferralSetReferee) ToProtoEdge(_ ...any) (*v2.ReferralSetRefereeEdge, error)
• type ReferralSetRefereeCursor
  • func (c *ReferralSetRefereeCursor) Parse(cursorString string) error
  • func (c ReferralSetRefereeCursor) ToString() string
• type ReferralSetRefereeStats
  • func (r ReferralSetRefereeStats) ToProto() *v2.ReferralSetReferee
  • func (r ReferralSetRefereeStats) ToProtoEdge(_ ...any) (*v2.ReferralSetRefereeEdge, error)
• type ReferralSetStats
  • func ReferralSetStatsFromProto(proto *eventspb.ReferralSetStatsUpdated, vegaTime time.Time) (*ReferralSetStats, error)
• type ReferralSetStatsCursor
  • func (c *ReferralSetStatsCursor) Parse(cursorString string) error
  • func (c ReferralSetStatsCursor) ToString() string
• type Reward
  • func RewardFromProto(pr eventspb.RewardPayoutEvent, txHash TxHash, vegaTime time.Time, ...) (Reward, error)
  • func (r Reward) Cursor() *Cursor
  • func (r Reward) String() string
  • func (r Reward) ToProto() *vega.Reward
  • func (r Reward) ToProtoEdge(_ ...any) (*v2.RewardEdge, error)
• type RewardCursor
  • func (rc *RewardCursor) Parse(cursorString string) error
  • func (rc RewardCursor) String() string
• type RewardScore
  • func (rs *RewardScore) ToProto() *vega.RewardScore
• type RewardScoreAux
• type RewardSummary
  • func (r *RewardSummary) ToProto() *vega.RewardSummary
• type RewardSummaryFilter
  • func RewardSummaryFilterFromProto(pb *v2.RewardSummaryFilter) (filter RewardSummaryFilter)
• type RewardTotals
• type RiskFactor
  • func RiskFactorFromProto(factor *vega.RiskFactor, txHash TxHash, vegaTime time.Time) (*RiskFactor, error)
  • func (rf *RiskFactor) ToProto() *vega.RiskFactor
• type Side
• type Signer
• type Signers
  • func SerializeSigners(signers []*dstypes.Signer) (Signers, error)
• type SpecID
• type StakeLinking
  • func StakeLinkingFromProto(stake *eventspb.StakeLinking, txHash TxHash, vegaTime time.Time) (*StakeLinking, error)
  • func (s StakeLinking) Cursor() *Cursor
  • func (s *StakeLinking) ToProto() *eventspb.StakeLinking
  • func (s StakeLinking) ToProtoEdge(_ ...any) (*v2.StakeLinkingEdge, error)
• type StakeLinkingCursor
  • func (s *StakeLinkingCursor) Parse(cursorString string) error
  • func (s StakeLinkingCursor) String() string
• type StakeLinkingID
• type StakeLinkingStatus
  • func (s *StakeLinkingStatus) DecodeText(_ *pgtype.ConnInfo, src []byte) error
  • func (s StakeLinkingStatus) EncodeText(_ *pgtype.ConnInfo, buf []byte) ([]byte, error)
• type StakeLinkingType
  • func (s *StakeLinkingType) DecodeText(_ *pgtype.ConnInfo, src []byte) error
  • func (s StakeLinkingType) EncodeText(_ *pgtype.ConnInfo, buf []byte) ([]byte, error)
• type StopOrder
  • func StopOrderFromProto(so *pbevents.StopOrderEvent, vegaTime time.Time, seqNum uint64, txHash TxHash) (StopOrder, error)
  • func (s StopOrder) Cursor() *Cursor
  • func (s StopOrder) Key() StopOrderKey
  • func (o StopOrder) ToProto() *pbevents.StopOrderEvent
  • func (s StopOrder) ToProtoEdge(_ ...any) (*v2.StopOrderEdge, error)
  • func (so StopOrder) ToRow() []interface{}
• type StopOrderCursor
  • func (c *StopOrderCursor) Parse(cursorString string) error
  • func (c *StopOrderCursor) String() string
• type StopOrderExpiryStrategy
  • func (s *StopOrderExpiryStrategy) DecodeText(_ *pgtype.ConnInfo, src []byte) error
  • func (s StopOrderExpiryStrategy) EncodeText(_ *pgtype.ConnInfo, buf []byte) ([]byte, error)
• type StopOrderFilter
• type StopOrderID
• type StopOrderKey
• type StopOrderRejectionReason
  • func (s *StopOrderRejectionReason) DecodeText(_ *pgtype.ConnInfo, src []byte) error
  • func (s StopOrderRejectionReason) EncodeText(_ *pgtype.ConnInfo, buf []byte) ([]byte, error)
• type StopOrderStatus
  • func (s *StopOrderStatus) DecodeText(_ *pgtype.ConnInfo, src []byte) error
  • func (s StopOrderStatus) EncodeText(_ *pgtype.ConnInfo, buf []byte) ([]byte, error)
• type StopOrderTriggerDirection
  • func (s *StopOrderTriggerDirection) DecodeText(_ *pgtype.ConnInfo, src []byte) error
  • func (s StopOrderTriggerDirection) EncodeText(_ *pgtype.ConnInfo, buf []byte) ([]byte, error)
• type SuccessorMarket
  • func (s SuccessorMarket) Cursor() *Cursor
  • func (s SuccessorMarket) ToProtoEdge(...any) (*v2.SuccessorMarketEdge, error)
• type SuccessorMarketCursor
  • func (mc *SuccessorMarketCursor) Parse(cursorString string) error
  • func (mc SuccessorMarketCursor) String() string
• type TargetStakeParameters
  • func (tsp TargetStakeParameters) ToProto() *vega.TargetStakeParameters
• type Team
  • func TeamCreatedFromProto(created *eventspb.TeamCreated, vegaTime time.Time) *Team
  • func (t Team) Cursor() *Cursor
  • func (t Team) ToProto() *v2.Team
  • func (t Team) ToProtoEdge(_ ...any) (*v2.TeamEdge, error)
• type TeamCursor
  • func (tc *TeamCursor) Parse(cursorString string) error
  • func (tc TeamCursor) String() string
• type TeamGameEntity
  • func (*TeamGameEntity) IsGameEntity()
  • func (t *TeamGameEntity) ToProto() *v2.TeamGameEntity
• type TeamGameParticipation
  • func (t TeamGameParticipation) ToProto() *v2.TeamGameParticipation
• type TeamGameScoreCursor
  • func (pg *TeamGameScoreCursor) Parse(cursorString string) error
  • func (pg TeamGameScoreCursor) String() string
• type TeamID
• type TeamMember
  • func TeamRefereeFromProto(joined *eventspb.RefereeJoinedTeam, vegaTime time.Time) *TeamMember
  • func (t TeamMember) Cursor() *Cursor
  • func (t TeamMember) ToProto() *v2.TeamReferee
  • func (t TeamMember) ToProtoEdge(_ ...any) (*v2.TeamRefereeEdge, error)
• type TeamMemberHistory
  • func (t TeamMemberHistory) Cursor() *Cursor
  • func (t TeamMemberHistory) ToProto() *v2.TeamRefereeHistory
  • func (t TeamMemberHistory) ToProtoEdge(_ ...any) (*v2.TeamRefereeHistoryEdge, error)
• type TeamMemberStatisticsCursor
  • func (c *TeamMemberStatisticsCursor) Parse(cursorString string) error
  • func (c TeamMemberStatisticsCursor) String() string
• type TeamMembersStatistics
  • func (t TeamMembersStatistics) Cursor() *Cursor
  • func (t TeamMembersStatistics) ToProto() *v2.TeamMemberStatistics
  • func (t TeamMembersStatistics) ToProtoEdge(_ ...any) (*v2.TeamMemberStatisticsEdge, error)
• type TeamUpdated
  • func TeamUpdatedFromProto(updated *eventspb.TeamUpdated, vegaTime time.Time) *TeamUpdated
• type TeamsStatistics
  • func (t TeamsStatistics) Cursor() *Cursor
  • func (t TeamsStatistics) ToProto() *v2.TeamStatistics
  • func (t TeamsStatistics) ToProtoEdge(_ ...any) (*v2.TeamStatisticsEdge, error)
• type TeamsStatisticsCursor
  • func (c *TeamsStatisticsCursor) Parse(cursorString string) error
  • func (c TeamsStatisticsCursor) String() string
• 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
  • func TimeWeightedNotionalPositionFromProto(event *eventspb.TimeWeightedNotionalPositionUpdated, vegaTime time.Time) (*TimeWeightedNotionalPosition, error)
  • func (tw *TimeWeightedNotionalPosition) ToProto() *v2.TimeWeightedNotionalPosition
• type TradableInstrument
  • func (ti TradableInstrument) MarshalJSON() ([]byte, error)
  • func (ti TradableInstrument) ToProto() *vega.TradableInstrument
  • func (ti *TradableInstrument) UnmarshalJSON(data []byte) error
• type Trade
  • func TradeFromProto(t *vega.Trade, txHash TxHash, vegaTime time.Time, sequenceNumber uint64) (*Trade, error)
  • func (t Trade) Cursor() *Cursor
  • func (t Trade) ToProto() *vega.Trade
  • func (t Trade) ToProtoEdge(_ ...any) (*v2.TradeEdge, error)
• type TradeCursor
  • func (c *TradeCursor) Parse(cursorString string) error
  • func (c TradeCursor) String() string
• type TradeID
• type TradeType
• type Transfer
  • func TransferFromProto(ctx context.Context, t *eventspb.Transfer, txHash TxHash, vegaTime time.Time, ...) (*Transfer, error)
  • func (t Transfer) Cursor() *Cursor
  • func (t *Transfer) ToProto(ctx context.Context, accountSource AccountSource) (*eventspb.Transfer, error)
  • func (t Transfer) ToProtoEdge(input ...any) (*v2.TransferEdge, error)
• type TransferCursor
  • func (tc *TransferCursor) Parse(cursorString string) error
  • func (tc TransferCursor) String() string
• type TransferDetails
  • func (d TransferDetails) ToProtoEdge(input ...any) (*v2.TransferEdge, error)
• type TransferFees
  • func TransferFeesFromProto(f *eventspb.TransferFees, vegaTime time.Time) *TransferFees
  • func (f *TransferFees) ToProto() *eventspb.TransferFees
• type TransferFeesDiscount
  • func TransferFeesDiscountFromProto(f *eventspb.TransferFeesDiscount, vegaTime time.Time) *TransferFeesDiscount
  • func (f *TransferFeesDiscount) ToProto() *eventspb.TransferFeesDiscount
• type TransferID
• type TransferScope
• type TransferStatus
  • func (m *TransferStatus) DecodeText(_ *pgtype.ConnInfo, src []byte) error
  • func (m TransferStatus) EncodeText(_ *pgtype.ConnInfo, buf []byte) ([]byte, error)
• type TransferType
  • func (m *TransferType) DecodeText(_ *pgtype.ConnInfo, src []byte) error
  • func (m TransferType) EncodeText(_ *pgtype.ConnInfo, buf []byte) ([]byte, error)
• type TxHash
  • func (h *TxHash) Bytes() ([]byte, error)
  • func (h *TxHash) DecodeBinary(ci *pgtype.ConnInfo, src []byte) error
  • func (h TxHash) EncodeBinary(ci *pgtype.ConnInfo, buf []byte) ([]byte, error)
  • func (h *TxHash) Error() error
  • func (h *TxHash) String() string
• type ValidatorNodeStatus
  • func ValidatorNodeStatusFromString(status string) ValidatorNodeStatus
  • func (ns *ValidatorNodeStatus) DecodeText(_ *pgtype.ConnInfo, src []byte) error
  • func (ns ValidatorNodeStatus) EncodeText(_ *pgtype.ConnInfo, buf []byte) ([]byte, error)
  • func (ns *ValidatorNodeStatus) UnmarshalJSON(src []byte) error
• type ValidatorUpdateAux
• type VegaPublicKey
  • func (pk *VegaPublicKey) Bytes() ([]byte, error)
  • func (pk *VegaPublicKey) DecodeBinary(ci *pgtype.ConnInfo, src []byte) error
  • func (pk VegaPublicKey) EncodeBinary(ci *pgtype.ConnInfo, buf []byte) ([]byte, error)
  • func (pk *VegaPublicKey) Error() error
  • func (pk *VegaPublicKey) String() string
• type VestingStatsUpdated
  • func NewVestingStatsFromProto(vestingStatsProto *eventspb.VestingStatsUpdated, vegaTime time.Time) (*VestingStatsUpdated, error)
• type VolumeDiscountProgram
  • func VolumeDiscountProgramFromProto(proto *vega.VolumeDiscountProgram, vegaTime time.Time, seqNum uint64) *VolumeDiscountProgram
  • func (rp VolumeDiscountProgram) ToProto() *v2.VolumeDiscountProgram
• type VolumeDiscountProgramID
• type VolumeDiscountStats
  • func NewVolumeDiscountStatsFromProto(vestingStatsProto *eventspb.VolumeDiscountStatsUpdated, vegaTime time.Time) (*VolumeDiscountStats, error)
• type VolumeDiscountStatsCursor
  • func (c *VolumeDiscountStatsCursor) Parse(cursorString string) error
  • func (c *VolumeDiscountStatsCursor) ToString() string
• type Vote
  • func VoteFromProto(pv *vega.Vote, txHash TxHash) (Vote, error)
  • func (v Vote) Cursor() *Cursor
  • func (v Vote) ToProto() *vega.Vote
  • func (v Vote) ToProtoEdge(_ ...any) (*v2.VoteEdge, error)
• type VoteCursor
  • func (vc *VoteCursor) Parse(cursorString string) error
  • func (vc VoteCursor) String() string
• type VoteValue
  • func (s *VoteValue) DecodeText(_ *pgtype.ConnInfo, src []byte) error
  • func (s VoteValue) EncodeText(_ *pgtype.ConnInfo, buf []byte) ([]byte, error)
• type WithdrawExt
  • func (we WithdrawExt) MarshalJSON() ([]byte, error)
  • func (we *WithdrawExt) UnmarshalJSON(b []byte) error
• type Withdrawal
  • func WithdrawalFromProto(withdrawal *vega.Withdrawal, txHash TxHash, vegaTime time.Time) (*Withdrawal, error)
  • func (w Withdrawal) Cursor() *Cursor
  • func (w Withdrawal) ToProto() *vega.Withdrawal
  • func (w Withdrawal) ToProtoEdge(_ ...any) (*v2.WithdrawalEdge, error)
• type WithdrawalCursor
  • func (wc *WithdrawalCursor) Parse(cursorString string) error
  • func (wc WithdrawalCursor) String() string
• type WithdrawalID
• type WithdrawalStatus
  • func (s *WithdrawalStatus) DecodeText(_ *pgtype.ConnInfo, src []byte) error
  • func (s WithdrawalStatus) EncodeText(_ *pgtype.ConnInfo, buf []byte) ([]byte, error)

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)
	DispatchMetricRealisedReturn                   = DispatchMetric(vega.DispatchMetric_DISPATCH_METRIC_REALISED_RETURN)
)

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)
	MarketTradingModelLongBlockAuction      = MarketTradingMode(vega.Market_TRADING_MODE_LONG_BLOCK_AUCTION)
)

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)
	ProposalErrorInsufficientEquityLikeShare      = ProposalError(vega.ProposalError_PROPOSAL_ERROR_INSUFFICIENT_EQUITY_LIKE_SHARE)
	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)
	StopOrderRejectionSizeOverrideUnSupportedForSpot     = StopOrderRejectionReason(vega.StopOrder_REJECTION_REASON_STOP_ORDER_SIZE_OVERRIDE_UNSUPPORTED_FOR_SPOT)
	StopOrderRejectionLinkedPercentageInvalid            = StopOrderRejectionReason(vega.StopOrder_REJECTION_REASON_STOP_ORDER_LINKED_PERCENTAGE_INVALID)
)

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 (
	AMMStatusUnspecified = AMMStatus(eventspb.AMM_STATUS_UNSPECIFIED)
	AMMStatusActive      = AMMStatus(eventspb.AMM_STATUS_ACTIVE)
	AMMStatusRejected    = AMMStatus(eventspb.AMM_STATUS_REJECTED)
	AMMStatusCancelled   = AMMStatus(eventspb.AMM_STATUS_CANCELLED)
	AMMStatusStopped     = AMMStatus(eventspb.AMM_STATUS_STOPPED)
	AMMStatusReduceOnly  = AMMStatus(eventspb.AMM_STATUS_REDUCE_ONLY)
)

const (
	AMMStatusReasonUnspecified           = AMMStatusReason(eventspb.AMM_STATUS_REASON_UNSPECIFIED)
	AMMStatusReasonCancelledByParty      = AMMStatusReason(eventspb.AMM_STATUS_REASON_CANCELLED_BY_PARTY)
	AMMStatusReasonCannotFillCommitment  = AMMStatusReason(eventspb.AMM_STATUS_REASON_CANNOT_FILL_COMMITMENT)
	AMMStatusReasonPartyAlreadyOwnsAPool = AMMStatusReason(eventspb.AMM_STATUS_REASON_PARTY_ALREADY_OWNS_AMM_FOR_MARKET)
	AMMStatusReasonPartyClosedOut        = AMMStatusReason(eventspb.AMM_STATUS_REASON_PARTY_CLOSED_OUT)
	AMMStatusReasonMarketClosed          = AMMStatusReason(eventspb.AMM_STATUS_REASON_MARKET_CLOSED)
	AMMStatusReasonCommitmentTooLow      = AMMStatusReason(eventspb.AMM_STATUS_REASON_COMMITMENT_TOO_LOW)
	AMMStatusReasonCannotRebase          = AMMStatusReason(eventspb.AMM_STATUS_REASON_CANNOT_REBASE)
)

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

func CalculateOpenClosedVolume(currentOpenVolume, tradedVolume int64) (int64, int64)

func CreateLedgerEntryTime

func CreateLedgerEntryTime(vegaTime time.Time, seqNum int) time.Time

func DeserializeSigners

func DeserializeSigners(data Signers) []*dstypes.Signer

func GameScoresFromProto

func GameScoresFromProto(gs *eventspb.GameScores, txHash TxHash, vegaTime time.Time, seqNum uint64) ([]GameTeamScore, []GamePartyScore, error)

func NanosToPostgresTimestamp

func NanosToPostgresTimestamp(nanos int64) time.Time

NanosToPostgresTimestamp postgres stores timestamps in microsecond resolution.

func NodeFromValidatorUpdateEvent

func NodeFromValidatorUpdateEvent(evt eventspb.ValidatorUpdate, txHash TxHash, vegaTime time.Time) (Node, ValidatorUpdateAux, error)

func PackNodeSignatures

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 AMMPool

type AMMPool struct {
	ID                             AMMPoolID
	PartyID                        PartyID
	MarketID                       MarketID
	AmmPartyID                     PartyID
	Commitment                     num.Decimal
	Status                         AMMStatus
	StatusReason                   AMMStatusReason
	ParametersBase                 num.Decimal
	ParametersLowerBound           *num.Decimal
	ParametersUpperBound           *num.Decimal
	ParametersLeverageAtLowerBound *num.Decimal
	ParametersLeverageAtUpperBound *num.Decimal
	ProposedFee                    *num.Decimal
	CreatedAt                      time.Time
	LastUpdated                    time.Time
	LowerVirtualLiquidity          num.Decimal
	LowerTheoreticalPosition       num.Decimal
	UpperVirtualLiquidity          num.Decimal
	UpperTheoreticalPosition       num.Decimal
}

func AMMPoolFromProto

func AMMPoolFromProto(pool *eventspb.AMM, vegaTime time.Time) (AMMPool, error)

func (AMMPool) Cursor

func (p AMMPool) Cursor() *Cursor

func (AMMPool) ToProto

func (p AMMPool) ToProto() *eventspb.AMM

func (AMMPool) ToProtoEdge

func (p AMMPool) ToProtoEdge(_ ...any) (*v2.AMMEdge, error)

type AMMPoolCursor

type AMMPoolCursor struct {
	CreatedAt  time.Time
	PartyID    PartyID
	MarketID   MarketID
	ID         AMMPoolID
	AMMPartyID PartyID
}

func (*AMMPoolCursor) Parse

func (c *AMMPoolCursor) Parse(cursorString string) error

func (AMMPoolCursor) String

func (c AMMPoolCursor) String() string

type AMMPoolID

type AMMPoolID = ID[_AMMPoolID]

type AMMPoolsFilter

type AMMPoolsFilter interface {
	*PartyID | *MarketID | *AMMPoolID | *AMMStatus

	// Where clause generated by the filter to be used in SQL queries.
	// Optionally override the default field name defined on the implemented filter
	// with the provided field name by providing a not nil value for the field name
	Where(fieldName *string, nextBindVar func(*[]any, any) string, args ...any) (string, []any)
}

type AMMStatus

type AMMStatus eventspb.AMM_Status

func (*AMMStatus) DecodeText

func (s *AMMStatus) DecodeText(_ *pgtype.ConnInfo, src []byte) error

func (AMMStatus) EncodeText

func (s AMMStatus) EncodeText(_ *pgtype.ConnInfo, buf []byte) ([]byte, error)

func (*AMMStatus) Where

func (s *AMMStatus) Where(fieldName *string, nextBindVar func(args *[]any, arg any) string, args ...any) (string, []any)

type AMMStatusReason

type AMMStatusReason eventspb.AMM_StatusReason

func (*AMMStatusReason) DecodeText

func (s *AMMStatusReason) DecodeText(_ *pgtype.ConnInfo, src []byte) error

func (AMMStatusReason) EncodeText

func (s AMMStatusReason) EncodeText(_ *pgtype.ConnInfo, buf []byte) ([]byte, error)

type Account

type Account struct {
	ID       AccountID
	PartyID  PartyID
	AssetID  AssetID
	MarketID MarketID
	Type     vega.AccountType
	TxHash   TxHash
	VegaTime time.Time
}

func AccountFromProto

func AccountFromProto(va *vega.Account, txHash TxHash) (Account, error)

func AccountProtoFromDetails

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

func GetAccountFromOrderMarginLevel(ctx context.Context, margin *vega.MarginLevels, accountSource AccountSource, txHash TxHash, vegaTime time.Time) (Account, error)

func (Account) String

func (a Account) String() string

func (Account) ToAccountDetailsProto

func (a Account) ToAccountDetailsProto() *vega.AccountDetails

func (Account) ToProto

func (a Account) ToProto() *vega.Account

type AccountBalance

type AccountBalance struct {
	*Account
	Balance  decimal.Decimal
	TxHash   TxHash
	VegaTime time.Time
}

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(args ...any) (*v2.AccountEdge, error)

func (AccountBalance) ToProtoWithParent

func (ab AccountBalance) ToProtoWithParent(parentPartyID *string) *v2.AccountBalance

func (AccountBalance) ToRow

func (ab AccountBalance) ToRow() []interface{}

type AccountBalanceKey

type AccountBalanceKey struct {
	AccountID AccountID
	VegaTime  time.Time
}

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 AccountID

type AccountID = ID[_Account]

type AccountSource

type AccountSource interface {
	Obtain(ctx context.Context, a *Account) error
	GetByID(ctx context.Context, id AccountID) (Account, error)
}

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

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

func (balance AggregatedBalance) Cursor() *Cursor

func (*AggregatedBalance) ToProto

func (balance *AggregatedBalance) ToProto() *v2.AggregatedBalance

func (AggregatedBalance) ToProtoEdge

func (balance AggregatedBalance) ToProtoEdge(_ ...any) (*v2.AggregatedBalanceEdge, error)

type AggregatedBalanceCursor

type AggregatedBalanceCursor struct {
	VegaTime  time.Time `json:"vega_time"`
	AccountID *AccountID
	PartyID   *PartyID
	AssetID   *AssetID
	MarketID  *MarketID
	Type      *types.AccountType
}

func (*AggregatedBalanceCursor) Parse

func (c *AggregatedBalanceCursor) Parse(cursorString string) error

func (AggregatedBalanceCursor) String

func (c AggregatedBalanceCursor) String() string

type AggregatedLedgerEntriesCursor

type AggregatedLedgerEntriesCursor struct {
	VegaTime time.Time `json:"vega_time"`
}

func (*AggregatedLedgerEntriesCursor) Parse

func (c *AggregatedLedgerEntriesCursor) Parse(cursorString string) error

func (AggregatedLedgerEntriesCursor) String

func (c AggregatedLedgerEntriesCursor) String() string

type AggregatedLedgerEntry

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

func (ledgerEntries AggregatedLedgerEntry) Cursor() *Cursor

func (*AggregatedLedgerEntry) ToProto

func (ledgerEntries *AggregatedLedgerEntry) ToProto() *v2.AggregatedLedgerEntry

func (AggregatedLedgerEntry) ToProtoEdge

func (ledgerEntries AggregatedLedgerEntry) ToProtoEdge(_ ...any) (*v2.AggregatedLedgerEntriesEdge, error)

type Asset

type Asset struct {
	ID                AssetID
	ChainID           string `db:"chain_id"`
	Name              string
	Symbol            string
	Decimals          int
	Quantum           decimal.Decimal
	Source            string
	ERC20Contract     string
	TxHash            TxHash
	VegaTime          time.Time
	LifetimeLimit     decimal.Decimal
	WithdrawThreshold decimal.Decimal
	Status            AssetStatus
}

func (Asset) Cursor

func (a Asset) Cursor() *Cursor

func (Asset) ToProto

func (a Asset) ToProto() *pb.Asset

func (Asset) ToProtoEdge

func (a Asset) ToProtoEdge(_ ...any) (*v2.AssetEdge, error)

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 AssetID

type AssetID = ID[_Asset]

type AssetStatus

type AssetStatus vega.Asset_Status

func (*AssetStatus) DecodeText

func (m *AssetStatus) DecodeText(_ *pgtype.ConnInfo, src []byte) error

func (AssetStatus) EncodeText

func (m AssetStatus) EncodeText(_ *pgtype.ConnInfo, buf []byte) ([]byte, error)

type AuctionDuration

type AuctionDuration struct {
	Duration int64  `json:"duration,omitempty"`
	Volume   uint64 `json:"volume,omitempty"`
}

type Balance

type Balance struct {
	AccountID AccountID
	TxHash    TxHash
	VegaTime  time.Time
	Balance   decimal.Decimal
}

func (Balance) Key

func (b Balance) Key() BalanceKey

func (Balance) ToRow

func (b Balance) ToRow() []interface{}

type BalanceKey

type BalanceKey struct {
	AccountID AccountID
	VegaTime  time.Time
}

type BatchProposalTerms

type BatchProposalTerms struct {
	*vega.BatchProposalTerms
}

func (BatchProposalTerms) MarshalJSON

func (pt BatchProposalTerms) MarshalJSON() ([]byte, error)

func (*BatchProposalTerms) UnmarshalJSON

func (pt *BatchProposalTerms) UnmarshalJSON(b []byte) error

type BeginBlockEvent

type BeginBlockEvent interface {
	events.Event
	BeginBlock() eventspb.BeginBlock
}

type Block

type Block struct {
	VegaTime time.Time
	Height   int64
	Hash     []byte
}

func BlockFromBeginBlock

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) Cursor

func (c Candle) Cursor() *Cursor

func (Candle) ToProtoEdge

func (c Candle) ToProtoEdge(_ ...any) (*v2.CandleEdge, error)

func (*Candle) ToV1CandleProto

func (c *Candle) ToV1CandleProto(interval vega.Interval) (*vega.Candle, error)

func (*Candle) ToV2CandleProto

func (c *Candle) ToV2CandleProto() *v2.Candle

type CandleCursor

type CandleCursor struct {
	PeriodStart time.Time `json:"periodStart"`
}

func (*CandleCursor) Parse

func (c *CandleCursor) Parse(cursorString string) error

func (CandleCursor) String

func (c CandleCursor) String() string

type Chain

type Chain struct {
	ID 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

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

type CompositePriceConfiguration struct {
	*vega.CompositePriceConfiguration
}

func (CompositePriceConfiguration) MarshalJSON

func (cpc CompositePriceConfiguration) MarshalJSON() ([]byte, error)

func (CompositePriceConfiguration) ToProto

func (cpc CompositePriceConfiguration) ToProto() *vega.CompositePriceConfiguration

func (*CompositePriceConfiguration) UnmarshalJSON

func (cpc *CompositePriceConfiguration) UnmarshalJSON(data []byte) error

type CompositePriceState

type CompositePriceState struct {
	*vega.CompositePriceState
}

func (CompositePriceState) MarshalJSON

func (cps CompositePriceState) MarshalJSON() ([]byte, error)

func (CompositePriceState) ToProto

func (p CompositePriceState) ToProto() *vega.CompositePriceState

func (*CompositePriceState) UnmarshalJSON

func (cps *CompositePriceState) UnmarshalJSON(data []byte) error

type Condition

type Condition struct {
	Operator datapb.Condition_Operator
	Value    string
}

func ConditionFromProto

func ConditionFromProto(protoCondition *datapb.Condition) Condition

func (Condition) ToProto

func (c Condition) ToProto() *datapb.Condition

type CoreSnapshotData

type CoreSnapshotData struct {
	BlockHeight     uint64
	BlockHash       string
	VegaCoreVersion string
	TxHash          TxHash
	VegaTime        time.Time
}

func CoreSnapshotDataFromProto

func CoreSnapshotDataFromProto(s *eventspb.CoreSnapshotData, txHash TxHash, vegaTime time.Time) CoreSnapshotData

func (CoreSnapshotData) Cursor

func (s CoreSnapshotData) Cursor() *Cursor

func (*CoreSnapshotData) ToProto

func (s *CoreSnapshotData) ToProto() *eventspb.CoreSnapshotData

func (CoreSnapshotData) ToProtoEdge

func (s CoreSnapshotData) ToProtoEdge(_ ...any) (*v2.CoreSnapshotEdge, error)

type CoreSnapshotDataCursor

type CoreSnapshotDataCursor struct {
	VegaTime        time.Time
	BlockHeight     uint64
	BlockHash       string
	VegaCoreVersion string
}

func (*CoreSnapshotDataCursor) Parse

func (sc *CoreSnapshotDataCursor) Parse(cursorString string) error

func (CoreSnapshotDataCursor) String

func (sc CoreSnapshotDataCursor) String() string

type CurrentAndPreviousLiquidityProvisions

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

func (lp CurrentAndPreviousLiquidityProvisions) Cursor() *Cursor

func (CurrentAndPreviousLiquidityProvisions) ToProto

func (lp CurrentAndPreviousLiquidityProvisions) ToProto() *v2.LiquidityProvision

func (CurrentAndPreviousLiquidityProvisions) ToProtoEdge

func (lp CurrentAndPreviousLiquidityProvisions) ToProtoEdge(_ ...any) (*v2.LiquidityProvisionWithPendingEdge, error)

type Cursor

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

func NewCursor

func NewCursor(cursor string) *Cursor

func (*Cursor) Decode

func (c *Cursor) Decode(value string) error

func (*Cursor) Encode

func (c *Cursor) Encode() string

func (*Cursor) IsSet

func (c *Cursor) IsSet() bool

func (*Cursor) Value

func (c *Cursor) Value() string

type CursorOffset

type CursorOffset struct {
	Limit  *int32
	Cursor *Cursor
}

func (CursorOffset) HasCursor

func (o CursorOffset) HasCursor() bool

func (CursorOffset) IsSet

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 NewCursorPagination(first *int32, after *string, last *int32, before *string, newestFirst bool) (CursorPagination, error)

func (CursorPagination) HasBackward

func (p CursorPagination) HasBackward() bool

func (CursorPagination) HasForward

func (p CursorPagination) HasForward() bool

type Data

type Data struct {
	Signers        Signers
	Data           []Property
	MetaData       []Property
	MatchedSpecIds [][]byte // pgx automatically handles [][]byte to Postgres ByteaArray mappings
	BroadcastAt    time.Time
	Error          *string
	TxHash         TxHash
	VegaTime       time.Time
	SeqNum         uint64
}

type DataSourceDefinition

type DataSourceDefinition struct {
	*vega.DataSourceDefinition
}

func DataSourceDefinitionFromProto

func DataSourceDefinitionFromProto(dsp *vega.DataSourceDefinition) DataSourceDefinition

func (*DataSourceDefinition) GetConditions

func (s *DataSourceDefinition) GetConditions() []Condition

func (*DataSourceDefinition) GetEthOracle

func (s *DataSourceDefinition) GetEthOracle() (*EthCallSpec, error)

func (*DataSourceDefinition) GetFilters

func (s *DataSourceDefinition) GetFilters() []Filter

func (*DataSourceDefinition) GetInternalTimeTrigger

func (s *DataSourceDefinition) GetInternalTimeTrigger() *DataSourceSpecConfigurationTime

func (*DataSourceDefinition) GetOracle

func (s *DataSourceDefinition) GetOracle() (*DataSourceSpecConfiguration, error)

func (*DataSourceDefinition) GetSigners

func (s *DataSourceDefinition) GetSigners() (Signers, error)

func (DataSourceDefinition) MarshalJSON

func (s DataSourceDefinition) MarshalJSON() ([]byte, error)

func (*DataSourceDefinition) UnmarshalJSON

func (s *DataSourceDefinition) UnmarshalJSON(b []byte) error

type DataSourceSpec

type DataSourceSpec struct {
	ID        SpecID
	CreatedAt time.Time
	UpdatedAt time.Time
	Data      *DataSourceDefinition
	Status    DataSourceSpecStatus
	TxHash    TxHash
	VegaTime  time.Time
}

func DataSourceSpecFromProto

func DataSourceSpecFromProto(protoSpec *vegapb.DataSourceSpec, txHash TxHash, vegaTime time.Time) *DataSourceSpec

func (DataSourceSpec) Cursor

func (ds DataSourceSpec) Cursor() *Cursor

func (*DataSourceSpec) ToOracleProto

func (ds *DataSourceSpec) ToOracleProto() *vegapb.OracleSpec

func (DataSourceSpec) ToOracleProtoEdge

func (ds DataSourceSpec) ToOracleProtoEdge(_ ...any) (*v2.OracleSpecEdge, error)

func (*DataSourceSpec) ToProto

func (ds *DataSourceSpec) ToProto() *vegapb.DataSourceSpec

type DataSourceSpecConfiguration

type DataSourceSpecConfiguration struct {
	Signers Signers
	Filters []Filter
}

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

func (ds *DataSourceSpecConfiguration) GetFilters() []Filter

func (*DataSourceSpecConfiguration) GetSigners

func (ds *DataSourceSpecConfiguration) GetSigners() Signers

type DataSourceSpecConfigurationTime

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

func (d *DataSourceSpecConfigurationTime) GetConditions() []Condition

type DataSourceSpecCursor

type DataSourceSpecCursor struct {
	VegaTime time.Time `json:"vegaTime"`
	ID       SpecID    `json:"id"`
}

func (*DataSourceSpecCursor) Parse

func (ds *DataSourceSpecCursor) Parse(cursorString string) error

func (DataSourceSpecCursor) String

func (ds DataSourceSpecCursor) String() string

type DataSourceSpecStatus

type DataSourceSpecStatus vegapb.DataSourceSpec_Status

func (*DataSourceSpecStatus) DecodeText

func (s *DataSourceSpecStatus) DecodeText(_ *pgtype.ConnInfo, src []byte) error

func (DataSourceSpecStatus) EncodeText

func (s DataSourceSpecStatus) EncodeText(_ *pgtype.ConnInfo, buf []byte) ([]byte, error)

type DateRange

type DateRange struct {
	Start *time.Time
	End   *time.Time
}

func DateRangeFromProto

func DateRangeFromProto(dateRangeInput *v2.DateRange) (dateRange DateRange)

func (DateRange) Validate

func (dr DateRange) Validate(required bool) error

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 DepositFromProto(deposit *vega.Deposit, txHash TxHash, vegaTime time.Time) (*Deposit, error)

func (Deposit) Cursor

func (d Deposit) Cursor() *Cursor

func (Deposit) ToProto

func (d Deposit) ToProto() *vega.Deposit

func (Deposit) ToProtoEdge

func (d Deposit) ToProtoEdge(_ ...any) (*v2.DepositEdge, error)

type DepositCursor

type DepositCursor struct {
	VegaTime time.Time `json:"vegaTime"`
	ID       DepositID `json:"id"`
}

func (*DepositCursor) Parse

func (dc *DepositCursor) Parse(cursorString string) error

func (DepositCursor) String

func (dc DepositCursor) String() string

type DepositID

type DepositID = ID[_Deposit]

type DepositStatus

type DepositStatus vega.Deposit_Status

func (*DepositStatus) DecodeText

func (s *DepositStatus) DecodeText(_ *pgtype.ConnInfo, src []byte) error

func (DepositStatus) EncodeText

func (s DepositStatus) EncodeText(_ *pgtype.ConnInfo, buf []byte) ([]byte, error)

type DispatchMetric

type DispatchMetric vega.DispatchMetric

func (*DispatchMetric) DecodeText

func (m *DispatchMetric) DecodeText(_ *pgtype.ConnInfo, src []byte) error

func (DispatchMetric) EncodeText

func (m DispatchMetric) EncodeText(_ *pgtype.ConnInfo, buf []byte) ([]byte, error)

type ERC20MultiSigSignerAddedEvent

type ERC20MultiSigSignerAddedEvent struct {
	ERC20MultiSigSignerEvent
}

func (ERC20MultiSigSignerAddedEvent) Cursor

func (e ERC20MultiSigSignerAddedEvent) Cursor() *Cursor

func (ERC20MultiSigSignerAddedEvent) ToDataNodeApiV2Proto

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

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

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 | GamePartyScore | GameTeamScore | AMMPool
}

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

func (*Epoch) ToProto

func (e *Epoch) ToProto() *vega.Epoch

type EpochData

type EpochData struct {
	*vega.EpochData
}

func (EpochData) MarshalJSON

func (ed EpochData) MarshalJSON() ([]byte, error)

func (*EpochData) UnmarshalJSON

func (ed *EpochData) UnmarshalJSON(b []byte) error

type EpochRewardSummary

type EpochRewardSummary struct {
	AssetID    AssetID
	MarketID   MarketID
	RewardType string
	EpochID    uint64
	Amount     num.Decimal
}

func (EpochRewardSummary) Cursor

func (r EpochRewardSummary) Cursor() *Cursor

func (*EpochRewardSummary) ToProto

func (r *EpochRewardSummary) ToProto() *vega.EpochRewardSummary

func (EpochRewardSummary) ToProtoEdge

func (r EpochRewardSummary) ToProtoEdge(_ ...any) (*v2.EpochRewardSummaryEdge, error)

type EpochRewardSummaryCursor

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

func (rc *EpochRewardSummaryCursor) Parse(cursorString string) error

func (EpochRewardSummaryCursor) String

func (rc EpochRewardSummaryCursor) String() string

type EthCallSpec

type EthCallSpec struct {
	Address               string
	Abi                   []byte
	Method                string
	ArgsJson              []string
	Trigger               EthCallTrigger
	RequiredConfirmations uint64
	Filters               []Filter
	Normalisers           []Normaliser
}

func (*EthCallSpec) GetAbi

func (es *EthCallSpec) GetAbi() []byte

func (*EthCallSpec) GetAddress

func (es *EthCallSpec) GetAddress() string

func (*EthCallSpec) GetArgs

func (es *EthCallSpec) GetArgs() []string

func (*EthCallSpec) GetFilters

func (es *EthCallSpec) GetFilters() []Filter

func (*EthCallSpec) GetMethod

func (es *EthCallSpec) GetMethod() string

func (*EthCallSpec) GetNormalisers

func (es *EthCallSpec) GetNormalisers() []Normaliser

func (*EthCallSpec) GetRequiredConfirmations

func (es *EthCallSpec) GetRequiredConfirmations() uint64

func (*EthCallSpec) GetTrigger

func (es *EthCallSpec) GetTrigger() EthCallTrigger

type EthCallTrigger

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 (addr EthereumAddress) EncodeBinary(ci *pgtype.ConnInfo, buf []byte) ([]byte, error)

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

type ExternalData struct {
	Data *Data
}

func ExternalDataFromProto

func ExternalDataFromProto(data *datapb.ExternalData, txHash TxHash, vegaTime time.Time, seqNum uint64) (*ExternalData, error)

func (ExternalData) Cursor

func (od ExternalData) Cursor() *Cursor

func (ExternalData) ToOracleProto

func (od ExternalData) ToOracleProto() *vegapb.OracleData

func (ExternalData) ToOracleProtoEdge

func (od ExternalData) ToOracleProtoEdge(_ ...any) (*v2.OracleDataEdge, error)

func (*ExternalData) ToProto

func (od *ExternalData) ToProto() *datapb.ExternalData

type ExternalDataCursor

type ExternalDataCursor struct {
	VegaTime time.Time `json:"vegaTime"`
	Signers  Signers   `json:"signers"`
}

func (*ExternalDataCursor) Parse

func (c *ExternalDataCursor) Parse(cursorString string) error

func (ExternalDataCursor) String

func (c ExternalDataCursor) String() string

type ExternalDataSourceSpec

type ExternalDataSourceSpec struct {
	Spec *DataSourceSpec
}

func ExternalDataSourceSpecFromProto

func ExternalDataSourceSpecFromProto(spec *vegapb.ExternalDataSourceSpec, txHash TxHash, vegaTime time.Time) *ExternalDataSourceSpec

func (*ExternalDataSourceSpec) ToProto

func (s *ExternalDataSourceSpec) ToProto() *vegapb.ExternalDataSourceSpec

type FeeFactors

type FeeFactors struct {
	MakerFee          string `json:"makerFee,omitempty"`
	InfrastructureFee string `json:"infrastructureFee,omitempty"`
	LiquidityFee      string `json:"liquidityFee,omitempty"`
}

type Fees

type Fees struct {
	Factors              *FeeFactors           `json:"factors,omitempty"`
	LiquidityFeeSettings *LiquidityFeeSettings `json:"liquidityFeeSettings,omitempty"`
}

func (Fees) ToProto

func (f Fees) ToProto() *vega.Fees

type FeesStats

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

func FeesStatsFromProto(proto *eventspb.FeesStats, vegaTime time.Time) *FeesStats

func (*FeesStats) ToProto

func (stats *FeesStats) ToProto() *eventspb.FeesStats

type FeesStatsForParty

type FeesStatsForParty struct {
	AssetID                 AssetID
	TotalRewardsReceived    string
	RefereesDiscountApplied string
	VolumeDiscountApplied   string
	TotalMakerFeesReceived  string
}

type Filter

type Filter struct {
	Key        PropertyKey `json:"key"`
	Conditions []Condition `json:"conditions"`
}

func FiltersFromProto

func FiltersFromProto(filters []*datapb.Filter) []Filter

func (Filter) ToProto

func (f Filter) ToProto() *datapb.Filter

type FlattenReferralSetStats

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

func (s FlattenReferralSetStats) Cursor() *Cursor

func (FlattenReferralSetStats) ToProto

func (s FlattenReferralSetStats) ToProto() *v2.ReferralSetStats

func (FlattenReferralSetStats) ToProtoEdge

func (s FlattenReferralSetStats) ToProtoEdge(_ ...any) (*v2.ReferralSetStatsEdge, error)

type FlattenVolumeDiscountStats

type FlattenVolumeDiscountStats struct {
	AtEpoch        uint64
	PartyID        string
	DiscountFactor string
	RunningVolume  string
	VegaTime       time.Time
}

func (FlattenVolumeDiscountStats) Cursor

func (s FlattenVolumeDiscountStats) Cursor() *Cursor

func (FlattenVolumeDiscountStats) ToProto

func (s FlattenVolumeDiscountStats) ToProto() *v2.VolumeDiscountStats

func (FlattenVolumeDiscountStats) ToProtoEdge

func (s FlattenVolumeDiscountStats) ToProtoEdge(_ ...any) (*v2.VolumeDiscountStatsEdge, error)

type FundingPayment

type FundingPayment struct {
	PartyID          PartyID
	MarketID         MarketID
	FundingPeriodSeq uint64
	Amount           num.Decimal
	VegaTime         time.Time
	TxHash           TxHash
}

func NewFundingPaymentsFromProto

func NewFundingPaymentsFromProto(
	fps *eventspb.FundingPayments,
	txHash TxHash,
	vegaTime time.Time,
) ([]*FundingPayment, error)

func (FundingPayment) Cursor

func (fp FundingPayment) Cursor() *Cursor

func (FundingPayment) ToProto

func (fp FundingPayment) ToProto() *v2.FundingPayment

func (FundingPayment) ToProtoEdge

func (fp FundingPayment) ToProtoEdge(_ ...any) (*v2.FundingPaymentEdge, error)

type FundingPaymentCursor

type FundingPaymentCursor struct {
	VegaTime time.Time `json:"vegaTime"`
	MarketID MarketID  `json:"marketID"`
	PartyID  PartyID   `json:"partyID"`
}

func (*FundingPaymentCursor) Parse

func (c *FundingPaymentCursor) Parse(cursorString string) error

func (FundingPaymentCursor) String

func (c FundingPaymentCursor) String() string

type FundingPeriod

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

func NewFundingPeriodFromProto(fp *events.FundingPeriod, txHash TxHash, vegaTime time.Time) (*FundingPeriod, error)

func (FundingPeriod) Cursor

func (fp FundingPeriod) Cursor() *Cursor

func (FundingPeriod) ToProto

func (fp FundingPeriod) ToProto() *events.FundingPeriod

func (FundingPeriod) ToProtoEdge

func (fp FundingPeriod) ToProtoEdge(_ ...any) (*v2.FundingPeriodEdge, error)

type FundingPeriodCursor

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

func (c *FundingPeriodCursor) Parse(cursorString string) error

func (FundingPeriodCursor) String

func (c FundingPeriodCursor) String() string

type FundingPeriodDataPoint

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

func NewFundingPeriodDataPointFromProto(fpdp *events.FundingPeriodDataPoint, txHash TxHash, vegaTime time.Time) (*FundingPeriodDataPoint, error)

func (FundingPeriodDataPoint) Cursor

func (dp FundingPeriodDataPoint) Cursor() *Cursor

func (FundingPeriodDataPoint) ToProto

func (dp FundingPeriodDataPoint) ToProto() *events.FundingPeriodDataPoint

func (FundingPeriodDataPoint) ToProtoEdge

func (dp FundingPeriodDataPoint) ToProtoEdge(_ ...any) (*v2.FundingPeriodDataPointEdge, error)

type FundingPeriodDataPointCursor

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

func (c *FundingPeriodDataPointCursor) Parse(cursorString string) error

func (FundingPeriodDataPointCursor) String

func (c FundingPeriodDataPointCursor) String() string

type FundingPeriodDataPointSource

type FundingPeriodDataPointSource eventspb.FundingPeriodDataPoint_Source

func (*FundingPeriodDataPointSource) DecodeText

func (s *FundingPeriodDataPointSource) DecodeText(_ *pgtype.ConnInfo, src []byte) error

func (FundingPeriodDataPointSource) EncodeText

func (s FundingPeriodDataPointSource) EncodeText(_ *pgtype.ConnInfo, buf []byte) ([]byte, error)

type Game

type Game struct {
	ID            GameID
	Epoch         uint64
	Participants  uint64
	Entities      []GameEntity
	RewardAssetID AssetID
}

func (Game) Cursor

func (g Game) Cursor() *Cursor

func (Game) ToProto

func (g Game) ToProto() *v2.Game

func (Game) ToProtoEdge

func (g Game) ToProtoEdge(_ ...any) (*v2.GameEdge, error)

type GameCursor

type GameCursor struct {
	EpochID uint64
	GameID  GameID
}

func (*GameCursor) Parse

func (gc *GameCursor) Parse(cursorString string) error

func (GameCursor) String

func (gc GameCursor) String() string

type GameEntity

type GameEntity interface {
	IsGameEntity()
}

type GameID

type GameID = ID[_Game]

type GamePartyScore

type GamePartyScore struct {
	GameID         GameID
	TeamID         *TeamID
	EpochID        int64
	PartyID        PartyID
	Score          decimal.Decimal
	StakingBalance decimal.Decimal
	OpenVolume     decimal.Decimal
	TotalFeesPaid  decimal.Decimal
	IsEligible     bool
	Rank           *uint64
	VegaTime       time.Time
}

func (GamePartyScore) Cursor

func (pgs GamePartyScore) Cursor() *Cursor

func (GamePartyScore) ToProto

func (pgs GamePartyScore) ToProto() *eventspb.GamePartyScore

func (GamePartyScore) ToProtoEdge

func (pgs GamePartyScore) ToProtoEdge(_ ...any) (*v2.GamePartyScoresEdge, error)

type GameTeamScore

type GameTeamScore struct {
	GameID   GameID
	TeamID   TeamID
	EpochID  int64
	Score    decimal.Decimal
	VegaTime time.Time
}

func (GameTeamScore) Cursor

func (pgs GameTeamScore) Cursor() *Cursor

func (GameTeamScore) ToProto

func (pgs GameTeamScore) ToProto() *eventspb.GameTeamScore

func (GameTeamScore) ToProtoEdge

func (pgs GameTeamScore) ToProtoEdge(_ ...any) (*v2.GameTeamScoresEdge, error)

type ID

type ID[T any] string

func (*ID[T]) Bytes

func (id *ID[T]) Bytes() ([]byte, error)

func (*ID[T]) DecodeBinary

func (id *ID[T]) DecodeBinary(ci *pgtype.ConnInfo, src []byte) error

func (ID[T]) EncodeBinary

func (id ID[T]) EncodeBinary(ci *pgtype.ConnInfo, buf []byte) ([]byte, error)

func (*ID[T]) Error

func (id *ID[T]) Error() error

func (*ID[T]) SetBytes

func (id *ID[T]) SetBytes(src []byte) error

func (*ID[T]) String

func (id *ID[T]) String() string

func (*ID[T]) Where

func (id *ID[T]) Where(fieldName *string, nextBindVar func(args *[]any, arg any) string, args ...any) (string, []any)

type IndividualGameEntity

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

func (*IndividualGameEntity) IsGameEntity()

func (*IndividualGameEntity) ToProto

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

func (le LedgerEntry) ToProto(ctx context.Context, accountSource AccountSource) (*vega.LedgerEntry, error)

func (LedgerEntry) ToRow

func (le LedgerEntry) ToRow() []any

type LedgerEntryField

type LedgerEntryField int64

LedgerEntryField is an enumeration of the properties of a ledger entry which can be used for grouping and sorting.

func LedgerEntryFieldFromProto

func LedgerEntryFieldFromProto(field v2.LedgerEntryField) (LedgerEntryField, error)

func (LedgerEntryField) String

func (s LedgerEntryField) String() string

type LedgerEntryFilter

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

func LedgerEntryFilterFromProto(pbFilter *v2.LedgerEntryFilter) (*LedgerEntryFilter, error)

type LedgerMovementType

type LedgerMovementType vega.TransferType

func (*LedgerMovementType) DecodeText

func (l *LedgerMovementType) DecodeText(_ *pgtype.ConnInfo, src []byte) error

func (LedgerMovementType) EncodeText

func (l LedgerMovementType) EncodeText(_ *pgtype.ConnInfo, buf []byte) ([]byte, error)

type LiquidationStrategy

type LiquidationStrategy struct {
	DisposalTimeStep    time.Duration `json:"disposalTimeStep"`
	DisposalFraction    num.Decimal   `json:"disposalFraction"`
	FullDisposalSize    uint64        `json:"fullDisposalSize"`
	MaxFractionConsumed num.Decimal   `json:"maxFractionConsumed"`
	DisposalSlippage    num.Decimal   `json:"disposalSlippageRange"`
}

func LiquidationStrategyFromProto

func LiquidationStrategyFromProto(ls *vega.LiquidationStrategy) LiquidationStrategy

func (LiquidationStrategy) IntoProto

func (l LiquidationStrategy) IntoProto() *vega.LiquidationStrategy

type LiquidityFeeSettings

type LiquidityFeeSettings struct {
	Method      LiquidityFeeSettingsMethod `json:"makerFee,omitempty"`
	FeeConstant *string                    `json:"feeConstant,omitempty"`
}

type LiquidityFeeSettingsMethod

type LiquidityFeeSettingsMethod vega.LiquidityFeeSettings_Method

func (*LiquidityFeeSettingsMethod) DecodeText

func (s *LiquidityFeeSettingsMethod) DecodeText(_ *pgtype.ConnInfo, src []byte) error

func (LiquidityFeeSettingsMethod) EncodeText

func (s LiquidityFeeSettingsMethod) EncodeText(_ *pgtype.ConnInfo, buf []byte) ([]byte, error)

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

func (l LiquidityOrderReference) EncodeBinary(_ *pgtype.ConnInfo, buf []byte) ([]byte, error)

type LiquidityProvider

type LiquidityProvider struct {
	PartyID    PartyID
	MarketID   MarketID
	Ordinality int64
	FeeShare   *vega.LiquidityProviderFeeShare
	SLA        *vega.LiquidityProviderSLA
}

func (LiquidityProvider) Cursor

func (lp LiquidityProvider) Cursor() *Cursor

func (LiquidityProvider) ToProto

func (lp LiquidityProvider) ToProto() *v2.LiquidityProvider

func (LiquidityProvider) ToProtoEdge

func (lp LiquidityProvider) ToProtoEdge(...any) (*v2.LiquidityProviderEdge, error)

type LiquidityProviderCursor

type LiquidityProviderCursor struct {
	MarketID   MarketID `json:"marketId"`
	PartyID    PartyID  `json:"partyId"`
	Ordinality int64    `json:"ordinality"`
}

func (*LiquidityProviderCursor) Parse

func (c *LiquidityProviderCursor) Parse(cursorString string) error

func (LiquidityProviderCursor) String

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

func (s LiquidityProvisionStatus) EncodeText(_ *pgtype.ConnInfo, buf []byte) ([]byte, error)

type LiquiditySLAParameters

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

func LiquiditySLAParametersFromProto(sla *vega.LiquiditySLAParameters) (LiquiditySLAParameters, error)

func (LiquiditySLAParameters) IntoProto

func (lsp LiquiditySLAParameters) IntoProto() *vega.LiquiditySLAParameters

type MarginCursor

type MarginCursor struct {
	VegaTime  time.Time
	AccountID AccountID
}

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 MarginLevelsKey struct {
	AccountID AccountID
	VegaTime  time.Time
}

type MarginMode

type MarginMode vega.MarginMode

func (*MarginMode) DecodeText

func (m *MarginMode) DecodeText(_ *pgtype.ConnInfo, src []byte) error

func (MarginMode) EncodeText

func (m MarginMode) EncodeText(_ *pgtype.ConnInfo, buf []byte) ([]byte, error)

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
	EnableTXReordering     bool
}

func NewMarketFromProto

func NewMarketFromProto(market *vega.Market, txHash TxHash, vegaTime time.Time) (*Market, error)

func (Market) Cursor

func (m Market) Cursor() *Cursor

func (*Market) HasCap

func (m *Market) HasCap() (cap *vega.FutureCap, hasCap bool)

func (Market) ToProto

func (m Market) ToProto() *vega.Market

func (Market) ToProtoEdge

func (m Market) ToProtoEdge(_ ...any) (*v2.MarketEdge, error)

type MarketCursor

type MarketCursor struct {
	VegaTime time.Time `json:"vegaTime"`
	ID       MarketID  `json:"id"`
}

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
	// the equity like share of liquidity fee for each liquidity provider
	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

type MarketDataCursor struct {
	SyntheticTime time.Time `json:"synthetic_time"`
}

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) AddAMMOrder

func (md *MarketDepth) AddAMMOrder(order *types.Order, estimated bool)

func (*MarketDepth) AddOrderUpdate

func (md *MarketDepth) AddOrderUpdate(order *types.Order, estimated bool)

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 MarketID

type MarketID = ID[_Market]

func NewMarketIDSlice

func NewMarketIDSlice(ids ...string) []MarketID

type MarketState

type MarketState vega.Market_State

func (*MarketState) DecodeText

func (s *MarketState) DecodeText(_ *pgtype.ConnInfo, src []byte) error

func (MarketState) EncodeText

func (s MarketState) EncodeText(_ *pgtype.ConnInfo, buf []byte) ([]byte, error)

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

func (m MarketTradingMode) EncodeText(_ *pgtype.ConnInfo, buf []byte) ([]byte, error)

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

type NetworkParameter struct {
	Key      string
	Value    string
	TxHash   TxHash
	VegaTime time.Time
}

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

func NodeFromProto(node *vega.Node, txHash TxHash, vegaTime time.Time) (Node, error)

func (Node) Cursor

func (node Node) Cursor() *Cursor

func (*Node) ToProto

func (node *Node) ToProto() *vega.Node

func (Node) ToProtoEdge

func (node Node) ToProtoEdge(_ ...any) (*v2.NodeEdge, error)

type NodeBasic

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
}

func (NodeBasic) ToProto

func (n NodeBasic) ToProto() *v2.NodeBasic

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 NodeData struct {
	StakedTotal     decimal.Decimal
	TotalNodes      uint32
	InactiveNodes   uint32
	TendermintNodes NodeSet
	ErsatzNodes     NodeSet
	PendingNodes    NodeSet
	Uptime          float64
	VegaTime        time.Time
}

func (*NodeData) ToProto

func (n *NodeData) ToProto() *vega.NodeData

type NodeID

type NodeID = ID[_Node]

type NodeSet

type NodeSet struct {
	Total    uint32
	Inactive uint32
	Promoted []string
	Demoted  []string
	Maximum  uint32
}

func (*NodeSet) ToProto

func (n *NodeSet) ToProto() *vega.NodeSet

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

func (s NodeSignatureKind) EncodeText(_ *pgtype.ConnInfo, buf []byte) ([]byte, error)

type NodeStatus

type NodeStatus vega.NodeStatus

func (*NodeStatus) DecodeText

func (ns *NodeStatus) DecodeText(_ *pgtype.ConnInfo, src []byte) error

func (NodeStatus) EncodeText

func (ns NodeStatus) EncodeText(_ *pgtype.ConnInfo, buf []byte) ([]byte, error)

type Normaliser

type Normaliser struct {
	Name       string
	Expression string
}

type NotaryService

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

func OrderFromProto(po *vega.Order, seqNum uint64, txHash TxHash) (Order, error)

func (Order) Cursor

func (o Order) Cursor() *Cursor

func (Order) Key

func (o Order) Key() OrderKey

func (Order) ToProto

func (o Order) ToProto() *vega.Order

func (Order) ToProtoEdge

func (o Order) ToProtoEdge(_ ...any) (*v2.OrderEdge, error)

func (Order) ToRow

func (o Order) ToRow() []interface{}

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

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 OrderID

type OrderID = ID[_Order]

type OrderKey

type OrderKey struct {
	ID       OrderID
	Version  int32
	VegaTime time.Time
}

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

type PageInfo struct {
	HasNextPage     bool
	HasPreviousPage bool
	StartCursor     string
	EndCursor       string
}

func PageEntities

func PageEntities[T proto.Message, U PagedEntity[T]](items []U, pagination CursorPagination) ([]U, PageInfo)

func (PageInfo) ToProto

func (p PageInfo) ToProto() *v2.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

type PaidLiquidityFeesStats struct {
	MarketID      MarketID
	AssetID       AssetID
	EpochSeq      uint64
	TotalFeesPaid string
	FeesPerParty  []*eventspb.PartyAmount
	VegaTime      time.Time
}

func PaidLiquidityFeesStatsFromProto

func PaidLiquidityFeesStatsFromProto(proto *eventspb.PaidLiquidityFeesStats, vegaTime time.Time) *PaidLiquidityFeesStats

func (PaidLiquidityFeesStats) Cursor

func (s PaidLiquidityFeesStats) Cursor() *Cursor

func (PaidLiquidityFeesStats) ToProto

func (s PaidLiquidityFeesStats) ToProto() *eventspb.PaidLiquidityFeesStats

func (PaidLiquidityFeesStats) ToProtoEdge

func (s PaidLiquidityFeesStats) ToProtoEdge(_ ...any) (*v2.PaidLiquidityFeesEdge, error)

type PaidLiquidityFeesStatsCursor

type PaidLiquidityFeesStatsCursor struct {
	Epoch    uint64
	MarketID string
	AssetID  string
}

func (*PaidLiquidityFeesStatsCursor) Parse

func (c *PaidLiquidityFeesStatsCursor) Parse(cursorString string) error

func (PaidLiquidityFeesStatsCursor) ToString

func (c PaidLiquidityFeesStatsCursor) ToString() string

type Party

type Party struct {
	ID       PartyID
	TxHash   TxHash
	VegaTime *time.Time // Can be NULL for built-in party 'network'
}

func PartyFromProto

func PartyFromProto(pp *vegapb.Party, txHash TxHash) Party

func (Party) Cursor

func (p Party) Cursor() *Cursor

func (*Party) Parse

func (p *Party) Parse(cursorString string) error

func (Party) String

func (p Party) String() string

func (Party) ToProto

func (p Party) ToProto() *vegapb.Party

func (Party) ToProtoEdge

func (p Party) ToProtoEdge(_ ...any) (*v2.PartyEdge, error)

type PartyActivityStreak

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

func NewPartyActivityStreakFromProto(
	ev *eventspb.PartyActivityStreak,
	txHash TxHash,
	t time.Time,
) *PartyActivityStreak

func (PartyActivityStreak) Cursor

func (pas PartyActivityStreak) Cursor() *Cursor

func (*PartyActivityStreak) Fields

func (pas *PartyActivityStreak) Fields() []interface{}

func (*PartyActivityStreak) ToProto

func (pas *PartyActivityStreak) ToProto() *eventspb.PartyActivityStreak

type PartyActivityStreakCursor

type PartyActivityStreakCursor struct {
	Party PartyID `json:"party"`
	Epoch uint64  `json:"epoch"`
}

func (*PartyActivityStreakCursor) Parse

func (c *PartyActivityStreakCursor) Parse(cursorString string) error

func (PartyActivityStreakCursor) String

func (c PartyActivityStreakCursor) String() string

type PartyGameScoreCursor

type PartyGameScoreCursor struct {
	GameID   string    `json:"game_id"`
	PartyID  string    `json:"party_id"`
	EpochID  int64     `json:"epoch_id"`
	VegaTime time.Time `json:"vega_time"`
}

func (*PartyGameScoreCursor) Parse

func (pg *PartyGameScoreCursor) Parse(cursorString string) error

func (PartyGameScoreCursor) String

func (pg PartyGameScoreCursor) String() string

type PartyID

type PartyID = ID[_Party]

func NewPartyIDSlice

func NewPartyIDSlice(ids ...string) []PartyID

type PartyLockedBalance

type PartyLockedBalance struct {
	PartyID    PartyID
	AssetID    AssetID
	AtEpoch    uint64
	UntilEpoch uint64
	Balance    num.Decimal
	VegaTime   time.Time
}

func PartyLockedBalanceFromProto

func PartyLockedBalanceFromProto(
	partyID string,
	atEpoch uint64,
	pvb *eventspb.PartyLockedBalance,
	t time.Time,
) (*PartyLockedBalance, error)

type PartyMarginMode

type PartyMarginMode struct {
	MarketID                   MarketID
	PartyID                    PartyID
	MarginMode                 vega.MarginMode
	MarginFactor               *num.Decimal
	MinTheoreticalMarginFactor *num.Decimal
	MaxTheoreticalLeverage     *num.Decimal
	AtEpoch                    uint64
}

func PartyMarginModeFromProto

func PartyMarginModeFromProto(update *eventspb.PartyMarginModeUpdated) PartyMarginMode

func (PartyMarginMode) Cursor

func (t PartyMarginMode) Cursor() *Cursor

func (PartyMarginMode) ToProto

func (t PartyMarginMode) ToProto() *v2.PartyMarginMode

func (PartyMarginMode) ToProtoEdge

func (t PartyMarginMode) ToProtoEdge(_ ...any) (*v2.PartyMarginModeEdge, error)

type PartyMarginModeCursor

type PartyMarginModeCursor struct {
	MarketID MarketID
	PartyID  PartyID
}

func (*PartyMarginModeCursor) Parse

func (tc *PartyMarginModeCursor) Parse(cursorString string) error

func (PartyMarginModeCursor) String

func (tc PartyMarginModeCursor) String() string

type PartyProfile

type PartyProfile struct {
	PartyID  PartyID
	Alias    string
	Metadata []*vegapb.Metadata
}

func PartyProfileFromProto

func PartyProfileFromProto(t *vegapb.PartyProfile) *PartyProfile

func (PartyProfile) Cursor

func (p PartyProfile) Cursor() *Cursor

func (*PartyProfile) Parse

func (p *PartyProfile) Parse(cursorString string) error

func (PartyProfile) String

func (p PartyProfile) String() string

func (PartyProfile) ToProto

func (p PartyProfile) ToProto() *vegapb.PartyProfile

func (PartyProfile) ToProtoEdge

func (p PartyProfile) ToProtoEdge(_ ...any) (*v2.PartyProfileEdge, error)

type PartyProfileCursor

type PartyProfileCursor struct {
	ID PartyID
}

func (*PartyProfileCursor) Parse

func (tc *PartyProfileCursor) Parse(cursorString string) error

func (PartyProfileCursor) String

func (tc PartyProfileCursor) String() string

type PartyVestingBalance

type PartyVestingBalance struct {
	PartyID  PartyID
	AssetID  AssetID
	AtEpoch  uint64
	Balance  num.Decimal
	VegaTime time.Time
}

func PartyVestingBalanceFromProto

func PartyVestingBalanceFromProto(
	partyID string,
	atEpoch uint64,
	pvb *eventspb.PartyVestingBalance,
	t time.Time,
) (*PartyVestingBalance, error)

type PartyVestingStats

type PartyVestingStats struct {
	RewardBonusMultiplier       num.Decimal
	QuantumBalance              num.Decimal
	SummedRewardBonusMultiplier num.Decimal
	SummedQuantumBalance        num.Decimal
	PartyID                     PartyID
	VegaTime                    time.Time
	AtEpoch                     uint64
}

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

type PerMarketELSWeight struct {
	Market string `json:"market"`
	ELS    string `json:"els"`
}

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 NewEmptyPosition(marketID MarketID, partyID PartyID) Position

func (*Position) ApplyFundingPayment

func (p *Position) ApplyFundingPayment(amount *num.Int)

func (*Position) AverageEntryPriceUint

func (p *Position) AverageEntryPriceUint() *num.Uint

func (Position) Cursor

func (p Position) Cursor() *Cursor

func (Position) Equal

func (p Position) Equal(q Position) bool

func (Position) Key

func (p Position) Key() PositionKey

func (Position) ToProto

func (p Position) ToProto() *vega.Position

func (Position) ToProtoEdge

func (p Position) ToProtoEdge(_ ...any) (*v2.PositionEdge, error)

func (Position) ToRow

func (p Position) ToRow() []interface{}

func (*Position) ToggleDistressedStatus

func (p *Position) ToggleDistressedStatus()

func (*Position) UpdateOrdersClosed

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

func (p *Position) UpdateWithSettleDistressed(e settleDistressed)

func (*Position) UpdateWithSettleMarket

func (p *Position) UpdateWithSettleMarket(e settleMarket)

func (*Position) UpdateWithTrade

func (p *Position) UpdateWithTrade(trade vega.Trade, seller bool, pf num.Decimal)

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 PositionKey

type PositionKey struct {
	MarketID MarketID
	PartyID  PartyID
	VegaTime time.Time
}

type PositionStatus

type PositionStatus int32

func (*PositionStatus) DecodeText

func (p *PositionStatus) DecodeText(_ *pgtype.ConnInfo, src []byte) error

func (PositionStatus) EncodeText

func (p PositionStatus) EncodeText(_ *pgtype.ConnInfo, buf []byte) ([]byte, error)

type PriceLevel

type PriceLevel struct {
	// Price of the price level
	Price *num.Uint
	// How many orders are at this level
	TotalOrders uint64
	// How much volume is at this level
	TotalVolume uint64
	// How much volume from AMM's are at this level
	TotalAMMVolume uint64
	// How much estimated volume from AMM's are at this level
	TotalEstimatedAMMVolume uint64
	// What side of the book is this level
	Side types.Side
}

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

type ProductData struct {
	*vega.ProductData
}

func (ProductData) MarshalJSON

func (p ProductData) MarshalJSON() ([]byte, error)

func (ProductData) ToProto

func (p ProductData) ToProto() *vega.ProductData

func (*ProductData) UnmarshalJSON

func (p *ProductData) UnmarshalJSON(data []byte) error

type Property

type Property struct {
	Name  string
	Value string
}

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 ProposalFromProto

func ProposalFromProto(pp *vega.Proposal, txHash TxHash) (Proposal, error)

func (Proposal) BelongsToBatch

func (p Proposal) BelongsToBatch() bool

func (Proposal) Cursor

func (p Proposal) Cursor() *Cursor

func (Proposal) IsBatch

func (p Proposal) IsBatch() bool

func (Proposal) ToProto

func (p Proposal) ToProto() *vega.Proposal

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

func (s ProposalError) EncodeText(_ *pgtype.ConnInfo, buf []byte) ([]byte, error)

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

func (s ProposalState) EncodeText(_ *pgtype.ConnInfo, buf []byte) ([]byte, error)

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

func (p *ProposalType) String() string

type ProtoEntity

type ProtoEntity[T proto.Message] interface {
	Entities | Account | NodeBasic
	ToProto() T
}

type ProtoEnum

type ProtoEnum interface {
	GetEnums() map[int32]string
}

type ProtocolUpgradeProposal

type ProtocolUpgradeProposal struct {
	UpgradeBlockHeight uint64
	VegaReleaseTag     string
	Approvers          []string
	Status             ProtocolUpgradeProposalStatus
	TxHash             TxHash
	VegaTime           time.Time
}

func ProtocolUpgradeProposalFromProto

func ProtocolUpgradeProposalFromProto(p *eventspb.ProtocolUpgradeEvent, txHash TxHash, vegaTime time.Time) ProtocolUpgradeProposal

func (ProtocolUpgradeProposal) Cursor

func (p ProtocolUpgradeProposal) Cursor() *Cursor

func (ProtocolUpgradeProposal) ToProto

func (p ProtocolUpgradeProposal) ToProto() *eventspb.ProtocolUpgradeEvent

func (ProtocolUpgradeProposal) ToProtoEdge

func (p ProtocolUpgradeProposal) ToProtoEdge(_ ...any) (*v2.ProtocolUpgradeProposalEdge, error)

type ProtocolUpgradeProposalCursor

type ProtocolUpgradeProposalCursor struct {
	VegaTime           time.Time
	UpgradeBlockHeight uint64
	VegaReleaseTag     string
}

func (*ProtocolUpgradeProposalCursor) Parse

func (pc *ProtocolUpgradeProposalCursor) Parse(cursorString string) error

func (ProtocolUpgradeProposalCursor) String

func (pc ProtocolUpgradeProposalCursor) String() string

type ProtocolUpgradeProposalStatus

type ProtocolUpgradeProposalStatus eventspb.ProtocolUpgradeProposalStatus

func (*ProtocolUpgradeProposalStatus) DecodeText

func (ps *ProtocolUpgradeProposalStatus) DecodeText(_ *pgtype.ConnInfo, src []byte) error

func (ProtocolUpgradeProposalStatus) EncodeText

func (ps ProtocolUpgradeProposalStatus) EncodeText(_ *pgtype.ConnInfo, buf []byte) ([]byte, error)

type QuantumRewardsPerEpoch

type QuantumRewardsPerEpoch struct {
	Epoch uint64
	Total num.Decimal
}

type QuantumVolumesPerEpoch

type QuantumVolumesPerEpoch struct {
	Epoch uint64
	Total *num.Uint
}

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 RankingScoreAux struct {
	NodeID   NodeID
	EpochSeq uint64
}

type RefereeCursor

type RefereeCursor struct {
	PartyID PartyID
}

func (*RefereeCursor) Parse

func (rc *RefereeCursor) Parse(cursorString string) error

func (RefereeCursor) String

func (rc RefereeCursor) String() string

type RefereeHistoryCursor

type RefereeHistoryCursor struct {
	JoinedAtEpoch uint64
}

func (*RefereeHistoryCursor) Parse

func (rh *RefereeHistoryCursor) Parse(cursorString string) error

func (RefereeHistoryCursor) String

func (rh RefereeHistoryCursor) String() string

type RefereeTeamSwitch

type RefereeTeamSwitch struct {
	FromTeamID      TeamID
	ToTeamID        TeamID
	PartyID         PartyID
	SwitchedAt      time.Time
	SwitchedAtEpoch uint64
	VegaTime        time.Time
}

func TeamRefereeHistoryFromProto

func TeamRefereeHistoryFromProto(switched *eventspb.RefereeSwitchedTeam, vegaTime time.Time) *RefereeTeamSwitch

type ReferralProgram

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

func ReferralProgramFromProto(proto *vega.ReferralProgram, vegaTime time.Time, seqNum uint64) *ReferralProgram

func (ReferralProgram) ToProto

func (rp ReferralProgram) ToProto() *v2.ReferralProgram

type ReferralProgramID

type ReferralProgramID = ID[_ReferralProgram]

type ReferralSet

type ReferralSet struct {
	ID           ReferralSetID
	Referrer     PartyID
	TotalMembers uint64
	CreatedAt    time.Time
	UpdatedAt    time.Time
	VegaTime     time.Time
}

func ReferralSetFromProto

func ReferralSetFromProto(proto *eventspb.ReferralSetCreated, vegaTime time.Time) *ReferralSet

func (ReferralSet) Cursor

func (rs ReferralSet) Cursor() *Cursor

func (ReferralSet) ToProto

func (rs ReferralSet) ToProto() *v2.ReferralSet

func (ReferralSet) ToProtoEdge

func (rs ReferralSet) ToProtoEdge(_ ...any) (*v2.ReferralSetEdge, error)

type ReferralSetCursor

type ReferralSetCursor struct {
	CreatedAt time.Time
	ID        ReferralSetID
}

func (*ReferralSetCursor) Parse

func (c *ReferralSetCursor) Parse(cursorString string) error

func (ReferralSetCursor) ToString

func (c ReferralSetCursor) ToString() string

type ReferralSetID

type ReferralSetID = ID[_ReferralSet]

type ReferralSetReferee

type ReferralSetReferee struct {
	ReferralSetID ReferralSetID
	Referee       PartyID
	JoinedAt      time.Time
	AtEpoch       uint64
	VegaTime      time.Time
}

func ReferralSetRefereeFromProto

func ReferralSetRefereeFromProto(proto *eventspb.RefereeJoinedReferralSet, vegaTime time.Time) *ReferralSetReferee

func (ReferralSetReferee) Cursor

func (r ReferralSetReferee) Cursor() *Cursor

func (ReferralSetReferee) ToProto

func (r ReferralSetReferee) ToProto() *v2.ReferralSetReferee

func (ReferralSetReferee) ToProtoEdge

func (r ReferralSetReferee) ToProtoEdge(_ ...any) (*v2.ReferralSetRefereeEdge, error)

type ReferralSetRefereeCursor

type ReferralSetRefereeCursor struct {
	JoinedAt time.Time
	Referee  PartyID
}

func (*ReferralSetRefereeCursor) Parse

func (c *ReferralSetRefereeCursor) Parse(cursorString string) error

func (ReferralSetRefereeCursor) ToString

func (c ReferralSetRefereeCursor) ToString() string

type ReferralSetRefereeStats

type ReferralSetRefereeStats struct {
	ReferralSetReferee
	PeriodVolume      num.Decimal
	PeriodRewardsPaid num.Decimal
}

func (ReferralSetRefereeStats) ToProto

func (r ReferralSetRefereeStats) ToProto() *v2.ReferralSetReferee

func (ReferralSetRefereeStats) ToProtoEdge

func (r ReferralSetRefereeStats) ToProtoEdge(_ ...any) (*v2.ReferralSetRefereeEdge, error)

type ReferralSetStats

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

func ReferralSetStatsFromProto(proto *eventspb.ReferralSetStatsUpdated, vegaTime time.Time) (*ReferralSetStats, error)

type ReferralSetStatsCursor

type ReferralSetStatsCursor struct {
	VegaTime time.Time
	AtEpoch  uint64
	SetID    string
	PartyID  string
}

func (*ReferralSetStatsCursor) Parse

func (c *ReferralSetStatsCursor) Parse(cursorString string) error

func (ReferralSetStatsCursor) ToString

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 RewardFromProto(pr eventspb.RewardPayoutEvent, txHash TxHash, vegaTime time.Time, seqNum uint64) (Reward, error)

func (Reward) Cursor

func (r Reward) Cursor() *Cursor

func (Reward) String

func (r Reward) String() string

func (Reward) ToProto

func (r Reward) ToProto() *vega.Reward

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 RewardScoreAux struct {
	NodeID   NodeID
	EpochSeq uint64
}

type RewardSummary

type RewardSummary struct {
	PartyID PartyID
	AssetID AssetID
	Amount  decimal.Decimal
}

func (*RewardSummary) ToProto

func (r *RewardSummary) ToProto() *vega.RewardSummary

type RewardSummaryFilter

type RewardSummaryFilter struct {
	AssetIDs  []AssetID
	MarketIDs []MarketID
	FromEpoch *uint64
	ToEpoch   *uint64
}

RewardSummaryFilter is the filter for the reward summary.

func RewardSummaryFilterFromProto

func RewardSummaryFilterFromProto(pb *v2.RewardSummaryFilter) (filter RewardSummaryFilter)

RewardSummaryFilterFromProto converts a protobuf v2.RewardSummaryFilter to an entities.RewardSummaryFilter.

type RewardTotals

type RewardTotals struct {
	GameID              GameID
	PartyID             PartyID
	AssetID             AssetID
	MarketID            MarketID
	EpochID             int64
	TeamID              TeamID
	TotalRewards        decimal.Decimal
	TotalRewardsQuantum decimal.Decimal
}

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

type Side = vega.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 Signer

type Signer []byte

type Signers

type Signers = []Signer

func SerializeSigners

func SerializeSigners(signers []*dstypes.Signer) (Signers, error)

type SpecID

type SpecID = ID[_Spec]

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

func (s StakeLinkingStatus) EncodeText(_ *pgtype.ConnInfo, buf []byte) ([]byte, error)

type StakeLinkingType

type StakeLinkingType eventspb.StakeLinking_Type

func (*StakeLinkingType) DecodeText

func (s *StakeLinkingType) DecodeText(_ *pgtype.ConnInfo, src []byte) error

func (StakeLinkingType) EncodeText

func (s StakeLinkingType) EncodeText(_ *pgtype.ConnInfo, buf []byte) ([]byte, error)

type StopOrder

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

func StopOrderFromProto(so *pbevents.StopOrderEvent, vegaTime time.Time, seqNum uint64, txHash TxHash) (StopOrder, error)

func (StopOrder) Cursor

func (s StopOrder) Cursor() *Cursor

func (StopOrder) Key

func (s StopOrder) Key() StopOrderKey

func (StopOrder) ToProto

func (o StopOrder) ToProto() *pbevents.StopOrderEvent

func (StopOrder) ToProtoEdge

func (s StopOrder) ToProtoEdge(_ ...any) (*v2.StopOrderEdge, error)

func (StopOrder) ToRow

func (so StopOrder) ToRow() []interface{}

type StopOrderCursor

type StopOrderCursor struct {
	CreatedAt time.Time   `json:"createdAt"`
	ID        StopOrderID `json:"id"`
	VegaTime  time.Time   `json:"vegaTime"`
}

func (*StopOrderCursor) Parse

func (c *StopOrderCursor) Parse(cursorString string) error

func (*StopOrderCursor) String

func (c *StopOrderCursor) String() string

type StopOrderExpiryStrategy

type StopOrderExpiryStrategy vega.StopOrder_ExpiryStrategy

func (*StopOrderExpiryStrategy) DecodeText

func (s *StopOrderExpiryStrategy) DecodeText(_ *pgtype.ConnInfo, src []byte) error

func (StopOrderExpiryStrategy) EncodeText

func (s StopOrderExpiryStrategy) EncodeText(_ *pgtype.ConnInfo, buf []byte) ([]byte, error)

type StopOrderFilter

type StopOrderFilter struct {
	Statuses       []StopOrderStatus
	ExpiryStrategy []StopOrderExpiryStrategy
	DateRange      *DateRange
	PartyIDs       []string
	MarketIDs      []string
	LiveOnly       bool
}

type StopOrderID

type StopOrderID = ID[_StopOrder]

type StopOrderKey

type StopOrderKey struct {
	ID        StopOrderID
	UpdatedAt time.Time
	VegaTime  time.Time
}

type StopOrderRejectionReason

type StopOrderRejectionReason vega.StopOrder_RejectionReason

func (*StopOrderRejectionReason) DecodeText

func (s *StopOrderRejectionReason) DecodeText(_ *pgtype.ConnInfo, src []byte) error

func (StopOrderRejectionReason) EncodeText

func (s StopOrderRejectionReason) EncodeText(_ *pgtype.ConnInfo, buf []byte) ([]byte, error)

type StopOrderStatus

type StopOrderStatus vega.StopOrder_Status

func (*StopOrderStatus) DecodeText

func (s *StopOrderStatus) DecodeText(_ *pgtype.ConnInfo, src []byte) error

func (StopOrderStatus) EncodeText

func (s StopOrderStatus) EncodeText(_ *pgtype.ConnInfo, buf []byte) ([]byte, error)

type StopOrderTriggerDirection

type StopOrderTriggerDirection vega.StopOrder_TriggerDirection

func (*StopOrderTriggerDirection) DecodeText

func (s *StopOrderTriggerDirection) DecodeText(_ *pgtype.ConnInfo, src []byte) error

func (StopOrderTriggerDirection) EncodeText

func (s StopOrderTriggerDirection) EncodeText(_ *pgtype.ConnInfo, buf []byte) ([]byte, error)

type SuccessorMarket

type SuccessorMarket struct {
	Market    Market
	Proposals []*Proposal
}

func (SuccessorMarket) Cursor

func (s SuccessorMarket) Cursor() *Cursor

func (SuccessorMarket) ToProtoEdge

func (s SuccessorMarket) ToProtoEdge(...any) (*v2.SuccessorMarketEdge, error)

type SuccessorMarketCursor

type SuccessorMarketCursor struct {
	VegaTime time.Time `json:"vegaTime"`
}

func (*SuccessorMarketCursor) Parse

func (mc *SuccessorMarketCursor) Parse(cursorString string) error

func (SuccessorMarketCursor) String

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

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

func TeamCreatedFromProto(created *eventspb.TeamCreated, vegaTime time.Time) *Team

func (Team) Cursor

func (t Team) Cursor() *Cursor

func (Team) ToProto

func (t Team) ToProto() *v2.Team

func (Team) ToProtoEdge

func (t Team) ToProtoEdge(_ ...any) (*v2.TeamEdge, error)

type TeamCursor

type TeamCursor struct {
	CreatedAt time.Time
	ID        TeamID
}

func (*TeamCursor) Parse

func (tc *TeamCursor) Parse(cursorString string) error

func (TeamCursor) String

func (tc TeamCursor) String() string

type TeamGameEntity

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

func (*TeamGameEntity) IsGameEntity()

func (*TeamGameEntity) ToProto

func (t *TeamGameEntity) ToProto() *v2.TeamGameEntity

type TeamGameParticipation

type TeamGameParticipation struct {
	TeamID               TeamID
	MembersParticipating []*IndividualGameEntity
}

func (TeamGameParticipation) ToProto

func (t TeamGameParticipation) ToProto() *v2.TeamGameParticipation

type TeamGameScoreCursor

type TeamGameScoreCursor struct {
	GameID   string    `json:"game_id"`
	TeamID   string    `json:"team_id"`
	EpochID  int64     `json:"epoch_id"`
	VegaTime time.Time `json:"vega_time"`
}

func (*TeamGameScoreCursor) Parse

func (pg *TeamGameScoreCursor) Parse(cursorString string) error

func (TeamGameScoreCursor) String

func (pg TeamGameScoreCursor) String() string

type TeamID

type TeamID = ID[_Team]

type TeamMember

type TeamMember struct {
	TeamID        TeamID
	PartyID       PartyID
	JoinedAt      time.Time
	JoinedAtEpoch uint64
	VegaTime      time.Time
}

func TeamRefereeFromProto

func TeamRefereeFromProto(joined *eventspb.RefereeJoinedTeam, vegaTime time.Time) *TeamMember

func (TeamMember) Cursor

func (t TeamMember) Cursor() *Cursor

func (TeamMember) ToProto

func (t TeamMember) ToProto() *v2.TeamReferee

func (TeamMember) ToProtoEdge

func (t TeamMember) ToProtoEdge(_ ...any) (*v2.TeamRefereeEdge, error)

type TeamMemberHistory

type TeamMemberHistory struct {
	TeamID        TeamID
	JoinedAt      time.Time
	JoinedAtEpoch uint64
}

func (TeamMemberHistory) Cursor

func (t TeamMemberHistory) Cursor() *Cursor

func (TeamMemberHistory) ToProto

func (t TeamMemberHistory) ToProto() *v2.TeamRefereeHistory

func (TeamMemberHistory) ToProtoEdge

func (t TeamMemberHistory) ToProtoEdge(_ ...any) (*v2.TeamRefereeHistoryEdge, error)

type TeamMemberStatisticsCursor

type TeamMemberStatisticsCursor struct {
	ID PartyID
}

func (*TeamMemberStatisticsCursor) Parse

func (c *TeamMemberStatisticsCursor) Parse(cursorString string) error

func (TeamMemberStatisticsCursor) String

func (c TeamMemberStatisticsCursor) String() string

type TeamMembersStatistics

type TeamMembersStatistics struct {
	PartyID             PartyID
	TotalQuantumVolumes *num.Uint
	TotalQuantumRewards num.Decimal
	QuantumRewards      []QuantumRewardsPerEpoch
	QuantumVolumes      []QuantumVolumesPerEpoch
	TotalGamesPlayed    uint64
	GamesPlayed         []GameID
}

func (TeamMembersStatistics) Cursor

func (t TeamMembersStatistics) Cursor() *Cursor

func (TeamMembersStatistics) ToProto

func (t TeamMembersStatistics) ToProto() *v2.TeamMemberStatistics

func (TeamMembersStatistics) ToProtoEdge

func (t TeamMembersStatistics) ToProtoEdge(_ ...any) (*v2.TeamMemberStatisticsEdge, error)

type TeamUpdated

type TeamUpdated struct {
	ID        TeamID
	Name      string
	TeamURL   *string
	AvatarURL *string
	Closed    bool
	AllowList []string
	VegaTime  time.Time
}

func TeamUpdatedFromProto

func TeamUpdatedFromProto(updated *eventspb.TeamUpdated, vegaTime time.Time) *TeamUpdated

type TeamsStatistics

type TeamsStatistics struct {
	TeamID              TeamID
	TotalQuantumRewards num.Decimal
	QuantumRewards      []QuantumRewardsPerEpoch
	TotalQuantumVolumes *num.Uint
	QuantumVolumes      []QuantumVolumesPerEpoch
	TotalGamesPlayed    uint64
	GamesPlayed         []GameID
}

func (TeamsStatistics) Cursor

func (t TeamsStatistics) Cursor() *Cursor

func (TeamsStatistics) ToProto

func (t TeamsStatistics) ToProto() *v2.TeamStatistics

func (TeamsStatistics) ToProtoEdge

func (t TeamsStatistics) ToProtoEdge(_ ...any) (*v2.TeamStatisticsEdge, error)

type TeamsStatisticsCursor

type TeamsStatisticsCursor struct {
	ID TeamID
}

func (*TeamsStatisticsCursor) Parse

func (c *TeamsStatisticsCursor) Parse(cursorString string) error

func (TeamsStatisticsCursor) String

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 (pk TendermintPublicKey) EncodeBinary(ci *pgtype.ConnInfo, buf []byte) ([]byte, error)

func (*TendermintPublicKey) Error

func (pk *TendermintPublicKey) Error() error

func (*TendermintPublicKey) String

func (pk *TendermintPublicKey) String() string

type TimeUpdateEvent

type TimeUpdateEvent interface {
	events.Event
	Time() time.Time
}

type TimeWeightedNotionalPosition

type TimeWeightedNotionalPosition struct {
	EpochSeq                     uint64
	AssetID                      AssetID
	PartyID                      PartyID
	GameID                       GameID
	TimeWeightedNotionalPosition num.Decimal
	VegaTime                     time.Time
}

func TimeWeightedNotionalPositionFromProto

func TimeWeightedNotionalPositionFromProto(event *eventspb.TimeWeightedNotionalPositionUpdated, vegaTime time.Time) (*TimeWeightedNotionalPosition, error)

func (*TimeWeightedNotionalPosition) ToProto

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

func TradeFromProto(t *vega.Trade, txHash TxHash, vegaTime time.Time, sequenceNumber uint64) (*Trade, error)

func (Trade) Cursor

func (t Trade) Cursor() *Cursor

func (Trade) ToProto

func (t Trade) ToProto() *vega.Trade

func (Trade) ToProtoEdge

func (t Trade) ToProtoEdge(_ ...any) (*v2.TradeEdge, error)

type TradeCursor

type TradeCursor struct {
	SyntheticTime time.Time `json:"synthetic_time"`
}

func (*TradeCursor) Parse

func (c *TradeCursor) Parse(cursorString string) error

func (TradeCursor) String

func (c TradeCursor) String() string

type TradeID

type TradeID = ID[_Trade]

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 TransferFromProto(ctx context.Context, t *eventspb.Transfer, txHash TxHash, vegaTime time.Time, accountSource AccountSource) (*Transfer, error)

func (Transfer) Cursor

func (t Transfer) Cursor() *Cursor

func (*Transfer) ToProto

func (t *Transfer) ToProto(ctx context.Context, accountSource AccountSource) (*eventspb.Transfer, error)

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

type TransferDetails struct {
	Transfer
	Fees []*TransferFees
}

func (TransferDetails) ToProtoEdge

func (d TransferDetails) ToProtoEdge(input ...any) (*v2.TransferEdge, error)

type TransferFees

type TransferFees struct {
	TransferID      TransferID
	EpochSeq        uint64
	Amount          decimal.Decimal
	DiscountApplied decimal.Decimal
	VegaTime        time.Time
}

func TransferFeesFromProto

func TransferFeesFromProto(f *eventspb.TransferFees, vegaTime time.Time) *TransferFees

func (*TransferFees) ToProto

func (f *TransferFees) ToProto() *eventspb.TransferFees

type TransferFeesDiscount

type TransferFeesDiscount struct {
	PartyID  PartyID
	AssetID  AssetID
	Amount   decimal.Decimal
	EpochSeq uint64
	VegaTime time.Time
}

func TransferFeesDiscountFromProto

func TransferFeesDiscountFromProto(f *eventspb.TransferFeesDiscount, vegaTime time.Time) *TransferFeesDiscount

func (*TransferFeesDiscount) ToProto

func (f *TransferFeesDiscount) ToProto() *eventspb.TransferFeesDiscount

type TransferID

type TransferID = ID[_Transfer]

type TransferScope

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

func (m TransferStatus) EncodeText(_ *pgtype.ConnInfo, buf []byte) ([]byte, error)

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

func (m TransferType) EncodeText(_ *pgtype.ConnInfo, buf []byte) ([]byte, error)

type TxHash

type TxHash string

func (*TxHash) Bytes

func (h *TxHash) Bytes() ([]byte, error)

func (*TxHash) DecodeBinary

func (h *TxHash) DecodeBinary(ci *pgtype.ConnInfo, src []byte) error

func (TxHash) EncodeBinary

func (h TxHash) EncodeBinary(ci *pgtype.ConnInfo, buf []byte) ([]byte, error)

func (*TxHash) Error

func (h *TxHash) Error() error

func (*TxHash) String

func (h *TxHash) String() string

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 (ns ValidatorNodeStatus) EncodeText(_ *pgtype.ConnInfo, buf []byte) ([]byte, error)

func (*ValidatorNodeStatus) UnmarshalJSON

func (ns *ValidatorNodeStatus) UnmarshalJSON(src []byte) error

type ValidatorUpdateAux

type ValidatorUpdateAux struct {
	Added           bool
	EpochSeq        uint64
	VegaPubKeyIndex uint32
	TxHash          TxHash
}

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 (pk VegaPublicKey) EncodeBinary(ci *pgtype.ConnInfo, buf []byte) ([]byte, error)

func (*VegaPublicKey) Error

func (pk *VegaPublicKey) Error() error

func (*VegaPublicKey) String

func (pk *VegaPublicKey) String() string

type VestingStatsUpdated

type VestingStatsUpdated struct {
	AtEpoch           uint64
	PartyVestingStats []*PartyVestingStats
	VegaTime          time.Time
}

func NewVestingStatsFromProto

func NewVestingStatsFromProto(vestingStatsProto *eventspb.VestingStatsUpdated, vegaTime time.Time) (*VestingStatsUpdated, error)

type VolumeDiscountProgram

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

func VolumeDiscountProgramFromProto(proto *vega.VolumeDiscountProgram, vegaTime time.Time, seqNum uint64) *VolumeDiscountProgram

func (VolumeDiscountProgram) ToProto

func (rp VolumeDiscountProgram) ToProto() *v2.VolumeDiscountProgram

type VolumeDiscountProgramID

type VolumeDiscountProgramID = ID[_VolumeDiscountProgram]

type VolumeDiscountStats

type VolumeDiscountStats struct {
	AtEpoch                    uint64
	PartiesVolumeDiscountStats []*eventspb.PartyVolumeDiscountStats
	VegaTime                   time.Time
}

func NewVolumeDiscountStatsFromProto

func NewVolumeDiscountStatsFromProto(vestingStatsProto *eventspb.VolumeDiscountStatsUpdated, vegaTime time.Time) (*VolumeDiscountStats, error)

type VolumeDiscountStatsCursor

type VolumeDiscountStatsCursor struct {
	VegaTime time.Time
	AtEpoch  uint64
	PartyID  string
}

func (*VolumeDiscountStatsCursor) Parse

func (c *VolumeDiscountStatsCursor) Parse(cursorString string) error

func (*VolumeDiscountStatsCursor) ToString

func (c *VolumeDiscountStatsCursor) ToString() string

type Vote

type Vote struct {
	PartyID                        PartyID
	ProposalID                     ProposalID
	Value                          VoteValue
	TotalGovernanceTokenBalance    decimal.Decimal
	TotalGovernanceTokenWeight     decimal.Decimal
	TotalEquityLikeShareWeight     decimal.Decimal
	PerMarketEquityLikeShareWeight []PerMarketELSWeight
	InitialTime                    time.Time // First vote for this party/proposal
	TxHash                         TxHash
	VegaTime                       time.Time // Time of last vote update
}

func VoteFromProto

func VoteFromProto(pv *vega.Vote, txHash TxHash) (Vote, error)

func (Vote) Cursor

func (v Vote) Cursor() *Cursor

func (Vote) ToProto

func (v Vote) ToProto() *vega.Vote

func (Vote) ToProtoEdge

func (v Vote) ToProtoEdge(_ ...any) (*v2.VoteEdge, error)

type VoteCursor

type VoteCursor struct {
	PartyID  PartyID   `json:"party_id"`
	VegaTime time.Time `json:"vega_time"`
}

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

func (*VoteValue) DecodeText

func (s *VoteValue) DecodeText(_ *pgtype.ConnInfo, src []byte) error

func (VoteValue) EncodeText

func (s VoteValue) EncodeText(_ *pgtype.ConnInfo, buf []byte) ([]byte, error)

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

func (s WithdrawalStatus) EncodeText(_ *pgtype.ConnInfo, buf []byte) ([]byte, error)