jobservice

package
v0.210.0 Latest Latest
Warning

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

 Go to latest Published: Jan 25, 2024 License: Apache-2.0 Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type API 

type API interface {
	/*
	   ActionGetJobLog gets job log by job id

	   Get job log by job id, it is only used by administrator*/
	ActionGetJobLog(ctx context.Context, params *ActionGetJobLogParams) (*ActionGetJobLogOK, error)
	/*
	   ActionPendingJobs stops and clean pause resume pending jobs in the queue

	   stop and clean, pause, resume pending jobs in the queue*/
	ActionPendingJobs(ctx context.Context, params *ActionPendingJobsParams) (*ActionPendingJobsOK, error)
	/*
	   GetWorkerPools gets worker pools

	   Get worker pools*/
	GetWorkerPools(ctx context.Context, params *GetWorkerPoolsParams) (*GetWorkerPoolsOK, error)
	/*
	   GetWorkers gets workers

	   Get workers in current pool*/
	GetWorkers(ctx context.Context, params *GetWorkersParams) (*GetWorkersOK, error)
	/*
	   ListJobQueues lists job queues

	   list job queue*/
	ListJobQueues(ctx context.Context, params *ListJobQueuesParams) (*ListJobQueuesOK, error)
	/*
	   StopRunningJob stops running job

	   Stop running job*/
	StopRunningJob(ctx context.Context, params *StopRunningJobParams) (*StopRunningJobOK, error)
}

API is the interface of the jobservice client

type ActionGetJobLogForbidden 

type ActionGetJobLogForbidden struct {

	/* The ID of the corresponding request for the response
	 */
	XRequestID string

	Payload *models.Errors
}

ActionGetJobLogForbidden describes a response with status code 403, with default header values.

Forbidden

func NewActionGetJobLogForbidden 

func NewActionGetJobLogForbidden() *ActionGetJobLogForbidden

NewActionGetJobLogForbidden creates a ActionGetJobLogForbidden with default headers values

func (*ActionGetJobLogForbidden) Error 

func (o *ActionGetJobLogForbidden) Error() string

func (*ActionGetJobLogForbidden) GetPayload 

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

func (*ActionGetJobLogForbidden) IsClientError 

func (o *ActionGetJobLogForbidden) IsClientError() bool

IsClientError returns true when this action get job log forbidden response has a 4xx status code

func (*ActionGetJobLogForbidden) IsCode 

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

IsCode returns true when this action get job log forbidden response a status code equal to that given

func (*ActionGetJobLogForbidden) IsRedirect 

func (o *ActionGetJobLogForbidden) IsRedirect() bool

IsRedirect returns true when this action get job log forbidden response has a 3xx status code

func (*ActionGetJobLogForbidden) IsServerError 

func (o *ActionGetJobLogForbidden) IsServerError() bool

IsServerError returns true when this action get job log forbidden response has a 5xx status code

func (*ActionGetJobLogForbidden) IsSuccess 

func (o *ActionGetJobLogForbidden) IsSuccess() bool

IsSuccess returns true when this action get job log forbidden response has a 2xx status code

func (*ActionGetJobLogForbidden) String 

func (o *ActionGetJobLogForbidden) String() string

type ActionGetJobLogInternalServerError 

type ActionGetJobLogInternalServerError struct {

	/* The ID of the corresponding request for the response
	 */
	XRequestID string

	Payload *models.Errors
}

ActionGetJobLogInternalServerError describes a response with status code 500, with default header values.

Internal server error

func NewActionGetJobLogInternalServerError 

func NewActionGetJobLogInternalServerError() *ActionGetJobLogInternalServerError

NewActionGetJobLogInternalServerError creates a ActionGetJobLogInternalServerError with default headers values

func (*ActionGetJobLogInternalServerError) Error 

func (o *ActionGetJobLogInternalServerError) Error() string

func (*ActionGetJobLogInternalServerError) GetPayload 

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

func (*ActionGetJobLogInternalServerError) IsClientError 

func (o *ActionGetJobLogInternalServerError) IsClientError() bool

IsClientError returns true when this action get job log internal server error response has a 4xx status code

func (*ActionGetJobLogInternalServerError) IsCode 

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

IsCode returns true when this action get job log internal server error response a status code equal to that given

func (*ActionGetJobLogInternalServerError) IsRedirect 

func (o *ActionGetJobLogInternalServerError) IsRedirect() bool

IsRedirect returns true when this action get job log internal server error response has a 3xx status code

func (*ActionGetJobLogInternalServerError) IsServerError 

func (o *ActionGetJobLogInternalServerError) IsServerError() bool

IsServerError returns true when this action get job log internal server error response has a 5xx status code

func (*ActionGetJobLogInternalServerError) IsSuccess 

func (o *ActionGetJobLogInternalServerError) IsSuccess() bool

IsSuccess returns true when this action get job log internal server error response has a 2xx status code

func (*ActionGetJobLogInternalServerError) String 

func (o *ActionGetJobLogInternalServerError) String() string

type ActionGetJobLogNotFound 

type ActionGetJobLogNotFound struct {

	/* The ID of the corresponding request for the response
	 */
	XRequestID string

	Payload *models.Errors
}

ActionGetJobLogNotFound describes a response with status code 404, with default header values.

Not found

func NewActionGetJobLogNotFound 

func NewActionGetJobLogNotFound() *ActionGetJobLogNotFound

NewActionGetJobLogNotFound creates a ActionGetJobLogNotFound with default headers values

func (*ActionGetJobLogNotFound) Error 

func (o *ActionGetJobLogNotFound) Error() string

func (*ActionGetJobLogNotFound) GetPayload 

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

func (*ActionGetJobLogNotFound) IsClientError 

func (o *ActionGetJobLogNotFound) IsClientError() bool

IsClientError returns true when this action get job log not found response has a 4xx status code

func (*ActionGetJobLogNotFound) IsCode 

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

IsCode returns true when this action get job log not found response a status code equal to that given

func (*ActionGetJobLogNotFound) IsRedirect 

func (o *ActionGetJobLogNotFound) IsRedirect() bool

IsRedirect returns true when this action get job log not found response has a 3xx status code

func (*ActionGetJobLogNotFound) IsServerError 

func (o *ActionGetJobLogNotFound) IsServerError() bool

IsServerError returns true when this action get job log not found response has a 5xx status code

func (*ActionGetJobLogNotFound) IsSuccess 

func (o *ActionGetJobLogNotFound) IsSuccess() bool

IsSuccess returns true when this action get job log not found response has a 2xx status code

func (*ActionGetJobLogNotFound) String 

func (o *ActionGetJobLogNotFound) String() string

type ActionGetJobLogOK 

type ActionGetJobLogOK struct {

	/* The content type of response body
	 */
	ContentType string

	Payload string
}

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

Get job log successfully.

func NewActionGetJobLogOK 

func NewActionGetJobLogOK() *ActionGetJobLogOK

NewActionGetJobLogOK creates a ActionGetJobLogOK with default headers values

func (*ActionGetJobLogOK) Error 

func (o *ActionGetJobLogOK) Error() string

func (*ActionGetJobLogOK) GetPayload 

func (o *ActionGetJobLogOK) GetPayload() string

func (*ActionGetJobLogOK) IsClientError 

func (o *ActionGetJobLogOK) IsClientError() bool

IsClientError returns true when this action get job log o k response has a 4xx status code

func (*ActionGetJobLogOK) IsCode 

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

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

func (*ActionGetJobLogOK) IsRedirect 

func (o *ActionGetJobLogOK) IsRedirect() bool

IsRedirect returns true when this action get job log o k response has a 3xx status code

func (*ActionGetJobLogOK) IsServerError 

func (o *ActionGetJobLogOK) IsServerError() bool

IsServerError returns true when this action get job log o k response has a 5xx status code

func (*ActionGetJobLogOK) IsSuccess 

func (o *ActionGetJobLogOK) IsSuccess() bool

IsSuccess returns true when this action get job log o k response has a 2xx status code

func (*ActionGetJobLogOK) String 

func (o *ActionGetJobLogOK) String() string

type ActionGetJobLogParams 

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 

func NewActionGetJobLogParams() *ActionGetJobLogParams

NewActionGetJobLogParams creates a new ActionGetJobLogParams object, with the default timeout for this client.

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

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

func NewActionGetJobLogParamsWithContext 

func NewActionGetJobLogParamsWithContext(ctx context.Context) *ActionGetJobLogParams

NewActionGetJobLogParamsWithContext creates a new ActionGetJobLogParams object with the ability to set a context for a request.

func NewActionGetJobLogParamsWithHTTPClient 

func NewActionGetJobLogParamsWithHTTPClient(client *http.Client) *ActionGetJobLogParams

NewActionGetJobLogParamsWithHTTPClient creates a new ActionGetJobLogParams object with the ability to set a custom HTTPClient for a request.

func NewActionGetJobLogParamsWithTimeout 

func NewActionGetJobLogParamsWithTimeout(timeout time.Duration) *ActionGetJobLogParams

NewActionGetJobLogParamsWithTimeout creates a new ActionGetJobLogParams object with the ability to set a timeout on a request.

func (*ActionGetJobLogParams) SetContext 

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

SetContext adds the context to the action get job log params

func (*ActionGetJobLogParams) SetDefaults 

func (o *ActionGetJobLogParams) SetDefaults()

SetDefaults hydrates default values in the action get job log params (not the query body).

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

func (*ActionGetJobLogParams) SetHTTPClient 

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

SetHTTPClient adds the HTTPClient to the action get job log params

func (*ActionGetJobLogParams) SetJobID 

func (o *ActionGetJobLogParams) SetJobID(jobID string)

SetJobID adds the jobId to the action get job log params

func (*ActionGetJobLogParams) SetTimeout 

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

SetTimeout adds the timeout to the action get job log params

func (*ActionGetJobLogParams) SetXRequestID 

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

SetXRequestID adds the xRequestId to the action get job log params

func (*ActionGetJobLogParams) WithContext 

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

WithContext adds the context to the action get job log params

func (*ActionGetJobLogParams) WithDefaults 

func (o *ActionGetJobLogParams) WithDefaults() *ActionGetJobLogParams

WithDefaults hydrates default values in the action get job log params (not the query body).

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

func (*ActionGetJobLogParams) WithHTTPClient 

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

WithHTTPClient adds the HTTPClient to the action get job log params

func (*ActionGetJobLogParams) WithJobID 

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

WithJobID adds the jobID to the action get job log params

func (*ActionGetJobLogParams) WithTimeout 

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

WithTimeout adds the timeout to the action get job log params

func (*ActionGetJobLogParams) WithXRequestID 

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

WithXRequestID adds the xRequestID to the action get job log params

func (*ActionGetJobLogParams) WriteToRequest 

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

WriteToRequest writes these params to a swagger request

type ActionGetJobLogReader 

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

ActionGetJobLogReader is a Reader for the ActionGetJobLog structure.

func (*ActionGetJobLogReader) ReadResponse 

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

ReadResponse reads a server response into the received o.

type ActionGetJobLogUnauthorized 

type ActionGetJobLogUnauthorized struct {

	/* The ID of the corresponding request for the response
	 */
	XRequestID string

	Payload *models.Errors
}

ActionGetJobLogUnauthorized describes a response with status code 401, with default header values.

Unauthorized

func NewActionGetJobLogUnauthorized 

func NewActionGetJobLogUnauthorized() *ActionGetJobLogUnauthorized

NewActionGetJobLogUnauthorized creates a ActionGetJobLogUnauthorized with default headers values

func (*ActionGetJobLogUnauthorized) Error 

func (o *ActionGetJobLogUnauthorized) Error() string

func (*ActionGetJobLogUnauthorized) GetPayload 

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

func (*ActionGetJobLogUnauthorized) IsClientError 

func (o *ActionGetJobLogUnauthorized) IsClientError() bool

IsClientError returns true when this action get job log unauthorized response has a 4xx status code

func (*ActionGetJobLogUnauthorized) IsCode 

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

IsCode returns true when this action get job log unauthorized response a status code equal to that given

func (*ActionGetJobLogUnauthorized) IsRedirect 

func (o *ActionGetJobLogUnauthorized) IsRedirect() bool

IsRedirect returns true when this action get job log unauthorized response has a 3xx status code

func (*ActionGetJobLogUnauthorized) IsServerError 

func (o *ActionGetJobLogUnauthorized) IsServerError() bool

IsServerError returns true when this action get job log unauthorized response has a 5xx status code

func (*ActionGetJobLogUnauthorized) IsSuccess 

func (o *ActionGetJobLogUnauthorized) IsSuccess() bool

IsSuccess returns true when this action get job log unauthorized response has a 2xx status code

func (*ActionGetJobLogUnauthorized) String 

func (o *ActionGetJobLogUnauthorized) String() string

type ActionPendingJobsForbidden 

type ActionPendingJobsForbidden struct {

	/* The ID of the corresponding request for the response
	 */
	XRequestID string

	Payload *models.Errors
}

ActionPendingJobsForbidden describes a response with status code 403, 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() *models.Errors

func (*ActionPendingJobsForbidden) IsClientError 

func (o *ActionPendingJobsForbidden) IsClientError() bool

IsClientError returns true when this action pending jobs forbidden response has a 4xx status code

func (*ActionPendingJobsForbidden) IsCode 

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

IsCode returns true when this action pending jobs forbidden response a status code equal to that given

func (*ActionPendingJobsForbidden) IsRedirect 

func (o *ActionPendingJobsForbidden) IsRedirect() bool

IsRedirect returns true when this action pending jobs forbidden response has a 3xx status code

func (*ActionPendingJobsForbidden) IsServerError 

func (o *ActionPendingJobsForbidden) IsServerError() bool

IsServerError returns true when this action pending jobs forbidden response has a 5xx status code

func (*ActionPendingJobsForbidden) IsSuccess 

func (o *ActionPendingJobsForbidden) IsSuccess() bool

IsSuccess returns true when this action pending jobs forbidden response has a 2xx status code

func (*ActionPendingJobsForbidden) String 

func (o *ActionPendingJobsForbidden) String() string

type ActionPendingJobsInternalServerError 

type ActionPendingJobsInternalServerError struct {

	/* The ID of the corresponding request for the response
	 */
	XRequestID string

	Payload *models.Errors
}

ActionPendingJobsInternalServerError describes a response with status code 500, 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() *models.Errors

func (*ActionPendingJobsInternalServerError) IsClientError 

func (o *ActionPendingJobsInternalServerError) IsClientError() bool

IsClientError returns true when this action pending jobs internal server error response has a 4xx status code

func (*ActionPendingJobsInternalServerError) IsCode 

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

IsCode returns true when this action pending jobs internal server error response a status code equal to that given

func (*ActionPendingJobsInternalServerError) IsRedirect 

func (o *ActionPendingJobsInternalServerError) IsRedirect() bool

IsRedirect returns true when this action pending jobs internal server error response has a 3xx status code

func (*ActionPendingJobsInternalServerError) IsServerError 

func (o *ActionPendingJobsInternalServerError) IsServerError() bool

IsServerError returns true when this action pending jobs internal server error response has a 5xx status code

func (*ActionPendingJobsInternalServerError) IsSuccess 

func (o *ActionPendingJobsInternalServerError) IsSuccess() bool

IsSuccess returns true when this action pending jobs internal server error response has a 2xx status code

func (*ActionPendingJobsInternalServerError) String 

func (o *ActionPendingJobsInternalServerError) String() string

type ActionPendingJobsNotFound 

type ActionPendingJobsNotFound struct {

	/* The ID of the corresponding request for the response
	 */
	XRequestID string

	Payload *models.Errors
}

ActionPendingJobsNotFound describes a response with status code 404, 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() *models.Errors

func (*ActionPendingJobsNotFound) IsClientError 

func (o *ActionPendingJobsNotFound) IsClientError() bool

IsClientError returns true when this action pending jobs not found response has a 4xx status code

func (*ActionPendingJobsNotFound) IsCode 

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

IsCode returns true when this action pending jobs not found response a status code equal to that given

func (*ActionPendingJobsNotFound) IsRedirect 

func (o *ActionPendingJobsNotFound) IsRedirect() bool

IsRedirect returns true when this action pending jobs not found response has a 3xx status code

func (*ActionPendingJobsNotFound) IsServerError 

func (o *ActionPendingJobsNotFound) IsServerError() bool

IsServerError returns true when this action pending jobs not found response has a 5xx status code

func (*ActionPendingJobsNotFound) IsSuccess 

func (o *ActionPendingJobsNotFound) IsSuccess() bool

IsSuccess returns true when this action pending jobs not found response has a 2xx status code

func (*ActionPendingJobsNotFound) String 

func (o *ActionPendingJobsNotFound) String() string

type ActionPendingJobsOK 

type ActionPendingJobsOK struct {
}

ActionPendingJobsOK describes a response with status code 200, 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

func (*ActionPendingJobsOK) IsClientError 

func (o *ActionPendingJobsOK) IsClientError() bool

IsClientError returns true when this action pending jobs o k response has a 4xx status code

func (*ActionPendingJobsOK) IsCode 

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

IsCode returns true when this action pending jobs o k response a status code equal to that given

func (*ActionPendingJobsOK) IsRedirect 

func (o *ActionPendingJobsOK) IsRedirect() bool

IsRedirect returns true when this action pending jobs o k response has a 3xx status code

func (*ActionPendingJobsOK) IsServerError 

func (o *ActionPendingJobsOK) IsServerError() bool

IsServerError returns true when this action pending jobs o k response has a 5xx status code

func (*ActionPendingJobsOK) IsSuccess 

func (o *ActionPendingJobsOK) IsSuccess() bool

IsSuccess returns true when this action pending jobs o k response has a 2xx status code

func (*ActionPendingJobsOK) String 

func (o *ActionPendingJobsOK) String() string

type ActionPendingJobsParams 

type ActionPendingJobsParams struct {

	/* XRequestID.

	   An unique ID for the request
	*/
	XRequestID *string

	// ActionRequest.
	ActionRequest *models.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 timeout for this client.

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

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

func NewActionPendingJobsParamsWithContext 

func NewActionPendingJobsParamsWithContext(ctx context.Context) *ActionPendingJobsParams

NewActionPendingJobsParamsWithContext creates a new ActionPendingJobsParams object with 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 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 ability to set a timeout on a request.

func (*ActionPendingJobsParams) SetActionRequest 

func (o *ActionPendingJobsParams) SetActionRequest(actionRequest *models.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) SetDefaults 

func (o *ActionPendingJobsParams) SetDefaults()

SetDefaults hydrates default values in the action pending jobs params (not the query body).

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

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 *models.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) WithDefaults 

func (o *ActionPendingJobsParams) WithDefaults() *ActionPendingJobsParams

WithDefaults hydrates default values in the action pending jobs params (not the query body).

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

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 *models.Errors
}

ActionPendingJobsUnauthorized describes a response with status code 401, 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() *models.Errors

func (*ActionPendingJobsUnauthorized) IsClientError 

func (o *ActionPendingJobsUnauthorized) IsClientError() bool

IsClientError returns true when this action pending jobs unauthorized response has a 4xx status code

func (*ActionPendingJobsUnauthorized) IsCode 

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

IsCode returns true when this action pending jobs unauthorized response a status code equal to that given

func (*ActionPendingJobsUnauthorized) IsRedirect 

func (o *ActionPendingJobsUnauthorized) IsRedirect() bool

IsRedirect returns true when this action pending jobs unauthorized response has a 3xx status code

func (*ActionPendingJobsUnauthorized) IsServerError 

func (o *ActionPendingJobsUnauthorized) IsServerError() bool

IsServerError returns true when this action pending jobs unauthorized response has a 5xx status code

func (*ActionPendingJobsUnauthorized) IsSuccess 

func (o *ActionPendingJobsUnauthorized) IsSuccess() bool

IsSuccess returns true when this action pending jobs unauthorized response has a 2xx status code

func (*ActionPendingJobsUnauthorized) String 

func (o *ActionPendingJobsUnauthorized) String() string

type Client 

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

Client for jobservice API

func New 

func New(transport runtime.ClientTransport, formats strfmt.Registry, authInfo runtime.ClientAuthInfoWriter) *Client

New creates a new jobservice API client.

func (*Client) ActionGetJobLog 

func (a *Client) ActionGetJobLog(ctx context.Context, params *ActionGetJobLogParams) (*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(ctx context.Context, params *ActionPendingJobsParams) (*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(ctx context.Context, params *GetWorkerPoolsParams) (*GetWorkerPoolsOK, error)

GetWorkerPools gets worker pools

Get worker pools

func (*Client) GetWorkers 

func (a *Client) GetWorkers(ctx context.Context, params *GetWorkersParams) (*GetWorkersOK, error)

GetWorkers gets workers

Get workers in current pool

func (*Client) ListJobQueues 

func (a *Client) ListJobQueues(ctx context.Context, params *ListJobQueuesParams) (*ListJobQueuesOK, error)

ListJobQueues lists job queues

list job queue

func (*Client) StopRunningJob 

func (a *Client) StopRunningJob(ctx context.Context, params *StopRunningJobParams) (*StopRunningJobOK, error)

StopRunningJob stops running job

Stop running job

type GetWorkerPoolsForbidden 

type GetWorkerPoolsForbidden struct {

	/* The ID of the corresponding request for the response
	 */
	XRequestID string

	Payload *models.Errors
}

GetWorkerPoolsForbidden describes a response with status code 403, 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() *models.Errors

func (*GetWorkerPoolsForbidden) IsClientError 

func (o *GetWorkerPoolsForbidden) IsClientError() bool

IsClientError returns true when this get worker pools forbidden response has a 4xx status code

func (*GetWorkerPoolsForbidden) IsCode 

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

IsCode returns true when this get worker pools forbidden response a status code equal to that given

func (*GetWorkerPoolsForbidden) IsRedirect 

func (o *GetWorkerPoolsForbidden) IsRedirect() bool

IsRedirect returns true when this get worker pools forbidden response has a 3xx status code

func (*GetWorkerPoolsForbidden) IsServerError 

func (o *GetWorkerPoolsForbidden) IsServerError() bool

IsServerError returns true when this get worker pools forbidden response has a 5xx status code

func (*GetWorkerPoolsForbidden) IsSuccess 

func (o *GetWorkerPoolsForbidden) IsSuccess() bool

IsSuccess returns true when this get worker pools forbidden response has a 2xx status code

func (*GetWorkerPoolsForbidden) String 

func (o *GetWorkerPoolsForbidden) String() string

type GetWorkerPoolsInternalServerError 

type GetWorkerPoolsInternalServerError struct {

	/* The ID of the corresponding request for the response
	 */
	XRequestID string

	Payload *models.Errors
}

GetWorkerPoolsInternalServerError describes a response with status code 500, 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() *models.Errors

func (*GetWorkerPoolsInternalServerError) IsClientError 

func (o *GetWorkerPoolsInternalServerError) IsClientError() bool

IsClientError returns true when this get worker pools internal server error response has a 4xx status code

func (*GetWorkerPoolsInternalServerError) IsCode 

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

IsCode returns true when this get worker pools internal server error response a status code equal to that given

func (*GetWorkerPoolsInternalServerError) IsRedirect 

func (o *GetWorkerPoolsInternalServerError) IsRedirect() bool

IsRedirect returns true when this get worker pools internal server error response has a 3xx status code

func (*GetWorkerPoolsInternalServerError) IsServerError 

func (o *GetWorkerPoolsInternalServerError) IsServerError() bool

IsServerError returns true when this get worker pools internal server error response has a 5xx status code

func (*GetWorkerPoolsInternalServerError) IsSuccess 

func (o *GetWorkerPoolsInternalServerError) IsSuccess() bool

IsSuccess returns true when this get worker pools internal server error response has a 2xx status code

func (*GetWorkerPoolsInternalServerError) String 

func (o *GetWorkerPoolsInternalServerError) String() string

type GetWorkerPoolsOK 

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

GetWorkerPoolsOK describes a response with status code 200, 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() []*models.WorkerPool

func (*GetWorkerPoolsOK) IsClientError 

func (o *GetWorkerPoolsOK) IsClientError() bool

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

func (*GetWorkerPoolsOK) IsCode 

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

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

func (*GetWorkerPoolsOK) IsRedirect 

func (o *GetWorkerPoolsOK) IsRedirect() bool

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

func (*GetWorkerPoolsOK) IsServerError 

func (o *GetWorkerPoolsOK) IsServerError() bool

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

func (*GetWorkerPoolsOK) IsSuccess 

func (o *GetWorkerPoolsOK) IsSuccess() bool

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

func (*GetWorkerPoolsOK) String 

func (o *GetWorkerPoolsOK) String() string

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 timeout for this client.

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

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

func NewGetWorkerPoolsParamsWithContext 

func NewGetWorkerPoolsParamsWithContext(ctx context.Context) *GetWorkerPoolsParams

NewGetWorkerPoolsParamsWithContext creates a new GetWorkerPoolsParams object with 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 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 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) SetDefaults 

func (o *GetWorkerPoolsParams) SetDefaults()

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

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

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) WithDefaults 

func (o *GetWorkerPoolsParams) WithDefaults() *GetWorkerPoolsParams

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

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

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 *models.Errors
}

GetWorkerPoolsUnauthorized describes a response with status code 401, 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() *models.Errors

func (*GetWorkerPoolsUnauthorized) IsClientError 

func (o *GetWorkerPoolsUnauthorized) IsClientError() bool

IsClientError returns true when this get worker pools unauthorized response has a 4xx status code

func (*GetWorkerPoolsUnauthorized) IsCode 

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

IsCode returns true when this get worker pools unauthorized response a status code equal to that given

func (*GetWorkerPoolsUnauthorized) IsRedirect 

func (o *GetWorkerPoolsUnauthorized) IsRedirect() bool

IsRedirect returns true when this get worker pools unauthorized response has a 3xx status code

func (*GetWorkerPoolsUnauthorized) IsServerError 

func (o *GetWorkerPoolsUnauthorized) IsServerError() bool

IsServerError returns true when this get worker pools unauthorized response has a 5xx status code

func (*GetWorkerPoolsUnauthorized) IsSuccess 

func (o *GetWorkerPoolsUnauthorized) IsSuccess() bool

IsSuccess returns true when this get worker pools unauthorized response has a 2xx status code

func (*GetWorkerPoolsUnauthorized) String 

func (o *GetWorkerPoolsUnauthorized) String() string

type GetWorkersForbidden 

type GetWorkersForbidden struct {

	/* The ID of the corresponding request for the response
	 */
	XRequestID string

	Payload *models.Errors
}

GetWorkersForbidden describes a response with status code 403, 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() *models.Errors

func (*GetWorkersForbidden) IsClientError 

func (o *GetWorkersForbidden) IsClientError() bool

IsClientError returns true when this get workers forbidden response has a 4xx status code

func (*GetWorkersForbidden) IsCode 

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

IsCode returns true when this get workers forbidden response a status code equal to that given

func (*GetWorkersForbidden) IsRedirect 

func (o *GetWorkersForbidden) IsRedirect() bool

IsRedirect returns true when this get workers forbidden response has a 3xx status code

func (*GetWorkersForbidden) IsServerError 

func (o *GetWorkersForbidden) IsServerError() bool

IsServerError returns true when this get workers forbidden response has a 5xx status code

func (*GetWorkersForbidden) IsSuccess 

func (o *GetWorkersForbidden) IsSuccess() bool

IsSuccess returns true when this get workers forbidden response has a 2xx status code

func (*GetWorkersForbidden) String 

func (o *GetWorkersForbidden) String() string

type GetWorkersInternalServerError 

type GetWorkersInternalServerError struct {

	/* The ID of the corresponding request for the response
	 */
	XRequestID string

	Payload *models.Errors
}

GetWorkersInternalServerError describes a response with status code 500, 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() *models.Errors

func (*GetWorkersInternalServerError) IsClientError 

func (o *GetWorkersInternalServerError) IsClientError() bool

IsClientError returns true when this get workers internal server error response has a 4xx status code

func (*GetWorkersInternalServerError) IsCode 

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

IsCode returns true when this get workers internal server error response a status code equal to that given

func (*GetWorkersInternalServerError) IsRedirect 

func (o *GetWorkersInternalServerError) IsRedirect() bool

IsRedirect returns true when this get workers internal server error response has a 3xx status code

func (*GetWorkersInternalServerError) IsServerError 

func (o *GetWorkersInternalServerError) IsServerError() bool

IsServerError returns true when this get workers internal server error response has a 5xx status code

func (*GetWorkersInternalServerError) IsSuccess 

func (o *GetWorkersInternalServerError) IsSuccess() bool

IsSuccess returns true when this get workers internal server error response has a 2xx status code

func (*GetWorkersInternalServerError) String 

func (o *GetWorkersInternalServerError) String() string

type GetWorkersNotFound 

type GetWorkersNotFound struct {

	/* The ID of the corresponding request for the response
	 */
	XRequestID string

	Payload *models.Errors
}

GetWorkersNotFound describes a response with status code 404, 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() *models.Errors

func (*GetWorkersNotFound) IsClientError 

func (o *GetWorkersNotFound) IsClientError() bool

IsClientError returns true when this get workers not found response has a 4xx status code

func (*GetWorkersNotFound) IsCode 

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

IsCode returns true when this get workers not found response a status code equal to that given

func (*GetWorkersNotFound) IsRedirect 

func (o *GetWorkersNotFound) IsRedirect() bool

IsRedirect returns true when this get workers not found response has a 3xx status code

func (*GetWorkersNotFound) IsServerError 

func (o *GetWorkersNotFound) IsServerError() bool

IsServerError returns true when this get workers not found response has a 5xx status code

func (*GetWorkersNotFound) IsSuccess 

func (o *GetWorkersNotFound) IsSuccess() bool

IsSuccess returns true when this get workers not found response has a 2xx status code

func (*GetWorkersNotFound) String 

func (o *GetWorkersNotFound) String() string

type GetWorkersOK 

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

GetWorkersOK describes a response with status code 200, 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() []*models.Worker

func (*GetWorkersOK) IsClientError 

func (o *GetWorkersOK) IsClientError() bool

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

func (*GetWorkersOK) IsCode 

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

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

func (*GetWorkersOK) IsRedirect 

func (o *GetWorkersOK) IsRedirect() bool

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

func (*GetWorkersOK) IsServerError 

func (o *GetWorkersOK) IsServerError() bool

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

func (*GetWorkersOK) IsSuccess 

func (o *GetWorkersOK) IsSuccess() bool

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

func (*GetWorkersOK) String 

func (o *GetWorkersOK) String() string

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 timeout for this client.

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

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

func NewGetWorkersParamsWithContext 

func NewGetWorkersParamsWithContext(ctx context.Context) *GetWorkersParams

NewGetWorkersParamsWithContext creates a new GetWorkersParams object with 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 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 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) SetDefaults 

func (o *GetWorkersParams) SetDefaults()

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

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

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) WithDefaults 

func (o *GetWorkersParams) WithDefaults() *GetWorkersParams

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

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

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 *models.Errors
}

GetWorkersUnauthorized describes a response with status code 401, 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() *models.Errors

func (*GetWorkersUnauthorized) IsClientError 

func (o *GetWorkersUnauthorized) IsClientError() bool

IsClientError returns true when this get workers unauthorized response has a 4xx status code

func (*GetWorkersUnauthorized) IsCode 

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

IsCode returns true when this get workers unauthorized response a status code equal to that given

func (*GetWorkersUnauthorized) IsRedirect 

func (o *GetWorkersUnauthorized) IsRedirect() bool

IsRedirect returns true when this get workers unauthorized response has a 3xx status code

func (*GetWorkersUnauthorized) IsServerError 

func (o *GetWorkersUnauthorized) IsServerError() bool

IsServerError returns true when this get workers unauthorized response has a 5xx status code

func (*GetWorkersUnauthorized) IsSuccess 

func (o *GetWorkersUnauthorized) IsSuccess() bool

IsSuccess returns true when this get workers unauthorized response has a 2xx status code

func (*GetWorkersUnauthorized) String 

func (o *GetWorkersUnauthorized) String() string

type ListJobQueuesForbidden 

type ListJobQueuesForbidden struct {

	/* The ID of the corresponding request for the response
	 */
	XRequestID string

	Payload *models.Errors
}

ListJobQueuesForbidden describes a response with status code 403, 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() *models.Errors

func (*ListJobQueuesForbidden) IsClientError 

func (o *ListJobQueuesForbidden) IsClientError() bool

IsClientError returns true when this list job queues forbidden response has a 4xx status code

func (*ListJobQueuesForbidden) IsCode 

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

IsCode returns true when this list job queues forbidden response a status code equal to that given

func (*ListJobQueuesForbidden) IsRedirect 

func (o *ListJobQueuesForbidden) IsRedirect() bool

IsRedirect returns true when this list job queues forbidden response has a 3xx status code

func (*ListJobQueuesForbidden) IsServerError 

func (o *ListJobQueuesForbidden) IsServerError() bool

IsServerError returns true when this list job queues forbidden response has a 5xx status code

func (*ListJobQueuesForbidden) IsSuccess 

func (o *ListJobQueuesForbidden) IsSuccess() bool

IsSuccess returns true when this list job queues forbidden response has a 2xx status code

func (*ListJobQueuesForbidden) String 

func (o *ListJobQueuesForbidden) String() string

type ListJobQueuesInternalServerError 

type ListJobQueuesInternalServerError struct {

	/* The ID of the corresponding request for the response
	 */
	XRequestID string

	Payload *models.Errors
}

ListJobQueuesInternalServerError describes a response with status code 500, 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() *models.Errors

func (*ListJobQueuesInternalServerError) IsClientError 

func (o *ListJobQueuesInternalServerError) IsClientError() bool

IsClientError returns true when this list job queues internal server error response has a 4xx status code

func (*ListJobQueuesInternalServerError) IsCode 

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

IsCode returns true when this list job queues internal server error response a status code equal to that given

func (*ListJobQueuesInternalServerError) IsRedirect 

func (o *ListJobQueuesInternalServerError) IsRedirect() bool

IsRedirect returns true when this list job queues internal server error response has a 3xx status code

func (*ListJobQueuesInternalServerError) IsServerError 

func (o *ListJobQueuesInternalServerError) IsServerError() bool

IsServerError returns true when this list job queues internal server error response has a 5xx status code

func (*ListJobQueuesInternalServerError) IsSuccess 

func (o *ListJobQueuesInternalServerError) IsSuccess() bool

IsSuccess returns true when this list job queues internal server error response has a 2xx status code

func (*ListJobQueuesInternalServerError) String 

func (o *ListJobQueuesInternalServerError) String() string

type ListJobQueuesNotFound 

type ListJobQueuesNotFound struct {

	/* The ID of the corresponding request for the response
	 */
	XRequestID string

	Payload *models.Errors
}

ListJobQueuesNotFound describes a response with status code 404, 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() *models.Errors

func (*ListJobQueuesNotFound) IsClientError 

func (o *ListJobQueuesNotFound) IsClientError() bool

IsClientError returns true when this list job queues not found response has a 4xx status code

func (*ListJobQueuesNotFound) IsCode 

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

IsCode returns true when this list job queues not found response a status code equal to that given

func (*ListJobQueuesNotFound) IsRedirect 

func (o *ListJobQueuesNotFound) IsRedirect() bool

IsRedirect returns true when this list job queues not found response has a 3xx status code

func (*ListJobQueuesNotFound) IsServerError 

func (o *ListJobQueuesNotFound) IsServerError() bool

IsServerError returns true when this list job queues not found response has a 5xx status code

func (*ListJobQueuesNotFound) IsSuccess 

func (o *ListJobQueuesNotFound) IsSuccess() bool

IsSuccess returns true when this list job queues not found response has a 2xx status code

func (*ListJobQueuesNotFound) String 

func (o *ListJobQueuesNotFound) String() string

type ListJobQueuesOK 

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

ListJobQueuesOK describes a response with status code 200, 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() []*models.JobQueue

func (*ListJobQueuesOK) IsClientError 

func (o *ListJobQueuesOK) IsClientError() bool

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

func (*ListJobQueuesOK) IsCode 

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

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

func (*ListJobQueuesOK) IsRedirect 

func (o *ListJobQueuesOK) IsRedirect() bool

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

func (*ListJobQueuesOK) IsServerError 

func (o *ListJobQueuesOK) IsServerError() bool

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

func (*ListJobQueuesOK) IsSuccess 

func (o *ListJobQueuesOK) IsSuccess() bool

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

func (*ListJobQueuesOK) String 

func (o *ListJobQueuesOK) String() string

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 timeout for this client.

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

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

func NewListJobQueuesParamsWithContext 

func NewListJobQueuesParamsWithContext(ctx context.Context) *ListJobQueuesParams

NewListJobQueuesParamsWithContext creates a new ListJobQueuesParams object with 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 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 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) SetDefaults 

func (o *ListJobQueuesParams) SetDefaults()

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

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

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) WithDefaults 

func (o *ListJobQueuesParams) WithDefaults() *ListJobQueuesParams

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

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

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 *models.Errors
}

ListJobQueuesUnauthorized describes a response with status code 401, 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() *models.Errors

func (*ListJobQueuesUnauthorized) IsClientError 

func (o *ListJobQueuesUnauthorized) IsClientError() bool

IsClientError returns true when this list job queues unauthorized response has a 4xx status code

func (*ListJobQueuesUnauthorized) IsCode 

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

IsCode returns true when this list job queues unauthorized response a status code equal to that given

func (*ListJobQueuesUnauthorized) IsRedirect 

func (o *ListJobQueuesUnauthorized) IsRedirect() bool

IsRedirect returns true when this list job queues unauthorized response has a 3xx status code

func (*ListJobQueuesUnauthorized) IsServerError 

func (o *ListJobQueuesUnauthorized) IsServerError() bool

IsServerError returns true when this list job queues unauthorized response has a 5xx status code

func (*ListJobQueuesUnauthorized) IsSuccess 

func (o *ListJobQueuesUnauthorized) IsSuccess() bool

IsSuccess returns true when this list job queues unauthorized response has a 2xx status code

func (*ListJobQueuesUnauthorized) String 

func (o *ListJobQueuesUnauthorized) String() string

type StopRunningJobForbidden 

type StopRunningJobForbidden struct {

	/* The ID of the corresponding request for the response
	 */
	XRequestID string

	Payload *models.Errors
}

StopRunningJobForbidden describes a response with status code 403, 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() *models.Errors

func (*StopRunningJobForbidden) IsClientError 

func (o *StopRunningJobForbidden) IsClientError() bool

IsClientError returns true when this stop running job forbidden response has a 4xx status code

func (*StopRunningJobForbidden) IsCode 

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

IsCode returns true when this stop running job forbidden response a status code equal to that given

func (*StopRunningJobForbidden) IsRedirect 

func (o *StopRunningJobForbidden) IsRedirect() bool

IsRedirect returns true when this stop running job forbidden response has a 3xx status code

func (*StopRunningJobForbidden) IsServerError 

func (o *StopRunningJobForbidden) IsServerError() bool

IsServerError returns true when this stop running job forbidden response has a 5xx status code

func (*StopRunningJobForbidden) IsSuccess 

func (o *StopRunningJobForbidden) IsSuccess() bool

IsSuccess returns true when this stop running job forbidden response has a 2xx status code

func (*StopRunningJobForbidden) String 

func (o *StopRunningJobForbidden) String() string

type StopRunningJobInternalServerError 

type StopRunningJobInternalServerError struct {

	/* The ID of the corresponding request for the response
	 */
	XRequestID string

	Payload *models.Errors
}

StopRunningJobInternalServerError describes a response with status code 500, 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() *models.Errors

func (*StopRunningJobInternalServerError) IsClientError 

func (o *StopRunningJobInternalServerError) IsClientError() bool

IsClientError returns true when this stop running job internal server error response has a 4xx status code

func (*StopRunningJobInternalServerError) IsCode 

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

IsCode returns true when this stop running job internal server error response a status code equal to that given

func (*StopRunningJobInternalServerError) IsRedirect 

func (o *StopRunningJobInternalServerError) IsRedirect() bool

IsRedirect returns true when this stop running job internal server error response has a 3xx status code

func (*StopRunningJobInternalServerError) IsServerError 

func (o *StopRunningJobInternalServerError) IsServerError() bool

IsServerError returns true when this stop running job internal server error response has a 5xx status code

func (*StopRunningJobInternalServerError) IsSuccess 

func (o *StopRunningJobInternalServerError) IsSuccess() bool

IsSuccess returns true when this stop running job internal server error response has a 2xx status code

func (*StopRunningJobInternalServerError) String 

func (o *StopRunningJobInternalServerError) String() string

type StopRunningJobNotFound 

type StopRunningJobNotFound struct {

	/* The ID of the corresponding request for the response
	 */
	XRequestID string

	Payload *models.Errors
}

StopRunningJobNotFound describes a response with status code 404, 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() *models.Errors

func (*StopRunningJobNotFound) IsClientError 

func (o *StopRunningJobNotFound) IsClientError() bool

IsClientError returns true when this stop running job not found response has a 4xx status code

func (*StopRunningJobNotFound) IsCode 

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

IsCode returns true when this stop running job not found response a status code equal to that given

func (*StopRunningJobNotFound) IsRedirect 

func (o *StopRunningJobNotFound) IsRedirect() bool

IsRedirect returns true when this stop running job not found response has a 3xx status code

func (*StopRunningJobNotFound) IsServerError 

func (o *StopRunningJobNotFound) IsServerError() bool

IsServerError returns true when this stop running job not found response has a 5xx status code

func (*StopRunningJobNotFound) IsSuccess 

func (o *StopRunningJobNotFound) IsSuccess() bool

IsSuccess returns true when this stop running job not found response has a 2xx status code

func (*StopRunningJobNotFound) String 

func (o *StopRunningJobNotFound) String() string

type StopRunningJobOK 

type StopRunningJobOK struct {
}

StopRunningJobOK describes a response with status code 200, 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

func (*StopRunningJobOK) IsClientError 

func (o *StopRunningJobOK) IsClientError() bool

IsClientError returns true when this stop running job o k response has a 4xx status code

func (*StopRunningJobOK) IsCode 

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

IsCode returns true when this stop running job o k response a status code equal to that given

func (*StopRunningJobOK) IsRedirect 

func (o *StopRunningJobOK) IsRedirect() bool

IsRedirect returns true when this stop running job o k response has a 3xx status code

func (*StopRunningJobOK) IsServerError 

func (o *StopRunningJobOK) IsServerError() bool

IsServerError returns true when this stop running job o k response has a 5xx status code

func (*StopRunningJobOK) IsSuccess 

func (o *StopRunningJobOK) IsSuccess() bool

IsSuccess returns true when this stop running job o k response has a 2xx status code

func (*StopRunningJobOK) String 

func (o *StopRunningJobOK) String() 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 timeout for this client.

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

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

func NewStopRunningJobParamsWithContext 

func NewStopRunningJobParamsWithContext(ctx context.Context) *StopRunningJobParams

NewStopRunningJobParamsWithContext creates a new StopRunningJobParams object with 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 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 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) SetDefaults 

func (o *StopRunningJobParams) SetDefaults()

SetDefaults hydrates default values in the stop running job params (not the query body).

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

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) WithDefaults 

func (o *StopRunningJobParams) WithDefaults() *StopRunningJobParams

WithDefaults hydrates default values in the stop running job params (not the query body).

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

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 *models.Errors
}

StopRunningJobUnauthorized describes a response with status code 401, 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() *models.Errors

func (*StopRunningJobUnauthorized) IsClientError 

func (o *StopRunningJobUnauthorized) IsClientError() bool

IsClientError returns true when this stop running job unauthorized response has a 4xx status code

func (*StopRunningJobUnauthorized) IsCode 

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

IsCode returns true when this stop running job unauthorized response a status code equal to that given

func (*StopRunningJobUnauthorized) IsRedirect 

func (o *StopRunningJobUnauthorized) IsRedirect() bool

IsRedirect returns true when this stop running job unauthorized response has a 3xx status code

func (*StopRunningJobUnauthorized) IsServerError 

func (o *StopRunningJobUnauthorized) IsServerError() bool

IsServerError returns true when this stop running job unauthorized response has a 5xx status code

func (*StopRunningJobUnauthorized) IsSuccess 

func (o *StopRunningJobUnauthorized) IsSuccess() bool

IsSuccess returns true when this stop running job unauthorized response has a 2xx status code

func (*StopRunningJobUnauthorized) String 

func (o *StopRunningJobUnauthorized) String() 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.