listener

Documentation

Index

• type Listener
  • func New(client *ethclient.Client, tracker *load.Tracker[common.Hash], ...) *Listener
  • func (l *Listener) IssuingDone()
  • func (l *Listener) Listen(ctx context.Context) error
  • func (l *Listener) RegisterIssued(txHash common.Hash)
• type NewHeadSubscriber

Types

type Listener

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

Listener listens for transaction confirmations from a node.

func New

func New(
	client *ethclient.Client,
	tracker *load.Tracker[common.Hash],
	address common.Address,
	nonce uint64,
) *Listener

func (*Listener) IssuingDone

func (l *Listener) IssuingDone()

func (*Listener) Listen

func (l *Listener) Listen(ctx context.Context) error

func (*Listener) RegisterIssued

func (l *Listener) RegisterIssued(txHash common.Hash)

type NewHeadSubscriber

type NewHeadSubscriber interface {
	SubscribeNewHead(ctx context.Context, ch chan<- *types.Header) (ethereum.Subscription, error)
}