server

Documentation

Index

• Constants
• func ConnectTmWS(tmRPCAddr, tmEndpoint string, logger tmlog.Logger) (*rpcclient.WSClient, error)
• func DataCmd() *cobra.Command
• func ExportSateCmd(appExporter types.AppExporter, defaultNodeHome string) *cobra.Command
• func Listen(addr string, maxOpenConnections int) (net.Listener, error)
• func ReplayCmd() *cobra.Command
• func ReplayConsoleCmd() *cobra.Command
• func RosettaCommand(ir codectypes.InterfaceRegistry, cdc codec.Codec) *cobra.Command
• func StartCmd(appCreator types.AppCreator, defaultNodeHome string) *cobra.Command
• func StartJSONRPC(svrCtx *server.Context, clientCtx client.Context, tmRPCAddr, tmEndpoint string, ...) (*http.Server, error)
• func TendermintCommand() *cobra.Command
• func UnsafeResetNodeKeyCmd() *cobra.Command
• func UnsafeRestPrivValidatorCmd() *cobra.Command
• type Database
  • func NewDatabase(cfg *tmcfg.Config, cdc codec.Codec) (*Database, error)
  • func (d *Database) AppStore() *rootmulti.Store
  • func (d *Database) BlockStore() *store.BlockStore
  • func (d *Database) Close()
  • func (d *Database) CurrentPlan() (*upgradetypes.Plan, error)
  • func (d *Database) GetBlockHeight() (int64, error)
  • func (d *Database) GetChainId() (string, error)
  • func (d *Database) GetConsensusValidators() ([]*tmservice.Validator, error)
  • func (d *Database) GetNodeInfo() (*tmservice.VersionInfo, error)
  • func (d *Database) GetState() (sm.State, error)
  • func (d *Database) GetSyncing() (bool, error)
  • func (d *Database) StateStore() sm.Store
• type FxZeroLogWrapper
  • func NewFxZeroLogWrapper(logger zerolog.Logger, logTypes []string) FxZeroLogWrapper
  • func (z FxZeroLogWrapper) Debug(msg string, keyVals ...interface{})
  • func (z FxZeroLogWrapper) Error(msg string, keyVals ...interface{})
  • func (z FxZeroLogWrapper) Info(msg string, keyVals ...interface{})
  • func (z FxZeroLogWrapper) With(keyVals ...interface{}) tmlog.Logger

Constants

const (
	BlockDBName = "blockstore"
	StateDBName = "state"
	AppDBName   = "application"
)

const (
	FlagHeight           = "height"
	FlagForZeroHeight    = "for-zero-height"
	FlagJailAllowedAddrs = "jail-allowed-addrs"
)

const FlagApplicationDatabaseDir = "application-db-dir"

const (
	FlagLogFilter = "log_filter"
)

Functions

func ConnectTmWS

func ConnectTmWS(tmRPCAddr, tmEndpoint string, logger tmlog.Logger) (*rpcclient.WSClient, error)

func DataCmd

func DataCmd() *cobra.Command

func ExportSateCmd

func ExportSateCmd(appExporter types.AppExporter, defaultNodeHome string) *cobra.Command

ExportSateCmd dumps app state to JSON.

func Listen

func Listen(addr string, maxOpenConnections int) (net.Listener, error)

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 ReplayCmd

func ReplayCmd() *cobra.Command

ReplayCmd allows replaying of messages from the WAL.

func ReplayConsoleCmd

func ReplayConsoleCmd() *cobra.Command

ReplayConsoleCmd allows replaying of messages from the WAL in a console.

func RosettaCommand

func RosettaCommand(ir codectypes.InterfaceRegistry, cdc codec.Codec) *cobra.Command

RosettaCommand builds the rosetta root command given a protocol buffers serializer/deserializer

func StartCmd

func StartCmd(appCreator types.AppCreator, defaultNodeHome string) *cobra.Command

StartCmd runs the service passed in, either stand-alone or in-process with Tendermint.

func StartJSONRPC

func StartJSONRPC(svrCtx *server.Context, clientCtx client.Context, tmRPCAddr, tmEndpoint string, config *config.Config, indexer ethermint.EVMTxIndexer) (*http.Server, error)

StartJSONRPC starts the JSON-RPC server

func TendermintCommand

func TendermintCommand() *cobra.Command

func UnsafeResetNodeKeyCmd

func UnsafeResetNodeKeyCmd() *cobra.Command

func UnsafeRestPrivValidatorCmd

func UnsafeRestPrivValidatorCmd() *cobra.Command

UnsafeRestPrivValidatorCmd Reset validator node consensus private key file

Types

type Database

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

func NewDatabase

func NewDatabase(cfg *tmcfg.Config, cdc codec.Codec) (*Database, error)

func (*Database) AppStore

func (d *Database) AppStore() *rootmulti.Store

func (*Database) BlockStore

func (d *Database) BlockStore() *store.BlockStore

func (*Database) Close

func (d *Database) Close()

func (*Database) CurrentPlan

func (d *Database) CurrentPlan() (*upgradetypes.Plan, error)

func (*Database) GetBlockHeight

func (d *Database) GetBlockHeight() (int64, error)

func (*Database) GetChainId

func (d *Database) GetChainId() (string, error)

func (*Database) GetConsensusValidators

func (d *Database) GetConsensusValidators() ([]*tmservice.Validator, error)

func (*Database) GetNodeInfo

func (d *Database) GetNodeInfo() (*tmservice.VersionInfo, error)

func (*Database) GetState

func (d *Database) GetState() (sm.State, error)

func (*Database) GetSyncing

func (d *Database) GetSyncing() (bool, error)

func (*Database) StateStore

func (d *Database) StateStore() sm.Store

type FxZeroLogWrapper

type FxZeroLogWrapper struct {
	zerolog.Logger
	// contains filtered or unexported fields
}

func NewFxZeroLogWrapper

func NewFxZeroLogWrapper(logger zerolog.Logger, logTypes []string) FxZeroLogWrapper

func (FxZeroLogWrapper) Debug

func (z FxZeroLogWrapper) Debug(msg string, keyVals ...interface{})

func (FxZeroLogWrapper) Error

func (z FxZeroLogWrapper) Error(msg string, keyVals ...interface{})

func (FxZeroLogWrapper) Info

func (z FxZeroLogWrapper) Info(msg string, keyVals ...interface{})

func (FxZeroLogWrapper) With

func (z FxZeroLogWrapper) With(keyVals ...interface{}) tmlog.Logger