v1

Documentation

Index

• Constants
• type BeaconBlobDeriver
  • func NewBeaconBlobDeriver(log logrus.FieldLogger, config *BeaconBlobDeriverConfig, ...) *BeaconBlobDeriver
  • func (b *BeaconBlobDeriver) ActivationFork() string
  • func (b *BeaconBlobDeriver) CannonType() xatu.CannonType
  • func (b *BeaconBlobDeriver) Name() string
  • func (b *BeaconBlobDeriver) OnEventsDerived(ctx context.Context, ...)
  • func (b *BeaconBlobDeriver) Start(ctx context.Context) error
  • func (b *BeaconBlobDeriver) Stop(ctx context.Context) error
• type BeaconBlobDeriverConfig
• type BeaconValidatorsDeriver
  • func NewBeaconValidatorsDeriver(log logrus.FieldLogger, config *BeaconValidatorsDeriverConfig, ...) *BeaconValidatorsDeriver
  • func (b *BeaconValidatorsDeriver) ActivationFork() string
  • func (b *BeaconValidatorsDeriver) CannonType() xatu.CannonType
  • func (b *BeaconValidatorsDeriver) Name() string
  • func (b *BeaconValidatorsDeriver) OnEventsDerived(ctx context.Context, ...)
  • func (b *BeaconValidatorsDeriver) Start(ctx context.Context) error
  • func (b *BeaconValidatorsDeriver) Stop(ctx context.Context) error
• type BeaconValidatorsDeriverConfig
• type ProposerDutyDeriver
  • func NewProposerDutyDeriver(log logrus.FieldLogger, config *ProposerDutyDeriverConfig, ...) *ProposerDutyDeriver
  • func (b *ProposerDutyDeriver) ActivationFork() string
  • func (b *ProposerDutyDeriver) CannonType() xatu.CannonType
  • func (b *ProposerDutyDeriver) Name() string
  • func (b *ProposerDutyDeriver) OnEventsDerived(ctx context.Context, ...)
  • func (b *ProposerDutyDeriver) Start(ctx context.Context) error
  • func (b *ProposerDutyDeriver) Stop(ctx context.Context) error
• type ProposerDutyDeriverConfig

Constants

const (
	BeaconBlobDeriverName = xatu.CannonType_BEACON_API_ETH_V1_BEACON_BLOB_SIDECAR
)

const (
	BeaconValidatorsDeriverName = xatu.CannonType_BEACON_API_ETH_V1_BEACON_VALIDATORS
)

const (
	ProposerDutyDeriverName = xatu.CannonType_BEACON_API_ETH_V1_PROPOSER_DUTY
)

Types

type BeaconBlobDeriver

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

func NewBeaconBlobDeriver

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

func (*BeaconBlobDeriver) ActivationFork

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 BeaconValidatorsDeriver

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

func NewBeaconValidatorsDeriver

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

func (*BeaconValidatorsDeriver) ActivationFork

func (b *BeaconValidatorsDeriver) ActivationFork() string

func (*BeaconValidatorsDeriver) CannonType

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

func (*BeaconValidatorsDeriver) Name

func (b *BeaconValidatorsDeriver) Name() string

func (*BeaconValidatorsDeriver) OnEventsDerived

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

func (*BeaconValidatorsDeriver) Start

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

func (*BeaconValidatorsDeriver) Stop

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

type BeaconValidatorsDeriverConfig

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

type ProposerDutyDeriver

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

func NewProposerDutyDeriver

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

func (*ProposerDutyDeriver) ActivationFork

func (b *ProposerDutyDeriver) ActivationFork() string

func (*ProposerDutyDeriver) CannonType

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

func (*ProposerDutyDeriver) Name

func (b *ProposerDutyDeriver) Name() string

func (*ProposerDutyDeriver) OnEventsDerived

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

func (*ProposerDutyDeriver) Start

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

func (*ProposerDutyDeriver) Stop

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

type ProposerDutyDeriverConfig

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