flink-on-k8s-operator: github.com/GoogleCloudPlatform/flink-on-k8s-operator/controllers Index | Files | Directories

package controllers

import "github.com/GoogleCloudPlatform/flink-on-k8s-operator/controllers"


Package Files

flinkcluster_controller.go flinkcluster_converter.go flinkcluster_observer.go flinkcluster_reconciler.go flinkcluster_submit_job_script.go flinkcluster_updater.go flinkcluster_util.go


const (
    ControlSavepointTriggerID = "SavepointTriggerID"
    ControlJobID              = "jobID"
    ControlRetries            = "retries"
    ControlMaxRetries         = "3"

    SavepointTimeoutSec = 60

type ClusterReconciler Uses

type ClusterReconciler struct {
    // contains filtered or unexported fields

ClusterReconciler takes actions to drive the observed state towards the desired state.

type ClusterStateObserver Uses

type ClusterStateObserver struct {
    // contains filtered or unexported fields

ClusterStateObserver gets the observed state of the cluster.

type ClusterStatusUpdater Uses

type ClusterStatusUpdater struct {
    // contains filtered or unexported fields

ClusterStatusUpdater updates the status of the FlinkCluster CR.

type DesiredClusterState Uses

type DesiredClusterState struct {
    JmDeployment *appsv1.Deployment
    JmService    *corev1.Service
    JmIngress    *extensionsv1beta1.Ingress
    TmDeployment *appsv1.Deployment
    ConfigMap    *corev1.ConfigMap
    Job          *batchv1.Job

DesiredClusterState holds desired state of a cluster.

type FlinkClusterHandler Uses

type FlinkClusterHandler struct {
    // contains filtered or unexported fields

FlinkClusterHandler holds the context and state for a reconcile request.

type FlinkClusterReconciler Uses

type FlinkClusterReconciler struct {
    Client client.Client
    Log    logr.Logger
    Mgr    ctrl.Manager

FlinkClusterReconciler reconciles a FlinkCluster object

func (*FlinkClusterReconciler) Reconcile Uses

func (reconciler *FlinkClusterReconciler) Reconcile(
    request ctrl.Request) (ctrl.Result, error)

Reconcile the observed state towards the desired state for a FlinkCluster custom resource.

func (*FlinkClusterReconciler) SetupWithManager Uses

func (reconciler *FlinkClusterReconciler) SetupWithManager(
    mgr ctrl.Manager) error

SetupWithManager registers this reconciler with the controller manager and starts watching FlinkCluster, Deployment and Service resources.

type ObservedClusterState Uses

type ObservedClusterState struct {
    // contains filtered or unexported fields

ObservedClusterState holds observed state of a cluster.

type TimeConverter Uses

type TimeConverter struct{}

TimeConverter converts between time.Time and string.

func (*TimeConverter) FromString Uses

func (tc *TimeConverter) FromString(timeStr string) time.Time

FromString converts string to time.Time.

func (*TimeConverter) ToString Uses

func (tc *TimeConverter) ToString(timestamp time.Time) string

ToString converts time.Time to string.



Package controllers imports 26 packages (graph). Updated 2020-05-29. Refresh now. Tools for package owners.