mock

package
v0.6.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Sep 16, 2021 License: Apache-2.0 Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type CompareAndUpdateClusterStatusFunc 

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

type CompareAndUpdateJobStatusFunc 

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

type CreateClusterFunc 

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

type CreateIfNotExistFunc 

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

type DeleteOldResourcesForApp added in v0.1.2 

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

type DeleteResourcesForAppWithHashFunc added in v0.5.0 

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

type DeleteStatusPostTeardownFunc added in v0.5.0 

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

type FindExternalizedCheckpointFunc 

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

type FlinkController 

type FlinkController struct {
	CreateClusterFunc                 CreateClusterFunc
	DeleteOldResourcesForAppFunc      DeleteOldResourcesForApp
	SavepointFunc                     SavepointFunc
	ForceCancelFunc                   ForceCancelFunc
	StartFlinkJobFunc                 StartFlinkJobFunc
	GetSavepointStatusFunc            GetSavepointStatusFunc
	IsClusterReadyFunc                IsClusterReadyFunc
	IsServiceReadyFunc                IsServiceReadyFunc
	GetJobsForApplicationFunc         GetJobsForApplicationFunc
	GetJobForApplicationFunc          GetJobForApplicationFunc
	GetCurrentDeploymentsForAppFunc   GetCurrentDeploymentsForAppFunc
	GetDeploymentsForHashFunc         GetDeploymentsForHashFunc
	FindExternalizedCheckpointFunc    FindExternalizedCheckpointFunc
	Events                            []corev1.Event
	CompareAndUpdateClusterStatusFunc CompareAndUpdateClusterStatusFunc
	CompareAndUpdateJobStatusFunc     CompareAndUpdateJobStatusFunc
	GetLatestClusterStatusFunc        GetLatestClusterStatusFunc
	GetLatestJobStatusFunc            GetLatestJobStatusFunc
	GetLatestJobIDFunc                GetLatestJobIDFunc
	UpdateLatestJobIDFunc             UpdateLatestJobIDFunc
	UpdateLatestJobStatusFunc         UpdateLatestJobStatusFunc
	UpdateLatestClusterStatusFunc     UpdateLatestClusterStatusFunc
	UpdateLatestVersionAndHashFunc    UpdateLatestVersionAndHashFunc
	DeleteResourcesForAppWithHashFunc DeleteResourcesForAppWithHashFunc
	DeleteStatusPostTeardownFunc      DeleteStatusPostTeardownFunc
	GetJobToDeleteForApplicationFunc  GetJobToDeleteForApplicationFunc
	GetVersionAndJobIDForHashFunc     GetVersionAndJobIDForHashFunc
	GetVersionAndHashPostTeardownFunc GetVersionAndHashPostTeardownFunc
}

func (*FlinkController) CompareAndUpdateClusterStatus 

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

func (*FlinkController) CompareAndUpdateJobStatus 

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

func (*FlinkController) CreateCluster 

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

func (*FlinkController) DeleteOldResourcesForApp added in v0.1.2 

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

func (*FlinkController) DeleteResourcesForAppWithHash added in v0.5.0 

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

func (*FlinkController) DeleteStatusPostTeardown added in v0.5.0 

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

func (*FlinkController) FindExternalizedCheckpoint 

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

func (*FlinkController) ForceCancel 

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

func (*FlinkController) GetCurrentDeploymentsForApp added in v0.1.2 

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

func (*FlinkController) GetDeploymentsForHash added in v0.6.0 

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

func (*FlinkController) GetJobForApplication added in v0.3.0 

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

func (*FlinkController) GetJobToDeleteForApplication added in v0.5.0 

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

func (*FlinkController) GetJobsForApplication 

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

func (*FlinkController) GetLatestClusterStatus added in v0.5.0 

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

func (*FlinkController) GetLatestJobID added in v0.5.0 

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

func (*FlinkController) GetLatestJobStatus added in v0.5.0 

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

func (*FlinkController) GetSavepointStatus 

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

func (*FlinkController) GetVersionAndHashPostTeardown added in v0.5.0 

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

func (*FlinkController) GetVersionAndJobIDForHash added in v0.5.0 

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

func (*FlinkController) IsClusterReady 

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

func (*FlinkController) IsServiceReady 

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

func (*FlinkController) LogEvent 

func (m *FlinkController) LogEvent(ctx context.Context, app *v1beta1.FlinkApplication, eventType string, reason string, message string)

func (*FlinkController) Savepoint added in v0.5.0 

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

func (*FlinkController) StartFlinkJob 

func (m *FlinkController) StartFlinkJob(ctx context.Context, application *v1beta1.FlinkApplication, hash string,
	jarName string, parallelism int32, entryClass string, programArgs string, allowNonRestoredState bool, savepointPath string) (string, error)

func (*FlinkController) UpdateLatestClusterStatus added in v0.5.0 

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

func (*FlinkController) UpdateLatestJobID added in v0.5.0 

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

func (*FlinkController) UpdateLatestJobStatus added in v0.5.0 

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

func (*FlinkController) UpdateLatestVersionAndHash added in v0.5.0 

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

type ForceCancelFunc 

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

type GetCurrentDeploymentsForAppFunc added in v0.1.2 

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

type GetDeploymentsForHashFunc added in v0.6.0 

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

type GetJobForApplicationFunc added in v0.3.0 

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

type GetJobToDeleteForApplicationFunc added in v0.5.0 

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

type GetJobsForApplicationFunc 

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

type GetLatestClusterStatusFunc added in v0.5.0 

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

type GetLatestJobIDFunc added in v0.5.0 

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

type GetLatestJobStatusFunc added in v0.5.0 

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

type GetRetryDelayFunc added in v0.1.3 

type GetRetryDelayFunc func(retryCount int32) time.Duration

type GetSavepointStatusFunc 

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

type GetVersionAndHashPostTeardownFunc added in v0.5.0 

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

type GetVersionAndJobIDForHashFunc added in v0.5.0 

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

type IsClusterReadyFunc 

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

type IsErrorFailFastFunc added in v0.1.3 

type IsErrorFailFastFunc func(err error) bool

type IsErrorRetryableFunc added in v0.1.3 

type IsErrorRetryableFunc func(err error) bool

type IsRetryRemainingFunc added in v0.1.3 

type IsRetryRemainingFunc func(err error, retryCount int32) bool

type IsServiceReadyFunc 

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

type IsTimeToRetryFunc added in v0.1.3 

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

type JobManagerController 

type JobManagerController struct {
	CreateIfNotExistFunc CreateIfNotExistFunc
}

func (*JobManagerController) CreateIfNotExist 

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

type RetryHandler added in v0.1.3 

type RetryHandler struct {
	IsErrorRetryableFunc IsErrorRetryableFunc
	IsRetryRemainingFunc IsRetryRemainingFunc
	IsErrorFailFastFunc  IsErrorFailFastFunc
	WaitOnErrorFunc      WaitOnErrorFunc
	GetRetryDelayFunc    GetRetryDelayFunc
	IsTimeToRetryFunc    IsTimeToRetryFunc
}

func (RetryHandler) GetRetryDelay added in v0.1.3 

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

func (RetryHandler) IsErrorFailFast added in v0.1.3 

func (e RetryHandler) IsErrorFailFast(err error) bool

func (RetryHandler) IsErrorRetryable added in v0.1.3 

func (e RetryHandler) IsErrorRetryable(err error) bool

func (RetryHandler) IsRetryRemaining added in v0.1.3 

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

func (RetryHandler) IsTimeToRetry added in v0.1.3 

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

func (RetryHandler) WaitOnError added in v0.1.3 

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

type SavepointFunc added in v0.5.0 

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

type StartFlinkJobFunc 

type StartFlinkJobFunc func(ctx context.Context, application *v1beta1.FlinkApplication, hash string,
	jarName string, parallelism int32, entryClass string, programArgs string, allowNonRestoredState bool, savepointPath string) (string, error)

type TaskManagerController 

type TaskManagerController struct {
	CreateIfNotExistFunc CreateIfNotExistFunc
}

func (*TaskManagerController) CreateIfNotExist 

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

type UpdateLatestClusterStatusFunc added in v0.5.0 

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

type UpdateLatestJobIDFunc added in v0.5.0 

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

type UpdateLatestJobStatusFunc added in v0.5.0 

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

type UpdateLatestVersionAndHashFunc added in v0.5.0 

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

type WaitOnErrorFunc added in v0.1.3 

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.