source

type Source interface {
	// Next fetches the next transaction to be restored.
	// This call can be BLOCKING
	Next(context.Context) (*std.Tx, error)

	// Close shuts down the transaction source
	Close() error
}