Documentation ¶
Index ¶
Constants ¶
const ExportLagCustomMetrics = "EXPORT_LAG_CUSTOM_METRICS"
Variables ¶
This section is empty.
Functions ¶
func Add ¶
Add creates a new KafkaConnect Controller and adds it to the Manager. The Manager will set fields on the Controller and Start it when the Manager is Started.
func GeneratePodLabels ¶
func GeneratePodLabels(instance kafkaconnectv1alpha1.KafkaConnect) map[string]string
GeneratePodLabels create label to select pod
func GetSvcName ¶
GetSvcName generate the service name from the KafkaConnect
Types ¶
type ReconcileKafkaConnect ¶
type ReconcileKafkaConnect struct {
// contains filtered or unexported fields
}
ReconcileKafkaConnect reconciles a KafkaConnect object
func (*ReconcileKafkaConnect) Reconcile ¶
Reconcile reads that state of the cluster for a KafkaConnect object and makes changes based on the state read and what is in the KafkaConnect.Spec a Pod as an example Note: The Controller will requeue the Request to be processed again if the returned error is non-nil or Result.Requeue is true, otherwise upon completion it will remove the work from the queue.
type Utils ¶
type Utils struct { // This client, initialized using mgr.Client() above, is a split client // that reads objects from the cache and writes to the apiserver ReconcileKafkaConnect // contains filtered or unexported fields }
Utils reconciles a KafkaConnect object
func (*Utils) CheckGlobalStatus ¶
func (utils *Utils) CheckGlobalStatus(instance *kafkaconnectv1alpha1.KafkaConnect) error
CheckGlobalStatus check all the status add see which object need to be updated
func (*Utils) ScaleDeployment ¶
func (utils *Utils) ScaleDeployment(instance *kafkaconnectv1alpha1.KafkaConnect, dep *appsv1.Deployment) error
ScaleDeployment will scale dep according to instance.Status.PodNb