jobservice

package
v5.4.2 Latest Latest
Warning

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

 Go to latest Published: Sep 12, 2023 License: MIT Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type ActionGetJobLogForbidden added in v5.4.0 

type ActionGetJobLogForbidden struct {
	/*The ID of the corresponding request for the response
	 */
	XRequestID string

	Payload *model.Errors
}

ActionGetJobLogForbidden handles this case with default header values.

Forbidden

func NewActionGetJobLogForbidden added in v5.4.0 

func NewActionGetJobLogForbidden() *ActionGetJobLogForbidden

NewActionGetJobLogForbidden creates a ActionGetJobLogForbidden with default headers values

func (*ActionGetJobLogForbidden) Error added in v5.4.0 

func (o *ActionGetJobLogForbidden) Error() string

func (*ActionGetJobLogForbidden) GetPayload added in v5.4.0 

func (o *ActionGetJobLogForbidden) GetPayload() *model.Errors

type ActionGetJobLogInternalServerError added in v5.4.0 

type ActionGetJobLogInternalServerError struct {
	/*The ID of the corresponding request for the response
	 */
	XRequestID string

	Payload *model.Errors
}

ActionGetJobLogInternalServerError handles this case with default header values.

Internal server error

func NewActionGetJobLogInternalServerError added in v5.4.0 

func NewActionGetJobLogInternalServerError() *ActionGetJobLogInternalServerError

NewActionGetJobLogInternalServerError creates a ActionGetJobLogInternalServerError with default headers values

func (*ActionGetJobLogInternalServerError) Error added in v5.4.0 

func (o *ActionGetJobLogInternalServerError) Error() string

func (*ActionGetJobLogInternalServerError) GetPayload added in v5.4.0 

func (o *ActionGetJobLogInternalServerError) GetPayload() *model.Errors

type ActionGetJobLogNotFound added in v5.4.0 

type ActionGetJobLogNotFound struct {
	/*The ID of the corresponding request for the response
	 */
	XRequestID string

	Payload *model.Errors
}

ActionGetJobLogNotFound handles this case with default header values.

Not found

func NewActionGetJobLogNotFound added in v5.4.0 

func NewActionGetJobLogNotFound() *ActionGetJobLogNotFound

NewActionGetJobLogNotFound creates a ActionGetJobLogNotFound with default headers values

func (*ActionGetJobLogNotFound) Error added in v5.4.0 

func (o *ActionGetJobLogNotFound) Error() string

func (*ActionGetJobLogNotFound) GetPayload added in v5.4.0 

func (o *ActionGetJobLogNotFound) GetPayload() *model.Errors

type ActionGetJobLogOK added in v5.4.0 

type ActionGetJobLogOK struct {
	/*The content type of response body
	 */
	ContentType string

	Payload string
}

ActionGetJobLogOK handles this case with default header values.

Get job log successfully.

func NewActionGetJobLogOK added in v5.4.0 

func NewActionGetJobLogOK() *ActionGetJobLogOK

NewActionGetJobLogOK creates a ActionGetJobLogOK with default headers values

func (*ActionGetJobLogOK) Error added in v5.4.0 

func (o *ActionGetJobLogOK) Error() string

func (*ActionGetJobLogOK) GetPayload added in v5.4.0 

func (o *ActionGetJobLogOK) GetPayload() string

type ActionGetJobLogParams added in v5.4.0 

type ActionGetJobLogParams struct {

	/*XRequestID
	  An unique ID for the request

	*/
	XRequestID *string
	/*JobID
	  The id of the job.

	*/
	JobID string

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

ActionGetJobLogParams contains all the parameters to send to the API endpoint for the action get job log operation typically these are written to a http.Request

func NewActionGetJobLogParams added in v5.4.0 

func NewActionGetJobLogParams() *ActionGetJobLogParams

NewActionGetJobLogParams creates a new ActionGetJobLogParams object with the default values initialized.

func NewActionGetJobLogParamsWithContext added in v5.4.0 

func NewActionGetJobLogParamsWithContext(ctx context.Context) *ActionGetJobLogParams

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

func NewActionGetJobLogParamsWithHTTPClient added in v5.4.0 

func NewActionGetJobLogParamsWithHTTPClient(client *http.Client) *ActionGetJobLogParams

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

func NewActionGetJobLogParamsWithTimeout added in v5.4.0 

func NewActionGetJobLogParamsWithTimeout(timeout time.Duration) *ActionGetJobLogParams

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

func (*ActionGetJobLogParams) SetContext added in v5.4.0 

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

SetContext adds the context to the action get job log params

func (*ActionGetJobLogParams) SetHTTPClient added in v5.4.0 

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

SetHTTPClient adds the HTTPClient to the action get job log params

func (*ActionGetJobLogParams) SetJobID added in v5.4.0 

func (o *ActionGetJobLogParams) SetJobID(jobID string)

SetJobID adds the jobId to the action get job log params

func (*ActionGetJobLogParams) SetTimeout added in v5.4.0 

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

SetTimeout adds the timeout to the action get job log params

func (*ActionGetJobLogParams) SetXRequestID added in v5.4.0 

func (o *ActionGetJobLogParams) SetXRequestID(xRequestID *string)

SetXRequestID adds the xRequestId to the action get job log params

func (*ActionGetJobLogParams) WithContext added in v5.4.0 

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

WithContext adds the context to the action get job log params

func (*ActionGetJobLogParams) WithHTTPClient added in v5.4.0 

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

WithHTTPClient adds the HTTPClient to the action get job log params

func (*ActionGetJobLogParams) WithJobID added in v5.4.0 

func (o *ActionGetJobLogParams) WithJobID(jobID string) *ActionGetJobLogParams

WithJobID adds the jobID to the action get job log params

func (*ActionGetJobLogParams) WithTimeout added in v5.4.0 

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

WithTimeout adds the timeout to the action get job log params

func (*ActionGetJobLogParams) WithXRequestID added in v5.4.0 

func (o *ActionGetJobLogParams) WithXRequestID(xRequestID *string) *ActionGetJobLogParams

WithXRequestID adds the xRequestID to the action get job log params

func (*ActionGetJobLogParams) WriteToRequest added in v5.4.0 

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

WriteToRequest writes these params to a swagger request

type ActionGetJobLogReader added in v5.4.0 

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

ActionGetJobLogReader is a Reader for the ActionGetJobLog structure.

func (*ActionGetJobLogReader) ReadResponse added in v5.4.0 

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

ReadResponse reads a server response into the received o.

type ActionGetJobLogUnauthorized added in v5.4.0 

type ActionGetJobLogUnauthorized struct {
	/*The ID of the corresponding request for the response
	 */
	XRequestID string

	Payload *model.Errors
}

ActionGetJobLogUnauthorized handles this case with default header values.

Unauthorized

func NewActionGetJobLogUnauthorized added in v5.4.0 

func NewActionGetJobLogUnauthorized() *ActionGetJobLogUnauthorized

NewActionGetJobLogUnauthorized creates a ActionGetJobLogUnauthorized with default headers values

func (*ActionGetJobLogUnauthorized) Error added in v5.4.0 

func (o *ActionGetJobLogUnauthorized) Error() string

func (*ActionGetJobLogUnauthorized) GetPayload added in v5.4.0 

func (o *ActionGetJobLogUnauthorized) GetPayload() *model.Errors

type ActionPendingJobsForbidden 

type ActionPendingJobsForbidden struct {
	/*The ID of the corresponding request for the response
	 */
	XRequestID string

	Payload *model.Errors
}

ActionPendingJobsForbidden handles this case with default header values.

Forbidden

func NewActionPendingJobsForbidden 

func NewActionPendingJobsForbidden() *ActionPendingJobsForbidden

NewActionPendingJobsForbidden creates a ActionPendingJobsForbidden with default headers values

func (*ActionPendingJobsForbidden) Error 

func (o *ActionPendingJobsForbidden) Error() string

func (*ActionPendingJobsForbidden) GetPayload 

func (o *ActionPendingJobsForbidden) GetPayload() *model.Errors

type ActionPendingJobsInternalServerError 

type ActionPendingJobsInternalServerError struct {
	/*The ID of the corresponding request for the response
	 */
	XRequestID string

	Payload *model.Errors
}

ActionPendingJobsInternalServerError handles this case with default header values.

Internal server error

func NewActionPendingJobsInternalServerError 

func NewActionPendingJobsInternalServerError() *ActionPendingJobsInternalServerError

NewActionPendingJobsInternalServerError creates a ActionPendingJobsInternalServerError with default headers values

func (*ActionPendingJobsInternalServerError) Error 

func (o *ActionPendingJobsInternalServerError) Error() string

func (*ActionPendingJobsInternalServerError) GetPayload 

func (o *ActionPendingJobsInternalServerError) GetPayload() *model.Errors

type ActionPendingJobsNotFound 

type ActionPendingJobsNotFound struct {
	/*The ID of the corresponding request for the response
	 */
	XRequestID string

	Payload *model.Errors
}

ActionPendingJobsNotFound handles this case with default header values.

Not found

func NewActionPendingJobsNotFound 

func NewActionPendingJobsNotFound() *ActionPendingJobsNotFound

NewActionPendingJobsNotFound creates a ActionPendingJobsNotFound with default headers values

func (*ActionPendingJobsNotFound) Error 

func (o *ActionPendingJobsNotFound) Error() string

func (*ActionPendingJobsNotFound) GetPayload 

func (o *ActionPendingJobsNotFound) GetPayload() *model.Errors

type ActionPendingJobsOK 

type ActionPendingJobsOK struct {
}

ActionPendingJobsOK handles this case with default header values.

take action to the jobs in the queue successfully.

func NewActionPendingJobsOK 

func NewActionPendingJobsOK() *ActionPendingJobsOK

NewActionPendingJobsOK creates a ActionPendingJobsOK with default headers values

func (*ActionPendingJobsOK) Error 

func (o *ActionPendingJobsOK) Error() string

type ActionPendingJobsParams 

type ActionPendingJobsParams struct {

	/*XRequestID
	  An unique ID for the request

	*/
	XRequestID *string
	/*ActionRequest*/
	ActionRequest *model.ActionRequest
	/*JobType
	  The type of the job. 'all' stands for all job types

	*/
	JobType string

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

ActionPendingJobsParams contains all the parameters to send to the API endpoint for the action pending jobs operation typically these are written to a http.Request

func NewActionPendingJobsParams 

func NewActionPendingJobsParams() *ActionPendingJobsParams

NewActionPendingJobsParams creates a new ActionPendingJobsParams object with the default values initialized.

func NewActionPendingJobsParamsWithContext 

func NewActionPendingJobsParamsWithContext(ctx context.Context) *ActionPendingJobsParams

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

func NewActionPendingJobsParamsWithHTTPClient 

func NewActionPendingJobsParamsWithHTTPClient(client *http.Client) *ActionPendingJobsParams

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

func NewActionPendingJobsParamsWithTimeout 

func NewActionPendingJobsParamsWithTimeout(timeout time.Duration) *ActionPendingJobsParams

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

func (*ActionPendingJobsParams) SetActionRequest 

func (o *ActionPendingJobsParams) SetActionRequest(actionRequest *model.ActionRequest)

SetActionRequest adds the actionRequest to the action pending jobs params

func (*ActionPendingJobsParams) SetContext 

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

SetContext adds the context to the action pending jobs params

func (*ActionPendingJobsParams) SetHTTPClient 

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

SetHTTPClient adds the HTTPClient to the action pending jobs params

func (*ActionPendingJobsParams) SetJobType 

func (o *ActionPendingJobsParams) SetJobType(jobType string)

SetJobType adds the jobType to the action pending jobs params

func (*ActionPendingJobsParams) SetTimeout 

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

SetTimeout adds the timeout to the action pending jobs params

func (*ActionPendingJobsParams) SetXRequestID 

func (o *ActionPendingJobsParams) SetXRequestID(xRequestID *string)

SetXRequestID adds the xRequestId to the action pending jobs params

func (*ActionPendingJobsParams) WithActionRequest 

func (o *ActionPendingJobsParams) WithActionRequest(actionRequest *model.ActionRequest) *ActionPendingJobsParams

WithActionRequest adds the actionRequest to the action pending jobs params

func (*ActionPendingJobsParams) WithContext 

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

WithContext adds the context to the action pending jobs params

func (*ActionPendingJobsParams) WithHTTPClient 

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

WithHTTPClient adds the HTTPClient to the action pending jobs params

func (*ActionPendingJobsParams) WithJobType 

func (o *ActionPendingJobsParams) WithJobType(jobType string) *ActionPendingJobsParams

WithJobType adds the jobType to the action pending jobs params

func (*ActionPendingJobsParams) WithTimeout 

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

WithTimeout adds the timeout to the action pending jobs params

func (*ActionPendingJobsParams) WithXRequestID 

func (o *ActionPendingJobsParams) WithXRequestID(xRequestID *string) *ActionPendingJobsParams

WithXRequestID adds the xRequestID to the action pending jobs params

func (*ActionPendingJobsParams) WriteToRequest 

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

WriteToRequest writes these params to a swagger request

type ActionPendingJobsReader 

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

ActionPendingJobsReader is a Reader for the ActionPendingJobs structure.

func (*ActionPendingJobsReader) ReadResponse 

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

ReadResponse reads a server response into the received o.

type ActionPendingJobsUnauthorized 

type ActionPendingJobsUnauthorized struct {
	/*The ID of the corresponding request for the response
	 */
	XRequestID string

	Payload *model.Errors
}

ActionPendingJobsUnauthorized handles this case with default header values.

Unauthorized

func NewActionPendingJobsUnauthorized 

func NewActionPendingJobsUnauthorized() *ActionPendingJobsUnauthorized

NewActionPendingJobsUnauthorized creates a ActionPendingJobsUnauthorized with default headers values

func (*ActionPendingJobsUnauthorized) Error 

func (o *ActionPendingJobsUnauthorized) Error() string

func (*ActionPendingJobsUnauthorized) GetPayload 

func (o *ActionPendingJobsUnauthorized) GetPayload() *model.Errors

type Client 

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

Client for jobservice API

func (*Client) ActionGetJobLog added in v5.4.0 

func (a *Client) ActionGetJobLog(params *ActionGetJobLogParams, authInfo runtime.ClientAuthInfoWriter) (*ActionGetJobLogOK, error)

ActionGetJobLog gets job log by job id

Get job log by job id, it is only used by administrator

func (*Client) ActionPendingJobs 

func (a *Client) ActionPendingJobs(params *ActionPendingJobsParams, authInfo runtime.ClientAuthInfoWriter) (*ActionPendingJobsOK, error)

ActionPendingJobs stops and clean pause resume pending jobs in the queue

stop and clean, pause, resume pending jobs in the queue

func (*Client) GetWorkerPools 

func (a *Client) GetWorkerPools(params *GetWorkerPoolsParams, authInfo runtime.ClientAuthInfoWriter) (*GetWorkerPoolsOK, error)

GetWorkerPools gets worker pools

Get worker pools

func (*Client) GetWorkers 

func (a *Client) GetWorkers(params *GetWorkersParams, authInfo runtime.ClientAuthInfoWriter) (*GetWorkersOK, error)

GetWorkers gets workers

Get workers in current pool

func (*Client) ListJobQueues 

func (a *Client) ListJobQueues(params *ListJobQueuesParams, authInfo runtime.ClientAuthInfoWriter) (*ListJobQueuesOK, error)

ListJobQueues lists job queues

list job queue

func (*Client) SetTransport 

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

SetTransport changes the transport on the client

func (*Client) StopRunningJob 

func (a *Client) StopRunningJob(params *StopRunningJobParams, authInfo runtime.ClientAuthInfoWriter) (*StopRunningJobOK, error)

StopRunningJob stops running job

Stop running job

type ClientService 

type ClientService interface {
	ActionGetJobLog(params *ActionGetJobLogParams, authInfo runtime.ClientAuthInfoWriter) (*ActionGetJobLogOK, error)

	ActionPendingJobs(params *ActionPendingJobsParams, authInfo runtime.ClientAuthInfoWriter) (*ActionPendingJobsOK, error)

	GetWorkerPools(params *GetWorkerPoolsParams, authInfo runtime.ClientAuthInfoWriter) (*GetWorkerPoolsOK, error)

	GetWorkers(params *GetWorkersParams, authInfo runtime.ClientAuthInfoWriter) (*GetWorkersOK, error)

	ListJobQueues(params *ListJobQueuesParams, authInfo runtime.ClientAuthInfoWriter) (*ListJobQueuesOK, error)

	StopRunningJob(params *StopRunningJobParams, authInfo runtime.ClientAuthInfoWriter) (*StopRunningJobOK, 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 jobservice API client.

type GetWorkerPoolsForbidden 

type GetWorkerPoolsForbidden struct {
	/*The ID of the corresponding request for the response
	 */
	XRequestID string

	Payload *model.Errors
}

GetWorkerPoolsForbidden handles this case with default header values.

Forbidden

func NewGetWorkerPoolsForbidden 

func NewGetWorkerPoolsForbidden() *GetWorkerPoolsForbidden

NewGetWorkerPoolsForbidden creates a GetWorkerPoolsForbidden with default headers values

func (*GetWorkerPoolsForbidden) Error 

func (o *GetWorkerPoolsForbidden) Error() string

func (*GetWorkerPoolsForbidden) GetPayload 

func (o *GetWorkerPoolsForbidden) GetPayload() *model.Errors

type GetWorkerPoolsInternalServerError 

type GetWorkerPoolsInternalServerError struct {
	/*The ID of the corresponding request for the response
	 */
	XRequestID string

	Payload *model.Errors
}

GetWorkerPoolsInternalServerError handles this case with default header values.

Internal server error

func NewGetWorkerPoolsInternalServerError 

func NewGetWorkerPoolsInternalServerError() *GetWorkerPoolsInternalServerError

NewGetWorkerPoolsInternalServerError creates a GetWorkerPoolsInternalServerError with default headers values

func (*GetWorkerPoolsInternalServerError) Error 

func (o *GetWorkerPoolsInternalServerError) Error() string

func (*GetWorkerPoolsInternalServerError) GetPayload 

func (o *GetWorkerPoolsInternalServerError) GetPayload() *model.Errors

type GetWorkerPoolsOK 

type GetWorkerPoolsOK struct {
	Payload []*model.WorkerPool
}

GetWorkerPoolsOK handles this case with default header values.

Get worker pools successfully.

func NewGetWorkerPoolsOK 

func NewGetWorkerPoolsOK() *GetWorkerPoolsOK

NewGetWorkerPoolsOK creates a GetWorkerPoolsOK with default headers values

func (*GetWorkerPoolsOK) Error 

func (o *GetWorkerPoolsOK) Error() string

func (*GetWorkerPoolsOK) GetPayload 

func (o *GetWorkerPoolsOK) GetPayload() []*model.WorkerPool

type GetWorkerPoolsParams 

type GetWorkerPoolsParams struct {

	/*XRequestID
	  An unique ID for the request

	*/
	XRequestID *string

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

GetWorkerPoolsParams contains all the parameters to send to the API endpoint for the get worker pools operation typically these are written to a http.Request

func NewGetWorkerPoolsParams 

func NewGetWorkerPoolsParams() *GetWorkerPoolsParams

NewGetWorkerPoolsParams creates a new GetWorkerPoolsParams object with the default values initialized.

func NewGetWorkerPoolsParamsWithContext 

func NewGetWorkerPoolsParamsWithContext(ctx context.Context) *GetWorkerPoolsParams

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

func NewGetWorkerPoolsParamsWithHTTPClient 

func NewGetWorkerPoolsParamsWithHTTPClient(client *http.Client) *GetWorkerPoolsParams

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

func NewGetWorkerPoolsParamsWithTimeout 

func NewGetWorkerPoolsParamsWithTimeout(timeout time.Duration) *GetWorkerPoolsParams

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

func (*GetWorkerPoolsParams) SetContext 

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

SetContext adds the context to the get worker pools params

func (*GetWorkerPoolsParams) SetHTTPClient 

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

SetHTTPClient adds the HTTPClient to the get worker pools params

func (*GetWorkerPoolsParams) SetTimeout 

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

SetTimeout adds the timeout to the get worker pools params

func (*GetWorkerPoolsParams) SetXRequestID 

func (o *GetWorkerPoolsParams) SetXRequestID(xRequestID *string)

SetXRequestID adds the xRequestId to the get worker pools params

func (*GetWorkerPoolsParams) WithContext 

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

WithContext adds the context to the get worker pools params

func (*GetWorkerPoolsParams) WithHTTPClient 

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

WithHTTPClient adds the HTTPClient to the get worker pools params

func (*GetWorkerPoolsParams) WithTimeout 

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

WithTimeout adds the timeout to the get worker pools params

func (*GetWorkerPoolsParams) WithXRequestID 

func (o *GetWorkerPoolsParams) WithXRequestID(xRequestID *string) *GetWorkerPoolsParams

WithXRequestID adds the xRequestID to the get worker pools params

func (*GetWorkerPoolsParams) WriteToRequest 

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

WriteToRequest writes these params to a swagger request

type GetWorkerPoolsReader 

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

GetWorkerPoolsReader is a Reader for the GetWorkerPools structure.

func (*GetWorkerPoolsReader) ReadResponse 

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

ReadResponse reads a server response into the received o.

type GetWorkerPoolsUnauthorized 

type GetWorkerPoolsUnauthorized struct {
	/*The ID of the corresponding request for the response
	 */
	XRequestID string

	Payload *model.Errors
}

GetWorkerPoolsUnauthorized handles this case with default header values.

Unauthorized

func NewGetWorkerPoolsUnauthorized 

func NewGetWorkerPoolsUnauthorized() *GetWorkerPoolsUnauthorized

NewGetWorkerPoolsUnauthorized creates a GetWorkerPoolsUnauthorized with default headers values

func (*GetWorkerPoolsUnauthorized) Error 

func (o *GetWorkerPoolsUnauthorized) Error() string

func (*GetWorkerPoolsUnauthorized) GetPayload 

func (o *GetWorkerPoolsUnauthorized) GetPayload() *model.Errors

type GetWorkersForbidden 

type GetWorkersForbidden struct {
	/*The ID of the corresponding request for the response
	 */
	XRequestID string

	Payload *model.Errors
}

GetWorkersForbidden handles this case with default header values.

Forbidden

func NewGetWorkersForbidden 

func NewGetWorkersForbidden() *GetWorkersForbidden

NewGetWorkersForbidden creates a GetWorkersForbidden with default headers values

func (*GetWorkersForbidden) Error 

func (o *GetWorkersForbidden) Error() string

func (*GetWorkersForbidden) GetPayload 

func (o *GetWorkersForbidden) GetPayload() *model.Errors

type GetWorkersInternalServerError 

type GetWorkersInternalServerError struct {
	/*The ID of the corresponding request for the response
	 */
	XRequestID string

	Payload *model.Errors
}

GetWorkersInternalServerError handles this case with default header values.

Internal server error

func NewGetWorkersInternalServerError 

func NewGetWorkersInternalServerError() *GetWorkersInternalServerError

NewGetWorkersInternalServerError creates a GetWorkersInternalServerError with default headers values

func (*GetWorkersInternalServerError) Error 

func (o *GetWorkersInternalServerError) Error() string

func (*GetWorkersInternalServerError) GetPayload 

func (o *GetWorkersInternalServerError) GetPayload() *model.Errors

type GetWorkersNotFound 

type GetWorkersNotFound struct {
	/*The ID of the corresponding request for the response
	 */
	XRequestID string

	Payload *model.Errors
}

GetWorkersNotFound handles this case with default header values.

Not found

func NewGetWorkersNotFound 

func NewGetWorkersNotFound() *GetWorkersNotFound

NewGetWorkersNotFound creates a GetWorkersNotFound with default headers values

func (*GetWorkersNotFound) Error 

func (o *GetWorkersNotFound) Error() string

func (*GetWorkersNotFound) GetPayload 

func (o *GetWorkersNotFound) GetPayload() *model.Errors

type GetWorkersOK 

type GetWorkersOK struct {
	Payload []*model.Worker
}

GetWorkersOK handles this case with default header values.

Get workers successfully.

func NewGetWorkersOK 

func NewGetWorkersOK() *GetWorkersOK

NewGetWorkersOK creates a GetWorkersOK with default headers values

func (*GetWorkersOK) Error 

func (o *GetWorkersOK) Error() string

func (*GetWorkersOK) GetPayload 

func (o *GetWorkersOK) GetPayload() []*model.Worker

type GetWorkersParams 

type GetWorkersParams struct {

	/*XRequestID
	  An unique ID for the request

	*/
	XRequestID *string
	/*PoolID
	  The name of the pool. 'all' stands for all pools

	*/
	PoolID string

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

GetWorkersParams contains all the parameters to send to the API endpoint for the get workers operation typically these are written to a http.Request

func NewGetWorkersParams 

func NewGetWorkersParams() *GetWorkersParams

NewGetWorkersParams creates a new GetWorkersParams object with the default values initialized.

func NewGetWorkersParamsWithContext 

func NewGetWorkersParamsWithContext(ctx context.Context) *GetWorkersParams

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

func NewGetWorkersParamsWithHTTPClient 

func NewGetWorkersParamsWithHTTPClient(client *http.Client) *GetWorkersParams

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

func NewGetWorkersParamsWithTimeout 

func NewGetWorkersParamsWithTimeout(timeout time.Duration) *GetWorkersParams

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

func (*GetWorkersParams) SetContext 

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

SetContext adds the context to the get workers params

func (*GetWorkersParams) SetHTTPClient 

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

SetHTTPClient adds the HTTPClient to the get workers params

func (*GetWorkersParams) SetPoolID 

func (o *GetWorkersParams) SetPoolID(poolID string)

SetPoolID adds the poolId to the get workers params

func (*GetWorkersParams) SetTimeout 

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

SetTimeout adds the timeout to the get workers params

func (*GetWorkersParams) SetXRequestID 

func (o *GetWorkersParams) SetXRequestID(xRequestID *string)

SetXRequestID adds the xRequestId to the get workers params

func (*GetWorkersParams) WithContext 

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

WithContext adds the context to the get workers params

func (*GetWorkersParams) WithHTTPClient 

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

WithHTTPClient adds the HTTPClient to the get workers params

func (*GetWorkersParams) WithPoolID 

func (o *GetWorkersParams) WithPoolID(poolID string) *GetWorkersParams

WithPoolID adds the poolID to the get workers params

func (*GetWorkersParams) WithTimeout 

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

WithTimeout adds the timeout to the get workers params

func (*GetWorkersParams) WithXRequestID 

func (o *GetWorkersParams) WithXRequestID(xRequestID *string) *GetWorkersParams

WithXRequestID adds the xRequestID to the get workers params

func (*GetWorkersParams) WriteToRequest 

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

WriteToRequest writes these params to a swagger request

type GetWorkersReader 

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

GetWorkersReader is a Reader for the GetWorkers structure.

func (*GetWorkersReader) ReadResponse 

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

ReadResponse reads a server response into the received o.

type GetWorkersUnauthorized 

type GetWorkersUnauthorized struct {
	/*The ID of the corresponding request for the response
	 */
	XRequestID string

	Payload *model.Errors
}

GetWorkersUnauthorized handles this case with default header values.

Unauthorized

func NewGetWorkersUnauthorized 

func NewGetWorkersUnauthorized() *GetWorkersUnauthorized

NewGetWorkersUnauthorized creates a GetWorkersUnauthorized with default headers values

func (*GetWorkersUnauthorized) Error 

func (o *GetWorkersUnauthorized) Error() string

func (*GetWorkersUnauthorized) GetPayload 

func (o *GetWorkersUnauthorized) GetPayload() *model.Errors

type ListJobQueuesForbidden 

type ListJobQueuesForbidden struct {
	/*The ID of the corresponding request for the response
	 */
	XRequestID string

	Payload *model.Errors
}

ListJobQueuesForbidden handles this case with default header values.

Forbidden

func NewListJobQueuesForbidden 

func NewListJobQueuesForbidden() *ListJobQueuesForbidden

NewListJobQueuesForbidden creates a ListJobQueuesForbidden with default headers values

func (*ListJobQueuesForbidden) Error 

func (o *ListJobQueuesForbidden) Error() string

func (*ListJobQueuesForbidden) GetPayload 

func (o *ListJobQueuesForbidden) GetPayload() *model.Errors

type ListJobQueuesInternalServerError 

type ListJobQueuesInternalServerError struct {
	/*The ID of the corresponding request for the response
	 */
	XRequestID string

	Payload *model.Errors
}

ListJobQueuesInternalServerError handles this case with default header values.

Internal server error

func NewListJobQueuesInternalServerError 

func NewListJobQueuesInternalServerError() *ListJobQueuesInternalServerError

NewListJobQueuesInternalServerError creates a ListJobQueuesInternalServerError with default headers values

func (*ListJobQueuesInternalServerError) Error 

func (o *ListJobQueuesInternalServerError) Error() string

func (*ListJobQueuesInternalServerError) GetPayload 

func (o *ListJobQueuesInternalServerError) GetPayload() *model.Errors

type ListJobQueuesNotFound 

type ListJobQueuesNotFound struct {
	/*The ID of the corresponding request for the response
	 */
	XRequestID string

	Payload *model.Errors
}

ListJobQueuesNotFound handles this case with default header values.

Not found

func NewListJobQueuesNotFound 

func NewListJobQueuesNotFound() *ListJobQueuesNotFound

NewListJobQueuesNotFound creates a ListJobQueuesNotFound with default headers values

func (*ListJobQueuesNotFound) Error 

func (o *ListJobQueuesNotFound) Error() string

func (*ListJobQueuesNotFound) GetPayload 

func (o *ListJobQueuesNotFound) GetPayload() *model.Errors

type ListJobQueuesOK 

type ListJobQueuesOK struct {
	Payload []*model.JobQueue
}

ListJobQueuesOK handles this case with default header values.

List job queue successfully.

func NewListJobQueuesOK 

func NewListJobQueuesOK() *ListJobQueuesOK

NewListJobQueuesOK creates a ListJobQueuesOK with default headers values

func (*ListJobQueuesOK) Error 

func (o *ListJobQueuesOK) Error() string

func (*ListJobQueuesOK) GetPayload 

func (o *ListJobQueuesOK) GetPayload() []*model.JobQueue

type ListJobQueuesParams 

type ListJobQueuesParams struct {

	/*XRequestID
	  An unique ID for the request

	*/
	XRequestID *string

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

ListJobQueuesParams contains all the parameters to send to the API endpoint for the list job queues operation typically these are written to a http.Request

func NewListJobQueuesParams 

func NewListJobQueuesParams() *ListJobQueuesParams

NewListJobQueuesParams creates a new ListJobQueuesParams object with the default values initialized.

func NewListJobQueuesParamsWithContext 

func NewListJobQueuesParamsWithContext(ctx context.Context) *ListJobQueuesParams

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

func NewListJobQueuesParamsWithHTTPClient 

func NewListJobQueuesParamsWithHTTPClient(client *http.Client) *ListJobQueuesParams

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

func NewListJobQueuesParamsWithTimeout 

func NewListJobQueuesParamsWithTimeout(timeout time.Duration) *ListJobQueuesParams

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

func (*ListJobQueuesParams) SetContext 

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

SetContext adds the context to the list job queues params

func (*ListJobQueuesParams) SetHTTPClient 

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

SetHTTPClient adds the HTTPClient to the list job queues params

func (*ListJobQueuesParams) SetTimeout 

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

SetTimeout adds the timeout to the list job queues params

func (*ListJobQueuesParams) SetXRequestID 

func (o *ListJobQueuesParams) SetXRequestID(xRequestID *string)

SetXRequestID adds the xRequestId to the list job queues params

func (*ListJobQueuesParams) WithContext 

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

WithContext adds the context to the list job queues params

func (*ListJobQueuesParams) WithHTTPClient 

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

WithHTTPClient adds the HTTPClient to the list job queues params

func (*ListJobQueuesParams) WithTimeout 

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

WithTimeout adds the timeout to the list job queues params

func (*ListJobQueuesParams) WithXRequestID 

func (o *ListJobQueuesParams) WithXRequestID(xRequestID *string) *ListJobQueuesParams

WithXRequestID adds the xRequestID to the list job queues params

func (*ListJobQueuesParams) WriteToRequest 

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

WriteToRequest writes these params to a swagger request

type ListJobQueuesReader 

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

ListJobQueuesReader is a Reader for the ListJobQueues structure.

func (*ListJobQueuesReader) ReadResponse 

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

ReadResponse reads a server response into the received o.

type ListJobQueuesUnauthorized 

type ListJobQueuesUnauthorized struct {
	/*The ID of the corresponding request for the response
	 */
	XRequestID string

	Payload *model.Errors
}

ListJobQueuesUnauthorized handles this case with default header values.

Unauthorized

func NewListJobQueuesUnauthorized 

func NewListJobQueuesUnauthorized() *ListJobQueuesUnauthorized

NewListJobQueuesUnauthorized creates a ListJobQueuesUnauthorized with default headers values

func (*ListJobQueuesUnauthorized) Error 

func (o *ListJobQueuesUnauthorized) Error() string

func (*ListJobQueuesUnauthorized) GetPayload 

func (o *ListJobQueuesUnauthorized) GetPayload() *model.Errors

type StopRunningJobForbidden 

type StopRunningJobForbidden struct {
	/*The ID of the corresponding request for the response
	 */
	XRequestID string

	Payload *model.Errors
}

StopRunningJobForbidden handles this case with default header values.

Forbidden

func NewStopRunningJobForbidden 

func NewStopRunningJobForbidden() *StopRunningJobForbidden

NewStopRunningJobForbidden creates a StopRunningJobForbidden with default headers values

func (*StopRunningJobForbidden) Error 

func (o *StopRunningJobForbidden) Error() string

func (*StopRunningJobForbidden) GetPayload 

func (o *StopRunningJobForbidden) GetPayload() *model.Errors

type StopRunningJobInternalServerError 

type StopRunningJobInternalServerError struct {
	/*The ID of the corresponding request for the response
	 */
	XRequestID string

	Payload *model.Errors
}

StopRunningJobInternalServerError handles this case with default header values.

Internal server error

func NewStopRunningJobInternalServerError 

func NewStopRunningJobInternalServerError() *StopRunningJobInternalServerError

NewStopRunningJobInternalServerError creates a StopRunningJobInternalServerError with default headers values

func (*StopRunningJobInternalServerError) Error 

func (o *StopRunningJobInternalServerError) Error() string

func (*StopRunningJobInternalServerError) GetPayload 

func (o *StopRunningJobInternalServerError) GetPayload() *model.Errors

type StopRunningJobNotFound 

type StopRunningJobNotFound struct {
	/*The ID of the corresponding request for the response
	 */
	XRequestID string

	Payload *model.Errors
}

StopRunningJobNotFound handles this case with default header values.

Not found

func NewStopRunningJobNotFound 

func NewStopRunningJobNotFound() *StopRunningJobNotFound

NewStopRunningJobNotFound creates a StopRunningJobNotFound with default headers values

func (*StopRunningJobNotFound) Error 

func (o *StopRunningJobNotFound) Error() string

func (*StopRunningJobNotFound) GetPayload 

func (o *StopRunningJobNotFound) GetPayload() *model.Errors

type StopRunningJobOK 

type StopRunningJobOK struct {
}

StopRunningJobOK handles this case with default header values.

Stop worker successfully.

func NewStopRunningJobOK 

func NewStopRunningJobOK() *StopRunningJobOK

NewStopRunningJobOK creates a StopRunningJobOK with default headers values

func (*StopRunningJobOK) Error 

func (o *StopRunningJobOK) Error() string

type StopRunningJobParams 

type StopRunningJobParams struct {

	/*XRequestID
	  An unique ID for the request

	*/
	XRequestID *string
	/*JobID
	  The id of the job.

	*/
	JobID string

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

StopRunningJobParams contains all the parameters to send to the API endpoint for the stop running job operation typically these are written to a http.Request

func NewStopRunningJobParams 

func NewStopRunningJobParams() *StopRunningJobParams

NewStopRunningJobParams creates a new StopRunningJobParams object with the default values initialized.

func NewStopRunningJobParamsWithContext 

func NewStopRunningJobParamsWithContext(ctx context.Context) *StopRunningJobParams

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

func NewStopRunningJobParamsWithHTTPClient 

func NewStopRunningJobParamsWithHTTPClient(client *http.Client) *StopRunningJobParams

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

func NewStopRunningJobParamsWithTimeout 

func NewStopRunningJobParamsWithTimeout(timeout time.Duration) *StopRunningJobParams

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

func (*StopRunningJobParams) SetContext 

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

SetContext adds the context to the stop running job params

func (*StopRunningJobParams) SetHTTPClient 

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

SetHTTPClient adds the HTTPClient to the stop running job params

func (*StopRunningJobParams) SetJobID 

func (o *StopRunningJobParams) SetJobID(jobID string)

SetJobID adds the jobId to the stop running job params

func (*StopRunningJobParams) SetTimeout 

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

SetTimeout adds the timeout to the stop running job params

func (*StopRunningJobParams) SetXRequestID 

func (o *StopRunningJobParams) SetXRequestID(xRequestID *string)

SetXRequestID adds the xRequestId to the stop running job params

func (*StopRunningJobParams) WithContext 

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

WithContext adds the context to the stop running job params

func (*StopRunningJobParams) WithHTTPClient 

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

WithHTTPClient adds the HTTPClient to the stop running job params

func (*StopRunningJobParams) WithJobID 

func (o *StopRunningJobParams) WithJobID(jobID string) *StopRunningJobParams

WithJobID adds the jobID to the stop running job params

func (*StopRunningJobParams) WithTimeout 

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

WithTimeout adds the timeout to the stop running job params

func (*StopRunningJobParams) WithXRequestID 

func (o *StopRunningJobParams) WithXRequestID(xRequestID *string) *StopRunningJobParams

WithXRequestID adds the xRequestID to the stop running job params

func (*StopRunningJobParams) WriteToRequest 

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

WriteToRequest writes these params to a swagger request

type StopRunningJobReader 

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

StopRunningJobReader is a Reader for the StopRunningJob structure.

func (*StopRunningJobReader) ReadResponse 

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

ReadResponse reads a server response into the received o.

type StopRunningJobUnauthorized 

type StopRunningJobUnauthorized struct {
	/*The ID of the corresponding request for the response
	 */
	XRequestID string

	Payload *model.Errors
}

StopRunningJobUnauthorized handles this case with default header values.

Unauthorized

func NewStopRunningJobUnauthorized 

func NewStopRunningJobUnauthorized() *StopRunningJobUnauthorized

NewStopRunningJobUnauthorized creates a StopRunningJobUnauthorized with default headers values

func (*StopRunningJobUnauthorized) Error 

func (o *StopRunningJobUnauthorized) Error() string

func (*StopRunningJobUnauthorized) GetPayload 

func (o *StopRunningJobUnauthorized) GetPayload() *model.Errors

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.