app_job_impl

Documentation

Index

• Variables
• func GetHistories(path mo_string.OptionalString) (histories []app_job.History, err error)
• func NewHistorian(ws app_workspace.Workspace) app_job.Historian
• func NewLauncher(ui app_ui.UI, wb app_workspace.Bundle, com app_opt.CommonOpts, ...) app_job.Launcher
• func NewOrphanHistory(path string) (h app_job.History, found bool)
• type Historian
  • func (z Historian) Histories() (histories []app_job.History, err error)
• type History
  • func (z History) AppName() string
  • func (z History) AppVersion() string
  • func (z History) Archive() (path string, err error)
  • func (z History) Delete() error
  • func (z History) IsNested() bool
  • func (z History) IsOrphaned() bool
  • func (z History) Job() app_workspace.Job
  • func (z History) JobId() string
  • func (z History) JobPath() string
  • func (z History) Logs() (logs []app_job.LogFile, err error)
  • func (z History) Recipe() (r rc_recipe.Spec, found bool)
  • func (z History) RecipeName() string
  • func (z History) ResultLog() app_job.ResultLog
  • func (z History) StartLog() app_job.StartLog
  • func (z History) TimeFinish() (t time.Time, found bool)
  • func (z History) TimeStart() (t time.Time, found bool)
• type HistoryMetadata
• type MsgLauncher
• type OrphanHistory
  • func (z OrphanHistory) AppName() string
  • func (z OrphanHistory) AppVersion() string
  • func (z OrphanHistory) IsNested() bool
  • func (z OrphanHistory) IsOrphaned() bool
  • func (z OrphanHistory) Job() app_workspace.Job
  • func (z OrphanHistory) JobId() string
  • func (z OrphanHistory) JobPath() string
  • func (z OrphanHistory) Logs() (logs []app_job.LogFile, err error)
  • func (z OrphanHistory) Recipe() (r rc_recipe.Spec, found bool)
  • func (z OrphanHistory) RecipeName() string
  • func (z OrphanHistory) ResultLog() app_job.ResultLog
  • func (z OrphanHistory) StartLog() app_job.StartLog
  • func (z OrphanHistory) TimeFinish() (t time.Time, found bool)
  • func (z OrphanHistory) TimeStart() (t time.Time, found bool)
• type OrphanJob
  • func (z OrphanJob) Descendant(name string) (path string, err error)
  • func (z OrphanJob) Job() string
  • func (z OrphanJob) JobId() string
  • func (z OrphanJob) JobStartTime() time.Time
  • func (z OrphanJob) KVS() string
  • func (z OrphanJob) Log() string
  • func (z OrphanJob) Report() string
  • func (z OrphanJob) Test() string

Variables

var (
	ErrorFileIsNotALog = errors.New("the file is not a log")
)

var (
	MLauncher = app_msg.Apply(&MsgLauncher{}).(*MsgLauncher)
)

Functions

func GetHistories

func GetHistories(path mo_string.OptionalString) (histories []app_job.History, err error)

func NewHistorian

func NewHistorian(ws app_workspace.Workspace) app_job.Historian

func NewLauncher

func NewLauncher(ui app_ui.UI, wb app_workspace.Bundle, com app_opt.CommonOpts, rcp rc_recipe.Spec) app_job.Launcher

func NewOrphanHistory

func NewOrphanHistory(path string) (h app_job.History, found bool)

Types

type Historian

type Historian struct {
	// contains filtered or unexported fields
}

func (Historian) Histories

func (z Historian) Histories() (histories []app_job.History, err error)

type History

type History struct {
	// contains filtered or unexported fields
}

func (History) AppName

func (z History) AppName() string

func (History) AppVersion

func (z History) AppVersion() string

func (History) Archive

func (z History) Archive() (path string, err error)

func (History) Delete

func (z History) Delete() error

func (History) IsNested

func (z History) IsNested() bool

func (History) IsOrphaned

func (z History) IsOrphaned() bool

func (History) Job

func (z History) Job() app_workspace.Job

func (History) JobId

func (z History) JobId() string

func (History) JobPath

func (z History) JobPath() string

func (History) Logs

func (z History) Logs() (logs []app_job.LogFile, err error)

func (History) Recipe

func (z History) Recipe() (r rc_recipe.Spec, found bool)

func (History) RecipeName

func (z History) RecipeName() string

func (History) ResultLog

func (z History) ResultLog() app_job.ResultLog

func (History) StartLog

func (z History) StartLog() app_job.StartLog

func (History) TimeFinish

func (z History) TimeFinish() (t time.Time, found bool)

func (History) TimeStart

func (z History) TimeStart() (t time.Time, found bool)

type HistoryMetadata

type HistoryMetadata struct {
	JobId string `json:"job_id"`
}

type MsgLauncher

type MsgLauncher struct {
	ElapsedTimeOnEnd app_msg.Message
}

type OrphanHistory

type OrphanHistory struct {
	// contains filtered or unexported fields
}

func (OrphanHistory) AppName

func (z OrphanHistory) AppName() string

func (OrphanHistory) AppVersion

func (z OrphanHistory) AppVersion() string

func (OrphanHistory) IsNested

func (z OrphanHistory) IsNested() bool

func (OrphanHistory) IsOrphaned

func (z OrphanHistory) IsOrphaned() bool

func (OrphanHistory) Job

func (z OrphanHistory) Job() app_workspace.Job

func (OrphanHistory) JobId

func (z OrphanHistory) JobId() string

func (OrphanHistory) JobPath

func (z OrphanHistory) JobPath() string

func (OrphanHistory) Logs

func (z OrphanHistory) Logs() (logs []app_job.LogFile, err error)

func (OrphanHistory) Recipe

func (z OrphanHistory) Recipe() (r rc_recipe.Spec, found bool)

func (OrphanHistory) RecipeName

func (z OrphanHistory) RecipeName() string

func (OrphanHistory) ResultLog

func (z OrphanHistory) ResultLog() app_job.ResultLog

func (OrphanHistory) StartLog

func (z OrphanHistory) StartLog() app_job.StartLog

func (OrphanHistory) TimeFinish

func (z OrphanHistory) TimeFinish() (t time.Time, found bool)

func (OrphanHistory) TimeStart

func (z OrphanHistory) TimeStart() (t time.Time, found bool)

type OrphanJob

type OrphanJob struct {
	// contains filtered or unexported fields
}

func (OrphanJob) Descendant

func (z OrphanJob) Descendant(name string) (path string, err error)

func (OrphanJob) Job

func (z OrphanJob) Job() string

func (OrphanJob) JobId

func (z OrphanJob) JobId() string

func (OrphanJob) JobStartTime

func (z OrphanJob) JobStartTime() time.Time

func (OrphanJob) KVS

func (z OrphanJob) KVS() string

func (OrphanJob) Log

func (z OrphanJob) Log() string

func (OrphanJob) Report

func (z OrphanJob) Report() string

func (OrphanJob) Test

func (z OrphanJob) Test() string