models

package
v0.2.6 Latest Latest
Warning

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

Go to latest
Published: Apr 28, 2024 License: Apache-2.0 Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type CreateImportReqImportType

type CreateImportReqImportType string

CreateImportReqImportType create import req import type

swagger:model CreateImportReqImportType

const (

	// CreateImportReqImportTypeS3 captures enum value "S3"
	CreateImportReqImportTypeS3 CreateImportReqImportType = "S3"

	// CreateImportReqImportTypeLOCAL captures enum value "LOCAL"
	CreateImportReqImportTypeLOCAL CreateImportReqImportType = "LOCAL"
)

func (CreateImportReqImportType) ContextValidate

func (m CreateImportReqImportType) ContextValidate(ctx context.Context, formats strfmt.Registry) error

ContextValidate validates this create import req import type based on context it is used

func (CreateImportReqImportType) Pointer

Pointer returns a pointer to a freshly-allocated CreateImportReqImportType.

func (CreateImportReqImportType) Validate

func (m CreateImportReqImportType) Validate(formats strfmt.Registry) error

Validate validates this create import req import type

type GooglerpcStatus

type GooglerpcStatus struct {

	// code
	Code int32 `json:"code,omitempty"`

	// details
	Details []*ProtobufAny `json:"details"`

	// message
	Message string `json:"message,omitempty"`
}

GooglerpcStatus googlerpc status

swagger:model googlerpcStatus

func (*GooglerpcStatus) ContextValidate

func (m *GooglerpcStatus) ContextValidate(ctx context.Context, formats strfmt.Registry) error

ContextValidate validate this googlerpc status based on the context it is used

func (*GooglerpcStatus) MarshalBinary

func (m *GooglerpcStatus) MarshalBinary() ([]byte, error)

MarshalBinary interface implementation

func (*GooglerpcStatus) UnmarshalBinary

func (m *GooglerpcStatus) UnmarshalBinary(b []byte) error

UnmarshalBinary interface implementation

func (*GooglerpcStatus) Validate

func (m *GooglerpcStatus) Validate(formats strfmt.Registry) error

Validate validates this googlerpc status

type ImportTableCompletionInfoResult

type ImportTableCompletionInfoResult string

ImportTableCompletionInfoResult import table completion info result

swagger:model ImportTableCompletionInfoResult

const (

	// ImportTableCompletionInfoResultSUCCESS captures enum value "SUCCESS"
	ImportTableCompletionInfoResultSUCCESS ImportTableCompletionInfoResult = "SUCCESS"

	// ImportTableCompletionInfoResultWARNING captures enum value "WARNING"
	ImportTableCompletionInfoResultWARNING ImportTableCompletionInfoResult = "WARNING"

	// ImportTableCompletionInfoResultERROR captures enum value "ERROR"
	ImportTableCompletionInfoResultERROR ImportTableCompletionInfoResult = "ERROR"
)

func (ImportTableCompletionInfoResult) ContextValidate

func (m ImportTableCompletionInfoResult) ContextValidate(ctx context.Context, formats strfmt.Registry) error

ContextValidate validates this import table completion info result based on context it is used

func (ImportTableCompletionInfoResult) Pointer

Pointer returns a pointer to a freshly-allocated ImportTableCompletionInfoResult.

func (ImportTableCompletionInfoResult) Validate

Validate validates this import table completion info result

type OpenapiCreateImportReq

type OpenapiCreateImportReq struct {

	// used for importing from S3
	//
	// The arn of AWS IAM role.
	AwsRoleArn string `json:"aws_role_arn,omitempty"`

	// The ID of the cluster.
	// Example: 1
	// Required: true
	ClusterID *string `json:"cluster_id"`

	// The CSV configuration.
	CsvFormat *OpenapiCustomCSVFormat `json:"csv_format,omitempty"`

	// The format of data to import.
	// Required: true
	DataFormat *OpenapiDataFormat `json:"data_format"`

	// used for importing from local file
	//
	// The file name returned by generating upload url.
	FileName string `json:"file_name,omitempty"`

	// The ID of the project.
	// Example: 1
	// Required: true
	ProjectID *string `json:"project_id"`

	// used for importing from S3
	//
	// The full s3 path that contains data to import.
	SourceURL string `json:"source_url,omitempty"`

	// The target db and table to import data.
	TargetTable *OpenapiTable `json:"target_table,omitempty"`

	// The type of data source.
	// Required: true
	Type *CreateImportReqImportType `json:"type"`
}

OpenapiCreateImportReq openapi create import req

swagger:model openapiCreateImportReq

func (*OpenapiCreateImportReq) ContextValidate

func (m *OpenapiCreateImportReq) ContextValidate(ctx context.Context, formats strfmt.Registry) error

ContextValidate validate this openapi create import req based on the context it is used

func (*OpenapiCreateImportReq) MarshalBinary

func (m *OpenapiCreateImportReq) MarshalBinary() ([]byte, error)

MarshalBinary interface implementation

func (*OpenapiCreateImportReq) UnmarshalBinary

func (m *OpenapiCreateImportReq) UnmarshalBinary(b []byte) error

UnmarshalBinary interface implementation

func (*OpenapiCreateImportReq) Validate

func (m *OpenapiCreateImportReq) Validate(formats strfmt.Registry) error

Validate validates this openapi create import req

type OpenapiCreateImportResp

type OpenapiCreateImportResp struct {

	// The ID of the import job.
	// Example: 1
	// Required: true
	ID *string `json:"id"`
}

OpenapiCreateImportResp openapi create import resp

swagger:model openapiCreateImportResp

func (*OpenapiCreateImportResp) ContextValidate

func (m *OpenapiCreateImportResp) ContextValidate(ctx context.Context, formats strfmt.Registry) error

ContextValidate validates this openapi create import resp based on context it is used

func (*OpenapiCreateImportResp) MarshalBinary

func (m *OpenapiCreateImportResp) MarshalBinary() ([]byte, error)

MarshalBinary interface implementation

func (*OpenapiCreateImportResp) UnmarshalBinary

func (m *OpenapiCreateImportResp) UnmarshalBinary(b []byte) error

UnmarshalBinary interface implementation

func (*OpenapiCreateImportResp) Validate

func (m *OpenapiCreateImportResp) Validate(formats strfmt.Registry) error

Validate validates this openapi create import resp

type OpenapiCurrentTable

type OpenapiCurrentTable struct {

	// The process in percent of importing the table.
	// Required: true
	// Maximum: 100
	// Minimum: 1
	CompletedPercent *int64 `json:"completed_percent"`

	// The name of the table.
	// Required: true
	Name *string `json:"name"`

	// The data size of the table.
	// Required: true
	Size *string `json:"size"`
}

OpenapiCurrentTable openapi current table

swagger:model openapiCurrentTable

func (*OpenapiCurrentTable) ContextValidate

func (m *OpenapiCurrentTable) ContextValidate(ctx context.Context, formats strfmt.Registry) error

ContextValidate validates this openapi current table based on context it is used

func (*OpenapiCurrentTable) MarshalBinary

func (m *OpenapiCurrentTable) MarshalBinary() ([]byte, error)

MarshalBinary interface implementation

func (*OpenapiCurrentTable) UnmarshalBinary

func (m *OpenapiCurrentTable) UnmarshalBinary(b []byte) error

UnmarshalBinary interface implementation

func (*OpenapiCurrentTable) Validate

func (m *OpenapiCurrentTable) Validate(formats strfmt.Registry) error

Validate validates this openapi current table

type OpenapiCustomCSVFormat

type OpenapiCustomCSVFormat struct {

	// backslash escape
	BackslashEscape bool `json:"backslash_escape,omitempty"`

	// delimiter
	Delimiter string `json:"delimiter,omitempty"`

	// header
	Header bool `json:"header,omitempty"`

	// not null
	NotNull bool `json:"not_null,omitempty"`

	// null
	Null string `json:"null,omitempty"`

	// separator
	Separator string `json:"separator,omitempty"`

	// trim last separator
	TrimLastSeparator bool `json:"trim_last_separator,omitempty"`
}

OpenapiCustomCSVFormat openapi custom c s v format

swagger:model openapiCustomCSVFormat

func (*OpenapiCustomCSVFormat) ContextValidate

func (m *OpenapiCustomCSVFormat) ContextValidate(ctx context.Context, formats strfmt.Registry) error

ContextValidate validates this openapi custom c s v format based on context it is used

func (*OpenapiCustomCSVFormat) MarshalBinary

func (m *OpenapiCustomCSVFormat) MarshalBinary() ([]byte, error)

MarshalBinary interface implementation

func (*OpenapiCustomCSVFormat) UnmarshalBinary

func (m *OpenapiCustomCSVFormat) UnmarshalBinary(b []byte) error

UnmarshalBinary interface implementation

func (*OpenapiCustomCSVFormat) Validate

func (m *OpenapiCustomCSVFormat) Validate(formats strfmt.Registry) error

Validate validates this openapi custom c s v format

type OpenapiDataFormat

type OpenapiDataFormat string

OpenapiDataFormat openapi data format

swagger:model openapiDataFormat

const (

	// OpenapiDataFormatSQLFile captures enum value "SqlFile"
	OpenapiDataFormatSQLFile OpenapiDataFormat = "SqlFile"

	// OpenapiDataFormatAuroraSnapshot captures enum value "AuroraSnapshot"
	OpenapiDataFormatAuroraSnapshot OpenapiDataFormat = "AuroraSnapshot"

	// OpenapiDataFormatCSV captures enum value "CSV"
	OpenapiDataFormatCSV OpenapiDataFormat = "CSV"

	// OpenapiDataFormatParquet captures enum value "Parquet"
	OpenapiDataFormatParquet OpenapiDataFormat = "Parquet"
)

func NewOpenapiDataFormat

func NewOpenapiDataFormat(value OpenapiDataFormat) *OpenapiDataFormat

func (OpenapiDataFormat) ContextValidate

func (m OpenapiDataFormat) ContextValidate(ctx context.Context, formats strfmt.Registry) error

ContextValidate validates this openapi data format based on context it is used

func (OpenapiDataFormat) Pointer

func (m OpenapiDataFormat) Pointer() *OpenapiDataFormat

Pointer returns a pointer to a freshly-allocated OpenapiDataFormat.

func (OpenapiDataFormat) Validate

func (m OpenapiDataFormat) Validate(formats strfmt.Registry) error

Validate validates this openapi data format

type OpenapiGenerateUploadURLResq

type OpenapiGenerateUploadURLResq struct {

	// new file name
	// Required: true
	NewFileName *string `json:"new_file_name"`

	// upload url
	// Required: true
	UploadURL *string `json:"upload_url"`
}

OpenapiGenerateUploadURLResq openapi generate upload URL resq

swagger:model openapiGenerateUploadURLResq

func (*OpenapiGenerateUploadURLResq) ContextValidate

func (m *OpenapiGenerateUploadURLResq) ContextValidate(ctx context.Context, formats strfmt.Registry) error

ContextValidate validates this openapi generate upload URL resq based on context it is used

func (*OpenapiGenerateUploadURLResq) MarshalBinary

func (m *OpenapiGenerateUploadURLResq) MarshalBinary() ([]byte, error)

MarshalBinary interface implementation

func (*OpenapiGenerateUploadURLResq) UnmarshalBinary

func (m *OpenapiGenerateUploadURLResq) UnmarshalBinary(b []byte) error

UnmarshalBinary interface implementation

func (*OpenapiGenerateUploadURLResq) Validate

func (m *OpenapiGenerateUploadURLResq) Validate(formats strfmt.Registry) error

Validate validates this openapi generate upload URL resq

type OpenapiGetImportResp

type OpenapiGetImportResp struct {

	// Completion information of the tables imported.
	AllCompletedTables []*OpenapiImportTableCompletionInfo `json:"all_completed_tables"`

	// The ID of the cluster.
	// Example: 1
	// Required: true
	ClusterID *string `json:"cluster_id"`

	//  The process in percent of the import job, but doesn't include the post-processing progress.
	// Required: true
	// Maximum: 100
	// Minimum: 1
	CompletedPercent *int64 `json:"completed_percent"`

	// The number of completed tables.
	// Required: true
	CompletedTables *int64 `json:"completed_tables"`

	// The creation timestamp of the import job.
	// Required: true
	// Format: date-time
	CreatedAt *strfmt.DateTime `json:"created_at"`

	// The creation details of the import job.
	CreationDetails *OpenapiCreateImportReq `json:"creation_details,omitempty"`

	// The current tables are being imported.
	// Required: true
	CurrentTables []*OpenapiCurrentTable `json:"current_tables"`

	// The format of data to import.
	// Required: true
	DataFormat *OpenapiDataFormat `json:"data_format"`

	// The elapsed time of the import job in seconds.
	// Required: true
	ElapsedTimeSeconds *int64 `json:"elapsed_time_seconds"`

	// The ID of the import job.
	// Example: 1
	ID string `json:"id,omitempty"`

	// The message.
	// Required: true
	Message *string `json:"message"`

	// The number of pending tables.
	// Required: true
	PendingTables *int64 `json:"pending_tables"`

	// The post-process in percent of the import job.
	// Maximum: 100
	// Minimum: 1
	PostImportCompletedPercent int64 `json:"post_import_completed_percent,omitempty"`

	// The size of source data processed.
	ProcessedSourceDataSize string `json:"processed_source_data_size,omitempty"`

	// The full s3 path that contains data to import.
	SourceURL string `json:"source_url,omitempty"`

	// The status of the import job.
	// Required: true
	Status *OpenapiGetImportRespStatus `json:"status"`

	// The total number of files of the data imported.
	// Required: true
	TotalFiles *int64 `json:"total_files"`

	// The total size of the data imported.
	// Required: true
	TotalSize *string `json:"total_size"`

	// The total number of tables.
	TotalTablesCount int64 `json:"total_tables_count,omitempty"`
}

OpenapiGetImportResp ImportItem

ImportItem is the information of import job.

swagger:model openapiGetImportResp

func (*OpenapiGetImportResp) ContextValidate

func (m *OpenapiGetImportResp) ContextValidate(ctx context.Context, formats strfmt.Registry) error

ContextValidate validate this openapi get import resp based on the context it is used

func (*OpenapiGetImportResp) MarshalBinary

func (m *OpenapiGetImportResp) MarshalBinary() ([]byte, error)

MarshalBinary interface implementation

func (*OpenapiGetImportResp) UnmarshalBinary

func (m *OpenapiGetImportResp) UnmarshalBinary(b []byte) error

UnmarshalBinary interface implementation

func (*OpenapiGetImportResp) Validate

func (m *OpenapiGetImportResp) Validate(formats strfmt.Registry) error

Validate validates this openapi get import resp

type OpenapiGetImportRespStatus

type OpenapiGetImportRespStatus string

OpenapiGetImportRespStatus openapi get import resp status

swagger:model openapiGetImportRespStatus

const (

	// OpenapiGetImportRespStatusPREPARING captures enum value "PREPARING"
	OpenapiGetImportRespStatusPREPARING OpenapiGetImportRespStatus = "PREPARING"

	// OpenapiGetImportRespStatusIMPORTING captures enum value "IMPORTING"
	OpenapiGetImportRespStatusIMPORTING OpenapiGetImportRespStatus = "IMPORTING"

	// OpenapiGetImportRespStatusCOMPLETED captures enum value "COMPLETED"
	OpenapiGetImportRespStatusCOMPLETED OpenapiGetImportRespStatus = "COMPLETED"

	// OpenapiGetImportRespStatusFAILED captures enum value "FAILED"
	OpenapiGetImportRespStatusFAILED OpenapiGetImportRespStatus = "FAILED"

	// OpenapiGetImportRespStatusCANCELING captures enum value "CANCELING"
	OpenapiGetImportRespStatusCANCELING OpenapiGetImportRespStatus = "CANCELING"

	// OpenapiGetImportRespStatusCANCELED captures enum value "CANCELED"
	OpenapiGetImportRespStatusCANCELED OpenapiGetImportRespStatus = "CANCELED"
)

func (OpenapiGetImportRespStatus) ContextValidate

func (m OpenapiGetImportRespStatus) ContextValidate(ctx context.Context, formats strfmt.Registry) error

ContextValidate validates this openapi get import resp status based on context it is used

func (OpenapiGetImportRespStatus) Pointer

Pointer returns a pointer to a freshly-allocated OpenapiGetImportRespStatus.

func (OpenapiGetImportRespStatus) Validate

func (m OpenapiGetImportRespStatus) Validate(formats strfmt.Registry) error

Validate validates this openapi get import resp status

type OpenapiImportTableCompletionInfo

type OpenapiImportTableCompletionInfo struct {

	// The message.
	Message string `json:"message,omitempty"`

	// The result status of importing the table.
	// Required: true
	Result *ImportTableCompletionInfoResult `json:"result"`

	// The name of the table.
	// Required: true
	TableName *string `json:"table_name"`
}

OpenapiImportTableCompletionInfo openapi import table completion info

swagger:model openapiImportTableCompletionInfo

func (*OpenapiImportTableCompletionInfo) ContextValidate

func (m *OpenapiImportTableCompletionInfo) ContextValidate(ctx context.Context, formats strfmt.Registry) error

ContextValidate validate this openapi import table completion info based on the context it is used

func (*OpenapiImportTableCompletionInfo) MarshalBinary

func (m *OpenapiImportTableCompletionInfo) MarshalBinary() ([]byte, error)

MarshalBinary interface implementation

func (*OpenapiImportTableCompletionInfo) UnmarshalBinary

func (m *OpenapiImportTableCompletionInfo) UnmarshalBinary(b []byte) error

UnmarshalBinary interface implementation

func (*OpenapiImportTableCompletionInfo) Validate

Validate validates this openapi import table completion info

type OpenapiListImportsResp

type OpenapiListImportsResp struct {

	// The items of import jobs in the cluster.
	// Required: true
	Imports []*OpenapiGetImportResp `json:"imports"`

	// The total number of import jobs in the cluster.
	// Required: true
	Total *string `json:"total"`
}

OpenapiListImportsResp openapi list imports resp

swagger:model openapiListImportsResp

func (*OpenapiListImportsResp) ContextValidate

func (m *OpenapiListImportsResp) ContextValidate(ctx context.Context, formats strfmt.Registry) error

ContextValidate validate this openapi list imports resp based on the context it is used

func (*OpenapiListImportsResp) MarshalBinary

func (m *OpenapiListImportsResp) MarshalBinary() ([]byte, error)

MarshalBinary interface implementation

func (*OpenapiListImportsResp) UnmarshalBinary

func (m *OpenapiListImportsResp) UnmarshalBinary(b []byte) error

UnmarshalBinary interface implementation

func (*OpenapiListImportsResp) Validate

func (m *OpenapiListImportsResp) Validate(formats strfmt.Registry) error

Validate validates this openapi list imports resp

type OpenapiTable

type OpenapiTable struct {

	// schema
	Schema string `json:"schema,omitempty"`

	// table
	Table string `json:"table,omitempty"`
}

OpenapiTable openapi table

swagger:model openapiTable

func (*OpenapiTable) ContextValidate

func (m *OpenapiTable) ContextValidate(ctx context.Context, formats strfmt.Registry) error

ContextValidate validates this openapi table based on context it is used

func (*OpenapiTable) MarshalBinary

func (m *OpenapiTable) MarshalBinary() ([]byte, error)

MarshalBinary interface implementation

func (*OpenapiTable) UnmarshalBinary

func (m *OpenapiTable) UnmarshalBinary(b []byte) error

UnmarshalBinary interface implementation

func (*OpenapiTable) Validate

func (m *OpenapiTable) Validate(formats strfmt.Registry) error

Validate validates this openapi table

type ProtobufAny

type ProtobufAny struct {

	// at type
	AtType string `json:"@type,omitempty"`
}

ProtobufAny protobuf any

swagger:model protobufAny

func (*ProtobufAny) ContextValidate

func (m *ProtobufAny) ContextValidate(ctx context.Context, formats strfmt.Registry) error

ContextValidate validates this protobuf any based on context it is used

func (*ProtobufAny) MarshalBinary

func (m *ProtobufAny) MarshalBinary() ([]byte, error)

MarshalBinary interface implementation

func (*ProtobufAny) UnmarshalBinary

func (m *ProtobufAny) UnmarshalBinary(b []byte) error

UnmarshalBinary interface implementation

func (*ProtobufAny) Validate

func (m *ProtobufAny) Validate(formats strfmt.Registry) error

Validate validates this protobuf any

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL