runtime

Documentation

Index

• func StatusTraitor(obj metav1.Object) (apiv1.JobStatus, error)
• type EmptyScaleImpl
  • func (e EmptyScaleImpl) CheckpointIfNecessary(job interface{}, activePods []*corev1.Pod) (completed bool, err error)
  • func (e EmptyScaleImpl) EnableElasticScaling(job metav1.Object, runPolicy *v1.RunPolicy) bool
  • func (e EmptyScaleImpl) ScaleIn(job interface{}, replicas map[v1.ReplicaType]*v1.ReplicaSpec, ...) error
  • func (e EmptyScaleImpl) ScaleOut(job interface{}, replicas map[v1.ReplicaType]*v1.ReplicaSpec, ...) error
• type FailedPodContents
  • func (fc FailedPodContents) Add(pod *v1.Pod, exitCode int32)
  • func (fc FailedPodContents) String() string
• type RawExtensionCodec
  • func NewRawExtensionCodec(scheme *runtime.Scheme) *RawExtensionCodec
  • func (rc *RawExtensionCodec) DecodeRaw(rawObj runtime.RawExtension, into runtime.Object) error
  • func (rc *RawExtensionCodec) EncodeRaw(obj runtime.Object) (*runtime.RawExtension, error)

Functions

func StatusTraitor

func StatusTraitor(obj metav1.Object) (apiv1.JobStatus, error)

StatusTraitor traits workload status field from object scheme.

Types

type EmptyScaleImpl

type EmptyScaleImpl struct{}

EmptyScaleImpl implements ElasticScaling interface but actually does no-ops.

func (EmptyScaleImpl) CheckpointIfNecessary

func (e EmptyScaleImpl) CheckpointIfNecessary(job interface{}, activePods []*corev1.Pod) (completed bool, err error)

func (EmptyScaleImpl) EnableElasticScaling

func (e EmptyScaleImpl) EnableElasticScaling(job metav1.Object, runPolicy *v1.RunPolicy) bool

func (EmptyScaleImpl) ScaleIn

func (e EmptyScaleImpl) ScaleIn(job interface{}, replicas map[v1.ReplicaType]*v1.ReplicaSpec, activePods []*corev1.Pod, activeServices []*corev1.Service) error

func (EmptyScaleImpl) ScaleOut

func (e EmptyScaleImpl) ScaleOut(job interface{}, replicas map[v1.ReplicaType]*v1.ReplicaSpec, activePods []*corev1.Pod, activeServices []*corev1.Service) error

type FailedPodContents

type FailedPodContents map[string][]string

FailedPodContents collects failed reasons while with its exit codes of failed pods. key is {reason}-{exit code}, value is a slice of related pods.

func (FailedPodContents) Add

func (fc FailedPodContents) Add(pod *v1.Pod, exitCode int32)

func (FailedPodContents) String

func (fc FailedPodContents) String() string

type RawExtensionCodec

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

func NewRawExtensionCodec

func NewRawExtensionCodec(scheme *runtime.Scheme) *RawExtensionCodec

func (*RawExtensionCodec) DecodeRaw

func (rc *RawExtensionCodec) DecodeRaw(rawObj runtime.RawExtension, into runtime.Object) error

func (*RawExtensionCodec) EncodeRaw

func (rc *RawExtensionCodec) EncodeRaw(obj runtime.Object) (*runtime.RawExtension, error)