statetracker

Documentation

Index

• Constants
• type ConsumerStateTracker
  • func (cst *ConsumerStateTracker) New(ctx context.Context, txFactory tx.Factory, clientCtx client.Context) (ret *ConsumerStateTracker, err error)
  • func (cst *ConsumerStateTracker) RegisterApiParserForSpecUpdates(ctx context.Context, chainParser chainlib.ChainParser)
  • func (cst *ConsumerStateTracker) RegisterConsumerSessionManagerForPairingUpdates(ctx context.Context, ...)
  • func (cst *ConsumerStateTracker) RegisterFinalizationConsensusForUpdates(ctx context.Context, finalizationConsensus *lavaprotocol.FinalizationConsensus)
  • func (cst *ConsumerStateTracker) TxConflictDetection(ctx context.Context, finalizationConflict *conflicttypes.FinalizationConflict, ...)
• type FinalizationConsensusUpdater
  • func NewFinalizationConsensusUpdater(consumerAddress sdk.AccAddress, stateQuery *StateQuery) *FinalizationConsensusUpdater
  • func (fcu *FinalizationConsensusUpdater) RegisterFinalizationConsensus(finalizationConsensus *lavaprotocol.FinalizationConsensus)
  • func (fcu *FinalizationConsensusUpdater) Update(latestBlock int64)
  • func (fcu *FinalizationConsensusUpdater) UpdaterKey() string
• type PairingUpdater
  • func NewPairingUpdater(consumerAddress sdk.AccAddress, stateQuery *StateQuery) *PairingUpdater
  • func (pu *PairingUpdater) RegisterPairing(consumerSessionManager *lavasession.ConsumerSessionManager)
  • func (pu *PairingUpdater) Update(latestBlock int64)
  • func (pu *PairingUpdater) UpdaterKey() string
• type StateQuery
  • func (sq *StateQuery) GetPairing(latestBlock int64) (pairingList []epochstoragetypes.StakeEntry, epoch uint64, ...)
  • func (sq *StateQuery) New(ctx context.Context, clientCtx client.Context) (ret *StateQuery, err error)
• type TxSender
  • func (ts *TxSender) New(ctx context.Context, txFactory tx.Factory, clientCtx client.Context) (ret *TxSender, err error)
  • func (ts *TxSender) TxConflictDetection(ctx context.Context, finalizationConflict *conflicttypes.FinalizationConflict, ...)
• type Updater

Constants

const (
	CallbackKeyForFinalizationConsensusUpdate = "finalization-consensus-update"
)

const (
	CallbackKeyForPairingUpdate = "pairing-update"
)

Types

type ConsumerStateTracker

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

ConsumerStateTracker CSTis a class for tracking consumer data from the lava blockchain, such as epoch changes. it allows also to query specific data form the blockchain and acts as a single place to send transactions

func (*ConsumerStateTracker) New

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

func (*ConsumerStateTracker) RegisterApiParserForSpecUpdates

func (cst *ConsumerStateTracker) RegisterApiParserForSpecUpdates(ctx context.Context, chainParser chainlib.ChainParser)

func (*ConsumerStateTracker) RegisterConsumerSessionManagerForPairingUpdates

func (cst *ConsumerStateTracker) RegisterConsumerSessionManagerForPairingUpdates(ctx context.Context, consumerSessionManager *lavasession.ConsumerSessionManager)

func (*ConsumerStateTracker) RegisterFinalizationConsensusForUpdates

func (cst *ConsumerStateTracker) RegisterFinalizationConsensusForUpdates(ctx context.Context, finalizationConsensus *lavaprotocol.FinalizationConsensus)

func (*ConsumerStateTracker) TxConflictDetection

func (cst *ConsumerStateTracker) TxConflictDetection(ctx context.Context, finalizationConflict *conflicttypes.FinalizationConflict, responseConflict *conflicttypes.ResponseConflict, sameProviderConflict *conflicttypes.FinalizationConflict)

type FinalizationConsensusUpdater

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

func NewFinalizationConsensusUpdater

func NewFinalizationConsensusUpdater(consumerAddress sdk.AccAddress, stateQuery *StateQuery) *FinalizationConsensusUpdater

func (*FinalizationConsensusUpdater) RegisterFinalizationConsensus

func (fcu *FinalizationConsensusUpdater) RegisterFinalizationConsensus(finalizationConsensus *lavaprotocol.FinalizationConsensus)

func (*FinalizationConsensusUpdater) Update

func (fcu *FinalizationConsensusUpdater) Update(latestBlock int64)

func (*FinalizationConsensusUpdater) UpdaterKey

func (fcu *FinalizationConsensusUpdater) UpdaterKey() string

type PairingUpdater

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

func NewPairingUpdater

func NewPairingUpdater(consumerAddress sdk.AccAddress, stateQuery *StateQuery) *PairingUpdater

func (*PairingUpdater) RegisterPairing

func (pu *PairingUpdater) RegisterPairing(consumerSessionManager *lavasession.ConsumerSessionManager)

func (*PairingUpdater) Update

func (pu *PairingUpdater) Update(latestBlock int64)

func (*PairingUpdater) UpdaterKey

func (pu *PairingUpdater) UpdaterKey() string

type StateQuery

type StateQuery struct{}

func (*StateQuery) GetPairing

func (sq *StateQuery) GetPairing(latestBlock int64) (pairingList []epochstoragetypes.StakeEntry, epoch uint64, nextBlockForUpdate uint64)

func (*StateQuery) New

func (sq *StateQuery) New(ctx context.Context, clientCtx client.Context) (ret *StateQuery, err error)

type TxSender

type TxSender struct{}

func (*TxSender) New

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

func (*TxSender) TxConflictDetection

func (ts *TxSender) TxConflictDetection(ctx context.Context, finalizationConflict *conflicttypes.FinalizationConflict, responseConflict *conflicttypes.ResponseConflict, sameProviderConflict *conflicttypes.FinalizationConflict)

type Updater

type Updater interface {
	Update(int64)
	UpdaterKey() string
}