blocking

type Manager interface {
	Filter(ctx context.Context, hashes []protocol.ID) ([]protocol.ID, error)
	Block(ctx context.Context, hashes []protocol.ID, flush bool) error
	Flush(ctx context.Context) error
}

type Params struct {
	fx.In
	Pool        lazy.Lazy[*pgxpool.Pool]
	PgxPoolWait *sync.WaitGroup `name:"pgx_pool_wait"`
}

type Result struct {
	fx.Out
	Manager lazy.Lazy[Manager]
	AppHook fx.Hook `group:"app_hooks"`
}