tasks

package
v0.0.0-...-83a686f Latest Latest
Warning

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

 Go to latest Published: Oct 14, 2020 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 ClaimTasksOK 

type ClaimTasksOK struct {
	Payload []*models.TaskTask
}

ClaimTasksOK handles this case with default header values.

OK

func NewClaimTasksOK 

func NewClaimTasksOK() *ClaimTasksOK

NewClaimTasksOK creates a ClaimTasksOK with default headers values

func (*ClaimTasksOK) Error 

func (o *ClaimTasksOK) Error() string

func (*ClaimTasksOK) GetPayload 

func (o *ClaimTasksOK) GetPayload() []*models.TaskTask

type ClaimTasksParams 

type ClaimTasksParams struct {

	/*XTASQUESWORKERID
	  Worker ID

	*/
	XTASQUESWORKERID string
	/*Claim
	  The request body

	*/
	Claim *models.TaskClaim

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

ClaimTasksParams contains all the parameters to send to the API endpoint for the claim tasks operation typically these are written to a http.Request

func NewClaimTasksParams 

func NewClaimTasksParams() *ClaimTasksParams

NewClaimTasksParams creates a new ClaimTasksParams object with the default values initialized.

func NewClaimTasksParamsWithContext 

func NewClaimTasksParamsWithContext(ctx context.Context) *ClaimTasksParams

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

func NewClaimTasksParamsWithHTTPClient 

func NewClaimTasksParamsWithHTTPClient(client *http.Client) *ClaimTasksParams

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

func NewClaimTasksParamsWithTimeout 

func NewClaimTasksParamsWithTimeout(timeout time.Duration) *ClaimTasksParams

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

func (*ClaimTasksParams) SetClaim 

func (o *ClaimTasksParams) SetClaim(claim *models.TaskClaim)

SetClaim adds the claim to the claim tasks params

func (*ClaimTasksParams) SetContext 

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

SetContext adds the context to the claim tasks params

func (*ClaimTasksParams) SetHTTPClient 

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

SetHTTPClient adds the HTTPClient to the claim tasks params

func (*ClaimTasksParams) SetTimeout 

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

SetTimeout adds the timeout to the claim tasks params

func (*ClaimTasksParams) SetXTASQUESWORKERID 

func (o *ClaimTasksParams) SetXTASQUESWORKERID(xTASQUESWORKERID string)

SetXTASQUESWORKERID adds the xTASQUESWORKERId to the claim tasks params

func (*ClaimTasksParams) WithClaim 

func (o *ClaimTasksParams) WithClaim(claim *models.TaskClaim) *ClaimTasksParams

WithClaim adds the claim to the claim tasks params

func (*ClaimTasksParams) WithContext 

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

WithContext adds the context to the claim tasks params

func (*ClaimTasksParams) WithHTTPClient 

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

WithHTTPClient adds the HTTPClient to the claim tasks params

func (*ClaimTasksParams) WithTimeout 

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

WithTimeout adds the timeout to the claim tasks params

func (*ClaimTasksParams) WithXTASQUESWORKERID 

func (o *ClaimTasksParams) WithXTASQUESWORKERID(xTASQUESWORKERID string) *ClaimTasksParams

WithXTASQUESWORKERID adds the xTASQUESWORKERID to the claim tasks params

func (*ClaimTasksParams) WriteToRequest 

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

WriteToRequest writes these params to a swagger request

type ClaimTasksReader 

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

ClaimTasksReader is a Reader for the ClaimTasks structure.

func (*ClaimTasksReader) ReadResponse 

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

ReadResponse reads a server response into the received o.

type Client 

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

Client for tasks API

func (*Client) ClaimTasks 

func (a *Client) ClaimTasks(params *ClaimTasksParams) (*ClaimTasksOK, error)

ClaimTasks claims a number of tasks

Claims a number of existing Tasks.

func (*Client) CreateTask 

func (a *Client) CreateTask(params *CreateTaskParams) (*CreateTaskCreated, error)

CreateTask adds a new task

Creates a new Task

func (*Client) GetExistingTask 

func (a *Client) GetExistingTask(params *GetExistingTaskParams) (*GetExistingTaskOK, error)

GetExistingTask gets a task

Retrieves a persisted Task

func (*Client) MarkClaimedTaskDone 

func (a *Client) MarkClaimedTaskDone(params *MarkClaimedTaskDoneParams) (*MarkClaimedTaskDoneOK, error)

MarkClaimedTaskDone marks task as done

Marks a claimed Task as done.

func (*Client) MarkClaimedTaskFailed 

func (a *Client) MarkClaimedTaskFailed(params *MarkClaimedTaskFailedParams) (*MarkClaimedTaskFailedOK, error)

MarkClaimedTaskFailed marks task as failed

Marks a claimed Task as failed.

func (*Client) ReportOnClaimedTask 

func (a *Client) ReportOnClaimedTask(params *ReportOnClaimedTaskParams) (*ReportOnClaimedTaskOK, error)

ReportOnClaimedTask reports on a task

Reports in on a claimed Task.

func (*Client) SetTransport 

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

SetTransport changes the transport on the client

func (*Client) UnclaimExistingTask 

func (a *Client) UnclaimExistingTask(params *UnclaimExistingTaskParams) (*UnclaimExistingTaskOK, error)

UnclaimExistingTask unclaims a task

Unclaims a claimed Task.

type ClientService 

type ClientService interface {
	ClaimTasks(params *ClaimTasksParams) (*ClaimTasksOK, error)

	CreateTask(params *CreateTaskParams) (*CreateTaskCreated, error)

	GetExistingTask(params *GetExistingTaskParams) (*GetExistingTaskOK, error)

	MarkClaimedTaskDone(params *MarkClaimedTaskDoneParams) (*MarkClaimedTaskDoneOK, error)

	MarkClaimedTaskFailed(params *MarkClaimedTaskFailedParams) (*MarkClaimedTaskFailedOK, error)

	ReportOnClaimedTask(params *ReportOnClaimedTaskParams) (*ReportOnClaimedTaskOK, error)

	UnclaimExistingTask(params *UnclaimExistingTaskParams) (*UnclaimExistingTaskOK, 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 tasks API client.

type CreateTaskBadRequest 

type CreateTaskBadRequest struct {
	Payload *models.CommonBody
}

CreateTaskBadRequest handles this case with default header values.

Invalid JSON

func NewCreateTaskBadRequest 

func NewCreateTaskBadRequest() *CreateTaskBadRequest

NewCreateTaskBadRequest creates a CreateTaskBadRequest with default headers values

func (*CreateTaskBadRequest) Error 

func (o *CreateTaskBadRequest) Error() string

func (*CreateTaskBadRequest) GetPayload 

func (o *CreateTaskBadRequest) GetPayload() *models.CommonBody

type CreateTaskCreated 

type CreateTaskCreated struct {
	Payload *models.TaskTask
}

CreateTaskCreated handles this case with default header values.

Created

func NewCreateTaskCreated 

func NewCreateTaskCreated() *CreateTaskCreated

NewCreateTaskCreated creates a CreateTaskCreated with default headers values

func (*CreateTaskCreated) Error 

func (o *CreateTaskCreated) Error() string

func (*CreateTaskCreated) GetPayload 

func (o *CreateTaskCreated) GetPayload() *models.TaskTask

type CreateTaskParams 

type CreateTaskParams struct {

	/*NewTask
	  The request body

	*/
	NewTask *models.TaskNewTask

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

CreateTaskParams contains all the parameters to send to the API endpoint for the create task operation typically these are written to a http.Request

func NewCreateTaskParams 

func NewCreateTaskParams() *CreateTaskParams

NewCreateTaskParams creates a new CreateTaskParams object with the default values initialized.

func NewCreateTaskParamsWithContext 

func NewCreateTaskParamsWithContext(ctx context.Context) *CreateTaskParams

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

func NewCreateTaskParamsWithHTTPClient 

func NewCreateTaskParamsWithHTTPClient(client *http.Client) *CreateTaskParams

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

func NewCreateTaskParamsWithTimeout 

func NewCreateTaskParamsWithTimeout(timeout time.Duration) *CreateTaskParams

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

func (*CreateTaskParams) SetContext 

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

SetContext adds the context to the create task params

func (*CreateTaskParams) SetHTTPClient 

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

SetHTTPClient adds the HTTPClient to the create task params

func (*CreateTaskParams) SetNewTask 

func (o *CreateTaskParams) SetNewTask(newTask *models.TaskNewTask)

SetNewTask adds the newTask to the create task params

func (*CreateTaskParams) SetTimeout 

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

SetTimeout adds the timeout to the create task params

func (*CreateTaskParams) WithContext 

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

WithContext adds the context to the create task params

func (*CreateTaskParams) WithHTTPClient 

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

WithHTTPClient adds the HTTPClient to the create task params

func (*CreateTaskParams) WithNewTask 

func (o *CreateTaskParams) WithNewTask(newTask *models.TaskNewTask) *CreateTaskParams

WithNewTask adds the newTask to the create task params

func (*CreateTaskParams) WithTimeout 

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

WithTimeout adds the timeout to the create task params

func (*CreateTaskParams) WriteToRequest 

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

WriteToRequest writes these params to a swagger request

type CreateTaskReader 

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

CreateTaskReader is a Reader for the CreateTask structure.

func (*CreateTaskReader) ReadResponse 

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

ReadResponse reads a server response into the received o.

type GetExistingTaskNotFound 

type GetExistingTaskNotFound struct {
	Payload *models.CommonBody
}

GetExistingTaskNotFound handles this case with default header values.

Task does not exist

func NewGetExistingTaskNotFound 

func NewGetExistingTaskNotFound() *GetExistingTaskNotFound

NewGetExistingTaskNotFound creates a GetExistingTaskNotFound with default headers values

func (*GetExistingTaskNotFound) Error 

func (o *GetExistingTaskNotFound) Error() string

func (*GetExistingTaskNotFound) GetPayload 

func (o *GetExistingTaskNotFound) GetPayload() *models.CommonBody

type GetExistingTaskOK 

type GetExistingTaskOK struct {
	Payload *models.TaskTask
}

GetExistingTaskOK handles this case with default header values.

OK

func NewGetExistingTaskOK 

func NewGetExistingTaskOK() *GetExistingTaskOK

NewGetExistingTaskOK creates a GetExistingTaskOK with default headers values

func (*GetExistingTaskOK) Error 

func (o *GetExistingTaskOK) Error() string

func (*GetExistingTaskOK) GetPayload 

func (o *GetExistingTaskOK) GetPayload() *models.TaskTask

type GetExistingTaskParams 

type GetExistingTaskParams struct {

	/*ID
	  The id of the Task

	*/
	ID string
	/*Queue
	  The Queue of the Task

	*/
	Queue string

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

GetExistingTaskParams contains all the parameters to send to the API endpoint for the get existing task operation typically these are written to a http.Request

func NewGetExistingTaskParams 

func NewGetExistingTaskParams() *GetExistingTaskParams

NewGetExistingTaskParams creates a new GetExistingTaskParams object with the default values initialized.

func NewGetExistingTaskParamsWithContext 

func NewGetExistingTaskParamsWithContext(ctx context.Context) *GetExistingTaskParams

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

func NewGetExistingTaskParamsWithHTTPClient 

func NewGetExistingTaskParamsWithHTTPClient(client *http.Client) *GetExistingTaskParams

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

func NewGetExistingTaskParamsWithTimeout 

func NewGetExistingTaskParamsWithTimeout(timeout time.Duration) *GetExistingTaskParams

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

func (*GetExistingTaskParams) SetContext 

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

SetContext adds the context to the get existing task params

func (*GetExistingTaskParams) SetHTTPClient 

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

SetHTTPClient adds the HTTPClient to the get existing task params

func (*GetExistingTaskParams) SetID 

func (o *GetExistingTaskParams) SetID(id string)

SetID adds the id to the get existing task params

func (*GetExistingTaskParams) SetQueue 

func (o *GetExistingTaskParams) SetQueue(queue string)

SetQueue adds the queue to the get existing task params

func (*GetExistingTaskParams) SetTimeout 

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

SetTimeout adds the timeout to the get existing task params

func (*GetExistingTaskParams) WithContext 

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

WithContext adds the context to the get existing task params

func (*GetExistingTaskParams) WithHTTPClient 

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

WithHTTPClient adds the HTTPClient to the get existing task params

func (*GetExistingTaskParams) WithID 

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

WithID adds the id to the get existing task params

func (*GetExistingTaskParams) WithQueue 

func (o *GetExistingTaskParams) WithQueue(queue string) *GetExistingTaskParams

WithQueue adds the queue to the get existing task params

func (*GetExistingTaskParams) WithTimeout 

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

WithTimeout adds the timeout to the get existing task params

func (*GetExistingTaskParams) WriteToRequest 

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

WriteToRequest writes these params to a swagger request

type GetExistingTaskReader 

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

GetExistingTaskReader is a Reader for the GetExistingTask structure.

func (*GetExistingTaskReader) ReadResponse 

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

ReadResponse reads a server response into the received o.

type MarkClaimedTaskDoneBadRequest 

type MarkClaimedTaskDoneBadRequest struct {
	Payload *models.CommonBody
}

MarkClaimedTaskDoneBadRequest handles this case with default header values.

The Task is not currently claimed

func NewMarkClaimedTaskDoneBadRequest 

func NewMarkClaimedTaskDoneBadRequest() *MarkClaimedTaskDoneBadRequest

NewMarkClaimedTaskDoneBadRequest creates a MarkClaimedTaskDoneBadRequest with default headers values

func (*MarkClaimedTaskDoneBadRequest) Error 

func (o *MarkClaimedTaskDoneBadRequest) Error() string

func (*MarkClaimedTaskDoneBadRequest) GetPayload 

func (o *MarkClaimedTaskDoneBadRequest) GetPayload() *models.CommonBody

type MarkClaimedTaskDoneForbidden 

type MarkClaimedTaskDoneForbidden struct {
	Payload *models.CommonBody
}

MarkClaimedTaskDoneForbidden handles this case with default header values.

Worker currently has not claimed the Task

func NewMarkClaimedTaskDoneForbidden 

func NewMarkClaimedTaskDoneForbidden() *MarkClaimedTaskDoneForbidden

NewMarkClaimedTaskDoneForbidden creates a MarkClaimedTaskDoneForbidden with default headers values

func (*MarkClaimedTaskDoneForbidden) Error 

func (o *MarkClaimedTaskDoneForbidden) Error() string

func (*MarkClaimedTaskDoneForbidden) GetPayload 

func (o *MarkClaimedTaskDoneForbidden) GetPayload() *models.CommonBody

type MarkClaimedTaskDoneNotFound 

type MarkClaimedTaskDoneNotFound struct {
	Payload *models.CommonBody
}

MarkClaimedTaskDoneNotFound handles this case with default header values.

Task does not exist

func NewMarkClaimedTaskDoneNotFound 

func NewMarkClaimedTaskDoneNotFound() *MarkClaimedTaskDoneNotFound

NewMarkClaimedTaskDoneNotFound creates a MarkClaimedTaskDoneNotFound with default headers values

func (*MarkClaimedTaskDoneNotFound) Error 

func (o *MarkClaimedTaskDoneNotFound) Error() string

func (*MarkClaimedTaskDoneNotFound) GetPayload 

func (o *MarkClaimedTaskDoneNotFound) GetPayload() *models.CommonBody

type MarkClaimedTaskDoneOK 

type MarkClaimedTaskDoneOK struct {
	Payload *models.TaskTask
}

MarkClaimedTaskDoneOK handles this case with default header values.

OK

func NewMarkClaimedTaskDoneOK 

func NewMarkClaimedTaskDoneOK() *MarkClaimedTaskDoneOK

NewMarkClaimedTaskDoneOK creates a MarkClaimedTaskDoneOK with default headers values

func (*MarkClaimedTaskDoneOK) Error 

func (o *MarkClaimedTaskDoneOK) Error() string

func (*MarkClaimedTaskDoneOK) GetPayload 

func (o *MarkClaimedTaskDoneOK) GetPayload() *models.TaskTask

type MarkClaimedTaskDoneParams 

type MarkClaimedTaskDoneParams struct {

	/*XTASQUESWORKERID
	  Worker ID

	*/
	XTASQUESWORKERID string
	/*ID
	  The id of the Task

	*/
	ID string
	/*Queue
	  The Queue of the Task

	*/
	Queue string
	/*Success
	  The request body

	*/
	Success *models.TaskSuccess

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

MarkClaimedTaskDoneParams contains all the parameters to send to the API endpoint for the mark claimed task done operation typically these are written to a http.Request

func NewMarkClaimedTaskDoneParams 

func NewMarkClaimedTaskDoneParams() *MarkClaimedTaskDoneParams

NewMarkClaimedTaskDoneParams creates a new MarkClaimedTaskDoneParams object with the default values initialized.

func NewMarkClaimedTaskDoneParamsWithContext 

func NewMarkClaimedTaskDoneParamsWithContext(ctx context.Context) *MarkClaimedTaskDoneParams

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

func NewMarkClaimedTaskDoneParamsWithHTTPClient 

func NewMarkClaimedTaskDoneParamsWithHTTPClient(client *http.Client) *MarkClaimedTaskDoneParams

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

func NewMarkClaimedTaskDoneParamsWithTimeout 

func NewMarkClaimedTaskDoneParamsWithTimeout(timeout time.Duration) *MarkClaimedTaskDoneParams

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

func (*MarkClaimedTaskDoneParams) SetContext 

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

SetContext adds the context to the mark claimed task done params

func (*MarkClaimedTaskDoneParams) SetHTTPClient 

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

SetHTTPClient adds the HTTPClient to the mark claimed task done params

func (*MarkClaimedTaskDoneParams) SetID 

func (o *MarkClaimedTaskDoneParams) SetID(id string)

SetID adds the id to the mark claimed task done params

func (*MarkClaimedTaskDoneParams) SetQueue 

func (o *MarkClaimedTaskDoneParams) SetQueue(queue string)

SetQueue adds the queue to the mark claimed task done params

func (*MarkClaimedTaskDoneParams) SetSuccess 

func (o *MarkClaimedTaskDoneParams) SetSuccess(success *models.TaskSuccess)

SetSuccess adds the success to the mark claimed task done params

func (*MarkClaimedTaskDoneParams) SetTimeout 

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

SetTimeout adds the timeout to the mark claimed task done params

func (*MarkClaimedTaskDoneParams) SetXTASQUESWORKERID 

func (o *MarkClaimedTaskDoneParams) SetXTASQUESWORKERID(xTASQUESWORKERID string)

SetXTASQUESWORKERID adds the xTASQUESWORKERId to the mark claimed task done params

func (*MarkClaimedTaskDoneParams) WithContext 

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

WithContext adds the context to the mark claimed task done params

func (*MarkClaimedTaskDoneParams) WithHTTPClient 

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

WithHTTPClient adds the HTTPClient to the mark claimed task done params

func (*MarkClaimedTaskDoneParams) WithID 

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

WithID adds the id to the mark claimed task done params

func (*MarkClaimedTaskDoneParams) WithQueue 

func (o *MarkClaimedTaskDoneParams) WithQueue(queue string) *MarkClaimedTaskDoneParams

WithQueue adds the queue to the mark claimed task done params

func (*MarkClaimedTaskDoneParams) WithSuccess 

func (o *MarkClaimedTaskDoneParams) WithSuccess(success *models.TaskSuccess) *MarkClaimedTaskDoneParams

WithSuccess adds the success to the mark claimed task done params

func (*MarkClaimedTaskDoneParams) WithTimeout 

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

WithTimeout adds the timeout to the mark claimed task done params

func (*MarkClaimedTaskDoneParams) WithXTASQUESWORKERID 

func (o *MarkClaimedTaskDoneParams) WithXTASQUESWORKERID(xTASQUESWORKERID string) *MarkClaimedTaskDoneParams

WithXTASQUESWORKERID adds the xTASQUESWORKERID to the mark claimed task done params

func (*MarkClaimedTaskDoneParams) WriteToRequest 

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

WriteToRequest writes these params to a swagger request

type MarkClaimedTaskDoneReader 

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

MarkClaimedTaskDoneReader is a Reader for the MarkClaimedTaskDone structure.

func (*MarkClaimedTaskDoneReader) ReadResponse 

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

ReadResponse reads a server response into the received o.

type MarkClaimedTaskFailedBadRequest 

type MarkClaimedTaskFailedBadRequest struct {
	Payload *models.CommonBody
}

MarkClaimedTaskFailedBadRequest handles this case with default header values.

The Task is not currently claimed

func NewMarkClaimedTaskFailedBadRequest 

func NewMarkClaimedTaskFailedBadRequest() *MarkClaimedTaskFailedBadRequest

NewMarkClaimedTaskFailedBadRequest creates a MarkClaimedTaskFailedBadRequest with default headers values

func (*MarkClaimedTaskFailedBadRequest) Error 

func (o *MarkClaimedTaskFailedBadRequest) Error() string

func (*MarkClaimedTaskFailedBadRequest) GetPayload 

func (o *MarkClaimedTaskFailedBadRequest) GetPayload() *models.CommonBody

type MarkClaimedTaskFailedForbidden 

type MarkClaimedTaskFailedForbidden struct {
	Payload *models.CommonBody
}

MarkClaimedTaskFailedForbidden handles this case with default header values.

Worker currently has not claimed the Task

func NewMarkClaimedTaskFailedForbidden 

func NewMarkClaimedTaskFailedForbidden() *MarkClaimedTaskFailedForbidden

NewMarkClaimedTaskFailedForbidden creates a MarkClaimedTaskFailedForbidden with default headers values

func (*MarkClaimedTaskFailedForbidden) Error 

func (o *MarkClaimedTaskFailedForbidden) Error() string

func (*MarkClaimedTaskFailedForbidden) GetPayload 

func (o *MarkClaimedTaskFailedForbidden) GetPayload() *models.CommonBody

type MarkClaimedTaskFailedNotFound 

type MarkClaimedTaskFailedNotFound struct {
	Payload *models.CommonBody
}

MarkClaimedTaskFailedNotFound handles this case with default header values.

Task does not exist

func NewMarkClaimedTaskFailedNotFound 

func NewMarkClaimedTaskFailedNotFound() *MarkClaimedTaskFailedNotFound

NewMarkClaimedTaskFailedNotFound creates a MarkClaimedTaskFailedNotFound with default headers values

func (*MarkClaimedTaskFailedNotFound) Error 

func (o *MarkClaimedTaskFailedNotFound) Error() string

func (*MarkClaimedTaskFailedNotFound) GetPayload 

func (o *MarkClaimedTaskFailedNotFound) GetPayload() *models.CommonBody

type MarkClaimedTaskFailedOK 

type MarkClaimedTaskFailedOK struct {
	Payload *models.TaskTask
}

MarkClaimedTaskFailedOK handles this case with default header values.

OK

func NewMarkClaimedTaskFailedOK 

func NewMarkClaimedTaskFailedOK() *MarkClaimedTaskFailedOK

NewMarkClaimedTaskFailedOK creates a MarkClaimedTaskFailedOK with default headers values

func (*MarkClaimedTaskFailedOK) Error 

func (o *MarkClaimedTaskFailedOK) Error() string

func (*MarkClaimedTaskFailedOK) GetPayload 

func (o *MarkClaimedTaskFailedOK) GetPayload() *models.TaskTask

type MarkClaimedTaskFailedParams 

type MarkClaimedTaskFailedParams struct {

	/*XTASQUESWORKERID
	  Worker ID

	*/
	XTASQUESWORKERID string
	/*Failure
	  The request body

	*/
	Failure *models.TaskFailure
	/*ID
	  The id of the Task

	*/
	ID string
	/*Queue
	  The Queue of the Task

	*/
	Queue string

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

MarkClaimedTaskFailedParams contains all the parameters to send to the API endpoint for the mark claimed task failed operation typically these are written to a http.Request

func NewMarkClaimedTaskFailedParams 

func NewMarkClaimedTaskFailedParams() *MarkClaimedTaskFailedParams

NewMarkClaimedTaskFailedParams creates a new MarkClaimedTaskFailedParams object with the default values initialized.

func NewMarkClaimedTaskFailedParamsWithContext 

func NewMarkClaimedTaskFailedParamsWithContext(ctx context.Context) *MarkClaimedTaskFailedParams

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

func NewMarkClaimedTaskFailedParamsWithHTTPClient 

func NewMarkClaimedTaskFailedParamsWithHTTPClient(client *http.Client) *MarkClaimedTaskFailedParams

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

func NewMarkClaimedTaskFailedParamsWithTimeout 

func NewMarkClaimedTaskFailedParamsWithTimeout(timeout time.Duration) *MarkClaimedTaskFailedParams

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

func (*MarkClaimedTaskFailedParams) SetContext 

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

SetContext adds the context to the mark claimed task failed params

func (*MarkClaimedTaskFailedParams) SetFailure 

func (o *MarkClaimedTaskFailedParams) SetFailure(failure *models.TaskFailure)

SetFailure adds the failure to the mark claimed task failed params

func (*MarkClaimedTaskFailedParams) SetHTTPClient 

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

SetHTTPClient adds the HTTPClient to the mark claimed task failed params

func (*MarkClaimedTaskFailedParams) SetID 

func (o *MarkClaimedTaskFailedParams) SetID(id string)

SetID adds the id to the mark claimed task failed params

func (*MarkClaimedTaskFailedParams) SetQueue 

func (o *MarkClaimedTaskFailedParams) SetQueue(queue string)

SetQueue adds the queue to the mark claimed task failed params

func (*MarkClaimedTaskFailedParams) SetTimeout 

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

SetTimeout adds the timeout to the mark claimed task failed params

func (*MarkClaimedTaskFailedParams) SetXTASQUESWORKERID 

func (o *MarkClaimedTaskFailedParams) SetXTASQUESWORKERID(xTASQUESWORKERID string)

SetXTASQUESWORKERID adds the xTASQUESWORKERId to the mark claimed task failed params

func (*MarkClaimedTaskFailedParams) WithContext 

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

WithContext adds the context to the mark claimed task failed params

func (*MarkClaimedTaskFailedParams) WithFailure 

func (o *MarkClaimedTaskFailedParams) WithFailure(failure *models.TaskFailure) *MarkClaimedTaskFailedParams

WithFailure adds the failure to the mark claimed task failed params

func (*MarkClaimedTaskFailedParams) WithHTTPClient 

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

WithHTTPClient adds the HTTPClient to the mark claimed task failed params

func (*MarkClaimedTaskFailedParams) WithID 

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

WithID adds the id to the mark claimed task failed params

func (*MarkClaimedTaskFailedParams) WithQueue 

func (o *MarkClaimedTaskFailedParams) WithQueue(queue string) *MarkClaimedTaskFailedParams

WithQueue adds the queue to the mark claimed task failed params

func (*MarkClaimedTaskFailedParams) WithTimeout 

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

WithTimeout adds the timeout to the mark claimed task failed params

func (*MarkClaimedTaskFailedParams) WithXTASQUESWORKERID 

func (o *MarkClaimedTaskFailedParams) WithXTASQUESWORKERID(xTASQUESWORKERID string) *MarkClaimedTaskFailedParams

WithXTASQUESWORKERID adds the xTASQUESWORKERID to the mark claimed task failed params

func (*MarkClaimedTaskFailedParams) WriteToRequest 

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

WriteToRequest writes these params to a swagger request

type MarkClaimedTaskFailedReader 

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

MarkClaimedTaskFailedReader is a Reader for the MarkClaimedTaskFailed structure.

func (*MarkClaimedTaskFailedReader) ReadResponse 

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

ReadResponse reads a server response into the received o.

type ReportOnClaimedTaskBadRequest 

type ReportOnClaimedTaskBadRequest struct {
	Payload *models.CommonBody
}

ReportOnClaimedTaskBadRequest handles this case with default header values.

The Task is not currently claimed

func NewReportOnClaimedTaskBadRequest 

func NewReportOnClaimedTaskBadRequest() *ReportOnClaimedTaskBadRequest

NewReportOnClaimedTaskBadRequest creates a ReportOnClaimedTaskBadRequest with default headers values

func (*ReportOnClaimedTaskBadRequest) Error 

func (o *ReportOnClaimedTaskBadRequest) Error() string

func (*ReportOnClaimedTaskBadRequest) GetPayload 

func (o *ReportOnClaimedTaskBadRequest) GetPayload() *models.CommonBody

type ReportOnClaimedTaskForbidden 

type ReportOnClaimedTaskForbidden struct {
	Payload *models.CommonBody
}

ReportOnClaimedTaskForbidden handles this case with default header values.

Worker currently has not claimed the Task

func NewReportOnClaimedTaskForbidden 

func NewReportOnClaimedTaskForbidden() *ReportOnClaimedTaskForbidden

NewReportOnClaimedTaskForbidden creates a ReportOnClaimedTaskForbidden with default headers values

func (*ReportOnClaimedTaskForbidden) Error 

func (o *ReportOnClaimedTaskForbidden) Error() string

func (*ReportOnClaimedTaskForbidden) GetPayload 

func (o *ReportOnClaimedTaskForbidden) GetPayload() *models.CommonBody

type ReportOnClaimedTaskNotFound 

type ReportOnClaimedTaskNotFound struct {
	Payload *models.CommonBody
}

ReportOnClaimedTaskNotFound handles this case with default header values.

Task does not exist

func NewReportOnClaimedTaskNotFound 

func NewReportOnClaimedTaskNotFound() *ReportOnClaimedTaskNotFound

NewReportOnClaimedTaskNotFound creates a ReportOnClaimedTaskNotFound with default headers values

func (*ReportOnClaimedTaskNotFound) Error 

func (o *ReportOnClaimedTaskNotFound) Error() string

func (*ReportOnClaimedTaskNotFound) GetPayload 

func (o *ReportOnClaimedTaskNotFound) GetPayload() *models.CommonBody

type ReportOnClaimedTaskOK 

type ReportOnClaimedTaskOK struct {
	Payload *models.TaskTask
}

ReportOnClaimedTaskOK handles this case with default header values.

OK

func NewReportOnClaimedTaskOK 

func NewReportOnClaimedTaskOK() *ReportOnClaimedTaskOK

NewReportOnClaimedTaskOK creates a ReportOnClaimedTaskOK with default headers values

func (*ReportOnClaimedTaskOK) Error 

func (o *ReportOnClaimedTaskOK) Error() string

func (*ReportOnClaimedTaskOK) GetPayload 

func (o *ReportOnClaimedTaskOK) GetPayload() *models.TaskTask

type ReportOnClaimedTaskParams 

type ReportOnClaimedTaskParams struct {

	/*XTASQUESWORKERID
	  Worker ID

	*/
	XTASQUESWORKERID string
	/*ID
	  The id of the Task

	*/
	ID string
	/*NewReport
	  The request body

	*/
	NewReport *models.TaskNewReport
	/*Queue
	  The Queue of the Task

	*/
	Queue string

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

ReportOnClaimedTaskParams contains all the parameters to send to the API endpoint for the report on claimed task operation typically these are written to a http.Request

func NewReportOnClaimedTaskParams 

func NewReportOnClaimedTaskParams() *ReportOnClaimedTaskParams

NewReportOnClaimedTaskParams creates a new ReportOnClaimedTaskParams object with the default values initialized.

func NewReportOnClaimedTaskParamsWithContext 

func NewReportOnClaimedTaskParamsWithContext(ctx context.Context) *ReportOnClaimedTaskParams

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

func NewReportOnClaimedTaskParamsWithHTTPClient 

func NewReportOnClaimedTaskParamsWithHTTPClient(client *http.Client) *ReportOnClaimedTaskParams

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

func NewReportOnClaimedTaskParamsWithTimeout 

func NewReportOnClaimedTaskParamsWithTimeout(timeout time.Duration) *ReportOnClaimedTaskParams

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

func (*ReportOnClaimedTaskParams) SetContext 

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

SetContext adds the context to the report on claimed task params

func (*ReportOnClaimedTaskParams) SetHTTPClient 

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

SetHTTPClient adds the HTTPClient to the report on claimed task params

func (*ReportOnClaimedTaskParams) SetID 

func (o *ReportOnClaimedTaskParams) SetID(id string)

SetID adds the id to the report on claimed task params

func (*ReportOnClaimedTaskParams) SetNewReport 

func (o *ReportOnClaimedTaskParams) SetNewReport(newReport *models.TaskNewReport)

SetNewReport adds the newReport to the report on claimed task params

func (*ReportOnClaimedTaskParams) SetQueue 

func (o *ReportOnClaimedTaskParams) SetQueue(queue string)

SetQueue adds the queue to the report on claimed task params

func (*ReportOnClaimedTaskParams) SetTimeout 

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

SetTimeout adds the timeout to the report on claimed task params

func (*ReportOnClaimedTaskParams) SetXTASQUESWORKERID 

func (o *ReportOnClaimedTaskParams) SetXTASQUESWORKERID(xTASQUESWORKERID string)

SetXTASQUESWORKERID adds the xTASQUESWORKERId to the report on claimed task params

func (*ReportOnClaimedTaskParams) WithContext 

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

WithContext adds the context to the report on claimed task params

func (*ReportOnClaimedTaskParams) WithHTTPClient 

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

WithHTTPClient adds the HTTPClient to the report on claimed task params

func (*ReportOnClaimedTaskParams) WithID 

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

WithID adds the id to the report on claimed task params

func (*ReportOnClaimedTaskParams) WithNewReport 

func (o *ReportOnClaimedTaskParams) WithNewReport(newReport *models.TaskNewReport) *ReportOnClaimedTaskParams

WithNewReport adds the newReport to the report on claimed task params

func (*ReportOnClaimedTaskParams) WithQueue 

func (o *ReportOnClaimedTaskParams) WithQueue(queue string) *ReportOnClaimedTaskParams

WithQueue adds the queue to the report on claimed task params

func (*ReportOnClaimedTaskParams) WithTimeout 

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

WithTimeout adds the timeout to the report on claimed task params

func (*ReportOnClaimedTaskParams) WithXTASQUESWORKERID 

func (o *ReportOnClaimedTaskParams) WithXTASQUESWORKERID(xTASQUESWORKERID string) *ReportOnClaimedTaskParams

WithXTASQUESWORKERID adds the xTASQUESWORKERID to the report on claimed task params

func (*ReportOnClaimedTaskParams) WriteToRequest 

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

WriteToRequest writes these params to a swagger request

type ReportOnClaimedTaskReader 

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

ReportOnClaimedTaskReader is a Reader for the ReportOnClaimedTask structure.

func (*ReportOnClaimedTaskReader) ReadResponse 

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

ReadResponse reads a server response into the received o.

type UnclaimExistingTaskBadRequest 

type UnclaimExistingTaskBadRequest struct {
	Payload *models.CommonBody
}

UnclaimExistingTaskBadRequest handles this case with default header values.

The Task is not currently claimed

func NewUnclaimExistingTaskBadRequest 

func NewUnclaimExistingTaskBadRequest() *UnclaimExistingTaskBadRequest

NewUnclaimExistingTaskBadRequest creates a UnclaimExistingTaskBadRequest with default headers values

func (*UnclaimExistingTaskBadRequest) Error 

func (o *UnclaimExistingTaskBadRequest) Error() string

func (*UnclaimExistingTaskBadRequest) GetPayload 

func (o *UnclaimExistingTaskBadRequest) GetPayload() *models.CommonBody

type UnclaimExistingTaskForbidden 

type UnclaimExistingTaskForbidden struct {
	Payload *models.CommonBody
}

UnclaimExistingTaskForbidden handles this case with default header values.

Worker currently has not claimed the Task

func NewUnclaimExistingTaskForbidden 

func NewUnclaimExistingTaskForbidden() *UnclaimExistingTaskForbidden

NewUnclaimExistingTaskForbidden creates a UnclaimExistingTaskForbidden with default headers values

func (*UnclaimExistingTaskForbidden) Error 

func (o *UnclaimExistingTaskForbidden) Error() string

func (*UnclaimExistingTaskForbidden) GetPayload 

func (o *UnclaimExistingTaskForbidden) GetPayload() *models.CommonBody

type UnclaimExistingTaskNotFound 

type UnclaimExistingTaskNotFound struct {
	Payload *models.CommonBody
}

UnclaimExistingTaskNotFound handles this case with default header values.

Task does not exist

func NewUnclaimExistingTaskNotFound 

func NewUnclaimExistingTaskNotFound() *UnclaimExistingTaskNotFound

NewUnclaimExistingTaskNotFound creates a UnclaimExistingTaskNotFound with default headers values

func (*UnclaimExistingTaskNotFound) Error 

func (o *UnclaimExistingTaskNotFound) Error() string

func (*UnclaimExistingTaskNotFound) GetPayload 

func (o *UnclaimExistingTaskNotFound) GetPayload() *models.CommonBody

type UnclaimExistingTaskOK 

type UnclaimExistingTaskOK struct {
	Payload *models.TaskTask
}

UnclaimExistingTaskOK handles this case with default header values.

OK

func NewUnclaimExistingTaskOK 

func NewUnclaimExistingTaskOK() *UnclaimExistingTaskOK

NewUnclaimExistingTaskOK creates a UnclaimExistingTaskOK with default headers values

func (*UnclaimExistingTaskOK) Error 

func (o *UnclaimExistingTaskOK) Error() string

func (*UnclaimExistingTaskOK) GetPayload 

func (o *UnclaimExistingTaskOK) GetPayload() *models.TaskTask

type UnclaimExistingTaskParams 

type UnclaimExistingTaskParams struct {

	/*XTASQUESWORKERID
	  Worker ID

	*/
	XTASQUESWORKERID string
	/*ID
	  The id of the Task

	*/
	ID string
	/*Queue
	  The Queue of the Task

	*/
	Queue string

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

UnclaimExistingTaskParams contains all the parameters to send to the API endpoint for the unclaim existing task operation typically these are written to a http.Request

func NewUnclaimExistingTaskParams 

func NewUnclaimExistingTaskParams() *UnclaimExistingTaskParams

NewUnclaimExistingTaskParams creates a new UnclaimExistingTaskParams object with the default values initialized.

func NewUnclaimExistingTaskParamsWithContext 

func NewUnclaimExistingTaskParamsWithContext(ctx context.Context) *UnclaimExistingTaskParams

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

func NewUnclaimExistingTaskParamsWithHTTPClient 

func NewUnclaimExistingTaskParamsWithHTTPClient(client *http.Client) *UnclaimExistingTaskParams

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

func NewUnclaimExistingTaskParamsWithTimeout 

func NewUnclaimExistingTaskParamsWithTimeout(timeout time.Duration) *UnclaimExistingTaskParams

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

func (*UnclaimExistingTaskParams) SetContext 

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

SetContext adds the context to the unclaim existing task params

func (*UnclaimExistingTaskParams) SetHTTPClient 

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

SetHTTPClient adds the HTTPClient to the unclaim existing task params

func (*UnclaimExistingTaskParams) SetID 

func (o *UnclaimExistingTaskParams) SetID(id string)

SetID adds the id to the unclaim existing task params

func (*UnclaimExistingTaskParams) SetQueue 

func (o *UnclaimExistingTaskParams) SetQueue(queue string)

SetQueue adds the queue to the unclaim existing task params

func (*UnclaimExistingTaskParams) SetTimeout 

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

SetTimeout adds the timeout to the unclaim existing task params

func (*UnclaimExistingTaskParams) SetXTASQUESWORKERID 

func (o *UnclaimExistingTaskParams) SetXTASQUESWORKERID(xTASQUESWORKERID string)

SetXTASQUESWORKERID adds the xTASQUESWORKERId to the unclaim existing task params

func (*UnclaimExistingTaskParams) WithContext 

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

WithContext adds the context to the unclaim existing task params

func (*UnclaimExistingTaskParams) WithHTTPClient 

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

WithHTTPClient adds the HTTPClient to the unclaim existing task params

func (*UnclaimExistingTaskParams) WithID 

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

WithID adds the id to the unclaim existing task params

func (*UnclaimExistingTaskParams) WithQueue 

func (o *UnclaimExistingTaskParams) WithQueue(queue string) *UnclaimExistingTaskParams

WithQueue adds the queue to the unclaim existing task params

func (*UnclaimExistingTaskParams) WithTimeout 

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

WithTimeout adds the timeout to the unclaim existing task params

func (*UnclaimExistingTaskParams) WithXTASQUESWORKERID 

func (o *UnclaimExistingTaskParams) WithXTASQUESWORKERID(xTASQUESWORKERID string) *UnclaimExistingTaskParams

WithXTASQUESWORKERID adds the xTASQUESWORKERID to the unclaim existing task params

func (*UnclaimExistingTaskParams) WriteToRequest 

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

WriteToRequest writes these params to a swagger request

type UnclaimExistingTaskReader 

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

UnclaimExistingTaskReader is a Reader for the UnclaimExistingTask structure.

func (*UnclaimExistingTaskReader) ReadResponse 

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

ReadResponse reads a server response into the received o.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.