cluster

Documentation

Index

• func ClusterAnnotations(ins ksqldbv1alpha1.KsqldbCluster) map[string]string
• func ClusterLabels(ins ksqldbv1alpha1.KsqldbCluster) map[string]string
• func Container(ins ksqldbv1alpha1.KsqldbCluster) corev1.Container
• func ContainerPort() corev1.ContainerPort
• func Env(ins ksqldbv1alpha1.KsqldbCluster) []corev1.EnvVar
• func NewClusterReconciler(config ClusterReconcilerConfig) clusterReconciler
• type ClusterReconcilerConfig
  • func (c ClusterReconcilerConfig) Validate() error

Functions

func ClusterAnnotations

func ClusterAnnotations(ins ksqldbv1alpha1.KsqldbCluster) map[string]string

func ClusterLabels

func ClusterLabels(ins ksqldbv1alpha1.KsqldbCluster) map[string]string

According to recommended labels: https://kubernetes.io/docs/concepts/overview/working-with-objects/common-labels/

func Container

func Container(ins ksqldbv1alpha1.KsqldbCluster) corev1.Container

func ContainerPort

func ContainerPort() corev1.ContainerPort

func Env

func Env(ins ksqldbv1alpha1.KsqldbCluster) []corev1.EnvVar

func NewClusterReconciler

func NewClusterReconciler(config ClusterReconcilerConfig) clusterReconciler

Types

type ClusterReconcilerConfig

type ClusterReconcilerConfig struct {
	config.BaseParam
	Instance ksqldbv1alpha1.KsqldbCluster
}

func (ClusterReconcilerConfig) Validate

func (c ClusterReconcilerConfig) Validate() error