sqlsubscribers

package
v0.73.1 Latest Latest
Warning

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

 Go to latest Published: Oct 31, 2023 License: AGPL-3.0 Imports: 15 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

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

Functions

This section is empty.

Types

type Account 

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

func NewAccount 

func NewAccount(accounts AccountService) *Account

func (*Account) Flush 

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

func (*Account) Push 

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

func (*Account) SetVegaTime 

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

func (*Account) Types 

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

type AccountEvent 

type AccountEvent interface {
	events.Event
	Account() vega.Account
}

type AccountService 

type AccountService interface {
	Obtain(ctx context.Context, a *entities.Account) error
	AddAccountBalance(b entities.AccountBalance) error
	Flush(ctx context.Context) error
}

type AccountSource 

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

type Asset 

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

func NewAsset 

func NewAsset(store AssetStore) *Asset

func (*Asset) Flush 

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

func (*Asset) Push 

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

func (*Asset) SetVegaTime 

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

func (*Asset) Types 

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

type AssetEvent 

type AssetEvent interface {
	events.Event
	Asset() vega.Asset
}

type AssetStore 

type AssetStore interface {
	Add(context.Context, entities.Asset) error
}

type Checkpoint 

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

func NewCheckpoint 

func NewCheckpoint(store CheckpointStore) *Checkpoint

func (*Checkpoint) Flush 

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

func (*Checkpoint) Push 

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

func (*Checkpoint) SetVegaTime 

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

func (*Checkpoint) Types 

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

type CheckpointEvent 

type CheckpointEvent interface {
	events.Event
	Proto() eventspb.CheckpointEvent
}

type CheckpointStore 

type CheckpointStore interface {
	Add(context.Context, entities.Checkpoint) error
}

type CoreSnapshotEvent added in v0.65.0 

type CoreSnapshotEvent interface {
	events.Event
	SnapshotTakenEvent() eventspb.CoreSnapshotData
}

type Delegation 

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

func NewDelegation 

func NewDelegation(store DelegationStore) *Delegation

func (*Delegation) Flush 

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

func (*Delegation) Push 

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

func (*Delegation) SetVegaTime 

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

func (*Delegation) Types 

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

type DelegationBalanceEvent 

type DelegationBalanceEvent interface {
	events.Event
	Proto() eventspb.DelegationBalanceEvent
}

type DelegationStore 

type DelegationStore interface {
	Add(context.Context, entities.Delegation) error
}

type Deposit 

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

func NewDeposit 

func NewDeposit(store DepositStore) *Deposit

func (*Deposit) Flush 

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

func (*Deposit) Push 

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

func (*Deposit) SetVegaTime 

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

func (*Deposit) Types 

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

type DepositEvent 

type DepositEvent interface {
	events.Event
	Deposit() vega.Deposit
}

type DepositStore 

type DepositStore interface {
	Upsert(context.Context, *entities.Deposit) error
}

type ERC20MultiSigSignerAddedEvent 

type ERC20MultiSigSignerAddedEvent interface {
	events.Event
	Proto() eventspb.ERC20MultiSigSignerAdded
}

type ERC20MultiSigSignerEvent 

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

func NewERC20MultiSigSignerEvent 

func NewERC20MultiSigSignerEvent(store ERC20MultiSigSignerEventStore) *ERC20MultiSigSignerEvent

func (*ERC20MultiSigSignerEvent) Flush 

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

func (*ERC20MultiSigSignerEvent) Push 

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

func (*ERC20MultiSigSignerEvent) SetVegaTime 

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

func (*ERC20MultiSigSignerEvent) Types 

func (m *ERC20MultiSigSignerEvent) Types() []events.Type

type ERC20MultiSigSignerEventStore 

type ERC20MultiSigSignerEventStore interface {
	Add(ctx context.Context, e *entities.ERC20MultiSigSignerEvent) error
}

type ERC20MultiSigSignerRemovedEvent 

type ERC20MultiSigSignerRemovedEvent interface {
	events.Event
	Proto() eventspb.ERC20MultiSigSignerRemoved
}

type Epoch 

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

func NewEpoch 

func NewEpoch(store EpochStore) *Epoch

func (*Epoch) Flush 

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

func (*Epoch) Push 

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

func (*Epoch) SetVegaTime 

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

func (*Epoch) Types 

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

type EpochStore 

type EpochStore interface {
	Add(context.Context, entities.Epoch) error
}

type EpochUpdateEvent 

type EpochUpdateEvent interface {
	events.Event
	Proto() eventspb.EpochEvent
}

type EthereumKeyRotation 

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

func NewEthereumKeyRotation 

func NewEthereumKeyRotation(service EthereumKeyRotationService) *EthereumKeyRotation

func (*EthereumKeyRotation) Flush 

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

func (*EthereumKeyRotation) Push 

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

func (*EthereumKeyRotation) SetVegaTime 

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

func (*EthereumKeyRotation) Types 

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

type EthereumKeyRotationEvent 

type EthereumKeyRotationEvent interface {
	events.Event
	EthereumKeyRotation() eventspb.EthereumKeyRotation
}

type EthereumKeyRotationService 

type EthereumKeyRotationService interface {
	Add(context.Context, entities.EthereumKeyRotation) error
}

type ExpiredOrdersEvent added in v0.68.0 

type ExpiredOrdersEvent interface {
	events.Event
	MarketID() string
	OrderIDs() []string
}

type FeesStats added in v0.73.0 

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

func NewFeesStats added in v0.73.0 

func NewFeesStats(store FeesStatsStore) *FeesStats

func (*FeesStats) Flush added in v0.73.0 

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

func (*FeesStats) Push added in v0.73.0 

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

func (*FeesStats) SetVegaTime added in v0.73.0 

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

func (*FeesStats) Types added in v0.73.0 

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

type FeesStatsEvent added in v0.73.0 

type FeesStatsEvent interface {
	events.Event
	FeesStats() *eventspb.FeesStats
}

type FeesStatsStore added in v0.73.0 

type FeesStatsStore interface {
	AddFeesStats(ctx context.Context, FeesStats *entities.FeesStats) error
}

type FundingPaymentSubscriber added in v0.73.0 

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

func NewFundingPaymentsSubscriber added in v0.73.0 

func NewFundingPaymentsSubscriber(store FundingPaymentsStore) *FundingPaymentSubscriber

func (*FundingPaymentSubscriber) Flush added in v0.73.0 

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

func (*FundingPaymentSubscriber) Push added in v0.73.0 

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

func (*FundingPaymentSubscriber) SetVegaTime added in v0.73.0 

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

func (*FundingPaymentSubscriber) Types added in v0.73.0 

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

type FundingPaymentsEvent added in v0.73.0 

type FundingPaymentsEvent interface {
	events.Event
	FundingPayments() *eventspb.FundingPayments
}

type FundingPaymentsStore added in v0.73.0 

type FundingPaymentsStore interface {
	Add(context.Context, []*entities.FundingPayment) error
}

type FundingPeriod added in v0.73.0 

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

func NewFundingPeriod added in v0.73.0 

func NewFundingPeriod(store FundingPeriodStore) *FundingPeriod

func (*FundingPeriod) Flush added in v0.73.0 

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

func (*FundingPeriod) Push added in v0.73.0 

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

func (*FundingPeriod) SetVegaTime added in v0.73.0 

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

func (*FundingPeriod) Types added in v0.73.0 

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

type FundingPeriodDataPointEvent added in v0.73.0 

type FundingPeriodDataPointEvent interface {
	events.Event
	FundingPeriodDataPoint() *eventspb.FundingPeriodDataPoint
}

type FundingPeriodEvent added in v0.73.0 

type FundingPeriodEvent interface {
	events.Event
	FundingPeriod() *eventspb.FundingPeriod
}

type FundingPeriodStore added in v0.73.0 

type FundingPeriodStore interface {
	AddFundingPeriod(ctx context.Context, period *entities.FundingPeriod) error
	AddDataPoint(ctx context.Context, dataPoint *entities.FundingPeriodDataPoint) error
}

type GovernanceService 

type GovernanceService interface {
	AddVote(context.Context, entities.Vote) error
}

type KeyRotation 

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

func NewKeyRotation 

func NewKeyRotation(store KeyRotationStore) *KeyRotation

func (*KeyRotation) Flush 

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

func (*KeyRotation) Push 

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

func (*KeyRotation) SetVegaTime 

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

func (*KeyRotation) Types 

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

type KeyRotationEvent 

type KeyRotationEvent interface {
	events.Event
	KeyRotation() eventspb.KeyRotation
}

type KeyRotationStore 

type KeyRotationStore interface {
	Upsert(context.Context, *entities.KeyRotation) error
}

type Ledger 

type Ledger interface {
	AddLedgerEntry(entities.LedgerEntry) error
	AddTransferResponse(*vega.LedgerMovement)
	Flush(ctx context.Context) error
}

type LiquidityProvision 

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

func NewLiquidityProvision 

func NewLiquidityProvision(store LiquidityProvisionStore) *LiquidityProvision

func (*LiquidityProvision) Flush 

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

func (*LiquidityProvision) Push 

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

func (*LiquidityProvision) SetVegaTime 

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

func (*LiquidityProvision) Types 

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

type LiquidityProvisionEvent 

type LiquidityProvisionEvent interface {
	events.Event
	LiquidityProvision() *vega.LiquidityProvision
}

type LiquidityProvisionStore 

type LiquidityProvisionStore interface {
	Upsert(context.Context, entities.LiquidityProvision) error
	Flush(ctx context.Context) error
}

type LockedBalancesStore added in v0.73.0 

type LockedBalancesStore interface {
	Add(ctx context.Context, balance entities.PartyLockedBalance) error
	Prune(ctx context.Context, currentEpoch uint64) error
}

type MarginLevels 

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

func NewMarginLevels 

func NewMarginLevels(store MarginLevelsStore, accountSource AccountSource) *MarginLevels

func (*MarginLevels) Flush 

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

func (*MarginLevels) Push 

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

func (*MarginLevels) SetVegaTime 

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

func (*MarginLevels) Types 

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

type MarginLevelsEvent 

type MarginLevelsEvent interface {
	events.Event
	MarginLevels() vega.MarginLevels
}

type MarginLevelsStore 

type MarginLevelsStore interface {
	Add(entities.MarginLevels) error
	Flush(context.Context) error
}

type MarketCreated 

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

func NewMarketCreated 

func NewMarketCreated(store MarketsStore) *MarketCreated

func (*MarketCreated) Flush 

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

func (*MarketCreated) Push 

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

func (*MarketCreated) SetVegaTime 

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

func (*MarketCreated) Types 

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

type MarketCreatedEvent 

type MarketCreatedEvent interface {
	events.Event
	Market() vega.Market
}

type MarketData 

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

func NewMarketData 

func NewMarketData(store MarketDataStore) *MarketData

func (*MarketData) Flush 

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

func (*MarketData) Push 

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

func (*MarketData) SetVegaTime 

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

func (*MarketData) Types 

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

type MarketDataEvent 

type MarketDataEvent interface {
	events.Event
	MarketData() types.MarketData
}

type MarketDataStore 

type MarketDataStore interface {
	Add(*entities.MarketData) error
	Flush(context.Context) error
}

type MarketDepthService 

type MarketDepthService interface {
	AddOrder(order *types.Order, vegaTime time.Time, sequenceNumber uint64)
	PublishAtEndOfBlock()
}

type MarketSvc added in v0.69.0 

type MarketSvc interface {
	GetMarketScalingFactor(ctx context.Context, marketID string) (num.Decimal, bool)
}

type MarketUpdated 

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

func NewMarketUpdated 

func NewMarketUpdated(store MarketsStore) *MarketUpdated

func (*MarketUpdated) Flush 

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

func (*MarketUpdated) Push 

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

func (*MarketUpdated) SetVegaTime 

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

func (*MarketUpdated) Types 

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

type MarketUpdatedEvent 

type MarketUpdatedEvent interface {
	events.Event
	Market() vega.Market
}

type MarketsStore 

type MarketsStore interface {
	Upsert(context.Context, *entities.Market) error
}

type NetworkLimitStore 

type NetworkLimitStore interface {
	Add(context.Context, entities.NetworkLimits) error
}

type NetworkLimits 

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

func NewNetworkLimitSub 

func NewNetworkLimitSub(store NetworkLimitStore) *NetworkLimits

func (*NetworkLimits) Flush 

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

func (*NetworkLimits) Push 

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

func (*NetworkLimits) SetVegaTime 

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

func (*NetworkLimits) Types 

func (nl *NetworkLimits) Types() []events.Type

type NetworkLimitsEvent 

type NetworkLimitsEvent interface {
	events.Event
	NetworkLimits() *vega.NetworkLimits
}

type NetworkParameter 

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

func NewNetworkParameter 

func NewNetworkParameter(store NetworkParameterStore) *NetworkParameter

func (*NetworkParameter) Flush 

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

func (*NetworkParameter) Push 

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

func (*NetworkParameter) SetVegaTime 

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

func (*NetworkParameter) Types 

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

type NetworkParameterEvent 

type NetworkParameterEvent interface {
	events.Event
	NetworkParameter() vega.NetworkParameter
}

type NetworkParameterStore 

type NetworkParameterStore interface {
	Add(context.Context, entities.NetworkParameter) error
}

type Node 

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

func NewNode 

func NewNode(store NodeStore) *Node

func (*Node) Flush 

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

func (*Node) Push 

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

func (*Node) SetVegaTime 

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

func (*Node) Types 

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

type NodeSignatureEvent 

type NodeSignatureEvent interface {
	events.Event
	NodeSignature() commandspb.NodeSignature
}

type NodeStore 

type NodeStore interface {
	UpsertNode(context.Context, *entities.Node) error
	UpsertRanking(context.Context, *entities.RankingScore, *entities.RankingScoreAux) error
	UpsertScore(context.Context, *entities.RewardScore, *entities.RewardScoreAux) error
	UpdatePublicKey(context.Context, *entities.KeyRotation) error
	AddNodeAnnouncedEvent(context.Context, string, time.Time, *entities.ValidatorUpdateAux) error
	UpdateEthereumAddress(ctx context.Context, kr entities.EthereumKeyRotation) error
}

type Notary 

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

func NewNotary 

func NewNotary(store NotaryStore) *Notary

func (*Notary) Flush 

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

func (*Notary) Push 

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

func (*Notary) SetVegaTime 

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

func (*Notary) Types 

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

type NotaryStore 

type NotaryStore interface {
	Add(context.Context, *entities.NodeSignature) error
}

type OracleData 

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

func NewOracleData 

func NewOracleData(store OracleDataStore) *OracleData

func (*OracleData) Flush 

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

func (*OracleData) Push 

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

func (*OracleData) SetVegaTime 

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

func (*OracleData) Types 

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

type OracleDataEvent 

type OracleDataEvent interface {
	events.Event
	OracleData() vegapb.OracleData
}

type OracleDataStore 

type OracleDataStore interface {
	Add(context.Context, *entities.OracleData) error
}

type OracleSpec 

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

func NewOracleSpec 

func NewOracleSpec(store OracleSpecStore) *OracleSpec

func (*OracleSpec) Flush 

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

func (*OracleSpec) Push 

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

func (*OracleSpec) SetVegaTime 

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

func (*OracleSpec) Types 

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

type OracleSpecEvent 

type OracleSpecEvent interface {
	events.Event
	OracleSpec() *vegapb.OracleSpec
}

type OracleSpecStore 

type OracleSpecStore interface {
	Upsert(context.Context, *entities.OracleSpec) error
}

type Order 

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

func NewOrder 

func NewOrder(store OrderStore, depthService MarketDepthService) *Order

func (*Order) Flush 

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

func (*Order) Push 

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

func (*Order) SetVegaTime 

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

func (*Order) Types 

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

type OrderEvent 

type OrderEvent interface {
	events.Event
	Order() *vega.Order
}

type OrderStore 

type OrderStore interface {
	Add(entities.Order) error
	Flush(ctx context.Context) error
	GetByMarketAndID(ctx context.Context, marketIDstr string, orderIDs []string) ([]entities.Order, error)
}

type PaidLiquidityFeesStats added in v0.73.0 

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

func NewPaidLiquidityFeesStats added in v0.73.0 

func NewPaidLiquidityFeesStats(store PaidLiquidityFeesStatsStore) *PaidLiquidityFeesStats

func (*PaidLiquidityFeesStats) Flush added in v0.73.0 

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

func (*PaidLiquidityFeesStats) Push added in v0.73.0 

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

func (*PaidLiquidityFeesStats) SetVegaTime added in v0.73.0 

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

func (*PaidLiquidityFeesStats) Types added in v0.73.0 

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

type PaidLiquidityFeesStatsEvent added in v0.73.0 

type PaidLiquidityFeesStatsEvent interface {
	events.Event
	PaidLiquidityFeesStats() *eventspb.PaidLiquidityFeesStats
}

type PaidLiquidityFeesStatsStore added in v0.73.0 

type PaidLiquidityFeesStatsStore interface {
	Add(ctx context.Context, stats *entities.PaidLiquidityFeesStats) error
}

type Party 

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

func NewParty 

func NewParty(store PartyStore) *Party

func (*Party) Flush 

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

func (*Party) Push 

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

func (*Party) SetVegaTime 

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

func (*Party) Types 

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

type PartyActivityStreak added in v0.73.0 

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

func NewPartyActivityStreak added in v0.73.0 

func NewPartyActivityStreak(store PartyActivityStreakStore) *PartyActivityStreak

func (*PartyActivityStreak) Flush added in v0.73.0 

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

func (*PartyActivityStreak) Push added in v0.73.0 

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

func (*PartyActivityStreak) SetVegaTime added in v0.73.0 

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

func (*PartyActivityStreak) Types added in v0.73.0 

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

type PartyActivityStreakEvent added in v0.73.0 

type PartyActivityStreakEvent interface {
	events.Event
	PartyActivityStreak() *eventspb.PartyActivityStreak
}

type PartyActivityStreakStore added in v0.73.0 

type PartyActivityStreakStore interface {
	Add(context.Context, *entities.PartyActivityStreak) error
}

type PartyEvent 

type PartyEvent interface {
	events.Event
	Party() types.Party
}

type PartyStore 

type PartyStore interface {
	Add(context.Context, entities.Party) error
}

type Position 

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

func NewPosition 

func NewPosition(store PositionStore, mktSvc MarketSvc) *Position

func (*Position) Flush 

func (p *Position) Flush(ctx context.Context) error

func (*Position) Push 

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

func (*Position) SetVegaTime 

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

func (*Position) Types 

func (p *Position) Types() []events.Type

type PositionStore 

type PositionStore interface {
	Add(context.Context, entities.Position) error
	GetByMarket(ctx context.Context, marketID string) ([]entities.Position, error)
	GetByMarketAndParty(ctx context.Context, marketID string, partyID string) (entities.Position, error)
	GetByMarketAndParties(ctx context.Context, marketID string, parties []string) ([]entities.Position, error)
	Flush(ctx context.Context) error
}

type Proposal 

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

func NewProposal 

func NewProposal(store proposalAdder) *Proposal

func (*Proposal) Flush 

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

func (*Proposal) Push 

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

func (*Proposal) SetVegaTime 

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

func (*Proposal) Types 

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

type ProposalEvent 

type ProposalEvent interface {
	events.Event
	ProposalID() string
	PartyID() string
	Proposal() vega.Proposal
}

type ProtocolUpgrade added in v0.61.0 

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

func NewProtocolUpgrade added in v0.61.0 

func NewProtocolUpgrade(store pupAdder) *ProtocolUpgrade

func (*ProtocolUpgrade) Flush added in v0.61.0 

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

func (*ProtocolUpgrade) Push added in v0.61.0 

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

func (*ProtocolUpgrade) SetVegaTime added in v0.61.0 

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

func (*ProtocolUpgrade) Types added in v0.61.0 

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

type ProtocolUpgradeProposalEvent added in v0.61.0 

type ProtocolUpgradeProposalEvent interface {
	events.Event
	ProtocolUpgradeProposalEvent() eventspb.ProtocolUpgradeEvent
}

type RefereeJoinedReferralSetEvent added in v0.73.0 

type RefereeJoinedReferralSetEvent interface {
	events.Event
	GetProtoEvent() *eventspb.RefereeJoinedReferralSet
}

type RefereeJoinedTeam added in v0.73.0 

type RefereeJoinedTeam interface {
	events.Event
	RefereeJoinedTeam() *eventspb.RefereeJoinedTeam
}

type RefereeSwitchedTeam added in v0.73.0 

type RefereeSwitchedTeam interface {
	events.Event
	RefereeSwitchedTeam() *eventspb.RefereeSwitchedTeam
}

type ReferralProgram added in v0.73.0 

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

func NewReferralProgram added in v0.73.0 

func NewReferralProgram(store ReferralStore) *ReferralProgram

func (*ReferralProgram) Flush added in v0.73.0 

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

func (*ReferralProgram) Push added in v0.73.0 

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

func (*ReferralProgram) SetVegaTime added in v0.73.0 

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

func (*ReferralProgram) Types added in v0.73.0 

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

type ReferralProgramEndedEvent added in v0.73.0 

type ReferralProgramEndedEvent interface {
	events.Event
	GetReferralProgramEnded() *eventspb.ReferralProgramEnded
}

type ReferralProgramStartedEvent added in v0.73.0 

type ReferralProgramStartedEvent interface {
	events.Event
	GetReferralProgramStarted() *eventspb.ReferralProgramStarted
}

type ReferralProgramUpdatedEvent added in v0.73.0 

type ReferralProgramUpdatedEvent interface {
	events.Event
	GetReferralProgramUpdated() *eventspb.ReferralProgramUpdated
}

type ReferralSetCreatedEvent added in v0.73.0 

type ReferralSetCreatedEvent interface {
	events.Event
	GetProtoEvent() *eventspb.ReferralSetCreated
}

type ReferralSetStatsUpdatedEvent added in v0.73.0 

type ReferralSetStatsUpdatedEvent interface {
	events.Event
	GetProtoEvent() *eventspb.ReferralSetStatsUpdated
}

type ReferralSets added in v0.73.0 

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

func NewReferralSets added in v0.73.0 

func NewReferralSets(store ReferralSetsStore) *ReferralSets

func (*ReferralSets) Flush added in v0.73.0 

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

func (*ReferralSets) Push added in v0.73.0 

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

func (*ReferralSets) SetVegaTime added in v0.73.0 

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

func (*ReferralSets) Types added in v0.73.0 

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

type ReferralSetsStore added in v0.73.0 

type ReferralSetsStore interface {
	AddReferralSet(ctx context.Context, referralSet *entities.ReferralSet) error
	RefereeJoinedReferralSet(ctx context.Context, referee *entities.ReferralSetReferee) error
	AddReferralSetStats(ctx context.Context, stats *entities.ReferralSetStats) error
}

type ReferralStore added in v0.73.0 

type ReferralStore interface {
	AddReferralProgram(ctx context.Context, referral *entities.ReferralProgram) error
	UpdateReferralProgram(ctx context.Context, referral *entities.ReferralProgram) error
	EndReferralProgram(ctx context.Context, version uint64, endedAt time.Time, vegaTime time.Time, seqNum uint64) error
}

type Reward 

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

func NewReward 

func NewReward(store RewardStore) *Reward

func (*Reward) Flush 

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

func (*Reward) Push 

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

func (*Reward) SetVegaTime 

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

func (*Reward) Types 

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

type RewardPayoutEvent 

type RewardPayoutEvent interface {
	events.Event
	RewardPayoutEvent() eventspb.RewardPayoutEvent
}

type RewardStore 

type RewardStore interface {
	Add(context.Context, entities.Reward) error
}

type RiskFactor 

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

func NewRiskFactor 

func NewRiskFactor(store RiskFactorStore) *RiskFactor

func (*RiskFactor) Flush 

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

func (*RiskFactor) Push 

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

func (*RiskFactor) SetVegaTime 

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

func (*RiskFactor) Types 

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

type RiskFactorEvent 

type RiskFactorEvent interface {
	events.Event
	RiskFactor() vega.RiskFactor
}

type RiskFactorStore 

type RiskFactorStore interface {
	Upsert(context.Context, *entities.RiskFactor) error
}

type SnapshotData added in v0.65.0 

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

func NewSnapshotData added in v0.65.0 

func NewSnapshotData(store snapAdder) *SnapshotData

func (*SnapshotData) Flush added in v0.65.0 

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

func (*SnapshotData) Push added in v0.65.0 

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

func (*SnapshotData) SetVegaTime added in v0.65.0 

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

func (*SnapshotData) Types added in v0.65.0 

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

type StakeLinking 

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

func NewStakeLinking 

func NewStakeLinking(store StakeLinkingStore) *StakeLinking

func (*StakeLinking) Flush 

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

func (*StakeLinking) Push 

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

func (*StakeLinking) SetVegaTime 

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

func (*StakeLinking) Types 

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

type StakeLinkingEvent 

type StakeLinkingEvent interface {
	events.Event
	StakeLinking() eventspb.StakeLinking
}

type StakeLinkingStore 

type StakeLinkingStore interface {
	Upsert(ctx context.Context, linking *entities.StakeLinking) error
}

type StopOrder added in v0.72.0 

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

func NewStopOrder added in v0.72.0 

func NewStopOrder(store StopOrderStore) *StopOrder

func (*StopOrder) Flush added in v0.72.0 

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

func (*StopOrder) Push added in v0.72.0 

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

func (*StopOrder) SetVegaTime added in v0.72.0 

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

func (*StopOrder) Types added in v0.72.0 

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

type StopOrderEvent added in v0.72.0 

type StopOrderEvent interface {
	events.Event
	StopOrder() *pbevents.StopOrderEvent
}

type StopOrderStore added in v0.72.0 

type StopOrderStore interface {
	Add(entities.StopOrder) error
	Flush(ctx context.Context) error
}

type TeamCreatedEvent added in v0.73.0 

type TeamCreatedEvent interface {
	events.Event
	TeamCreated() *eventspb.TeamCreated
}

type TeamStore added in v0.73.0 

type TeamStore interface {
	AddTeam(ctx context.Context, team *entities.Team) error
	UpdateTeam(ctx context.Context, team *entities.TeamUpdated) error
	RefereeJoinedTeam(ctx context.Context, referee *entities.TeamMember) error
	RefereeSwitchedTeam(ctx context.Context, referee *entities.RefereeTeamSwitch) error
}

type TeamUpdateEvent added in v0.73.0 

type TeamUpdateEvent interface {
	events.Event
	TeamUpdated() *eventspb.TeamUpdated
}

type Teams added in v0.73.0 

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

func NewTeams added in v0.73.0 

func NewTeams(store TeamStore) *Teams

func (*Teams) Flush added in v0.73.0 

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

func (*Teams) Push added in v0.73.0 

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

func (*Teams) SetVegaTime added in v0.73.0 

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

func (*Teams) Types added in v0.73.0 

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

type TradeEvent 

type TradeEvent interface {
	events.Event
	Trade() types.Trade
}

type TradeSubscriber 

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

func NewTradesSubscriber 

func NewTradesSubscriber(store TradesStore) *TradeSubscriber

func (*TradeSubscriber) Flush 

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

func (*TradeSubscriber) Push 

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

func (*TradeSubscriber) SetVegaTime 

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

func (*TradeSubscriber) Types 

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

type TradesStore 

type TradesStore interface {
	Add(*entities.Trade) error
	Flush(ctx context.Context) error
}

type Transfer 

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

func NewTransfer 

func NewTransfer(store TransferStore, accountSource AccountSource) *Transfer

func (*Transfer) Flush 

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

func (*Transfer) Push 

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

func (*Transfer) SetVegaTime 

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

func (*Transfer) Types 

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

type TransferEvent 

type TransferEvent interface {
	events.Event
	TransferFunds() eventspb.Transfer
}

type TransferFeesEvent added in v0.73.0 

type TransferFeesEvent interface {
	events.Event
	TransferFees() eventspb.TransferFees
}

type TransferResponse 

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

func NewTransferResponse 

func NewTransferResponse(ledger Ledger, accounts AccountService) *TransferResponse

func (*TransferResponse) Flush 

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

func (*TransferResponse) Push 

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

func (*TransferResponse) SetVegaTime 

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

func (*TransferResponse) Types 

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

type TransferResponseEvent 

type TransferResponseEvent interface {
	events.Event
	LedgerMovements() []*vega.LedgerMovement
}

type TransferStore 

type TransferStore interface {
	Upsert(ctx context.Context, transfer *entities.Transfer) error
	UpsertFees(ctx context.Context, tf *entities.TransferFees) error
}

type ValidatorRankingScoreEvent 

type ValidatorRankingScoreEvent interface {
	events.Event
	ValidatorRankingEvent() eventspb.ValidatorRankingEvent
}

type ValidatorRewardScoreEvent 

type ValidatorRewardScoreEvent interface {
	events.Event
	ValidatorScoreEvent() eventspb.ValidatorScoreEvent
}

type ValidatorUpdateEvent 

type ValidatorUpdateEvent interface {
	events.Event
	ValidatorUpdate() eventspb.ValidatorUpdate
}

type VestingBalancesStore added in v0.73.0 

type VestingBalancesStore interface {
	Add(ctx context.Context, balance entities.PartyVestingBalance) error
}

type VestingBalancesSummary added in v0.73.0 

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

func NewVestingBalancesSummary added in v0.73.0 

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

func (*VestingBalancesSummary) Flush added in v0.73.0 

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

func (*VestingBalancesSummary) Push added in v0.73.0 

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

func (*VestingBalancesSummary) SetVegaTime added in v0.73.0 

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

func (*VestingBalancesSummary) Types added in v0.73.0 

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

type VestingBalancesSummaryEvent added in v0.73.0 

type VestingBalancesSummaryEvent interface {
	events.Event
	VestingBalancesSummary() *eventspb.VestingBalancesSummary
}

type VestingStatsUpdated added in v0.73.0 

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

func NewVestingStatsUpdated added in v0.73.0 

func NewVestingStatsUpdated(store VestingStatsUpdatedStore) *VestingStatsUpdated

func (*VestingStatsUpdated) Flush added in v0.73.0 

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

func (*VestingStatsUpdated) Push added in v0.73.0 

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

func (*VestingStatsUpdated) SetVegaTime added in v0.73.0 

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

func (*VestingStatsUpdated) Types added in v0.73.0 

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

type VestingStatsUpdatedEvent added in v0.73.0 

type VestingStatsUpdatedEvent interface {
	events.Event
	VestingStatsUpdated() *eventspb.VestingStatsUpdated
}

type VestingStatsUpdatedStore added in v0.73.0 

type VestingStatsUpdatedStore interface {
	Add(context.Context, *entities.VestingStatsUpdated) error
}

type VolumeDiscountProgram added in v0.73.0 

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

func NewVolumeDiscountProgram added in v0.73.0 

func NewVolumeDiscountProgram(store VolumeDiscountStore) *VolumeDiscountProgram

func (*VolumeDiscountProgram) Flush added in v0.73.0 

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

func (*VolumeDiscountProgram) Push added in v0.73.0 

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

func (*VolumeDiscountProgram) SetVegaTime added in v0.73.0 

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

func (*VolumeDiscountProgram) Types added in v0.73.0 

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

type VolumeDiscountProgramEndedEvent added in v0.73.0 

type VolumeDiscountProgramEndedEvent interface {
	events.Event
	GetVolumeDiscountProgramEnded() *eventspb.VolumeDiscountProgramEnded
}

type VolumeDiscountProgramStartedEvent added in v0.73.0 

type VolumeDiscountProgramStartedEvent interface {
	events.Event
	GetVolumeDiscountProgramStarted() *eventspb.VolumeDiscountProgramStarted
}

type VolumeDiscountProgramUpdatedEvent added in v0.73.0 

type VolumeDiscountProgramUpdatedEvent interface {
	events.Event
	GetVolumeDiscountProgramUpdated() *eventspb.VolumeDiscountProgramUpdated
}

type VolumeDiscountStatsUpdated added in v0.73.0 

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

func NewVolumeDiscountStatsUpdated added in v0.73.0 

func NewVolumeDiscountStatsUpdated(store VolumeDiscountStatsUpdatedStore) *VolumeDiscountStatsUpdated

func (*VolumeDiscountStatsUpdated) Flush added in v0.73.0 

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

func (*VolumeDiscountStatsUpdated) Push added in v0.73.0 

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

func (*VolumeDiscountStatsUpdated) SetVegaTime added in v0.73.0 

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

func (*VolumeDiscountStatsUpdated) Types added in v0.73.0 

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

type VolumeDiscountStatsUpdatedEvent added in v0.73.0 

type VolumeDiscountStatsUpdatedEvent interface {
	events.Event
	VolumeDiscountStatsUpdated() *eventspb.VolumeDiscountStatsUpdated
}

type VolumeDiscountStatsUpdatedStore added in v0.73.0 

type VolumeDiscountStatsUpdatedStore interface {
	Add(context.Context, *entities.VolumeDiscountStats) error
}

type VolumeDiscountStore added in v0.73.0 

type VolumeDiscountStore interface {
	AddVolumeDiscountProgram(ctx context.Context, referral *entities.VolumeDiscountProgram) error
	UpdateVolumeDiscountProgram(ctx context.Context, referral *entities.VolumeDiscountProgram) error
	EndVolumeDiscountProgram(ctx context.Context, version uint64, endedAt time.Time, vegaTime time.Time, seqNum uint64) error
}

type Vote 

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

func NewVote 

func NewVote(store GovernanceService) *Vote

func (*Vote) Flush 

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

func (*Vote) Push 

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

func (*Vote) SetVegaTime 

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

func (*Vote) Types 

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

type VoteEvent 

type VoteEvent interface {
	events.Event
	ProposalID() string
	PartyID() string
	Vote() vega.Vote
	Value() vega.Vote_Value
}

type Withdrawal 

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

func NewWithdrawal 

func NewWithdrawal(store WithdrawalStore) *Withdrawal

func (*Withdrawal) Flush 

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

func (*Withdrawal) Push 

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

func (*Withdrawal) SetVegaTime 

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

func (*Withdrawal) Types 

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

type WithdrawalEvent 

type WithdrawalEvent interface {
	events.Event
	Withdrawal() vega.Withdrawal
}

type WithdrawalStore 

type WithdrawalStore interface {
	Upsert(context.Context, *entities.Withdrawal) error
}

Source Files

View all Source files

Directories

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.