mock

Documentation

Index

• type CancelWithSavepointFunc
• type CompareAndUpdateClusterStatusFunc
• type CompareAndUpdateJobStatusFunc
• type CreateClusterFunc
• type CreateIfNotExistFunc
• type DeleteClusterFunc
• type FindExternalizedCheckpointFunc
• type FlinkController
  • 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
• type GetCurrentAndOldDeploymentsForAppFunc
• type GetJobsForApplicationFunc
• type GetSavepointStatusFunc
• type IsClusterReadyFunc
• type IsServiceReadyFunc
• type JobManagerController
  • func (m *JobManagerController) CreateIfNotExist(ctx context.Context, application *v1alpha1.FlinkApplication) (bool, error)
• type StartFlinkJobFunc
• type TaskManagerController
  • func (m *TaskManagerController) CreateIfNotExist(ctx context.Context, application *v1alpha1.FlinkApplication) (bool, error)

Types

type CancelWithSavepointFunc

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

type CompareAndUpdateClusterStatusFunc

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

type CompareAndUpdateJobStatusFunc

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

type CreateClusterFunc

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

type CreateIfNotExistFunc

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

type DeleteClusterFunc

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

type FindExternalizedCheckpointFunc

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

type FlinkController

type FlinkController struct {
	CreateClusterFunc                     CreateClusterFunc
	DeleteClusterFunc                     DeleteClusterFunc
	CancelWithSavepointFunc               CancelWithSavepointFunc
	ForceCancelFunc                       ForceCancelFunc
	StartFlinkJobFunc                     StartFlinkJobFunc
	GetSavepointStatusFunc                GetSavepointStatusFunc
	IsClusterReadyFunc                    IsClusterReadyFunc
	IsServiceReadyFunc                    IsServiceReadyFunc
	GetJobsForApplicationFunc             GetJobsForApplicationFunc
	GetCurrentAndOldDeploymentsForAppFunc GetCurrentAndOldDeploymentsForAppFunc
	FindExternalizedCheckpointFunc        FindExternalizedCheckpointFunc
	Events                                []corev1.Event
	CompareAndUpdateClusterStatusFunc     CompareAndUpdateClusterStatusFunc
	CompareAndUpdateJobStatusFunc         CompareAndUpdateJobStatusFunc
}

func (*FlinkController) CancelWithSavepoint

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

func (*FlinkController) CompareAndUpdateClusterStatus

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

func (*FlinkController) CompareAndUpdateJobStatus

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

func (*FlinkController) CreateCluster

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

func (*FlinkController) DeleteCluster

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

func (*FlinkController) FindExternalizedCheckpoint

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

func (*FlinkController) ForceCancel

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

func (*FlinkController) GetCurrentAndOldDeploymentsForApp

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

func (*FlinkController) GetJobsForApplication

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

func (*FlinkController) GetSavepointStatus

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

func (*FlinkController) IsClusterReady

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

func (*FlinkController) IsServiceReady

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

func (*FlinkController) LogEvent

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

func (*FlinkController) StartFlinkJob

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

type ForceCancelFunc

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

type GetCurrentAndOldDeploymentsForAppFunc

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

type GetJobsForApplicationFunc

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

type GetSavepointStatusFunc

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

type IsClusterReadyFunc

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

type IsServiceReadyFunc

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

type JobManagerController

type JobManagerController struct {
	CreateIfNotExistFunc CreateIfNotExistFunc
}

func (*JobManagerController) CreateIfNotExist

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

type StartFlinkJobFunc

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

type TaskManagerController

type TaskManagerController struct {
	CreateIfNotExistFunc CreateIfNotExistFunc
}

func (*TaskManagerController) CreateIfNotExist

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