v1

package
v0.0.204 Latest Latest
Warning

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

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

Documentation

Index

Constants

View Source 
const (
	BeaconBlobDeriverName = xatu.CannonType_BEACON_API_ETH_V1_BEACON_BLOB_SIDECAR
)
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 NewBeaconBlobDeriver 

func NewBeaconBlobDeriver(log logrus.FieldLogger, config *BeaconBlobDeriverConfig, iter *iterator.BackfillingCheckpoint, beacon *ethereum.BeaconNode, clientMeta *xatu.ClientMeta) *BeaconBlobDeriver

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"`
}

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 (b *BeaconCommitteeDeriver) Start(ctx context.Context) error

func (*BeaconCommitteeDeriver) Stop added in v0.0.183 

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

type BeaconCommitteeDeriverConfig added in v0.0.183 

type BeaconCommitteeDeriverConfig struct {
	Enabled bool `yaml:"enabled" default:"true"`
}

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 (b *BeaconValidatorsDeriver) Start(ctx context.Context) error

func (*BeaconValidatorsDeriver) Stop added in v0.0.172 

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

type BeaconValidatorsDeriverConfig added in v0.0.172 

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

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 

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

type ProposerDutyDeriverConfig added in v0.0.136 

type ProposerDutyDeriverConfig struct {
	Enabled bool `yaml:"enabled" default:"true"`
}

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.