Documentation ¶
Index ¶
- Variables
- type Account
- type AccountEvent
- type AccountService
- type AccountSource
- type Asset
- type AssetEvent
- type AssetStore
- type Checkpoint
- type CheckpointEvent
- type CheckpointStore
- type CoreSnapshotEvent
- 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 ExpiredOrdersEvent
- type FeeStatsEvent
- type FundingPaymentSubscriber
- type FundingPaymentsEvent
- type FundingPaymentsStore
- type FundingPeriod
- type FundingPeriodDataPointEvent
- type FundingPeriodEvent
- type FundingPeriodStore
- 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 MarketDepthService
- type MarketSvc
- 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 PartyActivityStreak
- type PartyActivityStreakEvent
- type PartyActivityStreakStore
- type PartyEvent
- type PartyStore
- type Position
- type PositionStore
- type Proposal
- type ProposalEvent
- type ProtocolUpgrade
- type ProtocolUpgradeProposalEvent
- type RefereeJoinedReferralSetEvent
- type RefereeJoinedTeam
- type RefereeSwitchedTeam
- type ReferralFeeStats
- type ReferralFeeStatsStore
- type ReferralProgram
- type ReferralProgramEndedEvent
- type ReferralProgramStartedEvent
- type ReferralProgramUpdatedEvent
- type ReferralSetCreatedEvent
- type ReferralSetStatsUpdatedEvent
- type ReferralSets
- type ReferralSetsStore
- type ReferralStore
- type Reward
- type RewardPayoutEvent
- type RewardStore
- type RiskFactor
- type RiskFactorEvent
- type RiskFactorStore
- type SnapshotData
- type StakeLinking
- type StakeLinkingEvent
- type StakeLinkingStore
- type StopOrder
- type StopOrderEvent
- type StopOrderStore
- type TeamCreatedEvent
- type TeamStore
- type TeamUpdateEvent
- type Teams
- type TradeEvent
- type TradeSubscriber
- type TradesStore
- type Transfer
- type TransferEvent
- type TransferResponse
- type TransferResponseEvent
- type TransferStore
- type ValidatorRankingScoreEvent
- type ValidatorRewardScoreEvent
- type ValidatorUpdateEvent
- type VestingStatsUpdated
- type VestingStatsUpdatedEvent
- type VestingStatsUpdatedStore
- type VolumeDiscountProgram
- type VolumeDiscountProgramEndedEvent
- type VolumeDiscountProgramStartedEvent
- type VolumeDiscountProgramUpdatedEvent
- type VolumeDiscountStatsUpdated
- type VolumeDiscountStatsUpdatedEvent
- type VolumeDiscountStatsUpdatedStore
- type VolumeDiscountStore
- 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 ¶
This section is empty.
Types ¶
type Account ¶
type Account struct {
// contains filtered or unexported fields
}
func NewAccount ¶
func NewAccount(accounts AccountService) *Account
func (*Account) SetVegaTime ¶
type AccountService ¶
type AccountSource ¶
type Asset ¶
type Asset struct {
// contains filtered or unexported fields
}
func NewAsset ¶
func NewAsset(store AssetStore) *Asset
func (*Asset) SetVegaTime ¶
type Checkpoint ¶
type Checkpoint struct {
// contains filtered or unexported fields
}
func NewCheckpoint ¶
func NewCheckpoint(store CheckpointStore) *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 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) 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) *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) *ERC20MultiSigSignerEvent
func (*ERC20MultiSigSignerEvent) SetVegaTime ¶
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) 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) *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 ExpiredOrdersEvent ¶ added in v0.68.0
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) SetVegaTime ¶ added in v0.73.0
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) SetVegaTime ¶ added in v0.73.0
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 KeyRotation ¶
type KeyRotation struct {
// contains filtered or unexported fields
}
func NewKeyRotation ¶
func NewKeyRotation(store KeyRotationStore) *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.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) 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) *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) *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) *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 MarketDepthService ¶
type MarketUpdated ¶
type MarketUpdated struct {
// contains filtered or unexported fields
}
func NewMarketUpdated ¶
func NewMarketUpdated(store MarketsStore) *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(store NetworkLimitStore) *NetworkLimits
func (*NetworkLimits) SetVegaTime ¶
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) 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 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) 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) *OracleData
func (*OracleData) SetVegaTime ¶
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) SetVegaTime ¶
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) SetVegaTime ¶
type OrderStore ¶
type Party ¶
type Party struct {
// contains filtered or unexported fields
}
func NewParty ¶
func NewParty(store PartyStore) *Party
func (*Party) SetVegaTime ¶
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) SetVegaTime ¶ added in v0.73.0
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 Position ¶
type Position struct {
// contains filtered or unexported fields
}
func NewPosition ¶
func NewPosition(store PositionStore, mktSvc MarketSvc) *Position
func (*Position) SetVegaTime ¶
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) SetVegaTime ¶
type ProposalEvent ¶
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) SetVegaTime ¶ added in v0.61.0
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 ReferralFeeStats ¶
type ReferralFeeStats struct {
// contains filtered or unexported fields
}
func NewReferralFeeStats ¶
func NewReferralFeeStats(store ReferralFeeStatsStore) *ReferralFeeStats
func (*ReferralFeeStats) SetVegaTime ¶
func (*ReferralFeeStats) Types ¶
func (r *ReferralFeeStats) Types() []events.Type
type ReferralFeeStatsStore ¶
type ReferralFeeStatsStore interface {
AddFeeStats(ctx context.Context, feeStats *entities.ReferralFeeStats) error
}
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) SetVegaTime ¶ added in v0.73.0
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) SetVegaTime ¶ added in v0.73.0
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 Reward ¶
type Reward struct {
// contains filtered or unexported fields
}
func NewReward ¶
func NewReward(store RewardStore) *Reward
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) *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 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) SetVegaTime ¶ added in v0.65.0
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) 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 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) SetVegaTime ¶ added in v0.72.0
type StopOrderEvent ¶ added in v0.72.0
type StopOrderEvent interface { events.Event StopOrder() *pbevents.StopOrderEvent }
type StopOrderStore ¶ added in v0.72.0
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 (*Teams) SetVegaTime ¶ added in v0.73.0
type TradeSubscriber ¶
type TradeSubscriber struct {
// contains filtered or unexported fields
}
func NewTradesSubscriber ¶
func NewTradesSubscriber(store TradesStore) *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) *Transfer
func (*Transfer) SetVegaTime ¶
type TransferEvent ¶
type TransferResponse ¶
type TransferResponse struct {
// contains filtered or unexported fields
}
func NewTransferResponse ¶
func NewTransferResponse(ledger Ledger, accounts AccountService) *TransferResponse
func (*TransferResponse) SetVegaTime ¶
func (*TransferResponse) Types ¶
func (t *TransferResponse) Types() []events.Type
type TransferResponseEvent ¶
type TransferResponseEvent interface { events.Event LedgerMovements() []*vega.LedgerMovement }
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 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) SetVegaTime ¶ added in v0.73.0
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) SetVegaTime ¶ added in v0.73.0
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) SetVegaTime ¶ added in v0.73.0
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, 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) SetVegaTime ¶
type Withdrawal ¶
type Withdrawal struct {
// contains filtered or unexported fields
}
func NewWithdrawal ¶
func NewWithdrawal(store WithdrawalStore) *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
- funding_payments.go
- funding_period.go
- key_rotation.go
- ledger_movement.go
- liquidity_provision.go
- margin_levels.go
- market_created.go
- market_data.go
- market_updated.go
- network_limits.go
- network_parameters.go
- node.go
- notary.go
- oracle_data.go
- oracle_spec.go
- order.go
- party.go
- party_activity_streak.go
- position.go
- proposal.go
- protocol_upgrade_proposal.go
- referral_fee_stats.go
- referral_programs.go
- referral_sets.go
- rewards.go
- risk_factors.go
- snapshot_data.go
- stake_linking.go
- stop_orders.go
- subscriber.go
- teams.go
- trades.go
- transfers.go
- vesting_stats_updated.go
- volume_discount_programs.go
- volume_discount_stats_updated.go
- vote.go
- withdrawals.go
Click to show internal directories.
Click to hide internal directories.