server

Documentation

Index

• Constants
• func AddCommands(rootCmd *cobra.Command, opts StartOptions, appExport types.AppExporter, ...)
• func GenDocProvider(cfg *cmtcfg.Config) func() (*cmttypes.GenesisDoc, error)
• func Listen(addr string, config *config.Config) (net.Listener, error)
• func MountGRPCWebServices(router *mux.Router, grpcWeb *grpcweb.WrappedGrpcServer, grpcResources []string, ...)
• func NewIndexTxCmd() *cobra.Command
• func OpenIndexerDB(rootDir string, backendType dbm.BackendType) (dbm.DB, error)
• func StartCmd(opts StartOptions) *cobra.Command
• func StartJSONRPC(ctx context.Context, srvCtx *server.Context, clientCtx client.Context, ...) (*http.Server, error)
• type AppCreator
• type AppWithPendingTxStream
• type Application
• type CustomSlogHandler
  • func (h *CustomSlogHandler) Enabled(_ context.Context, _ slog.Level) bool
  • func (h *CustomSlogHandler) Handle(_ context.Context, r slog.Record) error
  • func (h *CustomSlogHandler) WithAttrs(_ []slog.Attr) slog.Handler
  • func (h *CustomSlogHandler) WithGroup(_ string) slog.Handler
• type DBOpener
• type EVMIndexerService
  • func NewEVMIndexerService(txIdxr cosmosevmtypes.EVMTxIndexer, client rpcclient.Client) *EVMIndexerService
  • func (eis *EVMIndexerService) OnStart() error
• type StartOptions
  • func NewDefaultStartOptions(appCreator AppCreator, defaultNodeHome string) StartOptions

Constants

const (
	ServiceName = "EVMIndexerService"

	NewBlockWaitTimeout = 60 * time.Second
)

Functions

func AddCommands

func AddCommands(
	rootCmd *cobra.Command,
	opts StartOptions,
	appExport types.AppExporter,
	addStartFlags types.ModuleInitFlags,
)

AddCommands adds server commands

func GenDocProvider

func GenDocProvider(cfg *cmtcfg.Config) func() (*cmttypes.GenesisDoc, error)

GenDocProvider returns a function which returns the genesis doc from the genesis file.

func Listen

func Listen(addr string, config *config.Config) (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 MountGRPCWebServices

func MountGRPCWebServices(
	router *mux.Router,
	grpcWeb *grpcweb.WrappedGrpcServer,
	grpcResources []string,
	logger log.Logger,
)

MountGRPCWebServices mounts gRPC-Web services on specific HTTP POST routes. Parameters: - router: The HTTP router instance to mount the routes on (using mux.Router). - grpcWeb: The wrapped gRPC-Web server that will handle incoming gRPC-Web and WebSocket requests. - grpcResources: A list of resource endpoints (URLs) that should be mounted for gRPC-Web POST requests. - logger: A logger instance used to log information about the mounted resources.

func NewIndexTxCmd

func NewIndexTxCmd() *cobra.Command

NewIndexTxCmd creates a new Cobra command to index historical Ethereum transactions.

func OpenIndexerDB

func OpenIndexerDB(rootDir string, backendType dbm.BackendType) (dbm.DB, error)

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 CometBFT.

func StartJSONRPC

func StartJSONRPC(
	ctx context.Context,
	srvCtx *server.Context,
	clientCtx client.Context,
	g *errgroup.Group,
	config *serverconfig.Config,
	indexer cosmosevmtypes.EVMTxIndexer,
	app AppWithPendingTxStream,
) (*http.Server, error)

StartJSONRPC starts the JSON-RPC server

Types

type AppCreator

type AppCreator func(log.Logger, dbm.DB, io.Writer, types.AppOptions) Application

AppCreator is a function that allows us to lazily initialize an application implementing with AppWithPendingTxStream.

type AppWithPendingTxStream

type AppWithPendingTxStream interface {
	RegisterPendingTxListener(listener func(common.Hash))
}

type Application

type Application interface {
	types.Application
	AppWithPendingTxStream
	SetClientCtx(clientCtx client.Context)
}

type CustomSlogHandler

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

CustomSlogHandler bridges Geth's slog logs to the existing Cosmos SDK logger.

func (*CustomSlogHandler) Enabled

func (h *CustomSlogHandler) Enabled(_ context.Context, _ slog.Level) bool

Enabled determines if the handler should log a given level.

func (*CustomSlogHandler) Handle

func (h *CustomSlogHandler) Handle(_ context.Context, r slog.Record) error

Handle processes slog records and forwards them to your Cosmos SDK logger.

func (*CustomSlogHandler) WithAttrs

func (h *CustomSlogHandler) WithAttrs(_ []slog.Attr) slog.Handler

WithAttrs allows adding additional attributes.

func (*CustomSlogHandler) WithGroup

func (h *CustomSlogHandler) WithGroup(_ string) slog.Handler

WithGroup is required to implement slog.Handler (not used).

type DBOpener

type DBOpener func(opts types.AppOptions, rootDir string, backend dbm.BackendType) (dbm.DB, error)

DBOpener is a function to open `application.db`, potentially with customized options.

type EVMIndexerService

type EVMIndexerService struct {
	service.BaseService
	// contains filtered or unexported fields
}

EVMIndexerService indexes transactions for json-rpc service.

func NewEVMIndexerService

func NewEVMIndexerService(
	txIdxr cosmosevmtypes.EVMTxIndexer,
	client rpcclient.Client,
) *EVMIndexerService

NewEVMIndexerService returns a new service instance.

func (*EVMIndexerService) OnStart

func (eis *EVMIndexerService) OnStart() error

OnStart implements service.Service by subscribing for new blocks and indexing them by events.

type StartOptions

type StartOptions struct {
	AppCreator      types.AppCreator
	DefaultNodeHome string
	DBOpener        DBOpener
}

StartOptions defines options that can be customized in `StartCmd`

func NewDefaultStartOptions

func NewDefaultStartOptions(appCreator AppCreator, defaultNodeHome string) StartOptions

NewDefaultStartOptions use the default db opener provided in tm-db.