listener

Documentation

Index

• Variables
• func New(logger logging.Logger, ev BlockHeightContractFilterer, ...) postage.Listener
• type BlockHeightContractFilterer
• type Shutdowner

Variables

var (
	ErrPostageSyncingStalled = errors.New("postage syncing stalled")
)

Functions

func New

func New(
	logger logging.Logger,
	ev BlockHeightContractFilterer,
	postageStampAddress common.Address,
	blockTime uint64,
	shutdowner Shutdowner,
	stallingTimeout time.Duration,
	backoffTime time.Duration,
) postage.Listener

Types

type BlockHeightContractFilterer

type BlockHeightContractFilterer interface {
	FilterLogs(ctx context.Context, query ethereum.FilterQuery) ([]types.Log, error)
	BlockNumber(context.Context) (uint64, error)
}

type Shutdowner

type Shutdowner interface {
	Shutdown(context.Context) error
}

Shutdowner interface is passed to the listener to shutdown the node if we hit error while listening for blockchain events.