Versions in this module Expand all Collapse all v1 v1.22.1 Dec 14, 2021 Changes in this version + func GetServiceStatus(settings *cli.EnvSettings) string + type JobExecution struct + Args map[string]string + Executor SparkExecutor + ID string + Pipeline ... + PostCheckStatus string + PreCheckStatus string + RunStatus string + Timeline utils.ExecutionTimeline + UID string + type JobSearchAPIResponse struct + Hits struct{ ... } + Took int + type JobsStore struct + JobExecutions []JobExecution + StoreName string + func NewJobsStore(settings *cli.EnvSettings, scheduleTitle string) *JobsStore + func (c *JobsStore) FetchJobsExecutions() + func (c *JobsStore) FindJobExecution(pipeline pipelines.Definition, id string) *JobExecution + type Meta struct + Count string + Display string + Index string + Query string + Reason string + Size string + Unit string + Value int + type SparkExecutor struct + Spark struct{ ... } + type StageHit struct + Error ... + Job ... + Kind string + Name string + PostCheck StagePhase + PreCheck StagePhase + Stage string + Status string + Timeline utils.ExecutionTimeline + type StagePhase struct + Link string + Meta Meta + Status string + type StageSearchAPIResponse struct + Hits struct{ ... } + Took int + type StagesStore struct + JobExecutions []JobExecution + StoreName string + func NewStagesStore(settings *cli.EnvSettings, scheduleTitle string) *StagesStore + func (c *StagesStore) FetchStagesExecutions(jobExecutionUID string) []StageHit
Go to main page