app

package
v4.0.0-rc0 Latest Latest
Warning

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

 Go to latest Published: Apr 17, 2025 License: Apache-2.0 Imports: 149 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	DefaultInitialVersion = appv4.Version
)
View Source 
const EnvPrefix = "CELESTIA"

EnvPrefix is the environment variable prefix for celestia-appd. Environment variables that Cobra reads must be prefixed with this value.

View Source 
const Name = "celestia-app"

Name is the name of the application.

View Source 
const UpgradeName = "v4"

UpgradeName defines the on-chain upgrade name from v3 to v4. IMPORTANT: UpgradeName must be formated as `v`+ app version.

Variables

View Source 
var DefaultNodeHome string

DefaultNodeHome is the default home directory for the application daemon. This gets set as a side-effect of the init() function.

View Source 
var ModuleEncodingRegisters = []module.AppModuleBasic{

	auth.AppModuleBasic{},
	authzmodule.AppModuleBasic{},
	bankModule{},
	capability.AppModuleBasic{},
	circuitModule{},
	consensus.AppModuleBasic{},
	distribution.AppModuleBasic{},
	evidence.AppModuleBasic{},
	feegrantmodule.AppModuleBasic{},
	genutil.AppModuleBasic{},
	govModule{},
	params.AppModuleBasic{},
	slashingModule{},
	stakingModule{},
	upgrade.AppModuleBasic{},
	vesting.AppModuleBasic{},

	ibcModule{},
	transfer.AppModuleBasic{},
	packetforward.AppModuleBasic{},
	icaModule{},
	ibctm.AppModuleBasic{},
	solomachine.AppModuleBasic{},

	hyperlanecore.AppModule{},
	warp.AppModule{},

	blob.AppModule{},
	minfee.AppModule{},
	mintModule{},
	signal.AppModule{},
}

ModuleEncodingRegisters keeps track of all the module methods needed to register interfaces and specific type to encoding config

Functions

func DefaultAppConfig 

func DefaultAppConfig() *serverconfig.Config

func DefaultBlockParams 

func DefaultBlockParams() *tmproto.BlockParams

DefaultBlockParams returns a default BlockParams with a MaxBytes determined using a goal square size.

func DefaultConsensusConfig 

func DefaultConsensusConfig() *tmcfg.Config

func DefaultConsensusParams 

func DefaultConsensusParams() *tmproto.ConsensusParams

DefaultConsensusParams returns a ConsensusParams with a MaxBytes determined using a goal square size.

func DefaultEvidenceParams 

func DefaultEvidenceParams() *tmproto.EvidenceParams

DefaultEvidenceParams returns a default EvidenceParams with a MaxAge determined using a goal block time.

func DefaultInitialConsensusParams 

func DefaultInitialConsensusParams() *tmproto.ConsensusParams

func FilterTxs 

func FilterTxs(logger log.Logger, ctx sdk.Context, handler sdk.AnteHandler, txConfig client.TxConfig, txs [][]byte) [][]byte

FilterTxs applies the antehandler to all proposed transactions and removes transactions that return an error.

Side-effect: arranges all normal transactions before all blob transactions.

Types

type App 

type App struct {
	*baseapp.BaseApp

	// keepers
	AccountKeeper       authkeeper.AccountKeeper
	BankKeeper          bankkeeper.Keeper
	AuthzKeeper         authzkeeper.Keeper
	ConsensusKeeper     consensuskeeper.Keeper
	CapabilityKeeper    *capabilitykeeper.Keeper
	StakingKeeper       *stakingkeeper.Keeper
	SlashingKeeper      slashingkeeper.Keeper
	MintKeeper          mintkeeper.Keeper
	DistrKeeper         distrkeeper.Keeper
	GovKeeper           *govkeeper.Keeper
	UpgradeKeeper       *upgradekeeper.Keeper // Upgrades are set in endblock when signaled
	SignalKeeper        signal.Keeper
	MinFeeKeeper        *minfeekeeper.Keeper
	ParamsKeeper        paramskeeper.Keeper
	IBCKeeper           *ibckeeper.Keeper // IBCKeeper must be a pointer in the app, so we can SetRouter on it correctly
	EvidenceKeeper      evidencekeeper.Keeper
	TransferKeeper      ibctransferkeeper.Keeper
	FeeGrantKeeper      feegrantkeeper.Keeper
	ICAHostKeeper       icahostkeeper.Keeper
	PacketForwardKeeper *packetforwardkeeper.Keeper
	BlobKeeper          blobkeeper.Keeper
	CircuitKeeper       circuitkeeper.Keeper
	HyperlaneKeeper     hyperlanekeeper.Keeper
	WarpKeeper          warpkeeper.Keeper

	ScopedIBCKeeper      capabilitykeeper.ScopedKeeper // This keeper is public for test purposes
	ScopedTransferKeeper capabilitykeeper.ScopedKeeper // This keeper is public for test purposes
	ScopedICAHostKeeper  capabilitykeeper.ScopedKeeper // This keeper is public for test purposes

	BasicManager  module.BasicManager
	ModuleManager *module.Manager
	// contains filtered or unexported fields
}

App extends an ABCI application, but with most of its parameters exported. They are exported for convenience in creating helper functions, as object capabilities aren't needed for testing.

func New 

func New(
	logger log.Logger,
	db dbm.DB,
	traceStore io.Writer,
	timeoutCommit time.Duration,
	appOpts servertypes.AppOptions,
	baseAppOptions ...func(*baseapp.BaseApp),
) *App

New returns a reference to an uninitialized app. Callers must subsequently call app.Info or app.InitChain to initialize the baseapp.

func (*App) AppCodec 

func (app *App) AppCodec() codec.Codec

AppCodec implements the TestingApp interface.

func (*App) AutoCliOpts 

func (app *App) AutoCliOpts() autocli.AppOptions

AutoCliOpts returns the autocli options for the app.

func (*App) BeginBlocker 

func (app *App) BeginBlocker(ctx sdk.Context) (sdk.BeginBlock, error)

BeginBlocker application updates every begin block

func (*App) BlockedAddresses 

func (app *App) BlockedAddresses() map[string]bool

BlockedAddresses returns all the app's blocked account addresses.

func (*App) CheckTx 

func (app *App) CheckTx(req *abci.RequestCheckTx) (*abci.ResponseCheckTx, error)

CheckTx implements the ABCI interface and executes a tx in CheckTx mode. This method wraps the default Baseapp's method so that it can parse and check transactions that contain blobs.

func (*App) DefaultGenesis 

func (app *App) DefaultGenesis() GenesisState

DefaultGenesis returns the default genesis state

func (*App) EndBlocker 

func (app *App) EndBlocker(ctx sdk.Context) (sdk.EndBlock, error)

EndBlocker executes application updates at the end of every block.

func (*App) ExportAppStateAndValidators 

func (app *App) ExportAppStateAndValidators(
	forZeroHeight bool, jailAllowedAddrs []string, _ []string,
) (servertypes.ExportedApp, error)

ExportAppStateAndValidators exports the state of the application for a genesis file.

func (*App) GetBaseApp 

func (app *App) GetBaseApp() *baseapp.BaseApp

GetBaseApp implements the TestingApp interface.

func (*App) GetEncodingConfig 

func (app *App) GetEncodingConfig() encoding.Config

GetEncodingConfig returns the app encoding config.

func (*App) GetIBCKeeper 

func (app *App) GetIBCKeeper() *ibckeeper.Keeper

GetIBCKeeper implements the TestingApp interface.

func (*App) GetKey 

func (app *App) GetKey(storeKey string) *storetypes.KVStoreKey

GetKey returns the KVStoreKey for the provided store key.

NOTE: This is solely to be used for testing purposes.

func (*App) GetMemKey 

func (app *App) GetMemKey(storeKey string) *storetypes.MemoryStoreKey

GetMemKey returns the MemStoreKey for the provided mem key.

NOTE: This is solely used for testing purposes.

func (*App) GetScopedIBCKeeper 

func (app *App) GetScopedIBCKeeper() capabilitykeeper.ScopedKeeper

GetScopedIBCKeeper implements the TestingApp interface.

func (*App) GetStakingKeeper 

func (app *App) GetStakingKeeper() ibctestingtypes.StakingKeeper

GetStakingKeeper implements the TestingApp interface.

func (*App) GetSubspace 

func (app *App) GetSubspace(moduleName string) paramstypes.Subspace

GetSubspace returns a param subspace for a given module name.

NOTE: This is solely to be used for testing purposes.

func (*App) GetTKey 

func (app *App) GetTKey(storeKey string) *storetypes.TransientStoreKey

GetTKey returns the TransientStoreKey for the provided store key.

NOTE: This is solely to be used for testing purposes.

func (*App) GetTxConfig 

func (app *App) GetTxConfig() client.TxConfig

GetTxConfig implements the TestingApp interface.

func (*App) GovParamFilters 

func (app *App) GovParamFilters() map[string]ante.ParamFilter

GovParamFilters returns the params that require a hardfork to change, and cannot be changed via governance.

func (*App) Info 

func (app *App) Info(req *abci.RequestInfo) (*abci.ResponseInfo, error)

Info implements the abci interface. It overrides baseapp's Info method, essentially becoming a decorator in order to assign TimeoutInfo values in the response.

func (*App) InitChainer 

func (app *App) InitChainer(ctx sdk.Context, req *abci.RequestInitChain) (*abci.ResponseInitChain, error)

InitChainer is middleware that gets invoked part-way through the baseapp's InitChain invocation.

func (*App) LoadHeight 

func (app *App) LoadHeight(height int64) error

LoadHeight loads a particular height

func (*App) MaxEffectiveSquareSize 

func (app *App) MaxEffectiveSquareSize(ctx sdk.Context) int

MaxEffectiveSquareSize returns the max effective square size.

func (*App) ModuleAccountAddrs 

func (app *App) ModuleAccountAddrs() map[string]bool

ModuleAccountAddrs returns all the app's module account addresses.

func (*App) Name 

func (app *App) Name() string

Name returns the name of the App

func (*App) NewProposalContext 

func (app *App) NewProposalContext(header tmproto.Header) sdk.Context

NewProposalContext returns a context with a branched version of the state that is safe to query during ProcessProposal.

func (*App) PreBlocker 

func (app *App) PreBlocker(ctx sdk.Context, _ *abci.RequestFinalizeBlock) (*sdk.ResponsePreBlock, error)

PreBlocker application updates every pre block

func (*App) PrepareProposalHandler 

func (app *App) PrepareProposalHandler(ctx sdk.Context, req *abci.RequestPrepareProposal) (*abci.ResponsePrepareProposal, error)

PrepareProposal fulfills the celestia-core version of the ABCI interface by preparing the proposal block data. This method generates the data root for the proposal block and passes it back to tendermint via the BlockData. Panics indicate a developer error and should immediately halt the node for visibility and so they can be quickly resolved.

func (*App) ProcessProposalHandler 

func (app *App) ProcessProposalHandler(ctx sdk.Context, req *abci.RequestProcessProposal) (resp *abci.ResponseProcessProposal, err error)

func (*App) RegisterAPIRoutes 

func (app *App) RegisterAPIRoutes(apiSvr *api.Server, _ config.APIConfig)

RegisterAPIRoutes registers all application module routes with the provided API server.

func (*App) RegisterNodeService 

func (app *App) RegisterNodeService(clientCtx client.Context, cfg config.Config)

func (*App) RegisterTendermintService 

func (app *App) RegisterTendermintService(clientCtx client.Context)

RegisterTendermintService implements the Application.RegisterTendermintService method.

func (*App) RegisterTxService 

func (app *App) RegisterTxService(clientCtx client.Context)

RegisterTxService implements the Application.RegisterTxService method.

func (App) RegisterUpgradeHandlers 

func (app App) RegisterUpgradeHandlers()

func (*App) TimeoutCommit 

func (app *App) TimeoutCommit() time.Duration

TimeoutCommit returns the timeout commit duration to be used on the next block. It returns the user specified value as overridden by the --timeout-commit flag, otherwise the default timeout commit value for the current app version.

func (*App) TimeoutPropose 

func (app *App) TimeoutPropose() time.Duration

TimeoutPropose returns the timeout propose duration to be used on the next block. It returns the default timeout propose value for the current app version.

type GenesisState 

type GenesisState map[string]json.RawMessage

The genesis state of the blockchain is represented here as a map of raw json messages key'd by an identifier string. The identifier is used to determine which module genesis information belongs to so it may be appropriately routed during init chain. Within this application default genesis information is retrieved from the ModuleBasicManager which populates json from each BasicModule object provided to it during init.

Source Files

View all Source files

Directories

Path Synopsis
grpc
gasestimation
tx
Package tx is a reverse proxy.
 Package tx is a reverse proxy.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.
JackTT - Gopher 🇻🇳