statetracker

Dec 19, 2024

Changes in this version

+ var DisableDR = false

Dec 2, 2024

Changes in this version

+ const MAINNET_SPEC

+ const TESTNET_SPEC

+ var LavaSpecOptions = []string

+ func IsLavaNativeSpec(checked string) bool

type ConsumerStateTracker

+ StateQuery *updaters.ConsumerStateQuery

type ProviderStateTracker

+ StateQuery *updaters.ProviderStateQuery

Oct 20, 2024

Changes in this version

+ const BlocksToSaveLavaChainTracker

+ const DefaultGasAdjustment

+ const DefaultGasPrice

+ const FlagBreak

+ const FlagDisableInteractiveShell

+ const FlagEventName

+ const FlagHasAttributeName

+ const FlagReset

+ const FlagShowAttributeName

+ const FlagTimeout

+ const FlagValue

+ const RETRY_INCORRECT_SEQUENCE

+ const TendermintConsensusParamsQuery

+ func CreateEventsCobraCommand() *cobra.Command

+ func CreateRelayPaymentCSVCobraCommand() *cobra.Command

+ func CreateTxCounterCobraCommand() *cobra.Command

+ func GetLavaSpecWithRetry(ctx context.Context, specQueryClient spectypes.QueryClient) (*spectypes.QueryGetSpecResponse, error)

+ func RegisterForSpecUpdatesOrSetStaticSpec(ctx context.Context, chainParser chainlib.ChainParser, specPath string, ...) (err error)

+ type ConsumerEmergencyTrackerInf interface

+ GetLatestVirtualEpoch func() uint64

+ type ConsumerStateTracker struct

+ func NewConsumerStateTracker(ctx context.Context, txFactory tx.Factory, clientCtx client.Context, ...) (ret *ConsumerStateTracker, err error)

+ func (cst *ConsumerStateTracker) GetConsumerPolicy(ctx context.Context, consumerAddress, chainID string) (*plantypes.Policy, error)

+ func (cst *ConsumerStateTracker) GetProtocolVersion(ctx context.Context) (*updaters.ProtocolVersionResponse, error)

+ func (cst *ConsumerStateTracker) RegisterConsumerSessionManagerForPairingUpdates(ctx context.Context, ...)

+ func (cst *ConsumerStateTracker) RegisterFinalizationConsensusForUpdates(ctx context.Context, ...)

+ func (cst *ConsumerStateTracker) RegisterForDowntimeParamsUpdates(ctx context.Context, downtimeParamsUpdatable updaters.DowntimeParamsUpdatable) error

+ func (cst *ConsumerStateTracker) RegisterForPairingUpdates(ctx context.Context, pairingUpdatable updaters.PairingUpdatable, specId string)

+ func (cst *ConsumerStateTracker) RegisterForSpecUpdates(ctx context.Context, specUpdatable updaters.SpecUpdatable, ...) error

+ func (cst *ConsumerStateTracker) RegisterForVersionUpdates(ctx context.Context, version *protocoltypes.Version, ...)

+ func (cst *ConsumerStateTracker) TxConflictDetection(ctx context.Context, finalizationConflict *conflicttypes.FinalizationConflict, ...) error

+ type ConsumerTxSender struct

+ func NewConsumerTxSender(ctx context.Context, clientCtx client.Context, txFactory tx.Factory) (ret *ConsumerTxSender, err error)

+ func (ts *ConsumerTxSender) TxSenderConflictDetection(ctx context.Context, finalizationConflict *conflicttypes.FinalizationConflict, ...) error

+ type ConsumerTxSenderInf interface

+ TxSenderConflictDetection func(ctx context.Context, finalizationConflict *conflicttypes.FinalizationConflict, ...) error

+ type EmergencyTracker struct

+ func NewEmergencyTracker(metrics EmergencyTrackerMetrics) (emergencyTracker *EmergencyTracker, ...)

+ func (cs *EmergencyTracker) GetDowntimeParams() downtimev1.Params

+ func (cs *EmergencyTracker) GetLatestVirtualEpoch() uint64

+ func (cs *EmergencyTracker) GetVirtualEpoch(epoch uint64) uint64

+ func (cs *EmergencyTracker) SetDowntimeParams(params downtimev1.Params)

+ func (cs *EmergencyTracker) UpdateEpoch(epoch uint64)

+ type EmergencyTrackerMetrics interface

+ SetVirtualEpoch func(virtualEpoch uint64)

+ type ProviderRewards map[string]map[string]*providerStats

+ type ProviderStateTracker struct

+ func NewProviderStateTracker(ctx context.Context, txFactory tx.Factory, clientCtx client.Context, ...) (ret *ProviderStateTracker, err error)

+ func (pst *ProviderStateTracker) EarliestBlockInMemory(ctx context.Context) (uint64, error)

+ func (pst *ProviderStateTracker) GetAverageBlockTime() time.Duration

+ func (pst *ProviderStateTracker) GetEpochSize(ctx context.Context) (uint64, error)

+ func (pst *ProviderStateTracker) GetEpochSizeMultipliedByRecommendedEpochNumToCollectPayment(ctx context.Context) (uint64, error)

+ func (pst *ProviderStateTracker) GetMaxCuForUser(ctx context.Context, consumerAddress, chainID string, epoch uint64) (maxCu uint64, err error)

+ func (pst *ProviderStateTracker) GetProtocolVersion(ctx context.Context) (*updaters.ProtocolVersionResponse, error)

+ func (pst *ProviderStateTracker) GetRecommendedEpochNumToCollectPayment(ctx context.Context) (uint64, error)

+ func (pst *ProviderStateTracker) LatestBlock() int64

+ func (pst *ProviderStateTracker) RegisterForDowntimeParamsUpdates(ctx context.Context, downtimeParamsUpdatable updaters.DowntimeParamsUpdatable) error

+ func (pst *ProviderStateTracker) RegisterForEpochUpdates(ctx context.Context, epochUpdatable updaters.EpochUpdatable)

+ func (pst *ProviderStateTracker) RegisterForSpecUpdates(ctx context.Context, specUpdatable updaters.SpecUpdatable, ...) error

+ func (pst *ProviderStateTracker) RegisterForSpecVerifications(ctx context.Context, specVerifier updaters.SpecVerifier, chainId string) error

+ func (pst *ProviderStateTracker) RegisterForVersionUpdates(ctx context.Context, version *protocoltypes.Version, ...)

+ func (pst *ProviderStateTracker) RegisterPaymentUpdatableForPayments(ctx context.Context, paymentUpdatable updaters.PaymentUpdatable)

+ func (pst *ProviderStateTracker) RegisterReliabilityManagerForVoteUpdates(ctx context.Context, voteUpdatable updaters.VoteUpdatable, ...)

+ func (pst *ProviderStateTracker) SendVoteCommitment(voteID string, vote *reliabilitymanager.VoteData, specID string) error

+ func (pst *ProviderStateTracker) SendVoteReveal(voteID string, vote *reliabilitymanager.VoteData, specID string) error

+ func (pst *ProviderStateTracker) TxRelayPayment(ctx context.Context, relayRequests []*pairingtypes.RelaySession, ...) error

+ func (pst *ProviderStateTracker) VerifyPairing(ctx context.Context, consumerAddress, providerAddress string, epoch uint64, ...) (valid bool, total int64, projectId string, err error)

+ type ProviderTxSender struct

+ func NewProviderTxSender(ctx context.Context, clientCtx client.Context, txFactory tx.Factory) (ret *ProviderTxSender, err error)

+ func (pts *ProviderTxSender) SendVoteCommitment(ctx context.Context, voteID string, vote *reliabilitymanager.VoteData, ...) error

+ func (pts *ProviderTxSender) SendVoteReveal(ctx context.Context, voteID string, vote *reliabilitymanager.VoteData, ...) error

+ func (pts *ProviderTxSender) TxRelayPayment(ctx context.Context, relayRequests []*pairingtypes.RelaySession, ...) error

+ func (pts *ProviderTxSender) UpdateEpoch(epoch uint64)

+ type SpecUpdaterInf interface

+ RegisterForSpecUpdates func(ctx context.Context, specUpdatable updaters.SpecUpdatable, ...) error

+ type StateTracker struct

+ AverageBlockTime time.Duration

+ EventTracker *updaters.EventTracker

+ func NewStateTracker(ctx context.Context, txFactory tx.Factory, clientCtx client.Context, ...) (ret *StateTracker, err error)

+ func (st *StateTracker) GetAverageBlockTime() time.Duration

+ func (st *StateTracker) GetEventTracker() *updaters.EventTracker

+ func (st *StateTracker) RegisterForUpdates(ctx context.Context, updater Updater) Updater

+ func (st *StateTracker) UpdateBlockTime(blockTime time.Duration)

+ type TxSender struct

+ func NewTxSender(ctx context.Context, clientCtx client.Context, txFactory tx.Factory) (ret *TxSender, err error)

+ func (ts *TxSender) SendTxAndVerifyCommit(txfactory tx.Factory, msg sdk.Msg) (parsedResult common.TxResultData, err error)

+ func (ts *TxSender) SimulateAndBroadCastTxWithRetryOnSeqMismatch(ctx context.Context, msg sdk.Msg, checkProfitability bool, ...) error

+ type Updater interface

+ Reset func(int64)

+ Update func(int64)

+ UpdaterKey func() string