controllers

Documentation

Index

• Variables
• func RunTestEnvironment(testEnv *envtest.Environment) (k8sManager ctrl.Manager, k8sClient client.Client)
• type KibanaDashboardPrerequisite
• type OpniClusterReconciler
  • func (r *OpniClusterReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *OpniClusterReconciler) SetupWithManager(mgr ctrl.Manager) error
• type OpniDemoReconciler
  • func (r *OpniDemoReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *OpniDemoReconciler) SetupWithManager(mgr ctrl.Manager) error

Variables

var (
	DrainServiceTemplate = &appsv1.Deployment{
		ObjectMeta: metav1.ObjectMeta{
			Name: "drain-service",
		},
		Spec: appsv1.DeploymentSpec{
			Selector: &metav1.LabelSelector{
				MatchLabels: appLabels,
			},
			Template: v1.PodTemplateSpec{
				ObjectMeta: metav1.ObjectMeta{
					Labels: appLabels,
				},
				Spec: v1.PodSpec{
					Containers: []v1.Container{
						{
							Name: "drain-service",
							Env: []v1.EnvVar{
								{
									Name: "NATS_SERVER_URL",
									ValueFrom: &v1.EnvVarSource{
										SecretKeyRef: &v1.SecretKeySelector{
											LocalObjectReference: drainServiceSecret,
											Key:                  "nats-server-url",
										},
									},
								},
								{
									Name: "S3_ACCESS_KEY",
									ValueFrom: &v1.EnvVarSource{
										SecretKeyRef: &v1.SecretKeySelector{
											LocalObjectReference: s3Secret,
											Key:                  "access-key",
										},
									},
								},
								{
									Name: "S3_SECRET_KEY",
									ValueFrom: &v1.EnvVarSource{
										SecretKeyRef: &v1.SecretKeySelector{
											LocalObjectReference: s3Secret,
											Key:                  "secret-key",
										},
									},
								},
								{
									Name: "ES_USERNAME",
									ValueFrom: &v1.EnvVarSource{
										SecretKeyRef: &v1.SecretKeySelector{
											LocalObjectReference: esSecret,
											Key:                  "username",
										},
									},
								},
								{
									Name: "ES_PASSWORD",
									ValueFrom: &v1.EnvVarSource{
										SecretKeyRef: &v1.SecretKeySelector{
											LocalObjectReference: esSecret,
											Key:                  "password",
										},
									},
								},
								{
									Name:  "FAIL_KEYWORDS",
									Value: "fail,error,missing,unable",
								},
							},
						},
					},
				},
			},
		},
	}
)

Functions

func RunTestEnvironment

func RunTestEnvironment(
	testEnv *envtest.Environment,
) (k8sManager ctrl.Manager, k8sClient client.Client)

Types

type KibanaDashboardPrerequisite

type KibanaDashboardPrerequisite struct {
	Name   string
	Object client.Object
}

KibanaDashboardPrerequisite describes a prerequisite object for the kibana dashboard pod

type OpniClusterReconciler

type OpniClusterReconciler struct {
	client.Client
	Log    logr.Logger
	Scheme *runtime.Scheme
}

OpniClusterReconciler reconciles a OpniCluster object

func (*OpniClusterReconciler) Reconcile

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

func (*OpniClusterReconciler) SetupWithManager

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

SetupWithManager sets up the controller with the Manager.

type OpniDemoReconciler

type OpniDemoReconciler struct {
	client.Client
	Log    logr.Logger
	Scheme *runtime.Scheme
}

OpniDemoReconciler reconciles a OpniDemo object

func (*OpniDemoReconciler) Reconcile

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

For more details, check Reconcile and its Result here: - https://pkg.go.dev/sigs.k8s.io/controller-runtime@v0.7.0/pkg/reconcile

func (*OpniDemoReconciler) SetupWithManager

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

SetupWithManager sets up the controller with the Manager.