v2

package
v1.0.10 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Nov 4, 2024 License: GPL-3.0 Imports: 30 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	AttesterSlashingDeriverName = xatu.CannonType_BEACON_API_ETH_V2_BEACON_BLOCK_ATTESTER_SLASHING
)
View Source 
const (
	BLSToExecutionChangeDeriverName = xatu.CannonType_BEACON_API_ETH_V2_BEACON_BLOCK_BLS_TO_EXECUTION_CHANGE
)
View Source 
const (
	BeaconBlockDeriverName = xatu.CannonType_BEACON_API_ETH_V2_BEACON_BLOCK
)
View Source 
const (
	DepositDeriverName = xatu.CannonType_BEACON_API_ETH_V2_BEACON_BLOCK_DEPOSIT
)
View Source 
const (
	ElaboratedAttestationDeriverName = xatu.CannonType_BEACON_API_ETH_V2_BEACON_BLOCK_ELABORATED_ATTESTATION
)
View Source 
const (
	ExecutionTransactionDeriverName = xatu.CannonType_BEACON_API_ETH_V2_BEACON_BLOCK_EXECUTION_TRANSACTION
)
View Source 
const (
	ProposerSlashingDeriverName = xatu.CannonType_BEACON_API_ETH_V2_BEACON_BLOCK_PROPOSER_SLASHING
)
View Source 
const (
	VoluntaryExitDeriverName = xatu.CannonType_BEACON_API_ETH_V2_BEACON_BLOCK_VOLUNTARY_EXIT
)
View Source 
const (
	WithdrawalDeriverName = xatu.CannonType_BEACON_API_ETH_V2_BEACON_BLOCK_WITHDRAWAL
)

Variables

This section is empty.

Functions

func GetBlockIdentifier 

func GetBlockIdentifier(block *spec.VersionedSignedBeaconBlock, wallclock *ethwallclock.EthereumBeaconChain) (*xatu.BlockIdentifier, error)

Types

type AttesterSlashingDeriver 

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

func NewAttesterSlashingDeriver 

func NewAttesterSlashingDeriver(log logrus.FieldLogger, config *AttesterSlashingDeriverConfig, iter *iterator.BackfillingCheckpoint, beacon *ethereum.BeaconNode, clientMeta *xatu.ClientMeta) *AttesterSlashingDeriver

func (*AttesterSlashingDeriver) ActivationFork added in v0.0.140 

func (a *AttesterSlashingDeriver) ActivationFork() string

func (*AttesterSlashingDeriver) CannonType 

func (a *AttesterSlashingDeriver) CannonType() xatu.CannonType

func (*AttesterSlashingDeriver) Name 

func (a *AttesterSlashingDeriver) Name() string

func (*AttesterSlashingDeriver) OnEventsDerived 

func (a *AttesterSlashingDeriver) OnEventsDerived(ctx context.Context, fn func(ctx context.Context, events []*xatu.DecoratedEvent) error)

func (*AttesterSlashingDeriver) Start 

func (a *AttesterSlashingDeriver) Start(ctx context.Context) error

func (*AttesterSlashingDeriver) Stop 

func (a *AttesterSlashingDeriver) Stop(ctx context.Context) error

type AttesterSlashingDeriverConfig 

type AttesterSlashingDeriverConfig struct {
	Enabled  bool                                 `yaml:"enabled" default:"true"`
	Iterator iterator.BackfillingCheckpointConfig `yaml:"iterator"`
}

type BLSToExecutionChangeDeriver 

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

func NewBLSToExecutionChangeDeriver 

func NewBLSToExecutionChangeDeriver(log logrus.FieldLogger, config *BLSToExecutionChangeDeriverConfig, iter *iterator.BackfillingCheckpoint, beacon *ethereum.BeaconNode, clientMeta *xatu.ClientMeta) *BLSToExecutionChangeDeriver

func (*BLSToExecutionChangeDeriver) ActivationFork added in v0.0.140 

func (b *BLSToExecutionChangeDeriver) ActivationFork() string

func (*BLSToExecutionChangeDeriver) CannonType 

func (b *BLSToExecutionChangeDeriver) CannonType() xatu.CannonType

func (*BLSToExecutionChangeDeriver) Name 

func (b *BLSToExecutionChangeDeriver) Name() string

func (*BLSToExecutionChangeDeriver) OnEventsDerived 

func (b *BLSToExecutionChangeDeriver) OnEventsDerived(ctx context.Context, fn func(ctx context.Context, events []*xatu.DecoratedEvent) error)

func (*BLSToExecutionChangeDeriver) Start 

func (b *BLSToExecutionChangeDeriver) Start(ctx context.Context) error

func (*BLSToExecutionChangeDeriver) Stop 

func (b *BLSToExecutionChangeDeriver) Stop(ctx context.Context) error

type BLSToExecutionChangeDeriverConfig 

type BLSToExecutionChangeDeriverConfig struct {
	Enabled  bool                                 `yaml:"enabled" default:"true"`
	Iterator iterator.BackfillingCheckpointConfig `yaml:"iterator"`
}

type BeaconBlockDeriver 

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

func NewBeaconBlockDeriver 

func NewBeaconBlockDeriver(log logrus.FieldLogger, config *BeaconBlockDeriverConfig, iter *iterator.BackfillingCheckpoint, beacon *ethereum.BeaconNode, clientMeta *xatu.ClientMeta) *BeaconBlockDeriver

func (*BeaconBlockDeriver) ActivationFork added in v0.0.140 

func (b *BeaconBlockDeriver) ActivationFork() string

func (*BeaconBlockDeriver) CannonType 

func (b *BeaconBlockDeriver) CannonType() xatu.CannonType

func (*BeaconBlockDeriver) Name 

func (b *BeaconBlockDeriver) Name() string

func (*BeaconBlockDeriver) OnEventsDerived 

func (b *BeaconBlockDeriver) OnEventsDerived(ctx context.Context, fn func(ctx context.Context, events []*xatu.DecoratedEvent) error)

func (*BeaconBlockDeriver) Start 

func (b *BeaconBlockDeriver) Start(ctx context.Context) error

func (*BeaconBlockDeriver) Stop 

func (b *BeaconBlockDeriver) Stop(ctx context.Context) error

type BeaconBlockDeriverConfig 

type BeaconBlockDeriverConfig struct {
	Enabled  bool                                 `yaml:"enabled" default:"true"`
	Iterator iterator.BackfillingCheckpointConfig `yaml:"iterator"`
}

type DepositDeriver 

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

func NewDepositDeriver 

func NewDepositDeriver(log logrus.FieldLogger, config *DepositDeriverConfig, iter *iterator.BackfillingCheckpoint, beacon *ethereum.BeaconNode, clientMeta *xatu.ClientMeta) *DepositDeriver

func (*DepositDeriver) ActivationFork added in v0.0.140 

func (b *DepositDeriver) ActivationFork() string

func (*DepositDeriver) CannonType 

func (b *DepositDeriver) CannonType() xatu.CannonType

func (*DepositDeriver) Name 

func (b *DepositDeriver) Name() string

func (*DepositDeriver) OnEventsDerived 

func (b *DepositDeriver) OnEventsDerived(ctx context.Context, fn func(ctx context.Context, events []*xatu.DecoratedEvent) error)

func (*DepositDeriver) Start 

func (b *DepositDeriver) Start(ctx context.Context) error

func (*DepositDeriver) Stop 

func (b *DepositDeriver) Stop(ctx context.Context) error

type DepositDeriverConfig 

type DepositDeriverConfig struct {
	Enabled  bool                                 `yaml:"enabled" default:"true"`
	Iterator iterator.BackfillingCheckpointConfig `yaml:"iterator"`
}

type ElaboratedAttestationDeriver added in v0.0.139 

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

func NewElaboratedAttestationDeriver added in v0.0.139 

func NewElaboratedAttestationDeriver(log logrus.FieldLogger, config *ElaboratedAttestationDeriverConfig, iter *iterator.BackfillingCheckpoint, beacon *ethereum.BeaconNode, clientMeta *xatu.ClientMeta) *ElaboratedAttestationDeriver

func (*ElaboratedAttestationDeriver) ActivationFork added in v0.0.140 

func (b *ElaboratedAttestationDeriver) ActivationFork() string

func (*ElaboratedAttestationDeriver) CannonType added in v0.0.139 

func (b *ElaboratedAttestationDeriver) CannonType() xatu.CannonType

func (*ElaboratedAttestationDeriver) Name added in v0.0.139 

func (b *ElaboratedAttestationDeriver) Name() string

func (*ElaboratedAttestationDeriver) OnEventsDerived added in v0.0.139 

func (b *ElaboratedAttestationDeriver) OnEventsDerived(ctx context.Context, fn func(ctx context.Context, events []*xatu.DecoratedEvent) error)

func (*ElaboratedAttestationDeriver) Start added in v0.0.139 

func (b *ElaboratedAttestationDeriver) Start(ctx context.Context) error

func (*ElaboratedAttestationDeriver) Stop added in v0.0.139 

func (b *ElaboratedAttestationDeriver) Stop(ctx context.Context) error

type ElaboratedAttestationDeriverConfig added in v0.0.139 

type ElaboratedAttestationDeriverConfig struct {
	Enabled  bool                                 `yaml:"enabled" default:"true"`
	Iterator iterator.BackfillingCheckpointConfig `yaml:"iterator"`
}

type ExecutionTransactionDeriver 

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

func NewExecutionTransactionDeriver 

func NewExecutionTransactionDeriver(log logrus.FieldLogger, config *ExecutionTransactionDeriverConfig, iter *iterator.BackfillingCheckpoint, beacon *ethereum.BeaconNode, clientMeta *xatu.ClientMeta) *ExecutionTransactionDeriver

func (*ExecutionTransactionDeriver) ActivationFork added in v0.0.140 

func (b *ExecutionTransactionDeriver) ActivationFork() string

func (*ExecutionTransactionDeriver) CannonType 

func (b *ExecutionTransactionDeriver) CannonType() xatu.CannonType

func (*ExecutionTransactionDeriver) Name 

func (b *ExecutionTransactionDeriver) Name() string

func (*ExecutionTransactionDeriver) OnEventsDerived 

func (b *ExecutionTransactionDeriver) OnEventsDerived(ctx context.Context, fn func(ctx context.Context, events []*xatu.DecoratedEvent) error)

func (*ExecutionTransactionDeriver) Start 

func (b *ExecutionTransactionDeriver) Start(ctx context.Context) error

func (*ExecutionTransactionDeriver) Stop 

func (b *ExecutionTransactionDeriver) Stop(ctx context.Context) error

type ExecutionTransactionDeriverConfig 

type ExecutionTransactionDeriverConfig struct {
	Enabled  bool                                 `yaml:"enabled" default:"true"`
	Iterator iterator.BackfillingCheckpointConfig `yaml:"iterator"`
}

type ProposerSlashingDeriver 

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

func NewProposerSlashingDeriver 

func NewProposerSlashingDeriver(log logrus.FieldLogger, config *ProposerSlashingDeriverConfig, iter *iterator.BackfillingCheckpoint, beacon *ethereum.BeaconNode, clientMeta *xatu.ClientMeta) *ProposerSlashingDeriver

func (*ProposerSlashingDeriver) ActivationFork added in v0.0.140 

func (b *ProposerSlashingDeriver) ActivationFork() string

func (*ProposerSlashingDeriver) CannonType 

func (b *ProposerSlashingDeriver) CannonType() xatu.CannonType

func (*ProposerSlashingDeriver) Name 

func (b *ProposerSlashingDeriver) Name() string

func (*ProposerSlashingDeriver) OnEventsDerived 

func (b *ProposerSlashingDeriver) OnEventsDerived(ctx context.Context, fn func(ctx context.Context, events []*xatu.DecoratedEvent) error)

func (*ProposerSlashingDeriver) Start 

func (b *ProposerSlashingDeriver) Start(ctx context.Context) error

func (*ProposerSlashingDeriver) Stop 

func (b *ProposerSlashingDeriver) Stop(ctx context.Context) error

type ProposerSlashingDeriverConfig 

type ProposerSlashingDeriverConfig struct {
	Enabled  bool                                 `yaml:"enabled" default:"true"`
	Iterator iterator.BackfillingCheckpointConfig `yaml:"iterator"`
}

type VoluntaryExitDeriver 

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

func NewVoluntaryExitDeriver 

func NewVoluntaryExitDeriver(log logrus.FieldLogger, config *VoluntaryExitDeriverConfig, iter *iterator.BackfillingCheckpoint, beacon *ethereum.BeaconNode, clientMeta *xatu.ClientMeta) *VoluntaryExitDeriver

func (*VoluntaryExitDeriver) ActivationFork added in v0.0.140 

func (b *VoluntaryExitDeriver) ActivationFork() string

func (*VoluntaryExitDeriver) CannonType 

func (b *VoluntaryExitDeriver) CannonType() xatu.CannonType

func (*VoluntaryExitDeriver) Name 

func (b *VoluntaryExitDeriver) Name() string

func (*VoluntaryExitDeriver) OnEventsDerived 

func (b *VoluntaryExitDeriver) OnEventsDerived(ctx context.Context, fn func(ctx context.Context, events []*xatu.DecoratedEvent) error)

func (*VoluntaryExitDeriver) Start 

func (b *VoluntaryExitDeriver) Start(ctx context.Context) error

func (*VoluntaryExitDeriver) Stop 

func (b *VoluntaryExitDeriver) Stop(ctx context.Context) error

type VoluntaryExitDeriverConfig 

type VoluntaryExitDeriverConfig struct {
	Enabled  bool                                 `yaml:"enabled" default:"true"`
	Iterator iterator.BackfillingCheckpointConfig `yaml:"iterator"`
}

type WithdrawalDeriver 

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

func NewWithdrawalDeriver 

func NewWithdrawalDeriver(log logrus.FieldLogger, config *WithdrawalDeriverConfig, iter *iterator.BackfillingCheckpoint, beacon *ethereum.BeaconNode, clientMeta *xatu.ClientMeta) *WithdrawalDeriver

func (*WithdrawalDeriver) ActivationFork added in v0.0.140 

func (b *WithdrawalDeriver) ActivationFork() string

func (*WithdrawalDeriver) CannonType 

func (b *WithdrawalDeriver) CannonType() xatu.CannonType

func (*WithdrawalDeriver) Name 

func (b *WithdrawalDeriver) Name() string

func (*WithdrawalDeriver) OnEventsDerived 

func (b *WithdrawalDeriver) OnEventsDerived(ctx context.Context, fn func(ctx context.Context, events []*xatu.DecoratedEvent) error)

func (*WithdrawalDeriver) Start 

func (b *WithdrawalDeriver) Start(ctx context.Context) error

func (*WithdrawalDeriver) Stop 

func (b *WithdrawalDeriver) Stop(ctx context.Context) error

type WithdrawalDeriverConfig 

type WithdrawalDeriverConfig struct {
	Enabled  bool                                 `yaml:"enabled" default:"true"`
	Iterator iterator.BackfillingCheckpointConfig `yaml:"iterator"`
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.