Versions in this module Expand all Collapse all v0 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