extendedjob

Documentation

Index

• Constants
• func AddErrand(ctx context.Context, config *config.Config, mgr manager.Manager) error
• func AddJob(ctx context.Context, config *config.Config, mgr manager.Manager) error
• func NewErrandReconciler(ctx context.Context, config *config.Config, mgr manager.Manager, ...) reconcile.Reconciler
• func NewJobReconciler(ctx context.Context, config *config.Config, mgr manager.Manager, ...) (reconcile.Reconciler, error)
• type ErrandReconciler
  • func (r *ErrandReconciler) Reconcile(request reconcile.Request) (reconcile.Result, error)
• type JobCreator
  • func NewJobCreator(client crc.Client, scheme *runtime.Scheme, f setOwnerReferenceFunc, ...) JobCreator
• type PodLogGetter
  • func NewPodLogGetter(client corev1client.CoreV1Interface) PodLogGetter
• type PodLogGetterImpl
  • func (p *PodLogGetterImpl) Get(namespace, podName, containerName string) ([]byte, error)
• type ReconcileJob
  • func (r *ReconcileJob) Reconcile(request reconcile.Request) (reconcile.Result, error)

Constants

const (
	// EnvKubeAz is set by available zone name
	EnvKubeAz = "KUBE_AZ"
	// EnvBoshAz is set by available zone name
	EnvBoshAz = "BOSH_AZ"
	// EnvReplicas describes the number of replicas in the ExtendedStatefulSet
	EnvReplicas = "REPLICAS"
	// EnvCfOperatorAz is set by available zone name
	EnvCfOperatorAz = "CF_OPERATOR_AZ"
	// EnvCfOperatorAzIndex is set by available zone index
	EnvCfOperatorAzIndex = "AZ_INDEX"
	// EnvPodOrdinal is the pod's index
	EnvPodOrdinal = "POD_ORDINAL"
)

Functions

func AddErrand

func AddErrand(ctx context.Context, config *config.Config, mgr manager.Manager) error

AddErrand creates a new ExtendedJob controller to start errands, when their trigger strategy matches 'now' or 'once', or their configuration changed.

func AddJob

func AddJob(ctx context.Context, config *config.Config, mgr manager.Manager) error

AddJob creates a new Job controller to collect the output from jobs, persist that output as a secret and delete the k8s job afterwards.

func NewErrandReconciler

func NewErrandReconciler(
	ctx context.Context,
	config *config.Config,
	mgr manager.Manager,
	f setOwnerReferenceFunc,
	store vss.VersionedSecretStore,
) reconcile.Reconciler

NewErrandReconciler returns a new reconciler for errand jobs.

func NewJobReconciler

func NewJobReconciler(ctx context.Context, config *config.Config, mgr manager.Manager, podLogGetter PodLogGetter) (reconcile.Reconciler, error)

NewJobReconciler returns a new Reconciler

Types

type ErrandReconciler

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

ErrandReconciler implements the Reconciler interface.

func (*ErrandReconciler) Reconcile

func (r *ErrandReconciler) Reconcile(request reconcile.Request) (reconcile.Result, error)

Reconcile starts jobs for extended jobs of the type errand with Run being set to 'now' manually.

type JobCreator

type JobCreator interface {
	Create(ctx context.Context, eJob ejv1.ExtendedJob) (retry bool, err error)
}

JobCreator is the interface that wraps the basic Create method.

func NewJobCreator

func NewJobCreator(client crc.Client, scheme *runtime.Scheme, f setOwnerReferenceFunc, store vss.VersionedSecretStore) JobCreator

NewJobCreator returns a new job creator

type PodLogGetter

type PodLogGetter interface {
	Get(namespace, podName, containerName string) ([]byte, error)
}

PodLogGetter fetches the logs from a Pod

func NewPodLogGetter

func NewPodLogGetter(client corev1client.CoreV1Interface) PodLogGetter

NewPodLogGetter returns an instance of a PodLogGetterImpl

type PodLogGetterImpl

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

PodLogGetterImpl implements the PodLogGetter interface

func (*PodLogGetterImpl) Get

func (p *PodLogGetterImpl) Get(namespace, podName, containerName string) ([]byte, error)

Get fetches the logs for the given pod

type ReconcileJob

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

ReconcileJob reconciles an Job object

func (*ReconcileJob) Reconcile

func (r *ReconcileJob) Reconcile(request reconcile.Request) (reconcile.Result, error)

Reconcile reads that state of the cluster for a Job object that is owned by an ExtendedJob and makes changes based on the state read and what is in the ExtendedJob.Spec Note: The Controller will requeue the Request to be processed again if the returned error is non-nil or Result.Requeue is true, otherwise upon completion it will remove the work from the queue.