flinkapplicationdeployment

package
v0.2.0 Latest Latest
Warning

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

 Go to latest Published: Feb 20, 2024 License: Apache-2.0 Imports: 4 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type DeploymentOut 

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 

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

func NewHandler 

func NewHandler(doer doer) FlinkApplicationDeploymentHandler

func (*FlinkApplicationDeploymentHandler) ServiceFlinkCancelApplicationDeployment 

func (h *FlinkApplicationDeploymentHandler) ServiceFlinkCancelApplicationDeployment(ctx context.Context, project string, serviceName string, applicationId string, deploymentId string) (*ServiceFlinkCancelApplicationDeploymentOut, error)

func (*FlinkApplicationDeploymentHandler) ServiceFlinkCreateApplicationDeployment 

func (h *FlinkApplicationDeploymentHandler) ServiceFlinkCreateApplicationDeployment(ctx context.Context, project string, serviceName string, applicationId string, in *ServiceFlinkCreateApplicationDeploymentIn) (*ServiceFlinkCreateApplicationDeploymentOut, error)

func (*FlinkApplicationDeploymentHandler) ServiceFlinkDeleteApplicationDeployment 

func (h *FlinkApplicationDeploymentHandler) ServiceFlinkDeleteApplicationDeployment(ctx context.Context, project string, serviceName string, applicationId string, deploymentId string) (*ServiceFlinkDeleteApplicationDeploymentOut, error)

func (*FlinkApplicationDeploymentHandler) ServiceFlinkGetApplicationDeployment 

func (h *FlinkApplicationDeploymentHandler) ServiceFlinkGetApplicationDeployment(ctx context.Context, project string, serviceName string, applicationId string, deploymentId string) (*ServiceFlinkGetApplicationDeploymentOut, error)

func (*FlinkApplicationDeploymentHandler) ServiceFlinkListApplicationDeployments 

func (h *FlinkApplicationDeploymentHandler) ServiceFlinkListApplicationDeployments(ctx context.Context, project string, serviceName string, applicationId string) ([]DeploymentOut, error)

func (*FlinkApplicationDeploymentHandler) ServiceFlinkStopApplicationDeployment 

func (h *FlinkApplicationDeploymentHandler) ServiceFlinkStopApplicationDeployment(ctx context.Context, project string, serviceName string, applicationId string, deploymentId string) (*ServiceFlinkStopApplicationDeploymentOut, error)

type Handler 

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 

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 

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 

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 

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 

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 

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"`
}

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.