sqlsubscribers

package
v0.58.0 Latest Latest
Warning

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

 Go to latest Published: Oct 11, 2022 License: MIT Imports: 19 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,
	log *logging.Logger,
) *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(id entities.AccountID) (entities.Account, error)
}

type Asset 

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

func NewAsset 

func NewAsset(store AssetStore, log *logging.Logger) *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,
	log *logging.Logger,
) *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 Delegation 

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

func NewDelegation 

func NewDelegation(
	store DelegationStore,
	log *logging.Logger,
) *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, log *logging.Logger) *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, log *logging.Logger) *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,
	log *logging.Logger,
) *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, log *logging.Logger) *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 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, log *logging.Logger) *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, log *logging.Logger) *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 MarginLevels 

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

func NewMarginLevels 

func NewMarginLevels(store MarginLevelsStore, accountSource AccountSource, log *logging.Logger) *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, log *logging.Logger) *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, log *logging.Logger) *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 MarketDepth 

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

func NewMarketDepth 

func NewMarketDepth(depthService MarketDepthService) *MarketDepth

NewMarketDepthBuilder constructor to create a market depth subscriber.

func (*MarketDepth) Flush 

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

func (*MarketDepth) Push 

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

func (*MarketDepth) SetVegaTime 

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

func (*MarketDepth) Types 

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

type MarketDepthService 

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

type MarketUpdated 

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

func NewMarketUpdated 

func NewMarketUpdated(store MarketsStore, log *logging.Logger) *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(
	ctx context.Context,
	store NetworkLimitStore,
	log *logging.Logger,
) *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,
	log *logging.Logger,
) *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, log *logging.Logger) *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, log *logging.Logger) *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, log *logging.Logger) *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() oraclespb.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, log *logging.Logger) *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() oraclespb.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, log *logging.Logger) *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
}

type Party 

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

func NewParty 

func NewParty(
	store PartyStore,
	log *logging.Logger,
) *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 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,
	log *logging.Logger,
) *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)
	Flush(ctx context.Context) error
}

type Proposal 

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

func NewProposal 

func NewProposal(
	store proposalAdder,
	log *logging.Logger,
) *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 Reward 

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

func NewReward 

func NewReward(
	store RewardStore,
	log *logging.Logger,
) *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, log *logging.Logger) *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 StakeLinking 

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

func NewStakeLinking 

func NewStakeLinking(store StakeLinkingStore, log *logging.Logger) *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 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, log *logging.Logger) *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, log *logging.Logger) *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 TransferResponse 

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

func NewTransferResponse 

func NewTransferResponse(
	ledger Ledger,
	accounts AccountService,
	log *logging.Logger,
) *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
}

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 Vote 

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

func NewVote 

func NewVote(
	store GovernanceService,
	log *logging.Logger,
) *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, log *logging.Logger) *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.