Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

source

package

Go to main page

Versions in this module

v0

v0.2.0

Oct 17, 2025

Changes in this version

+ var ErrInvalidPollingInterval = errors.New("pollingInterval must be at least 1 second for HTTP endpoints")

+ var ErrNodeRecordsRequired = errors.New("nodeRecords is required for p2p mode")

+ var ErrRPCEndpointsRequired = errors.New("rpcEndpoints is required for rpc mode")

+ var ErrUnknownMode = errors.New("unknown mode")

+ var ErrUnsupportedProtocol = errors.New(...)

type Config

+ PollingInterval time.Duration

+ RPCEndpoints []string

type Metrics

+ func NewMetricsWithRegisterer(namespace string, registerer prometheus.Registerer) *Metrics

v0.1.0

May 6, 2025

Changes in this version

type Metrics

+ func (m *Metrics) IncNewTxHashesCount(txType byte)

+ func (m *Metrics) IncReceivedTxCount(txType byte)

type Peer

+ func (p *Peer) ExportBlobTransactions(ctx context.Context, items []*common.Hash) error

+ func (p *Peer) ExportNormalTransactions(ctx context.Context, items []*common.Hash) error

+ type TransactionTypeHash struct

+ Hash common.Hash

+ Type byte

v0.0.1

Feb 13, 2023

Changes in this version

+ type Config struct

+ NodeRecords []string

+ RetryInterval time.Duration

+ TransactionFilters TransactionFilterConfig

+ func (c *Config) Validate() error

+ type Coordinator struct

+ func NewCoordinator(config *Config, ...) (*Coordinator, error)

+ func (c *Coordinator) Start(ctx context.Context) error

+ func (c *Coordinator) Stop(ctx context.Context) error

+ type CoordinatorStatus struct

+ ConnectedPeers int

+ DisconnectedPeers int

+ type Metrics struct

+ func NewMetrics(namespace string) *Metrics

+ func (m *Metrics) SetPeers(count int, status string)

+ type Peer struct

+ func NewPeer(ctx context.Context, log logrus.FieldLogger, nodeRecord string, ...) (*Peer, error)

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

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

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

+ type TransactionExporter struct

+ func NewTransactionExporter(log logrus.FieldLogger, ...) (TransactionExporter, error)

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

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

+ type TransactionFilterConfig struct

+ From []string

+ To []string