v1

package
v1.0.16 Latest Latest
Warning

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

Go to latest
Published: Dec 2, 2024 License: GPL-3.0 Imports: 23 Imported by: 0

Documentation

Index

Constants

View Source
const (
	BeaconCommitteeDeriverName = xatu.CannonType_BEACON_API_ETH_V1_BEACON_COMMITTEE
)
View Source
const (
	BeaconValidatorsDeriverName = xatu.CannonType_BEACON_API_ETH_V1_BEACON_VALIDATORS
)
View Source
const (
	ProposerDutyDeriverName = xatu.CannonType_BEACON_API_ETH_V1_PROPOSER_DUTY
)

Variables

This section is empty.

Functions

This section is empty.

Types

type BeaconBlobDeriver

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

func (*BeaconBlobDeriver) ActivationFork added in v0.0.140

func (b *BeaconBlobDeriver) ActivationFork() string

func (*BeaconBlobDeriver) CannonType

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

func (*BeaconBlobDeriver) Name

func (b *BeaconBlobDeriver) Name() string

func (*BeaconBlobDeriver) OnEventsDerived

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

func (*BeaconBlobDeriver) Start

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

func (*BeaconBlobDeriver) Stop

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

type BeaconBlobDeriverConfig

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

type BeaconCommitteeDeriver added in v0.0.183

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

func NewBeaconCommitteeDeriver added in v0.0.183

func NewBeaconCommitteeDeriver(log logrus.FieldLogger, config *BeaconCommitteeDeriverConfig, iter *iterator.BackfillingCheckpoint, beacon *ethereum.BeaconNode, clientMeta *xatu.ClientMeta) *BeaconCommitteeDeriver

func (*BeaconCommitteeDeriver) ActivationFork added in v0.0.183

func (b *BeaconCommitteeDeriver) ActivationFork() string

func (*BeaconCommitteeDeriver) CannonType added in v0.0.183

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

func (*BeaconCommitteeDeriver) Name added in v0.0.183

func (b *BeaconCommitteeDeriver) Name() string

func (*BeaconCommitteeDeriver) OnEventsDerived added in v0.0.183

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

func (*BeaconCommitteeDeriver) Start added in v0.0.183

func (*BeaconCommitteeDeriver) Stop added in v0.0.183

type BeaconCommitteeDeriverConfig added in v0.0.183

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

type BeaconValidatorsDeriver added in v0.0.172

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

func NewBeaconValidatorsDeriver added in v0.0.172

func NewBeaconValidatorsDeriver(log logrus.FieldLogger, config *BeaconValidatorsDeriverConfig, iter *iterator.BackfillingCheckpoint, beacon *ethereum.BeaconNode, clientMeta *xatu.ClientMeta) *BeaconValidatorsDeriver

func (*BeaconValidatorsDeriver) ActivationFork added in v0.0.172

func (b *BeaconValidatorsDeriver) ActivationFork() string

func (*BeaconValidatorsDeriver) CannonType added in v0.0.172

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

func (*BeaconValidatorsDeriver) Name added in v0.0.172

func (b *BeaconValidatorsDeriver) Name() string

func (*BeaconValidatorsDeriver) OnEventsDerived added in v0.0.172

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

func (*BeaconValidatorsDeriver) Start added in v0.0.172

func (*BeaconValidatorsDeriver) Stop added in v0.0.172

type BeaconValidatorsDeriverConfig added in v0.0.172

type BeaconValidatorsDeriverConfig struct {
	Enabled   bool                                 `yaml:"enabled" default:"true"`
	ChunkSize int                                  `yaml:"chunkSize" default:"100"`
	Iterator  iterator.BackfillingCheckpointConfig `yaml:"iterator"`
}

type ProposerDutyDeriver added in v0.0.136

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

func NewProposerDutyDeriver added in v0.0.136

func NewProposerDutyDeriver(log logrus.FieldLogger, config *ProposerDutyDeriverConfig, iter *iterator.BackfillingCheckpoint, beacon *ethereum.BeaconNode, clientMeta *xatu.ClientMeta) *ProposerDutyDeriver

func (*ProposerDutyDeriver) ActivationFork added in v0.0.140

func (b *ProposerDutyDeriver) ActivationFork() string

func (*ProposerDutyDeriver) CannonType added in v0.0.136

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

func (*ProposerDutyDeriver) Name added in v0.0.136

func (b *ProposerDutyDeriver) Name() string

func (*ProposerDutyDeriver) OnEventsDerived added in v0.0.136

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

func (*ProposerDutyDeriver) Start added in v0.0.136

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

func (*ProposerDutyDeriver) Stop added in v0.0.136

type ProposerDutyDeriverConfig added in v0.0.136

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL