service

Documentation

Index

• Variables
• type JobServiceApp
  • func NewJobServiceApp(mss stepService.StepServiceApp) JobServiceApp
• type JobServiceAppImpl
  • func (j JobServiceAppImpl) CancelAJob(uu string) (*module.Job, error)
  • func (j JobServiceAppImpl) CreateJob() *module.Job
  • func (j JobServiceAppImpl) GetAJob(uu string) (*module.Job, error)
  • func (j JobServiceAppImpl) GetJobResult(uu string) (*stepModule.StepResult, error)
  • func (j JobServiceAppImpl) StartAJob(uu string, step *stepModule.Step) (*module.Job, error)

Variables

var (
	JobNotFoundError = errors.New("uuid not found in job service")
	StepsNotSetError = errors.New("steps have not set to this job")
)

Types

type JobServiceApp

type JobServiceApp interface {
	CreateJob() *module.Job
	StartAJob(uuid string, steps *stepModule.Step) (*module.Job, error)
	CancelAJob(uuid string) (*module.Job, error)
	GetJobResult(uuid string) (*stepModule.StepResult, error)
	GetAJob(uu string) (*module.Job, error)
}

func NewJobServiceApp

func NewJobServiceApp(mss stepService.StepServiceApp) JobServiceApp

type JobServiceAppImpl

type JobServiceAppImpl struct {
	// todo: monitor long term jobs, mention user to delete it
	Jobs        map[string]*module.Job
	StepService stepService.StepServiceApp
}

func (JobServiceAppImpl) CancelAJob

func (j JobServiceAppImpl) CancelAJob(uu string) (*module.Job, error)

func (JobServiceAppImpl) CreateJob

func (j JobServiceAppImpl) CreateJob() *module.Job

func (JobServiceAppImpl) GetAJob

func (j JobServiceAppImpl) GetAJob(uu string) (*module.Job, error)

func (JobServiceAppImpl) GetJobResult

func (j JobServiceAppImpl) GetJobResult(uu string) (*stepModule.StepResult, error)

func (JobServiceAppImpl) StartAJob

func (j JobServiceAppImpl) StartAJob(uu string, step *stepModule.Step) (*module.Job, error)