sqlsubscribers

Oct 22, 2024

Changes in this version

type FundingPaymentsStore

+ GetByPartyAndMarket func(ctx context.Context, partyID, marketID string) (entities.FundingPayment, error)

+ type LossSocEvt interface

+ Amount func() *num.Int

+ IsFunding func() bool

+ MarketID func() string

+ Negative func() bool

+ PartyID func() string

Aug 14, 2024

Changes in this version

+ type VolumeRebateProgram struct

+ func NewVolumeRebateProgram(store VolumeRebateStore) *VolumeRebateProgram

+ func (rp *VolumeRebateProgram) Name() string

+ func (rp *VolumeRebateProgram) Push(ctx context.Context, evt events.Event) error

+ func (rp *VolumeRebateProgram) Types() []events.Type

+ func (s *VolumeRebateProgram) Flush(ctx context.Context) error

+ func (s *VolumeRebateProgram) SetVegaTime(vegaTime time.Time)

+ type VolumeRebateProgramEndedEvent interface

+ GetVolumeRebateProgramEnded func() *eventspb.VolumeRebateProgramEnded

+ type VolumeRebateProgramStartedEvent interface

+ GetVolumeRebateProgramStarted func() *eventspb.VolumeRebateProgramStarted

+ type VolumeRebateProgramUpdatedEvent interface

+ GetVolumeRebateProgramUpdated func() *eventspb.VolumeRebateProgramUpdated

+ type VolumeRebateStatsUpdated struct

+ func NewVolumeRebateStatsUpdated(store VolumeRebateStatsUpdatedStore) *VolumeRebateStatsUpdated

+ func (pas *VolumeRebateStatsUpdated) Name() string

+ func (pas *VolumeRebateStatsUpdated) Push(ctx context.Context, evt events.Event) error

+ func (pas *VolumeRebateStatsUpdated) Types() []events.Type

+ func (s *VolumeRebateStatsUpdated) Flush(ctx context.Context) error

+ func (s *VolumeRebateStatsUpdated) SetVegaTime(vegaTime time.Time)

+ type VolumeRebateStatsUpdatedEvent interface

+ VolumeRebateStatsUpdated func() *eventspb.VolumeRebateStatsUpdated

+ type VolumeRebateStatsUpdatedStore interface

+ Add func(context.Context, *entities.VolumeRebateStats) error

+ type VolumeRebateStore interface

+ AddVolumeRebateProgram func(ctx context.Context, referral *entities.VolumeRebateProgram) error

+ EndVolumeRebateProgram func(ctx context.Context, version uint64, endedAt time.Time, vegaTime time.Time, ...) error

+ UpdateVolumeRebateProgram func(ctx context.Context, referral *entities.VolumeRebateProgram) error

Jul 16, 2024

Changes in this version

+ type AMMPoolEvent interface

+ AMMPool func() *eventspb.AMM

+ type AMMPoolStore interface

+ Upsert func(ctx context.Context, pool entities.AMMPool) error

+ type AMMPools struct

+ func NewAMMPools(store AMMPoolStore, marketDepth MarketDepthService) *AMMPools

+ func (p *AMMPools) Name() string

+ func (p *AMMPools) Push(ctx context.Context, evt events.Event) error

+ func (p *AMMPools) Types() []events.Type

+ func (s *AMMPools) Flush(ctx context.Context) error

+ func (s *AMMPools) SetVegaTime(vegaTime time.Time)

type Account

+ func (as *Account) Name() string

type Asset

+ func (a *Asset) Name() string

type Checkpoint

+ func (n *Checkpoint) Name() string

type Delegation

+ func (ds *Delegation) Name() string

type Deposit

+ func (d *Deposit) Name() string

type ERC20MultiSigSignerEvent

+ func (m *ERC20MultiSigSignerEvent) Name() string

type Epoch

+ func (es *Epoch) Name() string

type EthereumKeyRotation

+ func (kr *EthereumKeyRotation) Name() string

type FeesStats

+ func (r *FeesStats) Name() string

type FundingPaymentSubscriber

+ func (ts *FundingPaymentSubscriber) Name() string

type FundingPeriod

+ func (fp *FundingPeriod) Name() string

+ type GameScore struct

+ func NewGameScore(store GameScoreStore) *GameScore

+ func (gs *GameScore) Name() string

+ func (gs *GameScore) Push(ctx context.Context, evt events.Event) error

+ func (gs *GameScore) Types() []events.Type

+ func (s *GameScore) Flush(ctx context.Context) error

+ func (s *GameScore) SetVegaTime(vegaTime time.Time)

+ type GameScoreEvent interface

+ GameScoreEvent func() eventspb.GameScores

+ type GameScoreStore interface

+ AddPartyScore func(context.Context, entities.GamePartyScore) error

+ AddTeamScore func(context.Context, entities.GameTeamScore) error

type KeyRotation

+ func (kr *KeyRotation) Name() string

type LiquidityProvision

+ func (lp *LiquidityProvision) Name() string

type MarginLevels

+ func (ml *MarginLevels) Name() string

type MarginModes

+ func (t *MarginModes) Name() string

type MarketCreated

+ func (m *MarketCreated) Name() string

type MarketData

+ func (md *MarketData) Name() string

type MarketDepthService

+ OnAMMUpdate func(pool entities.AMMPool, vt time.Time, seqNum uint64)

type MarketUpdated

+ func (m *MarketUpdated) Name() string

type NetworkLimits

+ func (nl *NetworkLimits) Name() string

type NetworkParameter

+ func (n *NetworkParameter) Name() string

type Node

+ func (n *Node) Name() string

type Notary

+ func (n *Notary) Name() string

type OracleData

+ func (od *OracleData) Name() string

type OracleSpec

+ func (od *OracleSpec) Name() string

type Order

+ func (os *Order) Name() string

type PaidLiquidityFeesStats

+ func (r *PaidLiquidityFeesStats) Name() string

type Party

+ func (ps *Party) Name() string

type PartyActivityStreak

+ func (pas *PartyActivityStreak) Name() string

type Position

+ func (p *Position) Name() string

type Proposal

+ func (ps *Proposal) Name() string

type ProtocolUpgrade

+ func (ps *ProtocolUpgrade) Name() string

type ReferralProgram

+ func (rp *ReferralProgram) Name() string

type ReferralSets

+ func (rs *ReferralSets) Name() string

type Reward

+ func (rs *Reward) Name() string

type RiskFactor

+ func (rf *RiskFactor) Name() string

type SnapshotData

+ func (s *SnapshotData) Name() string

type StakeLinking

+ func (sl *StakeLinking) Name() string

type StopOrder

+ func (so *StopOrder) Name() string

type Teams

+ func (t *Teams) Name() string

type TimeWeightedNotionalPosition

+ func (tw *TimeWeightedNotionalPosition) Name() string

type TradeSubscriber

+ func (ts *TradeSubscriber) Name() string

type TransactionResults

+ func (tr *TransactionResults) Name() string

type Transfer

+ func (rf *Transfer) Name() string

type TransferResponse

+ func (t *TransferResponse) Name() string

type VestingBalancesSummary

+ func (v *VestingBalancesSummary) Name() string

type VestingStatsUpdated

+ func (pas *VestingStatsUpdated) Name() string

type VolumeDiscountProgram

+ func (rp *VolumeDiscountProgram) Name() string

type VolumeDiscountStatsUpdated

+ func (pas *VolumeDiscountStatsUpdated) Name() string

type Vote

+ func (vs *Vote) Name() string

type Withdrawal

+ func (w *Withdrawal) Name() string

May 3, 2024

Changes in this version

+ type CancelledOrdersEvent interface

+ PartyID func() string

type MarketSvc

+ IsSpotMarket func(ctx context.Context, marketID string) bool

Mar 19, 2024

Changes in this version

+ type TimeWeightedNotionalPosition struct

+ func NewTimeWeightedNotionalPosition(store TimeWeightedNotionalPositionStore) *TimeWeightedNotionalPosition

+ func (s *TimeWeightedNotionalPosition) Flush(ctx context.Context) error

+ func (s *TimeWeightedNotionalPosition) SetVegaTime(vegaTime time.Time)

+ func (tw *TimeWeightedNotionalPosition) Push(ctx context.Context, e events.Event) error

+ func (tw *TimeWeightedNotionalPosition) Types() []events.Type

+ type TimeWeightedNotionalPositionStore interface

+ Upsert func(ctx context.Context, twNotionalPos entities.TimeWeightedNotionalPosition) error

+ type TimeWeightedNotionalPositionUpdatedEvent interface

+ TimeWeightedNotionalPositionUpdated func() *eventspb.TimeWeightedNotionalPositionUpdated

Feb 9, 2024

Changes in this version

+ type LedgerMovementEvents interface

+ LedgerMovements func() []*vega.LedgerMovement

+ type MarginModeStore interface

+ UpdatePartyMarginMode func(ctx context.Context, update entities.PartyMarginMode) error

+ type MarginModes struct

+ func NewMarginModes(store MarginModeStore) *MarginModes

+ func (s *MarginModes) Flush(ctx context.Context) error

+ func (s *MarginModes) SetVegaTime(vegaTime time.Time)

+ func (t *MarginModes) Push(ctx context.Context, evt events.Event) error

+ func (t *MarginModes) Types() []events.Type

+ type PartyMarginModeUpdatedEvent interface

+ PartyMarginModeUpdated func() *eventspb.PartyMarginModeUpdated

+ type PartyProfileUpdatedEvent interface

+ PartyProfileUpdated func() *eventspb.PartyProfileUpdated

type PartyStore

+ UpdateProfile func(ctx context.Context, updated *entities.PartyProfile) error

type TeamStore

+ TeamsStatsUpdated func(ctx context.Context, stats *eventspb.TeamsStatsUpdated) error

+ type TeamsStatsUpdated interface

+ TeamsStatsUpdated func() *eventspb.TeamsStatsUpdated

+ type TransactionResultEvent interface

+ TransactionResult func() events.TransactionResult

+ type TransactionResults struct

+ func NewTransactionResults(log *logging.Logger) *TransactionResults

+ func (s *TransactionResults) Flush(ctx context.Context) error

+ func (s *TransactionResults) SetVegaTime(vegaTime time.Time)

+ func (tr *TransactionResults) Observe(ctx context.Context, retries int, partyIDs []string, hashes []string, ...) (transactions <-chan []events.TransactionResult, ref uint64)

+ func (tr *TransactionResults) Push(ctx context.Context, evt events.Event) error

+ func (tr *TransactionResults) Types() []events.Type

+ type TransferFeesDiscountUpdateEvent interface

+ TransferFeesDiscount func() eventspb.TransferFeesDiscount

type TransferStore

+ UpsertFeesDiscount func(ctx context.Context, tfd *entities.TransferFeesDiscount) error

Oct 30, 2023

Changes in this version

+ type FeesStats struct

+ func NewFeesStats(store FeesStatsStore) *FeesStats

+ func (r *FeesStats) Push(ctx context.Context, evt events.Event) error

+ func (r *FeesStats) Types() []events.Type

+ func (s *FeesStats) Flush(ctx context.Context) error

+ func (s *FeesStats) SetVegaTime(vegaTime time.Time)

+ type FeesStatsEvent interface

+ FeesStats func() *eventspb.FeesStats

+ type FeesStatsStore interface

+ AddFeesStats func(ctx context.Context, FeesStats *entities.FeesStats) error

+ type FundingPaymentSubscriber struct

+ func NewFundingPaymentsSubscriber(store FundingPaymentsStore) *FundingPaymentSubscriber

+ func (s *FundingPaymentSubscriber) SetVegaTime(vegaTime time.Time)

+ func (ts *FundingPaymentSubscriber) Flush(ctx context.Context) error

+ func (ts *FundingPaymentSubscriber) Push(ctx context.Context, evt events.Event) error

+ func (ts *FundingPaymentSubscriber) Types() []events.Type

+ type FundingPaymentsEvent interface

+ FundingPayments func() *eventspb.FundingPayments

+ type FundingPaymentsStore interface

+ Add func(context.Context, []*entities.FundingPayment) error

+ type FundingPeriod struct

+ func NewFundingPeriod(store FundingPeriodStore) *FundingPeriod

+ func (fp *FundingPeriod) Push(ctx context.Context, evt events.Event) error

+ func (fp *FundingPeriod) Types() []events.Type

+ func (s *FundingPeriod) Flush(ctx context.Context) error

+ func (s *FundingPeriod) SetVegaTime(vegaTime time.Time)

+ type FundingPeriodDataPointEvent interface

+ FundingPeriodDataPoint func() *eventspb.FundingPeriodDataPoint

+ type FundingPeriodEvent interface

+ FundingPeriod func() *eventspb.FundingPeriod

+ type FundingPeriodStore interface

+ AddDataPoint func(ctx context.Context, dataPoint *entities.FundingPeriodDataPoint) error

+ AddFundingPeriod func(ctx context.Context, period *entities.FundingPeriod) error

+ type LockedBalancesStore interface

+ Add func(ctx context.Context, balance entities.PartyLockedBalance) error

+ Prune func(ctx context.Context, currentEpoch uint64) error

+ type PaidLiquidityFeesStats struct

+ func NewPaidLiquidityFeesStats(store PaidLiquidityFeesStatsStore) *PaidLiquidityFeesStats

+ func (r *PaidLiquidityFeesStats) Push(ctx context.Context, evt events.Event) error

+ func (r *PaidLiquidityFeesStats) Types() []events.Type

+ func (s *PaidLiquidityFeesStats) Flush(ctx context.Context) error

+ func (s *PaidLiquidityFeesStats) SetVegaTime(vegaTime time.Time)

+ type PaidLiquidityFeesStatsEvent interface

+ PaidLiquidityFeesStats func() *eventspb.PaidLiquidityFeesStats

+ type PaidLiquidityFeesStatsStore interface

+ Add func(ctx context.Context, stats *entities.PaidLiquidityFeesStats) error

+ type PartyActivityStreak struct

+ func NewPartyActivityStreak(store PartyActivityStreakStore) *PartyActivityStreak

+ func (pas *PartyActivityStreak) Push(ctx context.Context, evt events.Event) error

+ func (pas *PartyActivityStreak) Types() []events.Type

+ func (s *PartyActivityStreak) Flush(ctx context.Context) error

+ func (s *PartyActivityStreak) SetVegaTime(vegaTime time.Time)

+ type PartyActivityStreakEvent interface

+ PartyActivityStreak func() *eventspb.PartyActivityStreak

+ type PartyActivityStreakStore interface

+ Add func(context.Context, *entities.PartyActivityStreak) error

+ type RefereeJoinedReferralSetEvent interface

+ GetProtoEvent func() *eventspb.RefereeJoinedReferralSet

+ type RefereeJoinedTeam interface

+ RefereeJoinedTeam func() *eventspb.RefereeJoinedTeam

+ type RefereeSwitchedTeam interface

+ RefereeSwitchedTeam func() *eventspb.RefereeSwitchedTeam

+ type ReferralProgram struct

+ func NewReferralProgram(store ReferralStore) *ReferralProgram

+ func (rp *ReferralProgram) Push(ctx context.Context, evt events.Event) error

+ func (rp *ReferralProgram) Types() []events.Type

+ func (s *ReferralProgram) Flush(ctx context.Context) error

+ func (s *ReferralProgram) SetVegaTime(vegaTime time.Time)

+ type ReferralProgramEndedEvent interface

+ GetReferralProgramEnded func() *eventspb.ReferralProgramEnded

+ type ReferralProgramStartedEvent interface

+ GetReferralProgramStarted func() *eventspb.ReferralProgramStarted

+ type ReferralProgramUpdatedEvent interface

+ GetReferralProgramUpdated func() *eventspb.ReferralProgramUpdated

+ type ReferralSetCreatedEvent interface

+ GetProtoEvent func() *eventspb.ReferralSetCreated

+ type ReferralSetStatsUpdatedEvent interface

+ GetProtoEvent func() *eventspb.ReferralSetStatsUpdated

+ type ReferralSets struct

+ func NewReferralSets(store ReferralSetsStore) *ReferralSets

+ func (rs *ReferralSets) Push(ctx context.Context, evt events.Event) error

+ func (rs *ReferralSets) Types() []events.Type

+ func (s *ReferralSets) Flush(ctx context.Context) error

+ func (s *ReferralSets) SetVegaTime(vegaTime time.Time)

+ type ReferralSetsStore interface

+ AddReferralSet func(ctx context.Context, referralSet *entities.ReferralSet) error

+ AddReferralSetStats func(ctx context.Context, stats *entities.ReferralSetStats) error

+ RefereeJoinedReferralSet func(ctx context.Context, referee *entities.ReferralSetReferee) error

+ type ReferralStore interface

+ AddReferralProgram func(ctx context.Context, referral *entities.ReferralProgram) error

+ EndReferralProgram func(ctx context.Context, version uint64, endedAt time.Time, vegaTime time.Time, ...) error

+ UpdateReferralProgram func(ctx context.Context, referral *entities.ReferralProgram) error

+ type TeamCreatedEvent interface

+ TeamCreated func() *eventspb.TeamCreated

+ type TeamStore interface

+ AddTeam func(ctx context.Context, team *entities.Team) error

+ RefereeJoinedTeam func(ctx context.Context, referee *entities.TeamMember) error

+ RefereeSwitchedTeam func(ctx context.Context, referee *entities.RefereeTeamSwitch) error

+ UpdateTeam func(ctx context.Context, team *entities.TeamUpdated) error

+ type TeamUpdateEvent interface

+ TeamUpdated func() *eventspb.TeamUpdated

+ type Teams struct

+ func NewTeams(store TeamStore) *Teams

+ func (s *Teams) Flush(ctx context.Context) error

+ func (s *Teams) SetVegaTime(vegaTime time.Time)

+ func (t *Teams) Push(ctx context.Context, evt events.Event) error

+ func (t *Teams) Types() []events.Type

+ type TransferFeesEvent interface

+ TransferFees func() eventspb.TransferFees

type TransferStore

+ UpsertFees func(ctx context.Context, tf *entities.TransferFees) error

+ type VestingBalancesStore interface

+ Add func(ctx context.Context, balance entities.PartyVestingBalance) error

+ type VestingBalancesSummary struct

+ func NewVestingBalancesSummary(vestingStore VestingBalancesStore, lockedStore LockedBalancesStore) *VestingBalancesSummary

+ func (s *VestingBalancesSummary) Flush(ctx context.Context) error

+ func (s *VestingBalancesSummary) SetVegaTime(vegaTime time.Time)

+ func (v *VestingBalancesSummary) Push(ctx context.Context, evt events.Event) error

+ func (v *VestingBalancesSummary) Types() []events.Type

+ type VestingBalancesSummaryEvent interface

+ VestingBalancesSummary func() *eventspb.VestingBalancesSummary

+ type VestingStatsUpdated struct

+ func NewVestingStatsUpdated(store VestingStatsUpdatedStore) *VestingStatsUpdated

+ func (pas *VestingStatsUpdated) Push(ctx context.Context, evt events.Event) error

+ func (pas *VestingStatsUpdated) Types() []events.Type

+ func (s *VestingStatsUpdated) Flush(ctx context.Context) error

+ func (s *VestingStatsUpdated) SetVegaTime(vegaTime time.Time)

+ type VestingStatsUpdatedEvent interface

+ VestingStatsUpdated func() *eventspb.VestingStatsUpdated

+ type VestingStatsUpdatedStore interface

+ Add func(context.Context, *entities.VestingStatsUpdated) error

+ type VolumeDiscountProgram struct

+ func NewVolumeDiscountProgram(store VolumeDiscountStore) *VolumeDiscountProgram

+ func (rp *VolumeDiscountProgram) Push(ctx context.Context, evt events.Event) error

+ func (rp *VolumeDiscountProgram) Types() []events.Type

+ func (s *VolumeDiscountProgram) Flush(ctx context.Context) error

+ func (s *VolumeDiscountProgram) SetVegaTime(vegaTime time.Time)

+ type VolumeDiscountProgramEndedEvent interface

+ GetVolumeDiscountProgramEnded func() *eventspb.VolumeDiscountProgramEnded

+ type VolumeDiscountProgramStartedEvent interface

+ GetVolumeDiscountProgramStarted func() *eventspb.VolumeDiscountProgramStarted

+ type VolumeDiscountProgramUpdatedEvent interface

+ GetVolumeDiscountProgramUpdated func() *eventspb.VolumeDiscountProgramUpdated

+ type VolumeDiscountStatsUpdated struct

+ func NewVolumeDiscountStatsUpdated(store VolumeDiscountStatsUpdatedStore) *VolumeDiscountStatsUpdated

+ func (pas *VolumeDiscountStatsUpdated) Push(ctx context.Context, evt events.Event) error

+ func (pas *VolumeDiscountStatsUpdated) Types() []events.Type

+ func (s *VolumeDiscountStatsUpdated) Flush(ctx context.Context) error

+ func (s *VolumeDiscountStatsUpdated) SetVegaTime(vegaTime time.Time)

+ type VolumeDiscountStatsUpdatedEvent interface

+ VolumeDiscountStatsUpdated func() *eventspb.VolumeDiscountStatsUpdated

+ type VolumeDiscountStatsUpdatedStore interface

+ Add func(context.Context, *entities.VolumeDiscountStats) error

+ type VolumeDiscountStore interface

+ AddVolumeDiscountProgram func(ctx context.Context, referral *entities.VolumeDiscountProgram) error

+ EndVolumeDiscountProgram func(ctx context.Context, version uint64, endedAt time.Time, vegaTime time.Time, ...) error

+ UpdateVolumeDiscountProgram func(ctx context.Context, referral *entities.VolumeDiscountProgram) error

Jul 6, 2023

Changes in this version

+ type StopOrder struct

+ func NewStopOrder(store StopOrderStore) *StopOrder

+ func (s *StopOrder) SetVegaTime(vegaTime time.Time)

+ func (so *StopOrder) Flush(ctx context.Context) error

+ func (so *StopOrder) Push(ctx context.Context, evt events.Event) error

+ func (so *StopOrder) Types() []events.Type

+ type StopOrderEvent interface

+ StopOrder func() *pbevents.StopOrderEvent

+ type StopOrderStore interface

+ Add func(entities.StopOrder) error

+ Flush func(ctx context.Context) error

May 26, 2023 GO-2023-1865

  GO-2023-1865: Vega's validators able to submit duplicate transactions in code.vegaprotocol.io/vega

May 3, 2023 GO-2023-1865

  GO-2023-1865: Vega's validators able to submit duplicate transactions in code.vegaprotocol.io/vega

May 2, 2023 GO-2023-1865

  GO-2023-1865: Vega's validators able to submit duplicate transactions in code.vegaprotocol.io/vega

Apr 25, 2023 GO-2023-1865

  GO-2023-1865: Vega's validators able to submit duplicate transactions in code.vegaprotocol.io/vega

Apr 24, 2023 GO-2023-1865

  GO-2023-1865: Vega's validators able to submit duplicate transactions in code.vegaprotocol.io/vega

Apr 21, 2023 GO-2023-1865

  GO-2023-1865: Vega's validators able to submit duplicate transactions in code.vegaprotocol.io/vega

Apr 13, 2023 GO-2023-1865

  GO-2023-1865: Vega's validators able to submit duplicate transactions in code.vegaprotocol.io/vega

Apr 11, 2023 GO-2023-1865

  GO-2023-1865: Vega's validators able to submit duplicate transactions in code.vegaprotocol.io/vega

Mar 31, 2023 GO-2023-1865

  GO-2023-1865: Vega's validators able to submit duplicate transactions in code.vegaprotocol.io/vega

Mar 27, 2023 GO-2023-1865

  GO-2023-1865: Vega's validators able to submit duplicate transactions in code.vegaprotocol.io/vega

Mar 23, 2023 GO-2023-1865

  GO-2023-1865: Vega's validators able to submit duplicate transactions in code.vegaprotocol.io/vega

Mar 14, 2023 GO-2023-1865

  GO-2023-1865: Vega's validators able to submit duplicate transactions in code.vegaprotocol.io/vega

Changes in this version

+ type MarketSvc interface

+ GetMarketScalingFactor func(ctx context.Context, marketID string) (num.Decimal, bool)

Mar 21, 2023 GO-2023-1865

  GO-2023-1865: Vega's validators able to submit duplicate transactions in code.vegaprotocol.io/vega

Mar 10, 2023 GO-2023-1865

  GO-2023-1865: Vega's validators able to submit duplicate transactions in code.vegaprotocol.io/vega

Mar 3, 2023 GO-2023-1865

  GO-2023-1865: Vega's validators able to submit duplicate transactions in code.vegaprotocol.io/vega

Mar 1, 2023 GO-2023-1865

  GO-2023-1865: Vega's validators able to submit duplicate transactions in code.vegaprotocol.io/vega

Feb 21, 2023 GO-2023-1865

  GO-2023-1865: Vega's validators able to submit duplicate transactions in code.vegaprotocol.io/vega

Mar 1, 2023 GO-2023-1865

  GO-2023-1865: Vega's validators able to submit duplicate transactions in code.vegaprotocol.io/vega

Feb 21, 2023 GO-2023-1865

  GO-2023-1865: Vega's validators able to submit duplicate transactions in code.vegaprotocol.io/vega

Feb 21, 2023 GO-2023-1865

  GO-2023-1865: Vega's validators able to submit duplicate transactions in code.vegaprotocol.io/vega

Changes in this version

+ type ExpiredOrdersEvent interface

+ MarketID func() string

+ OrderIDs func() []string

type MarketDepthService

+ PublishAtEndOfBlock func()

type OrderStore

+ GetByMarketAndID func(ctx context.Context, marketIDstr string, orderIDs []string) ([]entities.Order, error)

type PositionStore

+ GetByMarketAndParties func(ctx context.Context, marketID string, parties []string) ([]entities.Position, error)

Feb 14, 2023 GO-2023-1865

  GO-2023-1865: Vega's validators able to submit duplicate transactions in code.vegaprotocol.io/vega

Feb 9, 2023 GO-2023-1865

  GO-2023-1865: Vega's validators able to submit duplicate transactions in code.vegaprotocol.io/vega

Feb 20, 2023 GO-2023-1865

  GO-2023-1865: Vega's validators able to submit duplicate transactions in code.vegaprotocol.io/vega

Jan 23, 2023 GO-2023-1865

  GO-2023-1865: Vega's validators able to submit duplicate transactions in code.vegaprotocol.io/vega

Jan 20, 2023 GO-2023-1865

  GO-2023-1865: Vega's validators able to submit duplicate transactions in code.vegaprotocol.io/vega

Jan 19, 2023 GO-2023-1865

  GO-2023-1865: Vega's validators able to submit duplicate transactions in code.vegaprotocol.io/vega

Jan 17, 2023 GO-2023-1865

  GO-2023-1865: Vega's validators able to submit duplicate transactions in code.vegaprotocol.io/vega

Jan 6, 2023 GO-2023-1865

  GO-2023-1865: Vega's validators able to submit duplicate transactions in code.vegaprotocol.io/vega

Jan 5, 2023 GO-2023-1865

  GO-2023-1865: Vega's validators able to submit duplicate transactions in code.vegaprotocol.io/vega

Dec 22, 2022 GO-2023-1865

  GO-2023-1865: Vega's validators able to submit duplicate transactions in code.vegaprotocol.io/vega

Dec 20, 2022 GO-2023-1865

  GO-2023-1865: Vega's validators able to submit duplicate transactions in code.vegaprotocol.io/vega

Changes in this version

+ type CoreSnapshotEvent interface

+ SnapshotTakenEvent func() eventspb.CoreSnapshotData

+ type SnapshotData struct

+ func NewSnapshotData(store snapAdder, log *logging.Logger) *SnapshotData

+ func (s *SnapshotData) Flush(ctx context.Context) error

+ func (s *SnapshotData) Push(ctx context.Context, evt events.Event) error

+ func (s *SnapshotData) SetVegaTime(vegaTime time.Time)

+ func (s *SnapshotData) Types() []events.Type

Dec 8, 2022 GO-2023-1865

  GO-2023-1865: Vega's validators able to submit duplicate transactions in code.vegaprotocol.io/vega

Dec 2, 2022 GO-2023-1865

  GO-2023-1865: Vega's validators able to submit duplicate transactions in code.vegaprotocol.io/vega

Dec 2, 2022 GO-2023-1865

  GO-2023-1865: Vega's validators able to submit duplicate transactions in code.vegaprotocol.io/vega

Nov 10, 2022 GO-2023-1865

  GO-2023-1865: Vega's validators able to submit duplicate transactions in code.vegaprotocol.io/vega

Nov 8, 2022 GO-2023-1865

  GO-2023-1865: Vega's validators able to submit duplicate transactions in code.vegaprotocol.io/vega

Oct 31, 2022 GO-2023-1865

  GO-2023-1865: Vega's validators able to submit duplicate transactions in code.vegaprotocol.io/vega

Changes in this version

+ type ProtocolUpgrade struct

+ func NewProtocolUpgrade(store pupAdder, log *logging.Logger) *ProtocolUpgrade

+ func (ps *ProtocolUpgrade) Push(ctx context.Context, evt events.Event) error

+ func (ps *ProtocolUpgrade) Types() []events.Type

+ func (s *ProtocolUpgrade) Flush(ctx context.Context) error

+ func (s *ProtocolUpgrade) SetVegaTime(vegaTime time.Time)

+ type ProtocolUpgradeProposalEvent interface

+ ProtocolUpgradeProposalEvent func() eventspb.ProtocolUpgradeEvent

Oct 25, 2022 GO-2023-1865

  GO-2023-1865: Vega's validators able to submit duplicate transactions in code.vegaprotocol.io/vega

Oct 20, 2022 GO-2023-1865

  GO-2023-1865: Vega's validators able to submit duplicate transactions in code.vegaprotocol.io/vega

Oct 11, 2022 GO-2023-1865

  GO-2023-1865: Vega's validators able to submit duplicate transactions in code.vegaprotocol.io/vega

Sep 28, 2022 GO-2023-1865

  GO-2023-1865: Vega's validators able to submit duplicate transactions in code.vegaprotocol.io/vega

Sep 26, 2022 GO-2023-1865

  GO-2023-1865: Vega's validators able to submit duplicate transactions in code.vegaprotocol.io/vega

Changes in this version

type TransferResponseEvent

+ LedgerMovements func() []*vega.LedgerMovement

Sep 12, 2022 GO-2023-1865

  GO-2023-1865: Vega's validators able to submit duplicate transactions in code.vegaprotocol.io/vega

Changes in this version

type NodeStore

+ AddNodeAnnouncedEvent func(context.Context, string, time.Time, *entities.ValidatorUpdateAux) error

Aug 18, 2022 GO-2023-1865

  GO-2023-1865: Vega's validators able to submit duplicate transactions in code.vegaprotocol.io/vega

Aug 16, 2022 GO-2023-1865

  GO-2023-1865: Vega's validators able to submit duplicate transactions in code.vegaprotocol.io/vega

Changes in this version

+ var ErrNoSignaturesForID = errors.New("no signatures for id")

+ func NewEventDeduplicator(getId func(context.Context, V, time.Time) (K, error)) *eventDeduplicator[K, V]

+ type Account struct

+ func NewAccount(accounts AccountService, log *logging.Logger) *Account

+ func (as *Account) Flush(ctx context.Context) error

+ func (as *Account) Push(ctx context.Context, evt events.Event) error

+ func (as *Account) Types() []events.Type

+ func (s *Account) SetVegaTime(vegaTime time.Time)

+ type AccountEvent interface

+ Account func() vega.Account

+ type AccountService interface

+ AddAccountBalance func(b entities.AccountBalance) error

+ Flush func(ctx context.Context) error

+ Obtain func(ctx context.Context, a *entities.Account) error

+ type AccountSource interface

+ GetByID func(id int64) (entities.Account, error)

+ Obtain func(ctx context.Context, a *entities.Account) error

+ type Asset struct

+ func NewAsset(store AssetStore, log *logging.Logger) *Asset

+ func (a *Asset) Types() []events.Type

+ func (as *Asset) Push(ctx context.Context, evt events.Event) error

+ func (s *Asset) Flush(ctx context.Context) error

+ func (s *Asset) SetVegaTime(vegaTime time.Time)

+ type AssetEvent interface

+ Asset func() vega.Asset

+ type AssetStore interface

+ Add func(context.Context, entities.Asset) error

+ type Checkpoint struct

+ func NewCheckpoint(store CheckpointStore, log *logging.Logger) *Checkpoint

+ func (n *Checkpoint) Push(ctx context.Context, evt events.Event) error

+ func (n *Checkpoint) Types() []events.Type

+ func (s *Checkpoint) Flush(ctx context.Context) error

+ func (s *Checkpoint) SetVegaTime(vegaTime time.Time)

+ type CheckpointEvent interface

+ Proto func() eventspb.CheckpointEvent

+ type CheckpointStore interface

+ Add func(context.Context, entities.Checkpoint) error

+ type Delegation struct

+ func NewDelegation(store DelegationStore, log *logging.Logger) *Delegation

+ func (ds *Delegation) Push(ctx context.Context, evt events.Event) error

+ func (ds *Delegation) Types() []events.Type

+ func (s *Delegation) Flush(ctx context.Context) error

+ func (s *Delegation) SetVegaTime(vegaTime time.Time)

+ type DelegationBalanceEvent interface

+ Proto func() eventspb.DelegationBalanceEvent

+ type DelegationStore interface

+ Add func(context.Context, entities.Delegation) error

+ type Deposit struct

+ func NewDeposit(store DepositStore, log *logging.Logger) *Deposit

+ func (d *Deposit) Push(ctx context.Context, evt events.Event) error

+ func (d *Deposit) Types() []events.Type

+ func (s *Deposit) Flush(ctx context.Context) error

+ func (s *Deposit) SetVegaTime(vegaTime time.Time)

+ type DepositEvent interface

+ Deposit func() vega.Deposit

+ type DepositStore interface

+ Upsert func(context.Context, *entities.Deposit) error

+ type ERC20MultiSigSignerAddedEvent interface

+ Proto func() eventspb.ERC20MultiSigSignerAdded

+ type ERC20MultiSigSignerEvent struct

+ func NewERC20MultiSigSignerEvent(store ERC20MultiSigSignerEventStore, log *logging.Logger) *ERC20MultiSigSignerEvent

+ func (m *ERC20MultiSigSignerEvent) Push(ctx context.Context, evt events.Event) error

+ func (s *ERC20MultiSigSignerEvent) Flush(ctx context.Context) error

+ func (s *ERC20MultiSigSignerEvent) SetVegaTime(vegaTime time.Time)

+ func (t *ERC20MultiSigSignerEvent) Types() []events.Type

+ type ERC20MultiSigSignerEventStore interface

+ Add func(ctx context.Context, e *entities.ERC20MultiSigSignerEvent) error

+ type ERC20MultiSigSignerRemovedEvent interface

+ Proto func() eventspb.ERC20MultiSigSignerRemoved

+ type Epoch struct

+ func NewEpoch(store EpochStore, log *logging.Logger) *Epoch

+ func (es *Epoch) Push(ctx context.Context, evt events.Event) error

+ func (es *Epoch) Types() []events.Type

+ func (s *Epoch) Flush(ctx context.Context) error

+ func (s *Epoch) SetVegaTime(vegaTime time.Time)

+ type EpochStore interface

+ Add func(context.Context, entities.Epoch) error

+ type EpochUpdateEvent interface

+ Proto func() eventspb.EpochEvent

+ type EthereumKeyRotation struct

+ func NewEthereumKeyRotation(service EthereumKeyRotationService, log *logging.Logger) *EthereumKeyRotation

+ func (kr *EthereumKeyRotation) Push(ctx context.Context, evt events.Event) error

+ func (kr *EthereumKeyRotation) Types() []events.Type

+ func (s *EthereumKeyRotation) Flush(ctx context.Context) error

+ func (s *EthereumKeyRotation) SetVegaTime(vegaTime time.Time)

+ type EthereumKeyRotationEvent interface

+ EthereumKeyRotation func() eventspb.EthereumKeyRotation

+ type EthereumKeyRotationService interface

+ Add func(context.Context, entities.EthereumKeyRotation) error

+ type GovernanceService interface

+ AddVote func(context.Context, entities.Vote) error

+ type KeyRotation struct

+ func NewKeyRotation(store KeyRotationStore, log *logging.Logger) *KeyRotation

+ func (kr *KeyRotation) Push(ctx context.Context, evt events.Event) error

+ func (kr *KeyRotation) Types() []events.Type

+ func (s *KeyRotation) Flush(ctx context.Context) error

+ func (s *KeyRotation) SetVegaTime(vegaTime time.Time)

+ type KeyRotationEvent interface

+ KeyRotation func() eventspb.KeyRotation

+ type KeyRotationStore interface

+ Upsert func(context.Context, *entities.KeyRotation) error

+ type Ledger interface

+ AddLedgerEntry func(entities.LedgerEntry) error

+ AddTransferResponse func(*vega.TransferResponse)

+ Flush func(ctx context.Context) error

+ type LiquidityProvision struct

+ func NewLiquidityProvision(store LiquidityProvisionStore, log *logging.Logger) *LiquidityProvision

+ func (lp *LiquidityProvision) Flush(ctx context.Context) error

+ func (lp *LiquidityProvision) Push(ctx context.Context, evt events.Event) error

+ func (lp *LiquidityProvision) Types() []events.Type

+ func (s *LiquidityProvision) SetVegaTime(vegaTime time.Time)

+ type LiquidityProvisionEvent interface

+ LiquidityProvision func() *vega.LiquidityProvision

+ type LiquidityProvisionStore interface

+ Flush func(ctx context.Context) error

+ Upsert func(context.Context, entities.LiquidityProvision) error

+ type MarginLevels struct

+ func NewMarginLevels(store MarginLevelsStore, accountSource AccountSource, log *logging.Logger) *MarginLevels

+ func (ml *MarginLevels) Flush(ctx context.Context) error

+ func (ml *MarginLevels) Push(ctx context.Context, evt events.Event) error

+ func (ml *MarginLevels) Types() []events.Type

+ func (s *MarginLevels) SetVegaTime(vegaTime time.Time)

+ type MarginLevelsEvent interface

+ MarginLevels func() vega.MarginLevels

+ type MarginLevelsStore interface

+ Add func(entities.MarginLevels) error

+ Flush func(context.Context) error

+ type MarketCreated struct

+ func NewMarketCreated(store MarketsStore, log *logging.Logger) *MarketCreated

+ func (m *MarketCreated) Push(ctx context.Context, evt events.Event) error

+ func (m *MarketCreated) Types() []events.Type

+ func (s *MarketCreated) Flush(ctx context.Context) error

+ func (s *MarketCreated) SetVegaTime(vegaTime time.Time)

+ type MarketCreatedEvent interface

+ Market func() vega.Market

+ type MarketData struct

+ func NewMarketData(store MarketDataStore, log *logging.Logger) *MarketData

+ func (md *MarketData) Flush(ctx context.Context) error

+ func (md *MarketData) Push(ctx context.Context, evt events.Event) error

+ func (md *MarketData) Types() []events.Type

+ func (s *MarketData) SetVegaTime(vegaTime time.Time)

+ type MarketDataEvent interface

+ MarketData func() types.MarketData

+ type MarketDataStore interface

+ Add func(*entities.MarketData) error

+ Flush func(context.Context) error

+ type MarketDepth struct

+ func NewMarketDepth(depthService MarketDepthService) *MarketDepth

+ func (m *MarketDepth) Push(ctx context.Context, evt events.Event) error

+ func (m *MarketDepth) Types() []events.Type

+ func (s *MarketDepth) Flush(ctx context.Context) error

+ func (s *MarketDepth) SetVegaTime(vegaTime time.Time)

+ type MarketDepthService interface

+ AddOrder func(order *types.Order, vegaTime time.Time, sequenceNumber uint64)

+ type MarketUpdated struct

+ func NewMarketUpdated(store MarketsStore, log *logging.Logger) *MarketUpdated

+ func (m *MarketUpdated) Push(ctx context.Context, evt events.Event) error

+ func (m *MarketUpdated) Types() []events.Type

+ func (s *MarketUpdated) Flush(ctx context.Context) error

+ func (s *MarketUpdated) SetVegaTime(vegaTime time.Time)

+ type MarketUpdatedEvent interface

+ Market func() vega.Market

+ type MarketsStore interface

+ Upsert func(context.Context, *entities.Market) error

+ type NetworkLimitStore interface

+ Add func(context.Context, entities.NetworkLimits) error

+ type NetworkLimits struct

+ func NewNetworkLimitSub(ctx context.Context, store NetworkLimitStore, log *logging.Logger) *NetworkLimits

+ func (nl *NetworkLimits) Push(ctx context.Context, evt events.Event) error

+ func (s *NetworkLimits) Flush(ctx context.Context) error

+ func (s *NetworkLimits) SetVegaTime(vegaTime time.Time)

+ func (t *NetworkLimits) Types() []events.Type

+ type NetworkLimitsEvent interface

+ NetworkLimits func() *vega.NetworkLimits

+ type NetworkParameter struct

+ func NewNetworkParameter(store NetworkParameterStore, log *logging.Logger) *NetworkParameter

+ func (n *NetworkParameter) Push(ctx context.Context, evt events.Event) error

+ func (n *NetworkParameter) Types() []events.Type

+ func (s *NetworkParameter) Flush(ctx context.Context) error

+ func (s *NetworkParameter) SetVegaTime(vegaTime time.Time)

+ type NetworkParameterEvent interface

+ NetworkParameter func() vega.NetworkParameter

+ type NetworkParameterStore interface

+ Add func(context.Context, entities.NetworkParameter) error

+ type Node struct

+ func NewNode(store NodeStore, log *logging.Logger) *Node

+ func (_ *Node) Types() []events.Type

+ func (n *Node) Push(ctx context.Context, evt events.Event) error

+ func (s *Node) Flush(ctx context.Context) error

+ func (s *Node) SetVegaTime(vegaTime time.Time)

+ type NodeSignatureEvent interface

+ NodeSignature func() commandspb.NodeSignature

+ type NodeStore interface

+ AddNodeAnnoucedEvent func(context.Context, string, time.Time, *entities.ValidatorUpdateAux) error

+ UpdateEthereumAddress func(ctx context.Context, kr entities.EthereumKeyRotation) error

+ UpdatePublicKey func(context.Context, *entities.KeyRotation) error

+ UpsertNode func(context.Context, *entities.Node) error

+ UpsertRanking func(context.Context, *entities.RankingScore, *entities.RankingScoreAux) error

+ UpsertScore func(context.Context, *entities.RewardScore, *entities.RewardScoreAux) error

+ type Notary struct

+ func NewNotary(store NotaryStore, log *logging.Logger) *Notary

+ func (n *Notary) Types() []events.Type

+ func (s *Notary) Flush(ctx context.Context) error

+ func (s *Notary) SetVegaTime(vegaTime time.Time)

+ func (w *Notary) Push(ctx context.Context, evt events.Event) error

+ type NotaryStore interface

+ Add func(context.Context, *entities.NodeSignature) error

+ type OracleData struct

+ func NewOracleData(store OracleDataStore, log *logging.Logger) *OracleData

+ func (od *OracleData) Push(ctx context.Context, evt events.Event) error

+ func (od *OracleData) Types() []events.Type

+ func (s *OracleData) Flush(ctx context.Context) error

+ func (s *OracleData) SetVegaTime(vegaTime time.Time)

+ type OracleDataEvent interface

+ OracleData func() oraclespb.OracleData

+ type OracleDataStore interface

+ Add func(context.Context, *entities.OracleData) error

+ type OracleSpec struct

+ func NewOracleSpec(store OracleSpecStore, log *logging.Logger) *OracleSpec

+ func (od *OracleSpec) Push(ctx context.Context, evt events.Event) error

+ func (od *OracleSpec) Types() []events.Type

+ func (s *OracleSpec) Flush(ctx context.Context) error

+ func (s *OracleSpec) SetVegaTime(vegaTime time.Time)

+ type OracleSpecEvent interface

+ OracleSpec func() oraclespb.OracleSpec

+ type OracleSpecStore interface

+ Upsert func(context.Context, *entities.OracleSpec) error

+ type Order struct

+ func NewOrder(store OrderStore, log *logging.Logger) *Order

+ func (os *Order) Flush(ctx context.Context) error

+ func (os *Order) Push(ctx context.Context, evt events.Event) error

+ func (os *Order) Types() []events.Type

+ func (s *Order) SetVegaTime(vegaTime time.Time)

+ type OrderEvent interface

+ Order func() *vega.Order

+ type OrderStore interface

+ Add func(entities.Order) error

+ Flush func(ctx context.Context) error

+ type Party struct

+ func NewParty(store PartyStore, log *logging.Logger) *Party

+ func (ps *Party) Push(ctx context.Context, evt events.Event) error

+ func (ps *Party) Types() []events.Type

+ func (s *Party) Flush(ctx context.Context) error

+ func (s *Party) SetVegaTime(vegaTime time.Time)

+ type PartyEvent interface

+ Party func() types.Party

+ type PartyStore interface

+ Add func(context.Context, entities.Party) error

+ type Position struct

+ func NewPosition(store PositionStore, log *logging.Logger) *Position

+ func (nl *Position) Flush(ctx context.Context) error

+ func (nl *Position) Push(ctx context.Context, evt events.Event) error

+ func (s *Position) SetVegaTime(vegaTime time.Time)

+ func (t *Position) Types() []events.Type

+ type PositionStore interface

+ Add func(context.Context, entities.Position) error

+ Flush func(ctx context.Context) error

+ GetByMarket func(ctx context.Context, marketID string) ([]entities.Position, error)

+ GetByMarketAndParty func(ctx context.Context, marketID string, partyID string) (entities.Position, error)

+ type Proposal struct

+ func NewProposal(store proposalAdder, log *logging.Logger) *Proposal

+ func (ps *Proposal) Push(ctx context.Context, evt events.Event) error

+ func (ps *Proposal) Types() []events.Type

+ func (s *Proposal) Flush(ctx context.Context) error

+ func (s *Proposal) SetVegaTime(vegaTime time.Time)

+ type ProposalEvent interface

+ PartyID func() string

+ Proposal func() vega.Proposal

+ ProposalID func() string

+ type Reward struct

+ func NewReward(store RewardStore, log *logging.Logger) *Reward

+ func (rs *Reward) Push(ctx context.Context, evt events.Event) error

+ func (rs *Reward) Types() []events.Type

+ func (s *Reward) Flush(ctx context.Context) error

+ func (s *Reward) SetVegaTime(vegaTime time.Time)

+ type RewardPayoutEvent interface

+ RewardPayoutEvent func() eventspb.RewardPayoutEvent

+ type RewardStore interface

+ Add func(context.Context, entities.Reward) error

+ type RiskFactor struct

+ func NewRiskFactor(store RiskFactorStore, log *logging.Logger) *RiskFactor

+ func (rf *RiskFactor) Push(ctx context.Context, evt events.Event) error

+ func (rf *RiskFactor) Types() []events.Type

+ func (s *RiskFactor) Flush(ctx context.Context) error

+ func (s *RiskFactor) SetVegaTime(vegaTime time.Time)

+ type RiskFactorEvent interface

+ RiskFactor func() vega.RiskFactor

+ type RiskFactorStore interface

+ Upsert func(context.Context, *entities.RiskFactor) error

+ type StakeLinking struct

+ func NewStakeLinking(store StakeLinkingStore, log *logging.Logger) *StakeLinking

+ func (s *StakeLinking) Flush(ctx context.Context) error

+ func (s *StakeLinking) SetVegaTime(vegaTime time.Time)

+ func (sl *StakeLinking) Push(ctx context.Context, evt events.Event) error

+ func (sl *StakeLinking) Types() []events.Type

+ type StakeLinkingEvent interface

+ StakeLinking func() eventspb.StakeLinking

+ type StakeLinkingStore interface

+ Upsert func(ctx context.Context, linking *entities.StakeLinking) error

+ type TradeEvent interface

+ Trade func() types.Trade

+ type TradeSubscriber struct

+ func NewTradesSubscriber(store TradesStore, log *logging.Logger) *TradeSubscriber

+ func (s *TradeSubscriber) SetVegaTime(vegaTime time.Time)

+ func (ts *TradeSubscriber) Flush(ctx context.Context) error

+ func (ts *TradeSubscriber) Push(ctx context.Context, evt events.Event) error

+ func (ts *TradeSubscriber) Types() []events.Type

+ type TradesStore interface

+ Add func(*entities.Trade) error

+ Flush func(ctx context.Context) error

+ type Transfer struct

+ func NewTransfer(store TransferStore, accountSource AccountSource, log *logging.Logger) *Transfer

+ func (rf *Transfer) Push(ctx context.Context, evt events.Event) error

+ func (rf *Transfer) Types() []events.Type

+ func (s *Transfer) Flush(ctx context.Context) error

+ func (s *Transfer) SetVegaTime(vegaTime time.Time)

+ type TransferEvent interface

+ TransferFunds func() eventspb.Transfer

+ type TransferResponse struct

+ func NewTransferResponse(ledger Ledger, accounts AccountService, log *logging.Logger) *TransferResponse

+ func (s *TransferResponse) SetVegaTime(vegaTime time.Time)

+ func (t *TransferResponse) Flush(ctx context.Context) error

+ func (t *TransferResponse) Push(ctx context.Context, evt events.Event) error

+ func (t *TransferResponse) Types() []events.Type

+ type TransferResponseEvent interface

+ TransferResponses func() []*vega.TransferResponse

+ type TransferStore interface

+ Upsert func(ctx context.Context, transfer *entities.Transfer) error

+ type ValidatorRankingScoreEvent interface

+ ValidatorRankingEvent func() eventspb.ValidatorRankingEvent

+ type ValidatorRewardScoreEvent interface

+ ValidatorScoreEvent func() eventspb.ValidatorScoreEvent

+ type ValidatorUpdateEvent interface

+ ValidatorUpdate func() eventspb.ValidatorUpdate

+ type Vote struct

+ func NewVote(store GovernanceService, log *logging.Logger) *Vote

+ func (s *Vote) Flush(ctx context.Context) error

+ func (s *Vote) SetVegaTime(vegaTime time.Time)

+ func (vs *Vote) Push(ctx context.Context, evt events.Event) error

+ func (vs *Vote) Types() []events.Type

+ type VoteEvent interface

+ PartyID func() string

+ ProposalID func() string

+ Value func() vega.Vote_Value

+ Vote func() vega.Vote

+ type Withdrawal struct

+ func NewWithdrawal(store WithdrawalStore, log *logging.Logger) *Withdrawal

+ func (s *Withdrawal) Flush(ctx context.Context) error

+ func (s *Withdrawal) SetVegaTime(vegaTime time.Time)

+ func (w *Withdrawal) Push(ctx context.Context, evt events.Event) error

+ func (w *Withdrawal) Types() []events.Type

+ type WithdrawalEvent interface

+ Withdrawal func() vega.Withdrawal

+ type WithdrawalStore interface

+ Upsert func(context.Context, *entities.Withdrawal) error