controllers

Documentation

Index

• Constants
• func MutateSts(canal *v1.Canal, sts *appsv1.StatefulSet) error
• func MutateSvc(canal *v1.Canal, svc *corev1.Service) error
• func MutateSvcAdmin(canal *v1.Canal, svc *corev1.Service) error
• func NewEnv(a ...corev1.EnvVar) []corev1.EnvVar
• type CanalReconciler
  • func (r *CanalReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *CanalReconciler) SetupWithManager(mgr ctrl.Manager) error

Constants

const ApplicationYml = `` /* 484-byte string literal not displayed */

Functions

func MutateSts

func MutateSts(canal *v1.Canal, sts *appsv1.StatefulSet) error

func MutateSvc

func MutateSvc(canal *v1.Canal, svc *corev1.Service) error

func MutateSvcAdmin

func MutateSvcAdmin(canal *v1.Canal, svc *corev1.Service) error

func NewEnv

func NewEnv(a ...corev1.EnvVar) []corev1.EnvVar

Types

type CanalReconciler

type CanalReconciler struct {
	client.Client
	Scheme *runtime.Scheme
}

CanalReconciler reconciles a Canal object

func (*CanalReconciler) Reconcile

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

Reconcile is part of the main kubernetes reconciliation loop which aims to move the current state of the cluster closer to the desired state. TODO(user): Modify the Reconcile function to compare the state specified by the Canal object against the actual cluster state, and then perform operations to make the cluster state reflect the state specified by the user.

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

func (*CanalReconciler) SetupWithManager

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

SetupWithManager sets up the controller with the Manager.