Documentation
¶
Overview ¶
Package execution holds EL cannon derivers. Each deriver pulls a single cryo dataset over a block range, converts the rows into chunked DecoratedEvents, and advances its own block cursor — mirroring the per-deriver independence of the consensus-layer derivers. The shared loop lives in deriver_base.go; each deriver supplies its row struct, cryo columns, and row→proto mapping.
Index ¶
- Constants
- type AddressAppearancesDeriver
- func (b *AddressAppearancesDeriver) ActivationFork() spec.DataVersion
- func (b *AddressAppearancesDeriver) CannonType() xatu.CannonType
- func (b *AddressAppearancesDeriver) Name() string
- func (b *AddressAppearancesDeriver) OnEventsDerived(_ context.Context, ...)
- func (b *AddressAppearancesDeriver) Start(ctx context.Context) error
- func (b *AddressAppearancesDeriver) Stop(_ context.Context) error
- type AddressAppearancesDeriverConfig
- type BalanceDiffsDeriver
- func (b *BalanceDiffsDeriver) ActivationFork() spec.DataVersion
- func (b *BalanceDiffsDeriver) CannonType() xatu.CannonType
- func (b *BalanceDiffsDeriver) Name() string
- func (b *BalanceDiffsDeriver) OnEventsDerived(_ context.Context, ...)
- func (b *BalanceDiffsDeriver) Start(ctx context.Context) error
- func (b *BalanceDiffsDeriver) Stop(_ context.Context) error
- type BalanceDiffsDeriverConfig
- type BalanceReadsDeriver
- func (b *BalanceReadsDeriver) ActivationFork() spec.DataVersion
- func (b *BalanceReadsDeriver) CannonType() xatu.CannonType
- func (b *BalanceReadsDeriver) Name() string
- func (b *BalanceReadsDeriver) OnEventsDerived(_ context.Context, ...)
- func (b *BalanceReadsDeriver) Start(ctx context.Context) error
- func (b *BalanceReadsDeriver) Stop(_ context.Context) error
- type BalanceReadsDeriverConfig
- type BlockDeriver
- func (b *BlockDeriver) ActivationFork() spec.DataVersion
- func (b *BlockDeriver) CannonType() xatu.CannonType
- func (b *BlockDeriver) Name() string
- func (b *BlockDeriver) OnEventsDerived(_ context.Context, ...)
- func (b *BlockDeriver) Start(ctx context.Context) error
- func (b *BlockDeriver) Stop(_ context.Context) error
- type BlockDeriverConfig
- type Config
- type ContractsDeriver
- func (b *ContractsDeriver) ActivationFork() spec.DataVersion
- func (b *ContractsDeriver) CannonType() xatu.CannonType
- func (b *ContractsDeriver) Name() string
- func (b *ContractsDeriver) OnEventsDerived(_ context.Context, ...)
- func (b *ContractsDeriver) Start(ctx context.Context) error
- func (b *ContractsDeriver) Stop(_ context.Context) error
- type ContractsDeriverConfig
- type Erc20TransfersDeriver
- func (b *Erc20TransfersDeriver) ActivationFork() spec.DataVersion
- func (b *Erc20TransfersDeriver) CannonType() xatu.CannonType
- func (b *Erc20TransfersDeriver) Name() string
- func (b *Erc20TransfersDeriver) OnEventsDerived(_ context.Context, ...)
- func (b *Erc20TransfersDeriver) Start(ctx context.Context) error
- func (b *Erc20TransfersDeriver) Stop(_ context.Context) error
- type Erc20TransfersDeriverConfig
- type Erc721TransfersDeriver
- func (b *Erc721TransfersDeriver) ActivationFork() spec.DataVersion
- func (b *Erc721TransfersDeriver) CannonType() xatu.CannonType
- func (b *Erc721TransfersDeriver) Name() string
- func (b *Erc721TransfersDeriver) OnEventsDerived(_ context.Context, ...)
- func (b *Erc721TransfersDeriver) Start(ctx context.Context) error
- func (b *Erc721TransfersDeriver) Stop(_ context.Context) error
- type Erc721TransfersDeriverConfig
- type FourByteCountsDeriver
- func (b *FourByteCountsDeriver) ActivationFork() spec.DataVersion
- func (b *FourByteCountsDeriver) CannonType() xatu.CannonType
- func (b *FourByteCountsDeriver) Name() string
- func (b *FourByteCountsDeriver) OnEventsDerived(_ context.Context, ...)
- func (b *FourByteCountsDeriver) Start(ctx context.Context) error
- func (b *FourByteCountsDeriver) Stop(_ context.Context) error
- type FourByteCountsDeriverConfig
- type LogsDeriver
- func (b *LogsDeriver) ActivationFork() spec.DataVersion
- func (b *LogsDeriver) CannonType() xatu.CannonType
- func (b *LogsDeriver) Name() string
- func (b *LogsDeriver) OnEventsDerived(_ context.Context, ...)
- func (b *LogsDeriver) Start(ctx context.Context) error
- func (b *LogsDeriver) Stop(_ context.Context) error
- type LogsDeriverConfig
- type NativeTransfersDeriver
- func (b *NativeTransfersDeriver) ActivationFork() spec.DataVersion
- func (b *NativeTransfersDeriver) CannonType() xatu.CannonType
- func (b *NativeTransfersDeriver) Name() string
- func (b *NativeTransfersDeriver) OnEventsDerived(_ context.Context, ...)
- func (b *NativeTransfersDeriver) Start(ctx context.Context) error
- func (b *NativeTransfersDeriver) Stop(_ context.Context) error
- type NativeTransfersDeriverConfig
- type NonceDiffsDeriver
- func (b *NonceDiffsDeriver) ActivationFork() spec.DataVersion
- func (b *NonceDiffsDeriver) CannonType() xatu.CannonType
- func (b *NonceDiffsDeriver) Name() string
- func (b *NonceDiffsDeriver) OnEventsDerived(_ context.Context, ...)
- func (b *NonceDiffsDeriver) Start(ctx context.Context) error
- func (b *NonceDiffsDeriver) Stop(_ context.Context) error
- type NonceDiffsDeriverConfig
- type NonceReadsDeriver
- func (b *NonceReadsDeriver) ActivationFork() spec.DataVersion
- func (b *NonceReadsDeriver) CannonType() xatu.CannonType
- func (b *NonceReadsDeriver) Name() string
- func (b *NonceReadsDeriver) OnEventsDerived(_ context.Context, ...)
- func (b *NonceReadsDeriver) Start(ctx context.Context) error
- func (b *NonceReadsDeriver) Stop(_ context.Context) error
- type NonceReadsDeriverConfig
- type StorageDiffsDeriver
- func (b *StorageDiffsDeriver) ActivationFork() spec.DataVersion
- func (b *StorageDiffsDeriver) CannonType() xatu.CannonType
- func (b *StorageDiffsDeriver) Name() string
- func (b *StorageDiffsDeriver) OnEventsDerived(_ context.Context, ...)
- func (b *StorageDiffsDeriver) Start(ctx context.Context) error
- func (b *StorageDiffsDeriver) Stop(_ context.Context) error
- type StorageDiffsDeriverConfig
- type StorageReadsDeriver
- func (b *StorageReadsDeriver) ActivationFork() spec.DataVersion
- func (b *StorageReadsDeriver) CannonType() xatu.CannonType
- func (b *StorageReadsDeriver) Name() string
- func (b *StorageReadsDeriver) OnEventsDerived(_ context.Context, ...)
- func (b *StorageReadsDeriver) Start(ctx context.Context) error
- func (b *StorageReadsDeriver) Stop(_ context.Context) error
- type StorageReadsDeriverConfig
- type TracesDeriver
- func (b *TracesDeriver) ActivationFork() spec.DataVersion
- func (b *TracesDeriver) CannonType() xatu.CannonType
- func (b *TracesDeriver) Name() string
- func (b *TracesDeriver) OnEventsDerived(_ context.Context, ...)
- func (b *TracesDeriver) Start(ctx context.Context) error
- func (b *TracesDeriver) Stop(_ context.Context) error
- type TracesDeriverConfig
- type TransactionDeriver
- func (b *TransactionDeriver) ActivationFork() spec.DataVersion
- func (b *TransactionDeriver) CannonType() xatu.CannonType
- func (b *TransactionDeriver) Name() string
- func (b *TransactionDeriver) OnEventsDerived(_ context.Context, ...)
- func (b *TransactionDeriver) Start(ctx context.Context) error
- func (b *TransactionDeriver) Stop(_ context.Context) error
- type TransactionDeriverConfig
Constants ¶
const AddressAppearancesDeriverName = xatu.CannonType_EXECUTION_CANONICAL_ADDRESS_APPEARANCES
AddressAppearancesDeriverName is the cannon type produced by the address appearances deriver.
const BalanceDiffsDeriverName = xatu.CannonType_EXECUTION_CANONICAL_BALANCE_DIFFS
BalanceDiffsDeriverName is the cannon type produced by the balance diffs deriver.
const BalanceReadsDeriverName = xatu.CannonType_EXECUTION_CANONICAL_BALANCE_READS
BalanceReadsDeriverName is the cannon type produced by the balance reads deriver.
const BlockDeriverName = xatu.CannonType_EXECUTION_CANONICAL_BLOCK
BlockDeriverName is the cannon type produced by the block deriver.
const ContractsDeriverName = xatu.CannonType_EXECUTION_CANONICAL_CONTRACTS
ContractsDeriverName is the cannon type produced by the contracts deriver.
const Erc20TransfersDeriverName = xatu.CannonType_EXECUTION_CANONICAL_ERC20_TRANSFERS
Erc20TransfersDeriverName is the cannon type produced by the erc20_transfers deriver.
const Erc721TransfersDeriverName = xatu.CannonType_EXECUTION_CANONICAL_ERC721_TRANSFERS
Erc721TransfersDeriverName is the cannon type produced by the erc721 transfers deriver.
const FourByteCountsDeriverName = xatu.CannonType_EXECUTION_CANONICAL_FOUR_BYTE_COUNTS
FourByteCountsDeriverName is the cannon type produced by the four_byte_counts deriver.
const LogsDeriverName = xatu.CannonType_EXECUTION_CANONICAL_LOGS
LogsDeriverName is the cannon type produced by the logs deriver.
const NativeTransfersDeriverName = xatu.CannonType_EXECUTION_CANONICAL_NATIVE_TRANSFERS
NativeTransfersDeriverName is the cannon type produced by the native transfers deriver.
const NonceDiffsDeriverName = xatu.CannonType_EXECUTION_CANONICAL_NONCE_DIFFS
NonceDiffsDeriverName is the cannon type produced by the nonce_diffs deriver.
const NonceReadsDeriverName = xatu.CannonType_EXECUTION_CANONICAL_NONCE_READS
NonceReadsDeriverName is the cannon type produced by the nonce reads deriver.
const StorageDiffsDeriverName = xatu.CannonType_EXECUTION_CANONICAL_STORAGE_DIFFS
StorageDiffsDeriverName is the cannon type produced by the storage diffs deriver.
const StorageReadsDeriverName = xatu.CannonType_EXECUTION_CANONICAL_STORAGE_READS
StorageReadsDeriverName is the cannon type produced by the storage reads deriver.
const TracesDeriverName = xatu.CannonType_EXECUTION_CANONICAL_TRACES
TracesDeriverName is the cannon type produced by the traces deriver.
const TransactionDeriverName = xatu.CannonType_EXECUTION_CANONICAL_TRANSACTION
TransactionDeriverName is the cannon type produced by the transaction deriver.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type AddressAppearancesDeriver ¶
type AddressAppearancesDeriver struct {
// contains filtered or unexported fields
}
AddressAppearancesDeriver derives canonical_execution_address_appearances events via cryo.
func NewAddressAppearancesDeriver ¶
func NewAddressAppearancesDeriver( log observability.ContextualLogger, config *AddressAppearancesDeriverConfig, iter *iterator.BackfillingBlock, runner *cryo.Runner, beacon *ethereum.BeaconNode, clientMeta *xatu.ClientMeta, ) *AddressAppearancesDeriver
NewAddressAppearancesDeriver creates an address appearances deriver.
func (*AddressAppearancesDeriver) ActivationFork ¶
func (b *AddressAppearancesDeriver) ActivationFork() spec.DataVersion
ActivationFork returns Phase0 so the deriver starts as soon as the beacon node is ready; the iterator gates EL progress on CL finality.
func (*AddressAppearancesDeriver) CannonType ¶
func (b *AddressAppearancesDeriver) CannonType() xatu.CannonType
CannonType returns the deriver's cannon type.
func (*AddressAppearancesDeriver) Name ¶
func (b *AddressAppearancesDeriver) Name() string
Name returns the deriver name.
func (*AddressAppearancesDeriver) OnEventsDerived ¶
func (b *AddressAppearancesDeriver) OnEventsDerived(_ context.Context, fn func(ctx context.Context, events []*xatu.DecoratedEvent) error)
OnEventsDerived registers a callback for derived events.
type AddressAppearancesDeriverConfig ¶
type AddressAppearancesDeriverConfig struct {
Enabled bool `yaml:"enabled" default:"false"`
ChunkSize int `yaml:"chunkSize" default:"100"`
Iterator iterator.BackfillingBlockConfig `yaml:"iterator"`
}
AddressAppearancesDeriverConfig configures the address appearances deriver.
type BalanceDiffsDeriver ¶
type BalanceDiffsDeriver struct {
// contains filtered or unexported fields
}
BalanceDiffsDeriver derives canonical_execution_balance_diffs events via cryo.
func NewBalanceDiffsDeriver ¶
func NewBalanceDiffsDeriver( log observability.ContextualLogger, config *BalanceDiffsDeriverConfig, iter *iterator.BackfillingBlock, runner *cryo.Runner, beacon *ethereum.BeaconNode, clientMeta *xatu.ClientMeta, ) *BalanceDiffsDeriver
NewBalanceDiffsDeriver creates a balance diffs deriver.
func (*BalanceDiffsDeriver) ActivationFork ¶
func (b *BalanceDiffsDeriver) ActivationFork() spec.DataVersion
ActivationFork returns Phase0 so the deriver starts as soon as the beacon node is ready; the iterator gates EL progress on CL finality.
func (*BalanceDiffsDeriver) CannonType ¶
func (b *BalanceDiffsDeriver) CannonType() xatu.CannonType
CannonType returns the deriver's cannon type.
func (*BalanceDiffsDeriver) Name ¶
func (b *BalanceDiffsDeriver) Name() string
Name returns the deriver name.
func (*BalanceDiffsDeriver) OnEventsDerived ¶
func (b *BalanceDiffsDeriver) OnEventsDerived(_ context.Context, fn func(ctx context.Context, events []*xatu.DecoratedEvent) error)
OnEventsDerived registers a callback for derived events.
type BalanceDiffsDeriverConfig ¶
type BalanceDiffsDeriverConfig struct {
Enabled bool `yaml:"enabled" default:"false"`
ChunkSize int `yaml:"chunkSize" default:"100"`
Iterator iterator.BackfillingBlockConfig `yaml:"iterator"`
}
BalanceDiffsDeriverConfig configures the balance diffs deriver.
type BalanceReadsDeriver ¶
type BalanceReadsDeriver struct {
// contains filtered or unexported fields
}
BalanceReadsDeriver derives canonical_execution_balance_reads events via cryo.
func NewBalanceReadsDeriver ¶
func NewBalanceReadsDeriver( log observability.ContextualLogger, config *BalanceReadsDeriverConfig, iter *iterator.BackfillingBlock, runner *cryo.Runner, beacon *ethereum.BeaconNode, clientMeta *xatu.ClientMeta, ) *BalanceReadsDeriver
NewBalanceReadsDeriver creates a balance reads deriver.
func (*BalanceReadsDeriver) ActivationFork ¶
func (b *BalanceReadsDeriver) ActivationFork() spec.DataVersion
ActivationFork returns Phase0 so the deriver starts as soon as the beacon node is ready; the iterator gates EL progress on CL finality.
func (*BalanceReadsDeriver) CannonType ¶
func (b *BalanceReadsDeriver) CannonType() xatu.CannonType
CannonType returns the deriver's cannon type.
func (*BalanceReadsDeriver) Name ¶
func (b *BalanceReadsDeriver) Name() string
Name returns the deriver name.
func (*BalanceReadsDeriver) OnEventsDerived ¶
func (b *BalanceReadsDeriver) OnEventsDerived(_ context.Context, fn func(ctx context.Context, events []*xatu.DecoratedEvent) error)
OnEventsDerived registers a callback for derived events.
type BalanceReadsDeriverConfig ¶
type BalanceReadsDeriverConfig struct {
Enabled bool `yaml:"enabled" default:"false"`
ChunkSize int `yaml:"chunkSize" default:"100"`
Iterator iterator.BackfillingBlockConfig `yaml:"iterator"`
}
BalanceReadsDeriverConfig configures the balance reads deriver.
type BlockDeriver ¶
type BlockDeriver struct {
// contains filtered or unexported fields
}
BlockDeriver derives canonical_execution_block events via cryo.
func NewBlockDeriver ¶
func NewBlockDeriver( log observability.ContextualLogger, config *BlockDeriverConfig, iter *iterator.BackfillingBlock, runner *cryo.Runner, beacon *ethereum.BeaconNode, clientMeta *xatu.ClientMeta, ) *BlockDeriver
NewBlockDeriver creates a block deriver.
func (*BlockDeriver) ActivationFork ¶
func (b *BlockDeriver) ActivationFork() spec.DataVersion
ActivationFork returns Phase0 so the deriver starts as soon as the beacon node is ready; the iterator gates EL progress on CL finality.
func (*BlockDeriver) CannonType ¶
func (b *BlockDeriver) CannonType() xatu.CannonType
CannonType returns the deriver's cannon type.
func (*BlockDeriver) OnEventsDerived ¶
func (b *BlockDeriver) OnEventsDerived(_ context.Context, fn func(ctx context.Context, events []*xatu.DecoratedEvent) error)
OnEventsDerived registers a callback for derived events.
type BlockDeriverConfig ¶
type BlockDeriverConfig struct {
Enabled bool `yaml:"enabled" default:"false"`
ChunkSize int `yaml:"chunkSize" default:"100"`
Iterator iterator.BackfillingBlockConfig `yaml:"iterator"`
}
BlockDeriverConfig configures the block deriver.
type Config ¶
type Config struct {
// Block configures the canonical_execution_block deriver.
Block BlockDeriverConfig `yaml:"block"`
// Transaction configures the canonical_execution_transaction deriver.
Transaction TransactionDeriverConfig `yaml:"transaction"`
// Logs configures the canonical_execution_logs deriver.
Logs LogsDeriverConfig `yaml:"logs"`
// Traces configures the canonical_execution_traces deriver.
Traces TracesDeriverConfig `yaml:"traces"`
// NativeTransfers configures the canonical_execution_native_transfers deriver.
NativeTransfers NativeTransfersDeriverConfig `yaml:"nativeTransfers"`
// Erc20Transfers configures the canonical_execution_erc20_transfers deriver.
Erc20Transfers Erc20TransfersDeriverConfig `yaml:"erc20Transfers"`
// Erc721Transfers configures the canonical_execution_erc721_transfers deriver.
Erc721Transfers Erc721TransfersDeriverConfig `yaml:"erc721Transfers"`
// Contracts configures the canonical_execution_contracts deriver.
Contracts ContractsDeriverConfig `yaml:"contracts"`
// BalanceDiffs configures the canonical_execution_balance_diffs deriver.
BalanceDiffs BalanceDiffsDeriverConfig `yaml:"balanceDiffs"`
// StorageDiffs configures the canonical_execution_storage_diffs deriver.
StorageDiffs StorageDiffsDeriverConfig `yaml:"storageDiffs"`
// NonceDiffs configures the canonical_execution_nonce_diffs deriver.
NonceDiffs NonceDiffsDeriverConfig `yaml:"nonceDiffs"`
// BalanceReads configures the canonical_execution_balance_reads deriver.
BalanceReads BalanceReadsDeriverConfig `yaml:"balanceReads"`
// StorageReads configures the canonical_execution_storage_reads deriver.
StorageReads StorageReadsDeriverConfig `yaml:"storageReads"`
// NonceReads configures the canonical_execution_nonce_reads deriver.
NonceReads NonceReadsDeriverConfig `yaml:"nonceReads"`
// FourByteCounts configures the canonical_execution_four_byte_counts deriver.
FourByteCounts FourByteCountsDeriverConfig `yaml:"fourByteCounts"`
// AddressAppearances configures the canonical_execution_address_appearances deriver.
AddressAppearances AddressAppearancesDeriverConfig `yaml:"addressAppearances"`
}
Config groups the per-dataset EL (execution-layer) deriver configs. It maps to the `derivers.execution` block in cannon config. The shared EL connection lives in `ethereum.executionNodeAddress` and the cryo runner in the top-level `cryo` config — both are supplied to the derivers by the cannon wiring.
func (*Config) AnyEnabled ¶
AnyEnabled reports whether at least one EL deriver is enabled. Cannon uses this to decide whether the execution node address + cryo config are required.
type ContractsDeriver ¶
type ContractsDeriver struct {
// contains filtered or unexported fields
}
ContractsDeriver derives canonical_execution_contracts events via cryo.
func NewContractsDeriver ¶
func NewContractsDeriver( log observability.ContextualLogger, config *ContractsDeriverConfig, iter *iterator.BackfillingBlock, runner *cryo.Runner, beacon *ethereum.BeaconNode, clientMeta *xatu.ClientMeta, ) *ContractsDeriver
NewContractsDeriver creates a contracts deriver.
func (*ContractsDeriver) ActivationFork ¶
func (b *ContractsDeriver) ActivationFork() spec.DataVersion
ActivationFork returns Phase0 so the deriver starts as soon as the beacon node is ready; the iterator gates EL progress on CL finality.
func (*ContractsDeriver) CannonType ¶
func (b *ContractsDeriver) CannonType() xatu.CannonType
CannonType returns the deriver's cannon type.
func (*ContractsDeriver) Name ¶
func (b *ContractsDeriver) Name() string
Name returns the deriver name.
func (*ContractsDeriver) OnEventsDerived ¶
func (b *ContractsDeriver) OnEventsDerived(_ context.Context, fn func(ctx context.Context, events []*xatu.DecoratedEvent) error)
OnEventsDerived registers a callback for derived events.
type ContractsDeriverConfig ¶
type ContractsDeriverConfig struct {
Enabled bool `yaml:"enabled" default:"false"`
ChunkSize int `yaml:"chunkSize" default:"100"`
Iterator iterator.BackfillingBlockConfig `yaml:"iterator"`
}
ContractsDeriverConfig configures the contracts deriver.
type Erc20TransfersDeriver ¶
type Erc20TransfersDeriver struct {
// contains filtered or unexported fields
}
Erc20TransfersDeriver derives canonical_execution_erc20_transfers events via cryo.
func NewErc20TransfersDeriver ¶
func NewErc20TransfersDeriver( log observability.ContextualLogger, config *Erc20TransfersDeriverConfig, iter *iterator.BackfillingBlock, runner *cryo.Runner, beacon *ethereum.BeaconNode, clientMeta *xatu.ClientMeta, ) *Erc20TransfersDeriver
NewErc20TransfersDeriver creates an erc20_transfers deriver.
func (*Erc20TransfersDeriver) ActivationFork ¶
func (b *Erc20TransfersDeriver) ActivationFork() spec.DataVersion
ActivationFork returns Phase0 so the deriver starts as soon as the beacon node is ready; the iterator gates EL progress on CL finality.
func (*Erc20TransfersDeriver) CannonType ¶
func (b *Erc20TransfersDeriver) CannonType() xatu.CannonType
CannonType returns the deriver's cannon type.
func (*Erc20TransfersDeriver) Name ¶
func (b *Erc20TransfersDeriver) Name() string
Name returns the deriver name.
func (*Erc20TransfersDeriver) OnEventsDerived ¶
func (b *Erc20TransfersDeriver) OnEventsDerived(_ context.Context, fn func(ctx context.Context, events []*xatu.DecoratedEvent) error)
OnEventsDerived registers a callback for derived events.
type Erc20TransfersDeriverConfig ¶
type Erc20TransfersDeriverConfig struct {
Enabled bool `yaml:"enabled" default:"false"`
ChunkSize int `yaml:"chunkSize" default:"100"`
Iterator iterator.BackfillingBlockConfig `yaml:"iterator"`
}
Erc20TransfersDeriverConfig configures the erc20_transfers deriver.
type Erc721TransfersDeriver ¶
type Erc721TransfersDeriver struct {
// contains filtered or unexported fields
}
Erc721TransfersDeriver derives canonical_execution_erc721_transfers events via cryo.
func NewErc721TransfersDeriver ¶
func NewErc721TransfersDeriver( log observability.ContextualLogger, config *Erc721TransfersDeriverConfig, iter *iterator.BackfillingBlock, runner *cryo.Runner, beacon *ethereum.BeaconNode, clientMeta *xatu.ClientMeta, ) *Erc721TransfersDeriver
NewErc721TransfersDeriver creates an erc721 transfers deriver.
func (*Erc721TransfersDeriver) ActivationFork ¶
func (b *Erc721TransfersDeriver) ActivationFork() spec.DataVersion
ActivationFork returns Phase0 so the deriver starts as soon as the beacon node is ready; the iterator gates EL progress on CL finality.
func (*Erc721TransfersDeriver) CannonType ¶
func (b *Erc721TransfersDeriver) CannonType() xatu.CannonType
CannonType returns the deriver's cannon type.
func (*Erc721TransfersDeriver) Name ¶
func (b *Erc721TransfersDeriver) Name() string
Name returns the deriver name.
func (*Erc721TransfersDeriver) OnEventsDerived ¶
func (b *Erc721TransfersDeriver) OnEventsDerived(_ context.Context, fn func(ctx context.Context, events []*xatu.DecoratedEvent) error)
OnEventsDerived registers a callback for derived events.
type Erc721TransfersDeriverConfig ¶
type Erc721TransfersDeriverConfig struct {
Enabled bool `yaml:"enabled" default:"false"`
ChunkSize int `yaml:"chunkSize" default:"100"`
Iterator iterator.BackfillingBlockConfig `yaml:"iterator"`
}
Erc721TransfersDeriverConfig configures the erc721 transfers deriver.
type FourByteCountsDeriver ¶
type FourByteCountsDeriver struct {
// contains filtered or unexported fields
}
FourByteCountsDeriver derives canonical_execution_four_byte_counts events via cryo.
func NewFourByteCountsDeriver ¶
func NewFourByteCountsDeriver( log observability.ContextualLogger, config *FourByteCountsDeriverConfig, iter *iterator.BackfillingBlock, runner *cryo.Runner, beacon *ethereum.BeaconNode, clientMeta *xatu.ClientMeta, ) *FourByteCountsDeriver
NewFourByteCountsDeriver creates a four_byte_counts deriver.
func (*FourByteCountsDeriver) ActivationFork ¶
func (b *FourByteCountsDeriver) ActivationFork() spec.DataVersion
ActivationFork returns Phase0 so the deriver starts as soon as the beacon node is ready; the iterator gates EL progress on CL finality.
func (*FourByteCountsDeriver) CannonType ¶
func (b *FourByteCountsDeriver) CannonType() xatu.CannonType
CannonType returns the deriver's cannon type.
func (*FourByteCountsDeriver) Name ¶
func (b *FourByteCountsDeriver) Name() string
Name returns the deriver name.
func (*FourByteCountsDeriver) OnEventsDerived ¶
func (b *FourByteCountsDeriver) OnEventsDerived(_ context.Context, fn func(ctx context.Context, events []*xatu.DecoratedEvent) error)
OnEventsDerived registers a callback for derived events.
type FourByteCountsDeriverConfig ¶
type FourByteCountsDeriverConfig struct {
Enabled bool `yaml:"enabled" default:"false"`
ChunkSize int `yaml:"chunkSize" default:"100"`
Iterator iterator.BackfillingBlockConfig `yaml:"iterator"`
}
FourByteCountsDeriverConfig configures the four_byte_counts deriver.
type LogsDeriver ¶
type LogsDeriver struct {
// contains filtered or unexported fields
}
LogsDeriver derives canonical_execution_logs events via cryo.
func NewLogsDeriver ¶
func NewLogsDeriver( log observability.ContextualLogger, config *LogsDeriverConfig, iter *iterator.BackfillingBlock, runner *cryo.Runner, beacon *ethereum.BeaconNode, clientMeta *xatu.ClientMeta, ) *LogsDeriver
NewLogsDeriver creates a logs deriver.
func (*LogsDeriver) ActivationFork ¶
func (b *LogsDeriver) ActivationFork() spec.DataVersion
ActivationFork returns Phase0 so the deriver starts as soon as the beacon node is ready; the iterator gates EL progress on CL finality.
func (*LogsDeriver) CannonType ¶
func (b *LogsDeriver) CannonType() xatu.CannonType
CannonType returns the deriver's cannon type.
func (*LogsDeriver) OnEventsDerived ¶
func (b *LogsDeriver) OnEventsDerived(_ context.Context, fn func(ctx context.Context, events []*xatu.DecoratedEvent) error)
OnEventsDerived registers a callback for derived events.
type LogsDeriverConfig ¶
type LogsDeriverConfig struct {
Enabled bool `yaml:"enabled" default:"false"`
ChunkSize int `yaml:"chunkSize" default:"100"`
Iterator iterator.BackfillingBlockConfig `yaml:"iterator"`
}
LogsDeriverConfig configures the logs deriver.
type NativeTransfersDeriver ¶
type NativeTransfersDeriver struct {
// contains filtered or unexported fields
}
NativeTransfersDeriver derives canonical_execution_native_transfers events via cryo.
func NewNativeTransfersDeriver ¶
func NewNativeTransfersDeriver( log observability.ContextualLogger, config *NativeTransfersDeriverConfig, iter *iterator.BackfillingBlock, runner *cryo.Runner, beacon *ethereum.BeaconNode, clientMeta *xatu.ClientMeta, ) *NativeTransfersDeriver
NewNativeTransfersDeriver creates a native transfers deriver.
func (*NativeTransfersDeriver) ActivationFork ¶
func (b *NativeTransfersDeriver) ActivationFork() spec.DataVersion
ActivationFork returns Phase0 so the deriver starts as soon as the beacon node is ready; the iterator gates EL progress on CL finality.
func (*NativeTransfersDeriver) CannonType ¶
func (b *NativeTransfersDeriver) CannonType() xatu.CannonType
CannonType returns the deriver's cannon type.
func (*NativeTransfersDeriver) Name ¶
func (b *NativeTransfersDeriver) Name() string
Name returns the deriver name.
func (*NativeTransfersDeriver) OnEventsDerived ¶
func (b *NativeTransfersDeriver) OnEventsDerived(_ context.Context, fn func(ctx context.Context, events []*xatu.DecoratedEvent) error)
OnEventsDerived registers a callback for derived events.
type NativeTransfersDeriverConfig ¶
type NativeTransfersDeriverConfig struct {
Enabled bool `yaml:"enabled" default:"false"`
ChunkSize int `yaml:"chunkSize" default:"100"`
Iterator iterator.BackfillingBlockConfig `yaml:"iterator"`
}
NativeTransfersDeriverConfig configures the native transfers deriver.
type NonceDiffsDeriver ¶
type NonceDiffsDeriver struct {
// contains filtered or unexported fields
}
NonceDiffsDeriver derives canonical_execution_nonce_diffs events via cryo.
func NewNonceDiffsDeriver ¶
func NewNonceDiffsDeriver( log observability.ContextualLogger, config *NonceDiffsDeriverConfig, iter *iterator.BackfillingBlock, runner *cryo.Runner, beacon *ethereum.BeaconNode, clientMeta *xatu.ClientMeta, ) *NonceDiffsDeriver
NewNonceDiffsDeriver creates a nonce_diffs deriver.
func (*NonceDiffsDeriver) ActivationFork ¶
func (b *NonceDiffsDeriver) ActivationFork() spec.DataVersion
ActivationFork returns Phase0 so the deriver starts as soon as the beacon node is ready; the iterator gates EL progress on CL finality.
func (*NonceDiffsDeriver) CannonType ¶
func (b *NonceDiffsDeriver) CannonType() xatu.CannonType
CannonType returns the deriver's cannon type.
func (*NonceDiffsDeriver) Name ¶
func (b *NonceDiffsDeriver) Name() string
Name returns the deriver name.
func (*NonceDiffsDeriver) OnEventsDerived ¶
func (b *NonceDiffsDeriver) OnEventsDerived(_ context.Context, fn func(ctx context.Context, events []*xatu.DecoratedEvent) error)
OnEventsDerived registers a callback for derived events.
type NonceDiffsDeriverConfig ¶
type NonceDiffsDeriverConfig struct {
Enabled bool `yaml:"enabled" default:"false"`
ChunkSize int `yaml:"chunkSize" default:"100"`
Iterator iterator.BackfillingBlockConfig `yaml:"iterator"`
}
NonceDiffsDeriverConfig configures the nonce_diffs deriver.
type NonceReadsDeriver ¶
type NonceReadsDeriver struct {
// contains filtered or unexported fields
}
NonceReadsDeriver derives canonical_execution_nonce_reads events via cryo.
func NewNonceReadsDeriver ¶
func NewNonceReadsDeriver( log observability.ContextualLogger, config *NonceReadsDeriverConfig, iter *iterator.BackfillingBlock, runner *cryo.Runner, beacon *ethereum.BeaconNode, clientMeta *xatu.ClientMeta, ) *NonceReadsDeriver
NewNonceReadsDeriver creates a nonce reads deriver.
func (*NonceReadsDeriver) ActivationFork ¶
func (b *NonceReadsDeriver) ActivationFork() spec.DataVersion
ActivationFork returns Phase0 so the deriver starts as soon as the beacon node is ready; the iterator gates EL progress on CL finality.
func (*NonceReadsDeriver) CannonType ¶
func (b *NonceReadsDeriver) CannonType() xatu.CannonType
CannonType returns the deriver's cannon type.
func (*NonceReadsDeriver) Name ¶
func (b *NonceReadsDeriver) Name() string
Name returns the deriver name.
func (*NonceReadsDeriver) OnEventsDerived ¶
func (b *NonceReadsDeriver) OnEventsDerived(_ context.Context, fn func(ctx context.Context, events []*xatu.DecoratedEvent) error)
OnEventsDerived registers a callback for derived events.
type NonceReadsDeriverConfig ¶
type NonceReadsDeriverConfig struct {
Enabled bool `yaml:"enabled" default:"false"`
ChunkSize int `yaml:"chunkSize" default:"100"`
Iterator iterator.BackfillingBlockConfig `yaml:"iterator"`
}
NonceReadsDeriverConfig configures the nonce reads deriver.
type StorageDiffsDeriver ¶
type StorageDiffsDeriver struct {
// contains filtered or unexported fields
}
StorageDiffsDeriver derives canonical_execution_storage_diffs events via cryo.
func NewStorageDiffsDeriver ¶
func NewStorageDiffsDeriver( log observability.ContextualLogger, config *StorageDiffsDeriverConfig, iter *iterator.BackfillingBlock, runner *cryo.Runner, beacon *ethereum.BeaconNode, clientMeta *xatu.ClientMeta, ) *StorageDiffsDeriver
NewStorageDiffsDeriver creates a storage diffs deriver.
func (*StorageDiffsDeriver) ActivationFork ¶
func (b *StorageDiffsDeriver) ActivationFork() spec.DataVersion
ActivationFork returns Phase0 so the deriver starts as soon as the beacon node is ready; the iterator gates EL progress on CL finality.
func (*StorageDiffsDeriver) CannonType ¶
func (b *StorageDiffsDeriver) CannonType() xatu.CannonType
CannonType returns the deriver's cannon type.
func (*StorageDiffsDeriver) Name ¶
func (b *StorageDiffsDeriver) Name() string
Name returns the deriver name.
func (*StorageDiffsDeriver) OnEventsDerived ¶
func (b *StorageDiffsDeriver) OnEventsDerived(_ context.Context, fn func(ctx context.Context, events []*xatu.DecoratedEvent) error)
OnEventsDerived registers a callback for derived events.
type StorageDiffsDeriverConfig ¶
type StorageDiffsDeriverConfig struct {
Enabled bool `yaml:"enabled" default:"false"`
ChunkSize int `yaml:"chunkSize" default:"100"`
Iterator iterator.BackfillingBlockConfig `yaml:"iterator"`
}
StorageDiffsDeriverConfig configures the storage diffs deriver.
type StorageReadsDeriver ¶
type StorageReadsDeriver struct {
// contains filtered or unexported fields
}
StorageReadsDeriver derives canonical_execution_storage_reads events via cryo.
func NewStorageReadsDeriver ¶
func NewStorageReadsDeriver( log observability.ContextualLogger, config *StorageReadsDeriverConfig, iter *iterator.BackfillingBlock, runner *cryo.Runner, beacon *ethereum.BeaconNode, clientMeta *xatu.ClientMeta, ) *StorageReadsDeriver
NewStorageReadsDeriver creates a storage reads deriver.
func (*StorageReadsDeriver) ActivationFork ¶
func (b *StorageReadsDeriver) ActivationFork() spec.DataVersion
ActivationFork returns Phase0 so the deriver starts as soon as the beacon node is ready; the iterator gates EL progress on CL finality.
func (*StorageReadsDeriver) CannonType ¶
func (b *StorageReadsDeriver) CannonType() xatu.CannonType
CannonType returns the deriver's cannon type.
func (*StorageReadsDeriver) Name ¶
func (b *StorageReadsDeriver) Name() string
Name returns the deriver name.
func (*StorageReadsDeriver) OnEventsDerived ¶
func (b *StorageReadsDeriver) OnEventsDerived(_ context.Context, fn func(ctx context.Context, events []*xatu.DecoratedEvent) error)
OnEventsDerived registers a callback for derived events.
type StorageReadsDeriverConfig ¶
type StorageReadsDeriverConfig struct {
Enabled bool `yaml:"enabled" default:"false"`
ChunkSize int `yaml:"chunkSize" default:"100"`
Iterator iterator.BackfillingBlockConfig `yaml:"iterator"`
}
StorageReadsDeriverConfig configures the storage reads deriver.
type TracesDeriver ¶
type TracesDeriver struct {
// contains filtered or unexported fields
}
TracesDeriver derives canonical_execution_traces events via cryo.
func NewTracesDeriver ¶
func NewTracesDeriver( log observability.ContextualLogger, config *TracesDeriverConfig, iter *iterator.BackfillingBlock, runner *cryo.Runner, beacon *ethereum.BeaconNode, clientMeta *xatu.ClientMeta, ) *TracesDeriver
NewTracesDeriver creates a traces deriver.
func (*TracesDeriver) ActivationFork ¶
func (b *TracesDeriver) ActivationFork() spec.DataVersion
ActivationFork returns Phase0 so the deriver starts as soon as the beacon node is ready; the iterator gates EL progress on CL finality.
func (*TracesDeriver) CannonType ¶
func (b *TracesDeriver) CannonType() xatu.CannonType
CannonType returns the deriver's cannon type.
func (*TracesDeriver) OnEventsDerived ¶
func (b *TracesDeriver) OnEventsDerived(_ context.Context, fn func(ctx context.Context, events []*xatu.DecoratedEvent) error)
OnEventsDerived registers a callback for derived events.
type TracesDeriverConfig ¶
type TracesDeriverConfig struct {
Enabled bool `yaml:"enabled" default:"false"`
ChunkSize int `yaml:"chunkSize" default:"100"`
Iterator iterator.BackfillingBlockConfig `yaml:"iterator"`
}
TracesDeriverConfig configures the traces deriver.
type TransactionDeriver ¶
type TransactionDeriver struct {
// contains filtered or unexported fields
}
TransactionDeriver derives canonical_execution_transaction events via cryo.
func NewTransactionDeriver ¶
func NewTransactionDeriver( log observability.ContextualLogger, config *TransactionDeriverConfig, iter *iterator.BackfillingBlock, runner *cryo.Runner, beacon *ethereum.BeaconNode, clientMeta *xatu.ClientMeta, ) *TransactionDeriver
NewTransactionDeriver creates a transaction deriver.
func (*TransactionDeriver) ActivationFork ¶
func (b *TransactionDeriver) ActivationFork() spec.DataVersion
ActivationFork returns Phase0 so the deriver starts as soon as the beacon node is ready; the iterator gates EL progress on CL finality.
func (*TransactionDeriver) CannonType ¶
func (b *TransactionDeriver) CannonType() xatu.CannonType
CannonType returns the deriver's cannon type.
func (*TransactionDeriver) Name ¶
func (b *TransactionDeriver) Name() string
Name returns the deriver name.
func (*TransactionDeriver) OnEventsDerived ¶
func (b *TransactionDeriver) OnEventsDerived(_ context.Context, fn func(ctx context.Context, events []*xatu.DecoratedEvent) error)
OnEventsDerived registers a callback for derived events.
type TransactionDeriverConfig ¶
type TransactionDeriverConfig struct {
Enabled bool `yaml:"enabled" default:"false"`
ChunkSize int `yaml:"chunkSize" default:"100"`
Iterator iterator.BackfillingBlockConfig `yaml:"iterator"`
}
TransactionDeriverConfig configures the transaction deriver.