flinkapplicationdeployment

package
v0.18.0 Latest Latest
Warning

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

 Go to latest Published: Jul 18, 2024 License: Apache-2.0 Imports: 5 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func DeploymentStatusTypeChoices added in v0.3.0 

func DeploymentStatusTypeChoices() []string

func ServiceFlinkApplicationDeploymentStatusTypeChoices added in v0.3.0 

func ServiceFlinkApplicationDeploymentStatusTypeChoices() []string

Types

type DeploymentOut 

type DeploymentOut struct {
	CreatedAt         time.Time            `json:"created_at"`                   // Created at
	CreatedBy         string               `json:"created_by"`                   // Created by
	ErrorMsg          *string              `json:"error_msg,omitempty"`          // Deployment error
	Id                string               `json:"id"`                           // Deployment ID
	JobId             *string              `json:"job_id,omitempty"`             // Job ID
	LastSavepoint     *string              `json:"last_savepoint,omitempty"`     // Job savepoint
	Parallelism       int                  `json:"parallelism"`                  // Flink Job parallelism
	RestartEnabled    bool                 `json:"restart_enabled"`              // Specifies whether a Flink Job is restarted in case it fails
	StartingSavepoint *string              `json:"starting_savepoint,omitempty"` // Job savepoint
	Status            DeploymentStatusType `json:"status"`                       // Deployment status
	VersionId         string               `json:"version_id"`                   // ApplicationVersion ID
}

type DeploymentStatusType added in v0.3.0 

type DeploymentStatusType string
const (
	DeploymentStatusTypeInitializing           DeploymentStatusType = "INITIALIZING"
	DeploymentStatusTypeCreated                DeploymentStatusType = "CREATED"
	DeploymentStatusTypeRunning                DeploymentStatusType = "RUNNING"
	DeploymentStatusTypeFailing                DeploymentStatusType = "FAILING"
	DeploymentStatusTypeFailed                 DeploymentStatusType = "FAILED"
	DeploymentStatusTypeSaving                 DeploymentStatusType = "SAVING"
	DeploymentStatusTypeCancellingRequested    DeploymentStatusType = "CANCELLING_REQUESTED"
	DeploymentStatusTypeCancelling             DeploymentStatusType = "CANCELLING"
	DeploymentStatusTypeCanceled               DeploymentStatusType = "CANCELED"
	DeploymentStatusTypeSavingAndStopRequested DeploymentStatusType = "SAVING_AND_STOP_REQUESTED"
	DeploymentStatusTypeSavingAndStop          DeploymentStatusType = "SAVING_AND_STOP"
	DeploymentStatusTypeFinished               DeploymentStatusType = "FINISHED"
	DeploymentStatusTypeRestarting             DeploymentStatusType = "RESTARTING"
	DeploymentStatusTypeSuspended              DeploymentStatusType = "SUSPENDED"
	DeploymentStatusTypeDeleteRequested        DeploymentStatusType = "DELETE_REQUESTED"
	DeploymentStatusTypeDeleting               DeploymentStatusType = "DELETING"
	DeploymentStatusTypeReconciling            DeploymentStatusType = "RECONCILING"
)

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 /v1/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 /v1/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 /v1/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 /v1/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 /v1/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 /v1/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 ServiceFlinkApplicationDeploymentStatusType added in v0.3.0 

type ServiceFlinkApplicationDeploymentStatusType string
const (
	ServiceFlinkApplicationDeploymentStatusTypeInitializing           ServiceFlinkApplicationDeploymentStatusType = "INITIALIZING"
	ServiceFlinkApplicationDeploymentStatusTypeCreated                ServiceFlinkApplicationDeploymentStatusType = "CREATED"
	ServiceFlinkApplicationDeploymentStatusTypeRunning                ServiceFlinkApplicationDeploymentStatusType = "RUNNING"
	ServiceFlinkApplicationDeploymentStatusTypeFailing                ServiceFlinkApplicationDeploymentStatusType = "FAILING"
	ServiceFlinkApplicationDeploymentStatusTypeFailed                 ServiceFlinkApplicationDeploymentStatusType = "FAILED"
	ServiceFlinkApplicationDeploymentStatusTypeSaving                 ServiceFlinkApplicationDeploymentStatusType = "SAVING"
	ServiceFlinkApplicationDeploymentStatusTypeCancellingRequested    ServiceFlinkApplicationDeploymentStatusType = "CANCELLING_REQUESTED"
	ServiceFlinkApplicationDeploymentStatusTypeCancelling             ServiceFlinkApplicationDeploymentStatusType = "CANCELLING"
	ServiceFlinkApplicationDeploymentStatusTypeCanceled               ServiceFlinkApplicationDeploymentStatusType = "CANCELED"
	ServiceFlinkApplicationDeploymentStatusTypeSavingAndStopRequested ServiceFlinkApplicationDeploymentStatusType = "SAVING_AND_STOP_REQUESTED"
	ServiceFlinkApplicationDeploymentStatusTypeSavingAndStop          ServiceFlinkApplicationDeploymentStatusType = "SAVING_AND_STOP"
	ServiceFlinkApplicationDeploymentStatusTypeFinished               ServiceFlinkApplicationDeploymentStatusType = "FINISHED"
	ServiceFlinkApplicationDeploymentStatusTypeRestarting             ServiceFlinkApplicationDeploymentStatusType = "RESTARTING"
	ServiceFlinkApplicationDeploymentStatusTypeSuspended              ServiceFlinkApplicationDeploymentStatusType = "SUSPENDED"
	ServiceFlinkApplicationDeploymentStatusTypeDeleteRequested        ServiceFlinkApplicationDeploymentStatusType = "DELETE_REQUESTED"
	ServiceFlinkApplicationDeploymentStatusTypeDeleting               ServiceFlinkApplicationDeploymentStatusType = "DELETING"
	ServiceFlinkApplicationDeploymentStatusTypeReconciling            ServiceFlinkApplicationDeploymentStatusType = "RECONCILING"
)

type ServiceFlinkCancelApplicationDeploymentOut 

type ServiceFlinkCancelApplicationDeploymentOut struct {
	CreatedAt         time.Time                                   `json:"created_at"`                   // Created at
	CreatedBy         string                                      `json:"created_by"`                   // Created by
	ErrorMsg          *string                                     `json:"error_msg,omitempty"`          // Deployment error
	Id                string                                      `json:"id"`                           // Deployment ID
	JobId             *string                                     `json:"job_id,omitempty"`             // Job ID
	LastSavepoint     *string                                     `json:"last_savepoint,omitempty"`     // Job savepoint
	Parallelism       int                                         `json:"parallelism"`                  // Flink Job parallelism
	RestartEnabled    bool                                        `json:"restart_enabled"`              // Specifies whether a Flink Job is restarted in case it fails
	StartingSavepoint *string                                     `json:"starting_savepoint,omitempty"` // Job savepoint
	Status            ServiceFlinkApplicationDeploymentStatusType `json:"status"`                       // Deployment status
	VersionId         string                                      `json:"version_id"`                   // ApplicationVersion ID
}

ServiceFlinkCancelApplicationDeploymentOut ServiceFlinkCancelApplicationDeploymentResponse

type ServiceFlinkCreateApplicationDeploymentIn 

type ServiceFlinkCreateApplicationDeploymentIn struct {
	Parallelism       *int    `json:"parallelism,omitempty"`        // Flink Job parallelism
	RestartEnabled    *bool   `json:"restart_enabled,omitempty"`    // Specifies whether a Flink Job is restarted in case it fails
	StartingSavepoint *string `json:"starting_savepoint,omitempty"` // Job savepoint
	VersionId         string  `json:"version_id"`                   // ApplicationVersion ID
}

ServiceFlinkCreateApplicationDeploymentIn ServiceFlinkCreateApplicationDeploymentRequestBody

type ServiceFlinkCreateApplicationDeploymentOut 

type ServiceFlinkCreateApplicationDeploymentOut struct {
	CreatedAt         time.Time                                   `json:"created_at"`                   // Created at
	CreatedBy         string                                      `json:"created_by"`                   // Created by
	ErrorMsg          *string                                     `json:"error_msg,omitempty"`          // Deployment error
	Id                string                                      `json:"id"`                           // Deployment ID
	JobId             *string                                     `json:"job_id,omitempty"`             // Job ID
	LastSavepoint     *string                                     `json:"last_savepoint,omitempty"`     // Job savepoint
	Parallelism       int                                         `json:"parallelism"`                  // Flink Job parallelism
	RestartEnabled    bool                                        `json:"restart_enabled"`              // Specifies whether a Flink Job is restarted in case it fails
	StartingSavepoint *string                                     `json:"starting_savepoint,omitempty"` // Job savepoint
	Status            ServiceFlinkApplicationDeploymentStatusType `json:"status"`                       // Deployment status
	VersionId         string                                      `json:"version_id"`                   // ApplicationVersion ID
}

ServiceFlinkCreateApplicationDeploymentOut ServiceFlinkCreateApplicationDeploymentResponse

type ServiceFlinkDeleteApplicationDeploymentOut 

type ServiceFlinkDeleteApplicationDeploymentOut struct {
	CreatedAt         time.Time                                   `json:"created_at"`                   // Created at
	CreatedBy         string                                      `json:"created_by"`                   // Created by
	ErrorMsg          *string                                     `json:"error_msg,omitempty"`          // Deployment error
	Id                string                                      `json:"id"`                           // Deployment ID
	JobId             *string                                     `json:"job_id,omitempty"`             // Job ID
	LastSavepoint     *string                                     `json:"last_savepoint,omitempty"`     // Job savepoint
	Parallelism       int                                         `json:"parallelism"`                  // Flink Job parallelism
	RestartEnabled    bool                                        `json:"restart_enabled"`              // Specifies whether a Flink Job is restarted in case it fails
	StartingSavepoint *string                                     `json:"starting_savepoint,omitempty"` // Job savepoint
	Status            ServiceFlinkApplicationDeploymentStatusType `json:"status"`                       // Deployment status
	VersionId         string                                      `json:"version_id"`                   // ApplicationVersion ID
}

ServiceFlinkDeleteApplicationDeploymentOut ServiceFlinkDeleteApplicationDeploymentResponse

type ServiceFlinkGetApplicationDeploymentOut 

type ServiceFlinkGetApplicationDeploymentOut struct {
	CreatedAt         time.Time                                   `json:"created_at"`                   // Created at
	CreatedBy         string                                      `json:"created_by"`                   // Created by
	ErrorMsg          *string                                     `json:"error_msg,omitempty"`          // Deployment error
	Id                string                                      `json:"id"`                           // Deployment ID
	JobId             *string                                     `json:"job_id,omitempty"`             // Job ID
	LastSavepoint     *string                                     `json:"last_savepoint,omitempty"`     // Job savepoint
	Parallelism       int                                         `json:"parallelism"`                  // Flink Job parallelism
	RestartEnabled    bool                                        `json:"restart_enabled"`              // Specifies whether a Flink Job is restarted in case it fails
	StartingSavepoint *string                                     `json:"starting_savepoint,omitempty"` // Job savepoint
	Status            ServiceFlinkApplicationDeploymentStatusType `json:"status"`                       // Deployment status
	VersionId         string                                      `json:"version_id"`                   // ApplicationVersion ID
}

ServiceFlinkGetApplicationDeploymentOut ServiceFlinkGetApplicationDeploymentResponse

type ServiceFlinkStopApplicationDeploymentOut 

type ServiceFlinkStopApplicationDeploymentOut struct {
	CreatedAt         time.Time                                   `json:"created_at"`                   // Created at
	CreatedBy         string                                      `json:"created_by"`                   // Created by
	ErrorMsg          *string                                     `json:"error_msg,omitempty"`          // Deployment error
	Id                string                                      `json:"id"`                           // Deployment ID
	JobId             *string                                     `json:"job_id,omitempty"`             // Job ID
	LastSavepoint     *string                                     `json:"last_savepoint,omitempty"`     // Job savepoint
	Parallelism       int                                         `json:"parallelism"`                  // Flink Job parallelism
	RestartEnabled    bool                                        `json:"restart_enabled"`              // Specifies whether a Flink Job is restarted in case it fails
	StartingSavepoint *string                                     `json:"starting_savepoint,omitempty"` // Job savepoint
	Status            ServiceFlinkApplicationDeploymentStatusType `json:"status"`                       // Deployment status
	VersionId         string                                      `json:"version_id"`                   // ApplicationVersion ID
}

ServiceFlinkStopApplicationDeploymentOut ServiceFlinkStopApplicationDeploymentResponse

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.