Method JobInsertFullMany

riverdriver/riversqlite/river_sqlite_driver.go:627–638

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

}

func (e *Executor) JobInsertFullMany(ctx context.Context, params *riverdriver.JobInsertFullManyParams) ([]*rivertype.JobRow, error) {
	jobsParam, err := sqliteJobInsertFullManyJobsParam(params.Jobs)
	if err != nil {
		return nil, err
	}

	jobs, err := dbsqlc.New().JobInsertFullMany(schemaTemplateParam(ctx, params.Schema), e.dbtx, jobsParam)
	if err != nil {
		return nil, interpretError(err)
	}
	return sliceutil.MapError(jobs, jobRowFromInternal)
}

func (e *Executor) JobKindList(ctx context.Context, params *riverdriver.JobKindListParams) ([]string, error) {
	exclude := params.Exclude