Versions in this module Expand all Collapse all v1 v1.1.0 Jul 21, 2026 Changes in this version + const MaxInboundAttempts + type InboundProcessArgs struct + IntakeID string + func (InboundProcessArgs) Kind() string + type InboundProcessWorker struct + func NewInboundProcessWorker(store Store, processor Processor) *InboundProcessWorker + func (w *InboundProcessWorker) NextRetry(job *river.Job[InboundProcessArgs]) time.Time + func (w *InboundProcessWorker) Work(ctx context.Context, job *river.Job[InboundProcessArgs]) error + type InboundRetentionArgs struct + func (InboundRetentionArgs) Kind() string + type Jobs struct + func NewJobs(store Store) *Jobs + func (j *Jobs) EnqueueInboundProcessTx(ctx context.Context, tx pgx.Tx, intakeID string) (int64, error) + func (j *Jobs) ProcessIntake(ctx context.Context, it *identity.InboundIntake) error + func (j *Jobs) ReconcilePending(ctx context.Context, pool *pgxpool.Pool) (int, error) + func (j *Jobs) RegisterJobs(w *river.Workers) []*river.PeriodicJob + func (j *Jobs) SetEnqueuer(e jobs.Enqueuer) + func (j *Jobs) SetProcessor(p Processor) + type Processor interface + ProcessIntake func(ctx context.Context, intake *identity.InboundIntake) error + type Pruner interface + PruneProcessedIntake func(ctx context.Context, olderThan time.Duration) (int64, error) + type RetentionWorker struct + func (w *RetentionWorker) Work(ctx context.Context, _ *river.Job[InboundRetentionArgs]) error + type Store interface + LoadInboundIntake func(ctx context.Context, intakeID string) (*identity.InboundIntake, error) + MarkInboundIntakeFailed func(ctx context.Context, intakeID, detail string) error + PruneProcessedIntake func(ctx context.Context, olderThan time.Duration) (int64, error) + StampInboundIntakeJobIDTx func(ctx context.Context, tx pgx.Tx, intakeID string, jobID int64) error
Go to main page