Method QueuePause

riverdriver/riversqlite/river_sqlite_driver.go:1218–1232

(ctx context.Context, params *riverdriver.QueuePauseParams)

}

func (e *Executor) QueuePause(ctx context.Context, params *riverdriver.QueuePauseParams) error {
	// `execresult` doesn't seem to return the right number of rows affected in
	// SQLite under every circumstance, so use a `many` return instead.
	rowsAffected, err := dbsqlc.New().QueuePause(schemaTemplateParam(ctx, params.Schema), e.dbtx, &dbsqlc.QueuePauseParams{
		Name: params.Name,
		Now:  timeStringNullable(params.Now),
	})
	if err != nil {
		return interpretError(err)
	}
	if rowsAffected < 1 && params.Name != riverdriver.AllQueuesString {
		return rivertype.ErrNotFound
	}
	return nil
}

func (e *Executor) QueueResume(ctx context.Context, params *riverdriver.QueueResumeParams) error {
	// `execresult` doesn't seem to return the right number of rows affected in