mock

Documentation

Index

• type CancelJobWithSavepointFunc
• type CheckSavepointStatusFunc
• type ForceCancelJobFunc
• type GetCheckpointCountsFunc
• type GetClusterOverviewFunc
• type GetJobConfigFunc
• type GetJobOverviewFunc
• type GetJobsFunc
• type GetLatestCheckpointFunc
• type GetTaskManagersFunc
• type JobManagerClient
  • func (m *JobManagerClient) CancelJobWithSavepoint(ctx context.Context, url string, jobID string) (string, error)
  • func (m *JobManagerClient) CheckSavepointStatus(ctx context.Context, url string, jobID, triggerID string) (*client.SavepointResponse, error)
  • func (m *JobManagerClient) ForceCancelJob(ctx context.Context, url string, jobID string) error
  • func (m *JobManagerClient) GetCheckpointCounts(ctx context.Context, url string, jobID string) (*client.CheckpointResponse, error)
  • func (m *JobManagerClient) GetClusterOverview(ctx context.Context, url string) (*client.ClusterOverviewResponse, error)
  • func (m *JobManagerClient) GetJobConfig(ctx context.Context, url string, jobID string) (*client.JobConfigResponse, error)
  • func (m *JobManagerClient) GetJobOverview(ctx context.Context, url string, jobID string) (*client.FlinkJobOverview, error)
  • func (m *JobManagerClient) GetJobs(ctx context.Context, url string) (*client.GetJobsResponse, error)
  • func (m *JobManagerClient) GetLatestCheckpoint(ctx context.Context, url string, jobID string) (*client.CheckpointStatistics, error)
  • func (m *JobManagerClient) GetTaskManagers(ctx context.Context, url string) (*client.TaskManagersResponse, error)
  • func (m *JobManagerClient) SavepointJob(ctx context.Context, url string, jobID string) (string, error)
  • func (m *JobManagerClient) SubmitJob(ctx context.Context, url string, jarID string, ...) (*client.SubmitJobResponse, error)
• type SavepointJobFunc
• type SubmitJobFunc

Types

type CancelJobWithSavepointFunc

type CancelJobWithSavepointFunc func(ctx context.Context, url string, jobID string) (string, error)

type CheckSavepointStatusFunc

type CheckSavepointStatusFunc func(ctx context.Context, url string, jobID, triggerID string) (*client.SavepointResponse, error)

type ForceCancelJobFunc

type ForceCancelJobFunc func(ctx context.Context, url string, jobID string) error

type GetCheckpointCountsFunc

type GetCheckpointCountsFunc func(ctx context.Context, url string, jobID string) (*client.CheckpointResponse, error)

type GetClusterOverviewFunc

type GetClusterOverviewFunc func(ctx context.Context, url string) (*client.ClusterOverviewResponse, error)

type GetJobConfigFunc

type GetJobConfigFunc func(ctx context.Context, url string, jobID string) (*client.JobConfigResponse, error)

type GetJobOverviewFunc

type GetJobOverviewFunc func(ctx context.Context, url string, jobID string) (*client.FlinkJobOverview, error)

type GetJobsFunc

type GetJobsFunc func(ctx context.Context, url string) (*client.GetJobsResponse, error)

type GetLatestCheckpointFunc

type GetLatestCheckpointFunc func(ctx context.Context, url string, jobID string) (*client.CheckpointStatistics, error)

type GetTaskManagersFunc

type GetTaskManagersFunc func(ctx context.Context, url string) (*client.TaskManagersResponse, error)

type JobManagerClient

type JobManagerClient struct {
	CancelJobWithSavepointFunc CancelJobWithSavepointFunc
	ForceCancelJobFunc         ForceCancelJobFunc
	SubmitJobFunc              SubmitJobFunc
	CheckSavepointStatusFunc   CheckSavepointStatusFunc
	GetJobsFunc                GetJobsFunc
	GetClusterOverviewFunc     GetClusterOverviewFunc
	GetJobConfigFunc           GetJobConfigFunc
	GetLatestCheckpointFunc    GetLatestCheckpointFunc
	GetTaskManagersFunc        GetTaskManagersFunc
	GetCheckpointCountsFunc    GetCheckpointCountsFunc
	GetJobOverviewFunc         GetJobOverviewFunc
	SavepointJobFunc           SavepointJobFunc
}

func (*JobManagerClient) CancelJobWithSavepoint

func (m *JobManagerClient) CancelJobWithSavepoint(ctx context.Context, url string, jobID string) (string, error)

func (*JobManagerClient) CheckSavepointStatus

func (m *JobManagerClient) CheckSavepointStatus(ctx context.Context, url string, jobID, triggerID string) (*client.SavepointResponse, error)

func (*JobManagerClient) ForceCancelJob

func (m *JobManagerClient) ForceCancelJob(ctx context.Context, url string, jobID string) error

func (*JobManagerClient) GetCheckpointCounts

func (m *JobManagerClient) GetCheckpointCounts(ctx context.Context, url string, jobID string) (*client.CheckpointResponse, error)

func (*JobManagerClient) GetClusterOverview

func (m *JobManagerClient) GetClusterOverview(ctx context.Context, url string) (*client.ClusterOverviewResponse, error)

func (*JobManagerClient) GetJobConfig

func (m *JobManagerClient) GetJobConfig(ctx context.Context, url string, jobID string) (*client.JobConfigResponse, error)

func (*JobManagerClient) GetJobOverview

func (m *JobManagerClient) GetJobOverview(ctx context.Context, url string, jobID string) (*client.FlinkJobOverview, error)

func (*JobManagerClient) GetJobs

func (m *JobManagerClient) GetJobs(ctx context.Context, url string) (*client.GetJobsResponse, error)

func (*JobManagerClient) GetLatestCheckpoint

func (m *JobManagerClient) GetLatestCheckpoint(ctx context.Context, url string, jobID string) (*client.CheckpointStatistics, error)

func (*JobManagerClient) GetTaskManagers

func (m *JobManagerClient) GetTaskManagers(ctx context.Context, url string) (*client.TaskManagersResponse, error)

func (*JobManagerClient) SavepointJob

func (m *JobManagerClient) SavepointJob(ctx context.Context, url string, jobID string) (string, error)

func (*JobManagerClient) SubmitJob

func (m *JobManagerClient) SubmitJob(ctx context.Context, url string, jarID string, submitJobRequest client.SubmitJobRequest) (*client.SubmitJobResponse, error)

type SavepointJobFunc

type SavepointJobFunc func(ctx context.Context, url string, jobID string) (string, error)

type SubmitJobFunc

type SubmitJobFunc func(ctx context.Context, url string, jarID string, submitJobRequest client.SubmitJobRequest) (*client.SubmitJobResponse, error)