models

package
v0.2.5 Latest Latest
Warning

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

 Go to latest Published: Apr 15, 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 NewCreateImportReqImportType 

func NewCreateImportReqImportType(value CreateImportReqImportType) *CreateImportReqImportType

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 

func (m CreateImportReqImportType) Pointer() *CreateImportReqImportType

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 NewImportTableCompletionInfoResult 

func NewImportTableCompletionInfoResult(value ImportTableCompletionInfoResult) *ImportTableCompletionInfoResult

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 

func (m ImportTableCompletionInfoResult) Pointer() *ImportTableCompletionInfoResult

Pointer returns a pointer to a freshly-allocated ImportTableCompletionInfoResult.

func (ImportTableCompletionInfoResult) Validate 

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

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 NewOpenapiGetImportRespStatus 

func NewOpenapiGetImportRespStatus(value OpenapiGetImportRespStatus) *OpenapiGetImportRespStatus

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 

func (m OpenapiGetImportRespStatus) Pointer() *OpenapiGetImportRespStatus

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 

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

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

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.