v1

package

v0.0.49 Latest Latest Go to latest Published: Jan 22, 2025 License: GPL-3.0 Imports: 13 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/ethpandaops/contributoor

Links

Open Source Insights

Documentation ¶

Index ¶

type BlobSidecarEvent
- func NewBlobSidecarEvent(log logrus.FieldLogger, beacon events.BeaconDataProvider, ...) *BlobSidecarEvent
type BlockEvent
- func NewBlockEvent(log logrus.FieldLogger, beacon events.BeaconDataProvider, ...) *BlockEvent
type ChainReorgEvent
- func NewChainReorgEvent(log logrus.FieldLogger, beacon events.BeaconDataProvider, ...) *ChainReorgEvent
type FinalizedCheckpointEvent
- func NewFinalizedCheckpointEvent(log logrus.FieldLogger, beacon events.BeaconDataProvider, ...) *FinalizedCheckpointEvent
type HeadEvent
- func NewHeadEvent(log logrus.FieldLogger, beacon events.BeaconDataProvider, ...) *HeadEvent

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type BlobSidecarEvent ¶

type BlobSidecarEvent struct {
	events.BaseEvent
	// contains filtered or unexported fields
}

BlobSidecarEvent represents a blob sidecar event.

func NewBlobSidecarEvent ¶

func NewBlobSidecarEvent(
	log logrus.FieldLogger,
	beacon events.BeaconDataProvider,
	cache *ttlcache.Cache[string, time.Time],
	meta *xatu.Meta,
	data *eth2v1.BlobSidecarEvent,
	recvTime time.Time,
) *BlobSidecarEvent

func (*BlobSidecarEvent) Data ¶

func (e *BlobSidecarEvent) Data() interface{}

func (*BlobSidecarEvent) Decorated ¶

func (e *BlobSidecarEvent) Decorated() *xatu.DecoratedEvent

func (*BlobSidecarEvent) Ignore ¶

func (e *BlobSidecarEvent) Ignore(ctx context.Context) (bool, error)

func (*BlobSidecarEvent) Type ¶

func (e *BlobSidecarEvent) Type() string

type BlockEvent ¶

type BlockEvent struct {
	events.BaseEvent
	// contains filtered or unexported fields
}

BlockEvent represents a beacon chain block event.

func NewBlockEvent ¶

func NewBlockEvent(
	log logrus.FieldLogger,
	beacon events.BeaconDataProvider,
	cache *ttlcache.Cache[string, time.Time],
	meta *xatu.Meta,
	data *eth2v1.BlockEvent,
	recvTime time.Time,
) *BlockEvent

func (*BlockEvent) Data ¶

func (e *BlockEvent) Data() interface{}

func (*BlockEvent) Decorated ¶

func (e *BlockEvent) Decorated() *xatu.DecoratedEvent

func (*BlockEvent) Ignore ¶

func (e *BlockEvent) Ignore(ctx context.Context) (bool, error)

func (*BlockEvent) Type ¶

func (e *BlockEvent) Type() string

type ChainReorgEvent ¶

type ChainReorgEvent struct {
	events.BaseEvent
	// contains filtered or unexported fields
}

ChainReorgEvent represents a beacon chain reorganization event.

func NewChainReorgEvent ¶

func NewChainReorgEvent(
	log logrus.FieldLogger,
	beacon events.BeaconDataProvider,
	cache *ttlcache.Cache[string, time.Time],
	meta *xatu.Meta,
	data *eth2v1.ChainReorgEvent,
	recvTime time.Time,
) *ChainReorgEvent

func (*ChainReorgEvent) Data ¶

func (e *ChainReorgEvent) Data() interface{}

func (*ChainReorgEvent) Decorated ¶

func (e *ChainReorgEvent) Decorated() *xatu.DecoratedEvent

func (*ChainReorgEvent) Ignore ¶

func (e *ChainReorgEvent) Ignore(ctx context.Context) (bool, error)

func (*ChainReorgEvent) Type ¶

func (e *ChainReorgEvent) Type() string

type FinalizedCheckpointEvent ¶

type FinalizedCheckpointEvent struct {
	events.BaseEvent
	// contains filtered or unexported fields
}

FinalizedCheckpointEvent represents a beacon chain finalization event.

func NewFinalizedCheckpointEvent ¶

func NewFinalizedCheckpointEvent(
	log logrus.FieldLogger,
	beacon events.BeaconDataProvider,
	cache *ttlcache.Cache[string, time.Time],
	meta *xatu.Meta,
	data *eth2v1.FinalizedCheckpointEvent,
	recvTime time.Time,
) *FinalizedCheckpointEvent

func (*FinalizedCheckpointEvent) Data ¶

func (e *FinalizedCheckpointEvent) Data() interface{}

func (*FinalizedCheckpointEvent) Decorated ¶

func (e *FinalizedCheckpointEvent) Decorated() *xatu.DecoratedEvent

func (*FinalizedCheckpointEvent) Ignore ¶

func (e *FinalizedCheckpointEvent) Ignore(ctx context.Context) (bool, error)

func (*FinalizedCheckpointEvent) Type ¶

func (e *FinalizedCheckpointEvent) Type() string

type HeadEvent ¶

type HeadEvent struct {
	events.BaseEvent
	// contains filtered or unexported fields
}

HeadEvent represents a beacon chain head event.

func NewHeadEvent ¶

func NewHeadEvent(
	log logrus.FieldLogger,
	beacon events.BeaconDataProvider,
	cache *ttlcache.Cache[string, time.Time],
	meta *xatu.Meta,
	data *eth2v1.HeadEvent,
	recvTime time.Time,
) *HeadEvent

func (*HeadEvent) Data ¶

func (e *HeadEvent) Data() interface{}

func (*HeadEvent) Decorated ¶

func (e *HeadEvent) Decorated() *xatu.DecoratedEvent

func (*HeadEvent) Ignore ¶

func (e *HeadEvent) Ignore(ctx context.Context) (bool, error)

func (*HeadEvent) Type ¶

func (e *HeadEvent) Type() string

Source Files ¶

View all Source files

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