job

Documentation

Index

• Variables
• type Cleanup
• type ID
  • func (i ID) ToSlice() []byte
• type Job
  • func (j *Job) AppendLog(line LogLine)
  • func (j *Job) Finish()
  • func (j *Job) ToBytes() ([]byte, error)
• type Log
• type LogLine
• type Repository
• type Target
• type WorkDir
  • func (w WorkDir) String() string

Variables

var ErrNotFound = errors.New("job not found")

ErrNotFound represents a job not found error

Types

type Cleanup

type Cleanup func()

Cleanup function for workdir

type ID

type ID uuid.UUID

ID is the identifier of job

func (ID) ToSlice

func (i ID) ToSlice() []byte

ToSlice returns slice value

type Job

type Job struct {
	ID       ID
	Finished bool      `json:"finished"`
	Stream   []LogLine `json:"stream"`
}

Job represents a task

func (*Job) AppendLog

func (j *Job) AppendLog(line LogLine)

AppendLog append log line to stream

func (*Job) Finish

func (j *Job) Finish()

Finish set true to Finished

func (*Job) ToBytes

func (j *Job) ToBytes() ([]byte, error)

ToBytes returns marshal byte slice

type Log

type Log interface {
	ReadLine() (*LogLine, error)
}

Log is a interface represents docker log.

type LogLine

type LogLine struct {
	Timestamp time.Time `json:"time"`
	Message   string    `json:"message"`
}

LogLine stores timestamp and message.

type Repository

type Repository interface {
	FindBy(ID) (*Job, error)
	Save(Job) error
}

Repository is Job Repository

type Target

type Target interface {
	Prepare(context.Context) (WorkDir, Cleanup, error)
}

Target represents build target

type WorkDir

type WorkDir string

WorkDir is a working directory for build job

func (WorkDir) String

func (w WorkDir) String() string

String returns string value