artifact_upload_process_queue

package
v0.68.0 Latest Latest
Warning

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

 Go to latest Published: Apr 16, 2024 License: MIT Imports: 16 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Client 

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

Client for artifact upload process queue API

func (*Client) DeleteActiveQueue deprecated 

func (a *Client) DeleteActiveQueue(params *DeleteActiveQueueParams, authInfo runtime.ClientAuthInfoWriter) (*DeleteActiveQueueNoContent, *DeleteActiveQueueBadRequest, *DeleteActiveQueueUnauthorized, *DeleteActiveQueueInternalServerError, error)

Deprecated: 2022-08-10 - Use DeleteActiveQueueShort instead.

DeleteActiveQueue delete active queue process on a node ``` Required permission: ADMIN:DSAM:ARTIFACT:QUEUE [DELETE]

This endpoint is used to delete active queue process on a node ```

func (*Client) DeleteActiveQueueShort 

func (a *Client) DeleteActiveQueueShort(params *DeleteActiveQueueParams, authInfo runtime.ClientAuthInfoWriter) (*DeleteActiveQueueNoContent, error)

DeleteActiveQueueShort delete active queue process on a node ``` Required permission: ADMIN:DSAM:ARTIFACT:QUEUE [DELETE]

This endpoint is used to delete active queue process on a node ```

func (*Client) DeleteNodeByID deprecated 

func (a *Client) DeleteNodeByID(params *DeleteNodeByIDParams, authInfo runtime.ClientAuthInfoWriter) (*DeleteNodeByIDNoContent, *DeleteNodeByIDBadRequest, *DeleteNodeByIDInternalServerError, error)

Deprecated: 2022-08-10 - Use DeleteNodeByIDShort instead.

DeleteNodeByID delete a node that previously held artifact queue by ip address Required permission: ADMIN:DSAM:ARTIFACT:NODES [DELETE]

Required scope: social

This endpoint will delete a node by IP

func (*Client) DeleteNodeByIDShort 

func (a *Client) DeleteNodeByIDShort(params *DeleteNodeByIDParams, authInfo runtime.ClientAuthInfoWriter) (*DeleteNodeByIDNoContent, error)

DeleteNodeByIDShort delete a node that previously held artifact queue by ip address Required permission: ADMIN:DSAM:ARTIFACT:NODES [DELETE]

Required scope: social

This endpoint will delete a node by IP

func (*Client) DeleteQueue deprecated 

func (a *Client) DeleteQueue(params *DeleteQueueParams, authInfo runtime.ClientAuthInfoWriter) (*DeleteQueueNoContent, *DeleteQueueBadRequest, *DeleteQueueInternalServerError, error)

Deprecated: 2022-08-10 - Use DeleteQueueShort instead.

DeleteQueue delete a queue entry Required permission: ADMIN:NAMESPACE:{namespace}:DSAM:ARTIFACT:QUEUE [DELETE]

Required scope: social

This endpoint will delete a queue entry

func (*Client) DeleteQueueShort 

func (a *Client) DeleteQueueShort(params *DeleteQueueParams, authInfo runtime.ClientAuthInfoWriter) (*DeleteQueueNoContent, error)

DeleteQueueShort delete a queue entry Required permission: ADMIN:NAMESPACE:{namespace}:DSAM:ARTIFACT:QUEUE [DELETE]

Required scope: social

This endpoint will delete a queue entry

func (*Client) GetActiveQueue deprecated 

func (a *Client) GetActiveQueue(params *GetActiveQueueParams, authInfo runtime.ClientAuthInfoWriter) (*GetActiveQueueOK, *GetActiveQueueBadRequest, *GetActiveQueueUnauthorized, *GetActiveQueueNotFound, *GetActiveQueueInternalServerError, error)

Deprecated: 2022-08-10 - Use GetActiveQueueShort instead.

GetActiveQueue get active queue process on a node ``` Required permission: ADMIN:DSAM:ARTIFACT:QUEUE [READ]

This endpoint is used to get an active queue process on a node ```

func (*Client) GetActiveQueueShort 

func (a *Client) GetActiveQueueShort(params *GetActiveQueueParams, authInfo runtime.ClientAuthInfoWriter) (*GetActiveQueueOK, error)

GetActiveQueueShort get active queue process on a node ``` Required permission: ADMIN:DSAM:ARTIFACT:QUEUE [READ]

This endpoint is used to get an active queue process on a node ```

func (*Client) ListAllActiveQueue deprecated 

func (a *Client) ListAllActiveQueue(params *ListAllActiveQueueParams, authInfo runtime.ClientAuthInfoWriter) (*ListAllActiveQueueOK, *ListAllActiveQueueBadRequest, *ListAllActiveQueueNotFound, *ListAllActiveQueueInternalServerError, error)

Deprecated: 2022-08-10 - Use ListAllActiveQueueShort instead.

ListAllActiveQueue get all currently uploading artifact queue Required permission: ADMIN:NAMESPACE:{namespace}:DSAM:ARTIFACT:QUEUE [READ]

Required scope: social

This endpoint will list all DSes which artifact is currently in uploading process.

func (*Client) ListAllActiveQueueShort 

func (a *Client) ListAllActiveQueueShort(params *ListAllActiveQueueParams, authInfo runtime.ClientAuthInfoWriter) (*ListAllActiveQueueOK, error)

ListAllActiveQueueShort get all currently uploading artifact queue Required permission: ADMIN:NAMESPACE:{namespace}:DSAM:ARTIFACT:QUEUE [READ]

Required scope: social

This endpoint will list all DSes which artifact is currently in uploading process.

func (*Client) ListAllQueue deprecated 

func (a *Client) ListAllQueue(params *ListAllQueueParams, authInfo runtime.ClientAuthInfoWriter) (*ListAllQueueOK, *ListAllQueueBadRequest, *ListAllQueueNotFound, *ListAllQueueInternalServerError, error)

Deprecated: 2022-08-10 - Use ListAllQueueShort instead.

ListAllQueue get all artifact upload process queues Required permission: ADMIN:NAMESPACE:{namespace}:DSAM:ARTIFACT:QUEUE [READ]

Required scope: social

This endpoint will list all DSes which has artifact in upload queue.

func (*Client) ListAllQueueShort 

func (a *Client) ListAllQueueShort(params *ListAllQueueParams, authInfo runtime.ClientAuthInfoWriter) (*ListAllQueueOK, error)

ListAllQueueShort get all artifact upload process queues Required permission: ADMIN:NAMESPACE:{namespace}:DSAM:ARTIFACT:QUEUE [READ]

Required scope: social

This endpoint will list all DSes which has artifact in upload queue.

func (*Client) ListNodesIPAddress deprecated 

func (a *Client) ListNodesIPAddress(params *ListNodesIPAddressParams, authInfo runtime.ClientAuthInfoWriter) (*ListNodesIPAddressOK, *ListNodesIPAddressBadRequest, *ListNodesIPAddressInternalServerError, error)

Deprecated: 2022-08-10 - Use ListNodesIPAddressShort instead.

ListNodesIPAddress get ip address of all nodes that all artifact in queue resides. this ip address is the ip address of nomad client Required permission: ADMIN:DSAM:ARTIFACT:NODES [READ]

Required scope: social

This endpoint will list IP Address of all artifact queue

func (*Client) ListNodesIPAddressShort 

func (a *Client) ListNodesIPAddressShort(params *ListNodesIPAddressParams, authInfo runtime.ClientAuthInfoWriter) (*ListNodesIPAddressOK, error)

ListNodesIPAddressShort get ip address of all nodes that all artifact in queue resides. this ip address is the ip address of nomad client Required permission: ADMIN:DSAM:ARTIFACT:NODES [READ]

Required scope: social

This endpoint will list IP Address of all artifact queue

func (*Client) ListQueue deprecated 

func (a *Client) ListQueue(params *ListQueueParams, authInfo runtime.ClientAuthInfoWriter) (*ListQueueOK, *ListQueueBadRequest, *ListQueueUnauthorized, *ListQueueNotFound, *ListQueueInternalServerError, error)

Deprecated: 2022-08-10 - Use ListQueueShort instead.

ListQueue get list of queues on a node ``` Required permission: ADMIN:DSAM:ARTIFACT:QUEUE [READ]

This endpoint is used to get the list of queues on a node ```

func (*Client) ListQueueShort 

func (a *Client) ListQueueShort(params *ListQueueParams, authInfo runtime.ClientAuthInfoWriter) (*ListQueueOK, error)

ListQueueShort get list of queues on a node ``` Required permission: ADMIN:DSAM:ARTIFACT:QUEUE [READ]

This endpoint is used to get the list of queues on a node ```

func (*Client) ReportFailedUpload deprecated 

func (a *Client) ReportFailedUpload(params *ReportFailedUploadParams, authInfo runtime.ClientAuthInfoWriter) (*ReportFailedUploadNoContent, *ReportFailedUploadBadRequest, *ReportFailedUploadUnauthorized, *ReportFailedUploadInternalServerError, error)

Deprecated: 2022-08-10 - Use ReportFailedUploadShort instead.

ReportFailedUpload report failed artifact upload ``` Required permission: ADMIN:DSAM:ARTIFACT:QUEUE [UPDATE]

This endpoint is used to report a failed artifact upload ```

func (*Client) ReportFailedUploadShort 

func (a *Client) ReportFailedUploadShort(params *ReportFailedUploadParams, authInfo runtime.ClientAuthInfoWriter) (*ReportFailedUploadNoContent, error)

ReportFailedUploadShort report failed artifact upload ``` Required permission: ADMIN:DSAM:ARTIFACT:QUEUE [UPDATE]

This endpoint is used to report a failed artifact upload ```

func (*Client) SetActiveQueue deprecated 

func (a *Client) SetActiveQueue(params *SetActiveQueueParams, authInfo runtime.ClientAuthInfoWriter) (*SetActiveQueueNoContent, *SetActiveQueueBadRequest, *SetActiveQueueUnauthorized, *SetActiveQueueInternalServerError, error)

Deprecated: 2022-08-10 - Use SetActiveQueueShort instead.

SetActiveQueue set a queue as active queue ``` Required permission: ADMIN:DSAM:ARTIFACT:QUEUE [UPDATE]

This endpoint is used to set a queue entry as the current active queue for artifact uploading process on a node ```

func (*Client) SetActiveQueueShort 

func (a *Client) SetActiveQueueShort(params *SetActiveQueueParams, authInfo runtime.ClientAuthInfoWriter) (*SetActiveQueueNoContent, error)

SetActiveQueueShort set a queue as active queue ``` Required permission: ADMIN:DSAM:ARTIFACT:QUEUE [UPDATE]

This endpoint is used to set a queue entry as the current active queue for artifact uploading process on a node ```

func (*Client) SetTransport 

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

SetTransport changes the transport on the client

type ClientService 

type ClientService interface {
	ListNodesIPAddress(params *ListNodesIPAddressParams, authInfo runtime.ClientAuthInfoWriter) (*ListNodesIPAddressOK, *ListNodesIPAddressBadRequest, *ListNodesIPAddressInternalServerError, error)
	ListNodesIPAddressShort(params *ListNodesIPAddressParams, authInfo runtime.ClientAuthInfoWriter) (*ListNodesIPAddressOK, error)
	DeleteNodeByID(params *DeleteNodeByIDParams, authInfo runtime.ClientAuthInfoWriter) (*DeleteNodeByIDNoContent, *DeleteNodeByIDBadRequest, *DeleteNodeByIDInternalServerError, error)
	DeleteNodeByIDShort(params *DeleteNodeByIDParams, authInfo runtime.ClientAuthInfoWriter) (*DeleteNodeByIDNoContent, error)
	ListQueue(params *ListQueueParams, authInfo runtime.ClientAuthInfoWriter) (*ListQueueOK, *ListQueueBadRequest, *ListQueueUnauthorized, *ListQueueNotFound, *ListQueueInternalServerError, error)
	ListQueueShort(params *ListQueueParams, authInfo runtime.ClientAuthInfoWriter) (*ListQueueOK, error)
	GetActiveQueue(params *GetActiveQueueParams, authInfo runtime.ClientAuthInfoWriter) (*GetActiveQueueOK, *GetActiveQueueBadRequest, *GetActiveQueueUnauthorized, *GetActiveQueueNotFound, *GetActiveQueueInternalServerError, error)
	GetActiveQueueShort(params *GetActiveQueueParams, authInfo runtime.ClientAuthInfoWriter) (*GetActiveQueueOK, error)
	SetActiveQueue(params *SetActiveQueueParams, authInfo runtime.ClientAuthInfoWriter) (*SetActiveQueueNoContent, *SetActiveQueueBadRequest, *SetActiveQueueUnauthorized, *SetActiveQueueInternalServerError, error)
	SetActiveQueueShort(params *SetActiveQueueParams, authInfo runtime.ClientAuthInfoWriter) (*SetActiveQueueNoContent, error)
	DeleteActiveQueue(params *DeleteActiveQueueParams, authInfo runtime.ClientAuthInfoWriter) (*DeleteActiveQueueNoContent, *DeleteActiveQueueBadRequest, *DeleteActiveQueueUnauthorized, *DeleteActiveQueueInternalServerError, error)
	DeleteActiveQueueShort(params *DeleteActiveQueueParams, authInfo runtime.ClientAuthInfoWriter) (*DeleteActiveQueueNoContent, error)
	ReportFailedUpload(params *ReportFailedUploadParams, authInfo runtime.ClientAuthInfoWriter) (*ReportFailedUploadNoContent, *ReportFailedUploadBadRequest, *ReportFailedUploadUnauthorized, *ReportFailedUploadInternalServerError, error)
	ReportFailedUploadShort(params *ReportFailedUploadParams, authInfo runtime.ClientAuthInfoWriter) (*ReportFailedUploadNoContent, error)
	DeleteQueue(params *DeleteQueueParams, authInfo runtime.ClientAuthInfoWriter) (*DeleteQueueNoContent, *DeleteQueueBadRequest, *DeleteQueueInternalServerError, error)
	DeleteQueueShort(params *DeleteQueueParams, authInfo runtime.ClientAuthInfoWriter) (*DeleteQueueNoContent, error)
	ListAllActiveQueue(params *ListAllActiveQueueParams, authInfo runtime.ClientAuthInfoWriter) (*ListAllActiveQueueOK, *ListAllActiveQueueBadRequest, *ListAllActiveQueueNotFound, *ListAllActiveQueueInternalServerError, error)
	ListAllActiveQueueShort(params *ListAllActiveQueueParams, authInfo runtime.ClientAuthInfoWriter) (*ListAllActiveQueueOK, error)
	ListAllQueue(params *ListAllQueueParams, authInfo runtime.ClientAuthInfoWriter) (*ListAllQueueOK, *ListAllQueueBadRequest, *ListAllQueueNotFound, *ListAllQueueInternalServerError, error)
	ListAllQueueShort(params *ListAllQueueParams, authInfo runtime.ClientAuthInfoWriter) (*ListAllQueueOK, 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 artifact upload process queue API client.

type DeleteActiveQueueBadRequest 

type DeleteActiveQueueBadRequest struct {
	Payload *dsartifactclientmodels.ResponseError
}

DeleteActiveQueueBadRequest handles this case with default header values. 

Bad Request

func NewDeleteActiveQueueBadRequest 

func NewDeleteActiveQueueBadRequest() *DeleteActiveQueueBadRequest

NewDeleteActiveQueueBadRequest creates a DeleteActiveQueueBadRequest with default headers values

func (*DeleteActiveQueueBadRequest) Error 

func (o *DeleteActiveQueueBadRequest) Error() string

func (*DeleteActiveQueueBadRequest) GetPayload 

func (o *DeleteActiveQueueBadRequest) GetPayload() *dsartifactclientmodels.ResponseError

func (*DeleteActiveQueueBadRequest) ToJSONString 

func (o *DeleteActiveQueueBadRequest) ToJSONString() string

type DeleteActiveQueueInternalServerError 

type DeleteActiveQueueInternalServerError struct {
	Payload *dsartifactclientmodels.ResponseError
}

DeleteActiveQueueInternalServerError handles this case with default header values. 

Internal Server Error

func NewDeleteActiveQueueInternalServerError 

func NewDeleteActiveQueueInternalServerError() *DeleteActiveQueueInternalServerError

NewDeleteActiveQueueInternalServerError creates a DeleteActiveQueueInternalServerError with default headers values

func (*DeleteActiveQueueInternalServerError) Error 

func (o *DeleteActiveQueueInternalServerError) Error() string

func (*DeleteActiveQueueInternalServerError) GetPayload 

func (o *DeleteActiveQueueInternalServerError) GetPayload() *dsartifactclientmodels.ResponseError

func (*DeleteActiveQueueInternalServerError) ToJSONString 

func (o *DeleteActiveQueueInternalServerError) ToJSONString() string

type DeleteActiveQueueNoContent 

type DeleteActiveQueueNoContent struct {
}

DeleteActiveQueueNoContent handles this case with default header values. 

No Content

func NewDeleteActiveQueueNoContent 

func NewDeleteActiveQueueNoContent() *DeleteActiveQueueNoContent

NewDeleteActiveQueueNoContent creates a DeleteActiveQueueNoContent with default headers values

func (*DeleteActiveQueueNoContent) Error 

func (o *DeleteActiveQueueNoContent) Error() string

type DeleteActiveQueueParams 

type DeleteActiveQueueParams struct {

	/*RetryPolicy*/
	RetryPolicy *utils.Retry
	/*NodeIP
	  IP Address of the node doing the upload process

	*/
	NodeIP string

	AuthInfoWriter runtime.ClientAuthInfoWriter
	Context        context.Context
	HTTPClient     *http.Client

	// XFlightId is an optional parameter from this SDK
	XFlightId *string
	// contains filtered or unexported fields
}

DeleteActiveQueueParams contains all the parameters to send to the API endpoint for the delete active queue operation typically these are written to a http.Request

func NewDeleteActiveQueueParams 

func NewDeleteActiveQueueParams() *DeleteActiveQueueParams

NewDeleteActiveQueueParams creates a new DeleteActiveQueueParams object with the default values initialized.

func NewDeleteActiveQueueParamsWithContext 

func NewDeleteActiveQueueParamsWithContext(ctx context.Context) *DeleteActiveQueueParams

NewDeleteActiveQueueParamsWithContext creates a new DeleteActiveQueueParams object with the default values initialized, and the ability to set a context for a request

func NewDeleteActiveQueueParamsWithHTTPClient 

func NewDeleteActiveQueueParamsWithHTTPClient(client *http.Client) *DeleteActiveQueueParams

NewDeleteActiveQueueParamsWithHTTPClient creates a new DeleteActiveQueueParams object with the default values initialized, and the ability to set a custom HTTPClient for a request

func NewDeleteActiveQueueParamsWithTimeout 

func NewDeleteActiveQueueParamsWithTimeout(timeout time.Duration) *DeleteActiveQueueParams

NewDeleteActiveQueueParamsWithTimeout creates a new DeleteActiveQueueParams object with the default values initialized, and the ability to set a timeout on a request

func (*DeleteActiveQueueParams) SetAuthInfoWriter 

func (o *DeleteActiveQueueParams) SetAuthInfoWriter(authInfoWriter runtime.ClientAuthInfoWriter)

SetAuthInfoWriter adds the authInfoWriter to the delete active queue params

func (*DeleteActiveQueueParams) SetContext 

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

SetContext adds the context to the delete active queue params

func (*DeleteActiveQueueParams) SetFlightId 

func (o *DeleteActiveQueueParams) SetFlightId(flightId string)

SetFlightId adds the flightId as the header value for this specific endpoint

func (*DeleteActiveQueueParams) SetHTTPClient 

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

SetHTTPClient adds the HTTPClient to the delete active queue params

func (*DeleteActiveQueueParams) SetHTTPClientTransport 

func (o *DeleteActiveQueueParams) SetHTTPClientTransport(roundTripper http.RoundTripper)

SetHTTPClient adds the HTTPClient Transport to the delete active queue params

func (*DeleteActiveQueueParams) SetNodeIP 

func (o *DeleteActiveQueueParams) SetNodeIP(nodeIP string)

SetNodeIP adds the nodeIp to the delete active queue params

func (*DeleteActiveQueueParams) SetTimeout 

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

SetTimeout adds the timeout to the delete active queue params

func (*DeleteActiveQueueParams) WithContext 

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

WithContext adds the context to the delete active queue params

func (*DeleteActiveQueueParams) WithHTTPClient 

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

WithHTTPClient adds the HTTPClient to the delete active queue params

func (*DeleteActiveQueueParams) WithNodeIP 

func (o *DeleteActiveQueueParams) WithNodeIP(nodeIP string) *DeleteActiveQueueParams

WithNodeIP adds the nodeIP to the delete active queue params

func (*DeleteActiveQueueParams) WithTimeout 

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

WithTimeout adds the timeout to the delete active queue params

func (*DeleteActiveQueueParams) WriteToRequest 

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

WriteToRequest writes these params to a swagger request

type DeleteActiveQueueReader 

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

DeleteActiveQueueReader is a Reader for the DeleteActiveQueue structure.

func (*DeleteActiveQueueReader) ReadResponse 

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

ReadResponse reads a server response into the received o.

type DeleteActiveQueueUnauthorized 

type DeleteActiveQueueUnauthorized struct {
	Payload *dsartifactclientmodels.ResponseError
}

DeleteActiveQueueUnauthorized handles this case with default header values. 

Unauthorized

func NewDeleteActiveQueueUnauthorized 

func NewDeleteActiveQueueUnauthorized() *DeleteActiveQueueUnauthorized

NewDeleteActiveQueueUnauthorized creates a DeleteActiveQueueUnauthorized with default headers values

func (*DeleteActiveQueueUnauthorized) Error 

func (o *DeleteActiveQueueUnauthorized) Error() string

func (*DeleteActiveQueueUnauthorized) GetPayload 

func (o *DeleteActiveQueueUnauthorized) GetPayload() *dsartifactclientmodels.ResponseError

func (*DeleteActiveQueueUnauthorized) ToJSONString 

func (o *DeleteActiveQueueUnauthorized) ToJSONString() string

type DeleteNodeByIDBadRequest 

type DeleteNodeByIDBadRequest struct {
	Payload *dsartifactclientmodels.ResponseError
}

DeleteNodeByIDBadRequest handles this case with default header values. 

Bad Request

func NewDeleteNodeByIDBadRequest 

func NewDeleteNodeByIDBadRequest() *DeleteNodeByIDBadRequest

NewDeleteNodeByIDBadRequest creates a DeleteNodeByIDBadRequest with default headers values

func (*DeleteNodeByIDBadRequest) Error 

func (o *DeleteNodeByIDBadRequest) Error() string

func (*DeleteNodeByIDBadRequest) GetPayload 

func (o *DeleteNodeByIDBadRequest) GetPayload() *dsartifactclientmodels.ResponseError

func (*DeleteNodeByIDBadRequest) ToJSONString 

func (o *DeleteNodeByIDBadRequest) ToJSONString() string

type DeleteNodeByIDInternalServerError 

type DeleteNodeByIDInternalServerError struct {
	Payload *dsartifactclientmodels.ResponseError
}

DeleteNodeByIDInternalServerError handles this case with default header values. 

Internal Server Error

func NewDeleteNodeByIDInternalServerError 

func NewDeleteNodeByIDInternalServerError() *DeleteNodeByIDInternalServerError

NewDeleteNodeByIDInternalServerError creates a DeleteNodeByIDInternalServerError with default headers values

func (*DeleteNodeByIDInternalServerError) Error 

func (o *DeleteNodeByIDInternalServerError) Error() string

func (*DeleteNodeByIDInternalServerError) GetPayload 

func (o *DeleteNodeByIDInternalServerError) GetPayload() *dsartifactclientmodels.ResponseError

func (*DeleteNodeByIDInternalServerError) ToJSONString 

func (o *DeleteNodeByIDInternalServerError) ToJSONString() string

type DeleteNodeByIDNoContent 

type DeleteNodeByIDNoContent struct {
}

DeleteNodeByIDNoContent handles this case with default header values. 

delete queue success.

func NewDeleteNodeByIDNoContent 

func NewDeleteNodeByIDNoContent() *DeleteNodeByIDNoContent

NewDeleteNodeByIDNoContent creates a DeleteNodeByIDNoContent with default headers values

func (*DeleteNodeByIDNoContent) Error 

func (o *DeleteNodeByIDNoContent) Error() string

type DeleteNodeByIDParams 

type DeleteNodeByIDParams struct {

	/*RetryPolicy*/
	RetryPolicy *utils.Retry
	/*NodeIP
	  IP Address of the node doing the upload process

	*/
	NodeIP string
	/*PodName
	  Pod Name of the DS who owns the artifact

	*/
	PodName string

	AuthInfoWriter runtime.ClientAuthInfoWriter
	Context        context.Context
	HTTPClient     *http.Client

	// XFlightId is an optional parameter from this SDK
	XFlightId *string
	// contains filtered or unexported fields
}

DeleteNodeByIDParams contains all the parameters to send to the API endpoint for the delete node by id operation typically these are written to a http.Request

func NewDeleteNodeByIDParams 

func NewDeleteNodeByIDParams() *DeleteNodeByIDParams

NewDeleteNodeByIDParams creates a new DeleteNodeByIDParams object with the default values initialized.

func NewDeleteNodeByIDParamsWithContext 

func NewDeleteNodeByIDParamsWithContext(ctx context.Context) *DeleteNodeByIDParams

NewDeleteNodeByIDParamsWithContext creates a new DeleteNodeByIDParams object with the default values initialized, and the ability to set a context for a request

func NewDeleteNodeByIDParamsWithHTTPClient 

func NewDeleteNodeByIDParamsWithHTTPClient(client *http.Client) *DeleteNodeByIDParams

NewDeleteNodeByIDParamsWithHTTPClient creates a new DeleteNodeByIDParams object with the default values initialized, and the ability to set a custom HTTPClient for a request

func NewDeleteNodeByIDParamsWithTimeout 

func NewDeleteNodeByIDParamsWithTimeout(timeout time.Duration) *DeleteNodeByIDParams

NewDeleteNodeByIDParamsWithTimeout creates a new DeleteNodeByIDParams object with the default values initialized, and the ability to set a timeout on a request

func (*DeleteNodeByIDParams) SetAuthInfoWriter 

func (o *DeleteNodeByIDParams) SetAuthInfoWriter(authInfoWriter runtime.ClientAuthInfoWriter)

SetAuthInfoWriter adds the authInfoWriter to the delete node by id params

func (*DeleteNodeByIDParams) SetContext 

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

SetContext adds the context to the delete node by id params

func (*DeleteNodeByIDParams) SetFlightId 

func (o *DeleteNodeByIDParams) SetFlightId(flightId string)

SetFlightId adds the flightId as the header value for this specific endpoint

func (*DeleteNodeByIDParams) SetHTTPClient 

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

SetHTTPClient adds the HTTPClient to the delete node by id params

func (*DeleteNodeByIDParams) SetHTTPClientTransport 

func (o *DeleteNodeByIDParams) SetHTTPClientTransport(roundTripper http.RoundTripper)

SetHTTPClient adds the HTTPClient Transport to the delete node by id params

func (*DeleteNodeByIDParams) SetNodeIP 

func (o *DeleteNodeByIDParams) SetNodeIP(nodeIP string)

SetNodeIP adds the nodeIp to the delete node by id params

func (*DeleteNodeByIDParams) SetPodName 

func (o *DeleteNodeByIDParams) SetPodName(podName string)

SetPodName adds the podName to the delete node by id params

func (*DeleteNodeByIDParams) SetTimeout 

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

SetTimeout adds the timeout to the delete node by id params

func (*DeleteNodeByIDParams) WithContext 

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

WithContext adds the context to the delete node by id params

func (*DeleteNodeByIDParams) WithHTTPClient 

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

WithHTTPClient adds the HTTPClient to the delete node by id params

func (*DeleteNodeByIDParams) WithNodeIP 

func (o *DeleteNodeByIDParams) WithNodeIP(nodeIP string) *DeleteNodeByIDParams

WithNodeIP adds the nodeIP to the delete node by id params

func (*DeleteNodeByIDParams) WithPodName 

func (o *DeleteNodeByIDParams) WithPodName(podName string) *DeleteNodeByIDParams

WithPodName adds the podName to the delete node by id params

func (*DeleteNodeByIDParams) WithTimeout 

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

WithTimeout adds the timeout to the delete node by id params

func (*DeleteNodeByIDParams) WriteToRequest 

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

WriteToRequest writes these params to a swagger request

type DeleteNodeByIDReader 

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

DeleteNodeByIDReader is a Reader for the DeleteNodeByID structure.

func (*DeleteNodeByIDReader) ReadResponse 

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

ReadResponse reads a server response into the received o.

type DeleteQueueBadRequest 

type DeleteQueueBadRequest struct {
	Payload *dsartifactclientmodels.ResponseError
}

DeleteQueueBadRequest handles this case with default header values. 

Bad Request

func NewDeleteQueueBadRequest 

func NewDeleteQueueBadRequest() *DeleteQueueBadRequest

NewDeleteQueueBadRequest creates a DeleteQueueBadRequest with default headers values

func (*DeleteQueueBadRequest) Error 

func (o *DeleteQueueBadRequest) Error() string

func (*DeleteQueueBadRequest) GetPayload 

func (o *DeleteQueueBadRequest) GetPayload() *dsartifactclientmodels.ResponseError

func (*DeleteQueueBadRequest) ToJSONString 

func (o *DeleteQueueBadRequest) ToJSONString() string

type DeleteQueueInternalServerError 

type DeleteQueueInternalServerError struct {
	Payload *dsartifactclientmodels.ResponseError
}

DeleteQueueInternalServerError handles this case with default header values. 

Internal Server Error

func NewDeleteQueueInternalServerError 

func NewDeleteQueueInternalServerError() *DeleteQueueInternalServerError

NewDeleteQueueInternalServerError creates a DeleteQueueInternalServerError with default headers values

func (*DeleteQueueInternalServerError) Error 

func (o *DeleteQueueInternalServerError) Error() string

func (*DeleteQueueInternalServerError) GetPayload 

func (o *DeleteQueueInternalServerError) GetPayload() *dsartifactclientmodels.ResponseError

func (*DeleteQueueInternalServerError) ToJSONString 

func (o *DeleteQueueInternalServerError) ToJSONString() string

type DeleteQueueNoContent 

type DeleteQueueNoContent struct {
}

DeleteQueueNoContent handles this case with default header values. 

delete queue success.

func NewDeleteQueueNoContent 

func NewDeleteQueueNoContent() *DeleteQueueNoContent

NewDeleteQueueNoContent creates a DeleteQueueNoContent with default headers values

func (*DeleteQueueNoContent) Error 

func (o *DeleteQueueNoContent) Error() string

type DeleteQueueParams 

type DeleteQueueParams struct {

	/*RetryPolicy*/
	RetryPolicy *utils.Retry
	/*Namespace
	  namespace of the game

	*/
	Namespace string
	/*NodeIP
	  IP Address of the node doing the upload process

	*/
	NodeIP string
	/*PodName
	  Pod Name of the DS who owns the artifact

	*/
	PodName string

	AuthInfoWriter runtime.ClientAuthInfoWriter
	Context        context.Context
	HTTPClient     *http.Client

	// XFlightId is an optional parameter from this SDK
	XFlightId *string
	// contains filtered or unexported fields
}

DeleteQueueParams contains all the parameters to send to the API endpoint for the delete queue operation typically these are written to a http.Request

func NewDeleteQueueParams 

func NewDeleteQueueParams() *DeleteQueueParams

NewDeleteQueueParams creates a new DeleteQueueParams object with the default values initialized.

func NewDeleteQueueParamsWithContext 

func NewDeleteQueueParamsWithContext(ctx context.Context) *DeleteQueueParams

NewDeleteQueueParamsWithContext creates a new DeleteQueueParams object with the default values initialized, and the ability to set a context for a request

func NewDeleteQueueParamsWithHTTPClient 

func NewDeleteQueueParamsWithHTTPClient(client *http.Client) *DeleteQueueParams

NewDeleteQueueParamsWithHTTPClient creates a new DeleteQueueParams object with the default values initialized, and the ability to set a custom HTTPClient for a request

func NewDeleteQueueParamsWithTimeout 

func NewDeleteQueueParamsWithTimeout(timeout time.Duration) *DeleteQueueParams

NewDeleteQueueParamsWithTimeout creates a new DeleteQueueParams object with the default values initialized, and the ability to set a timeout on a request

func (*DeleteQueueParams) SetAuthInfoWriter 

func (o *DeleteQueueParams) SetAuthInfoWriter(authInfoWriter runtime.ClientAuthInfoWriter)

SetAuthInfoWriter adds the authInfoWriter to the delete queue params

func (*DeleteQueueParams) SetContext 

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

SetContext adds the context to the delete queue params

func (*DeleteQueueParams) SetFlightId 

func (o *DeleteQueueParams) SetFlightId(flightId string)

SetFlightId adds the flightId as the header value for this specific endpoint

func (*DeleteQueueParams) SetHTTPClient 

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

SetHTTPClient adds the HTTPClient to the delete queue params

func (*DeleteQueueParams) SetHTTPClientTransport 

func (o *DeleteQueueParams) SetHTTPClientTransport(roundTripper http.RoundTripper)

SetHTTPClient adds the HTTPClient Transport to the delete queue params

func (*DeleteQueueParams) SetNamespace 

func (o *DeleteQueueParams) SetNamespace(namespace string)

SetNamespace adds the namespace to the delete queue params

func (*DeleteQueueParams) SetNodeIP 

func (o *DeleteQueueParams) SetNodeIP(nodeIP string)

SetNodeIP adds the nodeIp to the delete queue params

func (*DeleteQueueParams) SetPodName 

func (o *DeleteQueueParams) SetPodName(podName string)

SetPodName adds the podName to the delete queue params

func (*DeleteQueueParams) SetTimeout 

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

SetTimeout adds the timeout to the delete queue params

func (*DeleteQueueParams) WithContext 

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

WithContext adds the context to the delete queue params

func (*DeleteQueueParams) WithHTTPClient 

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

WithHTTPClient adds the HTTPClient to the delete queue params

func (*DeleteQueueParams) WithNamespace 

func (o *DeleteQueueParams) WithNamespace(namespace string) *DeleteQueueParams

WithNamespace adds the namespace to the delete queue params

func (*DeleteQueueParams) WithNodeIP 

func (o *DeleteQueueParams) WithNodeIP(nodeIP string) *DeleteQueueParams

WithNodeIP adds the nodeIP to the delete queue params

func (*DeleteQueueParams) WithPodName 

func (o *DeleteQueueParams) WithPodName(podName string) *DeleteQueueParams

WithPodName adds the podName to the delete queue params

func (*DeleteQueueParams) WithTimeout 

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

WithTimeout adds the timeout to the delete queue params

func (*DeleteQueueParams) WriteToRequest 

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

WriteToRequest writes these params to a swagger request

type DeleteQueueReader 

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

DeleteQueueReader is a Reader for the DeleteQueue structure.

func (*DeleteQueueReader) ReadResponse 

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

ReadResponse reads a server response into the received o.

type GetActiveQueueBadRequest 

type GetActiveQueueBadRequest struct {
	Payload *dsartifactclientmodels.ResponseError
}

GetActiveQueueBadRequest handles this case with default header values. 

Bad Request

func NewGetActiveQueueBadRequest 

func NewGetActiveQueueBadRequest() *GetActiveQueueBadRequest

NewGetActiveQueueBadRequest creates a GetActiveQueueBadRequest with default headers values

func (*GetActiveQueueBadRequest) Error 

func (o *GetActiveQueueBadRequest) Error() string

func (*GetActiveQueueBadRequest) GetPayload 

func (o *GetActiveQueueBadRequest) GetPayload() *dsartifactclientmodels.ResponseError

func (*GetActiveQueueBadRequest) ToJSONString 

func (o *GetActiveQueueBadRequest) ToJSONString() string

type GetActiveQueueInternalServerError 

type GetActiveQueueInternalServerError struct {
	Payload *dsartifactclientmodels.ResponseError
}

GetActiveQueueInternalServerError handles this case with default header values. 

Internal Server Error

func NewGetActiveQueueInternalServerError 

func NewGetActiveQueueInternalServerError() *GetActiveQueueInternalServerError

NewGetActiveQueueInternalServerError creates a GetActiveQueueInternalServerError with default headers values

func (*GetActiveQueueInternalServerError) Error 

func (o *GetActiveQueueInternalServerError) Error() string

func (*GetActiveQueueInternalServerError) GetPayload 

func (o *GetActiveQueueInternalServerError) GetPayload() *dsartifactclientmodels.ResponseError

func (*GetActiveQueueInternalServerError) ToJSONString 

func (o *GetActiveQueueInternalServerError) ToJSONString() string

type GetActiveQueueNotFound 

type GetActiveQueueNotFound struct {
	Payload *dsartifactclientmodels.ResponseError
}

GetActiveQueueNotFound handles this case with default header values. 

Not Found

func NewGetActiveQueueNotFound 

func NewGetActiveQueueNotFound() *GetActiveQueueNotFound

NewGetActiveQueueNotFound creates a GetActiveQueueNotFound with default headers values

func (*GetActiveQueueNotFound) Error 

func (o *GetActiveQueueNotFound) Error() string

func (*GetActiveQueueNotFound) GetPayload 

func (o *GetActiveQueueNotFound) GetPayload() *dsartifactclientmodels.ResponseError

func (*GetActiveQueueNotFound) ToJSONString 

func (o *GetActiveQueueNotFound) ToJSONString() string

type GetActiveQueueOK 

type GetActiveQueueOK struct {
	Payload *dsartifactclientmodels.ModelsQueue
}

GetActiveQueueOK handles this case with default header values. 

OK

func NewGetActiveQueueOK 

func NewGetActiveQueueOK() *GetActiveQueueOK

NewGetActiveQueueOK creates a GetActiveQueueOK with default headers values

func (*GetActiveQueueOK) Error 

func (o *GetActiveQueueOK) Error() string

func (*GetActiveQueueOK) GetPayload 

func (o *GetActiveQueueOK) GetPayload() *dsartifactclientmodels.ModelsQueue

func (*GetActiveQueueOK) ToJSONString 

func (o *GetActiveQueueOK) ToJSONString() string

type GetActiveQueueParams 

type GetActiveQueueParams struct {

	/*RetryPolicy*/
	RetryPolicy *utils.Retry
	/*NodeIP
	  IP Address of the node doing the upload process

	*/
	NodeIP string

	AuthInfoWriter runtime.ClientAuthInfoWriter
	Context        context.Context
	HTTPClient     *http.Client

	// XFlightId is an optional parameter from this SDK
	XFlightId *string
	// contains filtered or unexported fields
}

GetActiveQueueParams contains all the parameters to send to the API endpoint for the get active queue operation typically these are written to a http.Request

func NewGetActiveQueueParams 

func NewGetActiveQueueParams() *GetActiveQueueParams

NewGetActiveQueueParams creates a new GetActiveQueueParams object with the default values initialized.

func NewGetActiveQueueParamsWithContext 

func NewGetActiveQueueParamsWithContext(ctx context.Context) *GetActiveQueueParams

NewGetActiveQueueParamsWithContext creates a new GetActiveQueueParams object with the default values initialized, and the ability to set a context for a request

func NewGetActiveQueueParamsWithHTTPClient 

func NewGetActiveQueueParamsWithHTTPClient(client *http.Client) *GetActiveQueueParams

NewGetActiveQueueParamsWithHTTPClient creates a new GetActiveQueueParams object with the default values initialized, and the ability to set a custom HTTPClient for a request

func NewGetActiveQueueParamsWithTimeout 

func NewGetActiveQueueParamsWithTimeout(timeout time.Duration) *GetActiveQueueParams

NewGetActiveQueueParamsWithTimeout creates a new GetActiveQueueParams object with the default values initialized, and the ability to set a timeout on a request

func (*GetActiveQueueParams) SetAuthInfoWriter 

func (o *GetActiveQueueParams) SetAuthInfoWriter(authInfoWriter runtime.ClientAuthInfoWriter)

SetAuthInfoWriter adds the authInfoWriter to the get active queue params

func (*GetActiveQueueParams) SetContext 

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

SetContext adds the context to the get active queue params

func (*GetActiveQueueParams) SetFlightId 

func (o *GetActiveQueueParams) SetFlightId(flightId string)

SetFlightId adds the flightId as the header value for this specific endpoint

func (*GetActiveQueueParams) SetHTTPClient 

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

SetHTTPClient adds the HTTPClient to the get active queue params

func (*GetActiveQueueParams) SetHTTPClientTransport 

func (o *GetActiveQueueParams) SetHTTPClientTransport(roundTripper http.RoundTripper)

SetHTTPClient adds the HTTPClient Transport to the get active queue params

func (*GetActiveQueueParams) SetNodeIP 

func (o *GetActiveQueueParams) SetNodeIP(nodeIP string)

SetNodeIP adds the nodeIp to the get active queue params

func (*GetActiveQueueParams) SetTimeout 

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

SetTimeout adds the timeout to the get active queue params

func (*GetActiveQueueParams) WithContext 

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

WithContext adds the context to the get active queue params

func (*GetActiveQueueParams) WithHTTPClient 

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

WithHTTPClient adds the HTTPClient to the get active queue params

func (*GetActiveQueueParams) WithNodeIP 

func (o *GetActiveQueueParams) WithNodeIP(nodeIP string) *GetActiveQueueParams

WithNodeIP adds the nodeIP to the get active queue params

func (*GetActiveQueueParams) WithTimeout 

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

WithTimeout adds the timeout to the get active queue params

func (*GetActiveQueueParams) WriteToRequest 

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

WriteToRequest writes these params to a swagger request

type GetActiveQueueReader 

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

GetActiveQueueReader is a Reader for the GetActiveQueue structure.

func (*GetActiveQueueReader) ReadResponse 

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

ReadResponse reads a server response into the received o.

type GetActiveQueueUnauthorized 

type GetActiveQueueUnauthorized struct {
	Payload *dsartifactclientmodels.ResponseError
}

GetActiveQueueUnauthorized handles this case with default header values. 

Unauthorized

func NewGetActiveQueueUnauthorized 

func NewGetActiveQueueUnauthorized() *GetActiveQueueUnauthorized

NewGetActiveQueueUnauthorized creates a GetActiveQueueUnauthorized with default headers values

func (*GetActiveQueueUnauthorized) Error 

func (o *GetActiveQueueUnauthorized) Error() string

func (*GetActiveQueueUnauthorized) GetPayload 

func (o *GetActiveQueueUnauthorized) GetPayload() *dsartifactclientmodels.ResponseError

func (*GetActiveQueueUnauthorized) ToJSONString 

func (o *GetActiveQueueUnauthorized) ToJSONString() string

type ListAllActiveQueueBadRequest 

type ListAllActiveQueueBadRequest struct {
	Payload *dsartifactclientmodels.ResponseError
}

ListAllActiveQueueBadRequest handles this case with default header values. 

Bad Request

func NewListAllActiveQueueBadRequest 

func NewListAllActiveQueueBadRequest() *ListAllActiveQueueBadRequest

NewListAllActiveQueueBadRequest creates a ListAllActiveQueueBadRequest with default headers values

func (*ListAllActiveQueueBadRequest) Error 

func (o *ListAllActiveQueueBadRequest) Error() string

func (*ListAllActiveQueueBadRequest) GetPayload 

func (o *ListAllActiveQueueBadRequest) GetPayload() *dsartifactclientmodels.ResponseError

func (*ListAllActiveQueueBadRequest) ToJSONString 

func (o *ListAllActiveQueueBadRequest) ToJSONString() string

type ListAllActiveQueueInternalServerError 

type ListAllActiveQueueInternalServerError struct {
	Payload *dsartifactclientmodels.ResponseError
}

ListAllActiveQueueInternalServerError handles this case with default header values. 

Internal Server Error

func NewListAllActiveQueueInternalServerError 

func NewListAllActiveQueueInternalServerError() *ListAllActiveQueueInternalServerError

NewListAllActiveQueueInternalServerError creates a ListAllActiveQueueInternalServerError with default headers values

func (*ListAllActiveQueueInternalServerError) Error 

func (o *ListAllActiveQueueInternalServerError) Error() string

func (*ListAllActiveQueueInternalServerError) GetPayload 

func (o *ListAllActiveQueueInternalServerError) GetPayload() *dsartifactclientmodels.ResponseError

func (*ListAllActiveQueueInternalServerError) ToJSONString 

func (o *ListAllActiveQueueInternalServerError) ToJSONString() string

type ListAllActiveQueueNotFound 

type ListAllActiveQueueNotFound struct {
	Payload *dsartifactclientmodels.ResponseError
}

ListAllActiveQueueNotFound handles this case with default header values. 

Not Found

func NewListAllActiveQueueNotFound 

func NewListAllActiveQueueNotFound() *ListAllActiveQueueNotFound

NewListAllActiveQueueNotFound creates a ListAllActiveQueueNotFound with default headers values

func (*ListAllActiveQueueNotFound) Error 

func (o *ListAllActiveQueueNotFound) Error() string

func (*ListAllActiveQueueNotFound) GetPayload 

func (o *ListAllActiveQueueNotFound) GetPayload() *dsartifactclientmodels.ResponseError

func (*ListAllActiveQueueNotFound) ToJSONString 

func (o *ListAllActiveQueueNotFound) ToJSONString() string

type ListAllActiveQueueOK 

type ListAllActiveQueueOK struct {
	Payload *dsartifactclientmodels.ModelsListAllQueueResponse
}

ListAllActiveQueueOK handles this case with default header values. 

get all active queue success.

func NewListAllActiveQueueOK 

func NewListAllActiveQueueOK() *ListAllActiveQueueOK

NewListAllActiveQueueOK creates a ListAllActiveQueueOK with default headers values

func (*ListAllActiveQueueOK) Error 

func (o *ListAllActiveQueueOK) Error() string

func (*ListAllActiveQueueOK) GetPayload 

func (o *ListAllActiveQueueOK) GetPayload() *dsartifactclientmodels.ModelsListAllQueueResponse

func (*ListAllActiveQueueOK) ToJSONString 

func (o *ListAllActiveQueueOK) ToJSONString() string

type ListAllActiveQueueParams 

type ListAllActiveQueueParams struct {

	/*RetryPolicy*/
	RetryPolicy *utils.Retry
	/*Namespace
	  namespace of the game

	*/
	Namespace string
	/*Limit
	  limit

	*/
	Limit *int64
	/*Next
	  next

	*/
	Next *string
	/*NodeIP
	  IP Address of the node which the artifact located

	*/
	NodeIP *string
	/*PodName
	  Pod Name of the DS who owns the artifact

	*/
	PodName *string
	/*Previous
	  previous

	*/
	Previous *string

	AuthInfoWriter runtime.ClientAuthInfoWriter
	Context        context.Context
	HTTPClient     *http.Client

	// XFlightId is an optional parameter from this SDK
	XFlightId *string
	// contains filtered or unexported fields
}

ListAllActiveQueueParams contains all the parameters to send to the API endpoint for the list all active queue operation typically these are written to a http.Request

func NewListAllActiveQueueParams 

func NewListAllActiveQueueParams() *ListAllActiveQueueParams

NewListAllActiveQueueParams creates a new ListAllActiveQueueParams object with the default values initialized.

func NewListAllActiveQueueParamsWithContext 

func NewListAllActiveQueueParamsWithContext(ctx context.Context) *ListAllActiveQueueParams

NewListAllActiveQueueParamsWithContext creates a new ListAllActiveQueueParams object with the default values initialized, and the ability to set a context for a request

func NewListAllActiveQueueParamsWithHTTPClient 

func NewListAllActiveQueueParamsWithHTTPClient(client *http.Client) *ListAllActiveQueueParams

NewListAllActiveQueueParamsWithHTTPClient creates a new ListAllActiveQueueParams object with the default values initialized, and the ability to set a custom HTTPClient for a request

func NewListAllActiveQueueParamsWithTimeout 

func NewListAllActiveQueueParamsWithTimeout(timeout time.Duration) *ListAllActiveQueueParams

NewListAllActiveQueueParamsWithTimeout creates a new ListAllActiveQueueParams object with the default values initialized, and the ability to set a timeout on a request

func (*ListAllActiveQueueParams) SetAuthInfoWriter 

func (o *ListAllActiveQueueParams) SetAuthInfoWriter(authInfoWriter runtime.ClientAuthInfoWriter)

SetAuthInfoWriter adds the authInfoWriter to the list all active queue params

func (*ListAllActiveQueueParams) SetContext 

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

SetContext adds the context to the list all active queue params

func (*ListAllActiveQueueParams) SetFlightId 

func (o *ListAllActiveQueueParams) SetFlightId(flightId string)

SetFlightId adds the flightId as the header value for this specific endpoint

func (*ListAllActiveQueueParams) SetHTTPClient 

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

SetHTTPClient adds the HTTPClient to the list all active queue params

func (*ListAllActiveQueueParams) SetHTTPClientTransport 

func (o *ListAllActiveQueueParams) SetHTTPClientTransport(roundTripper http.RoundTripper)

SetHTTPClient adds the HTTPClient Transport to the list all active queue params

func (*ListAllActiveQueueParams) SetLimit 

func (o *ListAllActiveQueueParams) SetLimit(limit *int64)

SetLimit adds the limit to the list all active queue params

func (*ListAllActiveQueueParams) SetNamespace 

func (o *ListAllActiveQueueParams) SetNamespace(namespace string)

SetNamespace adds the namespace to the list all active queue params

func (*ListAllActiveQueueParams) SetNext 

func (o *ListAllActiveQueueParams) SetNext(nextVar *string)

SetNext adds the next to the list all active queue params

func (*ListAllActiveQueueParams) SetNodeIP 

func (o *ListAllActiveQueueParams) SetNodeIP(nodeIP *string)

SetNodeIP adds the nodeIp to the list all active queue params

func (*ListAllActiveQueueParams) SetPodName 

func (o *ListAllActiveQueueParams) SetPodName(podName *string)

SetPodName adds the podName to the list all active queue params

func (*ListAllActiveQueueParams) SetPrevious 

func (o *ListAllActiveQueueParams) SetPrevious(previous *string)

SetPrevious adds the previous to the list all active queue params

func (*ListAllActiveQueueParams) SetTimeout 

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

SetTimeout adds the timeout to the list all active queue params

func (*ListAllActiveQueueParams) WithContext 

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

WithContext adds the context to the list all active queue params

func (*ListAllActiveQueueParams) WithHTTPClient 

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

WithHTTPClient adds the HTTPClient to the list all active queue params

func (*ListAllActiveQueueParams) WithLimit 

func (o *ListAllActiveQueueParams) WithLimit(limit *int64) *ListAllActiveQueueParams

WithLimit adds the limit to the list all active queue params

func (*ListAllActiveQueueParams) WithNamespace 

func (o *ListAllActiveQueueParams) WithNamespace(namespace string) *ListAllActiveQueueParams

WithNamespace adds the namespace to the list all active queue params

func (*ListAllActiveQueueParams) WithNext 

func (o *ListAllActiveQueueParams) WithNext(nextVar *string) *ListAllActiveQueueParams

WithNext adds the nextVar to the list all active queue params

func (*ListAllActiveQueueParams) WithNodeIP 

func (o *ListAllActiveQueueParams) WithNodeIP(nodeIP *string) *ListAllActiveQueueParams

WithNodeIP adds the nodeIP to the list all active queue params

func (*ListAllActiveQueueParams) WithPodName 

func (o *ListAllActiveQueueParams) WithPodName(podName *string) *ListAllActiveQueueParams

WithPodName adds the podName to the list all active queue params

func (*ListAllActiveQueueParams) WithPrevious 

func (o *ListAllActiveQueueParams) WithPrevious(previous *string) *ListAllActiveQueueParams

WithPrevious adds the previous to the list all active queue params

func (*ListAllActiveQueueParams) WithTimeout 

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

WithTimeout adds the timeout to the list all active queue params

func (*ListAllActiveQueueParams) WriteToRequest 

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

WriteToRequest writes these params to a swagger request

type ListAllActiveQueueReader 

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

ListAllActiveQueueReader is a Reader for the ListAllActiveQueue structure.

func (*ListAllActiveQueueReader) ReadResponse 

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

ReadResponse reads a server response into the received o.

type ListAllQueueBadRequest 

type ListAllQueueBadRequest struct {
	Payload *dsartifactclientmodels.ResponseError
}

ListAllQueueBadRequest handles this case with default header values. 

Bad Request

func NewListAllQueueBadRequest 

func NewListAllQueueBadRequest() *ListAllQueueBadRequest

NewListAllQueueBadRequest creates a ListAllQueueBadRequest with default headers values

func (*ListAllQueueBadRequest) Error 

func (o *ListAllQueueBadRequest) Error() string

func (*ListAllQueueBadRequest) GetPayload 

func (o *ListAllQueueBadRequest) GetPayload() *dsartifactclientmodels.ResponseError

func (*ListAllQueueBadRequest) ToJSONString 

func (o *ListAllQueueBadRequest) ToJSONString() string

type ListAllQueueInternalServerError 

type ListAllQueueInternalServerError struct {
	Payload *dsartifactclientmodels.ResponseError
}

ListAllQueueInternalServerError handles this case with default header values. 

Internal Server Error

func NewListAllQueueInternalServerError 

func NewListAllQueueInternalServerError() *ListAllQueueInternalServerError

NewListAllQueueInternalServerError creates a ListAllQueueInternalServerError with default headers values

func (*ListAllQueueInternalServerError) Error 

func (o *ListAllQueueInternalServerError) Error() string

func (*ListAllQueueInternalServerError) GetPayload 

func (o *ListAllQueueInternalServerError) GetPayload() *dsartifactclientmodels.ResponseError

func (*ListAllQueueInternalServerError) ToJSONString 

func (o *ListAllQueueInternalServerError) ToJSONString() string

type ListAllQueueNotFound 

type ListAllQueueNotFound struct {
	Payload *dsartifactclientmodels.ResponseError
}

ListAllQueueNotFound handles this case with default header values. 

Not Found

func NewListAllQueueNotFound 

func NewListAllQueueNotFound() *ListAllQueueNotFound

NewListAllQueueNotFound creates a ListAllQueueNotFound with default headers values

func (*ListAllQueueNotFound) Error 

func (o *ListAllQueueNotFound) Error() string

func (*ListAllQueueNotFound) GetPayload 

func (o *ListAllQueueNotFound) GetPayload() *dsartifactclientmodels.ResponseError

func (*ListAllQueueNotFound) ToJSONString 

func (o *ListAllQueueNotFound) ToJSONString() string

type ListAllQueueOK 

type ListAllQueueOK struct {
	Payload *dsartifactclientmodels.ModelsListAllQueueResponse
}

ListAllQueueOK handles this case with default header values. 

get all queue success.

func NewListAllQueueOK 

func NewListAllQueueOK() *ListAllQueueOK

NewListAllQueueOK creates a ListAllQueueOK with default headers values

func (*ListAllQueueOK) Error 

func (o *ListAllQueueOK) Error() string

func (*ListAllQueueOK) GetPayload 

func (o *ListAllQueueOK) GetPayload() *dsartifactclientmodels.ModelsListAllQueueResponse

func (*ListAllQueueOK) ToJSONString 

func (o *ListAllQueueOK) ToJSONString() string

type ListAllQueueParams 

type ListAllQueueParams struct {

	/*RetryPolicy*/
	RetryPolicy *utils.Retry
	/*Namespace
	  namespace of the game

	*/
	Namespace string
	/*ExcludeUploading
	  whether the response will exclude the currently uploading DSes or not

	*/
	ExcludeUploading *bool
	/*Limit
	  limit

	*/
	Limit *int64
	/*Next
	  next

	*/
	Next *string
	/*NodeIP
	  IP Address of the node doing the upload process

	*/
	NodeIP *string
	/*Order
	  order

	*/
	Order *string
	/*PodName
	  pod name of the server

	*/
	PodName *string
	/*Previous
	  previous

	*/
	Previous *string

	AuthInfoWriter runtime.ClientAuthInfoWriter
	Context        context.Context
	HTTPClient     *http.Client

	// XFlightId is an optional parameter from this SDK
	XFlightId *string
	// contains filtered or unexported fields
}

ListAllQueueParams contains all the parameters to send to the API endpoint for the list all queue operation typically these are written to a http.Request

func NewListAllQueueParams 

func NewListAllQueueParams() *ListAllQueueParams

NewListAllQueueParams creates a new ListAllQueueParams object with the default values initialized.

func NewListAllQueueParamsWithContext 

func NewListAllQueueParamsWithContext(ctx context.Context) *ListAllQueueParams

NewListAllQueueParamsWithContext creates a new ListAllQueueParams object with the default values initialized, and the ability to set a context for a request

func NewListAllQueueParamsWithHTTPClient 

func NewListAllQueueParamsWithHTTPClient(client *http.Client) *ListAllQueueParams

NewListAllQueueParamsWithHTTPClient creates a new ListAllQueueParams object with the default values initialized, and the ability to set a custom HTTPClient for a request

func NewListAllQueueParamsWithTimeout 

func NewListAllQueueParamsWithTimeout(timeout time.Duration) *ListAllQueueParams

NewListAllQueueParamsWithTimeout creates a new ListAllQueueParams object with the default values initialized, and the ability to set a timeout on a request

func (*ListAllQueueParams) SetAuthInfoWriter 

func (o *ListAllQueueParams) SetAuthInfoWriter(authInfoWriter runtime.ClientAuthInfoWriter)

SetAuthInfoWriter adds the authInfoWriter to the list all queue params

func (*ListAllQueueParams) SetContext 

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

SetContext adds the context to the list all queue params

func (*ListAllQueueParams) SetExcludeUploading 

func (o *ListAllQueueParams) SetExcludeUploading(excludeUploading *bool)

SetExcludeUploading adds the excludeUploading to the list all queue params

func (*ListAllQueueParams) SetFlightId 

func (o *ListAllQueueParams) SetFlightId(flightId string)

SetFlightId adds the flightId as the header value for this specific endpoint

func (*ListAllQueueParams) SetHTTPClient 

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

SetHTTPClient adds the HTTPClient to the list all queue params

func (*ListAllQueueParams) SetHTTPClientTransport 

func (o *ListAllQueueParams) SetHTTPClientTransport(roundTripper http.RoundTripper)

SetHTTPClient adds the HTTPClient Transport to the list all queue params

func (*ListAllQueueParams) SetLimit 

func (o *ListAllQueueParams) SetLimit(limit *int64)

SetLimit adds the limit to the list all queue params

func (*ListAllQueueParams) SetNamespace 

func (o *ListAllQueueParams) SetNamespace(namespace string)

SetNamespace adds the namespace to the list all queue params

func (*ListAllQueueParams) SetNext 

func (o *ListAllQueueParams) SetNext(nextVar *string)

SetNext adds the next to the list all queue params

func (*ListAllQueueParams) SetNodeIP 

func (o *ListAllQueueParams) SetNodeIP(nodeIP *string)

SetNodeIP adds the nodeIp to the list all queue params

func (*ListAllQueueParams) SetOrder 

func (o *ListAllQueueParams) SetOrder(order *string)

SetOrder adds the order to the list all queue params

func (*ListAllQueueParams) SetPodName 

func (o *ListAllQueueParams) SetPodName(podName *string)

SetPodName adds the podName to the list all queue params

func (*ListAllQueueParams) SetPrevious 

func (o *ListAllQueueParams) SetPrevious(previous *string)

SetPrevious adds the previous to the list all queue params

func (*ListAllQueueParams) SetTimeout 

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

SetTimeout adds the timeout to the list all queue params

func (*ListAllQueueParams) WithContext 

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

WithContext adds the context to the list all queue params

func (*ListAllQueueParams) WithExcludeUploading 

func (o *ListAllQueueParams) WithExcludeUploading(excludeUploading *bool) *ListAllQueueParams

WithExcludeUploading adds the excludeUploading to the list all queue params

func (*ListAllQueueParams) WithHTTPClient 

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

WithHTTPClient adds the HTTPClient to the list all queue params

func (*ListAllQueueParams) WithLimit 

func (o *ListAllQueueParams) WithLimit(limit *int64) *ListAllQueueParams

WithLimit adds the limit to the list all queue params

func (*ListAllQueueParams) WithNamespace 

func (o *ListAllQueueParams) WithNamespace(namespace string) *ListAllQueueParams

WithNamespace adds the namespace to the list all queue params

func (*ListAllQueueParams) WithNext 

func (o *ListAllQueueParams) WithNext(nextVar *string) *ListAllQueueParams

WithNext adds the nextVar to the list all queue params

func (*ListAllQueueParams) WithNodeIP 

func (o *ListAllQueueParams) WithNodeIP(nodeIP *string) *ListAllQueueParams

WithNodeIP adds the nodeIP to the list all queue params

func (*ListAllQueueParams) WithOrder 

func (o *ListAllQueueParams) WithOrder(order *string) *ListAllQueueParams

WithOrder adds the order to the list all queue params

func (*ListAllQueueParams) WithPodName 

func (o *ListAllQueueParams) WithPodName(podName *string) *ListAllQueueParams

WithPodName adds the podName to the list all queue params

func (*ListAllQueueParams) WithPrevious 

func (o *ListAllQueueParams) WithPrevious(previous *string) *ListAllQueueParams

WithPrevious adds the previous to the list all queue params

func (*ListAllQueueParams) WithTimeout 

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

WithTimeout adds the timeout to the list all queue params

func (*ListAllQueueParams) WriteToRequest 

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

WriteToRequest writes these params to a swagger request

type ListAllQueueReader 

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

ListAllQueueReader is a Reader for the ListAllQueue structure.

func (*ListAllQueueReader) ReadResponse 

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

ReadResponse reads a server response into the received o.

type ListNodesIPAddressBadRequest 

type ListNodesIPAddressBadRequest struct {
	Payload *dsartifactclientmodels.ResponseError
}

ListNodesIPAddressBadRequest handles this case with default header values. 

Bad Request

func NewListNodesIPAddressBadRequest 

func NewListNodesIPAddressBadRequest() *ListNodesIPAddressBadRequest

NewListNodesIPAddressBadRequest creates a ListNodesIPAddressBadRequest with default headers values

func (*ListNodesIPAddressBadRequest) Error 

func (o *ListNodesIPAddressBadRequest) Error() string

func (*ListNodesIPAddressBadRequest) GetPayload 

func (o *ListNodesIPAddressBadRequest) GetPayload() *dsartifactclientmodels.ResponseError

func (*ListNodesIPAddressBadRequest) ToJSONString 

func (o *ListNodesIPAddressBadRequest) ToJSONString() string

type ListNodesIPAddressInternalServerError 

type ListNodesIPAddressInternalServerError struct {
	Payload *dsartifactclientmodels.ResponseError
}

ListNodesIPAddressInternalServerError handles this case with default header values. 

Internal Server Error

func NewListNodesIPAddressInternalServerError 

func NewListNodesIPAddressInternalServerError() *ListNodesIPAddressInternalServerError

NewListNodesIPAddressInternalServerError creates a ListNodesIPAddressInternalServerError with default headers values

func (*ListNodesIPAddressInternalServerError) Error 

func (o *ListNodesIPAddressInternalServerError) Error() string

func (*ListNodesIPAddressInternalServerError) GetPayload 

func (o *ListNodesIPAddressInternalServerError) GetPayload() *dsartifactclientmodels.ResponseError

func (*ListNodesIPAddressInternalServerError) ToJSONString 

func (o *ListNodesIPAddressInternalServerError) ToJSONString() string

type ListNodesIPAddressOK 

type ListNodesIPAddressOK struct {
	Payload *dsartifactclientmodels.ModelsListNodesIPAddress
}

ListNodesIPAddressOK handles this case with default header values. 

get all active queue success.

func NewListNodesIPAddressOK 

func NewListNodesIPAddressOK() *ListNodesIPAddressOK

NewListNodesIPAddressOK creates a ListNodesIPAddressOK with default headers values

func (*ListNodesIPAddressOK) Error 

func (o *ListNodesIPAddressOK) Error() string

func (*ListNodesIPAddressOK) GetPayload 

func (o *ListNodesIPAddressOK) GetPayload() *dsartifactclientmodels.ModelsListNodesIPAddress

func (*ListNodesIPAddressOK) ToJSONString 

func (o *ListNodesIPAddressOK) ToJSONString() string

type ListNodesIPAddressParams 

type ListNodesIPAddressParams struct {

	/*RetryPolicy*/
	RetryPolicy *utils.Retry
	/*Limit
	  limit

	*/
	Limit *int64
	/*Next
	  next

	*/
	Next *string
	/*NodeIP
	  IP Address of the node doing the upload process

	*/
	NodeIP *string
	/*Previous
	  previous

	*/
	Previous *string

	AuthInfoWriter runtime.ClientAuthInfoWriter
	Context        context.Context
	HTTPClient     *http.Client

	// XFlightId is an optional parameter from this SDK
	XFlightId *string
	// contains filtered or unexported fields
}

ListNodesIPAddressParams contains all the parameters to send to the API endpoint for the list nodes ip address operation typically these are written to a http.Request

func NewListNodesIPAddressParams 

func NewListNodesIPAddressParams() *ListNodesIPAddressParams

NewListNodesIPAddressParams creates a new ListNodesIPAddressParams object with the default values initialized.

func NewListNodesIPAddressParamsWithContext 

func NewListNodesIPAddressParamsWithContext(ctx context.Context) *ListNodesIPAddressParams

NewListNodesIPAddressParamsWithContext creates a new ListNodesIPAddressParams object with the default values initialized, and the ability to set a context for a request

func NewListNodesIPAddressParamsWithHTTPClient 

func NewListNodesIPAddressParamsWithHTTPClient(client *http.Client) *ListNodesIPAddressParams

NewListNodesIPAddressParamsWithHTTPClient creates a new ListNodesIPAddressParams object with the default values initialized, and the ability to set a custom HTTPClient for a request

func NewListNodesIPAddressParamsWithTimeout 

func NewListNodesIPAddressParamsWithTimeout(timeout time.Duration) *ListNodesIPAddressParams

NewListNodesIPAddressParamsWithTimeout creates a new ListNodesIPAddressParams object with the default values initialized, and the ability to set a timeout on a request

func (*ListNodesIPAddressParams) SetAuthInfoWriter 

func (o *ListNodesIPAddressParams) SetAuthInfoWriter(authInfoWriter runtime.ClientAuthInfoWriter)

SetAuthInfoWriter adds the authInfoWriter to the list nodes ip address params

func (*ListNodesIPAddressParams) SetContext 

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

SetContext adds the context to the list nodes ip address params

func (*ListNodesIPAddressParams) SetFlightId 

func (o *ListNodesIPAddressParams) SetFlightId(flightId string)

SetFlightId adds the flightId as the header value for this specific endpoint

func (*ListNodesIPAddressParams) SetHTTPClient 

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

SetHTTPClient adds the HTTPClient to the list nodes ip address params

func (*ListNodesIPAddressParams) SetHTTPClientTransport 

func (o *ListNodesIPAddressParams) SetHTTPClientTransport(roundTripper http.RoundTripper)

SetHTTPClient adds the HTTPClient Transport to the list nodes ip address params

func (*ListNodesIPAddressParams) SetLimit 

func (o *ListNodesIPAddressParams) SetLimit(limit *int64)

SetLimit adds the limit to the list nodes ip address params

func (*ListNodesIPAddressParams) SetNext 

func (o *ListNodesIPAddressParams) SetNext(nextVar *string)

SetNext adds the next to the list nodes ip address params

func (*ListNodesIPAddressParams) SetNodeIP 

func (o *ListNodesIPAddressParams) SetNodeIP(nodeIP *string)

SetNodeIP adds the nodeIp to the list nodes ip address params

func (*ListNodesIPAddressParams) SetPrevious 

func (o *ListNodesIPAddressParams) SetPrevious(previous *string)

SetPrevious adds the previous to the list nodes ip address params

func (*ListNodesIPAddressParams) SetTimeout 

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

SetTimeout adds the timeout to the list nodes ip address params

func (*ListNodesIPAddressParams) WithContext 

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

WithContext adds the context to the list nodes ip address params

func (*ListNodesIPAddressParams) WithHTTPClient 

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

WithHTTPClient adds the HTTPClient to the list nodes ip address params

func (*ListNodesIPAddressParams) WithLimit 

func (o *ListNodesIPAddressParams) WithLimit(limit *int64) *ListNodesIPAddressParams

WithLimit adds the limit to the list nodes ip address params

func (*ListNodesIPAddressParams) WithNext 

func (o *ListNodesIPAddressParams) WithNext(nextVar *string) *ListNodesIPAddressParams

WithNext adds the nextVar to the list nodes ip address params

func (*ListNodesIPAddressParams) WithNodeIP 

func (o *ListNodesIPAddressParams) WithNodeIP(nodeIP *string) *ListNodesIPAddressParams

WithNodeIP adds the nodeIP to the list nodes ip address params

func (*ListNodesIPAddressParams) WithPrevious 

func (o *ListNodesIPAddressParams) WithPrevious(previous *string) *ListNodesIPAddressParams

WithPrevious adds the previous to the list nodes ip address params

func (*ListNodesIPAddressParams) WithTimeout 

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

WithTimeout adds the timeout to the list nodes ip address params

func (*ListNodesIPAddressParams) WriteToRequest 

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

WriteToRequest writes these params to a swagger request

type ListNodesIPAddressReader 

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

ListNodesIPAddressReader is a Reader for the ListNodesIPAddress structure.

func (*ListNodesIPAddressReader) ReadResponse 

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

ReadResponse reads a server response into the received o.

type ListQueueBadRequest 

type ListQueueBadRequest struct {
	Payload *dsartifactclientmodels.ResponseError
}

ListQueueBadRequest handles this case with default header values. 

Bad Request

func NewListQueueBadRequest 

func NewListQueueBadRequest() *ListQueueBadRequest

NewListQueueBadRequest creates a ListQueueBadRequest with default headers values

func (*ListQueueBadRequest) Error 

func (o *ListQueueBadRequest) Error() string

func (*ListQueueBadRequest) GetPayload 

func (o *ListQueueBadRequest) GetPayload() *dsartifactclientmodels.ResponseError

func (*ListQueueBadRequest) ToJSONString 

func (o *ListQueueBadRequest) ToJSONString() string

type ListQueueInternalServerError 

type ListQueueInternalServerError struct {
	Payload *dsartifactclientmodels.ResponseError
}

ListQueueInternalServerError handles this case with default header values. 

Internal Server Error

func NewListQueueInternalServerError 

func NewListQueueInternalServerError() *ListQueueInternalServerError

NewListQueueInternalServerError creates a ListQueueInternalServerError with default headers values

func (*ListQueueInternalServerError) Error 

func (o *ListQueueInternalServerError) Error() string

func (*ListQueueInternalServerError) GetPayload 

func (o *ListQueueInternalServerError) GetPayload() *dsartifactclientmodels.ResponseError

func (*ListQueueInternalServerError) ToJSONString 

func (o *ListQueueInternalServerError) ToJSONString() string

type ListQueueNotFound 

type ListQueueNotFound struct {
	Payload *dsartifactclientmodels.ResponseError
}

ListQueueNotFound handles this case with default header values. 

Not Found

func NewListQueueNotFound 

func NewListQueueNotFound() *ListQueueNotFound

NewListQueueNotFound creates a ListQueueNotFound with default headers values

func (*ListQueueNotFound) Error 

func (o *ListQueueNotFound) Error() string

func (*ListQueueNotFound) GetPayload 

func (o *ListQueueNotFound) GetPayload() *dsartifactclientmodels.ResponseError

func (*ListQueueNotFound) ToJSONString 

func (o *ListQueueNotFound) ToJSONString() string

type ListQueueOK 

type ListQueueOK struct {
	Payload *dsartifactclientmodels.ModelsListQueueResponse
}

ListQueueOK handles this case with default header values. 

OK

func NewListQueueOK 

func NewListQueueOK() *ListQueueOK

NewListQueueOK creates a ListQueueOK with default headers values

func (*ListQueueOK) Error 

func (o *ListQueueOK) Error() string

func (*ListQueueOK) GetPayload 

func (o *ListQueueOK) GetPayload() *dsartifactclientmodels.ModelsListQueueResponse

func (*ListQueueOK) ToJSONString 

func (o *ListQueueOK) ToJSONString() string

type ListQueueParams 

type ListQueueParams struct {

	/*RetryPolicy*/
	RetryPolicy *utils.Retry
	/*Limit
	  limit

	*/
	Limit *int64
	/*Next
	  next

	*/
	Next *string
	/*Previous
	  previous

	*/
	Previous *string
	/*NodeIP
	  IP Address of the node doing the upload process

	*/
	NodeIP string

	AuthInfoWriter runtime.ClientAuthInfoWriter
	Context        context.Context
	HTTPClient     *http.Client

	// XFlightId is an optional parameter from this SDK
	XFlightId *string
	// contains filtered or unexported fields
}

ListQueueParams contains all the parameters to send to the API endpoint for the list queue operation typically these are written to a http.Request

func NewListQueueParams 

func NewListQueueParams() *ListQueueParams

NewListQueueParams creates a new ListQueueParams object with the default values initialized.

func NewListQueueParamsWithContext 

func NewListQueueParamsWithContext(ctx context.Context) *ListQueueParams

NewListQueueParamsWithContext creates a new ListQueueParams object with the default values initialized, and the ability to set a context for a request

func NewListQueueParamsWithHTTPClient 

func NewListQueueParamsWithHTTPClient(client *http.Client) *ListQueueParams

NewListQueueParamsWithHTTPClient creates a new ListQueueParams object with the default values initialized, and the ability to set a custom HTTPClient for a request

func NewListQueueParamsWithTimeout 

func NewListQueueParamsWithTimeout(timeout time.Duration) *ListQueueParams

NewListQueueParamsWithTimeout creates a new ListQueueParams object with the default values initialized, and the ability to set a timeout on a request

func (*ListQueueParams) SetAuthInfoWriter 

func (o *ListQueueParams) SetAuthInfoWriter(authInfoWriter runtime.ClientAuthInfoWriter)

SetAuthInfoWriter adds the authInfoWriter to the list queue params

func (*ListQueueParams) SetContext 

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

SetContext adds the context to the list queue params

func (*ListQueueParams) SetFlightId 

func (o *ListQueueParams) SetFlightId(flightId string)

SetFlightId adds the flightId as the header value for this specific endpoint

func (*ListQueueParams) SetHTTPClient 

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

SetHTTPClient adds the HTTPClient to the list queue params

func (*ListQueueParams) SetHTTPClientTransport 

func (o *ListQueueParams) SetHTTPClientTransport(roundTripper http.RoundTripper)

SetHTTPClient adds the HTTPClient Transport to the list queue params

func (*ListQueueParams) SetLimit 

func (o *ListQueueParams) SetLimit(limit *int64)

SetLimit adds the limit to the list queue params

func (*ListQueueParams) SetNext 

func (o *ListQueueParams) SetNext(nextVar *string)

SetNext adds the next to the list queue params

func (*ListQueueParams) SetNodeIP 

func (o *ListQueueParams) SetNodeIP(nodeIP string)

SetNodeIP adds the nodeIp to the list queue params

func (*ListQueueParams) SetPrevious 

func (o *ListQueueParams) SetPrevious(previous *string)

SetPrevious adds the previous to the list queue params

func (*ListQueueParams) SetTimeout 

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

SetTimeout adds the timeout to the list queue params

func (*ListQueueParams) WithContext 

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

WithContext adds the context to the list queue params

func (*ListQueueParams) WithHTTPClient 

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

WithHTTPClient adds the HTTPClient to the list queue params

func (*ListQueueParams) WithLimit 

func (o *ListQueueParams) WithLimit(limit *int64) *ListQueueParams

WithLimit adds the limit to the list queue params

func (*ListQueueParams) WithNext 

func (o *ListQueueParams) WithNext(nextVar *string) *ListQueueParams

WithNext adds the nextVar to the list queue params

func (*ListQueueParams) WithNodeIP 

func (o *ListQueueParams) WithNodeIP(nodeIP string) *ListQueueParams

WithNodeIP adds the nodeIP to the list queue params

func (*ListQueueParams) WithPrevious 

func (o *ListQueueParams) WithPrevious(previous *string) *ListQueueParams

WithPrevious adds the previous to the list queue params

func (*ListQueueParams) WithTimeout 

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

WithTimeout adds the timeout to the list queue params

func (*ListQueueParams) WriteToRequest 

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

WriteToRequest writes these params to a swagger request

type ListQueueReader 

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

ListQueueReader is a Reader for the ListQueue structure.

func (*ListQueueReader) ReadResponse 

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

ReadResponse reads a server response into the received o.

type ListQueueUnauthorized 

type ListQueueUnauthorized struct {
	Payload *dsartifactclientmodels.ResponseError
}

ListQueueUnauthorized handles this case with default header values. 

Unauthorized

func NewListQueueUnauthorized 

func NewListQueueUnauthorized() *ListQueueUnauthorized

NewListQueueUnauthorized creates a ListQueueUnauthorized with default headers values

func (*ListQueueUnauthorized) Error 

func (o *ListQueueUnauthorized) Error() string

func (*ListQueueUnauthorized) GetPayload 

func (o *ListQueueUnauthorized) GetPayload() *dsartifactclientmodels.ResponseError

func (*ListQueueUnauthorized) ToJSONString 

func (o *ListQueueUnauthorized) ToJSONString() string

type ReportFailedUploadBadRequest 

type ReportFailedUploadBadRequest struct {
	Payload *dsartifactclientmodels.ResponseError
}

ReportFailedUploadBadRequest handles this case with default header values. 

Bad Request

func NewReportFailedUploadBadRequest 

func NewReportFailedUploadBadRequest() *ReportFailedUploadBadRequest

NewReportFailedUploadBadRequest creates a ReportFailedUploadBadRequest with default headers values

func (*ReportFailedUploadBadRequest) Error 

func (o *ReportFailedUploadBadRequest) Error() string

func (*ReportFailedUploadBadRequest) GetPayload 

func (o *ReportFailedUploadBadRequest) GetPayload() *dsartifactclientmodels.ResponseError

func (*ReportFailedUploadBadRequest) ToJSONString 

func (o *ReportFailedUploadBadRequest) ToJSONString() string

type ReportFailedUploadInternalServerError 

type ReportFailedUploadInternalServerError struct {
	Payload *dsartifactclientmodels.ResponseError
}

ReportFailedUploadInternalServerError handles this case with default header values. 

Internal Server Error

func NewReportFailedUploadInternalServerError 

func NewReportFailedUploadInternalServerError() *ReportFailedUploadInternalServerError

NewReportFailedUploadInternalServerError creates a ReportFailedUploadInternalServerError with default headers values

func (*ReportFailedUploadInternalServerError) Error 

func (o *ReportFailedUploadInternalServerError) Error() string

func (*ReportFailedUploadInternalServerError) GetPayload 

func (o *ReportFailedUploadInternalServerError) GetPayload() *dsartifactclientmodels.ResponseError

func (*ReportFailedUploadInternalServerError) ToJSONString 

func (o *ReportFailedUploadInternalServerError) ToJSONString() string

type ReportFailedUploadNoContent 

type ReportFailedUploadNoContent struct {
}

ReportFailedUploadNoContent handles this case with default header values. 

No Content

func NewReportFailedUploadNoContent 

func NewReportFailedUploadNoContent() *ReportFailedUploadNoContent

NewReportFailedUploadNoContent creates a ReportFailedUploadNoContent with default headers values

func (*ReportFailedUploadNoContent) Error 

func (o *ReportFailedUploadNoContent) Error() string

type ReportFailedUploadParams 

type ReportFailedUploadParams struct {

	/*RetryPolicy*/
	RetryPolicy *utils.Retry
	/*NodeIP
	  Node IP of the ds nomad client that failed the artifact upload

	*/
	NodeIP string
	/*PodName
	  Pod Name of the DS who owns the artifact

	*/
	PodName string

	AuthInfoWriter runtime.ClientAuthInfoWriter
	Context        context.Context
	HTTPClient     *http.Client

	// XFlightId is an optional parameter from this SDK
	XFlightId *string
	// contains filtered or unexported fields
}

ReportFailedUploadParams contains all the parameters to send to the API endpoint for the report failed upload operation typically these are written to a http.Request

func NewReportFailedUploadParams 

func NewReportFailedUploadParams() *ReportFailedUploadParams

NewReportFailedUploadParams creates a new ReportFailedUploadParams object with the default values initialized.

func NewReportFailedUploadParamsWithContext 

func NewReportFailedUploadParamsWithContext(ctx context.Context) *ReportFailedUploadParams

NewReportFailedUploadParamsWithContext creates a new ReportFailedUploadParams object with the default values initialized, and the ability to set a context for a request

func NewReportFailedUploadParamsWithHTTPClient 

func NewReportFailedUploadParamsWithHTTPClient(client *http.Client) *ReportFailedUploadParams

NewReportFailedUploadParamsWithHTTPClient creates a new ReportFailedUploadParams object with the default values initialized, and the ability to set a custom HTTPClient for a request

func NewReportFailedUploadParamsWithTimeout 

func NewReportFailedUploadParamsWithTimeout(timeout time.Duration) *ReportFailedUploadParams

NewReportFailedUploadParamsWithTimeout creates a new ReportFailedUploadParams object with the default values initialized, and the ability to set a timeout on a request

func (*ReportFailedUploadParams) SetAuthInfoWriter 

func (o *ReportFailedUploadParams) SetAuthInfoWriter(authInfoWriter runtime.ClientAuthInfoWriter)

SetAuthInfoWriter adds the authInfoWriter to the report failed upload params

func (*ReportFailedUploadParams) SetContext 

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

SetContext adds the context to the report failed upload params

func (*ReportFailedUploadParams) SetFlightId 

func (o *ReportFailedUploadParams) SetFlightId(flightId string)

SetFlightId adds the flightId as the header value for this specific endpoint

func (*ReportFailedUploadParams) SetHTTPClient 

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

SetHTTPClient adds the HTTPClient to the report failed upload params

func (*ReportFailedUploadParams) SetHTTPClientTransport 

func (o *ReportFailedUploadParams) SetHTTPClientTransport(roundTripper http.RoundTripper)

SetHTTPClient adds the HTTPClient Transport to the report failed upload params

func (*ReportFailedUploadParams) SetNodeIP 

func (o *ReportFailedUploadParams) SetNodeIP(nodeIP string)

SetNodeIP adds the nodeIp to the report failed upload params

func (*ReportFailedUploadParams) SetPodName 

func (o *ReportFailedUploadParams) SetPodName(podName string)

SetPodName adds the podName to the report failed upload params

func (*ReportFailedUploadParams) SetTimeout 

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

SetTimeout adds the timeout to the report failed upload params

func (*ReportFailedUploadParams) WithContext 

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

WithContext adds the context to the report failed upload params

func (*ReportFailedUploadParams) WithHTTPClient 

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

WithHTTPClient adds the HTTPClient to the report failed upload params

func (*ReportFailedUploadParams) WithNodeIP 

func (o *ReportFailedUploadParams) WithNodeIP(nodeIP string) *ReportFailedUploadParams

WithNodeIP adds the nodeIP to the report failed upload params

func (*ReportFailedUploadParams) WithPodName 

func (o *ReportFailedUploadParams) WithPodName(podName string) *ReportFailedUploadParams

WithPodName adds the podName to the report failed upload params

func (*ReportFailedUploadParams) WithTimeout 

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

WithTimeout adds the timeout to the report failed upload params

func (*ReportFailedUploadParams) WriteToRequest 

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

WriteToRequest writes these params to a swagger request

type ReportFailedUploadReader 

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

ReportFailedUploadReader is a Reader for the ReportFailedUpload structure.

func (*ReportFailedUploadReader) ReadResponse 

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

ReadResponse reads a server response into the received o.

type ReportFailedUploadUnauthorized 

type ReportFailedUploadUnauthorized struct {
	Payload *dsartifactclientmodels.ResponseError
}

ReportFailedUploadUnauthorized handles this case with default header values. 

Unauthorized

func NewReportFailedUploadUnauthorized 

func NewReportFailedUploadUnauthorized() *ReportFailedUploadUnauthorized

NewReportFailedUploadUnauthorized creates a ReportFailedUploadUnauthorized with default headers values

func (*ReportFailedUploadUnauthorized) Error 

func (o *ReportFailedUploadUnauthorized) Error() string

func (*ReportFailedUploadUnauthorized) GetPayload 

func (o *ReportFailedUploadUnauthorized) GetPayload() *dsartifactclientmodels.ResponseError

func (*ReportFailedUploadUnauthorized) ToJSONString 

func (o *ReportFailedUploadUnauthorized) ToJSONString() string

type SetActiveQueueBadRequest 

type SetActiveQueueBadRequest struct {
	Payload *dsartifactclientmodels.ResponseError
}

SetActiveQueueBadRequest handles this case with default header values. 

Bad Request

func NewSetActiveQueueBadRequest 

func NewSetActiveQueueBadRequest() *SetActiveQueueBadRequest

NewSetActiveQueueBadRequest creates a SetActiveQueueBadRequest with default headers values

func (*SetActiveQueueBadRequest) Error 

func (o *SetActiveQueueBadRequest) Error() string

func (*SetActiveQueueBadRequest) GetPayload 

func (o *SetActiveQueueBadRequest) GetPayload() *dsartifactclientmodels.ResponseError

func (*SetActiveQueueBadRequest) ToJSONString 

func (o *SetActiveQueueBadRequest) ToJSONString() string

type SetActiveQueueInternalServerError 

type SetActiveQueueInternalServerError struct {
	Payload *dsartifactclientmodels.ResponseError
}

SetActiveQueueInternalServerError handles this case with default header values. 

Internal Server Error

func NewSetActiveQueueInternalServerError 

func NewSetActiveQueueInternalServerError() *SetActiveQueueInternalServerError

NewSetActiveQueueInternalServerError creates a SetActiveQueueInternalServerError with default headers values

func (*SetActiveQueueInternalServerError) Error 

func (o *SetActiveQueueInternalServerError) Error() string

func (*SetActiveQueueInternalServerError) GetPayload 

func (o *SetActiveQueueInternalServerError) GetPayload() *dsartifactclientmodels.ResponseError

func (*SetActiveQueueInternalServerError) ToJSONString 

func (o *SetActiveQueueInternalServerError) ToJSONString() string

type SetActiveQueueNoContent 

type SetActiveQueueNoContent struct {
}

SetActiveQueueNoContent handles this case with default header values. 

No Content

func NewSetActiveQueueNoContent 

func NewSetActiveQueueNoContent() *SetActiveQueueNoContent

NewSetActiveQueueNoContent creates a SetActiveQueueNoContent with default headers values

func (*SetActiveQueueNoContent) Error 

func (o *SetActiveQueueNoContent) Error() string

type SetActiveQueueParams 

type SetActiveQueueParams struct {

	/*RetryPolicy*/
	RetryPolicy *utils.Retry
	/*NodeIP
	  IP Address of the node doing the upload process

	*/
	NodeIP string
	/*PodName
	  Pod Name of the DS who owns the artifact

	*/
	PodName string

	AuthInfoWriter runtime.ClientAuthInfoWriter
	Context        context.Context
	HTTPClient     *http.Client

	// XFlightId is an optional parameter from this SDK
	XFlightId *string
	// contains filtered or unexported fields
}

SetActiveQueueParams contains all the parameters to send to the API endpoint for the set active queue operation typically these are written to a http.Request

func NewSetActiveQueueParams 

func NewSetActiveQueueParams() *SetActiveQueueParams

NewSetActiveQueueParams creates a new SetActiveQueueParams object with the default values initialized.

func NewSetActiveQueueParamsWithContext 

func NewSetActiveQueueParamsWithContext(ctx context.Context) *SetActiveQueueParams

NewSetActiveQueueParamsWithContext creates a new SetActiveQueueParams object with the default values initialized, and the ability to set a context for a request

func NewSetActiveQueueParamsWithHTTPClient 

func NewSetActiveQueueParamsWithHTTPClient(client *http.Client) *SetActiveQueueParams

NewSetActiveQueueParamsWithHTTPClient creates a new SetActiveQueueParams object with the default values initialized, and the ability to set a custom HTTPClient for a request

func NewSetActiveQueueParamsWithTimeout 

func NewSetActiveQueueParamsWithTimeout(timeout time.Duration) *SetActiveQueueParams

NewSetActiveQueueParamsWithTimeout creates a new SetActiveQueueParams object with the default values initialized, and the ability to set a timeout on a request

func (*SetActiveQueueParams) SetAuthInfoWriter 

func (o *SetActiveQueueParams) SetAuthInfoWriter(authInfoWriter runtime.ClientAuthInfoWriter)

SetAuthInfoWriter adds the authInfoWriter to the set active queue params

func (*SetActiveQueueParams) SetContext 

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

SetContext adds the context to the set active queue params

func (*SetActiveQueueParams) SetFlightId 

func (o *SetActiveQueueParams) SetFlightId(flightId string)

SetFlightId adds the flightId as the header value for this specific endpoint

func (*SetActiveQueueParams) SetHTTPClient 

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

SetHTTPClient adds the HTTPClient to the set active queue params

func (*SetActiveQueueParams) SetHTTPClientTransport 

func (o *SetActiveQueueParams) SetHTTPClientTransport(roundTripper http.RoundTripper)

SetHTTPClient adds the HTTPClient Transport to the set active queue params

func (*SetActiveQueueParams) SetNodeIP 

func (o *SetActiveQueueParams) SetNodeIP(nodeIP string)

SetNodeIP adds the nodeIp to the set active queue params

func (*SetActiveQueueParams) SetPodName 

func (o *SetActiveQueueParams) SetPodName(podName string)

SetPodName adds the podName to the set active queue params

func (*SetActiveQueueParams) SetTimeout 

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

SetTimeout adds the timeout to the set active queue params

func (*SetActiveQueueParams) WithContext 

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

WithContext adds the context to the set active queue params

func (*SetActiveQueueParams) WithHTTPClient 

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

WithHTTPClient adds the HTTPClient to the set active queue params

func (*SetActiveQueueParams) WithNodeIP 

func (o *SetActiveQueueParams) WithNodeIP(nodeIP string) *SetActiveQueueParams

WithNodeIP adds the nodeIP to the set active queue params

func (*SetActiveQueueParams) WithPodName 

func (o *SetActiveQueueParams) WithPodName(podName string) *SetActiveQueueParams

WithPodName adds the podName to the set active queue params

func (*SetActiveQueueParams) WithTimeout 

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

WithTimeout adds the timeout to the set active queue params

func (*SetActiveQueueParams) WriteToRequest 

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

WriteToRequest writes these params to a swagger request

type SetActiveQueueReader 

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

SetActiveQueueReader is a Reader for the SetActiveQueue structure.

func (*SetActiveQueueReader) ReadResponse 

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

ReadResponse reads a server response into the received o.

type SetActiveQueueUnauthorized 

type SetActiveQueueUnauthorized struct {
	Payload *dsartifactclientmodels.ResponseError
}

SetActiveQueueUnauthorized handles this case with default header values. 

Unauthorized

func NewSetActiveQueueUnauthorized 

func NewSetActiveQueueUnauthorized() *SetActiveQueueUnauthorized

NewSetActiveQueueUnauthorized creates a SetActiveQueueUnauthorized with default headers values

func (*SetActiveQueueUnauthorized) Error 

func (o *SetActiveQueueUnauthorized) Error() string

func (*SetActiveQueueUnauthorized) GetPayload 

func (o *SetActiveQueueUnauthorized) GetPayload() *dsartifactclientmodels.ResponseError

func (*SetActiveQueueUnauthorized) ToJSONString 

func (o *SetActiveQueueUnauthorized) ToJSONString() string

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.