Method JobInsertFull

riverdriver/riversqlite/river_sqlite_driver.go:573–625

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

}

func (e *Executor) JobInsertFull(ctx context.Context, params *riverdriver.JobInsertFullParams) (*rivertype.JobRow, error) {
	var attemptedBy []byte
	if params.AttemptedBy != nil {
		var err error
		attemptedBy, err = json.Marshal(params.AttemptedBy)
		if err != nil {
			return nil, err
		}
	}

	var errors []byte
	if len(params.Errors) > 0 {
		var err error
		errors, err = json.Marshal(sliceutil.Map(params.Errors, func(e []byte) json.RawMessage { return json.RawMessage(e) }))
		if err != nil {
			return nil, err
		}
	}

	tags, err := json.Marshal(params.Tags)
	if err != nil {
		return nil, err
	}

	var uniqueStates *int64
	if params.UniqueStates != 0 {
		uniqueStates = ptrutil.Ptr(int64(params.UniqueStates))
	}

	job, err := dbsqlc.New().JobInsertFull(schemaTemplateParam(ctx, params.Schema), e.dbtx, &dbsqlc.JobInsertFullParams{
		Attempt:      int64(params.Attempt),
		AttemptedAt:  timeStringNullable(params.AttemptedAt),
		AttemptedBy:  attemptedBy,
		Args:         params.EncodedArgs,
		CreatedAt:    timeStringNullable(params.CreatedAt),
		Errors:       errors,
		FinalizedAt:  timeStringNullable(params.FinalizedAt),
		Kind:         params.Kind,
		MaxAttempts:  int64(params.MaxAttempts),
		Metadata:     sliceutil.FirstNonEmpty(params.Metadata, []byte("{}")),
		Priority:     int64(params.Priority),
		Queue:        params.Queue,
		ScheduledAt:  timeStringNullable(params.ScheduledAt),
		State:        string(params.State),
		Tags:         tags,
		UniqueKey:    params.UniqueKey,
		UniqueStates: uniqueStates,
	})
	if err != nil {
		return nil, interpretError(err)
	}
	return jobRowFromInternal(job)
}

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