flinkjarapplicationdeployment

Documentation

Index

• func DeploymentStatusTypeChoices() []string
• func ServiceFlinkJarApplicationDeploymentStatusTypeChoices() []string
• type DeploymentOut
• type DeploymentStatusType
• type FlinkJarApplicationDeploymentHandler
  • func NewHandler(doer doer) FlinkJarApplicationDeploymentHandler
  • func (h *FlinkJarApplicationDeploymentHandler) ServiceFlinkCancelJarApplicationDeployment(ctx context.Context, project string, serviceName string, applicationId string, ...) (*ServiceFlinkCancelJarApplicationDeploymentOut, error)
  • func (h *FlinkJarApplicationDeploymentHandler) ServiceFlinkCreateJarApplicationDeployment(ctx context.Context, project string, serviceName string, applicationId string, ...) (*ServiceFlinkCreateJarApplicationDeploymentOut, error)
  • func (h *FlinkJarApplicationDeploymentHandler) ServiceFlinkDeleteJarApplicationDeployment(ctx context.Context, project string, serviceName string, applicationId string, ...) (*ServiceFlinkDeleteJarApplicationDeploymentOut, error)
  • func (h *FlinkJarApplicationDeploymentHandler) ServiceFlinkGetJarApplicationDeployment(ctx context.Context, project string, serviceName string, applicationId string, ...) (*ServiceFlinkGetJarApplicationDeploymentOut, error)
  • func (h *FlinkJarApplicationDeploymentHandler) ServiceFlinkListJarApplicationDeployments(ctx context.Context, project string, serviceName string, applicationId string) ([]DeploymentOut, error)
  • func (h *FlinkJarApplicationDeploymentHandler) ServiceFlinkStopJarApplicationDeployment(ctx context.Context, project string, serviceName string, applicationId string, ...) (*ServiceFlinkStopJarApplicationDeploymentOut, error)
• type Handler
• type ServiceFlinkCancelJarApplicationDeploymentOut
• type ServiceFlinkCreateJarApplicationDeploymentIn
• type ServiceFlinkCreateJarApplicationDeploymentOut
• type ServiceFlinkDeleteJarApplicationDeploymentOut
• type ServiceFlinkGetJarApplicationDeploymentOut
• type ServiceFlinkJarApplicationDeploymentStatusType
• type ServiceFlinkStopJarApplicationDeploymentOut

Functions

func DeploymentStatusTypeChoices

func DeploymentStatusTypeChoices() []string

func ServiceFlinkJarApplicationDeploymentStatusTypeChoices

func ServiceFlinkJarApplicationDeploymentStatusTypeChoices() []string

Types

type DeploymentOut

type DeploymentOut struct {
	CreatedAt         time.Time            `json:"created_at"`                   // Created at
	CreatedBy         string               `json:"created_by"`                   // Created by
	EntryClass        *string              `json:"entry_class,omitempty"`        // Entry class
	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
	ProgramArgs       []string             `json:"program_args,omitempty"`       // Program arguments. Arguments to pass during Flink job submission through the programArgsList parameter
	StartingSavepoint *string              `json:"starting_savepoint,omitempty"` // Job savepoint
	Status            DeploymentStatusType `json:"status"`                       // Deployment status
	VersionId         string               `json:"version_id"`                   // ApplicationVersion ID
}

type DeploymentStatusType

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 FlinkJarApplicationDeploymentHandler

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

func NewHandler

func NewHandler(doer doer) FlinkJarApplicationDeploymentHandler

func (*FlinkJarApplicationDeploymentHandler) ServiceFlinkCancelJarApplicationDeployment

func (h *FlinkJarApplicationDeploymentHandler) ServiceFlinkCancelJarApplicationDeployment(ctx context.Context, project string, serviceName string, applicationId string, deploymentId string) (*ServiceFlinkCancelJarApplicationDeploymentOut, error)

func (*FlinkJarApplicationDeploymentHandler) ServiceFlinkCreateJarApplicationDeployment

func (h *FlinkJarApplicationDeploymentHandler) ServiceFlinkCreateJarApplicationDeployment(ctx context.Context, project string, serviceName string, applicationId string, in *ServiceFlinkCreateJarApplicationDeploymentIn) (*ServiceFlinkCreateJarApplicationDeploymentOut, error)

func (*FlinkJarApplicationDeploymentHandler) ServiceFlinkDeleteJarApplicationDeployment

func (h *FlinkJarApplicationDeploymentHandler) ServiceFlinkDeleteJarApplicationDeployment(ctx context.Context, project string, serviceName string, applicationId string, deploymentId string) (*ServiceFlinkDeleteJarApplicationDeploymentOut, error)

func (*FlinkJarApplicationDeploymentHandler) ServiceFlinkGetJarApplicationDeployment

func (h *FlinkJarApplicationDeploymentHandler) ServiceFlinkGetJarApplicationDeployment(ctx context.Context, project string, serviceName string, applicationId string, deploymentId string) (*ServiceFlinkGetJarApplicationDeploymentOut, error)

func (*FlinkJarApplicationDeploymentHandler) ServiceFlinkListJarApplicationDeployments

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

func (*FlinkJarApplicationDeploymentHandler) ServiceFlinkStopJarApplicationDeployment

func (h *FlinkJarApplicationDeploymentHandler) ServiceFlinkStopJarApplicationDeployment(ctx context.Context, project string, serviceName string, applicationId string, deploymentId string) (*ServiceFlinkStopJarApplicationDeploymentOut, error)

type Handler

type Handler interface {
	// ServiceFlinkCancelJarApplicationDeployment [EXPERIMENTAL] Cancel a JarApplicationDeployment
	// POST /v1/project/{project}/service/{service_name}/flink/jar_application/{application_id}/deployment/{deployment_id}/cancel
	// https://api.aiven.io/doc/#tag/Service:_Flink/operation/ServiceFlinkCancelJarApplicationDeployment
	ServiceFlinkCancelJarApplicationDeployment(ctx context.Context, project string, serviceName string, applicationId string, deploymentId string) (*ServiceFlinkCancelJarApplicationDeploymentOut, error)

	// ServiceFlinkCreateJarApplicationDeployment [EXPERIMENTAL] Create an JarApplicationDeployment
	// POST /v1/project/{project}/service/{service_name}/flink/jar_application/{application_id}/deployment
	// https://api.aiven.io/doc/#tag/Service:_Flink/operation/ServiceFlinkCreateJarApplicationDeployment
	ServiceFlinkCreateJarApplicationDeployment(ctx context.Context, project string, serviceName string, applicationId string, in *ServiceFlinkCreateJarApplicationDeploymentIn) (*ServiceFlinkCreateJarApplicationDeploymentOut, error)

	// ServiceFlinkDeleteJarApplicationDeployment [EXPERIMENTAL] Delete a JarApplicationDeployment
	// DELETE /v1/project/{project}/service/{service_name}/flink/jar_application/{application_id}/deployment/{deployment_id}
	// https://api.aiven.io/doc/#tag/Service:_Flink/operation/ServiceFlinkDeleteJarApplicationDeployment
	ServiceFlinkDeleteJarApplicationDeployment(ctx context.Context, project string, serviceName string, applicationId string, deploymentId string) (*ServiceFlinkDeleteJarApplicationDeploymentOut, error)

	// ServiceFlinkGetJarApplicationDeployment [EXPERIMENTAL] Get a JarApplicationDeployment
	// GET /v1/project/{project}/service/{service_name}/flink/jar_application/{application_id}/deployment/{deployment_id}
	// https://api.aiven.io/doc/#tag/Service:_Flink/operation/ServiceFlinkGetJarApplicationDeployment
	ServiceFlinkGetJarApplicationDeployment(ctx context.Context, project string, serviceName string, applicationId string, deploymentId string) (*ServiceFlinkGetJarApplicationDeploymentOut, error)

	// ServiceFlinkListJarApplicationDeployments [EXPERIMENTAL] Get all JarApplicationDeployments
	// GET /v1/project/{project}/service/{service_name}/flink/jar_application/{application_id}/deployment
	// https://api.aiven.io/doc/#tag/Service:_Flink/operation/ServiceFlinkListJarApplicationDeployments
	ServiceFlinkListJarApplicationDeployments(ctx context.Context, project string, serviceName string, applicationId string) ([]DeploymentOut, error)

	// ServiceFlinkStopJarApplicationDeployment [EXPERIMENTAL] Stop an JarApplicationDeployment
	// POST /v1/project/{project}/service/{service_name}/flink/jar_application/{application_id}/deployment/{deployment_id}/stop
	// https://api.aiven.io/doc/#tag/Service:_Flink/operation/ServiceFlinkStopJarApplicationDeployment
	ServiceFlinkStopJarApplicationDeployment(ctx context.Context, project string, serviceName string, applicationId string, deploymentId string) (*ServiceFlinkStopJarApplicationDeploymentOut, error)
}

type ServiceFlinkCancelJarApplicationDeploymentOut

type ServiceFlinkCancelJarApplicationDeploymentOut struct {
	CreatedAt         time.Time                                      `json:"created_at"`                   // Created at
	CreatedBy         string                                         `json:"created_by"`                   // Created by
	EntryClass        *string                                        `json:"entry_class,omitempty"`        // Entry class
	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
	ProgramArgs       []string                                       `json:"program_args,omitempty"`       // Program arguments. Arguments to pass during Flink job submission through the programArgsList parameter
	StartingSavepoint *string                                        `json:"starting_savepoint,omitempty"` // Job savepoint
	Status            ServiceFlinkJarApplicationDeploymentStatusType `json:"status"`                       // Deployment status
	VersionId         string                                         `json:"version_id"`                   // ApplicationVersion ID
}

ServiceFlinkCancelJarApplicationDeploymentOut ServiceFlinkCancelJarApplicationDeploymentResponse

type ServiceFlinkCreateJarApplicationDeploymentIn

type ServiceFlinkCreateJarApplicationDeploymentIn struct {
	EntryClass        *string   `json:"entry_class,omitempty"`        // Entry class
	Parallelism       *int      `json:"parallelism,omitempty"`        // Flink Job parallelism
	ProgramArgs       *[]string `json:"program_args,omitempty"`       // Program arguments. Arguments to pass during Flink job submission through the programArgsList parameter
	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
}

ServiceFlinkCreateJarApplicationDeploymentIn ServiceFlinkCreateJarApplicationDeploymentRequestBody

type ServiceFlinkCreateJarApplicationDeploymentOut

type ServiceFlinkCreateJarApplicationDeploymentOut struct {
	CreatedAt         time.Time                                      `json:"created_at"`                   // Created at
	CreatedBy         string                                         `json:"created_by"`                   // Created by
	EntryClass        *string                                        `json:"entry_class,omitempty"`        // Entry class
	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
	ProgramArgs       []string                                       `json:"program_args,omitempty"`       // Program arguments. Arguments to pass during Flink job submission through the programArgsList parameter
	StartingSavepoint *string                                        `json:"starting_savepoint,omitempty"` // Job savepoint
	Status            ServiceFlinkJarApplicationDeploymentStatusType `json:"status"`                       // Deployment status
	VersionId         string                                         `json:"version_id"`                   // ApplicationVersion ID
}

ServiceFlinkCreateJarApplicationDeploymentOut ServiceFlinkCreateJarApplicationDeploymentResponse

type ServiceFlinkDeleteJarApplicationDeploymentOut

type ServiceFlinkDeleteJarApplicationDeploymentOut struct {
	CreatedAt         time.Time                                      `json:"created_at"`                   // Created at
	CreatedBy         string                                         `json:"created_by"`                   // Created by
	EntryClass        *string                                        `json:"entry_class,omitempty"`        // Entry class
	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
	ProgramArgs       []string                                       `json:"program_args,omitempty"`       // Program arguments. Arguments to pass during Flink job submission through the programArgsList parameter
	StartingSavepoint *string                                        `json:"starting_savepoint,omitempty"` // Job savepoint
	Status            ServiceFlinkJarApplicationDeploymentStatusType `json:"status"`                       // Deployment status
	VersionId         string                                         `json:"version_id"`                   // ApplicationVersion ID
}

ServiceFlinkDeleteJarApplicationDeploymentOut ServiceFlinkDeleteJarApplicationDeploymentResponse

type ServiceFlinkGetJarApplicationDeploymentOut

type ServiceFlinkGetJarApplicationDeploymentOut struct {
	CreatedAt         time.Time                                      `json:"created_at"`                   // Created at
	CreatedBy         string                                         `json:"created_by"`                   // Created by
	EntryClass        *string                                        `json:"entry_class,omitempty"`        // Entry class
	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
	ProgramArgs       []string                                       `json:"program_args,omitempty"`       // Program arguments. Arguments to pass during Flink job submission through the programArgsList parameter
	StartingSavepoint *string                                        `json:"starting_savepoint,omitempty"` // Job savepoint
	Status            ServiceFlinkJarApplicationDeploymentStatusType `json:"status"`                       // Deployment status
	VersionId         string                                         `json:"version_id"`                   // ApplicationVersion ID
}

ServiceFlinkGetJarApplicationDeploymentOut ServiceFlinkGetJarApplicationDeploymentResponse

type ServiceFlinkJarApplicationDeploymentStatusType

type ServiceFlinkJarApplicationDeploymentStatusType string

const (
	ServiceFlinkJarApplicationDeploymentStatusTypeInitializing           ServiceFlinkJarApplicationDeploymentStatusType = "INITIALIZING"
	ServiceFlinkJarApplicationDeploymentStatusTypeCreated                ServiceFlinkJarApplicationDeploymentStatusType = "CREATED"
	ServiceFlinkJarApplicationDeploymentStatusTypeRunning                ServiceFlinkJarApplicationDeploymentStatusType = "RUNNING"
	ServiceFlinkJarApplicationDeploymentStatusTypeFailing                ServiceFlinkJarApplicationDeploymentStatusType = "FAILING"
	ServiceFlinkJarApplicationDeploymentStatusTypeFailed                 ServiceFlinkJarApplicationDeploymentStatusType = "FAILED"
	ServiceFlinkJarApplicationDeploymentStatusTypeSaving                 ServiceFlinkJarApplicationDeploymentStatusType = "SAVING"
	ServiceFlinkJarApplicationDeploymentStatusTypeCancellingRequested    ServiceFlinkJarApplicationDeploymentStatusType = "CANCELLING_REQUESTED"
	ServiceFlinkJarApplicationDeploymentStatusTypeCancelling             ServiceFlinkJarApplicationDeploymentStatusType = "CANCELLING"
	ServiceFlinkJarApplicationDeploymentStatusTypeCanceled               ServiceFlinkJarApplicationDeploymentStatusType = "CANCELED"
	ServiceFlinkJarApplicationDeploymentStatusTypeSavingAndStopRequested ServiceFlinkJarApplicationDeploymentStatusType = "SAVING_AND_STOP_REQUESTED"
	ServiceFlinkJarApplicationDeploymentStatusTypeSavingAndStop          ServiceFlinkJarApplicationDeploymentStatusType = "SAVING_AND_STOP"
	ServiceFlinkJarApplicationDeploymentStatusTypeFinished               ServiceFlinkJarApplicationDeploymentStatusType = "FINISHED"
	ServiceFlinkJarApplicationDeploymentStatusTypeRestarting             ServiceFlinkJarApplicationDeploymentStatusType = "RESTARTING"
	ServiceFlinkJarApplicationDeploymentStatusTypeSuspended              ServiceFlinkJarApplicationDeploymentStatusType = "SUSPENDED"
	ServiceFlinkJarApplicationDeploymentStatusTypeDeleteRequested        ServiceFlinkJarApplicationDeploymentStatusType = "DELETE_REQUESTED"
	ServiceFlinkJarApplicationDeploymentStatusTypeDeleting               ServiceFlinkJarApplicationDeploymentStatusType = "DELETING"
	ServiceFlinkJarApplicationDeploymentStatusTypeReconciling            ServiceFlinkJarApplicationDeploymentStatusType = "RECONCILING"
)

type ServiceFlinkStopJarApplicationDeploymentOut

type ServiceFlinkStopJarApplicationDeploymentOut struct {
	CreatedAt         time.Time                                      `json:"created_at"`                   // Created at
	CreatedBy         string                                         `json:"created_by"`                   // Created by
	EntryClass        *string                                        `json:"entry_class,omitempty"`        // Entry class
	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
	ProgramArgs       []string                                       `json:"program_args,omitempty"`       // Program arguments. Arguments to pass during Flink job submission through the programArgsList parameter
	StartingSavepoint *string                                        `json:"starting_savepoint,omitempty"` // Job savepoint
	Status            ServiceFlinkJarApplicationDeploymentStatusType `json:"status"`                       // Deployment status
	VersionId         string                                         `json:"version_id"`                   // ApplicationVersion ID
}

ServiceFlinkStopJarApplicationDeploymentOut ServiceFlinkStopJarApplicationDeploymentResponse