Documentation
¶
Index ¶
- func FileStatusTypeChoices() []string
- func VerifyErrorCodeTypeChoices() []int
- type FileInfoOut
- type FileStatusType
- type 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
Constants ¶
This section is empty.
Variables ¶
This section is empty.
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"` // Indicates whether the uploaded .jar file has been verified by the system and deployment ready
Url *string `json:"url,omitempty"` // The pre-signed url of the bucket where the .jar file is uploaded. Becomes null when the JarApplicationVersion is ready or failed.
VerifyErrorCode VerifyErrorCodeType `json:"verify_error_code,omitempty"` // In the case file_status is FAILED, the error code of the failure.
VerifyErrorMessage *string `json:"verify_error_message,omitempty"` // In the case file_status is FAILED, may contain details about the failure.
}
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"` // The creation timestamp of this entity in ISO 8601 format, always in UTC
CreatedBy string `json:"created_by"` // The creator of this entity
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"` // The creation timestamp of this entity in ISO 8601 format, always in UTC
CreatedBy string `json:"created_by"` // The creator of this entity
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"` // The creation timestamp of this entity in ISO 8601 format, always in UTC
CreatedBy string `json:"created_by"` // The creator of this entity
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 )
Click to show internal directories.
Click to hide internal directories.