execution

package

v1.15.0 Latest Latest Go to latest Published: May 21, 2026 License: GPL-3.0 Imports: 33 Imported by: 0

Details

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

Repository

github.com/ethpandaops/xatu

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
type Metrics
- func NewMetrics(namespace string) *Metrics
type Peer
- func New(ctx context.Context, log observability.ContextualLogger, nodeRecord string, ...) (*Peer, error)
type TransactionExporter
- func NewTransactionExporter(log observability.ContextualLogger, ...) (TransactionExporter, error)
- func (t TransactionExporter) ExportItems(ctx context.Context, items []*TransactionHashItem) error
- func (t TransactionExporter) Shutdown(ctx context.Context) error
type TransactionHashItem

Constants ¶

View Source

const PeerType = "execution"

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type Metrics ¶ added in v1.8.13

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

func NewMetrics ¶ added in v1.8.13

func NewMetrics(namespace string) *Metrics

func (*Metrics) AddDisconnect ¶ added in v1.8.13

func (m *Metrics) AddDisconnect(implementation, reason string)

func (*Metrics) DecConnectedPeer ¶ added in v1.8.13

func (m *Metrics) DecConnectedPeer(implementation, networkID string)

func (*Metrics) DeleteConnectedPeerStartTime ¶ added in v1.8.13

func (m *Metrics) DeleteConnectedPeerStartTime(implementation, networkID, nodeRecord string)

func (*Metrics) IncConnectedPeer ¶ added in v1.8.13

func (m *Metrics) IncConnectedPeer(implementation, networkID string)

func (*Metrics) SetConnectedPeerStartTime ¶ added in v1.8.13

func (m *Metrics) SetConnectedPeerStartTime(implementation, networkID, nodeRecord string, timestamp float64)

type Peer ¶

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

func New ¶

func New(ctx context.Context, log observability.ContextualLogger, nodeRecord string, handlers *handler.Peer, captureDelay time.Duration, sharedCache *coordCache.SharedCache, ethereumConfig *ethereum.Config) (*Peer, error)

func (*Peer) ExportTransactions ¶

func (p *Peer) ExportTransactions(ctx context.Context, items []*TransactionHashItem) error

func (*Peer) Start ¶

func (p *Peer) Start(ctx context.Context) (<-chan error, error)

func (*Peer) Stop ¶

func (p *Peer) Stop(ctx context.Context) error

func (*Peer) Type ¶

func (p *Peer) Type() string

type TransactionExporter ¶

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

func NewTransactionExporter ¶

func NewTransactionExporter(log observability.ContextualLogger, handler func(ctx context.Context, items []*TransactionHashItem) error) (TransactionExporter, error)

func (TransactionExporter) ExportItems ¶

func (t TransactionExporter) ExportItems(ctx context.Context, items []*TransactionHashItem) error

func (TransactionExporter) Shutdown ¶

func (t TransactionExporter) Shutdown(ctx context.Context) error

type TransactionHashItem ¶

type TransactionHashItem struct {
	Hash common.Hash
	Seen time.Time
	Type uint8
}

Source Files ¶

View all Source files

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