controllers

Documentation

Index

• Variables
• func GetClowdAppCondition(status *crd.ClowdAppStatus, conditionType crd.ClowdConditionType) (int, *crd.ClowdCondition)
• func GetClowdAppConditionFromList(conditions []crd.ClowdCondition, conditionType crd.ClowdConditionType) (int, *crd.ClowdCondition)
• func GetClowdEnvCondition(status *crd.ClowdEnvironmentStatus, conditionType crd.ClowdConditionType) (int, *crd.ClowdCondition)
• func GetClowdEnvConditionFromList(conditions []crd.ClowdCondition, conditionType crd.ClowdConditionType) (int, *crd.ClowdCondition)
• func GetDeploymentStatus(ctx context.Context, client client.Client, o object.ClowdObject) (bool, error)
• func ReadEnv() string
• func ReleaseEnv()
• func Run(metricsAddr string, probeAddr string, enableLeaderElection bool, ...)
• 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 SetDeploymentStatus(ctx context.Context, client client.Client, o object.ClowdObject) error
• func SetEnv(name string)
• func UpdateClowdAppCondition(status *crd.ClowdAppStatus, condition *crd.ClowdCondition) bool
• func UpdateClowdEnvCondition(status *crd.ClowdEnvironmentStatus, condition *crd.ClowdCondition) bool
• 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(cache *providers.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 DeploymentStats
  • func GetDeploymentFigures(ctx context.Context, client client.Client, o object.ClowdObject) (DeploymentStats, error)

Variables

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

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

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

Functions

func GetClowdAppCondition

func GetClowdAppCondition(status *crd.ClowdAppStatus, conditionType crd.ClowdConditionType) (int, *crd.ClowdCondition)

The following function was modified from the kubnernetes repo under the apache license here https://github.com/kubernetes/kubernetes/blob/v1.21.1/pkg/api/v1/pod/util.go#L317-L367

func GetClowdAppConditionFromList

func GetClowdAppConditionFromList(conditions []crd.ClowdCondition, conditionType crd.ClowdConditionType) (int, *crd.ClowdCondition)

The following function was modified from the kubnernetes repo under the apache license here https://github.com/kubernetes/kubernetes/blob/v1.21.1/pkg/api/v1/pod/util.go#L317-L367

func GetClowdEnvCondition

func GetClowdEnvCondition(status *crd.ClowdEnvironmentStatus, conditionType crd.ClowdConditionType) (int, *crd.ClowdCondition)

The following function was modified from the kubnernetes repo under the apache license here https://github.com/kubernetes/kubernetes/blob/v1.21.1/pkg/api/v1/pod/util.go#L317-L367

func GetClowdEnvConditionFromList

func GetClowdEnvConditionFromList(conditions []crd.ClowdCondition, conditionType crd.ClowdConditionType) (int, *crd.ClowdCondition)

The following function was modified from the kubnernetes repo under the apache license here https://github.com/kubernetes/kubernetes/blob/v1.21.1/pkg/api/v1/pod/util.go#L317-L367

func GetDeploymentStatus

func GetDeploymentStatus(ctx context.Context, client client.Client, o object.ClowdObject) (bool, error)

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 SetClowdAppConditions

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

func SetClowdEnvConditions

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

func SetDeploymentStatus

func SetDeploymentStatus(ctx context.Context, client client.Client, o object.ClowdObject) error

SetDeploymentStatus the status on the passed ClowdObject interface.

func SetEnv

func SetEnv(name string)

func UpdateClowdAppCondition

func UpdateClowdAppCondition(status *crd.ClowdAppStatus, condition *crd.ClowdCondition) bool

The following function was modified from the kubnernetes repo under the apache license here https://github.com/kubernetes/kubernetes/blob/v1.21.1/pkg/api/v1/pod/util.go#L317-L367

func UpdateClowdEnvCondition

func UpdateClowdEnvCondition(status *crd.ClowdEnvironmentStatus, condition *crd.ClowdCondition) bool

The following function was modified from the kubnernetes repo under the apache license here https://github.com/kubernetes/kubernetes/blob/v1.21.1/pkg/api/v1/pod/util.go#L317-L367

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(cache *providers.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 DeploymentStats

type DeploymentStats struct {
	ManagedDeployments int32
	ReadyDeployments   int32
}

func GetDeploymentFigures

func GetDeploymentFigures(ctx context.Context, client client.Client, o object.ClowdObject) (DeploymentStats, error)