jobs

Documentation

Index

• Constants
• type ImageBuilderJobManager
  • func (m *ImageBuilderJobManager) Create(ctx context.Context, owner *kubernetesupgraderv1.MachineImage, ...) (*corev1.ObjectReference, error)
  • func (m *ImageBuilderJobManager) Delete(ctx context.Context, ref *corev1.ObjectReference) error
  • func (m *ImageBuilderJobManager) Latest(ctx context.Context, owner *kubernetesupgraderv1.MachineImage) (*corev1.ObjectReference, error)
  • func (m *ImageBuilderJobManager) Status(ctx context.Context, ref *corev1.ObjectReference) (*batchv1.JobStatus, string, error)
• type Manager
  • func NewManager(k8sClient client.Client, scheme *runtime.Scheme) Manager

Constants

const (
	MachineImageNameLabel = "kubernetesupgraded.dimitrikoshkin.com/machine-image-name"

	IDAnnotation = "kubernetesupgraded.dimitrikoshkin.com/image-id"
)

Types

type ImageBuilderJobManager

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

func (*ImageBuilderJobManager) Create

func (m *ImageBuilderJobManager) Create(
	ctx context.Context,
	owner *kubernetesupgraderv1.MachineImage,
	spec *corev1.PodSpec,
) (*corev1.ObjectReference, error)

func (*ImageBuilderJobManager) Delete

func (m *ImageBuilderJobManager) Delete(
	ctx context.Context,
	ref *corev1.ObjectReference,
) error

func (*ImageBuilderJobManager) Latest

func (m *ImageBuilderJobManager) Latest(
	ctx context.Context,
	owner *kubernetesupgraderv1.MachineImage,
) (*corev1.ObjectReference, error)

Latest will return the latest job (using createdAt timestamp) for the given owner. Returns nil if no jobs exist.

func (*ImageBuilderJobManager) Status

func (m *ImageBuilderJobManager) Status(
	ctx context.Context,
	ref *corev1.ObjectReference,
) (*batchv1.JobStatus, string, error)

Status will return the status of the job and the image ID if it was built successfully.

type Manager

type Manager interface {
	Create(
		ctx context.Context,
		owner *kubernetesupgraderv1.MachineImage,
		spec *corev1.PodSpec,
	) (*corev1.ObjectReference, error)
	Latest(
		ctx context.Context,
		owner *kubernetesupgraderv1.MachineImage,
	) (*corev1.ObjectReference, error)
	Status(ctx context.Context, ref *corev1.ObjectReference) (*batchv1.JobStatus, string, error)
	Delete(ctx context.Context, ref *corev1.ObjectReference) error
}

func NewManager

func NewManager(k8sClient client.Client, scheme *runtime.Scheme) Manager