controllers

Documentation

Index

• Variables
• func GetAppResourceFigures(ctx context.Context, client client.Client, o *crd.ClowdApp) (crd.AppResourceStatus, string, error)
• func GetAppResourceStatus(ctx context.Context, client client.Client, o *crd.ClowdApp) (bool, error)
• func GetEnvResourceFigures(ctx context.Context, client client.Client, o *crd.ClowdEnvironment) (crd.EnvResourceStatus, string, error)
• func GetEnvResourceStatus(ctx context.Context, client client.Client, o *crd.ClowdEnvironment) (bool, string, error)
• func GetJobsStatus(jobs *batchv1.JobList, cji *crd.ClowdJobInvocation) bool
• func ReadEnv() string
• func ReleaseEnv()
• func Run(metricsAddr string, probeAddr string, enableLeaderElection bool, ...)
• func SetAppResourceStatus(ctx context.Context, client client.Client, o *crd.ClowdApp) error
• func SetClowdAppConditions(ctx context.Context, client client.Client, o *crd.ClowdApp, ...) error
• func SetClowdEnvConditions(ctx context.Context, client client.Client, o *crd.ClowdEnvironment, ...) error
• func SetClowdJobInvocationConditions(ctx context.Context, client client.Client, o *crd.ClowdJobInvocation, ...) error
• func SetEnv(name string)
• func SetEnvResourceStatus(ctx context.Context, client client.Client, o *crd.ClowdEnvironment) error
• func UpdateInvokedJobStatus(ctx context.Context, jobs *batchv1.JobList, cji *crd.ClowdJobInvocation) error
• type ClowdAppReconciler
  • func (r *ClowdAppReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *ClowdAppReconciler) SetupWithManager(mgr ctrl.Manager) error
• type ClowdEnvironmentReconciler
  • func (r *ClowdEnvironmentReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *ClowdEnvironmentReconciler) SetupWithManager(mgr ctrl.Manager) error
• type ClowdJobInvocationReconciler
  • func (r *ClowdJobInvocationReconciler) InvokeJob(ctx context.Context, cache *rc.ObjectCache, job *crd.Job, app *crd.ClowdApp, ...) error
  • func (r *ClowdJobInvocationReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *ClowdJobInvocationReconciler) SetupWithManager(mgr ctrl.Manager) error
• type ReconciliationMetrics

Variables

var (
	Scheme        = runtime.NewScheme()
	CacheConfig   *rc.CacheConfig
	DebugOptions  rc.DebugOptions
	ProtectedGVKs = make(map[schema.GroupVersionKind]bool)
)

var ClowdJob = rc.NewMultiResourceIdent("cji", "clowdjob", &batchv1.Job{})

var IqeClowdJob = rc.NewSingleResourceIdent("cji", "iqe_clowdjob", &batchv1.Job{})

var IqeSecret = rc.NewSingleResourceIdent("cji", "iqe_secret", &core.Secret{})

var Version string

Functions

func GetAppResourceFigures

func GetAppResourceFigures(ctx context.Context, client client.Client, o *crd.ClowdApp) (crd.AppResourceStatus, string, error)

func GetAppResourceStatus

func GetAppResourceStatus(ctx context.Context, client client.Client, o *crd.ClowdApp) (bool, error)

func GetEnvResourceFigures

func GetEnvResourceFigures(ctx context.Context, client client.Client, o *crd.ClowdEnvironment) (crd.EnvResourceStatus, string, error)

func GetEnvResourceStatus

func GetEnvResourceStatus(ctx context.Context, client client.Client, o *crd.ClowdEnvironment) (bool, string, error)

func GetJobsStatus

func GetJobsStatus(jobs *batchv1.JobList, cji *crd.ClowdJobInvocation) bool

func ReadEnv

func ReadEnv() string

func ReleaseEnv

func ReleaseEnv()

func Run

func Run(metricsAddr string, probeAddr string, enableLeaderElection bool, config *rest.Config, signalHandler context.Context, enableWebHooks bool)

Run inits the manager and controllers and then starts the manager

func SetAppResourceStatus

func SetAppResourceStatus(ctx context.Context, client client.Client, o *crd.ClowdApp) error

SetAppResourceStatus the status on the passed ClowdObject interface.

func SetClowdAppConditions

func SetClowdAppConditions(ctx context.Context, client client.Client, o *crd.ClowdApp, state clusterv1.ConditionType, err error) error

func SetClowdEnvConditions

func SetClowdEnvConditions(ctx context.Context, client client.Client, o *crd.ClowdEnvironment, state clusterv1.ConditionType, err error) error

func SetClowdJobInvocationConditions

func SetClowdJobInvocationConditions(ctx context.Context, client client.Client, o *crd.ClowdJobInvocation, state clusterv1.ConditionType, err error) error

func SetEnv

func SetEnv(name string)

func SetEnvResourceStatus

func SetEnvResourceStatus(ctx context.Context, client client.Client, o *crd.ClowdEnvironment) error

SetEnvResourceStatus the status on the passed ClowdObject interface.

func UpdateInvokedJobStatus

func UpdateInvokedJobStatus(ctx context.Context, jobs *batchv1.JobList, cji *crd.ClowdJobInvocation) error

Types

type ClowdAppReconciler

type ClowdAppReconciler struct {
	client.Client
	Log      logr.Logger
	Scheme   *runtime.Scheme
	Recorder record.EventRecorder
}

ClowdAppReconciler reconciles a ClowdApp object

func (*ClowdAppReconciler) Reconcile

func (r *ClowdAppReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

Reconcile fn

func (*ClowdAppReconciler) SetupWithManager

func (r *ClowdAppReconciler) SetupWithManager(mgr ctrl.Manager) error

SetupWithManager sets up with Manager

type ClowdEnvironmentReconciler

type ClowdEnvironmentReconciler struct {
	client.Client
	Log      logr.Logger
	Scheme   *runtime.Scheme
	Recorder record.EventRecorder
}

ClowdEnvironmentReconciler reconciles a ClowdEnvironment object

func (*ClowdEnvironmentReconciler) Reconcile

func (r *ClowdEnvironmentReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

Reconcile fn

func (*ClowdEnvironmentReconciler) SetupWithManager

func (r *ClowdEnvironmentReconciler) SetupWithManager(mgr ctrl.Manager) error

SetupWithManager sets up with manager

type ClowdJobInvocationReconciler

type ClowdJobInvocationReconciler struct {
	client.Client
	Log      logr.Logger
	Scheme   *runtime.Scheme
	Recorder record.EventRecorder
}

ClowdJobInvocationReconciler reconciles a ClowdJobInvocation object

func (*ClowdJobInvocationReconciler) InvokeJob

func (r *ClowdJobInvocationReconciler) InvokeJob(ctx context.Context, cache *rc.ObjectCache, job *crd.Job, app *crd.ClowdApp, env *crd.ClowdEnvironment, cji *crd.ClowdJobInvocation) error

InvokeJob is responsible for applying the Job. It also updates and reports the status of that job

func (*ClowdJobInvocationReconciler) Reconcile

func (r *ClowdJobInvocationReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

Reconcile CJI Resources

func (*ClowdJobInvocationReconciler) SetupWithManager

func (r *ClowdJobInvocationReconciler) SetupWithManager(mgr ctrl.Manager) error

SetupWithManager registers the CJI with the main manager process

type ReconciliationMetrics

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