v1

Documentation

Index

• Constants
• type BeaconBlobDeriver
  • func NewBeaconBlobDeriver(log logrus.FieldLogger, config *BeaconBlobDeriverConfig, ...) *BeaconBlobDeriver
  • 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 ProposerDutyDeriver
  • func NewProposerDutyDeriver(log logrus.FieldLogger, config *ProposerDutyDeriverConfig, ...) *ProposerDutyDeriver
  • 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 (
	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) 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:"false"`
}

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