const ( MigrationLineSequence = "sequence" MigrationLineWorkflow = "workflow" )
This section is empty.
This section is empty.
type ProDriver[TTx any] interface { riverdriver.Driver[TTx] GetProExecutor() ProExecutor ProConfigInit(pilot riverpilot.Pilot) UnwrapProExecutor(tx TTx) ProExecutorTx }
type ProExecutor interface { riverdriver.Executor // BeginPro begins a new subtransaction returning a ProExecutorTx. // ErrSubTxNotSupported may be returned if the executor is a transaction and // the driver doesn't support subtransactions (like // riverdriver/riverdatabasesql for database/sql). BeginPro(ctx context.Context) (ProExecutorTx, error) CancelWorkflowJobsWithFailedDepsMany(ctx context.Context, params *CancelWorkflowJobsWithFailedDepsManyParams) ([]*rivertype.JobRow, error) GetPendingWorkflowIDs(ctx context.Context, params *GetPendingWorkflowIDsParams) ([]*GetPendingWorkflowIDsRow, error) SequenceAppendMany(ctx context.Context, seqKeys []string) (int, error) SequenceList(ctx context.Context, count int) ([]*Sequence, error) // SequencePromote promotes the sequences with the given keys. It returns the // keys of the sequences which were actually promoted. SequencePromote(ctx context.Context, params *SequencePromoteParams) ([]string, error) // SequencePromoteFromTable promotes sequences from the river_job_sequence // table. It returns the keys of the sequences which were actually promoted. SequencePromoteFromTable(ctx context.Context, params *SequencePromoteFromTableParams) (*SequencePromoteFromTableResult, error) SequenceScanAndPromoteStalled(ctx context.Context, params *SequenceScanAndPromoteStalledParams) (*SequenceScanAndPromoteStalledResult, error) StageWorkflowJobsMany(ctx context.Context, params *StageWorkflowJobsManyParams) ([]*rivertype.JobRow, error) WorkflowCancel(ctx context.Context, params *WorkflowCancelParams) ([]*rivertype.JobRow, error) WorkflowLoadTasksByNames(ctx context.Context, params *WorkflowLoadTasksByNamesParams) ([]*WorkflowTask, error) }
type ProExecutorTx interface { ProExecutor riverdriver.ExecutorTx }
Path | Synopsis |
---|---|
riverpropgxv5 module |