Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func JobMakeDriverParams ¶ added in v0.24.0
func JobMakeDriverParams(ctx context.Context, params *JobListParams, sqlFragmentColumnIn func(column string, values any) (string, any, error)) (*riverdriver.JobListParams, error)
JobMakeDriverParams converts client-level parameters for job and delete to driver-level parameters for use with an executor, which generally goes by converting typed fields for IDs, kinds, queues, etc. to lower-level SQL.
This was originally implemented for listing jobs, but since the logic is so similar, it also performs the same function for JobDeleteMany. This works because `riverdriver.JobListParams` is identical to `JobDeleteMany` and therefore pointer-level converts to it.
Types ¶
type JobListOrderBy ¶
type JobListParams ¶
type JobListParams struct {
IDs []int64
Kinds []string
LimitCount int32
OrderBy []JobListOrderBy
Priorities []int16
Queues []string
Schema string
States []rivertype.JobState
Where []WherePredicate
}
type WherePredicate ¶ added in v0.23.0
Click to show internal directories.
Click to hide internal directories.