flinkapplicationdeployment

type DeploymentOut struct {
	CreatedAt         time.Time `json:"created_at"`
	CreatedBy         string    `json:"created_by"`
	ErrorMsg          string    `json:"error_msg,omitempty"`
	Id                string    `json:"id"`
	JobId             string    `json:"job_id,omitempty"`
	LastSavepoint     string    `json:"last_savepoint,omitempty"`
	Parallelism       int       `json:"parallelism"`
	RestartEnabled    bool      `json:"restart_enabled"`
	StartingSavepoint string    `json:"starting_savepoint,omitempty"`
	Status            string    `json:"status"`
	VersionId         string    `json:"version_id"`
}

type FlinkApplicationDeploymentHandler struct {
	// contains filtered or unexported fields
}

type Handler interface {
	// ServiceFlinkCancelApplicationDeployment cancel an ApplicationDeployment
	// POST /project/{project}/service/{service_name}/flink/application/{application_id}/deployment/{deployment_id}/cancel
	// https://api.aiven.io/doc/#tag/Service:_Flink/operation/ServiceFlinkCancelApplicationDeployment
	ServiceFlinkCancelApplicationDeployment(ctx context.Context, project string, serviceName string, applicationId string, deploymentId string) (*ServiceFlinkCancelApplicationDeploymentOut, error)

	// ServiceFlinkCreateApplicationDeployment create an ApplicationDeployment
	// POST /project/{project}/service/{service_name}/flink/application/{application_id}/deployment
	// https://api.aiven.io/doc/#tag/Service:_Flink/operation/ServiceFlinkCreateApplicationDeployment
	ServiceFlinkCreateApplicationDeployment(ctx context.Context, project string, serviceName string, applicationId string, in *ServiceFlinkCreateApplicationDeploymentIn) (*ServiceFlinkCreateApplicationDeploymentOut, error)

	// ServiceFlinkDeleteApplicationDeployment delete an ApplicationDeployment
	// DELETE /project/{project}/service/{service_name}/flink/application/{application_id}/deployment/{deployment_id}
	// https://api.aiven.io/doc/#tag/Service:_Flink/operation/ServiceFlinkDeleteApplicationDeployment
	ServiceFlinkDeleteApplicationDeployment(ctx context.Context, project string, serviceName string, applicationId string, deploymentId string) (*ServiceFlinkDeleteApplicationDeploymentOut, error)

	// ServiceFlinkGetApplicationDeployment get an ApplicationDeployment
	// GET /project/{project}/service/{service_name}/flink/application/{application_id}/deployment/{deployment_id}
	// https://api.aiven.io/doc/#tag/Service:_Flink/operation/ServiceFlinkGetApplicationDeployment
	ServiceFlinkGetApplicationDeployment(ctx context.Context, project string, serviceName string, applicationId string, deploymentId string) (*ServiceFlinkGetApplicationDeploymentOut, error)

	// ServiceFlinkListApplicationDeployments get all ApplicationDeployments
	// GET /project/{project}/service/{service_name}/flink/application/{application_id}/deployment
	// https://api.aiven.io/doc/#tag/Service:_Flink/operation/ServiceFlinkListApplicationDeployments
	ServiceFlinkListApplicationDeployments(ctx context.Context, project string, serviceName string, applicationId string) ([]DeploymentOut, error)

	// ServiceFlinkStopApplicationDeployment stop an ApplicationDeployment
	// POST /project/{project}/service/{service_name}/flink/application/{application_id}/deployment/{deployment_id}/stop
	// https://api.aiven.io/doc/#tag/Service:_Flink/operation/ServiceFlinkStopApplicationDeployment
	ServiceFlinkStopApplicationDeployment(ctx context.Context, project string, serviceName string, applicationId string, deploymentId string) (*ServiceFlinkStopApplicationDeploymentOut, error)
}

type ServiceFlinkCancelApplicationDeploymentOut struct {
	CreatedAt         time.Time `json:"created_at"`
	CreatedBy         string    `json:"created_by"`
	ErrorMsg          string    `json:"error_msg,omitempty"`
	Id                string    `json:"id"`
	JobId             string    `json:"job_id,omitempty"`
	LastSavepoint     string    `json:"last_savepoint,omitempty"`
	Parallelism       int       `json:"parallelism"`
	RestartEnabled    bool      `json:"restart_enabled"`
	StartingSavepoint string    `json:"starting_savepoint,omitempty"`
	Status            string    `json:"status"`
	VersionId         string    `json:"version_id"`
}

type ServiceFlinkCreateApplicationDeploymentIn struct {
	Parallelism       *int   `json:"parallelism,omitempty"`
	RestartEnabled    *bool  `json:"restart_enabled,omitempty"`
	StartingSavepoint string `json:"starting_savepoint,omitempty"`
	VersionId         string `json:"version_id"`
}

type ServiceFlinkCreateApplicationDeploymentOut struct {
	CreatedAt         time.Time `json:"created_at"`
	CreatedBy         string    `json:"created_by"`
	ErrorMsg          string    `json:"error_msg,omitempty"`
	Id                string    `json:"id"`
	JobId             string    `json:"job_id,omitempty"`
	LastSavepoint     string    `json:"last_savepoint,omitempty"`
	Parallelism       int       `json:"parallelism"`
	RestartEnabled    bool      `json:"restart_enabled"`
	StartingSavepoint string    `json:"starting_savepoint,omitempty"`
	Status            string    `json:"status"`
	VersionId         string    `json:"version_id"`
}

type ServiceFlinkDeleteApplicationDeploymentOut struct {
	CreatedAt         time.Time `json:"created_at"`
	CreatedBy         string    `json:"created_by"`
	ErrorMsg          string    `json:"error_msg,omitempty"`
	Id                string    `json:"id"`
	JobId             string    `json:"job_id,omitempty"`
	LastSavepoint     string    `json:"last_savepoint,omitempty"`
	Parallelism       int       `json:"parallelism"`
	RestartEnabled    bool      `json:"restart_enabled"`
	StartingSavepoint string    `json:"starting_savepoint,omitempty"`
	Status            string    `json:"status"`
	VersionId         string    `json:"version_id"`
}

type ServiceFlinkGetApplicationDeploymentOut struct {
	CreatedAt         time.Time `json:"created_at"`
	CreatedBy         string    `json:"created_by"`
	ErrorMsg          string    `json:"error_msg,omitempty"`
	Id                string    `json:"id"`
	JobId             string    `json:"job_id,omitempty"`
	LastSavepoint     string    `json:"last_savepoint,omitempty"`
	Parallelism       int       `json:"parallelism"`
	RestartEnabled    bool      `json:"restart_enabled"`
	StartingSavepoint string    `json:"starting_savepoint,omitempty"`
	Status            string    `json:"status"`
	VersionId         string    `json:"version_id"`
}

type ServiceFlinkStopApplicationDeploymentOut struct {
	CreatedAt         time.Time `json:"created_at"`
	CreatedBy         string    `json:"created_by"`
	ErrorMsg          string    `json:"error_msg,omitempty"`
	Id                string    `json:"id"`
	JobId             string    `json:"job_id,omitempty"`
	LastSavepoint     string    `json:"last_savepoint,omitempty"`
	Parallelism       int       `json:"parallelism"`
	RestartEnabled    bool      `json:"restart_enabled"`
	StartingSavepoint string    `json:"starting_savepoint,omitempty"`
	Status            string    `json:"status"`
	VersionId         string    `json:"version_id"`
}