Version: v1.5.0 Latest Latest

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

Go to latest
Published: May 2, 2018 License: Apache-2.0 Imports: 8 Imported by: 16




View Source
const (
	//ImageScanJob is name of scan job it will be used as key to register to job service.
	ImageScanJob = "IMAGE_SCAN"
	// ImageTransfer : the name of image transfer job in job service
	ImageTransfer = "IMAGE_TRANSFER"
	// ImageDelete : the name of image delete job in job service
	ImageDelete = "IMAGE_DELETE"
	// ImageReplicate : the name of image replicate job in job service
	ImageReplicate = "IMAGE_REPLICATE"

	//JobKindGeneric : Kind of generic job
	JobKindGeneric = "Generic"
	//JobKindScheduled : Kind of scheduled job
	JobKindScheduled = "Scheduled"
	//JobKindPeriodic : Kind of periodic job
	JobKindPeriodic = "Periodic"

	//JobServiceStatusPending   : job status pending
	JobServiceStatusPending = "Pending"
	//JobServiceStatusRunning   : job status running
	JobServiceStatusRunning = "Running"
	//JobServiceStatusStopped   : job status stopped
	JobServiceStatusStopped = "Stopped"
	//JobServiceStatusCancelled : job status cancelled
	JobServiceStatusCancelled = "Cancelled"
	//JobServiceStatusError     : job status error
	JobServiceStatusError = "Error"
	//JobServiceStatusSuccess   : job status success
	JobServiceStatusSuccess = "Success"
	//JobServiceStatusScheduled : job status scheduled
	JobServiceStatusScheduled = "Scheduled"

	// JobActionStop : the action to stop the job
	JobActionStop = "stop"


This section is empty.


This section is empty.


type Client

type Client interface {
	SubmitJob(*models.JobData) (string, error)
	GetJobLog(uuid string) ([]byte, error)
	PostAction(uuid, action string) error

Client wraps interface to access jobservice.

type DefaultClient

type DefaultClient struct {
	// contains filtered or unexported fields

DefaultClient is the default implementation of Client interface

func NewDefaultClient

func NewDefaultClient(endpoint, secret string) *DefaultClient

NewDefaultClient creates a default client based on endpoint and secret.

func (*DefaultClient) GetJobLog

func (d *DefaultClient) GetJobLog(uuid string) ([]byte, error)

GetJobLog call jobserivce API to get the log of a job. It only accepts the UUID of the job

func (*DefaultClient) PostAction

func (d *DefaultClient) PostAction(uuid, action string) error

PostAction call jobservice's API to operate action for job specified by uuid

func (*DefaultClient) SubmitJob

func (d *DefaultClient) SubmitJob(jd *models.JobData) (string, error)

SubmitJob call jobserivce API to submit a job and returns the job's UUID.

type ScanJobParms

type ScanJobParms struct {
	JobID      int64  `json:"job_int_id"`
	Repository string `json:"repository"`
	Tag        string `json:"tag"`
	Digest     string `json:"digest"`

ScanJobParms holds parameters used to submit jobs to jobservice


Path Synopsis

Jump to

Keyboard shortcuts

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