cli

Documentation

Index

• func EmbeddedServices(ctx context.Context, erigonDB kv.RoDB, stateCacheCfg kvcache.CoherentConfig, ...) (eth rpchelper.ApiBackend, txPool txpool.TxpoolClient, ...)
• func RemoteServices(ctx context.Context, cfg *httpcfg.HttpCfg, logger log.Logger, ...) (db kv.RoDB, eth rpchelper.ApiBackend, txPool txpool.TxpoolClient, ...)
• func RootCommand() (*cobra.Command, *httpcfg.HttpCfg)
• func StartRpcServer(ctx context.Context, cfg *httpcfg.HttpCfg, rpcAPI []rpc.API, logger log.Logger) error
• func StartRpcServerWithJwtAuthentication(ctx context.Context, cfg *httpcfg.HttpCfg, rpcAPI []rpc.API, logger log.Logger) error
• type StateChangesClient

Functions

func EmbeddedServices

func EmbeddedServices(ctx context.Context,
	erigonDB kv.RoDB, stateCacheCfg kvcache.CoherentConfig,
	blockReader services.FullBlockReader, ethBackendServer remote.ETHBACKENDServer, txPoolServer txpool.TxpoolServer,
	miningServer txpool.MiningServer, stateDiffClient StateChangesClient,
	logger log.Logger,
) (eth rpchelper.ApiBackend, txPool txpool.TxpoolClient, mining txpool.MiningClient, stateCache kvcache.Cache, ff *rpchelper.Filters, err error)

func RemoteServices

func RemoteServices(ctx context.Context, cfg *httpcfg.HttpCfg, logger log.Logger, rootCancel context.CancelFunc) (
	db kv.RoDB, eth rpchelper.ApiBackend, txPool txpool.TxpoolClient, mining txpool.MiningClient,
	stateCache kvcache.Cache, blockReader services.FullBlockReader, engine consensus.EngineReader,
	ff *rpchelper.Filters, agg *libstate.AggregatorV3, err error)

RemoteServices - use when RPCDaemon run as independent process. Still it can use --datadir flag to enable `cfg.WithDatadir` (mode when it on 1 machine with Erigon)

func RootCommand

func RootCommand() (*cobra.Command, *httpcfg.HttpCfg)

func StartRpcServer

func StartRpcServer(ctx context.Context, cfg *httpcfg.HttpCfg, rpcAPI []rpc.API, logger log.Logger) error

func StartRpcServerWithJwtAuthentication

func StartRpcServerWithJwtAuthentication(ctx context.Context, cfg *httpcfg.HttpCfg, rpcAPI []rpc.API, logger log.Logger) error

Types

type StateChangesClient

type StateChangesClient interface {
	StateChanges(ctx context.Context, in *remote.StateChangeRequest, opts ...grpc.CallOption) (remote.KV_StateChangesClient, error)
}