mock

package

Go to main page

Versions in this module

v0

v0.6.0

Sep 16, 2021

Changes in this version

type FlinkController

+ GetDeploymentsForHashFunc GetDeploymentsForHashFunc

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

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

v0.5.0

Apr 27, 2020

Changes in this version

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

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

type FlinkController

+ DeleteResourcesForAppWithHashFunc DeleteResourcesForAppWithHashFunc

+ DeleteStatusPostTeardownFunc DeleteStatusPostTeardownFunc

+ GetJobToDeleteForApplicationFunc GetJobToDeleteForApplicationFunc

+ GetLatestClusterStatusFunc GetLatestClusterStatusFunc

+ GetLatestJobIDFunc GetLatestJobIDFunc

+ GetLatestJobStatusFunc GetLatestJobStatusFunc

+ GetVersionAndHashPostTeardownFunc GetVersionAndHashPostTeardownFunc

+ GetVersionAndJobIDForHashFunc GetVersionAndJobIDForHashFunc

+ SavepointFunc SavepointFunc

+ UpdateLatestClusterStatusFunc UpdateLatestClusterStatusFunc

+ UpdateLatestJobIDFunc UpdateLatestJobIDFunc

+ UpdateLatestJobStatusFunc UpdateLatestJobStatusFunc

+ UpdateLatestVersionAndHashFunc UpdateLatestVersionAndHashFunc

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

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

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

+ func (m *FlinkController) GetLatestClusterStatus(ctx context.Context, application *v1beta1.FlinkApplication) v1beta1.FlinkClusterStatus

+ func (m *FlinkController) GetLatestJobID(ctx context.Context, application *v1beta1.FlinkApplication) string

+ func (m *FlinkController) GetLatestJobStatus(ctx context.Context, application *v1beta1.FlinkApplication) v1beta1.FlinkJobStatus

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

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

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

+ func (m *FlinkController) UpdateLatestClusterStatus(ctx context.Context, application *v1beta1.FlinkApplication, ...)

+ func (m *FlinkController) UpdateLatestJobID(ctx context.Context, application *v1beta1.FlinkApplication, jobID string)

+ func (m *FlinkController) UpdateLatestJobStatus(ctx context.Context, application *v1beta1.FlinkApplication, ...)

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

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

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

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

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

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

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

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

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

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

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

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

v0.4.0

Jan 14, 2020

v0.3.0

Oct 10, 2019

Changes in this version

type FlinkController

+ GetJobForApplicationFunc GetJobForApplicationFunc

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

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

v0.2.0

Aug 12, 2019

v0.1.3

Jul 17, 2019

Changes in this version

+ type GetRetryDelayFunc func(retryCount int32) time.Duration

+ type IsErrorFailFastFunc func(err error) bool

+ type IsErrorRetryableFunc func(err error) bool

+ type IsRetryRemainingFunc func(err error, retryCount int32) bool

+ type IsTimeToRetryFunc func(clock clock.Clock, lastUpdatedTime time.Time, retryCount int32) bool

+ type RetryHandler struct

+ GetRetryDelayFunc GetRetryDelayFunc

+ IsErrorFailFastFunc IsErrorFailFastFunc

+ IsErrorRetryableFunc IsErrorRetryableFunc

+ IsRetryRemainingFunc IsRetryRemainingFunc

+ IsTimeToRetryFunc IsTimeToRetryFunc

+ WaitOnErrorFunc WaitOnErrorFunc

+ func (e RetryHandler) GetRetryDelay(retryCount int32) time.Duration

+ func (e RetryHandler) IsErrorFailFast(err error) bool

+ func (e RetryHandler) IsErrorRetryable(err error) bool

+ func (e RetryHandler) IsRetryRemaining(err error, retryCount int32) bool

+ func (e RetryHandler) IsTimeToRetry(clock clock.Clock, lastUpdatedTime time.Time, retryCount int32) bool

+ func (e RetryHandler) WaitOnError(clock clock.Clock, lastUpdatedTime time.Time) (time.Duration, bool)

+ type WaitOnErrorFunc func(clock clock.Clock, lastUpdatedTime time.Time) (time.Duration, bool)

v0.1.2

Jun 24, 2019

Changes in this version

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

type FlinkController

+ DeleteOldResourcesForAppFunc DeleteOldResourcesForApp

+ GetCurrentDeploymentsForAppFunc GetCurrentDeploymentsForAppFunc

+ func (m *FlinkController) DeleteOldResourcesForApp(ctx context.Context, application *v1alpha1.FlinkApplication) error

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

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

v0.1.1

May 31, 2019

Changes in this version

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

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

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

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

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

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

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

+ type FlinkController struct

+ CancelWithSavepointFunc CancelWithSavepointFunc

+ CompareAndUpdateClusterStatusFunc CompareAndUpdateClusterStatusFunc

+ CompareAndUpdateJobStatusFunc CompareAndUpdateJobStatusFunc

+ CreateClusterFunc CreateClusterFunc

+ DeleteClusterFunc DeleteClusterFunc

+ Events []corev1.Event

+ FindExternalizedCheckpointFunc FindExternalizedCheckpointFunc

+ ForceCancelFunc ForceCancelFunc

+ GetCurrentAndOldDeploymentsForAppFunc GetCurrentAndOldDeploymentsForAppFunc

+ GetJobsForApplicationFunc GetJobsForApplicationFunc

+ GetSavepointStatusFunc GetSavepointStatusFunc

+ IsClusterReadyFunc IsClusterReadyFunc

+ IsServiceReadyFunc IsServiceReadyFunc

+ StartFlinkJobFunc StartFlinkJobFunc

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

+ type JobManagerController struct

+ CreateIfNotExistFunc CreateIfNotExistFunc

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

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

+ type TaskManagerController struct

+ CreateIfNotExistFunc CreateIfNotExistFunc

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

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