v1alpha1

package

Go to main page

Versions in this module

v0

v0.6.0

Sep 16, 2021

Changes in this version

type JobManagerConfig

+ SystemMemoryFraction *float64

type TaskManagerConfig

+ SystemMemoryFraction *float64

v0.5.0

Apr 27, 2020

v0.4.0

Jan 14, 2020

v0.3.0

Oct 10, 2019

Changes in this version

+ type FlinkApplicationError struct

+ AppError string

+ ErrorCode string

+ IsFailFast bool

+ IsRetryable bool

+ LastErrorUpdateTime *metav1.Time

+ MaxRetries int32

+ Method FlinkMethod

+ func NewFlinkApplicationError(appError string, method FlinkMethod, errorCode string, isRetryable bool, ...) *FlinkApplicationError

+ func (f *FlinkApplicationError) Error() string

+ func (in *FlinkApplicationError) DeepCopy() *FlinkApplicationError

+ func (in *FlinkApplicationError) DeepCopyInto(out *FlinkApplicationError)

+ type FlinkMethod string

+ const CancelJobWithSavepoint

+ const CheckSavepointStatus

+ const ForceCancelJob

+ const GetCheckpointCounts

+ const GetClusterOverview

+ const GetJobConfig

+ const GetJobOverview

+ const GetJobs

+ const GetLatestCheckpoint

+ const GetTaskManagers

+ const SubmitJob

v0.2.0

Aug 12, 2019

Changes in this version

type FlinkApplicationSpec

+ ForceRollback bool

type FlinkApplicationStatus

+ RollbackHash string

type JobManagerConfig

+ EnvConfig EnvironmentConfig

type TaskManagerConfig

+ EnvConfig EnvironmentConfig

v0.1.3

Jul 17, 2019

Changes in this version

type FlinkApplicationSpec

+ AllowNonRestoredState bool

type FlinkApplicationStatus

+ LastSeenError *client.FlinkApplicationError

+ RetryCount int32

type FlinkJobStatus

+ AllowNonRestoredState bool

v0.1.2

Jun 24, 2019

Changes in this version

type JobManagerConfig

+ NodeSelector map[string]string

type TaskManagerConfig

+ NodeSelector map[string]string

v0.1.1

May 31, 2019

Changes in this version

+ const FlinkApplicationKind

+ var AddToScheme = SchemeBuilder.AddToScheme

+ var FlinkApplicationPhases = []FlinkApplicationPhase

+ var SchemeBuilder = runtime.NewSchemeBuilder(addKnownTypes)

+ var SchemeGroupVersion = schema.GroupVersion

+ func IsRunningPhase(phase FlinkApplicationPhase) bool

+ func Kind(kind string) schema.GroupKind

+ func Resource(resource string) schema.GroupResource

+ type DeleteMode string

+ const DeleteModeForceCancel

+ const DeleteModeNone

+ const DeleteModeSavepoint

+ type DeploymentMode string

+ const DeploymentModeDual

+ const DeploymentModeSingle

+ type EnvironmentConfig struct

+ Env []apiv1.EnvVar

+ EnvFrom []apiv1.EnvFromSource

+ func (in *EnvironmentConfig) DeepCopy() *EnvironmentConfig

+ func (in *EnvironmentConfig) DeepCopyInto(out *EnvironmentConfig)

+ type FlinkApplication struct

+ Spec FlinkApplicationSpec

+ Status FlinkApplicationStatus

+ func (in *FlinkApplication) DeepCopy() *FlinkApplication

+ func (in *FlinkApplication) DeepCopyInto(out *FlinkApplication)

+ func (in *FlinkApplication) DeepCopyObject() runtime.Object

+ type FlinkApplicationList struct

+ Items []FlinkApplication

+ func (in *FlinkApplicationList) DeepCopy() *FlinkApplicationList

+ func (in *FlinkApplicationList) DeepCopyInto(out *FlinkApplicationList)

+ func (in *FlinkApplicationList) DeepCopyObject() runtime.Object

+ type FlinkApplicationPhase string

+ const FlinkApplicationClusterStarting

+ const FlinkApplicationDeleting

+ const FlinkApplicationDeployFailed

+ const FlinkApplicationNew

+ const FlinkApplicationRollingBackJob

+ const FlinkApplicationRunning

+ const FlinkApplicationSavepointing

+ const FlinkApplicationSubmittingJob

+ const FlinkApplicationUpdating

+ func (p FlinkApplicationPhase) VerboseString() string

+ type FlinkApplicationSpec struct

+ BlobPort *int32

+ DeleteMode DeleteMode

+ DeploymentMode DeploymentMode

+ EntryClass string

+ FlinkConfig FlinkConfig

+ FlinkVersion string

+ Image string

+ ImagePullPolicy apiv1.PullPolicy

+ ImagePullSecrets []apiv1.LocalObjectReference

+ JarName string

+ JobManagerConfig JobManagerConfig

+ MetricsQueryPort *int32

+ Parallelism int32

+ ProgramArgs string

+ QueryPort *int32

+ RPCPort *int32

+ RestartNonce string

+ SavepointInfo SavepointInfo

+ TaskManagerConfig TaskManagerConfig

+ UIPort *int32

+ VolumeMounts []apiv1.VolumeMount

+ Volumes []apiv1.Volume

+ func (in *FlinkApplicationSpec) DeepCopy() *FlinkApplicationSpec

+ func (in *FlinkApplicationSpec) DeepCopyInto(out *FlinkApplicationSpec)

+ type FlinkApplicationStatus struct

+ ClusterStatus FlinkClusterStatus

+ DeployHash string

+ FailedDeployHash string

+ JobStatus FlinkJobStatus

+ LastUpdatedAt *metav1.Time

+ Phase FlinkApplicationPhase

+ Reason string

+ StartedAt *metav1.Time

+ func (in *FlinkApplicationStatus) DeepCopy() *FlinkApplicationStatus

+ func (in *FlinkApplicationStatus) DeepCopyInto(out *FlinkApplicationStatus)

+ func (in *FlinkApplicationStatus) GetPhase() FlinkApplicationPhase

+ func (in *FlinkApplicationStatus) TouchResource(reason string)

+ func (in *FlinkApplicationStatus) UpdatePhase(phase FlinkApplicationPhase, reason string)

+ type FlinkClusterStatus struct

+ AvailableTaskSlots int32

+ Health HealthStatus

+ HealthyTaskManagers int32

+ NumberOfTaskManagers int32

+ NumberOfTaskSlots int32

+ func (in *FlinkClusterStatus) DeepCopy() *FlinkClusterStatus

+ func (in *FlinkClusterStatus) DeepCopyInto(out *FlinkClusterStatus)

+ type FlinkConfig map[string]interface

+ func (in *FlinkConfig) DeepCopy() *FlinkConfig

+ func (in *FlinkConfig) DeepCopyInto(out *FlinkConfig)

+ type FlinkJobStatus struct

+ CompletedCheckpointCount int32

+ EntryClass string

+ FailedCheckpointCount int32

+ Health HealthStatus

+ JarName string

+ JobID string

+ JobRestartCount int32

+ LastCheckpointTime *metav1.Time

+ LastFailingTime *metav1.Time

+ Parallelism int32

+ ProgramArgs string

+ RestorePath string

+ RestoreTime *metav1.Time

+ StartTime *metav1.Time

+ State JobState

+ func (in *FlinkJobStatus) DeepCopy() *FlinkJobStatus

+ func (in *FlinkJobStatus) DeepCopyInto(out *FlinkJobStatus)

+ type HealthStatus string

+ const Green

+ const Red

+ const Yellow

+ type JobManagerConfig struct

+ Environment EnvironmentConfig

+ OffHeapMemoryFraction *float64

+ Replicas *int32

+ Resources *apiv1.ResourceRequirements

+ func (in *JobManagerConfig) DeepCopy() *JobManagerConfig

+ func (in *JobManagerConfig) DeepCopyInto(out *JobManagerConfig)

+ type JobState string

+ const Canceled

+ const Cancelling

+ const Created

+ const Failed

+ const Failing

+ const Finished

+ const Reconciling

+ const Restarting

+ const Running

+ const Suspended

+ type SavepointInfo struct

+ SavepointLocation string

+ TriggerID string

+ func (in *SavepointInfo) DeepCopy() *SavepointInfo

+ func (in *SavepointInfo) DeepCopyInto(out *SavepointInfo)

+ type TaskManagerConfig struct

+ Environment EnvironmentConfig

+ OffHeapMemoryFraction *float64

+ Resources *apiv1.ResourceRequirements

+ TaskSlots *int32

+ func (in *TaskManagerConfig) DeepCopy() *TaskManagerConfig

+ func (in *TaskManagerConfig) DeepCopyInto(out *TaskManagerConfig)

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