sqlsubscribers

package
v0.0.0-...-f6bc33c Latest Latest
Warning

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

Go to latest
Published: Apr 28, 2023 License: MIT 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) SetZetaTime

func (s *Account) SetZetaTime(zetaTime time.Time)

func (*Account) Types

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

type AccountEvent

type AccountEvent interface {
	events.Event
	Account() zeta.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) SetZetaTime

func (s *Asset) SetZetaTime(zetaTime time.Time)

func (*Asset) Types

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

type AssetEvent

type AssetEvent interface {
	events.Event
	Asset() zeta.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) SetZetaTime

func (s *Checkpoint) SetZetaTime(zetaTime 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

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) SetZetaTime

func (s *Delegation) SetZetaTime(zetaTime 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) SetZetaTime

func (s *Deposit) SetZetaTime(zetaTime time.Time)

func (*Deposit) Types

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

type DepositEvent

type DepositEvent interface {
	events.Event
	Deposit() zeta.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) SetZetaTime

func (s *ERC20MultiSigSignerEvent) SetZetaTime(zetaTime 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) SetZetaTime

func (s *Epoch) SetZetaTime(zetaTime 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) SetZetaTime

func (s *EthereumKeyRotation) SetZetaTime(zetaTime 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

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

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) SetZetaTime

func (s *KeyRotation) SetZetaTime(zetaTime 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(*zeta.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) SetZetaTime

func (s *LiquidityProvision) SetZetaTime(zetaTime time.Time)

func (*LiquidityProvision) Types

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

type LiquidityProvisionEvent

type LiquidityProvisionEvent interface {
	events.Event
	LiquidityProvision() *zeta.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) *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) SetZetaTime

func (s *MarginLevels) SetZetaTime(zetaTime time.Time)

func (*MarginLevels) Types

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

type MarginLevelsEvent

type MarginLevelsEvent interface {
	events.Event
	MarginLevels() zeta.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) SetZetaTime

func (s *MarketCreated) SetZetaTime(zetaTime time.Time)

func (*MarketCreated) Types

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

type MarketCreatedEvent

type MarketCreatedEvent interface {
	events.Event
	Market() zeta.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) SetZetaTime

func (s *MarketData) SetZetaTime(zetaTime 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, zetaTime time.Time, sequenceNumber uint64)
	PublishAtEndOfBlock()
}

type MarketSvc

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) SetZetaTime

func (s *MarketUpdated) SetZetaTime(zetaTime time.Time)

func (*MarketUpdated) Types

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

type MarketUpdatedEvent

type MarketUpdatedEvent interface {
	events.Event
	Market() zeta.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) SetZetaTime

func (s *NetworkLimits) SetZetaTime(zetaTime time.Time)

func (*NetworkLimits) Types

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

type NetworkLimitsEvent

type NetworkLimitsEvent interface {
	events.Event
	NetworkLimits() *zeta.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) SetZetaTime

func (s *NetworkParameter) SetZetaTime(zetaTime time.Time)

func (*NetworkParameter) Types

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

type NetworkParameterEvent

type NetworkParameterEvent interface {
	events.Event
	NetworkParameter() zeta.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) SetZetaTime

func (s *Node) SetZetaTime(zetaTime 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) SetZetaTime

func (s *Notary) SetZetaTime(zetaTime 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) SetZetaTime

func (s *OracleData) SetZetaTime(zetaTime time.Time)

func (*OracleData) Types

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

type OracleDataEvent

type OracleDataEvent interface {
	events.Event
	OracleData() zetapb.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) SetZetaTime

func (s *OracleSpec) SetZetaTime(zetaTime time.Time)

func (*OracleSpec) Types

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

type OracleSpecEvent

type OracleSpecEvent interface {
	events.Event
	OracleSpec() zetapb.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) SetZetaTime

func (s *Order) SetZetaTime(zetaTime time.Time)

func (*Order) Types

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

type OrderEvent

type OrderEvent interface {
	events.Event
	Order() *zeta.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 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) SetZetaTime

func (s *Party) SetZetaTime(zetaTime 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, 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) SetZetaTime

func (s *Position) SetZetaTime(zetaTime 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) SetZetaTime

func (s *Proposal) SetZetaTime(zetaTime time.Time)

func (*Proposal) Types

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

type ProposalEvent

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

type ProtocolUpgrade

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

func NewProtocolUpgrade

func NewProtocolUpgrade(store pupAdder) *ProtocolUpgrade

func (*ProtocolUpgrade) Flush

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

func (*ProtocolUpgrade) Push

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

func (*ProtocolUpgrade) SetZetaTime

func (s *ProtocolUpgrade) SetZetaTime(zetaTime time.Time)

func (*ProtocolUpgrade) Types

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

type ProtocolUpgradeProposalEvent

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

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) SetZetaTime

func (s *Reward) SetZetaTime(zetaTime 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) SetZetaTime

func (s *RiskFactor) SetZetaTime(zetaTime time.Time)

func (*RiskFactor) Types

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

type RiskFactorEvent

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

type RiskFactorStore

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

type SnapshotData

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

func NewSnapshotData

func NewSnapshotData(store snapAdder) *SnapshotData

func (*SnapshotData) Flush

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

func (*SnapshotData) Push

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

func (*SnapshotData) SetZetaTime

func (s *SnapshotData) SetZetaTime(zetaTime time.Time)

func (*SnapshotData) Types

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) SetZetaTime

func (s *StakeLinking) SetZetaTime(zetaTime 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) *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) SetZetaTime

func (s *TradeSubscriber) SetZetaTime(zetaTime 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) SetZetaTime

func (s *Transfer) SetZetaTime(zetaTime 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) *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) SetZetaTime

func (s *TransferResponse) SetZetaTime(zetaTime time.Time)

func (*TransferResponse) Types

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

type TransferResponseEvent

type TransferResponseEvent interface {
	events.Event
	LedgerMovements() []*zeta.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) *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) SetZetaTime

func (s *Vote) SetZetaTime(zetaTime time.Time)

func (*Vote) Types

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

type VoteEvent

type VoteEvent interface {
	events.Event
	ProposalID() string
	PartyID() string
	Vote() zeta.Vote
	Value() zeta.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) SetZetaTime

func (s *Withdrawal) SetZetaTime(zetaTime time.Time)

func (*Withdrawal) Types

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

type WithdrawalEvent

type WithdrawalEvent interface {
	events.Event
	Withdrawal() zeta.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