task_manager

package
v0.4.1 Latest Latest
Warning

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

 Go to latest Published: May 9, 2019 License: Apache-2.0 Imports: 11 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Client 

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

Client for task manager API

func New 

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

New creates a new task manager API client.

func (*Client) DescribeTasks 

func (a *Client) DescribeTasks(params *DescribeTasksParams, authInfo runtime.ClientAuthInfoWriter) (*DescribeTasksOK, error)

DescribeTasks gets tasks can filter with these fields job id task id executor status owner default return all tasks

func (*Client) RetryTasks 

func (a *Client) RetryTasks(params *RetryTasksParams, authInfo runtime.ClientAuthInfoWriter) (*RetryTasksOK, error)

RetryTasks retries tasks

func (*Client) SetTransport 

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

SetTransport changes the transport on the client

type DescribeTasksOK 

type DescribeTasksOK struct {
	Payload *models.OpenpitrixDescribeTasksResponse
}

DescribeTasksOK handles this case with default header values.

A successful response.

func NewDescribeTasksOK 

func NewDescribeTasksOK() *DescribeTasksOK

NewDescribeTasksOK creates a DescribeTasksOK with default headers values

func (*DescribeTasksOK) Error 

func (o *DescribeTasksOK) Error() string

type DescribeTasksParams 

type DescribeTasksParams struct {

	/*DisplayColumns
	  select columns to display.

	*/
	DisplayColumns []string
	/*Executor
	  host name of server.

	*/
	Executor *string
	/*JobID
	  job ids.

	*/
	JobID []string
	/*Limit
	  data limit per page, default value 20, max value 200.

	*/
	Limit *int64
	/*Offset
	  data offset, default 0.

	*/
	Offset *int64
	/*Owner
	  owner.

	*/
	Owner []string
	/*Reverse
	  value = 0 sort ASC, value = 1 sort DESC.

	*/
	Reverse *bool
	/*SearchWord
	  query key, support these fields(job_id, task_id, executor, status, owner).

	*/
	SearchWord *string
	/*SortKey
	  sort key, order by sort_key, default create_time.

	*/
	SortKey *string
	/*Status
	  task status eg.[running|successful|failed|pending].

	*/
	Status []string
	/*Target
	  target eg.[runtime|pilot].

	*/
	Target *string
	/*TaskID
	  task ids.

	*/
	TaskID []string

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

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

func NewDescribeTasksParams 

func NewDescribeTasksParams() *DescribeTasksParams

NewDescribeTasksParams creates a new DescribeTasksParams object with the default values initialized.

func NewDescribeTasksParamsWithContext 

func NewDescribeTasksParamsWithContext(ctx context.Context) *DescribeTasksParams

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

func NewDescribeTasksParamsWithHTTPClient 

func NewDescribeTasksParamsWithHTTPClient(client *http.Client) *DescribeTasksParams

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

func NewDescribeTasksParamsWithTimeout 

func NewDescribeTasksParamsWithTimeout(timeout time.Duration) *DescribeTasksParams

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

func (*DescribeTasksParams) SetContext 

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

SetContext adds the context to the describe tasks params

func (*DescribeTasksParams) SetDisplayColumns added in v0.4.0 

func (o *DescribeTasksParams) SetDisplayColumns(displayColumns []string)

SetDisplayColumns adds the displayColumns to the describe tasks params

func (*DescribeTasksParams) SetExecutor 

func (o *DescribeTasksParams) SetExecutor(executor *string)

SetExecutor adds the executor to the describe tasks params

func (*DescribeTasksParams) SetHTTPClient 

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

SetHTTPClient adds the HTTPClient to the describe tasks params

func (*DescribeTasksParams) SetJobID 

func (o *DescribeTasksParams) SetJobID(jobID []string)

SetJobID adds the jobId to the describe tasks params

func (*DescribeTasksParams) SetLimit 

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

SetLimit adds the limit to the describe tasks params

func (*DescribeTasksParams) SetOffset 

func (o *DescribeTasksParams) SetOffset(offset *int64)

SetOffset adds the offset to the describe tasks params

func (*DescribeTasksParams) SetOwner added in v0.2.3 

func (o *DescribeTasksParams) SetOwner(owner []string)

SetOwner adds the owner to the describe tasks params

func (*DescribeTasksParams) SetReverse added in v0.4.0 

func (o *DescribeTasksParams) SetReverse(reverse *bool)

SetReverse adds the reverse to the describe tasks params

func (*DescribeTasksParams) SetSearchWord added in v0.1.5 

func (o *DescribeTasksParams) SetSearchWord(searchWord *string)

SetSearchWord adds the searchWord to the describe tasks params

func (*DescribeTasksParams) SetSortKey added in v0.4.0 

func (o *DescribeTasksParams) SetSortKey(sortKey *string)

SetSortKey adds the sortKey to the describe tasks params

func (*DescribeTasksParams) SetStatus 

func (o *DescribeTasksParams) SetStatus(status []string)

SetStatus adds the status to the describe tasks params

func (*DescribeTasksParams) SetTarget 

func (o *DescribeTasksParams) SetTarget(target *string)

SetTarget adds the target to the describe tasks params

func (*DescribeTasksParams) SetTaskID 

func (o *DescribeTasksParams) SetTaskID(taskID []string)

SetTaskID adds the taskId to the describe tasks params

func (*DescribeTasksParams) SetTimeout 

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

SetTimeout adds the timeout to the describe tasks params

func (*DescribeTasksParams) WithContext 

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

WithContext adds the context to the describe tasks params

func (*DescribeTasksParams) WithDisplayColumns added in v0.4.0 

func (o *DescribeTasksParams) WithDisplayColumns(displayColumns []string) *DescribeTasksParams

WithDisplayColumns adds the displayColumns to the describe tasks params

func (*DescribeTasksParams) WithExecutor 

func (o *DescribeTasksParams) WithExecutor(executor *string) *DescribeTasksParams

WithExecutor adds the executor to the describe tasks params

func (*DescribeTasksParams) WithHTTPClient 

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

WithHTTPClient adds the HTTPClient to the describe tasks params

func (*DescribeTasksParams) WithJobID 

func (o *DescribeTasksParams) WithJobID(jobID []string) *DescribeTasksParams

WithJobID adds the jobID to the describe tasks params

func (*DescribeTasksParams) WithLimit 

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

WithLimit adds the limit to the describe tasks params

func (*DescribeTasksParams) WithOffset 

func (o *DescribeTasksParams) WithOffset(offset *int64) *DescribeTasksParams

WithOffset adds the offset to the describe tasks params

func (*DescribeTasksParams) WithOwner added in v0.2.3 

func (o *DescribeTasksParams) WithOwner(owner []string) *DescribeTasksParams

WithOwner adds the owner to the describe tasks params

func (*DescribeTasksParams) WithReverse added in v0.4.0 

func (o *DescribeTasksParams) WithReverse(reverse *bool) *DescribeTasksParams

WithReverse adds the reverse to the describe tasks params

func (*DescribeTasksParams) WithSearchWord added in v0.1.5 

func (o *DescribeTasksParams) WithSearchWord(searchWord *string) *DescribeTasksParams

WithSearchWord adds the searchWord to the describe tasks params

func (*DescribeTasksParams) WithSortKey added in v0.4.0 

func (o *DescribeTasksParams) WithSortKey(sortKey *string) *DescribeTasksParams

WithSortKey adds the sortKey to the describe tasks params

func (*DescribeTasksParams) WithStatus 

func (o *DescribeTasksParams) WithStatus(status []string) *DescribeTasksParams

WithStatus adds the status to the describe tasks params

func (*DescribeTasksParams) WithTarget 

func (o *DescribeTasksParams) WithTarget(target *string) *DescribeTasksParams

WithTarget adds the target to the describe tasks params

func (*DescribeTasksParams) WithTaskID 

func (o *DescribeTasksParams) WithTaskID(taskID []string) *DescribeTasksParams

WithTaskID adds the taskID to the describe tasks params

func (*DescribeTasksParams) WithTimeout 

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

WithTimeout adds the timeout to the describe tasks params

func (*DescribeTasksParams) WriteToRequest 

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

WriteToRequest writes these params to a swagger request

type DescribeTasksReader 

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

DescribeTasksReader is a Reader for the DescribeTasks structure.

func (*DescribeTasksReader) ReadResponse 

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

ReadResponse reads a server response into the received o.

type RetryTasksOK 

type RetryTasksOK struct {
	Payload *models.OpenpitrixRetryTasksResponse
}

RetryTasksOK handles this case with default header values.

A successful response.

func NewRetryTasksOK 

func NewRetryTasksOK() *RetryTasksOK

NewRetryTasksOK creates a RetryTasksOK with default headers values

func (*RetryTasksOK) Error 

func (o *RetryTasksOK) Error() string

type RetryTasksParams 

type RetryTasksParams struct {

	/*Body*/
	Body *models.OpenpitrixRetryTasksRequest

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

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

func NewRetryTasksParams 

func NewRetryTasksParams() *RetryTasksParams

NewRetryTasksParams creates a new RetryTasksParams object with the default values initialized.

func NewRetryTasksParamsWithContext 

func NewRetryTasksParamsWithContext(ctx context.Context) *RetryTasksParams

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

func NewRetryTasksParamsWithHTTPClient 

func NewRetryTasksParamsWithHTTPClient(client *http.Client) *RetryTasksParams

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

func NewRetryTasksParamsWithTimeout 

func NewRetryTasksParamsWithTimeout(timeout time.Duration) *RetryTasksParams

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

func (*RetryTasksParams) SetBody 

func (o *RetryTasksParams) SetBody(body *models.OpenpitrixRetryTasksRequest)

SetBody adds the body to the retry tasks params

func (*RetryTasksParams) SetContext 

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

SetContext adds the context to the retry tasks params

func (*RetryTasksParams) SetHTTPClient 

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

SetHTTPClient adds the HTTPClient to the retry tasks params

func (*RetryTasksParams) SetTimeout 

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

SetTimeout adds the timeout to the retry tasks params

func (*RetryTasksParams) WithBody 

func (o *RetryTasksParams) WithBody(body *models.OpenpitrixRetryTasksRequest) *RetryTasksParams

WithBody adds the body to the retry tasks params

func (*RetryTasksParams) WithContext 

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

WithContext adds the context to the retry tasks params

func (*RetryTasksParams) WithHTTPClient 

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

WithHTTPClient adds the HTTPClient to the retry tasks params

func (*RetryTasksParams) WithTimeout 

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

WithTimeout adds the timeout to the retry tasks params

func (*RetryTasksParams) WriteToRequest 

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

WriteToRequest writes these params to a swagger request

type RetryTasksReader 

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

RetryTasksReader is a Reader for the RetryTasks structure.

func (*RetryTasksReader) ReadResponse 

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