v1

package

Go to main page

Versions in this module

v1

v1.0.1

Feb 23, 2022

v1.0.0

Jan 17, 2022

v0

v0.9.0

Oct 19, 2020

Changes in this version

+ const AnnotationKeyFrameworkUID

+ const AnnotationKeyTaskRoleUID

+ const AnnotationKeyTaskUID

+ const EnvNameFrameworkUID

+ const EnvNameTaskRoleUID

+ const EnvNameTaskUID

+ const LogMarkerObjectSnapshot

+ const LogMarkerOnFrameworkDeletion

+ const LogMarkerOnFrameworkRetry

+ const LogMarkerOnPodDeletion

+ const LogMarkerOnTaskDeletion

+ const LogMarkerOnTaskRetry

+ const TaskKind

+ var TaskGroupVersionKind = SchemeGroupVersion.WithKind(TaskKind)

+ func GetTaskName(frameworkName string, taskRoleName string, taskIndex int32) string

+ func SplitTaskName(taskName string) (frameworkName string, taskRoleName string, taskIndex int32)

type Framework

+ func (f *Framework) GetTaskSpec(taskRoleName string) *TaskSpec

+ func (f *Framework) MockTask(taskRoleName string, taskIndex int32, taskDeleting bool) *Task

+ func (f *Framework) NewTaskRoleStatus(taskRoleName string, taskNumber int32) *TaskRoleStatus

+ func (f *Framework) NewTaskStatuses(taskRoleName string, taskNumber int32) []*TaskStatus

type FrameworkStatus

+ RunTime *meta.Time

type LogFrameworkSnapshot

+ func (s *LogFrameworkSnapshot) GetLogTailOnFrameworkDeletion(f *Framework) string

+ func (s *LogFrameworkSnapshot) GetLogTailOnFrameworkRetry(f *Framework) string

type LogObjectSnapshot

+ Task LogTaskSnapshot

type LogPodSnapshot

+ func (s *LogPodSnapshot) GetLogTailOnPodDeletion(pod *core.Pod) string

+ type LogTaskSnapshot struct

+ OnTaskDeletion *bool

+ OnTaskRetry *bool

+ func (in *LogTaskSnapshot) DeepCopy() *LogTaskSnapshot

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

+ func (s *LogTaskSnapshot) GetLogTailOnTaskDeletion(task *Task) string

+ func (s *LogTaskSnapshot) GetLogTailOnTaskRetry(task *Task) string

+ type ObjectSnapshotTrigger string

+ type Task struct

+ Spec *TaskSpec

+ Status *TaskStatus

+ func (in *Task) DeepCopy() *Task

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

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

type TaskRoleStatus

+ InstanceUID types.UID

type TaskStatus

+ InstanceUID types.UID

+ RunTime *meta.Time

v0.8.0

Aug 31, 2020

Changes in this version

type CompletionCode

+ const CompletionCodeConfigMapLocalCacheCreationTimeout

+ const CompletionCodePodCreationPermanentError

+ const CompletionCodePodCreationTransientError

+ const CompletionCodePodCreationUnknownError

+ const CompletionCodePodLocalCacheCreationTimeout

type Config

+ KubeClientBurst *int32

+ KubeClientQps *float32

type PodMatchResult

+ func ClassifyPodCreationError(apiErr error) PodMatchResult

v0.7.0

Aug 11, 2020

Changes in this version

+ const LabelKeyTaskIndex

type CompletionCode

+ const CompletionCodeDeleteTaskRequested

type ExecutionType

+ const ExecutionCreate

type Framework

+ func (f *Framework) GetTaskCountSpec() int32

+ func (f *Framework) GetTaskCountStatus(selector TaskStatusSelector) int32

+ func (f *Framework) GetTaskRoleSpec(taskRoleName string) *TaskRoleSpec

+ func (f *Framework) GetTaskRoleStatus(taskRoleName string) *TaskRoleStatus

+ func (f *Framework) GetTaskStatus(taskRoleName string, taskIndex int32) *TaskStatus

+ func (f *Framework) GetTotalTaskCountSpec() int32

+ func (f *Framework) GetTotalTaskCountStatus() int32

type FrameworkAttemptCompletionStatus

+ func NewCompletedTaskTriggeredCompletionStatus(triggerTaskStatus *TaskStatus, triggerTaskRoleName string, ...) *FrameworkAttemptCompletionStatus

+ func NewFailedTaskTriggeredCompletionStatus(triggerTaskStatus *TaskStatus, triggerTaskRoleName string, ...) *FrameworkAttemptCompletionStatus

+ func NewSucceededTaskTriggeredCompletionStatus(triggerTaskStatus *TaskStatus, triggerTaskRoleName string, ...) *FrameworkAttemptCompletionStatus

type LogFrameworkSnapshot

+ OnFrameworkRescale *bool

type TaskRoleStatus

+ PodGracefulDeletionTimeoutSec *int64

+ func (trs *TaskRoleStatus) CompletionTimeOrderedTaskStatus(selector TaskStatusSelector, orderIndex int32) *TaskStatus

+ func (trs *TaskRoleStatus) GetTaskCountStatus(selector TaskStatusSelector) int32

type TaskStatus

+ DeletionPending bool

+ func (ts *TaskStatus) IsDeletionPendingIgnored(ignoreDeletionPending bool) bool

+ func (ts *TaskStatus) MarkAsDeletionPending() (isNewDeletionPendingTask bool)

type TaskStatusSelector

+ func BindIDP(selectorIDP TaskStatusSelectorIDP, ignoreDeletionPending bool) TaskStatusSelector

+ type TaskStatusSelectorIDP func(taskStatus *TaskStatus, ignoreDeletionPending bool) bool

v0.6.0

Jan 17, 2020

Changes in this version

+ func SplitFrameworkKey(frameworkKey string) (frameworkNamespace, frameworkName string)

type CompletionCode

+ const CompletionCodePodSpecPermanentError

v0.5.1

Nov 12, 2019

v0.5.0

Nov 6, 2019

Changes in this version

+ const LargeFrameworkCompressionMinBytes

type Config

+ LargeFrameworkCompression *bool

type Framework

+ func (f *Framework) Compress() error

+ func (f *Framework) Decompress() error

type FrameworkAttemptStatus

+ TaskRoleStatusesCompressed []byte

type TaskAttemptStatus

+ PodNodeName *string

v0.4.0

Sep 19, 2019

Changes in this version

+ const PlaceholderConfigMapName

+ const PlaceholderFrameworkName

+ const PlaceholderFrameworkNamespace

+ const PlaceholderPodName

+ const PlaceholderTaskIndex

+ const PlaceholderTaskRoleName

+ const PodKind

+ var CompletionCodeReservedNonPositive = CompletionCodeRange

+ var CompletionCodeReservedPositive = CompletionCodeRange

+ var PodGroupVersionKind = core.SchemeGroupVersion.WithKind(PodKind)

+ func AppendCompletionCodeInfos(codeInfos []*CompletionCodeInfo)

+ func GetAllContainerStatuses(pod *core.Pod) []core.ContainerStatus

+ func GetFrameworkSnapshotLogTail(f *Framework) string

+ func GetPodSnapshotLogTail(pod *core.Pod) string

type CompletionCode

+ const CompletionCodeFrameworkAttemptCompletion

+ const CompletionCodeStopFrameworkRequested

+ func (cc CompletionCode) NewFrameworkAttemptCompletionStatus(diag string, cpts *CompletionPolicyTriggerStatus) *FrameworkAttemptCompletionStatus

+ func (cc CompletionCode) NewTaskAttemptCompletionStatus(diag string, pcs *PodCompletionStatus) *TaskAttemptCompletionStatus

+ func (cc CompletionCode) Ptr() *CompletionCode

type CompletionCodeInfo

+ Code *CompletionCode

+ PodPatterns []*PodPattern

+ type CompletionCodeRange struct

+ Max CompletionCode

+ Min CompletionCode

+ func (ccr CompletionCodeRange) Contains(cc CompletionCode) bool

+ func (ccr CompletionCodeRange) Int32Range() Int32Range

+ func (ccr CompletionCodeRange) String() string

+ func (in *CompletionCodeRange) DeepCopy() *CompletionCodeRange

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

+ type CompletionPolicyTriggerStatus struct

+ Message string

+ TaskIndex int32

+ TaskRoleName string

+ func (in *CompletionPolicyTriggerStatus) DeepCopy() *CompletionPolicyTriggerStatus

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

type Config

+ FrameworkCompletedRetainSec *int64

+ LogObjectSnapshot LogObjectSnapshot

+ PodFailureSpec []*CompletionCodeInfo

+ type ContainerCompletionStatus struct

+ Code int32

+ Message string

+ Name string

+ Reason string

+ Signal int32

+ func (in *ContainerCompletionStatus) DeepCopy() *ContainerCompletionStatus

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

+ type ContainerPattern struct

+ CodeRange Int32Range

+ MessageRegex Regex

+ NameRegex Regex

+ ReasonRegex Regex

+ SignalRange Int32Range

+ func (in *ContainerPattern) DeepCopy() *ContainerPattern

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

type Framework

+ func (f *Framework) IsAnyTaskRunning() bool

+ func (f *Framework) IsCompleting() bool

+ func (f *Framework) IsRunning() bool

+ type FrameworkAttemptCompletionStatus struct

+ Trigger *CompletionPolicyTriggerStatus

+ func (in *FrameworkAttemptCompletionStatus) DeepCopy() *FrameworkAttemptCompletionStatus

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

type FrameworkAttemptStatus

+ RunTime *meta.Time

type FrameworkState

+ const FrameworkAttemptPreparing

+ type Int32Range struct

+ Max *int32

+ Min *int32

+ func (in *Int32Range) DeepCopy() *Int32Range

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

+ func (ir Int32Range) Contains(i int32) bool

+ func (ir Int32Range) IsZero() bool

+ func (ir Int32Range) String() string

+ type LogFrameworkSnapshot struct

+ OnFrameworkDeletion *bool

+ OnFrameworkRetry *bool

+ OnTaskRetry *bool

+ func (in *LogFrameworkSnapshot) DeepCopy() *LogFrameworkSnapshot

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

+ type LogObjectSnapshot struct

+ Framework LogFrameworkSnapshot

+ Pod LogPodSnapshot

+ func (in *LogObjectSnapshot) DeepCopy() *LogObjectSnapshot

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

+ type LogPodSnapshot struct

+ OnPodDeletion *bool

+ func (in *LogPodSnapshot) DeepCopy() *LogPodSnapshot

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

+ type MatchedContainer struct

+ Code *int32

+ Message string

+ Name *string

+ Reason string

+ Signal int32

+ func (in *MatchedContainer) DeepCopy() *MatchedContainer

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

+ type MatchedPod struct

+ Containers []*MatchedContainer

+ Message string

+ Name *string

+ Reason string

+ func (in *MatchedPod) DeepCopy() *MatchedPod

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

+ type PodCompletionStatus struct

+ Containers []*ContainerCompletionStatus

+ Message string

+ Reason string

+ func ExtractPodCompletionStatus(pod *core.Pod) *PodCompletionStatus

+ func (in *PodCompletionStatus) DeepCopy() *PodCompletionStatus

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

+ type PodMatchResult struct

+ CodeInfo *CompletionCodeInfo

+ Diagnostics string

+ func MatchCompletionCodeInfos(pod *core.Pod) PodMatchResult

+ func (in *PodMatchResult) DeepCopy() *PodMatchResult

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

+ type PodPattern struct

+ Containers []*ContainerPattern

+ MessageRegex Regex

+ NameRegex Regex

+ ReasonRegex Regex

+ func (in *PodPattern) DeepCopy() *PodPattern

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

+ type Regex struct

+ func NewRegex(pattern string) Regex

+ func (in *Regex) DeepCopy() *Regex

+ func (re *Regex) DeepCopyInto(out *Regex)

+ func (re *Regex) UnmarshalYAML(unmarshal func(interface{}) error) error

+ func (re Regex) FindString(s string) *string

+ func (re Regex) IsZero() bool

+ func (re Regex) MarshalYAML() (interface{}, error)

+ type TaskAttemptCompletionStatus struct

+ Pod *PodCompletionStatus

+ func (in *TaskAttemptCompletionStatus) DeepCopy() *TaskAttemptCompletionStatus

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

type TaskAttemptStatus

+ RunTime *meta.Time

type TaskSpec

+ PodGracefulDeletionTimeoutSec *int64

type TaskStatus

+ func (ts *TaskStatus) IsCompleting() bool

+ func (ts *TaskStatus) IsRunning() bool

v0.3.0

Jan 17, 2019

Changes in this version

+ const AnnotationKeyFrameworkNamespace

+ const EnvNameFrameworkNamespace

v0.2.0

Nov 23, 2018

Changes in this version

+ const ComponentName

+ const ConfigFilePath

+ var DefaultKubeConfigFilePath = os.Getenv("HOME") + "/.kube/config"

+ var EnvValueKubeApiServerAddress = os.Getenv("KUBE_APISERVER_ADDRESS")

+ var EnvValueKubeConfigFilePath = os.Getenv("KUBECONFIG")

+ func BuildKubeConfig(cConfig *Config) *rest.Config

+ type Config struct

+ CRDEstablishedCheckIntervalSec *int64

+ CRDEstablishedCheckTimeoutSec *int64

+ FrameworkMaxRetryDelaySecForTransientConflictFailed *int64

+ FrameworkMinRetryDelaySecForTransientConflictFailed *int64

+ KubeApiServerAddress *string

+ KubeConfigFilePath *string

+ ObjectLocalCacheCreationTimeoutSec *int64

+ WorkerNumber *int32

+ func NewConfig() *Config

+ func (in *Config) DeepCopy() *Config

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

v0.1.0

Oct 23, 2018

Changes in this version

+ const AnnotationKeyConfigMapName

+ const AnnotationKeyConfigMapUID

+ const AnnotationKeyFrameworkAttemptID

+ const AnnotationKeyFrameworkAttemptInstanceUID

+ const AnnotationKeyFrameworkName

+ const AnnotationKeyPodName

+ const AnnotationKeyPodNamespace

+ const AnnotationKeyTaskAttemptID

+ const AnnotationKeyTaskIndex

+ const AnnotationKeyTaskRoleName

+ const ConfigMapKind

+ const ControllerConfigFile

+ const ControllerName

+ const EnvNameConfigMapName

+ const EnvNameConfigMapUID

+ const EnvNameFrameworkAttemptID

+ const EnvNameFrameworkAttemptInstanceUID

+ const EnvNameFrameworkName

+ const EnvNamePodName

+ const EnvNamePodNamespace

+ const EnvNamePodUID

+ const EnvNameTaskAttemptID

+ const EnvNameTaskAttemptInstanceUID

+ const EnvNameTaskIndex

+ const EnvNameTaskRoleName

+ const ExtendedUnlimitedValue

+ const FrameworkCRDName

+ const FrameworkKind

+ const FrameworkPlural

+ const GroupName

+ const LabelKeyFrameworkName

+ const LabelKeyTaskRoleName

+ const NamingConvention

+ const ObjectUIDFieldPath

+ const UnlimitedValue

+ const Version

+ var AddToScheme = SchemeBuilder.AddToScheme

+ var CompletionCodeInfoContainerFailedWithUnknownExitCode = CompletionCodeInfo

+ var CompletionCodeInfos = map[CompletionCode]CompletionCodeInfo

+ var ConfigMapGroupVersionKind = core.SchemeGroupVersion.WithKind(ConfigMapKind)

+ var FrameworkGroupVersionKind = SchemeGroupVersion.WithKind(FrameworkKind)

+ var ObjectUIDEnvVarSource = &core.EnvVarSource

+ var SchemeBuilder = runtime.NewSchemeBuilder(addKnownTypes)

+ var SchemeGroupVersion = schema.GroupVersion

+ func BuildFrameworkCRD() *apiExtensions.CustomResourceDefinition

+ func GetConfigMapName(frameworkName string) string

+ func GetFrameworkAttemptInstanceUID(frameworkAttemptID int32, configMapUID *types.UID) *types.UID

+ func GetPodName(frameworkName string, taskRoleName string, taskIndex int32) string

+ func GetTaskAttemptInstanceUID(taskAttemptID int32, podUID *types.UID) *types.UID

+ func Resource(resource string) schema.GroupResource

+ func SplitConfigMapName(configMapName string) (frameworkName string)

+ func SplitFrameworkAttemptInstanceUID(frameworkAttemptInstanceUID *types.UID) (frameworkAttemptID int32, configMapUID *types.UID)

+ func SplitPodName(podName string) (frameworkName string, taskRoleName string, taskIndex int32)

+ func SplitTaskAttemptInstanceUID(taskAttemptInstanceUID *types.UID) (taskAttemptID int32, podUID *types.UID)

+ type CompletionCode int32

+ const CompletionCodeConfigMapCreationTimeout

+ const CompletionCodeConfigMapExternalDeleted

+ const CompletionCodeContainerOOMKilled

+ const CompletionCodeContainerPermanentFailed

+ const CompletionCodeContainerSigIntReceived

+ const CompletionCodeContainerSigKillReceived

+ const CompletionCodeContainerSigTermReceived

+ const CompletionCodeContainerTransientConflictFailed

+ const CompletionCodeContainerTransientFailed

+ const CompletionCodePodCreationTimeout

+ const CompletionCodePodExternalDeleted

+ const CompletionCodePodFailedWithoutFailedContainer

+ const CompletionCodePodSpecInvalid

+ const CompletionCodeSucceeded

+ func (cc CompletionCode) NewCompletionStatus(diagnostics string) *CompletionStatus

+ type CompletionCodeInfo struct

+ Phrase CompletionPhrase

+ Type CompletionType

+ func (in *CompletionCodeInfo) DeepCopy() *CompletionCodeInfo

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

+ type CompletionPhrase string

+ type CompletionPolicySpec struct

+ MinFailedTaskCount int32

+ MinSucceededTaskCount int32

+ func (in *CompletionPolicySpec) DeepCopy() *CompletionPolicySpec

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

+ type CompletionStatus struct

+ Code CompletionCode

+ Diagnostics string

+ Phrase CompletionPhrase

+ Type CompletionType

+ func (cs *CompletionStatus) String() string

+ func (in *CompletionStatus) DeepCopy() *CompletionStatus

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

+ type CompletionType struct

+ Attributes []CompletionTypeAttribute

+ Name CompletionTypeName

+ func (ct CompletionType) ContainsAttribute(attribute CompletionTypeAttribute) bool

+ func (ct CompletionType) IsFailed() bool

+ func (ct CompletionType) IsSucceeded() bool

+ func (in *CompletionType) DeepCopy() *CompletionType

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

+ type CompletionTypeAttribute string

+ const CompletionTypeAttributeConflict

+ const CompletionTypeAttributeExternal

+ const CompletionTypeAttributeInternal

+ const CompletionTypeAttributePermanent

+ const CompletionTypeAttributeTransient

+ type CompletionTypeName string

+ const CompletionTypeNameFailed

+ const CompletionTypeNameSucceeded

+ type ContainerStateTerminatedReason string

+ const ReasonOOMKilled

+ type ControllerConfig struct

+ CRDEstablishedCheckIntervalSec *int64

+ CRDEstablishedCheckTimeoutSec *int64

+ FrameworkMaxRetryDelaySecForTransientConflictFailed *int64

+ FrameworkMinRetryDelaySecForTransientConflictFailed *int64

+ KubeApiServerAddress *string

+ KubeConfigFilePath *string

+ ObjectLocalCacheCreationTimeoutSec *int64

+ WorkerNumber *int32

+ func NewControllerConfig() *ControllerConfig

+ func (in *ControllerConfig) DeepCopy() *ControllerConfig

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

+ type ExecutionType string

+ const ExecutionStart

+ const ExecutionStop

+ type Framework struct

+ Spec FrameworkSpec

+ Status *FrameworkStatus

+ func (f *Framework) AreAllTasksCompleted() bool

+ func (f *Framework) CompletionType() CompletionType

+ func (f *Framework) ConfigMapName() string

+ func (f *Framework) ConfigMapUID() *types.UID

+ func (f *Framework) FrameworkAttemptID() int32

+ func (f *Framework) FrameworkAttemptInstanceUID() *types.UID

+ func (f *Framework) GetTaskCount(selector TaskStatusSelector) int32

+ func (f *Framework) IsCompleted() bool

+ func (f *Framework) IsFailed() bool

+ func (f *Framework) IsSucceeded() bool

+ func (f *Framework) Key() string

+ func (f *Framework) NewConfigMap() *core.ConfigMap

+ func (f *Framework) NewFrameworkAttemptStatus(frameworkAttemptID int32) FrameworkAttemptStatus

+ func (f *Framework) NewFrameworkStatus() *FrameworkStatus

+ func (f *Framework) NewPod(cm *core.ConfigMap, taskRoleName string, taskIndex int32) *core.Pod

+ func (f *Framework) NewTaskAttemptStatus(taskRoleName string, taskIndex int32, taskAttemptID int32) TaskAttemptStatus

+ func (f *Framework) NewTaskRoleStatuses() []TaskRoleStatus

+ func (f *Framework) NewTaskStatus(taskRoleName string, taskIndex int32) TaskStatus

+ func (f *Framework) TaskRoleSpec(taskRoleName string) *TaskRoleSpec

+ func (f *Framework) TaskRoleStatus(taskRoleName string) *TaskRoleStatus

+ func (f *Framework) TaskRoleStatuses() []TaskRoleStatus

+ func (f *Framework) TaskStatus(taskRoleName string, taskIndex int32) *TaskStatus

+ func (f *Framework) TransitionFrameworkState(dstState FrameworkState)

+ func (f *Framework) TransitionTaskState(taskRoleName string, taskIndex int32, dstState TaskState)

+ func (in *Framework) DeepCopy() *Framework

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

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

+ type FrameworkAttemptStatus struct

+ CompletionStatus *CompletionStatus

+ CompletionTime *meta.Time

+ ConfigMapName string

+ ConfigMapUID *types.UID

+ ID int32

+ InstanceUID *types.UID

+ StartTime meta.Time

+ TaskRoleStatuses []TaskRoleStatus

+ func (in *FrameworkAttemptStatus) DeepCopy() *FrameworkAttemptStatus

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

+ type FrameworkList struct

+ Items []Framework

+ func (in *FrameworkList) DeepCopy() *FrameworkList

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

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

+ type FrameworkSpec struct

+ Description string

+ ExecutionType ExecutionType

+ RetryPolicy RetryPolicySpec

+ TaskRoles []TaskRoleSpec

+ func (in *FrameworkSpec) DeepCopy() *FrameworkSpec

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

+ type FrameworkState string

+ const FrameworkAttemptCompleted

+ const FrameworkAttemptCreationPending

+ const FrameworkAttemptCreationRequested

+ const FrameworkAttemptDeleting

+ const FrameworkAttemptDeletionPending

+ const FrameworkAttemptDeletionRequested

+ const FrameworkAttemptRunning

+ const FrameworkCompleted

+ type FrameworkStatus struct

+ AttemptStatus FrameworkAttemptStatus

+ CompletionTime *meta.Time

+ RetryPolicyStatus RetryPolicyStatus

+ StartTime meta.Time

+ State FrameworkState

+ TransitionTime meta.Time

+ func (in *FrameworkStatus) DeepCopy() *FrameworkStatus

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

+ type RetryDecision struct

+ DelaySec int64

+ IsAccountable bool

+ Reason string

+ ShouldRetry bool

+ func (in *RetryDecision) DeepCopy() *RetryDecision

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

+ func (rd RetryDecision) String() string

+ type RetryPolicySpec struct

+ FancyRetryPolicy bool

+ MaxRetryCount int32

+ func (in *RetryPolicySpec) DeepCopy() *RetryPolicySpec

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

+ func (rp RetryPolicySpec) ShouldRetry(rps RetryPolicyStatus, ct CompletionType, ...) RetryDecision

+ type RetryPolicyStatus struct

+ AccountableRetriedCount int32

+ RetryDelaySec *int64

+ TotalRetriedCount int32

+ func (in *RetryPolicyStatus) DeepCopy() *RetryPolicyStatus

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

+ type TaskAttemptStatus struct

+ CompletionStatus *CompletionStatus

+ CompletionTime *meta.Time

+ ID int32

+ InstanceUID *types.UID

+ PodHostIP *string

+ PodIP *string

+ PodName string

+ PodUID *types.UID

+ StartTime meta.Time

+ func (in *TaskAttemptStatus) DeepCopy() *TaskAttemptStatus

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

+ type TaskRoleSpec struct

+ FrameworkAttemptCompletionPolicy CompletionPolicySpec

+ Name string

+ Task TaskSpec

+ TaskNumber int32

+ func (in *TaskRoleSpec) DeepCopy() *TaskRoleSpec

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

+ type TaskRoleStatus struct

+ Name string

+ TaskStatuses []TaskStatus

+ func (in *TaskRoleStatus) DeepCopy() *TaskRoleStatus

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

+ func (trs *TaskRoleStatus) GetTaskCount(selector TaskStatusSelector) int32

+ func (trs *TaskRoleStatus) GetTaskStatuses(selector TaskStatusSelector) []TaskStatus

+ type TaskSpec struct

+ Pod core.PodTemplateSpec

+ RetryPolicy RetryPolicySpec

+ func (in *TaskSpec) DeepCopy() *TaskSpec

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

+ type TaskState string

+ const TaskAttemptCompleted

+ const TaskAttemptCreationPending

+ const TaskAttemptCreationRequested

+ const TaskAttemptDeleting

+ const TaskAttemptDeletionPending

+ const TaskAttemptDeletionRequested

+ const TaskAttemptPreparing

+ const TaskAttemptRunning

+ const TaskCompleted

+ type TaskStatus struct

+ AttemptStatus TaskAttemptStatus

+ CompletionTime *meta.Time

+ Index int32

+ RetryPolicyStatus RetryPolicyStatus

+ StartTime meta.Time

+ State TaskState

+ TransitionTime meta.Time

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

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

+ func (ts *TaskStatus) CompletionType() CompletionType

+ func (ts *TaskStatus) IsCompleted() bool

+ func (ts *TaskStatus) IsFailed() bool

+ func (ts *TaskStatus) IsSucceeded() bool

+ func (ts *TaskStatus) PodName() string

+ func (ts *TaskStatus) PodUID() *types.UID

+ func (ts *TaskStatus) TaskAttemptID() int32

+ func (ts *TaskStatus) TaskAttemptInstanceUID() *types.UID

+ type TaskStatusSelector func(*TaskStatus) bool

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