worker

Documentation

Index

• Variables
• type AlrWorker
  • func NewAlrWorker(db *sql.DB) AlrWorker
  • func (a *AlrWorker) ProcessAlrJob(ctx context.Context, jobArgs models.JobAlrEnqueueArgs) error
• type JobError
  • func (je JobError) Error() string
• type MockWorker
  • func (_m *MockWorker) ProcessJob(ctx context.Context, job models.Job, jobArgs models.JobEnqueueArgs) error
  • func (_m *MockWorker) ValidateJob(ctx context.Context, jobArgs models.JobEnqueueArgs) (*models.Job, error)
• type Worker
  • func NewWorker(db *sql.DB) Worker

Variables

var (
	ErrNoBasePathSet      = JobError{"empty BBBasePath: Must be set"}
	ErrParentJobNotFound  = JobError{"parent job not found"}
	ErrParentJobCancelled = JobError{"parent job cancelled"}
)

Types

type AlrWorker

type AlrWorker struct {
	*postgres.AlrRepository
	repository.Repository
	StagingDir string `conf:"FHIR_STAGING_DIR"`
}

func NewAlrWorker

func NewAlrWorker(db *sql.DB) AlrWorker

func (*AlrWorker) ProcessAlrJob

func (a *AlrWorker) ProcessAlrJob(
	ctx context.Context,
	jobArgs models.JobAlrEnqueueArgs,
) error

ProcessAlrJob is a function called by the Worker to serve ALR data to users

type JobError

type JobError struct {
	ErrorString string
}

func (JobError) Error

func (je JobError) Error() string

type MockWorker

type MockWorker struct {
	mock.Mock
}

MockWorker is an autogenerated mock type for the Worker type

func (*MockWorker) ProcessJob

func (_m *MockWorker) ProcessJob(ctx context.Context, job models.Job, jobArgs models.JobEnqueueArgs) error

ProcessJob provides a mock function with given fields: ctx, job, jobArgs

func (*MockWorker) ValidateJob

func (_m *MockWorker) ValidateJob(ctx context.Context, jobArgs models.JobEnqueueArgs) (*models.Job, error)

ValidateJob provides a mock function with given fields: ctx, jobArgs

type Worker

type Worker interface {
	ValidateJob(ctx context.Context, jobArgs models.JobEnqueueArgs) (*models.Job, error)
	ProcessJob(ctx context.Context, job models.Job, jobArgs models.JobEnqueueArgs) error
}

func NewWorker

func NewWorker(db *sql.DB) Worker