import_service

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: 12 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type CancelImportDefault 

type CancelImportDefault struct {
	Payload *models.GooglerpcStatus
	// contains filtered or unexported fields
}

CancelImportDefault describes a response with status code -1, with default header values.

An unexpected error response.

func NewCancelImportDefault 

func NewCancelImportDefault(code int) *CancelImportDefault

NewCancelImportDefault creates a CancelImportDefault with default headers values

func (*CancelImportDefault) Code 

func (o *CancelImportDefault) Code() int

Code gets the status code for the cancel import default response

func (*CancelImportDefault) Error 

func (o *CancelImportDefault) Error() string

func (*CancelImportDefault) GetPayload 

func (o *CancelImportDefault) GetPayload() *models.GooglerpcStatus

func (*CancelImportDefault) IsClientError 

func (o *CancelImportDefault) IsClientError() bool

IsClientError returns true when this cancel import default response has a 4xx status code

func (*CancelImportDefault) IsCode 

func (o *CancelImportDefault) IsCode(code int) bool

IsCode returns true when this cancel import default response a status code equal to that given

func (*CancelImportDefault) IsRedirect 

func (o *CancelImportDefault) IsRedirect() bool

IsRedirect returns true when this cancel import default response has a 3xx status code

func (*CancelImportDefault) IsServerError 

func (o *CancelImportDefault) IsServerError() bool

IsServerError returns true when this cancel import default response has a 5xx status code

func (*CancelImportDefault) IsSuccess 

func (o *CancelImportDefault) IsSuccess() bool

IsSuccess returns true when this cancel import default response has a 2xx status code

func (*CancelImportDefault) String 

func (o *CancelImportDefault) String() string

type CancelImportOK 

type CancelImportOK struct {
	Payload interface{}
}

CancelImportOK describes a response with status code 200, with default header values.

A successful response.

func NewCancelImportOK 

func NewCancelImportOK() *CancelImportOK

NewCancelImportOK creates a CancelImportOK with default headers values

func (*CancelImportOK) Error 

func (o *CancelImportOK) Error() string

func (*CancelImportOK) GetPayload 

func (o *CancelImportOK) GetPayload() interface{}

func (*CancelImportOK) IsClientError 

func (o *CancelImportOK) IsClientError() bool

IsClientError returns true when this cancel import o k response has a 4xx status code

func (*CancelImportOK) IsCode 

func (o *CancelImportOK) IsCode(code int) bool

IsCode returns true when this cancel import o k response a status code equal to that given

func (*CancelImportOK) IsRedirect 

func (o *CancelImportOK) IsRedirect() bool

IsRedirect returns true when this cancel import o k response has a 3xx status code

func (*CancelImportOK) IsServerError 

func (o *CancelImportOK) IsServerError() bool

IsServerError returns true when this cancel import o k response has a 5xx status code

func (*CancelImportOK) IsSuccess 

func (o *CancelImportOK) IsSuccess() bool

IsSuccess returns true when this cancel import o k response has a 2xx status code

func (*CancelImportOK) String 

func (o *CancelImportOK) String() string

type CancelImportParams 

type CancelImportParams struct {

	/* ClusterID.

	   The ID of the cluster.

	   Format: uint64
	*/
	ClusterID string

	/* ID.

	   The ID of the import job.

	   Format: uint64
	*/
	ID string

	/* ProjectID.

	   The ID of the project.

	   Format: uint64
	*/
	ProjectID string

	Context    context.Context
	HTTPClient *http.Client
	// contains filtered or unexported fields
}

CancelImportParams contains all the parameters to send to the API endpoint 

for the cancel import operation.

Typically these are written to a http.Request.

func NewCancelImportParams 

func NewCancelImportParams() *CancelImportParams

NewCancelImportParams creates a new CancelImportParams object, with the default timeout for this client.

Default values are not hydrated, since defaults are normally applied by the API server side.

To enforce default values in parameter, use SetDefaults or WithDefaults.

func NewCancelImportParamsWithContext 

func NewCancelImportParamsWithContext(ctx context.Context) *CancelImportParams

NewCancelImportParamsWithContext creates a new CancelImportParams object with the ability to set a context for a request.

func NewCancelImportParamsWithHTTPClient 

func NewCancelImportParamsWithHTTPClient(client *http.Client) *CancelImportParams

NewCancelImportParamsWithHTTPClient creates a new CancelImportParams object with the ability to set a custom HTTPClient for a request.

func NewCancelImportParamsWithTimeout 

func NewCancelImportParamsWithTimeout(timeout time.Duration) *CancelImportParams

NewCancelImportParamsWithTimeout creates a new CancelImportParams object with the ability to set a timeout on a request.

func (*CancelImportParams) SetClusterID 

func (o *CancelImportParams) SetClusterID(clusterID string)

SetClusterID adds the clusterId to the cancel import params

func (*CancelImportParams) SetContext 

func (o *CancelImportParams) SetContext(ctx context.Context)

SetContext adds the context to the cancel import params

func (*CancelImportParams) SetDefaults 

func (o *CancelImportParams) SetDefaults()

SetDefaults hydrates default values in the cancel import params (not the query body).

All values with no default are reset to their zero value.

func (*CancelImportParams) SetHTTPClient 

func (o *CancelImportParams) SetHTTPClient(client *http.Client)

SetHTTPClient adds the HTTPClient to the cancel import params

func (*CancelImportParams) SetID 

func (o *CancelImportParams) SetID(id string)

SetID adds the id to the cancel import params

func (*CancelImportParams) SetProjectID 

func (o *CancelImportParams) SetProjectID(projectID string)

SetProjectID adds the projectId to the cancel import params

func (*CancelImportParams) SetTimeout 

func (o *CancelImportParams) SetTimeout(timeout time.Duration)

SetTimeout adds the timeout to the cancel import params

func (*CancelImportParams) WithClusterID 

func (o *CancelImportParams) WithClusterID(clusterID string) *CancelImportParams

WithClusterID adds the clusterID to the cancel import params

func (*CancelImportParams) WithContext 

func (o *CancelImportParams) WithContext(ctx context.Context) *CancelImportParams

WithContext adds the context to the cancel import params

func (*CancelImportParams) WithDefaults 

func (o *CancelImportParams) WithDefaults() *CancelImportParams

WithDefaults hydrates default values in the cancel import params (not the query body).

All values with no default are reset to their zero value.

func (*CancelImportParams) WithHTTPClient 

func (o *CancelImportParams) WithHTTPClient(client *http.Client) *CancelImportParams

WithHTTPClient adds the HTTPClient to the cancel import params

func (*CancelImportParams) WithID 

func (o *CancelImportParams) WithID(id string) *CancelImportParams

WithID adds the id to the cancel import params

func (*CancelImportParams) WithProjectID 

func (o *CancelImportParams) WithProjectID(projectID string) *CancelImportParams

WithProjectID adds the projectID to the cancel import params

func (*CancelImportParams) WithTimeout 

func (o *CancelImportParams) WithTimeout(timeout time.Duration) *CancelImportParams

WithTimeout adds the timeout to the cancel import params

func (*CancelImportParams) WriteToRequest 

func (o *CancelImportParams) WriteToRequest(r runtime.ClientRequest, reg strfmt.Registry) error

WriteToRequest writes these params to a swagger request

type CancelImportReader 

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

CancelImportReader is a Reader for the CancelImport structure.

func (*CancelImportReader) ReadResponse 

func (o *CancelImportReader) ReadResponse(response runtime.ClientResponse, consumer runtime.Consumer) (interface{}, error)

ReadResponse reads a server response into the received o.

type Client 

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

Client for import service API

func (*Client) CancelImport 

func (a *Client) CancelImport(params *CancelImportParams, opts ...ClientOption) (*CancelImportOK, error)

CancelImport cancels an import job

func (*Client) CreateImport 

func (a *Client) CreateImport(params *CreateImportParams, opts ...ClientOption) (*CreateImportOK, error)

CreateImport creates an import job

func (*Client) GenerateUploadURL 

func (a *Client) GenerateUploadURL(params *GenerateUploadURLParams, opts ...ClientOption) (*GenerateUploadURLOK, error)

GenerateUploadURL generates s3 url to upload file

func (*Client) GetImport 

func (a *Client) GetImport(params *GetImportParams, opts ...ClientOption) (*GetImportOK, error)

GetImport gets an import job

func (*Client) ListImports 

func (a *Client) ListImports(params *ListImportsParams, opts ...ClientOption) (*ListImportsOK, error)

ListImports lists all import jobs in the cluster

func (*Client) SetTransport 

func (a *Client) SetTransport(transport runtime.ClientTransport)

SetTransport changes the transport on the client

type ClientOption 

type ClientOption func(*runtime.ClientOperation)

ClientOption is the option for Client methods

type ClientService 

type ClientService interface {
	CancelImport(params *CancelImportParams, opts ...ClientOption) (*CancelImportOK, error)

	CreateImport(params *CreateImportParams, opts ...ClientOption) (*CreateImportOK, error)

	GenerateUploadURL(params *GenerateUploadURLParams, opts ...ClientOption) (*GenerateUploadURLOK, error)

	GetImport(params *GetImportParams, opts ...ClientOption) (*GetImportOK, error)

	ListImports(params *ListImportsParams, opts ...ClientOption) (*ListImportsOK, error)

	SetTransport(transport runtime.ClientTransport)
}

ClientService is the interface for Client methods

func New 

func New(transport runtime.ClientTransport, formats strfmt.Registry) ClientService

New creates a new import service API client.

type CreateImportBody 

type CreateImportBody struct {

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

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

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

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

	// 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 *models.OpenapiTable `json:"target_table,omitempty"`

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

CreateImportBody create import body swagger:model CreateImportBody

func (*CreateImportBody) ContextValidate 

func (o *CreateImportBody) ContextValidate(ctx context.Context, formats strfmt.Registry) error

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

func (*CreateImportBody) MarshalBinary 

func (o *CreateImportBody) MarshalBinary() ([]byte, error)

MarshalBinary interface implementation

func (*CreateImportBody) UnmarshalBinary 

func (o *CreateImportBody) UnmarshalBinary(b []byte) error

UnmarshalBinary interface implementation

func (*CreateImportBody) Validate 

func (o *CreateImportBody) Validate(formats strfmt.Registry) error

Validate validates this create import body

type CreateImportDefault 

type CreateImportDefault struct {
	Payload *models.GooglerpcStatus
	// contains filtered or unexported fields
}

CreateImportDefault describes a response with status code -1, with default header values.

An unexpected error response.

func NewCreateImportDefault 

func NewCreateImportDefault(code int) *CreateImportDefault

NewCreateImportDefault creates a CreateImportDefault with default headers values

func (*CreateImportDefault) Code 

func (o *CreateImportDefault) Code() int

Code gets the status code for the create import default response

func (*CreateImportDefault) Error 

func (o *CreateImportDefault) Error() string

func (*CreateImportDefault) GetPayload 

func (o *CreateImportDefault) GetPayload() *models.GooglerpcStatus

func (*CreateImportDefault) IsClientError 

func (o *CreateImportDefault) IsClientError() bool

IsClientError returns true when this create import default response has a 4xx status code

func (*CreateImportDefault) IsCode 

func (o *CreateImportDefault) IsCode(code int) bool

IsCode returns true when this create import default response a status code equal to that given

func (*CreateImportDefault) IsRedirect 

func (o *CreateImportDefault) IsRedirect() bool

IsRedirect returns true when this create import default response has a 3xx status code

func (*CreateImportDefault) IsServerError 

func (o *CreateImportDefault) IsServerError() bool

IsServerError returns true when this create import default response has a 5xx status code

func (*CreateImportDefault) IsSuccess 

func (o *CreateImportDefault) IsSuccess() bool

IsSuccess returns true when this create import default response has a 2xx status code

func (*CreateImportDefault) String 

func (o *CreateImportDefault) String() string

type CreateImportOK 

type CreateImportOK struct {
	Payload *models.OpenapiCreateImportResp
}

CreateImportOK describes a response with status code 200, with default header values.

A successful response.

func NewCreateImportOK 

func NewCreateImportOK() *CreateImportOK

NewCreateImportOK creates a CreateImportOK with default headers values

func (*CreateImportOK) Error 

func (o *CreateImportOK) Error() string

func (*CreateImportOK) GetPayload 

func (o *CreateImportOK) GetPayload() *models.OpenapiCreateImportResp

func (*CreateImportOK) IsClientError 

func (o *CreateImportOK) IsClientError() bool

IsClientError returns true when this create import o k response has a 4xx status code

func (*CreateImportOK) IsCode 

func (o *CreateImportOK) IsCode(code int) bool

IsCode returns true when this create import o k response a status code equal to that given

func (*CreateImportOK) IsRedirect 

func (o *CreateImportOK) IsRedirect() bool

IsRedirect returns true when this create import o k response has a 3xx status code

func (*CreateImportOK) IsServerError 

func (o *CreateImportOK) IsServerError() bool

IsServerError returns true when this create import o k response has a 5xx status code

func (*CreateImportOK) IsSuccess 

func (o *CreateImportOK) IsSuccess() bool

IsSuccess returns true when this create import o k response has a 2xx status code

func (*CreateImportOK) String 

func (o *CreateImportOK) String() string

type CreateImportParams 

type CreateImportParams struct {

	// Body.
	Body CreateImportBody

	/* ClusterID.

	   The ID of the cluster.

	   Format: uint64
	*/
	ClusterID string

	/* ProjectID.

	   The ID of the project.

	   Format: uint64
	*/
	ProjectID string

	Context    context.Context
	HTTPClient *http.Client
	// contains filtered or unexported fields
}

CreateImportParams contains all the parameters to send to the API endpoint 

for the create import operation.

Typically these are written to a http.Request.

func NewCreateImportParams 

func NewCreateImportParams() *CreateImportParams

NewCreateImportParams creates a new CreateImportParams object, with the default timeout for this client.

Default values are not hydrated, since defaults are normally applied by the API server side.

To enforce default values in parameter, use SetDefaults or WithDefaults.

func NewCreateImportParamsWithContext 

func NewCreateImportParamsWithContext(ctx context.Context) *CreateImportParams

NewCreateImportParamsWithContext creates a new CreateImportParams object with the ability to set a context for a request.

func NewCreateImportParamsWithHTTPClient 

func NewCreateImportParamsWithHTTPClient(client *http.Client) *CreateImportParams

NewCreateImportParamsWithHTTPClient creates a new CreateImportParams object with the ability to set a custom HTTPClient for a request.

func NewCreateImportParamsWithTimeout 

func NewCreateImportParamsWithTimeout(timeout time.Duration) *CreateImportParams

NewCreateImportParamsWithTimeout creates a new CreateImportParams object with the ability to set a timeout on a request.

func (*CreateImportParams) SetBody 

func (o *CreateImportParams) SetBody(body CreateImportBody)

SetBody adds the body to the create import params

func (*CreateImportParams) SetClusterID 

func (o *CreateImportParams) SetClusterID(clusterID string)

SetClusterID adds the clusterId to the create import params

func (*CreateImportParams) SetContext 

func (o *CreateImportParams) SetContext(ctx context.Context)

SetContext adds the context to the create import params

func (*CreateImportParams) SetDefaults 

func (o *CreateImportParams) SetDefaults()

SetDefaults hydrates default values in the create import params (not the query body).

All values with no default are reset to their zero value.

func (*CreateImportParams) SetHTTPClient 

func (o *CreateImportParams) SetHTTPClient(client *http.Client)

SetHTTPClient adds the HTTPClient to the create import params

func (*CreateImportParams) SetProjectID 

func (o *CreateImportParams) SetProjectID(projectID string)

SetProjectID adds the projectId to the create import params

func (*CreateImportParams) SetTimeout 

func (o *CreateImportParams) SetTimeout(timeout time.Duration)

SetTimeout adds the timeout to the create import params

func (*CreateImportParams) WithBody 

func (o *CreateImportParams) WithBody(body CreateImportBody) *CreateImportParams

WithBody adds the body to the create import params

func (*CreateImportParams) WithClusterID 

func (o *CreateImportParams) WithClusterID(clusterID string) *CreateImportParams

WithClusterID adds the clusterID to the create import params

func (*CreateImportParams) WithContext 

func (o *CreateImportParams) WithContext(ctx context.Context) *CreateImportParams

WithContext adds the context to the create import params

func (*CreateImportParams) WithDefaults 

func (o *CreateImportParams) WithDefaults() *CreateImportParams

WithDefaults hydrates default values in the create import params (not the query body).

All values with no default are reset to their zero value.

func (*CreateImportParams) WithHTTPClient 

func (o *CreateImportParams) WithHTTPClient(client *http.Client) *CreateImportParams

WithHTTPClient adds the HTTPClient to the create import params

func (*CreateImportParams) WithProjectID 

func (o *CreateImportParams) WithProjectID(projectID string) *CreateImportParams

WithProjectID adds the projectID to the create import params

func (*CreateImportParams) WithTimeout 

func (o *CreateImportParams) WithTimeout(timeout time.Duration) *CreateImportParams

WithTimeout adds the timeout to the create import params

func (*CreateImportParams) WriteToRequest 

func (o *CreateImportParams) WriteToRequest(r runtime.ClientRequest, reg strfmt.Registry) error

WriteToRequest writes these params to a swagger request

type CreateImportReader 

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

CreateImportReader is a Reader for the CreateImport structure.

func (*CreateImportReader) ReadResponse 

func (o *CreateImportReader) ReadResponse(response runtime.ClientResponse, consumer runtime.Consumer) (interface{}, error)

ReadResponse reads a server response into the received o.

type GenerateUploadURLBody 

type GenerateUploadURLBody struct {

	// content length
	// Required: true
	ContentLength *string `json:"content_length"`

	// file name
	// Required: true
	FileName *string `json:"file_name"`
}

GenerateUploadURLBody generate upload URL body swagger:model GenerateUploadURLBody

func (*GenerateUploadURLBody) ContextValidate 

func (o *GenerateUploadURLBody) ContextValidate(ctx context.Context, formats strfmt.Registry) error

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

func (*GenerateUploadURLBody) MarshalBinary 

func (o *GenerateUploadURLBody) MarshalBinary() ([]byte, error)

MarshalBinary interface implementation

func (*GenerateUploadURLBody) UnmarshalBinary 

func (o *GenerateUploadURLBody) UnmarshalBinary(b []byte) error

UnmarshalBinary interface implementation

func (*GenerateUploadURLBody) Validate 

func (o *GenerateUploadURLBody) Validate(formats strfmt.Registry) error

Validate validates this generate upload URL body

type GenerateUploadURLDefault 

type GenerateUploadURLDefault struct {
	Payload *models.GooglerpcStatus
	// contains filtered or unexported fields
}

GenerateUploadURLDefault describes a response with status code -1, with default header values.

An unexpected error response.

func NewGenerateUploadURLDefault 

func NewGenerateUploadURLDefault(code int) *GenerateUploadURLDefault

NewGenerateUploadURLDefault creates a GenerateUploadURLDefault with default headers values

func (*GenerateUploadURLDefault) Code 

func (o *GenerateUploadURLDefault) Code() int

Code gets the status code for the generate upload URL default response

func (*GenerateUploadURLDefault) Error 

func (o *GenerateUploadURLDefault) Error() string

func (*GenerateUploadURLDefault) GetPayload 

func (o *GenerateUploadURLDefault) GetPayload() *models.GooglerpcStatus

func (*GenerateUploadURLDefault) IsClientError 

func (o *GenerateUploadURLDefault) IsClientError() bool

IsClientError returns true when this generate upload URL default response has a 4xx status code

func (*GenerateUploadURLDefault) IsCode 

func (o *GenerateUploadURLDefault) IsCode(code int) bool

IsCode returns true when this generate upload URL default response a status code equal to that given

func (*GenerateUploadURLDefault) IsRedirect 

func (o *GenerateUploadURLDefault) IsRedirect() bool

IsRedirect returns true when this generate upload URL default response has a 3xx status code

func (*GenerateUploadURLDefault) IsServerError 

func (o *GenerateUploadURLDefault) IsServerError() bool

IsServerError returns true when this generate upload URL default response has a 5xx status code

func (*GenerateUploadURLDefault) IsSuccess 

func (o *GenerateUploadURLDefault) IsSuccess() bool

IsSuccess returns true when this generate upload URL default response has a 2xx status code

func (*GenerateUploadURLDefault) String 

func (o *GenerateUploadURLDefault) String() string

type GenerateUploadURLOK 

type GenerateUploadURLOK struct {
	Payload *models.OpenapiGenerateUploadURLResq
}

GenerateUploadURLOK describes a response with status code 200, with default header values.

A successful response.

func NewGenerateUploadURLOK 

func NewGenerateUploadURLOK() *GenerateUploadURLOK

NewGenerateUploadURLOK creates a GenerateUploadURLOK with default headers values

func (*GenerateUploadURLOK) Error 

func (o *GenerateUploadURLOK) Error() string

func (*GenerateUploadURLOK) GetPayload 

func (o *GenerateUploadURLOK) GetPayload() *models.OpenapiGenerateUploadURLResq

func (*GenerateUploadURLOK) IsClientError 

func (o *GenerateUploadURLOK) IsClientError() bool

IsClientError returns true when this generate upload Url o k response has a 4xx status code

func (*GenerateUploadURLOK) IsCode 

func (o *GenerateUploadURLOK) IsCode(code int) bool

IsCode returns true when this generate upload Url o k response a status code equal to that given

func (*GenerateUploadURLOK) IsRedirect 

func (o *GenerateUploadURLOK) IsRedirect() bool

IsRedirect returns true when this generate upload Url o k response has a 3xx status code

func (*GenerateUploadURLOK) IsServerError 

func (o *GenerateUploadURLOK) IsServerError() bool

IsServerError returns true when this generate upload Url o k response has a 5xx status code

func (*GenerateUploadURLOK) IsSuccess 

func (o *GenerateUploadURLOK) IsSuccess() bool

IsSuccess returns true when this generate upload Url o k response has a 2xx status code

func (*GenerateUploadURLOK) String 

func (o *GenerateUploadURLOK) String() string

type GenerateUploadURLParams 

type GenerateUploadURLParams struct {

	// Body.
	Body GenerateUploadURLBody

	/* ClusterID.

	   The ID of the cluster.

	   Format: uint64
	*/
	ClusterID string

	/* ProjectID.

	   The ID of the project.

	   Format: uint64
	*/
	ProjectID string

	Context    context.Context
	HTTPClient *http.Client
	// contains filtered or unexported fields
}

GenerateUploadURLParams contains all the parameters to send to the API endpoint 

for the generate upload URL operation.

Typically these are written to a http.Request.

func NewGenerateUploadURLParams 

func NewGenerateUploadURLParams() *GenerateUploadURLParams

NewGenerateUploadURLParams creates a new GenerateUploadURLParams object, with the default timeout for this client.

Default values are not hydrated, since defaults are normally applied by the API server side.

To enforce default values in parameter, use SetDefaults or WithDefaults.

func NewGenerateUploadURLParamsWithContext 

func NewGenerateUploadURLParamsWithContext(ctx context.Context) *GenerateUploadURLParams

NewGenerateUploadURLParamsWithContext creates a new GenerateUploadURLParams object with the ability to set a context for a request.

func NewGenerateUploadURLParamsWithHTTPClient 

func NewGenerateUploadURLParamsWithHTTPClient(client *http.Client) *GenerateUploadURLParams

NewGenerateUploadURLParamsWithHTTPClient creates a new GenerateUploadURLParams object with the ability to set a custom HTTPClient for a request.

func NewGenerateUploadURLParamsWithTimeout 

func NewGenerateUploadURLParamsWithTimeout(timeout time.Duration) *GenerateUploadURLParams

NewGenerateUploadURLParamsWithTimeout creates a new GenerateUploadURLParams object with the ability to set a timeout on a request.

func (*GenerateUploadURLParams) SetBody 

func (o *GenerateUploadURLParams) SetBody(body GenerateUploadURLBody)

SetBody adds the body to the generate upload URL params

func (*GenerateUploadURLParams) SetClusterID 

func (o *GenerateUploadURLParams) SetClusterID(clusterID string)

SetClusterID adds the clusterId to the generate upload URL params

func (*GenerateUploadURLParams) SetContext 

func (o *GenerateUploadURLParams) SetContext(ctx context.Context)

SetContext adds the context to the generate upload URL params

func (*GenerateUploadURLParams) SetDefaults 

func (o *GenerateUploadURLParams) SetDefaults()

SetDefaults hydrates default values in the generate upload URL params (not the query body).

All values with no default are reset to their zero value.

func (*GenerateUploadURLParams) SetHTTPClient 

func (o *GenerateUploadURLParams) SetHTTPClient(client *http.Client)

SetHTTPClient adds the HTTPClient to the generate upload URL params

func (*GenerateUploadURLParams) SetProjectID 

func (o *GenerateUploadURLParams) SetProjectID(projectID string)

SetProjectID adds the projectId to the generate upload URL params

func (*GenerateUploadURLParams) SetTimeout 

func (o *GenerateUploadURLParams) SetTimeout(timeout time.Duration)

SetTimeout adds the timeout to the generate upload URL params

func (*GenerateUploadURLParams) WithBody 

func (o *GenerateUploadURLParams) WithBody(body GenerateUploadURLBody) *GenerateUploadURLParams

WithBody adds the body to the generate upload URL params

func (*GenerateUploadURLParams) WithClusterID 

func (o *GenerateUploadURLParams) WithClusterID(clusterID string) *GenerateUploadURLParams

WithClusterID adds the clusterID to the generate upload URL params

func (*GenerateUploadURLParams) WithContext 

func (o *GenerateUploadURLParams) WithContext(ctx context.Context) *GenerateUploadURLParams

WithContext adds the context to the generate upload URL params

func (*GenerateUploadURLParams) WithDefaults 

func (o *GenerateUploadURLParams) WithDefaults() *GenerateUploadURLParams

WithDefaults hydrates default values in the generate upload URL params (not the query body).

All values with no default are reset to their zero value.

func (*GenerateUploadURLParams) WithHTTPClient 

func (o *GenerateUploadURLParams) WithHTTPClient(client *http.Client) *GenerateUploadURLParams

WithHTTPClient adds the HTTPClient to the generate upload URL params

func (*GenerateUploadURLParams) WithProjectID 

func (o *GenerateUploadURLParams) WithProjectID(projectID string) *GenerateUploadURLParams

WithProjectID adds the projectID to the generate upload URL params

func (*GenerateUploadURLParams) WithTimeout 

func (o *GenerateUploadURLParams) WithTimeout(timeout time.Duration) *GenerateUploadURLParams

WithTimeout adds the timeout to the generate upload URL params

func (*GenerateUploadURLParams) WriteToRequest 

func (o *GenerateUploadURLParams) WriteToRequest(r runtime.ClientRequest, reg strfmt.Registry) error

WriteToRequest writes these params to a swagger request

type GenerateUploadURLReader 

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

GenerateUploadURLReader is a Reader for the GenerateUploadURL structure.

func (*GenerateUploadURLReader) ReadResponse 

func (o *GenerateUploadURLReader) ReadResponse(response runtime.ClientResponse, consumer runtime.Consumer) (interface{}, error)

ReadResponse reads a server response into the received o.

type GetImportDefault 

type GetImportDefault struct {
	Payload *models.GooglerpcStatus
	// contains filtered or unexported fields
}

GetImportDefault describes a response with status code -1, with default header values.

An unexpected error response.

func NewGetImportDefault 

func NewGetImportDefault(code int) *GetImportDefault

NewGetImportDefault creates a GetImportDefault with default headers values

func (*GetImportDefault) Code 

func (o *GetImportDefault) Code() int

Code gets the status code for the get import default response

func (*GetImportDefault) Error 

func (o *GetImportDefault) Error() string

func (*GetImportDefault) GetPayload 

func (o *GetImportDefault) GetPayload() *models.GooglerpcStatus

func (*GetImportDefault) IsClientError 

func (o *GetImportDefault) IsClientError() bool

IsClientError returns true when this get import default response has a 4xx status code

func (*GetImportDefault) IsCode 

func (o *GetImportDefault) IsCode(code int) bool

IsCode returns true when this get import default response a status code equal to that given

func (*GetImportDefault) IsRedirect 

func (o *GetImportDefault) IsRedirect() bool

IsRedirect returns true when this get import default response has a 3xx status code

func (*GetImportDefault) IsServerError 

func (o *GetImportDefault) IsServerError() bool

IsServerError returns true when this get import default response has a 5xx status code

func (*GetImportDefault) IsSuccess 

func (o *GetImportDefault) IsSuccess() bool

IsSuccess returns true when this get import default response has a 2xx status code

func (*GetImportDefault) String 

func (o *GetImportDefault) String() string

type GetImportOK 

type GetImportOK struct {
	Payload *models.OpenapiGetImportResp
}

GetImportOK describes a response with status code 200, with default header values.

A successful response.

func NewGetImportOK 

func NewGetImportOK() *GetImportOK

NewGetImportOK creates a GetImportOK with default headers values

func (*GetImportOK) Error 

func (o *GetImportOK) Error() string

func (*GetImportOK) GetPayload 

func (o *GetImportOK) GetPayload() *models.OpenapiGetImportResp

func (*GetImportOK) IsClientError 

func (o *GetImportOK) IsClientError() bool

IsClientError returns true when this get import o k response has a 4xx status code

func (*GetImportOK) IsCode 

func (o *GetImportOK) IsCode(code int) bool

IsCode returns true when this get import o k response a status code equal to that given

func (*GetImportOK) IsRedirect 

func (o *GetImportOK) IsRedirect() bool

IsRedirect returns true when this get import o k response has a 3xx status code

func (*GetImportOK) IsServerError 

func (o *GetImportOK) IsServerError() bool

IsServerError returns true when this get import o k response has a 5xx status code

func (*GetImportOK) IsSuccess 

func (o *GetImportOK) IsSuccess() bool

IsSuccess returns true when this get import o k response has a 2xx status code

func (*GetImportOK) String 

func (o *GetImportOK) String() string

type GetImportParams 

type GetImportParams struct {

	/* ClusterID.

	   The ID of the cluster.

	   Format: uint64
	*/
	ClusterID string

	/* ID.

	   The ID of the import job.

	   Format: uint64
	*/
	ID string

	/* ProjectID.

	   The ID of the project.

	   Format: uint64
	*/
	ProjectID string

	Context    context.Context
	HTTPClient *http.Client
	// contains filtered or unexported fields
}

GetImportParams contains all the parameters to send to the API endpoint 

for the get import operation.

Typically these are written to a http.Request.

func NewGetImportParams 

func NewGetImportParams() *GetImportParams

NewGetImportParams creates a new GetImportParams object, with the default timeout for this client.

Default values are not hydrated, since defaults are normally applied by the API server side.

To enforce default values in parameter, use SetDefaults or WithDefaults.

func NewGetImportParamsWithContext 

func NewGetImportParamsWithContext(ctx context.Context) *GetImportParams

NewGetImportParamsWithContext creates a new GetImportParams object with the ability to set a context for a request.

func NewGetImportParamsWithHTTPClient 

func NewGetImportParamsWithHTTPClient(client *http.Client) *GetImportParams

NewGetImportParamsWithHTTPClient creates a new GetImportParams object with the ability to set a custom HTTPClient for a request.

func NewGetImportParamsWithTimeout 

func NewGetImportParamsWithTimeout(timeout time.Duration) *GetImportParams

NewGetImportParamsWithTimeout creates a new GetImportParams object with the ability to set a timeout on a request.

func (*GetImportParams) SetClusterID 

func (o *GetImportParams) SetClusterID(clusterID string)

SetClusterID adds the clusterId to the get import params

func (*GetImportParams) SetContext 

func (o *GetImportParams) SetContext(ctx context.Context)

SetContext adds the context to the get import params

func (*GetImportParams) SetDefaults 

func (o *GetImportParams) SetDefaults()

SetDefaults hydrates default values in the get import params (not the query body).

All values with no default are reset to their zero value.

func (*GetImportParams) SetHTTPClient 

func (o *GetImportParams) SetHTTPClient(client *http.Client)

SetHTTPClient adds the HTTPClient to the get import params

func (*GetImportParams) SetID 

func (o *GetImportParams) SetID(id string)

SetID adds the id to the get import params

func (*GetImportParams) SetProjectID 

func (o *GetImportParams) SetProjectID(projectID string)

SetProjectID adds the projectId to the get import params

func (*GetImportParams) SetTimeout 

func (o *GetImportParams) SetTimeout(timeout time.Duration)

SetTimeout adds the timeout to the get import params

func (*GetImportParams) WithClusterID 

func (o *GetImportParams) WithClusterID(clusterID string) *GetImportParams

WithClusterID adds the clusterID to the get import params

func (*GetImportParams) WithContext 

func (o *GetImportParams) WithContext(ctx context.Context) *GetImportParams

WithContext adds the context to the get import params

func (*GetImportParams) WithDefaults 

func (o *GetImportParams) WithDefaults() *GetImportParams

WithDefaults hydrates default values in the get import params (not the query body).

All values with no default are reset to their zero value.

func (*GetImportParams) WithHTTPClient 

func (o *GetImportParams) WithHTTPClient(client *http.Client) *GetImportParams

WithHTTPClient adds the HTTPClient to the get import params

func (*GetImportParams) WithID 

func (o *GetImportParams) WithID(id string) *GetImportParams

WithID adds the id to the get import params

func (*GetImportParams) WithProjectID 

func (o *GetImportParams) WithProjectID(projectID string) *GetImportParams

WithProjectID adds the projectID to the get import params

func (*GetImportParams) WithTimeout 

func (o *GetImportParams) WithTimeout(timeout time.Duration) *GetImportParams

WithTimeout adds the timeout to the get import params

func (*GetImportParams) WriteToRequest 

func (o *GetImportParams) WriteToRequest(r runtime.ClientRequest, reg strfmt.Registry) error

WriteToRequest writes these params to a swagger request

type GetImportReader 

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

GetImportReader is a Reader for the GetImport structure.

func (*GetImportReader) ReadResponse 

func (o *GetImportReader) ReadResponse(response runtime.ClientResponse, consumer runtime.Consumer) (interface{}, error)

ReadResponse reads a server response into the received o.

type ListImportsDefault 

type ListImportsDefault struct {
	Payload *models.GooglerpcStatus
	// contains filtered or unexported fields
}

ListImportsDefault describes a response with status code -1, with default header values.

An unexpected error response.

func NewListImportsDefault 

func NewListImportsDefault(code int) *ListImportsDefault

NewListImportsDefault creates a ListImportsDefault with default headers values

func (*ListImportsDefault) Code 

func (o *ListImportsDefault) Code() int

Code gets the status code for the list imports default response

func (*ListImportsDefault) Error 

func (o *ListImportsDefault) Error() string

func (*ListImportsDefault) GetPayload 

func (o *ListImportsDefault) GetPayload() *models.GooglerpcStatus

func (*ListImportsDefault) IsClientError 

func (o *ListImportsDefault) IsClientError() bool

IsClientError returns true when this list imports default response has a 4xx status code

func (*ListImportsDefault) IsCode 

func (o *ListImportsDefault) IsCode(code int) bool

IsCode returns true when this list imports default response a status code equal to that given

func (*ListImportsDefault) IsRedirect 

func (o *ListImportsDefault) IsRedirect() bool

IsRedirect returns true when this list imports default response has a 3xx status code

func (*ListImportsDefault) IsServerError 

func (o *ListImportsDefault) IsServerError() bool

IsServerError returns true when this list imports default response has a 5xx status code

func (*ListImportsDefault) IsSuccess 

func (o *ListImportsDefault) IsSuccess() bool

IsSuccess returns true when this list imports default response has a 2xx status code

func (*ListImportsDefault) String 

func (o *ListImportsDefault) String() string

type ListImportsOK 

type ListImportsOK struct {
	Payload *models.OpenapiListImportsResp
}

ListImportsOK describes a response with status code 200, with default header values.

A successful response.

func NewListImportsOK 

func NewListImportsOK() *ListImportsOK

NewListImportsOK creates a ListImportsOK with default headers values

func (*ListImportsOK) Error 

func (o *ListImportsOK) Error() string

func (*ListImportsOK) GetPayload 

func (o *ListImportsOK) GetPayload() *models.OpenapiListImportsResp

func (*ListImportsOK) IsClientError 

func (o *ListImportsOK) IsClientError() bool

IsClientError returns true when this list imports o k response has a 4xx status code

func (*ListImportsOK) IsCode 

func (o *ListImportsOK) IsCode(code int) bool

IsCode returns true when this list imports o k response a status code equal to that given

func (*ListImportsOK) IsRedirect 

func (o *ListImportsOK) IsRedirect() bool

IsRedirect returns true when this list imports o k response has a 3xx status code

func (*ListImportsOK) IsServerError 

func (o *ListImportsOK) IsServerError() bool

IsServerError returns true when this list imports o k response has a 5xx status code

func (*ListImportsOK) IsSuccess 

func (o *ListImportsOK) IsSuccess() bool

IsSuccess returns true when this list imports o k response has a 2xx status code

func (*ListImportsOK) String 

func (o *ListImportsOK) String() string

type ListImportsParams 

type ListImportsParams struct {

	/* ClusterID.

	   The ID of the cluster.

	   Format: uint64
	*/
	ClusterID string

	/* Page.

	   The number of pages.

	   Format: int32
	   Default: 1
	*/
	Page *int32

	/* PageSize.

	   The size of a page.

	   Format: int32
	   Default: 10
	*/
	PageSize *int32

	/* ProjectID.

	   The ID of the project.

	   Format: uint64
	*/
	ProjectID string

	Context    context.Context
	HTTPClient *http.Client
	// contains filtered or unexported fields
}

ListImportsParams contains all the parameters to send to the API endpoint 

for the list imports operation.

Typically these are written to a http.Request.

func NewListImportsParams 

func NewListImportsParams() *ListImportsParams

NewListImportsParams creates a new ListImportsParams object, with the default timeout for this client.

Default values are not hydrated, since defaults are normally applied by the API server side.

To enforce default values in parameter, use SetDefaults or WithDefaults.

func NewListImportsParamsWithContext 

func NewListImportsParamsWithContext(ctx context.Context) *ListImportsParams

NewListImportsParamsWithContext creates a new ListImportsParams object with the ability to set a context for a request.

func NewListImportsParamsWithHTTPClient 

func NewListImportsParamsWithHTTPClient(client *http.Client) *ListImportsParams

NewListImportsParamsWithHTTPClient creates a new ListImportsParams object with the ability to set a custom HTTPClient for a request.

func NewListImportsParamsWithTimeout 

func NewListImportsParamsWithTimeout(timeout time.Duration) *ListImportsParams

NewListImportsParamsWithTimeout creates a new ListImportsParams object with the ability to set a timeout on a request.

func (*ListImportsParams) SetClusterID 

func (o *ListImportsParams) SetClusterID(clusterID string)

SetClusterID adds the clusterId to the list imports params

func (*ListImportsParams) SetContext 

func (o *ListImportsParams) SetContext(ctx context.Context)

SetContext adds the context to the list imports params

func (*ListImportsParams) SetDefaults 

func (o *ListImportsParams) SetDefaults()

SetDefaults hydrates default values in the list imports params (not the query body).

All values with no default are reset to their zero value.

func (*ListImportsParams) SetHTTPClient 

func (o *ListImportsParams) SetHTTPClient(client *http.Client)

SetHTTPClient adds the HTTPClient to the list imports params

func (*ListImportsParams) SetPage 

func (o *ListImportsParams) SetPage(page *int32)

SetPage adds the page to the list imports params

func (*ListImportsParams) SetPageSize 

func (o *ListImportsParams) SetPageSize(pageSize *int32)

SetPageSize adds the pageSize to the list imports params

func (*ListImportsParams) SetProjectID 

func (o *ListImportsParams) SetProjectID(projectID string)

SetProjectID adds the projectId to the list imports params

func (*ListImportsParams) SetTimeout 

func (o *ListImportsParams) SetTimeout(timeout time.Duration)

SetTimeout adds the timeout to the list imports params

func (*ListImportsParams) WithClusterID 

func (o *ListImportsParams) WithClusterID(clusterID string) *ListImportsParams

WithClusterID adds the clusterID to the list imports params

func (*ListImportsParams) WithContext 

func (o *ListImportsParams) WithContext(ctx context.Context) *ListImportsParams

WithContext adds the context to the list imports params

func (*ListImportsParams) WithDefaults 

func (o *ListImportsParams) WithDefaults() *ListImportsParams

WithDefaults hydrates default values in the list imports params (not the query body).

All values with no default are reset to their zero value.

func (*ListImportsParams) WithHTTPClient 

func (o *ListImportsParams) WithHTTPClient(client *http.Client) *ListImportsParams

WithHTTPClient adds the HTTPClient to the list imports params

func (*ListImportsParams) WithPage 

func (o *ListImportsParams) WithPage(page *int32) *ListImportsParams

WithPage adds the page to the list imports params

func (*ListImportsParams) WithPageSize 

func (o *ListImportsParams) WithPageSize(pageSize *int32) *ListImportsParams

WithPageSize adds the pageSize to the list imports params

func (*ListImportsParams) WithProjectID 

func (o *ListImportsParams) WithProjectID(projectID string) *ListImportsParams

WithProjectID adds the projectID to the list imports params

func (*ListImportsParams) WithTimeout 

func (o *ListImportsParams) WithTimeout(timeout time.Duration) *ListImportsParams

WithTimeout adds the timeout to the list imports params

func (*ListImportsParams) WriteToRequest 

func (o *ListImportsParams) WriteToRequest(r runtime.ClientRequest, reg strfmt.Registry) error

WriteToRequest writes these params to a swagger request

type ListImportsReader 

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

ListImportsReader is a Reader for the ListImports structure.

func (*ListImportsReader) ReadResponse 

func (o *ListImportsReader) ReadResponse(response runtime.ClientResponse, consumer runtime.Consumer) (interface{}, error)

ReadResponse reads a server response into the received o.

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.