Name: riverpropgxv5 package
Availability: InStock
Author: River

Types ¶

type Driver ¶

type Driver struct {
	riverpgxv5.Driver
	*baseservice.Archetype
	// contains filtered or unexported fields
}

Driver is an implementation of riverdriver.Driver for Pgx v5.

func New ¶

func New(dbPool *pgxpool.Pool) *Driver

func (*Driver) GetExecutor ¶

func (d *Driver) GetExecutor() riverdriver.Executor

func (*Driver) GetMigrationDefaultLines ¶

func (d *Driver) GetMigrationDefaultLines() []string

func (*Driver) GetMigrationFS ¶

func (d *Driver) GetMigrationFS(line string) fs.FS

func (*Driver) GetMigrationLines ¶

func (d *Driver) GetMigrationLines() []string

func (*Driver) GetMigrationTruncateTables ¶

func (d *Driver) GetMigrationTruncateTables(line string, version int) []string

func (*Driver) GetProExecutor ¶

func (d *Driver) GetProExecutor() driver.ProExecutor

func (*Driver) HasPool ¶

func (d *Driver) HasPool() bool

func (*Driver) PluginInit ¶

func (d *Driver) PluginInit(archetype *baseservice.Archetype)

PluginInit initializes a plugin with an archetype. It's invoked on Client.NewClient.

func (*Driver) PluginPilot ¶

func (d *Driver) PluginPilot() riverpilot.Pilot

func (*Driver) ProConfigInit ¶

func (d *Driver) ProConfigInit(pilot riverpilot.Pilot)

func (*Driver) UnwrapExecutor ¶

func (d *Driver) UnwrapExecutor(tx pgx.Tx) riverdriver.ExecutorTx

func (*Driver) UnwrapProExecutor ¶

func (d *Driver) UnwrapProExecutor(tx pgx.Tx) driver.ProExecutorTx

func (*Driver) UnwrapTx ¶

func (d *Driver) UnwrapTx(execTx riverdriver.ExecutorTx) pgx.Tx

type Executor ¶

type Executor struct {
	*riverpgxv5.Executor
	// contains filtered or unexported fields
}

func (*Executor) Begin ¶

func (e *Executor) Begin(ctx context.Context) (riverdriver.ExecutorTx, error)

func (*Executor) BeginPro ¶

func (e *Executor) BeginPro(ctx context.Context) (driver.ProExecutorTx, error)

func (*Executor) GetPendingWorkflowIDs ¶

func (e *Executor) GetPendingWorkflowIDs(ctx context.Context, params *driver.GetPendingWorkflowIDsParams) ([]*driver.GetPendingWorkflowIDsRow, error)

func (*Executor) JobDeadLetterDeleteByID ¶

func (e *Executor) JobDeadLetterDeleteByID(ctx context.Context, params *driver.JobDeadLetterDeleteByIDParams) (*rivertype.JobRow, error)

func (*Executor) JobDeadLetterGetAll ¶

func (e *Executor) JobDeadLetterGetAll(ctx context.Context, params *driver.JobDeadLetterGetAllParams) ([]*rivertype.JobRow, error)

func (*Executor) JobDeadLetterGetByID ¶

func (e *Executor) JobDeadLetterGetByID(ctx context.Context, params *driver.JobDeadLetterGetByIDParams) (*rivertype.JobRow, error)

func (*Executor) JobDeadLetterMoveByID ¶

func (e *Executor) JobDeadLetterMoveByID(ctx context.Context, params *driver.JobDeadLetterMoveByIDParams) (*rivertype.JobRow, error)

func (*Executor) JobDeadLetterMoveDiscarded ¶

func (e *Executor) JobDeadLetterMoveDiscarded(ctx context.Context, params *driver.JobDeadLetterMoveDiscardedParams) ([]*rivertype.JobRow, error)

func (*Executor) JobDeleteByIDMany ¶

func (e *Executor) JobDeleteByIDMany(ctx context.Context, params *driver.JobDeleteByIDManyParams) ([]*rivertype.JobRow, error)

func (*Executor) JobGetAvailableForBatch ¶

func (e *Executor) JobGetAvailableForBatch(ctx context.Context, params *driver.JobGetAvailableForBatchParams) ([]*rivertype.JobRow, error)

func (*Executor) JobGetAvailableLimited ¶

func (e *Executor) JobGetAvailableLimited(ctx context.Context, params *driver.JobGetAvailableLimitedParams) ([]*rivertype.JobRow, error)

func (*Executor) JobGetAvailablePartitionKeys ¶

func (e *Executor) JobGetAvailablePartitionKeys(ctx context.Context, params *driver.JobGetAvailablePartitionKeysParams) ([]string, error)

func (*Executor) JobGetByWorkflowIDAndTaskName ¶

func (e *Executor) JobGetByWorkflowIDAndTaskName(ctx context.Context, params *driver.JobGetByWorkflowIDAndTaskNameParams) (*rivertype.JobRow, error)

func (*Executor) PGTryAdvisoryXactLock ¶

func (e *Executor) PGTryAdvisoryXactLock(ctx context.Context, key int64) (bool, error)

func (*Executor) PeriodicJobGetAll ¶

func (e *Executor) PeriodicJobGetAll(ctx context.Context, params *driver.PeriodicJobGetAllParams) ([]*driver.PeriodicJob, error)

func (*Executor) PeriodicJobGetByID ¶

func (e *Executor) PeriodicJobGetByID(ctx context.Context, params *driver.PeriodicJobGetByIDParams) (*driver.PeriodicJob, error)

func (*Executor) PeriodicJobInsert ¶

func (e *Executor) PeriodicJobInsert(ctx context.Context, params *driver.PeriodicJobInsertParams) (*driver.PeriodicJob, error)

func (*Executor) PeriodicJobKeepAliveAndReap ¶

func (e *Executor) PeriodicJobKeepAliveAndReap(ctx context.Context, params *driver.PeriodicJobKeepAliveAndReapParams) ([]*driver.PeriodicJob, error)

func (*Executor) PeriodicJobUpsertMany ¶

func (e *Executor) PeriodicJobUpsertMany(ctx context.Context, params *driver.PeriodicJobUpsertManyParams) ([]*driver.PeriodicJob, error)

func (*Executor) ProducerDelete ¶

func (e *Executor) ProducerDelete(ctx context.Context, params *driver.ProducerDeleteParams) error

func (*Executor) ProducerGetByID ¶

func (e *Executor) ProducerGetByID(ctx context.Context, params *driver.ProducerGetByIDParams) (*driver.Producer, error)

func (*Executor) ProducerInsertOrUpdate ¶

func (e *Executor) ProducerInsertOrUpdate(ctx context.Context, params *driver.ProducerInsertOrUpdateParams) (*driver.Producer, error)

func (*Executor) ProducerKeepAlive ¶

func (e *Executor) ProducerKeepAlive(ctx context.Context, params *driver.ProducerKeepAliveParams) (*driver.Producer, error)

func (*Executor) ProducerListByQueue ¶

func (e *Executor) ProducerListByQueue(ctx context.Context, params *driver.ProducerListByQueueParams) ([]*driver.ProducerListByQueueResult, error)

func (*Executor) ProducerUpdate ¶

func (e *Executor) ProducerUpdate(ctx context.Context, params *driver.ProducerUpdateParams) (*driver.Producer, error)

func (*Executor) QueueGetMetadataForInsert ¶

func (e *Executor) QueueGetMetadataForInsert(ctx context.Context, params *driver.QueueGetMetadataForInsertParams) ([]*driver.QueueGetMetadataForInsertResult, error)

func (*Executor) SequenceAppendMany ¶

func (e *Executor) SequenceAppendMany(ctx context.Context, params *driver.SequenceAppendManyParams) (int, error)

func (*Executor) SequenceList ¶

func (e *Executor) SequenceList(ctx context.Context, params *driver.SequenceListParams) ([]*driver.Sequence, error)

func (*Executor) SequencePromote ¶

func (e *Executor) SequencePromote(ctx context.Context, params *driver.SequencePromoteParams) ([]string, error)

func (*Executor) SequencePromoteFromTable ¶

func (e *Executor) SequencePromoteFromTable(ctx context.Context, params *driver.SequencePromoteFromTableParams) (*driver.SequencePromoteFromTableResult, error)

func (*Executor) SequenceScanAndPromoteStalled ¶

func (e *Executor) SequenceScanAndPromoteStalled(ctx context.Context, params *driver.SequenceScanAndPromoteStalledParams) (*driver.SequenceScanAndPromoteStalledResult, error)

func (*Executor) StageWorkflowJobsMany ¶

func (e *Executor) StageWorkflowJobsMany(ctx context.Context, params *driver.StageWorkflowJobsManyParams) ([]*rivertype.JobRow, error)

func (*Executor) WorkflowCancel ¶

func (e *Executor) WorkflowCancel(ctx context.Context, params *driver.WorkflowCancelParams) ([]*rivertype.JobRow, error)

func (*Executor) WorkflowCancelWithFailedDepsMany ¶

func (e *Executor) WorkflowCancelWithFailedDepsMany(ctx context.Context, params *driver.WorkflowCancelWithFailedDepsManyParams) ([]*rivertype.JobRow, error)

func (*Executor) WorkflowJobList ¶

func (e *Executor) WorkflowJobList(ctx context.Context, params *driver.WorkflowJobListParams) ([]*rivertype.JobRow, error)

func (*Executor) WorkflowListActive ¶

func (e *Executor) WorkflowListActive(ctx context.Context, params *driver.WorkflowListParams) ([]*driver.WorkflowListItem, error)

func (*Executor) WorkflowListAll ¶

func (e *Executor) WorkflowListAll(ctx context.Context, params *driver.WorkflowListParams) ([]*driver.WorkflowListItem, error)

func (*Executor) WorkflowListInactive ¶

func (e *Executor) WorkflowListInactive(ctx context.Context, params *driver.WorkflowListParams) ([]*driver.WorkflowListItem, error)

func (*Executor) WorkflowLoadDepTasksAndIDs ¶

func (e *Executor) WorkflowLoadDepTasksAndIDs(ctx context.Context, params *driver.WorkflowLoadDepTasksAndIDsParams) (map[string]*int64, error)

func (*Executor) WorkflowLoadJobsWithDeps ¶

func (e *Executor) WorkflowLoadJobsWithDeps(ctx context.Context, params *driver.WorkflowLoadJobsWithDepsParams) ([]*driver.WorkflowTaskWithJob, error)

func (*Executor) WorkflowLoadTaskWithDeps ¶

func (e *Executor) WorkflowLoadTaskWithDeps(ctx context.Context, params *driver.WorkflowLoadTaskWithDepsParams) (*driver.WorkflowTaskWithJob, error)

func (*Executor) WorkflowLoadTasksByNames ¶

func (e *Executor) WorkflowLoadTasksByNames(ctx context.Context, params *driver.WorkflowLoadTasksByNamesParams) ([]*driver.WorkflowTask, error)

func (*Executor) WorkflowRetry ¶

func (e *Executor) WorkflowRetry(ctx context.Context, params *driver.WorkflowRetryParams) ([]*rivertype.JobRow, error)

func (*Executor) WorkflowRetryLockAndCheckRunning ¶

func (e *Executor) WorkflowRetryLockAndCheckRunning(ctx context.Context, params *driver.WorkflowRetryLockAndCheckRunningParams) (*driver.WorkflowRetryLockAndCheckRunningResult, error)

type ExecutorTx ¶

type ExecutorTx struct {
	Executor
	// contains filtered or unexported fields
}

func (*ExecutorTx) BeginPro ¶

func (e *ExecutorTx) BeginPro(ctx context.Context) (driver.ProExecutorTx, error)

func (*ExecutorTx) Commit ¶

func (t *ExecutorTx) Commit(ctx context.Context) error

func (*ExecutorTx) Rollback ¶

func (t *ExecutorTx) Rollback(ctx context.Context) error

Index ¶