flinkjarapplication

package
v0.73.0 Latest Latest
Warning

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

 Go to latest Published: Dec 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 CurrentDeploymentStatusTypeChoices 

func CurrentDeploymentStatusTypeChoices() []string

func FileStatusTypeChoices 

func FileStatusTypeChoices() []string

func VerifyErrorCodeTypeChoices 

func VerifyErrorCodeTypeChoices() []int

Types

type ApplicationOut 

type ApplicationOut struct {
	CreatedAt *time.Time `json:"created_at,omitempty"` // Created at
	CreatedBy *string    `json:"created_by,omitempty"` // Created by
	Id        string     `json:"id"`                   // Application ID
	Name      string     `json:"name"`                 // Application name
	UpdatedAt *time.Time `json:"updated_at,omitempty"` // Updated at
	UpdatedBy *string    `json:"updated_by,omitempty"` // Updated by
}

type ApplicationVersionOut 

type ApplicationVersionOut struct {
	CreatedAt time.Time    `json:"created_at"`          // Created at
	CreatedBy string       `json:"created_by"`          // Created by
	FileInfo  *FileInfoOut `json:"file_info,omitempty"` // Flink JarApplicationVersion FileInfo
	Id        string       `json:"id"`                  // ApplicationVersion ID
	Version   int          `json:"version"`             // Version number
}

type CurrentDeploymentOut 

type CurrentDeploymentOut 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            CurrentDeploymentStatusType `json:"status"`                       // Deployment status
	VersionId         string                      `json:"version_id"`                   // ApplicationVersion ID
}

CurrentDeploymentOut Flink JarApplicationDeployment

type CurrentDeploymentStatusType 

type CurrentDeploymentStatusType string
const (
	CurrentDeploymentStatusTypeInitializing           CurrentDeploymentStatusType = "INITIALIZING"
	CurrentDeploymentStatusTypeCreated                CurrentDeploymentStatusType = "CREATED"
	CurrentDeploymentStatusTypeRunning                CurrentDeploymentStatusType = "RUNNING"
	CurrentDeploymentStatusTypeFailing                CurrentDeploymentStatusType = "FAILING"
	CurrentDeploymentStatusTypeFailed                 CurrentDeploymentStatusType = "FAILED"
	CurrentDeploymentStatusTypeSaving                 CurrentDeploymentStatusType = "SAVING"
	CurrentDeploymentStatusTypeCancellingRequested    CurrentDeploymentStatusType = "CANCELLING_REQUESTED"
	CurrentDeploymentStatusTypeCancelling             CurrentDeploymentStatusType = "CANCELLING"
	CurrentDeploymentStatusTypeCanceled               CurrentDeploymentStatusType = "CANCELED"
	CurrentDeploymentStatusTypeSavingAndStopRequested CurrentDeploymentStatusType = "SAVING_AND_STOP_REQUESTED"
	CurrentDeploymentStatusTypeSavingAndStop          CurrentDeploymentStatusType = "SAVING_AND_STOP"
	CurrentDeploymentStatusTypeFinished               CurrentDeploymentStatusType = "FINISHED"
	CurrentDeploymentStatusTypeRestarting             CurrentDeploymentStatusType = "RESTARTING"
	CurrentDeploymentStatusTypeSuspended              CurrentDeploymentStatusType = "SUSPENDED"
	CurrentDeploymentStatusTypeDeleteRequested        CurrentDeploymentStatusType = "DELETE_REQUESTED"
	CurrentDeploymentStatusTypeDeleting               CurrentDeploymentStatusType = "DELETING"
	CurrentDeploymentStatusTypeReconciling            CurrentDeploymentStatusType = "RECONCILING"
)

type FileInfoOut 

type FileInfoOut struct {
	FileSha256         *string             `json:"file_sha256,omitempty"`          // sha256 of the file if known
	FileSize           *int                `json:"file_size,omitempty"`            // The size of the file in bytes
	FileStatus         FileStatusType      `json:"file_status,omitempty"`          // File status
	Url                *string             `json:"url,omitempty"`                  // AWS s3 pre-signed url
	VerifyErrorCode    VerifyErrorCodeType `json:"verify_error_code,omitempty"`    // Verify error code
	VerifyErrorMessage *string             `json:"verify_error_message,omitempty"` // Verify error message
}

FileInfoOut Flink JarApplicationVersion FileInfo

type FileStatusType 

type FileStatusType string
const (
	FileStatusTypeInitial FileStatusType = "INITIAL"
	FileStatusTypeReady   FileStatusType = "READY"
	FileStatusTypeFailed  FileStatusType = "FAILED"
)

type FlinkJarApplicationHandler 

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

func NewHandler 

func NewHandler(doer doer) FlinkJarApplicationHandler

func (*FlinkJarApplicationHandler) ServiceFlinkCreateJarApplication 

func (h *FlinkJarApplicationHandler) ServiceFlinkCreateJarApplication(ctx context.Context, project string, serviceName string, in *ServiceFlinkCreateJarApplicationIn) (*ServiceFlinkCreateJarApplicationOut, error)

func (*FlinkJarApplicationHandler) ServiceFlinkDeleteJarApplication 

func (h *FlinkJarApplicationHandler) ServiceFlinkDeleteJarApplication(ctx context.Context, project string, serviceName string, applicationId string) (*ServiceFlinkDeleteJarApplicationOut, error)

func (*FlinkJarApplicationHandler) ServiceFlinkGetJarApplication 

func (h *FlinkJarApplicationHandler) ServiceFlinkGetJarApplication(ctx context.Context, project string, serviceName string, applicationId string) (*ServiceFlinkGetJarApplicationOut, error)

func (*FlinkJarApplicationHandler) ServiceFlinkListJarApplications 

func (h *FlinkJarApplicationHandler) ServiceFlinkListJarApplications(ctx context.Context, project string, serviceName string) ([]ApplicationOut, error)

func (*FlinkJarApplicationHandler) ServiceFlinkUpdateJarApplication 

func (h *FlinkJarApplicationHandler) ServiceFlinkUpdateJarApplication(ctx context.Context, project string, serviceName string, applicationId string, in *ServiceFlinkUpdateJarApplicationIn) (*ServiceFlinkUpdateJarApplicationOut, error)

type Handler 

type Handler interface {
	// ServiceFlinkCreateJarApplication [EXPERIMENTAL] Create a Flink JarApplication
	// POST /v1/project/{project}/service/{service_name}/flink/jar_application
	// https://api.aiven.io/doc/#tag/Service:_Flink/operation/ServiceFlinkCreateJarApplication
	ServiceFlinkCreateJarApplication(ctx context.Context, project string, serviceName string, in *ServiceFlinkCreateJarApplicationIn) (*ServiceFlinkCreateJarApplicationOut, error)

	// ServiceFlinkDeleteJarApplication [EXPERIMENTAL] Delete a Flink JarApplication
	// DELETE /v1/project/{project}/service/{service_name}/flink/jar_application/{application_id}
	// https://api.aiven.io/doc/#tag/Service:_Flink/operation/ServiceFlinkDeleteJarApplication
	ServiceFlinkDeleteJarApplication(ctx context.Context, project string, serviceName string, applicationId string) (*ServiceFlinkDeleteJarApplicationOut, error)

	// ServiceFlinkGetJarApplication [EXPERIMENTAL] Get a Flink JarApplication
	// GET /v1/project/{project}/service/{service_name}/flink/jar_application/{application_id}
	// https://api.aiven.io/doc/#tag/Service:_Flink/operation/ServiceFlinkGetJarApplication
	ServiceFlinkGetJarApplication(ctx context.Context, project string, serviceName string, applicationId string) (*ServiceFlinkGetJarApplicationOut, error)

	// ServiceFlinkListJarApplications [EXPERIMENTAL] Get all Flink JarApplications
	// GET /v1/project/{project}/service/{service_name}/flink/jar_application
	// https://api.aiven.io/doc/#tag/Service:_Flink/operation/ServiceFlinkListJarApplications
	ServiceFlinkListJarApplications(ctx context.Context, project string, serviceName string) ([]ApplicationOut, error)

	// ServiceFlinkUpdateJarApplication [EXPERIMENTAL] Update a Flink JarApplication
	// PUT /v1/project/{project}/service/{service_name}/flink/jar_application/{application_id}
	// https://api.aiven.io/doc/#tag/Service:_Flink/operation/ServiceFlinkUpdateJarApplication
	ServiceFlinkUpdateJarApplication(ctx context.Context, project string, serviceName string, applicationId string, in *ServiceFlinkUpdateJarApplicationIn) (*ServiceFlinkUpdateJarApplicationOut, error)
}

type ServiceFlinkCreateJarApplicationIn 

type ServiceFlinkCreateJarApplicationIn struct {
	Name string `json:"name"` // Application name
}

ServiceFlinkCreateJarApplicationIn ServiceFlinkCreateJarApplicationRequestBody

type ServiceFlinkCreateJarApplicationOut 

type ServiceFlinkCreateJarApplicationOut struct {
	ApplicationVersions []ApplicationVersionOut `json:"application_versions"`         // JarApplicationVersions
	CreatedAt           time.Time               `json:"created_at"`                   // Created at
	CreatedBy           string                  `json:"created_by"`                   // Created by
	CurrentDeployment   *CurrentDeploymentOut   `json:"current_deployment,omitempty"` // Flink JarApplicationDeployment
	Id                  string                  `json:"id"`                           // Application ID
	Name                string                  `json:"name"`                         // Application name
	UpdatedAt           time.Time               `json:"updated_at"`                   // Updated at
	UpdatedBy           string                  `json:"updated_by"`                   // Updated by
}

ServiceFlinkCreateJarApplicationOut ServiceFlinkCreateJarApplicationResponse

type ServiceFlinkDeleteJarApplicationOut 

type ServiceFlinkDeleteJarApplicationOut struct {
	ApplicationVersions []ApplicationVersionOut `json:"application_versions"`         // JarApplicationVersions
	CreatedAt           time.Time               `json:"created_at"`                   // Created at
	CreatedBy           string                  `json:"created_by"`                   // Created by
	CurrentDeployment   *CurrentDeploymentOut   `json:"current_deployment,omitempty"` // Flink JarApplicationDeployment
	Id                  string                  `json:"id"`                           // Application ID
	Name                string                  `json:"name"`                         // Application name
	UpdatedAt           time.Time               `json:"updated_at"`                   // Updated at
	UpdatedBy           string                  `json:"updated_by"`                   // Updated by
}

ServiceFlinkDeleteJarApplicationOut ServiceFlinkDeleteJarApplicationResponse

type ServiceFlinkGetJarApplicationOut 

type ServiceFlinkGetJarApplicationOut struct {
	ApplicationVersions []ApplicationVersionOut `json:"application_versions"`         // JarApplicationVersions
	CreatedAt           time.Time               `json:"created_at"`                   // Created at
	CreatedBy           string                  `json:"created_by"`                   // Created by
	CurrentDeployment   *CurrentDeploymentOut   `json:"current_deployment,omitempty"` // Flink JarApplicationDeployment
	Id                  string                  `json:"id"`                           // Application ID
	Name                string                  `json:"name"`                         // Application name
	UpdatedAt           time.Time               `json:"updated_at"`                   // Updated at
	UpdatedBy           string                  `json:"updated_by"`                   // Updated by
}

ServiceFlinkGetJarApplicationOut ServiceFlinkGetJarApplicationResponse

type ServiceFlinkUpdateJarApplicationIn 

type ServiceFlinkUpdateJarApplicationIn struct {
	Name string `json:"name"` // Application name
}

ServiceFlinkUpdateJarApplicationIn ServiceFlinkUpdateJarApplicationRequestBody

type ServiceFlinkUpdateJarApplicationOut 

type ServiceFlinkUpdateJarApplicationOut struct {
	ApplicationVersions []ApplicationVersionOut `json:"application_versions"`         // JarApplicationVersions
	CreatedAt           time.Time               `json:"created_at"`                   // Created at
	CreatedBy           string                  `json:"created_by"`                   // Created by
	CurrentDeployment   *CurrentDeploymentOut   `json:"current_deployment,omitempty"` // Flink JarApplicationDeployment
	Id                  string                  `json:"id"`                           // Application ID
	Name                string                  `json:"name"`                         // Application name
	UpdatedAt           time.Time               `json:"updated_at"`                   // Updated at
	UpdatedBy           string                  `json:"updated_by"`                   // Updated by
}

ServiceFlinkUpdateJarApplicationOut ServiceFlinkUpdateJarApplicationResponse

type VerifyErrorCodeType 

type VerifyErrorCodeType int
const (
	VerifyErrorCodeType1 VerifyErrorCodeType = 1
	VerifyErrorCodeType2 VerifyErrorCodeType = 2
	VerifyErrorCodeType3 VerifyErrorCodeType = 3
)

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.