app

package
v6.0.0-...-542b673 Latest Latest
Warning

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

 Go to latest Published: Mar 10, 2026 License: Apache-2.0 Imports: 153 Imported by: 0

Documentation

Index

Constants

View Source 
const EnvPrefix = "CELESTIA_APP"

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.

Variables

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{},
	fibre.AppModule{},
	minfee.AppModule{},
	mintModule{},
	signal.AppModule{},
	valaddr.AppModule{},
}

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

View Source 
var NodeHome string

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

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 default consensus params.

func EvidenceParams 

func EvidenceParams() *tmproto.EvidenceParams

EvidenceParams returns the evidence params defined in CIP-37. The evidence parameters are not modifiable by governance so a consensus breaking release is needed to modify the evidence parameters.

func IcaAllowMessages 

func IcaAllowMessages() []string

IcaAllowMessages returns the list of messages that are allowed to be sent via ICA.

func NewPayForFibreHandler 

func NewPayForFibreHandler(txConfig client.TxConfig) square.PayForFibreHandler

NewPayForFibreHandler creates a new PayForFibreHandler for celestia-app.

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
	ValAddrKeeper       valaddrkeeper.Keeper
	FibreKeeper         *fibrekeeper.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,
	delayedPrecommitTimeout 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. Setting delayedPrecommitTimeout to 0 will result in using the default value.

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)

PrepareProposalHandler 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. Errors are returned instead of panicking to improve error handling and reduce attack surface.

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

RegisterUpgradeHandlers is used for registering any on-chain upgrades.

func (App) SetEvidenceParams 

func (app App) SetEvidenceParams(ctx context.Context) error

func (App) SetMinCommissionRate 

func (a App) SetMinCommissionRate(ctx context.Context) error

func (App) SetUnbondingTime 

func (app App) SetUnbondingTime(ctx context.Context) error

func (*App) TimeoutInfo 

func (app *App) TimeoutInfo() abci.TimeoutInfo

func (*App) TreePool 

func (app *App) TreePool() *wrapper.TreePool

TreePool returns the instance used for managing a pool of Merkle trees.

func (App) UpdateValidatorCommissionRates 

func (a App) UpdateValidatorCommissionRates(ctx context.Context) error

UpdateValidatorCommissionRates iterates over all validators and increases their commission rate and max commission rate if they are below the new minimum commission rate.

type FilteredSquareBuilder 

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

FilteredSquareBuilder filters txs and blobs using a copy of the state and tx validity rules before adding it the square.

func NewFilteredSquareBuilder 

func NewFilteredSquareBuilder(
	handler sdk.AnteHandler,
	txConfig client.TxConfig,
	maxSquareSize,
	subtreeRootThreshold int,
) (*FilteredSquareBuilder, error)

func (*FilteredSquareBuilder) Build 

func (fsb *FilteredSquareBuilder) Build() (square.Square, error)

func (*FilteredSquareBuilder) Builder 

func (fsb *FilteredSquareBuilder) Builder() *square.Builder

func (*FilteredSquareBuilder) Fill 

func (fsb *FilteredSquareBuilder) Fill(ctx sdk.Context, txs [][]byte) [][]byte

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.