jobhook

var Fleet func(ctx context.Context, engine any, cfg *river.Config, extra ...riverhelpers.Contribution) (*river.Client[pgx.Tx], error)

Fleet starts engine (a *contentkit.Engine) on an unstarted River client built from cfg with the engine's jobs and extra. The caller starts and stops the client; Engine.Close leaves it running.

var SearchExpansion func(engine any, batch, pages int)

SearchExpansion sizes engine's search sync: items per rename-expansion batch and batches per run (zero is the default).

var SearchSync func(ctx context.Context, engine any) (more bool, err error)

SearchSync runs one run of engine's search sync, as its job does without queueing the next, and reports whether work remains.