Versions in this module Expand all Collapse all v0 v0.2.0 Oct 17, 2025 Changes in this version + var ErrConfigRequired = errors.New("config is required") + var ErrPollingPanicked = errors.New("polling handler panicked") + var ErrRPCEndpointsRequired = errors.New("rpcEndpoints is required") + type Coordinator struct + func NewCoordinator(config *source.Config, ...) (*Coordinator, error) + func (c *Coordinator) Start(ctx context.Context) error + func (c *Coordinator) Stop(_ context.Context) error + type CoordinatorStatus struct + ConnectedPeers int + DisconnectedPeers int + type Peer struct + func NewPeer(_ context.Context, log logrus.FieldLogger, rpcEndpoint string, ...) (*Peer, error) + func (p *Peer) Start(ctx context.Context) (<-chan error, error) + func (p *Peer) Stop(_ context.Context) error + type PollingPeer struct + func NewPollingPeer(_ context.Context, log logrus.FieldLogger, rpcEndpoint string, ...) (*PollingPeer, error) + func (p *PollingPeer) Start(ctx context.Context) (<-chan error, error) + func (p *PollingPeer) Stop(_ context.Context) error + type TxPoolContent struct + Pending map[string]map[string]*types.Transaction + Queued map[string]map[string]*types.Transaction
Go to main page