event

package
v1.8.13 Latest Latest
Warning

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

 Go to latest Published: May 7, 2026 License: GPL-3.0 Imports: 16 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Event 

type Event interface {
	Type() string
	Validate(ctx context.Context) error
	Filter(ctx context.Context) bool
	AppendServerMeta(ctx context.Context, meta *xatu.ServerMeta) *xatu.ServerMeta
}

type EventRouter added in v0.0.196 

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

func NewEventRouter added in v0.0.196 

func NewEventRouter(log logrus.FieldLogger, cache store.Cache, geoipProvider geoip.Provider) *EventRouter

func (*EventRouter) HasRoute added in v0.0.197 

func (er *EventRouter) HasRoute(eventType Type) bool

func (*EventRouter) RegisterHandler added in v0.0.196 

func (er *EventRouter) RegisterHandler(eventType Type, handler func(event *xatu.DecoratedEvent, router *EventRouter) (Event, error))

func (*EventRouter) Route added in v0.0.196 

func (er *EventRouter) Route(eventType Type, event *xatu.DecoratedEvent) (Event, error)

type Type 

type Type string
var (
	TypeUnknown                                 Type = "unknown"
	TypeBeaconETHV1EventsBlock                  Type = v1.EventsBlockType
	TypeBeaconETHV1EventsBlockV2                Type = v1.EventsBlockV2Type
	TypeBeaconETHV1EventsBlockGossip            Type = v1.EventsBlockGossipType
	TypeBeaconETHV1EventsChainReorg             Type = v1.EventsChainReorgType
	TypeBeaconETHV1EventsChainReorgV2           Type = v1.EventsChainReorgV2Type
	TypeBeaconETHV1EventsFinalizedCheckpoint    Type = v1.EventsFinalizedCheckpointType
	TypeBeaconETHV1EventsFinalizedCheckpointV2  Type = v1.EventsFinalizedCheckpointV2Type
	TypeBeaconETHV1EventsHead                   Type = v1.EventsHeadType
	TypeBeaconETHV1EventsHeadV2                 Type = v1.EventsHeadV2Type
	TypeBeaconETHV1EventsVoluntaryExit          Type = v1.EventsVoluntaryExitType
	TypeBeaconETHV1EventsVoluntaryExitV2        Type = v1.EventsVoluntaryExitV2Type
	TypeBeaconETHV1EventsAttestation            Type = v1.EventsAttestationType
	TypeBeaconETHV1EventsAttestationV2          Type = v1.EventsAttestationV2Type
	TypeBeaconETHV1EventsContributionAndProof   Type = v1.EventsContributionAndProofType
	TypeBeaconETHV1EventsContributionAndProofV2 Type = v1.EventsContributionAndProofV2Type
	TypeMempoolTransaction                      Type = mempool.TransactionType
	TypeMempoolTransactionV2                    Type = mempool.TransactionV2Type
	TypeExecutionStateSize                      Type = execution.ExecutionStateSizeType
	TypeExecutionEngineNewPayload               Type = execution.EngineNewPayloadType
	TypeExecutionEngineGetBlobs                 Type = execution.EngineGetBlobsType
	TypeExecutionBlockMetrics                   Type = execution.BlockMetricsType
	TypeConsensusEngineAPINewPayload            Type = consensus.EngineAPINewPayloadType
	TypeConsensusEngineAPIGetBlobs              Type = consensus.EngineAPIGetBlobsType
	TypeBeaconETHV2BeaconBlock                  Type = v2.BeaconBlockType
	TypeBeaconETHV2BeaconBlockV2                Type = v2.BeaconBlockV2Type
	TypeDebugForkChoice                         Type = v1.DebugForkChoiceType
	TypeDebugForkChoiceV2                       Type = v1.DebugForkChoiceV2Type
	TypeDebugForkChoiceReorg                    Type = v1.DebugForkChoiceReorgType
	TypeDebugForkChoiceReorgV2                  Type = v1.DebugForkChoiceReorgV2Type
	TypeBeaconEthV1BeaconCommittee              Type = v1.BeaconCommitteeType
	TypeBeaconEthV1BeaconSyncCommittee          Type = v1.BeaconSyncCommitteeType
	TypeBeaconEthV2BeaconBlockSyncAggregate     Type = v2.BeaconBlockSyncAggregateType
	TypeBeaconEthV1ValidatorAttestationData     Type = v1.ValidatorAttestationDataType
	TypeBeaconEthV2BeaconBlockAttesterSlashing  Type = v2.BeaconBlockAttesterSlashingType
	TypeBeaconEthV2BeaconBlockProposerSlashing  Type = v2.BeaconBlockProposerSlashingType
	TypeBeaconEthV2BeaconBlockVoluntaryExit     Type = v2.BeaconBlockVoluntaryExitType
	TypeBeaconEthV2BeaconBlockDeposit           Type = v2.BeaconBlockDepositType
	TypeBeaconEthV2BeaconExecutionTransaction   Type = v2.BeaconBlockExecutionTransactionType
	TypeBeaconEthV2BeaconBLSToExecutionChange   Type = v2.BeaconBlockBLSToExecutionChangeType
	TypeBeaconEthV2BeaconWithdrawal             Type = v2.BeaconBlockWithdrawalType
	TypeBeaconETHV1EventsBlobSidecar            Type = v1.EventsBlobSidecarType
	TypeBeaconETHV1EventsDataColumnSidecar      Type = v1.EventsDataColumnSidecarType
	TypeBeaconETHV1BeaconBlobSidecar            Type = v1.BeaconBlobSidecarType
	TypeBeaconETHV1BeaconBlob                   Type = v1.BeaconBlobType
	TypeBeaconEthV1ProposerDuty                 Type = v1.BeaconProposerDutyType
	TypeBeaconP2PAttestation                    Type = v1.BeaconP2PAttestationType
	TypeBeaconEthV2BeaconElaboratedAttestation  Type = v2.BeaconBlockElaboratedAttestationType
	TypeLibP2PTraceDuplicateMessage             Type = Type(libp2p.TraceDuplicateMessageType)
	TypeLibP2PTraceDeliverMessage               Type = Type(libp2p.TraceDeliverMessageType)
	TypeLibP2PTraceRejectMessage                Type = Type(libp2p.TraceRejectMessageType)
	TypeLibP2PTracePublishMessage               Type = Type(libp2p.TracePublishMessageType)
	TypeLibP2PTraceAddPeer                      Type = Type(libp2p.TraceAddPeerType)
	TypeLibP2PTraceConnected                    Type = Type(libp2p.TraceConnectedType)
	TypeLibP2PTraceJoin                         Type = Type(libp2p.TraceJoinType)
	TypeLibP2PTraceLeave                        Type = Type(libp2p.TraceLeaveType)
	TypeLibP2PTraceGraft                        Type = Type(libp2p.TraceGraftType)
	TypeLibP2PTracePrune                        Type = Type(libp2p.TracePruneType)
	TypeLibP2PTraceDisconnected                 Type = Type(libp2p.TraceDisconnectedType)
	TypeLibP2PTraceRemovePeer                   Type = Type(libp2p.TraceRemovePeerType)
	TypeLibP2PTraceRecvRPC                      Type = Type(libp2p.TraceRecvRPCType)
	TypeLibP2PTraceSendRPC                      Type = Type(libp2p.TraceSendRPCType)
	TypeLibP2PTraceDropRPC                      Type = Type(libp2p.TraceDropRPCType)
	TypeLibP2PTraceHandleStatus                 Type = Type(libp2p.TraceHandleStatusType)
	TypeLibP2PTraceHandleMetadata               Type = Type(libp2p.TraceHandleMetadataType)
	TypeLibP2PTraceGossipSubBeaconBlock         Type = Type(libp2p.TraceGossipSubBeaconBlockType)
	TypeLibP2PTraceGossipSubBeaconAttestation   Type = Type(libp2p.TraceGossipSubBeaconAttestationType)
	TypeLibP2PTraceGossipSubAggregateAndProof   Type = Type(libp2p.TraceGossipSubAggregateAndProofType)
	TypeLibP2PTraceGossipSubBlobSidecar         Type = Type(libp2p.TraceGossipSubBlobSidecarType)
	TypeLibP2PTraceGossipSubDataColumnSidecar   Type = Type(libp2p.TraceGossipSubDataColumnSidecarType)
	TypeBeaconETHV1BeaconValidators             Type = Type(v1.BeaconValidatorsType)
	TypeMEVRelayBidTraceBuilderBlockSubmission  Type = Type(mevrelay.BidTraceBuilderBlockSubmissionType)
	TypeMEVRelayProposerPayloadDelivered        Type = Type(mevrelay.ProposerPayloadDeliveredType)
	TypeMEVRelayValidatorRegistration           Type = Type(mevrelay.ValidatorRegistrationType)
	TypeBeaconETHV3ValidatorBlock               Type = v3.ValidatorBlockType
	TypeLibP2PTraceRPCMetaControlIHave          Type = Type(libp2p.TraceRPCMetaControlIHaveType)
	TypeLibP2PTraceRPCMetaControlIWant          Type = Type(libp2p.TraceRPCMetaControlIWantType)
	TypeLibP2PTraceRPCMetaControlIDontWant      Type = Type(libp2p.TraceRPCMetaControlIDontWantType)
	TypeLibP2PTraceRPCMetaControlGraft          Type = Type(libp2p.TraceRPCMetaControlGraftType)
	TypeLibP2PTraceRPCMetaControlPrune          Type = Type(libp2p.TraceRPCMetaControlPruneType)
	TypeLibP2PTraceRPCMetaSubscription          Type = Type(libp2p.TraceRPCMetaSubscriptionType)
	TypeLibP2PTraceRPCMetaMessage               Type = Type(libp2p.TraceRPCMetaMessageType)
	TypeNodeRecordExecution                     Type = Type(noderecord.ExecutionType)
	TypeNodeRecordConsensus                     Type = Type(noderecord.ConsensusType)
	TypeLibP2PTraceSyntheticHeartbeat           Type = Type(libp2p.TraceSyntheticHeartbeatType)
	TypeLibP2PTraceIdentify                     Type = Type(libp2p.TraceIdentifyType)
	TypeLibP2PRPCDataColumnCustodyProbe         Type = Type(libp2p.TypeLibp2pRPCDataColumnCustodyProbe)
)

Source Files

View all Source files

Directories

Path Synopsis
beacon
eth/v1
eth/v2
eth/v3

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.