listener

Documentation

Index

• Variables
• func New(syncingStopped *util.Signaler, logger log.Logger, ...) postage.Listener
• type BlockHeightContractFilterer

Variables

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

Functions

func New

func New(
	syncingStopped *util.Signaler,
	logger log.Logger,
	ev BlockHeightContractFilterer,
	postageStampContractAddress common.Address,
	postageStampContractABI abi.ABI,
	blockTime time.Duration,
	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)
}