event

package
v0.0.169 Latest Latest
Warning

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

Go to latest
Published: May 1, 2024 License: GPL-3.0 Imports: 18 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type BeaconCommittee

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

func NewBeaconCommittee

func NewBeaconCommittee(log logrus.FieldLogger, event *v1.BeaconCommittee, epoch phase0.Epoch, now time.Time, beacon *ethereum.BeaconNode, clientMeta *xatu.ClientMeta, duplicateCache *ttlcache.Cache[string, time.Time]) *BeaconCommittee

func (*BeaconCommittee) Decorate

func (e *BeaconCommittee) Decorate(ctx context.Context) (*xatu.DecoratedEvent, error)

func (*BeaconCommittee) ShouldIgnore

func (e *BeaconCommittee) ShouldIgnore(ctx context.Context) (bool, error)

type EventsAttestation

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

func NewEventsAttestation

func NewEventsAttestation(log logrus.FieldLogger, event *phase0.Attestation, now time.Time, beacon *ethereum.BeaconNode, duplicateCache *ttlcache.Cache[string, time.Time], clientMeta *xatu.ClientMeta) *EventsAttestation

func (*EventsAttestation) Decorate

func (*EventsAttestation) ShouldIgnore

func (e *EventsAttestation) ShouldIgnore(ctx context.Context) (bool, error)

type EventsBlobSidecar

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

func NewEventsBlobSidecar

func NewEventsBlobSidecar(log logrus.FieldLogger, event *eth2v1.BlobSidecarEvent, now time.Time, beacon *ethereum.BeaconNode, duplicateCache *ttlcache.Cache[string, time.Time], clientMeta *xatu.ClientMeta) *EventsBlobSidecar

func (*EventsBlobSidecar) Decorate

func (*EventsBlobSidecar) ShouldIgnore

func (e *EventsBlobSidecar) ShouldIgnore(ctx context.Context) (bool, error)

type EventsBlock

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

func NewEventsBlock

func NewEventsBlock(log logrus.FieldLogger, event *eth2v1.BlockEvent, now time.Time, beacon *ethereum.BeaconNode, duplicateCache *ttlcache.Cache[string, time.Time], clientMeta *xatu.ClientMeta) *EventsBlock

func (*EventsBlock) Decorate

func (e *EventsBlock) Decorate(ctx context.Context) (*xatu.DecoratedEvent, error)

func (*EventsBlock) ShouldIgnore

func (e *EventsBlock) ShouldIgnore(ctx context.Context) (bool, error)

type EventsChainReorg

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

func NewEventsChainReorg

func NewEventsChainReorg(log logrus.FieldLogger, event *eth2v1.ChainReorgEvent, now time.Time, beacon *ethereum.BeaconNode, duplicateCache *ttlcache.Cache[string, time.Time], clientMeta *xatu.ClientMeta) *EventsChainReorg

func (*EventsChainReorg) Decorate

func (*EventsChainReorg) ShouldIgnore

func (e *EventsChainReorg) ShouldIgnore(ctx context.Context) (bool, error)

type EventsContributionAndProof

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

func NewEventsContributionAndProof

func NewEventsContributionAndProof(log logrus.FieldLogger, event *altair.SignedContributionAndProof, now time.Time, beacon *ethereum.BeaconNode, duplicateCache *ttlcache.Cache[string, time.Time], clientMeta *xatu.ClientMeta) *EventsContributionAndProof

func (*EventsContributionAndProof) Decorate

func (*EventsContributionAndProof) ShouldIgnore

func (e *EventsContributionAndProof) ShouldIgnore(ctx context.Context) (bool, error)

type EventsFinalizedCheckpoint

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

func NewEventsFinalizedCheckpoint

func NewEventsFinalizedCheckpoint(log logrus.FieldLogger, event *eth2v1.FinalizedCheckpointEvent, now time.Time, beacon *ethereum.BeaconNode, duplicateCache *ttlcache.Cache[string, time.Time], clientMeta *xatu.ClientMeta) *EventsFinalizedCheckpoint

func (*EventsFinalizedCheckpoint) Decorate

func (*EventsFinalizedCheckpoint) ShouldIgnore

func (e *EventsFinalizedCheckpoint) ShouldIgnore(ctx context.Context) (bool, error)

type EventsHead

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

func NewEventsHead

func NewEventsHead(log logrus.FieldLogger, event *eth2v1.HeadEvent, now time.Time, beacon *ethereum.BeaconNode, duplicateCache *ttlcache.Cache[string, time.Time], clientMeta *xatu.ClientMeta) *EventsHead

func (*EventsHead) Decorate

func (e *EventsHead) Decorate(ctx context.Context) (*xatu.DecoratedEvent, error)

func (*EventsHead) ShouldIgnore

func (e *EventsHead) ShouldIgnore(ctx context.Context) (bool, error)

type EventsVoluntaryExit

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

func NewEventsVoluntaryExit

func NewEventsVoluntaryExit(log logrus.FieldLogger, event *phase0.SignedVoluntaryExit, now time.Time, beacon *ethereum.BeaconNode, duplicateCache *ttlcache.Cache[string, time.Time], clientMeta *xatu.ClientMeta) *EventsVoluntaryExit

func (*EventsVoluntaryExit) Decorate

func (*EventsVoluntaryExit) ShouldIgnore

func (e *EventsVoluntaryExit) ShouldIgnore(ctx context.Context) (bool, error)

type ForkChoice

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

func NewForkChoice

func NewForkChoice(log logrus.FieldLogger, snapshot *ForkChoiceSnapshot, beacon *ethereum.BeaconNode, clientMeta *xatu.ClientMeta) *ForkChoice

func (*ForkChoice) Decorate

func (f *ForkChoice) Decorate(ctx context.Context) (*xatu.DecoratedEvent, error)

func (*ForkChoice) GetData

func (f *ForkChoice) GetData() (*xatuethv1.ForkChoiceV2, error)

func (*ForkChoice) ShouldIgnore

func (f *ForkChoice) ShouldIgnore(ctx context.Context) (bool, error)

type ForkChoiceReOrg

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

func NewForkChoiceReOrg

func NewForkChoiceReOrg(log logrus.FieldLogger, snapshot *ForkChoiceReOrgSnapshot, beacon *ethereum.BeaconNode, clientMeta *xatu.ClientMeta) *ForkChoiceReOrg

func (*ForkChoiceReOrg) Decorate

func (f *ForkChoiceReOrg) Decorate(ctx context.Context) (*xatu.DecoratedEvent, error)

func (*ForkChoiceReOrg) ShouldIgnore

func (f *ForkChoiceReOrg) ShouldIgnore(ctx context.Context) (bool, error)

type ForkChoiceReOrgSnapshot

type ForkChoiceReOrgSnapshot struct {
	ReOrgEventAt time.Time
	Before       *ForkChoice
	After        *ForkChoice
	Event        *xatuethv1.EventChainReorgV2
}

type ForkChoiceSnapshot

type ForkChoiceSnapshot struct {
	Event           *eth2v1.ForkChoice
	RequestSlot     phase0.Slot
	RequestEpoch    phase0.Epoch
	RequestAt       time.Time
	RequestDuration time.Duration
}

type ProposerDuty added in v0.0.156

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

func NewProposerDuty added in v0.0.156

func NewProposerDuty(log logrus.FieldLogger, duty *v1.ProposerDuty, epoch phase0.Epoch, now time.Time, beacon *ethereum.BeaconNode, clientMeta *xatu.ClientMeta, duplicateCache *ttlcache.Cache[string, time.Time]) *ProposerDuty

func (*ProposerDuty) Decorate added in v0.0.156

func (e *ProposerDuty) Decorate(ctx context.Context) (*xatu.DecoratedEvent, error)

func (*ProposerDuty) ShouldIgnore added in v0.0.156

func (e *ProposerDuty) ShouldIgnore(ctx context.Context) (bool, error)

type ValidatorAttestationData

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

func (*ValidatorAttestationData) Decorate

func (*ValidatorAttestationData) ShouldIgnore

func (e *ValidatorAttestationData) ShouldIgnore(ctx context.Context) (bool, error)

type ValidatorAttestationDataSnapshot

type ValidatorAttestationDataSnapshot struct {
	RequestAt       time.Time
	RequestDuration time.Duration
}

Jump to

Keyboard shortcuts

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