v1alpha1

package

Go to main page

Versions in this module

v0

v0.2.1

Dec 8, 2022

Changes in this version

type ConcurrencySpec

+ MaxConcurrency *int64

+ func (c ConcurrencySpec) GetMaxConcurrency() int64

v0.2.0

Jun 5, 2022

Changes in this version

+ type IndexState string

+ const IndexNotCreated

+ const IndexRetryBackoff

+ const IndexRunning

+ const IndexStarting

+ const IndexTerminated

type Job

+ func (j *Job) GetMaxAttempts() int64

+ func (j *Job) GetRetryDelay() time.Duration

type JobConditionFinished

+ FinishTimestamp metav1.Time

+ LatestCreationTimestamp *metav1.Time

+ LatestRunningTimestamp *metav1.Time

type JobConditionRunning

+ LatestCreationTimestamp metav1.Time

+ LatestRunningTimestamp metav1.Time

+ TerminatingTasks int64

type JobPhase

+ const JobFailed

+ const JobTerminating

type JobResult

+ const JobResultFailed

type JobStatus

+ ParallelStatus *ParallelStatus

+ RunningTasks int64

type JobTemplate

+ ForbidTaskForceDeletion bool

+ MaxAttempts *int64

+ Parallelism *ParallelismSpec

+ RetryDelaySeconds *int64

+ TaskPendingTimeoutSeconds *int64

+ TaskTemplate TaskTemplate

type JobTemplateSpec

+ Spec JobTemplate

+ type ParallelCompletionStrategy string

+ const AllSuccessful

+ const AnySuccessful

+ type ParallelIndex struct

+ IndexKey string

+ IndexNumber *int64

+ MatrixValues map[string]string

+ func (in *ParallelIndex) DeepCopy() *ParallelIndex

+ func (in *ParallelIndex) DeepCopyInto(out *ParallelIndex)

+ type ParallelIndexStatus struct

+ CreatedTasks int64

+ Hash string

+ Index ParallelIndex

+ Result TaskResult

+ State IndexState

+ func (in *ParallelIndexStatus) DeepCopy() *ParallelIndexStatus

+ func (in *ParallelIndexStatus) DeepCopyInto(out *ParallelIndexStatus)

+ type ParallelStatus struct

+ Indexes []ParallelIndexStatus

+ func (in *ParallelStatus) DeepCopy() *ParallelStatus

+ func (in *ParallelStatus) DeepCopyInto(out *ParallelStatus)

+ type ParallelStatusCounters struct

+ Created int64

+ Failed int64

+ RetryBackoff int64

+ Running int64

+ Starting int64

+ Succeeded int64

+ Terminated int64

+ func (in *ParallelStatusCounters) DeepCopy() *ParallelStatusCounters

+ func (in *ParallelStatusCounters) DeepCopyInto(out *ParallelStatusCounters)

+ type ParallelStatusSummary struct

+ Complete bool

+ Successful *bool

+ func (in *ParallelStatusSummary) DeepCopy() *ParallelStatusSummary

+ func (in *ParallelStatusSummary) DeepCopyInto(out *ParallelStatusSummary)

+ type ParallelismSpec struct

+ CompletionStrategy ParallelCompletionStrategy

+ WithCount *int64

+ WithKeys []string

+ WithMatrix map[string][]string

+ func (in *ParallelismSpec) DeepCopy() *ParallelismSpec

+ func (in *ParallelismSpec) DeepCopyInto(out *ParallelismSpec)

+ func (in *ParallelismSpec) GetCompletionStrategy() ParallelCompletionStrategy

+ type PodTemplateSpec struct

+ Spec corev1.PodSpec

+ func (in *PodTemplateSpec) DeepCopy() *PodTemplateSpec

+ func (in *PodTemplateSpec) DeepCopyInto(out *PodTemplateSpec)

+ func (p *PodTemplateSpec) ConvertToCoreSpec() *corev1.PodTemplateSpec

type TaskRef

+ ParallelIndex *ParallelIndex

+ RetryIndex int64

+ type TaskResult string

+ const TaskSucceeded

type TaskState

+ const TaskTerminated

+ type TaskTemplate struct

+ Pod *PodTemplateSpec

+ func (in *TaskTemplate) DeepCopy() *TaskTemplate

+ func (in *TaskTemplate) DeepCopyInto(out *TaskTemplate)

v0.1.0

Apr 29, 2022

Changes in this version

type JobConfigStatus

+ LastScheduled *metav1.Time

type JobReference

+ CreationTimestamp metav1.Time

+ Phase JobPhase

+ StartTime *metav1.Time

+ UID types.UID

type JobTemplateSpec

+ MaxAttempts *int32

type ScheduleContraints

+ NotAfter *metav1.Time

type ScheduleSpec

+ LastUpdated *metav1.Time

v0.0.1

Mar 27, 2022

Changes in this version

+ const KindJob

+ const KindJobConfig

+ const Version

+ var AddToScheme = SchemeBuilder.AddToScheme

+ var AllFailedJobResults = []JobResult

+ var BoolOptionFormatsAll = []BoolOptionFormat

+ var GVKJob = SchemeGroupVersion.WithKind(KindJob)

+ var GVKJobConfig = SchemeGroupVersion.WithKind(KindJobConfig)

+ var GroupVersion = schema.GroupVersion

+ var OptionTypesAll = []OptionType

+ var SchemeBuilder = &scheme.Builder

+ var SchemeGroupVersion = schema.GroupVersion

+ func Resource(resource string) schema.GroupResource

+ type BoolOptionConfig struct

+ Default bool

+ FalseVal string

+ Format BoolOptionFormat

+ TrueVal string

+ func (c *BoolOptionConfig) FormatValue(value bool) (string, error)

+ func (in *BoolOptionConfig) DeepCopy() *BoolOptionConfig

+ func (in *BoolOptionConfig) DeepCopyInto(out *BoolOptionConfig)

+ type BoolOptionFormat string

+ const BoolOptionFormatCustom

+ const BoolOptionFormatOneZero

+ const BoolOptionFormatTrueFalse

+ const BoolOptionFormatYesNo

+ func (b BoolOptionFormat) Format(val bool) (string, error)

+ func (b BoolOptionFormat) IsValid() bool

+ type ConcurrencyPolicy string

+ const ConcurrencyPolicyAllow

+ const ConcurrencyPolicyEnqueue

+ const ConcurrencyPolicyForbid

+ type ConcurrencySpec struct

+ Policy ConcurrencyPolicy

+ func (in *ConcurrencySpec) DeepCopy() *ConcurrencySpec

+ func (in *ConcurrencySpec) DeepCopyInto(out *ConcurrencySpec)

+ type CronSchedule struct

+ Expression string

+ Timezone string

+ func (in *CronSchedule) DeepCopy() *CronSchedule

+ func (in *CronSchedule) DeepCopyInto(out *CronSchedule)

+ type DateOptionConfig struct

+ Format string

+ func (in *DateOptionConfig) DeepCopy() *DateOptionConfig

+ func (in *DateOptionConfig) DeepCopyInto(out *DateOptionConfig)

+ type Job struct

+ Spec JobSpec

+ Status JobStatus

+ func (in *Job) DeepCopy() *Job

+ func (in *Job) DeepCopyInto(out *Job)

+ func (in *Job) DeepCopyObject() runtime.Object

+ type JobCondition struct

+ Finished *JobConditionFinished

+ Queueing *JobConditionQueueing

+ Running *JobConditionRunning

+ Waiting *JobConditionWaiting

+ func (in *JobCondition) DeepCopy() *JobCondition

+ func (in *JobCondition) DeepCopyInto(out *JobCondition)

+ type JobConditionFinished struct

+ CreatedAt *metav1.Time

+ FinishedAt metav1.Time

+ Message string

+ Reason string

+ Result JobResult

+ StartedAt *metav1.Time

+ func (in *JobConditionFinished) DeepCopy() *JobConditionFinished

+ func (in *JobConditionFinished) DeepCopyInto(out *JobConditionFinished)

+ type JobConditionQueueing struct

+ Message string

+ Reason string

+ func (in *JobConditionQueueing) DeepCopy() *JobConditionQueueing

+ func (in *JobConditionQueueing) DeepCopyInto(out *JobConditionQueueing)

+ type JobConditionRunning struct

+ CreatedAt metav1.Time

+ StartedAt metav1.Time

+ func (in *JobConditionRunning) DeepCopy() *JobConditionRunning

+ func (in *JobConditionRunning) DeepCopyInto(out *JobConditionRunning)

+ type JobConditionWaiting struct

+ CreatedAt *metav1.Time

+ Message string

+ Reason string

+ func (in *JobConditionWaiting) DeepCopy() *JobConditionWaiting

+ func (in *JobConditionWaiting) DeepCopyInto(out *JobConditionWaiting)

+ type JobConfig struct

+ Spec JobConfigSpec

+ Status JobConfigStatus

+ func (in *JobConfig) DeepCopy() *JobConfig

+ func (in *JobConfig) DeepCopyInto(out *JobConfig)

+ func (in *JobConfig) DeepCopyObject() runtime.Object

+ type JobConfigList struct

+ Items []JobConfig

+ func (in *JobConfigList) DeepCopy() *JobConfigList

+ func (in *JobConfigList) DeepCopyInto(out *JobConfigList)

+ func (in *JobConfigList) DeepCopyObject() runtime.Object

+ type JobConfigSpec struct

+ Concurrency ConcurrencySpec

+ Option *OptionSpec

+ Schedule *ScheduleSpec

+ Template JobTemplate

+ func (in *JobConfigSpec) DeepCopy() *JobConfigSpec

+ func (in *JobConfigSpec) DeepCopyInto(out *JobConfigSpec)

+ type JobConfigState string

+ const JobConfigExecuting

+ const JobConfigJobQueued

+ const JobConfigReady

+ const JobConfigReadyDisabled

+ const JobConfigReadyEnabled

+ type JobConfigStatus struct

+ Active int64

+ ActiveJobs []JobReference

+ LastScheduleTime *metav1.Time

+ Queued int64

+ QueuedJobs []JobReference

+ State JobConfigState

+ func (in *JobConfigStatus) DeepCopy() *JobConfigStatus

+ func (in *JobConfigStatus) DeepCopyInto(out *JobConfigStatus)

+ type JobList struct

+ Items []Job

+ func (in *JobList) DeepCopy() *JobList

+ func (in *JobList) DeepCopyInto(out *JobList)

+ func (in *JobList) DeepCopyObject() runtime.Object

+ type JobPhase string

+ const JobAdmissionError

+ const JobDeadlineExceeded

+ const JobFinishedUnknown

+ const JobKilled

+ const JobKilling

+ const JobPending

+ const JobPendingTimeout

+ const JobQueued

+ const JobRetryBackoff

+ const JobRetryLimitExceeded

+ const JobRetrying

+ const JobRunning

+ const JobStarting

+ const JobSucceeded

+ func (p JobPhase) IsTerminal() bool

+ type JobReference struct

+ Name string

+ Namespace string

+ func (in *JobReference) DeepCopy() *JobReference

+ func (in *JobReference) DeepCopyInto(out *JobReference)

+ type JobResult string

+ const JobResultAdmissionError

+ const JobResultDeadlineExceeded

+ const JobResultFinalStateUnknown

+ const JobResultKilled

+ const JobResultPendingTimeout

+ const JobResultSuccess

+ const JobResultTaskFailed

+ func (r JobResult) IsFailed() bool

+ type JobSpec struct

+ ConfigName string

+ KillTimestamp *metav1.Time

+ OptionValues string

+ StartPolicy *StartPolicySpec

+ Substitutions map[string]string

+ TTLSecondsAfterFinished *int32

+ Template *JobTemplateSpec

+ Type JobType

+ func (in *JobSpec) DeepCopy() *JobSpec

+ func (in *JobSpec) DeepCopyInto(out *JobSpec)

+ type JobStatus struct

+ Condition JobCondition

+ CreatedTasks int64

+ Phase JobPhase

+ StartTime *metav1.Time

+ Tasks []TaskRef

+ func (in *JobStatus) DeepCopy() *JobStatus

+ func (in *JobStatus) DeepCopyInto(out *JobStatus)

+ type JobTaskSpec struct

+ ForbidForceDeletion bool

+ PendingTimeoutSeconds *int64

+ Template corev1.PodTemplateSpec

+ func (in *JobTaskSpec) DeepCopy() *JobTaskSpec

+ func (in *JobTaskSpec) DeepCopyInto(out *JobTaskSpec)

+ type JobTemplate struct

+ Spec JobTemplateSpec

+ func (in *JobTemplate) DeepCopy() *JobTemplate

+ func (in *JobTemplate) DeepCopyInto(out *JobTemplate)

+ type JobTemplateSpec struct

+ MaxRetryAttempts *int32

+ RetryDelaySeconds *int64

+ Task JobTaskSpec

+ func (in *JobTemplateSpec) DeepCopy() *JobTemplateSpec

+ func (in *JobTemplateSpec) DeepCopyInto(out *JobTemplateSpec)

+ type JobType string

+ const JobTypeAdhoc

+ const JobTypeScheduled

+ type MultiOptionConfig struct

+ AllowCustom bool

+ Default []string

+ Delimiter string

+ Values []string

+ func (in *MultiOptionConfig) DeepCopy() *MultiOptionConfig

+ func (in *MultiOptionConfig) DeepCopyInto(out *MultiOptionConfig)

+ type Option struct

+ Bool *BoolOptionConfig

+ Date *DateOptionConfig

+ Label string

+ Multi *MultiOptionConfig

+ Name string

+ Required bool

+ Select *SelectOptionConfig

+ String *StringOptionConfig

+ Type OptionType

+ func (in *Option) DeepCopy() *Option

+ func (in *Option) DeepCopyInto(out *Option)

+ type OptionSpec struct

+ Options []Option

+ func (in *OptionSpec) DeepCopy() *OptionSpec

+ func (in *OptionSpec) DeepCopyInto(out *OptionSpec)

+ type OptionType string

+ const OptionTypeBool

+ const OptionTypeDate

+ const OptionTypeMulti

+ const OptionTypeSelect

+ const OptionTypeString

+ func (t OptionType) IsValid() bool

+ type ScheduleContraints struct

+ NotBefore *metav1.Time

+ func (in *ScheduleContraints) DeepCopy() *ScheduleContraints

+ func (in *ScheduleContraints) DeepCopyInto(out *ScheduleContraints)

+ type ScheduleSpec struct

+ Constraints *ScheduleContraints

+ Cron *CronSchedule

+ Disabled bool

+ func (in *ScheduleSpec) DeepCopy() *ScheduleSpec

+ func (in *ScheduleSpec) DeepCopyInto(out *ScheduleSpec)

+ type SelectOptionConfig struct

+ AllowCustom bool

+ Default string

+ Values []string

+ func (in *SelectOptionConfig) DeepCopy() *SelectOptionConfig

+ func (in *SelectOptionConfig) DeepCopyInto(out *SelectOptionConfig)

+ type StartPolicySpec struct

+ ConcurrencyPolicy ConcurrencyPolicy

+ StartAfter *metav1.Time

+ func (in *StartPolicySpec) DeepCopy() *StartPolicySpec

+ func (in *StartPolicySpec) DeepCopyInto(out *StartPolicySpec)

+ type StringOptionConfig struct

+ Default string

+ TrimSpaces bool

+ func (in *StringOptionConfig) DeepCopy() *StringOptionConfig

+ func (in *StringOptionConfig) DeepCopyInto(out *StringOptionConfig)

+ type TaskContainerState struct

+ ContainerID string

+ ExitCode int32

+ Message string

+ Reason string

+ Signal int32

+ func (in *TaskContainerState) DeepCopy() *TaskContainerState

+ func (in *TaskContainerState) DeepCopyInto(out *TaskContainerState)

+ type TaskRef struct

+ ContainerStates []TaskContainerState

+ CreationTimestamp metav1.Time

+ DeletedStatus *TaskStatus

+ FinishTimestamp *metav1.Time

+ Name string

+ NodeName string

+ RunningTimestamp *metav1.Time

+ Status TaskStatus

+ func (in *TaskRef) DeepCopy() *TaskRef

+ func (in *TaskRef) DeepCopyInto(out *TaskRef)

+ type TaskState string

+ const TaskDeadlineExceeded

+ const TaskDeletedFinalStateUnknown

+ const TaskFailed

+ const TaskKilled

+ const TaskKilling

+ const TaskPendingTimeout

+ const TaskRunning

+ const TaskStaging

+ const TaskStarting

+ const TaskSuccess

+ type TaskStatus struct

+ Message string

+ Reason string

+ Result *JobResult

+ State TaskState

+ func (in *TaskStatus) DeepCopy() *TaskStatus

+ func (in *TaskStatus) DeepCopyInto(out *TaskStatus)

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