Documentation
¶
Index ¶
- func NewBaseRethNodeClient(logger log.Logger, options *config.InternalClientOptions, ...) types.ExecutionClient
- type BaseRethNodeClient
- func (r *BaseRethNodeClient) AuthClient() client.RPC
- func (r *BaseRethNodeClient) Client() *ethclient.Client
- func (r *BaseRethNodeClient) ClientURL() string
- func (r *BaseRethNodeClient) FlashblocksClient() types.FlashblocksClient
- func (r *BaseRethNodeClient) GetVersion(ctx context.Context) (string, error)
- func (r *BaseRethNodeClient) MetricsCollector() metrics.Collector
- func (r *BaseRethNodeClient) MetricsPort() int
- func (r *BaseRethNodeClient) Run(ctx context.Context, cfg *types.RuntimeConfig) error
- func (r *BaseRethNodeClient) SetHead(ctx context.Context, blockNumber uint64) error
- func (r *BaseRethNodeClient) Stop()
- func (r *BaseRethNodeClient) SupportsFlashblocks() bool
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewBaseRethNodeClient ¶
func NewBaseRethNodeClient(logger log.Logger, options *config.InternalClientOptions, ports portmanager.PortManager) types.ExecutionClient
NewBaseRethNodeClient creates a new client for base-reth-node.
Types ¶
type BaseRethNodeClient ¶
type BaseRethNodeClient struct {
// contains filtered or unexported fields
}
BaseRethNodeClient handles the lifecycle of a base-reth-node client. This client is configured to receive flashblocks via websocket.
func (*BaseRethNodeClient) AuthClient ¶
func (r *BaseRethNodeClient) AuthClient() client.RPC
AuthClient returns the auth client used for CL communication.
func (*BaseRethNodeClient) Client ¶
func (r *BaseRethNodeClient) Client() *ethclient.Client
Client returns the ethclient client.
func (*BaseRethNodeClient) ClientURL ¶
func (r *BaseRethNodeClient) ClientURL() string
ClientURL returns the raw client URL for transaction generators.
func (*BaseRethNodeClient) FlashblocksClient ¶
func (r *BaseRethNodeClient) FlashblocksClient() types.FlashblocksClient
FlashblocksClient returns nil as base-reth-node receives flashblocks but doesn't produce them.
func (*BaseRethNodeClient) GetVersion ¶
func (r *BaseRethNodeClient) GetVersion(ctx context.Context) (string, error)
GetVersion returns the version of the base-reth-node client
func (*BaseRethNodeClient) MetricsCollector ¶
func (r *BaseRethNodeClient) MetricsCollector() metrics.Collector
func (*BaseRethNodeClient) MetricsPort ¶
func (r *BaseRethNodeClient) MetricsPort() int
func (*BaseRethNodeClient) Run ¶
func (r *BaseRethNodeClient) Run(ctx context.Context, cfg *types.RuntimeConfig) error
Run runs the base-reth-node client with the given runtime config.
func (*BaseRethNodeClient) SetHead ¶
func (r *BaseRethNodeClient) SetHead(ctx context.Context, blockNumber uint64) error
SetHead resets the blockchain to a specific block using debug.setHead
func (*BaseRethNodeClient) Stop ¶
func (r *BaseRethNodeClient) Stop()
Stop stops the base-reth-node client.
func (*BaseRethNodeClient) SupportsFlashblocks ¶
func (r *BaseRethNodeClient) SupportsFlashblocks() bool
SupportsFlashblocks returns true as base-reth-node supports receiving flashblock payloads.
Source Files
Directories