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 (*ERC20MultiSigSignerEvent) Flush

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

func (*ERC20MultiSigSignerEvent) Push

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 (*FundingPaymentSubscriber) Push added in v0.73.0

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 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 (*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 (*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 (*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 (*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
}

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