This section is empty.
This section is empty.
This section is empty.
type Driver struct { riverpgxv5.Driver // contains filtered or unexported fields }
Driver is an implementation of riverdriver.Driver for Pgx v5.
func (d *Driver) GetExecutor() riverdriver.Executor
func (d *Driver) GetProExecutor() driver.ProExecutor
func (d *Driver) PluginInit(archetype *baseservice.Archetype)
PluginInit initializes a plugin with an archetype It's invoked on Client.NewClient.
func (d *Driver) PluginPilot() riverpilot.Pilot
func (d *Driver) ProConfigInit(pilot riverpilot.Pilot)
func (d *Driver) UnwrapExecutor(tx pgx.Tx) riverdriver.ExecutorTx
func (d *Driver) UnwrapProExecutor(tx pgx.Tx) driver.ProExecutorTx
type Executor struct { // riverdriver.Executor *riverpgxv5.Executor // contains filtered or unexported fields }
func (e *Executor) Begin(ctx context.Context) (riverdriver.ExecutorTx, error)
func (e *Executor) GetPendingWorkflowIDs(ctx context.Context, params *driver.GetPendingWorkflowIDsParams) ([]*driver.GetPendingWorkflowIDsRow, error)
func (e *Executor) JobGetAvailable(ctx context.Context, params *riverdriver.JobGetAvailableParams) ([]*rivertype.JobRow, error)
func (e *Executor) SequencePromoteFromTable(ctx context.Context, params *driver.SequencePromoteFromTableParams) (*driver.SequencePromoteFromTableResult, error)
func (e *Executor) SequenceScanAndPromoteStalled(ctx context.Context, params *driver.SequenceScanAndPromoteStalledParams) (*driver.SequenceScanAndPromoteStalledResult, error)
func (e *Executor) WorkflowLoadTasksByNames(ctx context.Context, params *driver.WorkflowLoadTasksByNamesParams) ([]*driver.WorkflowTask, error)