controllers

Documentation

Index

• Constants
• Variables
• func CreateFateCluster(fateclusterCR *appv1beta1.FateCluster) (*fatecluster.FateCluster, error)
• func CreateFateJob(fateJobCR *appv1beta1.FateJob) *batchv1.Job
• func IsExitEnv(env []corev1.EnvVar, s string) bool
• func IsRunning(job *batchv1.Job) bool
• func NewFateJob() *batchv1.Job
• func RandomString(length int) string
• type FateClusterReconciler
  • func (r *FateClusterReconciler) Apply(fateclusterCR *appv1beta1.FateCluster, kubefateCR *appv1beta1.Kubefate) (bool, error)
  • func (r *FateClusterReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *FateClusterReconciler) SetupWithManager(mgr ctrl.Manager) error
• type FateJobReconciler
  • func (r *FateJobReconciler) Apply(fateJobCR *appv1beta1.FateJob) (bool, error)
  • func (r *FateJobReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *FateJobReconciler) SetupWithManager(mgr ctrl.Manager) error
• type Kubefate
  • func NewKubefate(kubefate *appv1beta1.Kubefate) *Kubefate
• type KubefateReconciler
  • func (r *KubefateReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *KubefateReconciler) SetupWithManager(mgr ctrl.Manager) error

Constants

const (
	NamespaceDefault = "kube-fate"
	PREFIX           = "kubefate"
)

Variables

var FateOperatorTest bool

Functions

func CreateFateCluster

func CreateFateCluster(fateclusterCR *appv1beta1.FateCluster) (*fatecluster.FateCluster, error)

func CreateFateJob

func CreateFateJob(fateJobCR *appv1beta1.FateJob) *batchv1.Job

func IsExitEnv

func IsExitEnv(env []corev1.EnvVar, s string) bool

func IsRunning

func IsRunning(job *batchv1.Job) bool

func NewFateJob

func NewFateJob() *batchv1.Job

func RandomString

func RandomString(length int) string

RandomString generates a random string from a subset of characters

Types

type FateClusterReconciler

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

FateClusterReconciler reconciles a FateCluster object

func (*FateClusterReconciler) Apply

func (r *FateClusterReconciler) Apply(fateclusterCR *appv1beta1.FateCluster, kubefateCR *appv1beta1.Kubefate) (bool, error)

func (*FateClusterReconciler) Reconcile

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

func (*FateClusterReconciler) SetupWithManager

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

type FateJobReconciler

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

FateJobReconciler reconciles a FateJob object

func (*FateJobReconciler) Apply

func (r *FateJobReconciler) Apply(fateJobCR *appv1beta1.FateJob) (bool, error)

func (*FateJobReconciler) Reconcile

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

func (*FateJobReconciler) SetupWithManager

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

type Kubefate

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

func NewKubefate

func NewKubefate(kubefate *appv1beta1.Kubefate) *Kubefate

type KubefateReconciler

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

KubefateReconciler reconciles a Kubefate object

func (*KubefateReconciler) Reconcile

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

func (*KubefateReconciler) SetupWithManager

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