controllers

Documentation

Index

• Variables
• func ConfigMap(ctx context.Context, c client.Client, s *runtime.Scheme, ...) (requeue time.Duration, err error)
• func Deployment(ctx context.Context, c client.Client, s *runtime.Scheme, ...) (requeue time.Duration, err error)
• func GecBotLabels(app *appv1alpha1.Cluster) map[string]string
• func GecBotSelectors(app *appv1alpha1.Cluster) map[string]string
• func GecMetaLabels(app *appv1alpha1.Cluster) map[string]string
• func GecMetaSelectors(app *appv1alpha1.Cluster) map[string]string
• func GecProcessorLabels(app *appv1alpha1.Cluster) map[string]string
• func GecProcessorSelectors(app *appv1alpha1.Cluster) map[string]string
• func GecSlackerLabels(app *appv1alpha1.Cluster) map[string]string
• func GecSlackerSelectors(app *appv1alpha1.Cluster) map[string]string
• func PVC(ctx context.Context, c client.Client, s *runtime.Scheme, ...) (requeue time.Duration, err error)
• func ServiceAccount(ctx context.Context, c client.Client, s *runtime.Scheme, ...) (requeue time.Duration, err error)
• type ClusterReconciler
  • func (r *ClusterReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *ClusterReconciler) SetupWithManager(mgr ctrl.Manager) error
  • func (r *ClusterReconciler) Upsert(ctx context.Context, upserters []upserter, ca appv1alpha1.ClusterApp, ...) (requeue time.Duration, err error)

Variables

var (
	Project string
)

Functions

func ConfigMap

func ConfigMap(ctx context.Context, c client.Client, s *runtime.Scheme, app *deploymentv1alpha1.Cluster, ca deploymentv1alpha1.ClusterApp, labels, selectors map[string]string) (requeue time.Duration, err error)

func Deployment

func Deployment(ctx context.Context, c client.Client, s *runtime.Scheme, app *deploymentv1alpha1.Cluster, ca deploymentv1alpha1.ClusterApp, labels, selectors map[string]string) (requeue time.Duration, err error)

func GecBotLabels

func GecBotLabels(app *appv1alpha1.Cluster) map[string]string

func GecBotSelectors

func GecBotSelectors(app *appv1alpha1.Cluster) map[string]string

func GecMetaLabels

func GecMetaLabels(app *appv1alpha1.Cluster) map[string]string

func GecMetaSelectors

func GecMetaSelectors(app *appv1alpha1.Cluster) map[string]string

func GecProcessorLabels

func GecProcessorLabels(app *appv1alpha1.Cluster) map[string]string

func GecProcessorSelectors

func GecProcessorSelectors(app *appv1alpha1.Cluster) map[string]string

func GecSlackerLabels

func GecSlackerLabels(app *appv1alpha1.Cluster) map[string]string

func GecSlackerSelectors

func GecSlackerSelectors(app *appv1alpha1.Cluster) map[string]string

func PVC

func PVC(ctx context.Context, c client.Client, s *runtime.Scheme, app *deploymentv1alpha1.Cluster, ca deploymentv1alpha1.ClusterApp, labels, selectors map[string]string) (requeue time.Duration, err error)

func ServiceAccount

func ServiceAccount(ctx context.Context, c client.Client, s *runtime.Scheme, app *deploymentv1alpha1.Cluster, ca deploymentv1alpha1.ClusterApp, labels, selectors map[string]string) (requeue time.Duration, err error)

Types

type ClusterReconciler

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

ClusterReconciler reconciles a Cluster object

func (*ClusterReconciler) Reconcile

func (r *ClusterReconciler) 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.

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

func (*ClusterReconciler) SetupWithManager

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

SetupWithManager sets up the controller with the Manager.

func (*ClusterReconciler) Upsert

func (r *ClusterReconciler) Upsert(ctx context.Context, upserters []upserter, ca appv1alpha1.ClusterApp, app *appv1alpha1.Cluster, labels, selectors, config map[string]string) (requeue time.Duration, err error)