flink

package

Go to main page

Versions in this module

v0

v0.6.0

Sep 16, 2021

Changes in this version

+ const PodDeploymentSelector

+ const SystemMemoryDefaultFraction

+ func ComputeTaskManagerReplicas(application *v1beta1.FlinkApplication) int32

+ func GetCommonAppLabels(app *v1beta1.FlinkApplication) map[string]string

+ func RandomPodDeploymentSelector() string

type Controller

+ func (f *Controller) GetDeploymentsForHash(ctx context.Context, application *v1beta1.FlinkApplication, hash string) (*common.FlinkDeployment, error)

type ControllerInterface

+ GetDeploymentsForHash func(ctx context.Context, application *v1beta1.FlinkApplication, hash string) (*common.FlinkDeployment, error)

v0.5.0

Apr 27, 2020

Changes in this version

+ const AppIngressName

+ const FlinkApplicationVersion

+ const FlinkApplicationVersionEnv

+ const JobManagerServiceName

+ const JobManagerVersionNameFormat

+ const JobManagerVersionServiceName

+ const TaskManagerVersionNameFormat

+ func GetDeploySpecificEnv(app *v1beta1.FlinkApplication) []v1.EnvVar

+ func Min(x, y int32) int32

type Controller

+ func (f *Controller) DeleteResourcesForAppWithHash(ctx context.Context, app *v1beta1.FlinkApplication, hash string) error

+ func (f *Controller) DeleteStatusPostTeardown(ctx context.Context, application *v1beta1.FlinkApplication, hash string)

+ func (f *Controller) GetJobToDeleteForApplication(ctx context.Context, app *v1beta1.FlinkApplication, hash string) (*client.FlinkJobOverview, error)

+ func (f *Controller) GetLatestClusterStatus(ctx context.Context, application *v1beta1.FlinkApplication) v1beta1.FlinkClusterStatus

+ func (f *Controller) GetLatestJobID(ctx context.Context, application *v1beta1.FlinkApplication) string

+ func (f *Controller) GetLatestJobStatus(ctx context.Context, application *v1beta1.FlinkApplication) v1beta1.FlinkJobStatus

+ func (f *Controller) GetVersionAndHashPostTeardown(ctx context.Context, application *v1beta1.FlinkApplication) (v1beta1.FlinkApplicationVersion, string)

+ func (f *Controller) GetVersionAndJobIDForHash(ctx context.Context, app *v1beta1.FlinkApplication, hash string) (string, string, error)

+ func (f *Controller) Savepoint(ctx context.Context, application *v1beta1.FlinkApplication, hash string, ...) (string, error)

+ func (f *Controller) UpdateLatestClusterStatus(ctx context.Context, app *v1beta1.FlinkApplication, ...)

+ func (f *Controller) UpdateLatestJobID(ctx context.Context, app *v1beta1.FlinkApplication, jobID string)

+ func (f *Controller) UpdateLatestJobStatus(ctx context.Context, app *v1beta1.FlinkApplication, ...)

+ func (f *Controller) UpdateLatestVersionAndHash(application *v1beta1.FlinkApplication, version v1beta1.FlinkApplicationVersion, ...)

type ControllerInterface

+ DeleteResourcesForAppWithHash func(ctx context.Context, application *v1beta1.FlinkApplication, hash string) error

+ DeleteStatusPostTeardown func(ctx context.Context, application *v1beta1.FlinkApplication, hash string)

+ GetJobToDeleteForApplication func(ctx context.Context, app *v1beta1.FlinkApplication, hash string) (*client.FlinkJobOverview, error)

+ GetLatestClusterStatus func(ctx context.Context, app *v1beta1.FlinkApplication) v1beta1.FlinkClusterStatus

+ GetLatestJobID func(ctx context.Context, app *v1beta1.FlinkApplication) string

+ GetLatestJobStatus func(ctx context.Context, app *v1beta1.FlinkApplication) v1beta1.FlinkJobStatus

+ GetVersionAndHashPostTeardown func(ctx context.Context, application *v1beta1.FlinkApplication) (v1beta1.FlinkApplicationVersion, string)

+ GetVersionAndJobIDForHash func(ctx context.Context, application *v1beta1.FlinkApplication, hash string) (string, string, error)

+ Savepoint func(ctx context.Context, application *v1beta1.FlinkApplication, hash string, ...) (string, error)

+ UpdateLatestClusterStatus func(ctx context.Context, app *v1beta1.FlinkApplication, ...)

+ UpdateLatestJobID func(ctx context.Context, app *v1beta1.FlinkApplication, jobID string)

+ UpdateLatestJobStatus func(ctx context.Context, app *v1beta1.FlinkApplication, ...)

+ UpdateLatestVersionAndHash func(application *v1beta1.FlinkApplication, version v1beta1.FlinkApplicationVersion, ...)

v0.4.0

Jan 14, 2020

Changes in this version

+ const MaxCheckpointRestoreAgeSeconds

v0.3.0

Oct 10, 2019

Changes in this version

+ func GetActiveFlinkJobs(jobs []client.FlinkJob) []client.FlinkJob

type Controller

+ func (f *Controller) GetJobForApplication(ctx context.Context, application *v1beta1.FlinkApplication, hash string) (*client.FlinkJobOverview, error)

type ControllerInterface

+ GetJobForApplication func(ctx context.Context, application *v1beta1.FlinkApplication, hash string) (*client.FlinkJobOverview, error)

v0.2.0

Aug 12, 2019

Changes in this version

+ func ComputeDeploymentHash(deployment appsv1.Deployment) ([]byte, error)

v0.1.3

Jul 17, 2019

Changes in this version

+ const FlinkDeploymentTypeEnv

+ const HighAvailabilityKey

+ const HostIP

+ const HostName

+ func InjectOperatorCustomizedConfig(deployment *appsv1.Deployment, app *v1alpha1.FlinkApplication, hash string, ...)

v0.1.2

Jun 24, 2019

Changes in this version

+ func VersionedJobManagerServiceName(app *v1alpha1.FlinkApplication, hash string) string

type Controller

+ func (f *Controller) DeleteOldResourcesForApp(ctx context.Context, app *v1alpha1.FlinkApplication) error

+ func (f *Controller) GetCurrentDeploymentsForApp(ctx context.Context, application *v1alpha1.FlinkApplication) (*common.FlinkDeployment, error)

type ControllerInterface

+ DeleteOldResourcesForApp func(ctx context.Context, app *v1alpha1.FlinkApplication) error

+ GetCurrentDeploymentsForApp func(ctx context.Context, application *v1alpha1.FlinkApplication) (*common.FlinkDeployment, error)

v0.1.1

May 31, 2019

Changes in this version

+ const AppName

+ const AwsMetadataServiceNumAttempts

+ const AwsMetadataServiceNumAttemptsKey

+ const AwsMetadataServiceTimeout

+ const AwsMetadataServiceTimeoutKey

+ const BlobDefaultPort

+ const FlinkAppHash

+ const FlinkBlobPortName

+ const FlinkDeploymentType

+ const FlinkDeploymentTypeJobmanager

+ const FlinkDeploymentTypeTaskmanager

+ const FlinkInternalMetricPortName

+ const FlinkJobProperties

+ const FlinkQueryPortName

+ const FlinkRPCPortName

+ const FlinkUIPortName

+ const JobManagerArg

+ const JobManagerContainerName

+ const JobManagerDefaultReplicaCount

+ const JobManagerNameFormat

+ const JobManagerPodNameFormat

+ const JobManagerReadinessFailureThreshold

+ const JobManagerReadinessInitialDelaySec

+ const JobManagerReadinessPath

+ const JobManagerReadinessPeriodSec

+ const JobManagerReadinessSuccessThreshold

+ const JobManagerReadinessTimeoutSec

+ const MetricsQueryDefaultPort

+ const OffHeapMemoryDefaultFraction

+ const OperatorFlinkConfig

+ const QueryDefaultPort

+ const RPCDefaultPort

+ const RestartNonce

+ const TaskManagerArg

+ const TaskManagerContainerName

+ const TaskManagerDefaultSlots

+ const TaskManagerHostnameEnvVar

+ const TaskManagerNameFormat

+ const TaskManagerPodNameFormat

+ const UIDefaultPort

+ var JobManagerDefaultResources = coreV1.ResourceRequirements

+ var TaskManagerDefaultResources = coreV1.ResourceRequirements

+ func DeploymentIsJobmanager(deployment *v1.Deployment) bool

+ func DeploymentIsTaskmanager(deployment *v1.Deployment) bool

+ func DeploymentsEqual(a *appsv1.Deployment, b *appsv1.Deployment) bool

+ func FetchJobManagerContainerObj(application *v1alpha1.FlinkApplication) *coreV1.Container

+ func FetchJobManagerIngressCreateObj(app *v1alpha1.FlinkApplication) *v1beta1.Ingress

+ func FetchJobManagerServiceCreateObj(app *v1alpha1.FlinkApplication, hash string) *coreV1.Service

+ func FetchJobMangerDeploymentCreateObj(app *v1alpha1.FlinkApplication, hash string) *v1.Deployment

+ func FetchJobMangerDeploymentDeleteObj(app *v1alpha1.FlinkApplication, hash string) *v1.Deployment

+ func FetchTaskManagerContainerObj(application *v1alpha1.FlinkApplication) *coreV1.Container

+ func FetchTaskMangerDeploymentCreateObj(app *v1alpha1.FlinkApplication, hash string) *v1.Deployment

+ func FetchTaskMangerDeploymentDeleteObj(app *v1alpha1.FlinkApplication, hash string) *v1.Deployment

+ func FetchVersionedJobManagerServiceDeleteObj(app *v1alpha1.FlinkApplication, hash string) *coreV1.Service

+ func GetAWSServiceEnv() []v1.EnvVar

+ func GetActiveFlinkJob(jobs []client.FlinkJob) *client.FlinkJob

+ func GetAppHashSelector(app *v1alpha1.FlinkApplication) map[string]string

+ func GetAppHashSelectorWithHash(hash string) map[string]string

+ func GetFlinkContainerEnv(app *v1alpha1.FlinkApplication) []v1.EnvVar

+ func GetFlinkUIIngressURL(jobName string) string

+ func GetTaskManagerPorts(app *v1alpha1.FlinkApplication) []coreV1.ContainerPort

+ func HashForApplication(app *v1alpha1.FlinkApplication) string

+ func ImagePullPolicy(app *v1alpha1.FlinkApplication) v1.PullPolicy

+ func InjectHashesIntoConfig(deployment *appsv1.Deployment, app *v1alpha1.FlinkApplication, hash string)

+ func JobManagerDeploymentMatches(deployment *v1.Deployment, application *v1alpha1.FlinkApplication) bool

+ func ReplaceJobURL(value string, input string) string

+ func TaskManagerDeploymentMatches(deployment *v1.Deployment, application *v1alpha1.FlinkApplication) bool

+ func VersionedJobManagerService(app *v1alpha1.FlinkApplication, hash string) string

+ type Controller struct

+ func (f *Controller) CancelWithSavepoint(ctx context.Context, application *v1alpha1.FlinkApplication, hash string) (string, error)

+ func (f *Controller) CompareAndUpdateClusterStatus(ctx context.Context, application *v1alpha1.FlinkApplication, hash string) (bool, error)

+ func (f *Controller) CompareAndUpdateJobStatus(ctx context.Context, app *v1alpha1.FlinkApplication, hash string) (bool, error)

+ func (f *Controller) CreateCluster(ctx context.Context, application *v1alpha1.FlinkApplication) error

+ func (f *Controller) DeleteCluster(ctx context.Context, application *v1alpha1.FlinkApplication, hash string) error

+ func (f *Controller) FindExternalizedCheckpoint(ctx context.Context, application *v1alpha1.FlinkApplication, hash string) (string, error)

+ func (f *Controller) ForceCancel(ctx context.Context, application *v1alpha1.FlinkApplication, hash string) error

+ func (f *Controller) GetCurrentAndOldDeploymentsForApp(ctx context.Context, application *v1alpha1.FlinkApplication) (*common.FlinkDeployment, []common.FlinkDeployment, error)

+ func (f *Controller) GetJobsForApplication(ctx context.Context, application *v1alpha1.FlinkApplication, hash string) ([]client.FlinkJob, error)

+ func (f *Controller) GetSavepointStatus(ctx context.Context, application *v1alpha1.FlinkApplication, hash string) (*client.SavepointResponse, error)

+ func (f *Controller) IsClusterReady(ctx context.Context, application *v1alpha1.FlinkApplication) (bool, error)

+ func (f *Controller) IsServiceReady(ctx context.Context, application *v1alpha1.FlinkApplication, hash string) (bool, error)

+ func (f *Controller) LogEvent(ctx context.Context, app *v1alpha1.FlinkApplication, fieldPath string, ...)

+ func (f *Controller) StartFlinkJob(ctx context.Context, application *v1alpha1.FlinkApplication, hash string, ...) (string, error)

+ type ControllerInterface interface

+ CancelWithSavepoint func(ctx context.Context, application *v1alpha1.FlinkApplication, hash string) (string, error)

+ CompareAndUpdateClusterStatus func(ctx context.Context, application *v1alpha1.FlinkApplication, hash string) (bool, error)

+ CompareAndUpdateJobStatus func(ctx context.Context, app *v1alpha1.FlinkApplication, hash string) (bool, error)

+ CreateCluster func(ctx context.Context, application *v1alpha1.FlinkApplication) error

+ DeleteCluster func(ctx context.Context, application *v1alpha1.FlinkApplication, hash string) error

+ FindExternalizedCheckpoint func(ctx context.Context, application *v1alpha1.FlinkApplication, hash string) (string, error)

+ ForceCancel func(ctx context.Context, application *v1alpha1.FlinkApplication, hash string) error

+ GetCurrentAndOldDeploymentsForApp func(ctx context.Context, application *v1alpha1.FlinkApplication) (*common.FlinkDeployment, []common.FlinkDeployment, error)

+ GetJobsForApplication func(ctx context.Context, application *v1alpha1.FlinkApplication, hash string) ([]client.FlinkJob, error)

+ GetSavepointStatus func(ctx context.Context, application *v1alpha1.FlinkApplication, hash string) (*client.SavepointResponse, error)

+ IsClusterReady func(ctx context.Context, application *v1alpha1.FlinkApplication) (bool, error)

+ IsServiceReady func(ctx context.Context, application *v1alpha1.FlinkApplication, hash string) (bool, error)

+ LogEvent func(ctx context.Context, app *v1alpha1.FlinkApplication, fieldPath string, ...)

+ StartFlinkJob func(ctx context.Context, application *v1alpha1.FlinkApplication, hash string, ...) (string, error)

+ func NewController(k8sCluster k8.ClusterInterface, config config.RuntimeConfig) ControllerInterface

+ type JobManagerController struct

+ func (j *JobManagerController) CreateIfNotExist(ctx context.Context, application *v1alpha1.FlinkApplication) (bool, error)

+ type JobManagerControllerInterface interface

+ CreateIfNotExist func(ctx context.Context, application *v1alpha1.FlinkApplication) (bool, error)

+ func NewJobManagerController(k8sCluster k8.ClusterInterface, config config.RuntimeConfig) JobManagerControllerInterface

+ type TaskManagerController struct

+ func (t *TaskManagerController) CreateIfNotExist(ctx context.Context, application *v1alpha1.FlinkApplication) (bool, error)

+ type TaskManagerControllerInterface interface

+ CreateIfNotExist func(ctx context.Context, application *v1alpha1.FlinkApplication) (bool, error)

+ func NewTaskManagerController(k8sCluster k8.ClusterInterface, config config.RuntimeConfig) TaskManagerControllerInterface

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL