event

package
v1.0.24 Latest Latest
Warning

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

 Go to latest Published: Dec 12, 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 (e *EventsAttestation) Decorate(ctx context.Context) (*xatu.DecoratedEvent, error)

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 (e *EventsBlobSidecar) Decorate(ctx context.Context) (*xatu.DecoratedEvent, error)

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 (e *EventsChainReorg) Decorate(ctx context.Context) (*xatu.DecoratedEvent, error)

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 (e *EventsContributionAndProof) Decorate(ctx context.Context) (*xatu.DecoratedEvent, error)

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 (e *EventsFinalizedCheckpoint) Decorate(ctx context.Context) (*xatu.DecoratedEvent, error)

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 (e *EventsVoluntaryExit) Decorate(ctx context.Context) (*xatu.DecoratedEvent, error)

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) GetAdditionalData 

func (f *ForkChoice) GetAdditionalData(_ context.Context) *xatu.ClientMeta_AdditionalEthV1DebugForkChoiceV2Data

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 NewValidatorAttestationData 

func NewValidatorAttestationData(log logrus.FieldLogger, snapshot *ValidatorAttestationDataSnapshot, event *phase0.AttestationData, beacon *ethereum.BeaconNode, clientMeta *xatu.ClientMeta) *ValidatorAttestationData

func (*ValidatorAttestationData) Decorate 

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

func (*ValidatorAttestationData) ShouldIgnore 

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

type ValidatorAttestationDataSnapshot 

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

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.