execution

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

type ClientProvider interface {
	// GetTxpoolContent retrieves the full transaction pool content.
	GetTxpoolContent(ctx context.Context) (json.RawMessage, error)

	// GetPendingTransactions retrieves pending transactions.
	GetPendingTransactions(ctx context.Context) ([]json.RawMessage, error)

	// BatchGetTransactionsByHash retrieves transactions by their hashes.
	BatchGetTransactionsByHash(ctx context.Context, hashes []string) ([]json.RawMessage, error)

	// SubscribeToNewPendingTxs subscribes to new pending transaction notifications.
	SubscribeToNewPendingTxs(ctx context.Context) (<-chan string, <-chan error, error)

	// CallContext performs a JSON-RPC call with the given arguments.
	CallContext(ctx context.Context, result interface{}, method string, args ...interface{}) error
}

type Config struct {
	// Enabled is whether the execution client is enabled.
	Enabled bool `yaml:"enabled" default:"false"`
	// EthPendingTxsEnabled is whether we suppliment fetching tx's using eth_pendingTransactions periodically.
	EthPendingTxsEnabled bool `yaml:"ethPendingTxsEnabled" default:"false"`
	// TxPoolContentEnabled is whether we suppliment fetching tx's using txpool_content periodically.
	TxPoolContentEnabled bool `yaml:"txPoolContentEnabled" default:"true"`
	// WebsocketEnabled is whether the websocket is enabled.
	WebsocketEnabled bool `yaml:"websocketEnabled" default:"false"`
	// WSAddress is the WebSocket address of the execution client for subscriptions.
	WSAddress string `yaml:"wsAddress"`
	// RPCAddress is the RPC address of the execution client for txpool_content calls.
	RPCAddress string `yaml:"rpcAddress"`
	// Headers is a map of headers to send to the execution client.
	Headers map[string]string `yaml:"headers"`
	// FetchInterval is how often to fetch txpool_content (in seconds).
	FetchInterval int `yaml:"fetchInterval" default:"15"`
	// PruneDuration is how long to keep pending transactions in memory before pruning (in seconds).
	PruneDuration int `yaml:"pruneDuration" default:"300"`
	// ProcessorWorkerCount is the number of worker goroutines for processing transactions.
	ProcessorWorkerCount int `yaml:"processorWorkerCount" default:"50"`
	// RpcBatchSize is the number of transactions to include in a single RPC batch call.
	RpcBatchSize int `yaml:"rpcBatchSize" default:"40"`
	// QueueSize is the size of the transaction processing queue.
	QueueSize int `yaml:"queueSize" default:"5000"`
	// ProcessingInterval is the interval at which to process batches of transactions (in milliseconds).
	ProcessingInterval int `yaml:"processingInterval" default:"500"`
	// MaxConcurrency is the maximum number of concurrent batch RPC requests.
	MaxConcurrency int `yaml:"maxConcurrency" default:"5"`
	// CircuitBreakerFailureThreshold is the number of consecutive failures before opening the circuit breaker.
	CircuitBreakerFailureThreshold int `yaml:"circuitBreakerFailureThreshold" default:"5"`
	// CircuitBreakerResetTimeout is the time to wait before transitioning from open to half-open (in seconds).
	CircuitBreakerResetTimeout int `yaml:"circuitBreakerResetTimeout" default:"30"`
}

type EventCallback func(ctx context.Context, event interface{}) error

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

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

type PendingTxRecord struct {
	Hash             string
	FirstSeen        time.Time
	Attempts         int
	TxData           json.RawMessage // Raw tx data (when available).
	Source           string          // Eg: "websocket", "txpool_content", or "eth_pendingTransactions".
	MarkedForPruning bool
}

type SubscriptionType string

type TransactionCallback func(ctx context.Context, tx string) error