Documentation ¶
Index ¶
- Variables
- func NewEventDeduplicator[K comparable, V proto.Message](getId func(context.Context, V, time.Time) (K, error)) *eventDeduplicator[K, V]
- type Account
- type AccountEvent
- type AccountService
- type AccountSource
- type Asset
- type AssetEvent
- type AssetStore
- type Checkpoint
- type CheckpointEvent
- type CheckpointStore
- type Delegation
- type DelegationBalanceEvent
- type DelegationStore
- type Deposit
- type DepositEvent
- type DepositStore
- type ERC20MultiSigSignerAddedEvent
- type ERC20MultiSigSignerEvent
- type ERC20MultiSigSignerEventStore
- type ERC20MultiSigSignerRemovedEvent
- type Epoch
- type EpochStore
- type EpochUpdateEvent
- type EthereumKeyRotation
- type EthereumKeyRotationEvent
- type EthereumKeyRotationService
- type GovernanceService
- type KeyRotation
- type KeyRotationEvent
- type KeyRotationStore
- type Ledger
- type LiquidityProvision
- type LiquidityProvisionEvent
- type LiquidityProvisionStore
- type MarginLevels
- type MarginLevelsEvent
- type MarginLevelsStore
- type MarketCreated
- type MarketCreatedEvent
- type MarketData
- type MarketDataEvent
- type MarketDataStore
- type MarketDepth
- type MarketDepthService
- type MarketUpdated
- type MarketUpdatedEvent
- type MarketsStore
- type NetworkLimitStore
- type NetworkLimits
- type NetworkLimitsEvent
- type NetworkParameter
- type NetworkParameterEvent
- type NetworkParameterStore
- type Node
- type NodeSignatureEvent
- type NodeStore
- type Notary
- type NotaryStore
- type OracleData
- type OracleDataEvent
- type OracleDataStore
- type OracleSpec
- type OracleSpecEvent
- type OracleSpecStore
- type Order
- type OrderEvent
- type OrderStore
- type Party
- type PartyEvent
- type PartyStore
- type Position
- type PositionStore
- type Proposal
- type ProposalEvent
- type Reward
- type RewardPayoutEvent
- type RewardStore
- type RiskFactor
- type RiskFactorEvent
- type RiskFactorStore
- type StakeLinking
- type StakeLinkingEvent
- type StakeLinkingStore
- type TradeEvent
- type TradeSubscriber
- type TradesStore
- type Transfer
- type TransferEvent
- type TransferResponse
- type TransferResponseEvent
- type TransferStore
- type ValidatorRankingScoreEvent
- type ValidatorRewardScoreEvent
- type ValidatorUpdateEvent
- type Vote
- type VoteEvent
- type Withdrawal
- type WithdrawalEvent
- type WithdrawalStore
Constants ¶
This section is empty.
Variables ¶
View Source
var ErrNoSignaturesForID = errors.New("no signatures for id")
Functions ¶
func NewEventDeduplicator ¶
Types ¶
type Account ¶
type Account struct {
// contains filtered or unexported fields
}
func NewAccount ¶
func NewAccount( accounts AccountService, log *logging.Logger, ) *Account
func (*Account) SetVegaTime ¶
type AccountService ¶
type AccountSource ¶
type Asset ¶
type Asset struct {
// contains filtered or unexported fields
}
func (*Asset) SetVegaTime ¶
type Checkpoint ¶
type Checkpoint struct {
// contains filtered or unexported fields
}
func NewCheckpoint ¶
func NewCheckpoint( store CheckpointStore, log *logging.Logger, ) *Checkpoint
func (*Checkpoint) SetVegaTime ¶
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) SetVegaTime ¶
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) SetVegaTime ¶
type DepositStore ¶
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) SetVegaTime ¶
func (*ERC20MultiSigSignerEvent) Types ¶
func (t *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 (*Epoch) SetVegaTime ¶
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) SetVegaTime ¶
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 KeyRotation ¶
type KeyRotation struct {
// contains filtered or unexported fields
}
func NewKeyRotation ¶
func NewKeyRotation(store KeyRotationStore, log *logging.Logger) *KeyRotation
func (*KeyRotation) SetVegaTime ¶
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.TransferResponse) 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) SetVegaTime ¶
func (*LiquidityProvision) Types ¶
func (lp *LiquidityProvision) Types() []events.Type
type LiquidityProvisionEvent ¶
type LiquidityProvisionEvent interface { events.Event LiquidityProvision() *vega.LiquidityProvision }
type LiquidityProvisionStore ¶
type MarginLevels ¶
type MarginLevels struct {
// contains filtered or unexported fields
}
func NewMarginLevels ¶
func NewMarginLevels(store MarginLevelsStore, accountSource AccountSource, log *logging.Logger) *MarginLevels
func (*MarginLevels) SetVegaTime ¶
func (*MarginLevels) Types ¶
func (ml *MarginLevels) Types() []events.Type
type MarginLevelsEvent ¶
type MarginLevelsEvent interface { events.Event MarginLevels() vega.MarginLevels }
type MarginLevelsStore ¶
type MarketCreated ¶
type MarketCreated struct {
// contains filtered or unexported fields
}
func NewMarketCreated ¶
func NewMarketCreated(store MarketsStore, log *logging.Logger) *MarketCreated
func (*MarketCreated) SetVegaTime ¶
func (*MarketCreated) Types ¶
func (m *MarketCreated) Types() []events.Type
type MarketData ¶
type MarketData struct {
// contains filtered or unexported fields
}
func NewMarketData ¶
func NewMarketData(store MarketDataStore, log *logging.Logger) *MarketData
func (*MarketData) SetVegaTime ¶
func (*MarketData) Types ¶
func (md *MarketData) Types() []events.Type
type MarketDataEvent ¶
type MarketDataEvent interface { events.Event MarketData() types.MarketData }
type MarketDataStore ¶
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) SetVegaTime ¶
func (*MarketDepth) Types ¶
func (m *MarketDepth) Types() []events.Type
type MarketDepthService ¶
type MarketUpdated ¶
type MarketUpdated struct {
// contains filtered or unexported fields
}
func NewMarketUpdated ¶
func NewMarketUpdated(store MarketsStore, log *logging.Logger) *MarketUpdated
func (*MarketUpdated) SetVegaTime ¶
func (*MarketUpdated) Types ¶
func (m *MarketUpdated) Types() []events.Type
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) SetVegaTime ¶
func (*NetworkLimits) Types ¶
func (t *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) SetVegaTime ¶
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 (*Node) SetVegaTime ¶
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 AddNodeAnnoucedEvent(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 (*Notary) SetVegaTime ¶
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) SetVegaTime ¶
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) SetVegaTime ¶
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 (*Order) SetVegaTime ¶
type OrderStore ¶
type Party ¶
type Party struct {
// contains filtered or unexported fields
}
func (*Party) SetVegaTime ¶
type Position ¶
type Position struct {
// contains filtered or unexported fields
}
func NewPosition ¶
func NewPosition( store PositionStore, log *logging.Logger, ) *Position
func (*Position) SetVegaTime ¶
type PositionStore ¶
type Proposal ¶
type Proposal struct {
// contains filtered or unexported fields
}
func NewProposal ¶
func (*Proposal) SetVegaTime ¶
type ProposalEvent ¶
type Reward ¶
type Reward struct {
// contains filtered or unexported fields
}
func (*Reward) SetVegaTime ¶
type RewardPayoutEvent ¶
type RewardPayoutEvent interface { events.Event RewardPayoutEvent() eventspb.RewardPayoutEvent }
type RiskFactor ¶
type RiskFactor struct {
// contains filtered or unexported fields
}
func NewRiskFactor ¶
func NewRiskFactor(store RiskFactorStore, log *logging.Logger) *RiskFactor
func (*RiskFactor) SetVegaTime ¶
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) SetVegaTime ¶
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 TradeSubscriber ¶
type TradeSubscriber struct {
// contains filtered or unexported fields
}
func NewTradesSubscriber ¶
func NewTradesSubscriber(store TradesStore, log *logging.Logger) *TradeSubscriber
func (*TradeSubscriber) SetVegaTime ¶
func (*TradeSubscriber) Types ¶
func (ts *TradeSubscriber) Types() []events.Type
type TradesStore ¶
type Transfer ¶
type Transfer struct {
// contains filtered or unexported fields
}
func NewTransfer ¶
func NewTransfer(store TransferStore, accountSource AccountSource, log *logging.Logger) *Transfer
func (*Transfer) SetVegaTime ¶
type TransferEvent ¶
type TransferResponse ¶
type TransferResponse struct {
// contains filtered or unexported fields
}
func NewTransferResponse ¶
func NewTransferResponse( ledger Ledger, accounts AccountService, log *logging.Logger, ) *TransferResponse
func (*TransferResponse) SetVegaTime ¶
func (*TransferResponse) Types ¶
func (t *TransferResponse) Types() []events.Type
type TransferResponseEvent ¶
type TransferResponseEvent interface { events.Event TransferResponses() []*vega.TransferResponse }
type TransferStore ¶
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 (*Vote) SetVegaTime ¶
type Withdrawal ¶
type Withdrawal struct {
// contains filtered or unexported fields
}
func NewWithdrawal ¶
func NewWithdrawal(store WithdrawalStore, log *logging.Logger) *Withdrawal
func (*Withdrawal) SetVegaTime ¶
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 ¶
- account.go
- asset.go
- checkpoint.go
- delegations.go
- deposits.go
- epoch.go
- erc20_multisig_event.go
- ethereum_key_rotation.go
- event_deduplicator.go
- key_rotation.go
- liquidity_provision.go
- margin_levels.go
- market_created.go
- market_data.go
- market_depth.go
- market_updated.go
- network_limits.go
- network_parameters.go
- node.go
- notary.go
- oracle_data.go
- oracle_spec.go
- order.go
- party.go
- position.go
- proposal.go
- rewards.go
- risk_factors.go
- stake_linking.go
- subscriber.go
- trades.go
- transfer_response.go
- transfers.go
- vote.go
- withdrawals.go
Click to show internal directories.
Click to hide internal directories.