service

package
v1.2.3 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Oct 19, 2022 License: AGPL-3.0 Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL