Versions in this module Expand all Collapse all v1 v1.0.1 Aug 5, 2020 Changes in this version + const ControlJobID + const ControlMaxRetries + const ControlRetries + const ControlSavepointTriggerID + const DefaultLog4jConfig + const DefaultLogbackConfig + const RevisionNameLabel + const SavepointAgeForJobUpdateSec + const SavepointRequestRetryIntervalSec + const SavepointTimeoutSec + func ToOwnerReference(flinkCluster *v1beta1.FlinkCluster) metav1.OwnerReference + type ClusterReconciler struct + type ClusterStateObserver struct + type ClusterStatusUpdater struct + type FlinkClusterHandler struct + type FlinkClusterReconciler struct + Client client.Client + Log logr.Logger + Mgr ctrl.Manager + func (reconciler *FlinkClusterReconciler) Reconcile(request ctrl.Request) (ctrl.Result, error) + func (reconciler *FlinkClusterReconciler) SetupWithManager(mgr ctrl.Manager) error + type ObservedClusterState struct + type RevisionStatus struct + type TimeConverter struct + func (tc *TimeConverter) FromString(timeStr string) time.Time + func (tc *TimeConverter) ToString(timestamp time.Time) string + type UpdateState string + const UpdateStateFinished + const UpdateStateStoppingJob + const UpdateStateUpdating
Go to main page