flinkjarapplicationversion

Documentation

Index

• func FileStatusTypeChoices() []string
• func VerifyErrorCodeTypeChoices() []int
• type FileInfoOut
• type FileStatusType
• type FlinkJarApplicationVersionHandler
  • func NewHandler(doer doer) FlinkJarApplicationVersionHandler
  • func (h *FlinkJarApplicationVersionHandler) ServiceFlinkCreateJarApplicationVersion(ctx context.Context, project string, serviceName string, applicationId string) (*ServiceFlinkCreateJarApplicationVersionOut, error)
  • func (h *FlinkJarApplicationVersionHandler) ServiceFlinkDeleteJarApplicationVersion(ctx context.Context, project string, serviceName string, applicationId string, ...) (*ServiceFlinkDeleteJarApplicationVersionOut, error)
  • func (h *FlinkJarApplicationVersionHandler) ServiceFlinkGetJarApplicationVersion(ctx context.Context, project string, serviceName string, applicationId string, ...) (*ServiceFlinkGetJarApplicationVersionOut, error)
• type Handler
• type ServiceFlinkCreateJarApplicationVersionOut
• type ServiceFlinkDeleteJarApplicationVersionOut
• type ServiceFlinkGetJarApplicationVersionOut
• type VerifyErrorCodeType

Functions

func FileStatusTypeChoices

func FileStatusTypeChoices() []string

func VerifyErrorCodeTypeChoices

func VerifyErrorCodeTypeChoices() []int

Types

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 FlinkJarApplicationVersionHandler

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

func NewHandler

func NewHandler(doer doer) FlinkJarApplicationVersionHandler

func (*FlinkJarApplicationVersionHandler) ServiceFlinkCreateJarApplicationVersion

func (h *FlinkJarApplicationVersionHandler) ServiceFlinkCreateJarApplicationVersion(ctx context.Context, project string, serviceName string, applicationId string) (*ServiceFlinkCreateJarApplicationVersionOut, error)

func (*FlinkJarApplicationVersionHandler) ServiceFlinkDeleteJarApplicationVersion

func (h *FlinkJarApplicationVersionHandler) ServiceFlinkDeleteJarApplicationVersion(ctx context.Context, project string, serviceName string, applicationId string, applicationVersionId string) (*ServiceFlinkDeleteJarApplicationVersionOut, error)

func (*FlinkJarApplicationVersionHandler) ServiceFlinkGetJarApplicationVersion

func (h *FlinkJarApplicationVersionHandler) ServiceFlinkGetJarApplicationVersion(ctx context.Context, project string, serviceName string, applicationId string, applicationVersionId string) (*ServiceFlinkGetJarApplicationVersionOut, error)

type Handler

type Handler interface {
	// ServiceFlinkCreateJarApplicationVersion [EXPERIMENTAL] Create a Flink JarApplicationVersion
	// POST /v1/project/{project}/service/{service_name}/flink/jar_application/{application_id}/version
	// https://api.aiven.io/doc/#tag/Service:_Flink/operation/ServiceFlinkCreateJarApplicationVersion
	ServiceFlinkCreateJarApplicationVersion(ctx context.Context, project string, serviceName string, applicationId string) (*ServiceFlinkCreateJarApplicationVersionOut, error)

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

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

type ServiceFlinkCreateJarApplicationVersionOut

type ServiceFlinkCreateJarApplicationVersionOut 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
}

ServiceFlinkCreateJarApplicationVersionOut ServiceFlinkCreateJarApplicationVersionResponse

type ServiceFlinkDeleteJarApplicationVersionOut

type ServiceFlinkDeleteJarApplicationVersionOut 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
}

ServiceFlinkDeleteJarApplicationVersionOut ServiceFlinkDeleteJarApplicationVersionResponse

type ServiceFlinkGetJarApplicationVersionOut

type ServiceFlinkGetJarApplicationVersionOut 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
}

ServiceFlinkGetJarApplicationVersionOut ServiceFlinkGetJarApplicationVersionResponse

type VerifyErrorCodeType

type VerifyErrorCodeType int

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