testfactory

Documentation

Overview

Package testfactory provides low level helpers for inserting records directly into the database.

Index

• func Job(ctx context.Context, t *testing.T, exec riverdriver.Executor, opts *JobOpts) *rivertype.JobRow
• func Leader(ctx context.Context, t *testing.T, exec riverdriver.Executor, opts *LeaderOpts) *riverdriver.Leader
• func Migration(ctx context.Context, t *testing.T, exec riverdriver.Executor, ...) *riverdriver.Migration
• type JobOpts
• type LeaderOpts
• type MigrationOpts

Functions

func Job

func Job(ctx context.Context, t *testing.T, exec riverdriver.Executor, opts *JobOpts) *rivertype.JobRow

func Leader

func Leader(ctx context.Context, t *testing.T, exec riverdriver.Executor, opts *LeaderOpts) *riverdriver.Leader

func Migration

func Migration(ctx context.Context, t *testing.T, exec riverdriver.Executor, opts *MigrationOpts) *riverdriver.Migration

Types

type JobOpts

type JobOpts struct {
	Attempt     *int
	AttemptedAt *time.Time
	CreatedAt   *time.Time
	EncodedArgs []byte
	Errors      [][]byte
	FinalizedAt *time.Time
	Kind        *string
	MaxAttempts *int
	Metadata    []byte
	Priority    *int
	Queue       *string
	ScheduledAt *time.Time
	State       *rivertype.JobState
	Tags        []string
}

type LeaderOpts

type LeaderOpts struct {
	ElectedAt *time.Time
	ExpiresAt *time.Time
	LeaderID  *string
	Name      *string
}

type MigrationOpts

type MigrationOpts struct {
	Version *int
}