types

type BlockNotifier interface {
	// NotifyEpochStarted notifies the epoch has started.
	Subscribe(id string) <-chan EventNewBlock
	GetCurrentBlockNumber() uint64
	String() string
	Start(ctx context.Context)
	Initialize(ctx context.Context) error
}

type BlockNotifierManager interface {
	GetBlockNotifier(ctx context.Context, finality aggkittypes.BlockNumberFinality) (BlockNotifier, error)
	GetCurrentBlockNumber(ctx context.Context, finality aggkittypes.BlockNumberFinality) (uint64, error)
}

type EventNewBlock struct {
	BlockNumber       uint64
	BlockFinalityType aggkittypes.BlockNumberFinality
	BlockRate         time.Duration
}