service

Documentation

Index

• type APIClient
• type JobSvc
  • func (js *JobSvc) JobSvc(ctx context.Context) error
• type Looper
  • func (l *Looper) Loop(ctx context.Context) error

Types

type APIClient

type APIClient interface {
	Get(ctx context.Context) (model.Job, error)
	UpdateStatus(ctx context.Context, status model.JobStatus, jobID int) error
}

type JobSvc

type JobSvc struct {
	API        APIClient
	Deleter    deleter
	DestDetail destDetail
}

func (*JobSvc) JobSvc

func (js *JobSvc) JobSvc(ctx context.Context) error

called by looper calls api-client.getJob(workspaceID) calls api-client to get new job with workspaceID, which returns jobID.

type Looper

type Looper struct {
	Backoff backoff.BackOffContext
	Svc     JobSvc
}

func (*Looper) Loop

func (l *Looper) Loop(ctx context.Context) error