Documentation
¶
Overview ¶
Copyright (c) 2023-2024 Nibi, Inc.
Copyright (c) 2023-2024 Nibi, Inc.
Index ¶
- Constants
- func AddCommands(rootCmd *cobra.Command, opts StartOptions, appExport types.AppExporter, ...)
- func AddTxFlags(cmd *cobra.Command) (*cobra.Command, error)
- func ConnectTmWS(tmRPCAddr, tmEndpoint string, logger tmlog.Logger) *rpcclient.WSClient
- func Listen(addr string, config *srvconfig.Config) (net.Listener, error)
- func NewEVMTxIndexCmd() *cobra.Command
- func OpenIndexerDB(rootDir string, backendType dbm.BackendType) (dbm.DB, error)
- func StartCmd(opts StartOptions) *cobra.Command
- func StartEthereumJSONRPC(ctx *server.Context, clientCtx client.Context, tmRPCAddr, tmEndpoint string, ...) (*http.Server, chan struct{}, error)
- func WaitForQuitSignals() sdkserver.ErrorCode
- type EVMTxIndexerService
- type LogHandler
- type StartOptions
Constants ¶
const ( EVMTxIndexerServiceName = "EVMTxIndexerService" NewBlockWaitTimeout = 60 * time.Second )
const ( WithTendermint = "with-tendermint" Address = "address" Transport = "transport" TraceStore = "trace-store" CPUProfile = "cpu-profile" // The type of database for application and snapshots databases AppDBBackend = "app-db-backend" )
Tendermint/cosmos-sdk full-node start flags
const ( GRPCOnly = "grpc-only" GRPCEnable = "grpc.enable" GRPCAddress = "grpc.address" GRPCWebEnable = "grpc-web.enable" GRPCWebAddress = "grpc-web.address" )
GRPC-related flags.
const ( RPCEnable = "api.enable" EnabledUnsafeCors = "api.enabled-unsafe-cors" )
Cosmos API flags
const ( JSONRPCEnable = "json-rpc.enable" JSONRPCAPI = "json-rpc.api" JSONRPCAddress = "json-rpc.address" JSONWsAddress = "json-rpc.ws-address" JSONRPCGasCap = "json-rpc.gas-cap" JSONRPCEVMTimeout = "json-rpc.evm-timeout" JSONRPCTxFeeCap = "json-rpc.txfee-cap" JSONRPCFilterCap = "json-rpc.filter-cap" JSONRPCLogsCap = "json-rpc.logs-cap" JSONRPCBlockRangeCap = "json-rpc.block-range-cap" JSONRPCHTTPTimeout = "json-rpc.http-timeout" JSONRPCHTTPIdleTimeout = "json-rpc.http-idle-timeout" JSONRPCAllowUnprotectedTxs = "json-rpc.allow-unprotected-txs" JSONRPCMaxOpenConnections = "json-rpc.max-open-connections" JSONRPCEnableIndexer = "json-rpc.enable-indexer" JSONRPCEnableMetrics = "metrics" )
JSON-RPC flags
const ( EVMTracer = "evm.tracer" EVMMaxTxGasWanted = "evm.max-tx-gas-wanted" )
EVM flags
const ( TLSCertPath = "tls.certificate-path" TLSKeyPath = "tls.key-path" )
TLS flags
Variables ¶
This section is empty.
Functions ¶
func AddCommands ¶
func AddCommands( rootCmd *cobra.Command, opts StartOptions, appExport types.AppExporter, addStartFlags types.ModuleInitFlags, )
AddCommands adds server commands
func AddTxFlags ¶
AddTxFlags adds common flags for commands to post tx
func ConnectTmWS ¶
func Listen ¶
Listen starts a net.Listener on the tcp network on the given address. If there is a specified MaxOpenConnections in the config, it will also set the limitListener.
func NewEVMTxIndexCmd ¶
func OpenIndexerDB ¶
OpenIndexerDB opens the custom eth indexer db, using the same db backend as the main app
func StartCmd ¶
func StartCmd(opts StartOptions) *cobra.Command
StartCmd runs the service passed in, either stand-alone or in-process with Tendermint.
func StartEthereumJSONRPC ¶ added in v2.5.0
func StartEthereumJSONRPC( ctx *server.Context, clientCtx client.Context, tmRPCAddr, tmEndpoint string, config *srvconfig.Config, indexer eth.EVMTxIndexer, ) (*http.Server, chan struct{}, error)
StartEthereumJSONRPC starts the Ethereum JSON-RPC server and websocket server for Nibiru.
func WaitForQuitSignals ¶
WaitForQuitSignals waits for SIGINT and SIGTERM and returns.
Types ¶
type EVMTxIndexerService ¶
type EVMTxIndexerService struct {
service.BaseService
// contains filtered or unexported fields
}
EVMTxIndexerService indexes transactions for json-rpc service.
func NewEVMIndexerService ¶
func NewEVMIndexerService(evmTxIndexer *indexer.EVMTxIndexer, rpcClient cmtrpcclient.Client) *EVMTxIndexerService
NewEVMIndexerService returns a new service instance.
func OpenEVMIndexer ¶
func OpenEVMIndexer( ctx *sdkserver.Context, indexerDb dbm.DB, clientCtx client.Context, ) (eth.EVMTxIndexer, *EVMTxIndexerService, error)
func (*EVMTxIndexerService) OnStart ¶
func (service *EVMTxIndexerService) OnStart() error
OnStart implements service.Service by subscribing for new blocks and indexing them by events.
func (*EVMTxIndexerService) OnStop ¶
func (service *EVMTxIndexerService) OnStop()
type LogHandler ¶ added in v2.4.0
LogHandler implements slog.Handler, which is needed to construct the conventional go-ethereum.Logger, using a CometBFT logger ("github.com/cometbft/cometbft/libs/log".Logger).
func (*LogHandler) Enabled ¶ added in v2.4.0
Enabled decides whether a log record should be processed. We let the underlying CometBFT logger handle filtering.
func (*LogHandler) Handle ¶ added in v2.4.0
Handle processes the log record and sends it to the CometBFT logger.
type StartOptions ¶
type StartOptions struct {
AppCreator types.AppCreator
DefaultNodeHome string
}
StartOptions defines options that can be customized in `StartCmd`
func NewDefaultStartOptions ¶
func NewDefaultStartOptions(appCreator types.AppCreator, defaultNodeHome string) StartOptions
NewDefaultStartOptions use the default db opener provided in tm-db.
Source Files
Directories