keeper

Documentation

Index

• Constants
• func NewMsgServerImpl(keeper Keeper) types.MsgServer
• type Keeper
  • func NewKeeper(cdc codec.BinaryCodec, storeService store.KVStoreService, logger log.Logger, ...) Keeper
  • func (k Keeper) AddPendingProofIndex(ctx context.Context, proofId []byte)
  • func (k *Keeper) BeginBlocker(ctx context.Context) error
  • func (k Keeper) BitVMChallengeData(goCtx context.Context, req *types.QueryBitVMChallengeDataRequest) (*types.QueryBitVMChallengeDataResponse, error)
  • func (k Keeper) DASubmissionQueue(goCtx context.Context, req *types.QueryDASubmissionQueueRequest) (*types.QueryDASubmissionQueueResponse, error)
  • func (k Keeper) DASubmissionQueueStore(ctx context.Context) prefix.Store
  • func (k Keeper) DASubmissionResultsStore(ctx context.Context) prefix.Store
  • func (k Keeper) DASubmitter(goCtx context.Context, req *types.QueryDASubmitterRequest) (*types.QueryDASubmitterResponse, error)
  • func (k Keeper) DASubmitterStore(ctx context.Context) prefix.Store
  • func (k Keeper) DaSubmissionData(goCtx context.Context, req *types.QueryDaSubmissionDataRequest) (*types.QueryDaSubmissionDataResponse, error)
  • func (k Keeper) DaSubmissionResult(goCtx context.Context, req *types.QueryDaSubmissionResultRequest) (*types.QueryDaSubmissionResultResponse, error)
  • func (k Keeper) DequeueDASubmission(ctx context.Context, proofId []byte)
  • func (k *Keeper) EndBlocker(ctx context.Context) error
  • func (k Keeper) EnqueueDASubmission(ctx context.Context, proofId []byte, daSubmissionData types.DASubmissionData)
  • func (k Keeper) ExportGenesis(ctx context.Context) *types.GenesisState
  • func (k Keeper) GetAuthority() string
  • func (k Keeper) GetBitVMChallengeData(ctx context.Context, proofId []byte) (types.BitVMChallengeData, bool)
  • func (k Keeper) GetBlockProposer(ctx context.Context, height int64) string
  • func (k Keeper) GetDASubmissionData(ctx context.Context, proofId []byte) (types.DASubmissionData, bool)
  • func (k Keeper) GetDASubmissionQueue(ctx context.Context, pagination *query.PageRequest) ([]types.DASubmissionData, *query.PageResponse, error)
  • func (k Keeper) GetDASubmissionResult(ctx context.Context, proofId []byte) (types.DASubmissionResult, bool)
  • func (k Keeper) GetDASubmitter(ctx context.Context) string
  • func (k Keeper) GetParams(ctx context.Context) (params types.Params)
  • func (k Keeper) GetProofData(ctx context.Context, proofId []byte) (types.ProofData, bool)
  • func (k Keeper) GetProofId(proofData types.ProofData) ([32]byte, error)
  • func (k Keeper) GetVerifyResult(ctx context.Context, proofId []byte) (types.VerifyResult, bool)
  • func (k Keeper) InitGenesis(ctx context.Context, gs types.GenesisState) error
  • func (k Keeper) IsPendingProof(ctx context.Context, proofId []byte) bool
  • func (k Keeper) Logger() log.Logger
  • func (k Keeper) Params(goCtx context.Context, req *types.QueryParamsRequest) (*types.QueryParamsResponse, error)
  • func (k Keeper) PendingProof(goCtx context.Context, req *types.QueryPendingProofRequest) (*types.QueryPendingProofResponse, error)
  • func (k Keeper) PendingProofByNamespace(goCtx context.Context, req *types.QueryPendingProofByNamespaceRequest) (*types.QueryPendingProofByNamespaceResponse, error)
  • func (k Keeper) PendingProofsIndexStore(ctx context.Context) prefix.Store
  • func (k Keeper) ProofData(goCtx context.Context, req *types.QueryProofDataRequest) (*types.QueryProofDataResponse, error)
  • func (k Keeper) RemovePendingProofIndex(ctx context.Context, proofId []byte)
  • func (k Keeper) SetBitVMChallengeData(ctx context.Context, proofId []byte, challengeData types.BitVMChallengeData)
  • func (k Keeper) SetBlockProposer(ctx context.Context, height int64, proposer string)
  • func (k Keeper) SetDASubmissionResult(ctx context.Context, proofId []byte, result *types.DASubmissionResult)
  • func (k Keeper) SetDASubmitter(ctx context.Context, submitter string)
  • func (k Keeper) SetParams(ctx context.Context, params types.Params) error
  • func (k Keeper) SetProofData(ctx context.Context, proofId []byte, proofData types.ProofData)
  • func (k Keeper) SetVerifyResult(ctx sdk.Context, proofId []byte, verifyResult types.VerifyResult)
  • func (k Keeper) VerifyResult(goCtx context.Context, req *types.QueryVerifyResultRequest) (*types.QueryVerifyResultResponse, error)
  • func (k Keeper) VerifyResultStore(ctx context.Context) prefix.Store
  • func (k Keeper) VerifyResultsByNamespace(goCtx context.Context, req *types.QueryVerifyResultsByNamespaceRequest) (*types.QueryVerifyResultsByNamespaceResponse, error)

Constants

const (
	VerificationCountLimit uint64 = 4
)

Functions

func NewMsgServerImpl

func NewMsgServerImpl(keeper Keeper) types.MsgServer

NewMsgServerImpl returns an implementation of the MsgServer interface for the provided Keeper.

Types

type Keeper

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

func NewKeeper

func NewKeeper(
	cdc codec.BinaryCodec,
	storeService store.KVStoreService,
	logger log.Logger,
	authority string,

	stakingKeeper types.StakingKeeper,
	bitvmstakerKeeper types.BitvmstakerKeeper,
) Keeper

func (Keeper) AddPendingProofIndex

func (k Keeper) AddPendingProofIndex(ctx context.Context, proofId []byte)

AddPendingProofIndex adds a proof ID to the pending proofs index

func (*Keeper) BeginBlocker

func (k *Keeper) BeginBlocker(ctx context.Context) error

BeginBlocker will persist the current header and validator set as a historical entry and prune the oldest entry based on the HistoricalEntries parameter

func (Keeper) BitVMChallengeData

func (k Keeper) BitVMChallengeData(goCtx context.Context, req *types.QueryBitVMChallengeDataRequest) (*types.QueryBitVMChallengeDataResponse, error)

func (Keeper) DASubmissionQueue

func (k Keeper) DASubmissionQueue(goCtx context.Context, req *types.QueryDASubmissionQueueRequest) (*types.QueryDASubmissionQueueResponse, error)

func (Keeper) DASubmissionQueueStore

func (k Keeper) DASubmissionQueueStore(ctx context.Context) prefix.Store

DASubmissionQueueStore returns a prefix store for the DA submission data

func (Keeper) DASubmissionResultsStore

func (k Keeper) DASubmissionResultsStore(ctx context.Context) prefix.Store

DASubmissionResultsStore returns a prefix store for the DA submission results

func (Keeper) DASubmitter

func (k Keeper) DASubmitter(goCtx context.Context, req *types.QueryDASubmitterRequest) (*types.QueryDASubmitterResponse, error)

func (Keeper) DASubmitterStore

func (k Keeper) DASubmitterStore(ctx context.Context) prefix.Store

DASubmitterStore returns a prefix store for the DA submitter

func (Keeper) DaSubmissionData

func (k Keeper) DaSubmissionData(goCtx context.Context, req *types.QueryDaSubmissionDataRequest) (*types.QueryDaSubmissionDataResponse, error)

func (Keeper) DaSubmissionResult

func (k Keeper) DaSubmissionResult(goCtx context.Context, req *types.QueryDaSubmissionResultRequest) (*types.QueryDaSubmissionResultResponse, error)

func (Keeper) DequeueDASubmission

func (k Keeper) DequeueDASubmission(ctx context.Context, proofId []byte)

func (*Keeper) EndBlocker

func (k *Keeper) EndBlocker(ctx context.Context) error

EndBlocker Called every block, update validator set

func (Keeper) EnqueueDASubmission

func (k Keeper) EnqueueDASubmission(ctx context.Context, proofId []byte, daSubmissionData types.DASubmissionData)

func (Keeper) ExportGenesis

func (k Keeper) ExportGenesis(ctx context.Context) *types.GenesisState

ExportGenesis returns the module's exported genesis

func (Keeper) GetAuthority

func (k Keeper) GetAuthority() string

GetAuthority returns the module's authority.

func (Keeper) GetBitVMChallengeData

func (k Keeper) GetBitVMChallengeData(ctx context.Context, proofId []byte) (types.BitVMChallengeData, bool)

GetBitVMChallengeData retrieves witness data from the chain

func (Keeper) GetBlockProposer

func (k Keeper) GetBlockProposer(ctx context.Context, height int64) string

func (Keeper) GetDASubmissionData

func (k Keeper) GetDASubmissionData(ctx context.Context, proofId []byte) (types.DASubmissionData, bool)

func (Keeper) GetDASubmissionQueue

func (k Keeper) GetDASubmissionQueue(ctx context.Context, pagination *query.PageRequest) ([]types.DASubmissionData, *query.PageResponse, error)

func (Keeper) GetDASubmissionResult

func (k Keeper) GetDASubmissionResult(ctx context.Context, proofId []byte) (types.DASubmissionResult, bool)

func (Keeper) GetDASubmitter

func (k Keeper) GetDASubmitter(ctx context.Context) string

func (Keeper) GetParams

func (k Keeper) GetParams(ctx context.Context) (params types.Params)

GetParams get all parameters as types.Params

func (Keeper) GetProofData

func (k Keeper) GetProofData(ctx context.Context, proofId []byte) (types.ProofData, bool)

GetProofData retrieves proof information

func (Keeper) GetProofId

func (k Keeper) GetProofId(proofData types.ProofData) ([32]byte, error)

GetProofId returns the proof id

func (Keeper) GetVerifyResult

func (k Keeper) GetVerifyResult(ctx context.Context, proofId []byte) (types.VerifyResult, bool)

GetVerifyResult retrieves proof verification information

func (Keeper) InitGenesis

func (k Keeper) InitGenesis(ctx context.Context, gs types.GenesisState) error

InitGenesis initializes the module's state from a provided genesis state.

func (Keeper) IsPendingProof

func (k Keeper) IsPendingProof(ctx context.Context, proofId []byte) bool

IsPendingProof checks if a proof ID is in the pending proofs index

func (Keeper) Logger

func (k Keeper) Logger() log.Logger

Logger returns a module-specific logger.

func (Keeper) Params

func (k Keeper) Params(goCtx context.Context, req *types.QueryParamsRequest) (*types.QueryParamsResponse, error)

func (Keeper) PendingProof

func (k Keeper) PendingProof(goCtx context.Context, req *types.QueryPendingProofRequest) (*types.QueryPendingProofResponse, error)

func (Keeper) PendingProofByNamespace

func (k Keeper) PendingProofByNamespace(goCtx context.Context, req *types.QueryPendingProofByNamespaceRequest) (*types.QueryPendingProofByNamespaceResponse, error)

func (Keeper) PendingProofsIndexStore

func (k Keeper) PendingProofsIndexStore(ctx context.Context) prefix.Store

PendingProofsIndexStore returns a prefix store for the pending proofs index

func (Keeper) ProofData

func (k Keeper) ProofData(goCtx context.Context, req *types.QueryProofDataRequest) (*types.QueryProofDataResponse, error)

func (Keeper) RemovePendingProofIndex

func (k Keeper) RemovePendingProofIndex(ctx context.Context, proofId []byte)

RemovePendingProofIndex removes a proof ID from the pending proofs index

func (Keeper) SetBitVMChallengeData

func (k Keeper) SetBitVMChallengeData(ctx context.Context, proofId []byte, challengeData types.BitVMChallengeData)

SetBitVMChallengeData stores witness data

func (Keeper) SetBlockProposer

func (k Keeper) SetBlockProposer(ctx context.Context, height int64, proposer string)

func (Keeper) SetDASubmissionResult

func (k Keeper) SetDASubmissionResult(ctx context.Context, proofId []byte, result *types.DASubmissionResult)

func (Keeper) SetDASubmitter

func (k Keeper) SetDASubmitter(ctx context.Context, submitter string)

func (Keeper) SetParams

func (k Keeper) SetParams(ctx context.Context, params types.Params) error

SetParams set the params

func (Keeper) SetProofData

func (k Keeper) SetProofData(ctx context.Context, proofId []byte, proofData types.ProofData)

SetProofData stores proof information

func (Keeper) SetVerifyResult

func (k Keeper) SetVerifyResult(ctx sdk.Context, proofId []byte, verifyResult types.VerifyResult)

SetVerifyResult stores proof verification information

func (Keeper) VerifyResult

func (k Keeper) VerifyResult(goCtx context.Context, req *types.QueryVerifyResultRequest) (*types.QueryVerifyResultResponse, error)

func (Keeper) VerifyResultStore

func (k Keeper) VerifyResultStore(ctx context.Context) prefix.Store

func (Keeper) VerifyResultsByNamespace

func (k Keeper) VerifyResultsByNamespace(goCtx context.Context, req *types.QueryVerifyResultsByNamespaceRequest) (*types.QueryVerifyResultsByNamespaceResponse, error)