(ctx context.Context, params *riverdriver.JobDeleteBeforeParams)
| 386 | } |
| 387 | |
| 388 | func (e *Executor) JobDeleteBefore(ctx context.Context, params *riverdriver.JobDeleteBeforeParams) (int, error) { |
| 389 | if len(params.QueuesIncluded) > 0 { |
| 390 | return 0, riverdriver.ErrNotImplemented |
| 391 | } |
| 392 | |
| 393 | res, err := dbsqlc.New().JobDeleteBefore(schemaTemplateParam(ctx, params.Schema), e.dbtx, &dbsqlc.JobDeleteBeforeParams{ |
| 394 | CancelledFinalizedAtHorizon: timeString(params.CancelledFinalizedAtHorizon), |
| 395 | CompletedFinalizedAtHorizon: timeString(params.CompletedFinalizedAtHorizon), |
| 396 | DiscardedFinalizedAtHorizon: timeString(params.DiscardedFinalizedAtHorizon), |
| 397 | Max: int64(params.Max), |
| 398 | QueuesExcluded: params.QueuesExcluded, |
| 399 | QueuesExcludedEmpty: len(params.QueuesExcluded) < 1, // not in the Postgres version, but I couldn't find a way around it |
| 400 | }) |
| 401 | if err != nil { |
| 402 | return 0, interpretError(err) |
| 403 | } |
| 404 | rowsAffected, err := res.RowsAffected() |
| 405 | if err != nil { |
| 406 | return 0, interpretError(err) |
| 407 | } |
| 408 | return int(rowsAffected), nil |
| 409 | } |
| 410 | |
| 411 | func (e *Executor) JobDeleteMany(ctx context.Context, params *riverdriver.JobDeleteManyParams) ([]*rivertype.JobRow, error) { |
| 412 | ctx = sqlctemplate.WithReplacements(ctx, map[string]sqlctemplate.Replacement{ |
nothing calls this directly
no test coverage detected