Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

artifact_upload_process_queue

package

Go to main page

Versions in this module

v0

v0.80.1

Jul 9, 2025

v0.80.0

Jun 3, 2025

v0.79.1

Jul 2, 2025

v0.79.0

Apr 30, 2025

v0.78.1

Mar 28, 2025

v0.78.0

Mar 7, 2025

v0.77.3

Feb 26, 2025

v0.77.2

Feb 25, 2025

v0.77.1

Feb 24, 2025

v0.77.0

Feb 7, 2025

v0.76.1

Jan 30, 2025

v0.76.0

Jan 3, 2025

v0.75.0

Nov 22, 2024

v0.74.0

Oct 11, 2024

v0.73.0

Sep 6, 2024

v0.72.0

Aug 5, 2024

v0.71.0

Jun 20, 2024

v0.70.0

May 21, 2024

v0.69.0

May 7, 2024

v0.68.0

Apr 16, 2024

v0.67.0

Mar 26, 2024

v0.66.0

Mar 13, 2024

v0.65.0

Feb 27, 2024

Changes in this version

+ type Client struct

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

+ type ClientService interface

+ DeleteActiveQueue func(params *DeleteActiveQueueParams, authInfo runtime.ClientAuthInfoWriter) (*DeleteActiveQueueNoContent, *DeleteActiveQueueBadRequest, ...)

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

+ DeleteNodeByID func(params *DeleteNodeByIDParams, authInfo runtime.ClientAuthInfoWriter) (*DeleteNodeByIDNoContent, *DeleteNodeByIDBadRequest, ...)

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

+ DeleteQueue func(params *DeleteQueueParams, authInfo runtime.ClientAuthInfoWriter) (*DeleteQueueNoContent, *DeleteQueueBadRequest, *DeleteQueueInternalServerError, ...)

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

+ GetActiveQueue func(params *GetActiveQueueParams, authInfo runtime.ClientAuthInfoWriter) (*GetActiveQueueOK, *GetActiveQueueBadRequest, *GetActiveQueueUnauthorized, ...)

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

+ ListAllActiveQueue func(params *ListAllActiveQueueParams, authInfo runtime.ClientAuthInfoWriter) (*ListAllActiveQueueOK, *ListAllActiveQueueBadRequest, ...)

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

+ ListAllQueue func(params *ListAllQueueParams, authInfo runtime.ClientAuthInfoWriter) (*ListAllQueueOK, *ListAllQueueBadRequest, *ListAllQueueNotFound, ...)

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

+ ListNodesIPAddress func(params *ListNodesIPAddressParams, authInfo runtime.ClientAuthInfoWriter) (*ListNodesIPAddressOK, *ListNodesIPAddressBadRequest, ...)

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

+ ListQueue func(params *ListQueueParams, authInfo runtime.ClientAuthInfoWriter) (*ListQueueOK, *ListQueueBadRequest, *ListQueueUnauthorized, *ListQueueNotFound, ...)

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

+ ReportFailedUpload func(params *ReportFailedUploadParams, authInfo runtime.ClientAuthInfoWriter) (*ReportFailedUploadNoContent, *ReportFailedUploadBadRequest, ...)

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

+ SetActiveQueue func(params *SetActiveQueueParams, authInfo runtime.ClientAuthInfoWriter) (*SetActiveQueueNoContent, *SetActiveQueueBadRequest, ...)

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

+ SetTransport func(transport runtime.ClientTransport)

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

+ type DeleteActiveQueueBadRequest struct

+ Payload *dsartifactclientmodels.ResponseError

+ func NewDeleteActiveQueueBadRequest() *DeleteActiveQueueBadRequest

+ func (o *DeleteActiveQueueBadRequest) Error() string

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

+ func (o *DeleteActiveQueueBadRequest) ToJSONString() string

+ type DeleteActiveQueueInternalServerError struct

+ Payload *dsartifactclientmodels.ResponseError

+ func NewDeleteActiveQueueInternalServerError() *DeleteActiveQueueInternalServerError

+ func (o *DeleteActiveQueueInternalServerError) Error() string

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

+ func (o *DeleteActiveQueueInternalServerError) ToJSONString() string

+ type DeleteActiveQueueNoContent struct

+ func NewDeleteActiveQueueNoContent() *DeleteActiveQueueNoContent

+ func (o *DeleteActiveQueueNoContent) Error() string

+ type DeleteActiveQueueParams struct

+ AuthInfoWriter runtime.ClientAuthInfoWriter

+ Context context.Context

+ HTTPClient *http.Client

+ NodeIP string

+ RetryPolicy *utils.Retry

+ XFlightId *string

+ func NewDeleteActiveQueueParams() *DeleteActiveQueueParams

+ func NewDeleteActiveQueueParamsWithContext(ctx context.Context) *DeleteActiveQueueParams

+ func NewDeleteActiveQueueParamsWithHTTPClient(client *http.Client) *DeleteActiveQueueParams

+ func NewDeleteActiveQueueParamsWithTimeout(timeout time.Duration) *DeleteActiveQueueParams

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

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

+ func (o *DeleteActiveQueueParams) SetFlightId(flightId string)

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

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

+ func (o *DeleteActiveQueueParams) SetNodeIP(nodeIP string)

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

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

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

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

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

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

+ type DeleteActiveQueueReader struct

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

+ type DeleteActiveQueueUnauthorized struct

+ Payload *dsartifactclientmodels.ResponseError

+ func NewDeleteActiveQueueUnauthorized() *DeleteActiveQueueUnauthorized

+ func (o *DeleteActiveQueueUnauthorized) Error() string

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

+ func (o *DeleteActiveQueueUnauthorized) ToJSONString() string

+ type DeleteNodeByIDBadRequest struct

+ Payload *dsartifactclientmodels.ResponseError

+ func NewDeleteNodeByIDBadRequest() *DeleteNodeByIDBadRequest

+ func (o *DeleteNodeByIDBadRequest) Error() string

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

+ func (o *DeleteNodeByIDBadRequest) ToJSONString() string

+ type DeleteNodeByIDInternalServerError struct

+ Payload *dsartifactclientmodels.ResponseError

+ func NewDeleteNodeByIDInternalServerError() *DeleteNodeByIDInternalServerError

+ func (o *DeleteNodeByIDInternalServerError) Error() string

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

+ func (o *DeleteNodeByIDInternalServerError) ToJSONString() string

+ type DeleteNodeByIDNoContent struct

+ func NewDeleteNodeByIDNoContent() *DeleteNodeByIDNoContent

+ func (o *DeleteNodeByIDNoContent) Error() string

+ type DeleteNodeByIDParams struct

+ AuthInfoWriter runtime.ClientAuthInfoWriter

+ Context context.Context

+ HTTPClient *http.Client

+ NodeIP string

+ PodName string

+ RetryPolicy *utils.Retry

+ XFlightId *string

+ func NewDeleteNodeByIDParams() *DeleteNodeByIDParams

+ func NewDeleteNodeByIDParamsWithContext(ctx context.Context) *DeleteNodeByIDParams

+ func NewDeleteNodeByIDParamsWithHTTPClient(client *http.Client) *DeleteNodeByIDParams

+ func NewDeleteNodeByIDParamsWithTimeout(timeout time.Duration) *DeleteNodeByIDParams

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

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

+ func (o *DeleteNodeByIDParams) SetFlightId(flightId string)

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

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

+ func (o *DeleteNodeByIDParams) SetNodeIP(nodeIP string)

+ func (o *DeleteNodeByIDParams) SetPodName(podName string)

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

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

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

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

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

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

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

+ type DeleteNodeByIDReader struct

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

+ type DeleteQueueBadRequest struct

+ Payload *dsartifactclientmodels.ResponseError

+ func NewDeleteQueueBadRequest() *DeleteQueueBadRequest

+ func (o *DeleteQueueBadRequest) Error() string

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

+ func (o *DeleteQueueBadRequest) ToJSONString() string

+ type DeleteQueueInternalServerError struct

+ Payload *dsartifactclientmodels.ResponseError

+ func NewDeleteQueueInternalServerError() *DeleteQueueInternalServerError

+ func (o *DeleteQueueInternalServerError) Error() string

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

+ func (o *DeleteQueueInternalServerError) ToJSONString() string

+ type DeleteQueueNoContent struct

+ func NewDeleteQueueNoContent() *DeleteQueueNoContent

+ func (o *DeleteQueueNoContent) Error() string

+ type DeleteQueueParams struct

+ AuthInfoWriter runtime.ClientAuthInfoWriter

+ Context context.Context

+ HTTPClient *http.Client

+ Namespace string

+ NodeIP string

+ PodName string

+ RetryPolicy *utils.Retry

+ XFlightId *string

+ func NewDeleteQueueParams() *DeleteQueueParams

+ func NewDeleteQueueParamsWithContext(ctx context.Context) *DeleteQueueParams

+ func NewDeleteQueueParamsWithHTTPClient(client *http.Client) *DeleteQueueParams

+ func NewDeleteQueueParamsWithTimeout(timeout time.Duration) *DeleteQueueParams

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

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

+ func (o *DeleteQueueParams) SetFlightId(flightId string)

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

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

+ func (o *DeleteQueueParams) SetNamespace(namespace string)

+ func (o *DeleteQueueParams) SetNodeIP(nodeIP string)

+ func (o *DeleteQueueParams) SetPodName(podName string)

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

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

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

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

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

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

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

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

+ type DeleteQueueReader struct

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

+ type GetActiveQueueBadRequest struct

+ Payload *dsartifactclientmodels.ResponseError

+ func NewGetActiveQueueBadRequest() *GetActiveQueueBadRequest

+ func (o *GetActiveQueueBadRequest) Error() string

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

+ func (o *GetActiveQueueBadRequest) ToJSONString() string

+ type GetActiveQueueInternalServerError struct

+ Payload *dsartifactclientmodels.ResponseError

+ func NewGetActiveQueueInternalServerError() *GetActiveQueueInternalServerError

+ func (o *GetActiveQueueInternalServerError) Error() string

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

+ func (o *GetActiveQueueInternalServerError) ToJSONString() string

+ type GetActiveQueueNotFound struct

+ Payload *dsartifactclientmodels.ResponseError

+ func NewGetActiveQueueNotFound() *GetActiveQueueNotFound

+ func (o *GetActiveQueueNotFound) Error() string

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

+ func (o *GetActiveQueueNotFound) ToJSONString() string

+ type GetActiveQueueOK struct

+ Payload *dsartifactclientmodels.ModelsQueue

+ func NewGetActiveQueueOK() *GetActiveQueueOK

+ func (o *GetActiveQueueOK) Error() string

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

+ func (o *GetActiveQueueOK) ToJSONString() string

+ type GetActiveQueueParams struct

+ AuthInfoWriter runtime.ClientAuthInfoWriter

+ Context context.Context

+ HTTPClient *http.Client

+ NodeIP string

+ RetryPolicy *utils.Retry

+ XFlightId *string

+ func NewGetActiveQueueParams() *GetActiveQueueParams

+ func NewGetActiveQueueParamsWithContext(ctx context.Context) *GetActiveQueueParams

+ func NewGetActiveQueueParamsWithHTTPClient(client *http.Client) *GetActiveQueueParams

+ func NewGetActiveQueueParamsWithTimeout(timeout time.Duration) *GetActiveQueueParams

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

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

+ func (o *GetActiveQueueParams) SetFlightId(flightId string)

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

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

+ func (o *GetActiveQueueParams) SetNodeIP(nodeIP string)

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

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

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

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

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

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

+ type GetActiveQueueReader struct

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

+ type GetActiveQueueUnauthorized struct

+ Payload *dsartifactclientmodels.ResponseError

+ func NewGetActiveQueueUnauthorized() *GetActiveQueueUnauthorized

+ func (o *GetActiveQueueUnauthorized) Error() string

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

+ func (o *GetActiveQueueUnauthorized) ToJSONString() string

+ type ListAllActiveQueueBadRequest struct

+ Payload *dsartifactclientmodels.ResponseError

+ func NewListAllActiveQueueBadRequest() *ListAllActiveQueueBadRequest

+ func (o *ListAllActiveQueueBadRequest) Error() string

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

+ func (o *ListAllActiveQueueBadRequest) ToJSONString() string

+ type ListAllActiveQueueInternalServerError struct

+ Payload *dsartifactclientmodels.ResponseError

+ func NewListAllActiveQueueInternalServerError() *ListAllActiveQueueInternalServerError

+ func (o *ListAllActiveQueueInternalServerError) Error() string

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

+ func (o *ListAllActiveQueueInternalServerError) ToJSONString() string

+ type ListAllActiveQueueNotFound struct

+ Payload *dsartifactclientmodels.ResponseError

+ func NewListAllActiveQueueNotFound() *ListAllActiveQueueNotFound

+ func (o *ListAllActiveQueueNotFound) Error() string

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

+ func (o *ListAllActiveQueueNotFound) ToJSONString() string

+ type ListAllActiveQueueOK struct

+ Payload *dsartifactclientmodels.ModelsListAllQueueResponse

+ func NewListAllActiveQueueOK() *ListAllActiveQueueOK

+ func (o *ListAllActiveQueueOK) Error() string

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

+ func (o *ListAllActiveQueueOK) ToJSONString() string

+ type ListAllActiveQueueParams struct

+ AuthInfoWriter runtime.ClientAuthInfoWriter

+ Context context.Context

+ HTTPClient *http.Client

+ Limit *int64

+ Namespace string

+ Next *string

+ NodeIP *string

+ PodName *string

+ Previous *string

+ RetryPolicy *utils.Retry

+ XFlightId *string

+ func NewListAllActiveQueueParams() *ListAllActiveQueueParams

+ func NewListAllActiveQueueParamsWithContext(ctx context.Context) *ListAllActiveQueueParams

+ func NewListAllActiveQueueParamsWithHTTPClient(client *http.Client) *ListAllActiveQueueParams

+ func NewListAllActiveQueueParamsWithTimeout(timeout time.Duration) *ListAllActiveQueueParams

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

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

+ func (o *ListAllActiveQueueParams) SetFlightId(flightId string)

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

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

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

+ func (o *ListAllActiveQueueParams) SetNamespace(namespace string)

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

+ type ListAllActiveQueueReader struct

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

+ type ListAllQueueBadRequest struct

+ Payload *dsartifactclientmodels.ResponseError

+ func NewListAllQueueBadRequest() *ListAllQueueBadRequest

+ func (o *ListAllQueueBadRequest) Error() string

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

+ func (o *ListAllQueueBadRequest) ToJSONString() string

+ type ListAllQueueInternalServerError struct

+ Payload *dsartifactclientmodels.ResponseError

+ func NewListAllQueueInternalServerError() *ListAllQueueInternalServerError

+ func (o *ListAllQueueInternalServerError) Error() string

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

+ func (o *ListAllQueueInternalServerError) ToJSONString() string

+ type ListAllQueueNotFound struct

+ Payload *dsartifactclientmodels.ResponseError

+ func NewListAllQueueNotFound() *ListAllQueueNotFound

+ func (o *ListAllQueueNotFound) Error() string

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

+ func (o *ListAllQueueNotFound) ToJSONString() string

+ type ListAllQueueOK struct

+ Payload *dsartifactclientmodels.ModelsListAllQueueResponse

+ func NewListAllQueueOK() *ListAllQueueOK

+ func (o *ListAllQueueOK) Error() string

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

+ func (o *ListAllQueueOK) ToJSONString() string

+ type ListAllQueueParams struct

+ AuthInfoWriter runtime.ClientAuthInfoWriter

+ Context context.Context

+ ExcludeUploading *bool

+ HTTPClient *http.Client

+ Limit *int64

+ Namespace string

+ Next *string

+ NodeIP *string

+ Order *string

+ PodName *string

+ Previous *string

+ RetryPolicy *utils.Retry

+ XFlightId *string

+ func NewListAllQueueParams() *ListAllQueueParams

+ func NewListAllQueueParamsWithContext(ctx context.Context) *ListAllQueueParams

+ func NewListAllQueueParamsWithHTTPClient(client *http.Client) *ListAllQueueParams

+ func NewListAllQueueParamsWithTimeout(timeout time.Duration) *ListAllQueueParams

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

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

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

+ func (o *ListAllQueueParams) SetFlightId(flightId string)

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

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

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

+ func (o *ListAllQueueParams) SetNamespace(namespace string)

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

+ type ListAllQueueReader struct

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

+ type ListNodesIPAddressBadRequest struct

+ Payload *dsartifactclientmodels.ResponseError

+ func NewListNodesIPAddressBadRequest() *ListNodesIPAddressBadRequest

+ func (o *ListNodesIPAddressBadRequest) Error() string

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

+ func (o *ListNodesIPAddressBadRequest) ToJSONString() string

+ type ListNodesIPAddressInternalServerError struct

+ Payload *dsartifactclientmodels.ResponseError

+ func NewListNodesIPAddressInternalServerError() *ListNodesIPAddressInternalServerError

+ func (o *ListNodesIPAddressInternalServerError) Error() string

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

+ func (o *ListNodesIPAddressInternalServerError) ToJSONString() string

+ type ListNodesIPAddressOK struct

+ Payload *dsartifactclientmodels.ModelsListNodesIPAddress

+ func NewListNodesIPAddressOK() *ListNodesIPAddressOK

+ func (o *ListNodesIPAddressOK) Error() string

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

+ func (o *ListNodesIPAddressOK) ToJSONString() string

+ type ListNodesIPAddressParams struct

+ AuthInfoWriter runtime.ClientAuthInfoWriter

+ Context context.Context

+ HTTPClient *http.Client

+ Limit *int64

+ Next *string

+ NodeIP *string

+ Previous *string

+ RetryPolicy *utils.Retry

+ XFlightId *string

+ func NewListNodesIPAddressParams() *ListNodesIPAddressParams

+ func NewListNodesIPAddressParamsWithContext(ctx context.Context) *ListNodesIPAddressParams

+ func NewListNodesIPAddressParamsWithHTTPClient(client *http.Client) *ListNodesIPAddressParams

+ func NewListNodesIPAddressParamsWithTimeout(timeout time.Duration) *ListNodesIPAddressParams

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

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

+ func (o *ListNodesIPAddressParams) SetFlightId(flightId string)

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

+ type ListNodesIPAddressReader struct

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

+ type ListQueueBadRequest struct

+ Payload *dsartifactclientmodels.ResponseError

+ func NewListQueueBadRequest() *ListQueueBadRequest

+ func (o *ListQueueBadRequest) Error() string

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

+ func (o *ListQueueBadRequest) ToJSONString() string

+ type ListQueueInternalServerError struct

+ Payload *dsartifactclientmodels.ResponseError

+ func NewListQueueInternalServerError() *ListQueueInternalServerError

+ func (o *ListQueueInternalServerError) Error() string

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

+ func (o *ListQueueInternalServerError) ToJSONString() string

+ type ListQueueNotFound struct

+ Payload *dsartifactclientmodels.ResponseError

+ func NewListQueueNotFound() *ListQueueNotFound

+ func (o *ListQueueNotFound) Error() string

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

+ func (o *ListQueueNotFound) ToJSONString() string

+ type ListQueueOK struct

+ Payload *dsartifactclientmodels.ModelsListQueueResponse

+ func NewListQueueOK() *ListQueueOK

+ func (o *ListQueueOK) Error() string

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

+ func (o *ListQueueOK) ToJSONString() string

+ type ListQueueParams struct

+ AuthInfoWriter runtime.ClientAuthInfoWriter

+ Context context.Context

+ HTTPClient *http.Client

+ Limit *int64

+ Next *string

+ NodeIP string

+ Previous *string

+ RetryPolicy *utils.Retry

+ XFlightId *string

+ func NewListQueueParams() *ListQueueParams

+ func NewListQueueParamsWithContext(ctx context.Context) *ListQueueParams

+ func NewListQueueParamsWithHTTPClient(client *http.Client) *ListQueueParams

+ func NewListQueueParamsWithTimeout(timeout time.Duration) *ListQueueParams

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

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

+ func (o *ListQueueParams) SetFlightId(flightId string)

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

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

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

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

+ func (o *ListQueueParams) SetNodeIP(nodeIP string)

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

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

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

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

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

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

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

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

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

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

+ type ListQueueReader struct

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

+ type ListQueueUnauthorized struct

+ Payload *dsartifactclientmodels.ResponseError

+ func NewListQueueUnauthorized() *ListQueueUnauthorized

+ func (o *ListQueueUnauthorized) Error() string

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

+ func (o *ListQueueUnauthorized) ToJSONString() string

+ type ReportFailedUploadBadRequest struct

+ Payload *dsartifactclientmodels.ResponseError

+ func NewReportFailedUploadBadRequest() *ReportFailedUploadBadRequest

+ func (o *ReportFailedUploadBadRequest) Error() string

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

+ func (o *ReportFailedUploadBadRequest) ToJSONString() string

+ type ReportFailedUploadInternalServerError struct

+ Payload *dsartifactclientmodels.ResponseError

+ func NewReportFailedUploadInternalServerError() *ReportFailedUploadInternalServerError

+ func (o *ReportFailedUploadInternalServerError) Error() string

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

+ func (o *ReportFailedUploadInternalServerError) ToJSONString() string

+ type ReportFailedUploadNoContent struct

+ func NewReportFailedUploadNoContent() *ReportFailedUploadNoContent

+ func (o *ReportFailedUploadNoContent) Error() string

+ type ReportFailedUploadParams struct

+ AuthInfoWriter runtime.ClientAuthInfoWriter

+ Context context.Context

+ HTTPClient *http.Client

+ NodeIP string

+ PodName string

+ RetryPolicy *utils.Retry

+ XFlightId *string

+ func NewReportFailedUploadParams() *ReportFailedUploadParams

+ func NewReportFailedUploadParamsWithContext(ctx context.Context) *ReportFailedUploadParams

+ func NewReportFailedUploadParamsWithHTTPClient(client *http.Client) *ReportFailedUploadParams

+ func NewReportFailedUploadParamsWithTimeout(timeout time.Duration) *ReportFailedUploadParams

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

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

+ func (o *ReportFailedUploadParams) SetFlightId(flightId string)

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

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

+ func (o *ReportFailedUploadParams) SetNodeIP(nodeIP string)

+ func (o *ReportFailedUploadParams) SetPodName(podName string)

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

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

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

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

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

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

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

+ type ReportFailedUploadReader struct

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

+ type ReportFailedUploadUnauthorized struct

+ Payload *dsartifactclientmodels.ResponseError

+ func NewReportFailedUploadUnauthorized() *ReportFailedUploadUnauthorized

+ func (o *ReportFailedUploadUnauthorized) Error() string

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

+ func (o *ReportFailedUploadUnauthorized) ToJSONString() string

+ type SetActiveQueueBadRequest struct

+ Payload *dsartifactclientmodels.ResponseError

+ func NewSetActiveQueueBadRequest() *SetActiveQueueBadRequest

+ func (o *SetActiveQueueBadRequest) Error() string

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

+ func (o *SetActiveQueueBadRequest) ToJSONString() string

+ type SetActiveQueueInternalServerError struct

+ Payload *dsartifactclientmodels.ResponseError

+ func NewSetActiveQueueInternalServerError() *SetActiveQueueInternalServerError

+ func (o *SetActiveQueueInternalServerError) Error() string

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

+ func (o *SetActiveQueueInternalServerError) ToJSONString() string

+ type SetActiveQueueNoContent struct

+ func NewSetActiveQueueNoContent() *SetActiveQueueNoContent

+ func (o *SetActiveQueueNoContent) Error() string

+ type SetActiveQueueParams struct

+ AuthInfoWriter runtime.ClientAuthInfoWriter

+ Context context.Context

+ HTTPClient *http.Client

+ NodeIP string

+ PodName string

+ RetryPolicy *utils.Retry

+ XFlightId *string

+ func NewSetActiveQueueParams() *SetActiveQueueParams

+ func NewSetActiveQueueParamsWithContext(ctx context.Context) *SetActiveQueueParams

+ func NewSetActiveQueueParamsWithHTTPClient(client *http.Client) *SetActiveQueueParams

+ func NewSetActiveQueueParamsWithTimeout(timeout time.Duration) *SetActiveQueueParams

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

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

+ func (o *SetActiveQueueParams) SetFlightId(flightId string)

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

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

+ func (o *SetActiveQueueParams) SetNodeIP(nodeIP string)

+ func (o *SetActiveQueueParams) SetPodName(podName string)

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

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

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

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

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

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

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

+ type SetActiveQueueReader struct

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

+ type SetActiveQueueUnauthorized struct

+ Payload *dsartifactclientmodels.ResponseError

+ func NewSetActiveQueueUnauthorized() *SetActiveQueueUnauthorized

+ func (o *SetActiveQueueUnauthorized) Error() string

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

+ func (o *SetActiveQueueUnauthorized) ToJSONString() string