Method QueueNameList

riverdriver/riversqlite/river_sqlite_driver.go:1201–1216

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

}

func (e *Executor) QueueNameList(ctx context.Context, params *riverdriver.QueueNameListParams) ([]string, error) {
	exclude := params.Exclude
	if len(exclude) == 0 {
		exclude = []string{""}
	}
	queueNames, err := dbsqlc.New().QueueNameList(schemaTemplateParam(ctx, params.Schema), e.dbtx, &dbsqlc.QueueNameListParams{
		After:   params.After,
		Exclude: exclude,
		Match:   params.Match,
		Max:     int64(min(params.Max, math.MaxInt32)),
	})
	if err != nil {
		return nil, interpretError(err)
	}
	return queueNames, nil
}

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