Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

baseapp

package

Go to main page

Versions in this module

v3

v3.1.3

Jul 10, 2024

v3.1.2

Jul 9, 2024

v3.1.1

Jul 9, 2024

Changes in this version

+ const InitialAppVersion

+ const Paramspace

+ const QueryPathApp

+ const QueryPathBroadcastTx

+ const QueryPathCustom

+ const QueryPathP2P

+ const QueryPathStore

+ const StreamingABCIKeysTomlKey

+ const StreamingABCIPluginTomlKey

+ const StreamingABCIStopNodeOnErrTomlKey

+ const StreamingABCITomlKey

+ const StreamingTomlKey

+ var ParamStoreKeyBlockParams = []byte("BlockParams")

+ var ParamStoreKeyEvidenceParams = []byte("EvidenceParams")

+ var ParamStoreKeyValidatorParams = []byte("ValidatorParams")

+ func DefaultStoreLoader(ms storetypes.CommitMultiStore) error

+ func GetConsensusParams(ctx sdk.Context, paramStore LegacyParamStore) *cmtproto.ConsensusParams

+ func MigrateParams(ctx sdk.Context, lps LegacyParamStore, ps ParamStore) error

+ func NoOpExtendVote() sdk.ExtendVoteHandler

+ func NoOpPrepareProposal() sdk.PrepareProposalHandler

+ func NoOpProcessProposal() sdk.ProcessProposalHandler

+ func NoOpVerifyVoteExtensionHandler() sdk.VerifyVoteExtensionHandler

+ func SetChainID(chainID string) func(*BaseApp)

+ func SetHaltHeight(blockHeight uint64) func(*BaseApp)

+ func SetHaltTime(haltTime uint64) func(*BaseApp)

+ func SetIAVLCacheSize(size int) func(*BaseApp)

+ func SetIAVLDisableFastNode(disable bool) func(*BaseApp)

+ func SetIndexEvents(ie []string) func(*BaseApp)

+ func SetInterBlockCache(cache storetypes.MultiStorePersistentCache) func(*BaseApp)

+ func SetMempool(mempool mempool.Mempool) func(*BaseApp)

+ func SetMinGasPrices(gasPricesStr string) func(*BaseApp)

+ func SetMinRetainBlocks(minRetainBlocks uint64) func(*BaseApp)

+ func SetOptimisticExecution(opts ...func(*oe.OptimisticExecution)) func(*BaseApp)

+ func SetPruning(opts pruningtypes.PruningOptions) func(*BaseApp)

+ func SetQueryGasLimit(queryGasLimit uint64) func(*BaseApp)

+ func SetSnapshot(snapshotStore *snapshots.Store, opts snapshottypes.SnapshotOptions) func(*BaseApp)

+ func SetStoreLoader(loader StoreLoader) func(*BaseApp)

+ func SetTrace(trace bool) func(*BaseApp)

+ func SplitABCIQueryPath(requestPath string) (path []string)

+ func ValidateBlockParams(i interface{}) error

+ func ValidateEvidenceParams(i interface{}) error

+ func ValidateValidatorParams(i interface{}) error

+ func ValidateVoteExtensions(ctx sdk.Context, valStore ValidatorStore, extCommit abci.ExtendedCommitInfo) error

+ type AuthKeeper interface

+ GetAccount func(ctx context.Context, addr sdk.AccAddress) sdk.AccountI

+ type BankKeeper interface

+ GetBalance func(ctx context.Context, addr sdk.AccAddress, denom string) sdk.Coin

+ MintCoins func(ctx context.Context, moduleName string, amt sdk.Coins) error

+ SendCoinsFromModuleToAccount func(ctx context.Context, senderModule string, recipientAddr sdk.AccAddress, ...) error

+ type BaseApp struct

+ func NewBaseApp(name string, logger log.Logger, db dbm.DB, txDecoder sdk.TxDecoder, ...) *BaseApp

+ func (app *BaseApp) AddRunTxRecoveryHandler(handlers ...RecoveryHandler)

+ func (app *BaseApp) AnteHandler() sdk.AnteHandler

+ func (app *BaseApp) AppVersion(ctx context.Context) (uint64, error)

+ func (app *BaseApp) ApplySnapshotChunk(req *abci.ApplySnapshotChunkRequest) (*abci.ApplySnapshotChunkResponse, error)

+ func (app *BaseApp) ChainID() string

+ func (app *BaseApp) CheckTx(req *abci.CheckTxRequest) (*abci.CheckTxResponse, error)

+ func (app *BaseApp) Close() error

+ func (app *BaseApp) Commit() (*abci.CommitResponse, error)

+ func (app *BaseApp) CommitMultiStore() storetypes.CommitMultiStore

+ func (app *BaseApp) CreateQueryContext(height int64, prove bool) (sdk.Context, error)

+ func (app *BaseApp) ExtendVote(_ context.Context, req *abci.ExtendVoteRequest) (resp *abci.ExtendVoteResponse, err error)

+ func (app *BaseApp) FilterPeerByAddrPort(info string) *abci.QueryResponse

+ func (app *BaseApp) FilterPeerByID(info string) *abci.QueryResponse

+ func (app *BaseApp) FinalizeBlock(req *abci.FinalizeBlockRequest) (res *abci.FinalizeBlockResponse, err error)

+ func (app *BaseApp) GRPCQueryRouter() *GRPCQueryRouter

+ func (app *BaseApp) GetBaseApp() *BaseApp

+ func (app *BaseApp) GetBlockRetentionHeight(commitHeight int64) int64

+ func (app *BaseApp) GetConsensusParams(ctx context.Context) cmtproto.ConsensusParams

+ func (app *BaseApp) GetContextForCheckTx(txBytes []byte) sdk.Context

+ func (app *BaseApp) GetContextForFinalizeBlock(txBytes []byte) sdk.Context

+ func (app *BaseApp) GetMaximumBlockGas(ctx sdk.Context) uint64

+ func (app *BaseApp) Info(_ *abci.InfoRequest) (*abci.InfoResponse, error)

+ func (app *BaseApp) Init() error

+ func (app *BaseApp) InitChain(req *abci.InitChainRequest) (*abci.InitChainResponse, error)

+ func (app *BaseApp) IsSealed() bool

+ func (app *BaseApp) LastBlockHeight() int64

+ func (app *BaseApp) LastCommitID() storetypes.CommitID

+ func (app *BaseApp) ListSnapshots(req *abci.ListSnapshotsRequest) (*abci.ListSnapshotsResponse, error)

+ func (app *BaseApp) LoadLatestVersion() error

+ func (app *BaseApp) LoadSnapshotChunk(req *abci.LoadSnapshotChunkRequest) (*abci.LoadSnapshotChunkResponse, error)

+ func (app *BaseApp) LoadVersion(version int64) error

+ func (app *BaseApp) Logger() log.Logger

+ func (app *BaseApp) Mempool() mempool.Mempool

+ func (app *BaseApp) MountKVStores(keys map[string]*storetypes.KVStoreKey)

+ func (app *BaseApp) MountMemoryStores(keys map[string]*storetypes.MemoryStoreKey)

+ func (app *BaseApp) MountStore(key storetypes.StoreKey, typ storetypes.StoreType)

+ func (app *BaseApp) MountStores(keys ...storetypes.StoreKey)

+ func (app *BaseApp) MountTransientStores(keys map[string]*storetypes.TransientStoreKey)

+ func (app *BaseApp) MsgServiceRouter() *MsgServiceRouter

+ func (app *BaseApp) Name() string

+ func (app *BaseApp) NewContext(isCheckTx bool) sdk.Context

+ func (app *BaseApp) NewContextLegacy(isCheckTx bool, header cmtproto.Header) sdk.Context

+ func (app *BaseApp) NewUncachedContext(isCheckTx bool, header cmtproto.Header) sdk.Context

+ func (app *BaseApp) OfferSnapshot(req *abci.OfferSnapshotRequest) (*abci.OfferSnapshotResponse, error)

+ func (app *BaseApp) PreBlocker() sdk.PreBlocker

+ func (app *BaseApp) PrepareProposal(req *abci.PrepareProposalRequest) (resp *abci.PrepareProposalResponse, err error)

+ func (app *BaseApp) PrepareProposalVerifyTx(tx sdk.Tx) ([]byte, error)

+ func (app *BaseApp) ProcessProposal(req *abci.ProcessProposalRequest) (resp *abci.ProcessProposalResponse, err error)

+ func (app *BaseApp) ProcessProposalVerifyTx(txBz []byte) (sdk.Tx, error)

+ func (app *BaseApp) Query(_ context.Context, req *abci.QueryRequest) (resp *abci.QueryResponse, err error)

+ func (app *BaseApp) RegisterGRPCServer(server gogogrpc.Server)

+ func (app *BaseApp) RegisterStreamingServices(appOpts servertypes.AppOptions, keys map[string]*storetypes.KVStoreKey) error

+ func (app *BaseApp) Seal()

+ func (app *BaseApp) SetAddrPeerFilter(pf sdk.PeerFilter)

+ func (app *BaseApp) SetAnteHandler(ah sdk.AnteHandler)

+ func (app *BaseApp) SetAppVersion(ctx context.Context, v uint64) error

+ func (app *BaseApp) SetBeginBlocker(beginBlocker sdk.BeginBlocker)

+ func (app *BaseApp) SetCMS(cms storetypes.CommitMultiStore)

+ func (app *BaseApp) SetCircuitBreaker(cb CircuitBreaker)

+ func (app *BaseApp) SetCommitMultiStoreTracer(w io.Writer)

+ func (app *BaseApp) SetDB(db dbm.DB)

+ func (app *BaseApp) SetEndBlocker(endBlocker sdk.EndBlocker)

+ func (app *BaseApp) SetExtendVoteHandler(handler sdk.ExtendVoteHandler)

+ func (app *BaseApp) SetFauxMerkleMode()

+ func (app *BaseApp) SetGRPCQueryRouter(grpcQueryRouter *GRPCQueryRouter)

+ func (app *BaseApp) SetIDPeerFilter(pf sdk.PeerFilter)

+ func (app *BaseApp) SetInitChainer(initChainer sdk.InitChainer)

+ func (app *BaseApp) SetInterfaceRegistry(registry types.InterfaceRegistry)

+ func (app *BaseApp) SetMempool(mempool mempool.Mempool)

+ func (app *BaseApp) SetMsgServiceRouter(msgServiceRouter *MsgServiceRouter)

+ func (app *BaseApp) SetName(name string)

+ func (app *BaseApp) SetNotSigverifyTx()

+ func (app *BaseApp) SetParamStore(ps ParamStore)

+ func (app *BaseApp) SetPostHandler(ph sdk.PostHandler)

+ func (app *BaseApp) SetPreBlocker(preBlocker sdk.PreBlocker)

+ func (app *BaseApp) SetPrecommiter(precommiter sdk.Precommiter)

+ func (app *BaseApp) SetPrepareCheckStater(prepareCheckStater sdk.PrepareCheckStater)

+ func (app *BaseApp) SetPrepareProposal(handler sdk.PrepareProposalHandler)

+ func (app *BaseApp) SetProcessProposal(handler sdk.ProcessProposalHandler)

+ func (app *BaseApp) SetQueryMultiStore(ms storetypes.MultiStore)

+ func (app *BaseApp) SetSnapshot(snapshotStore *snapshots.Store, opts snapshottypes.SnapshotOptions)

+ func (app *BaseApp) SetStoreLoader(loader StoreLoader)

+ func (app *BaseApp) SetStoreMetrics(gatherer metrics.StoreMetrics)

+ func (app *BaseApp) SetStreamingManager(manager storetypes.StreamingManager)

+ func (app *BaseApp) SetTxDecoder(txDecoder sdk.TxDecoder)

+ func (app *BaseApp) SetTxEncoder(txEncoder sdk.TxEncoder)

+ func (app *BaseApp) SetVerifyVoteExtensionHandler(handler sdk.VerifyVoteExtensionHandler)

+ func (app *BaseApp) SetVersion(v string)

+ func (app *BaseApp) SimCheck(txEncoder sdk.TxEncoder, tx sdk.Tx) (sdk.GasInfo, *sdk.Result, error)

+ func (app *BaseApp) SimDeliver(txEncoder sdk.TxEncoder, tx sdk.Tx) (sdk.GasInfo, *sdk.Result, error)

+ func (app *BaseApp) Simulate(txBytes []byte) (sdk.GasInfo, *sdk.Result, error)

+ func (app *BaseApp) SnapshotManager() *snapshots.Manager

+ func (app *BaseApp) StoreConsensusParams(ctx context.Context, cp cmtproto.ConsensusParams) error

+ func (app *BaseApp) Trace() bool

+ func (app *BaseApp) TxDecode(txBytes []byte) (sdk.Tx, error)

+ func (app *BaseApp) TxEncode(tx sdk.Tx) ([]byte, error)

+ func (app *BaseApp) VerifyVoteExtension(req *abci.VerifyVoteExtensionRequest) (resp *abci.VerifyVoteExtensionResponse, err error)

+ func (app *BaseApp) Version() string

+ func (ba *BaseApp) ExecuteGenesisTx(tx []byte) error

+ type CircuitBreaker interface

+ IsAllowed func(ctx context.Context, typeURL string) (bool, error)

+ type DefaultProposalHandler struct

+ func NewDefaultProposalHandler(mp mempool.Mempool, txVerifier ProposalTxVerifier) *DefaultProposalHandler

+ func (h *DefaultProposalHandler) PrepareProposalHandler() sdk.PrepareProposalHandler

+ func (h *DefaultProposalHandler) ProcessProposalHandler() sdk.ProcessProposalHandler

+ func (h *DefaultProposalHandler) SetTxSelector(ts TxSelector)

+ type GRPCQueryHandler = func(ctx sdk.Context, req *abci.QueryRequest) (*abci.QueryResponse, error)

+ type GRPCQueryRouter struct

+ func NewGRPCQueryRouter() *GRPCQueryRouter

+ func (qrt *GRPCQueryRouter) HybridHandlerByRequestName(name string) []func(ctx context.Context, req, resp protoiface.MessageV1) error

+ func (qrt *GRPCQueryRouter) RegisterService(sd *grpc.ServiceDesc, handler interface{})

+ func (qrt *GRPCQueryRouter) ResponseNameByRequestName(requestName string) string

+ func (qrt *GRPCQueryRouter) Route(path string) GRPCQueryHandler

+ func (qrt *GRPCQueryRouter) SetInterfaceRegistry(interfaceRegistry codectypes.InterfaceRegistry)

+ type GasTx interface

+ GetGas func() uint64

+ type LegacyParamStore interface

+ Get func(ctx sdk.Context, key []byte, ptr interface{})

+ Has func(ctx sdk.Context, key []byte) bool

+ type MessageRouter interface

+ Handler func(msg sdk.Msg) MsgServiceHandler

+ HandlerByTypeURL func(typeURL string) MsgServiceHandler

+ HybridHandlerByMsgName func(msgName string) func(ctx context.Context, req, resp protoiface.MessageV1) error

+ ResponseNameByMsgName func(msgName string) string

+ type MsgServiceHandler = func(ctx sdk.Context, req sdk.Msg) (*sdk.Result, error)

+ type MsgServiceRouter struct

+ func NewMsgServiceRouter() *MsgServiceRouter

+ func (msr *MsgServiceRouter) Handler(msg sdk.Msg) MsgServiceHandler

+ func (msr *MsgServiceRouter) HandlerByTypeURL(typeURL string) MsgServiceHandler

+ func (msr *MsgServiceRouter) HybridHandlerByMsgName(msgName string) func(ctx context.Context, req, resp protoiface.MessageV1) error

+ func (msr *MsgServiceRouter) RegisterService(sd *grpc.ServiceDesc, handler interface{})

+ func (msr *MsgServiceRouter) ResponseNameByMsgName(msgName string) string

+ func (msr *MsgServiceRouter) SetCircuit(cb CircuitBreaker)

+ func (msr *MsgServiceRouter) SetInterfaceRegistry(interfaceRegistry codectypes.InterfaceRegistry)

+ type ParamStore interface

+ Get func(ctx context.Context) (cmtproto.ConsensusParams, error)

+ Has func(ctx context.Context) (bool, error)

+ Set func(ctx context.Context, cp cmtproto.ConsensusParams) error

+ type ProposalTxVerifier interface

+ PrepareProposalVerifyTx func(tx sdk.Tx) ([]byte, error)

+ ProcessProposalVerifyTx func(txBz []byte) (sdk.Tx, error)

+ TxDecode func(txBz []byte) (sdk.Tx, error)

+ TxEncode func(tx sdk.Tx) ([]byte, error)

+ type QueryRouter interface

+ HybridHandlerByRequestName func(name string) []func(ctx context.Context, req, resp protoiface.MessageV1) error

+ RegisterService func(sd *grpc.ServiceDesc, handler interface{})

+ ResponseNameByRequestName func(requestName string) string

+ Route func(path string) GRPCQueryHandler

+ SetInterfaceRegistry func(interfaceRegistry codectypes.InterfaceRegistry)

+ type QueryServiceTestHelper struct

+ Ctx sdk.Context

+ func NewQueryServerTestHelper(ctx sdk.Context, interfaceRegistry types.InterfaceRegistry) *QueryServiceTestHelper

+ func (q *QueryServiceTestHelper) Invoke(_ gocontext.Context, method string, args, reply interface{}, ...) error

+ func (q *QueryServiceTestHelper) NewStream(gocontext.Context, *grpc.StreamDesc, string, ...grpc.CallOption) (grpc.ClientStream, error)

+ type RecoveryHandler func(recoveryObj interface{}) error

+ type StoreLoader func(ms storetypes.CommitMultiStore) error

+ type TxSelector interface

+ Clear func()

+ SelectTxForProposal func(ctx context.Context, maxTxBytes, maxBlockGas uint64, memTx sdk.Tx, txBz []byte) bool

+ SelectedTxs func(ctx context.Context) [][]byte

+ func NewDefaultTxSelector() TxSelector

+ type ValidatorStore interface

+ GetPubKeyByConsAddr func(context.Context, sdk.ConsAddress) (cryptotypes.PubKey, error)

Other modules containing this package

github.com/T-ragon/cosmos-sdk