job

package
v0.1.1 Latest Latest
Warning

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

 Go to latest Published: Jan 12, 2023 License: Apache-2.0 Imports: 12 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 job API

func (*Client) Delete 

func (a *Client) Delete(params *DeleteParams, opts ...ClientOption) (*DeleteOK, error)

Delete Delete job

func (*Client) Input 

func (a *Client) Input(params *InputParams, opts ...ClientOption) (*InputOK, error)

Input Expect and input

func (*Client) Kill 

func (a *Client) Kill(params *KillParams, opts ...ClientOption) (*KillOK, error)

Kill Kill job

func (*Client) List 

func (a *Client) List(params *ListParams, opts ...ClientOption) (*ListOK, error)

List List Jobs

func (*Client) Query 

func (a *Client) Query(params *QueryParams, opts ...ClientOption) (*QueryOK, error)

Query Query job

func (*Client) SetTransport 

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

SetTransport changes the transport on the client

func (*Client) Submit 

func (a *Client) Submit(params *SubmitParams, opts ...ClientOption) (*SubmitOK, error)

Submit Submit jobs

type ClientOption 

type ClientOption func(*runtime.ClientOperation)

ClientOption is the option for Client methods

type ClientService 

type ClientService interface {
	Delete(params *DeleteParams, opts ...ClientOption) (*DeleteOK, error)

	Input(params *InputParams, opts ...ClientOption) (*InputOK, error)

	Kill(params *KillParams, opts ...ClientOption) (*KillOK, error)

	List(params *ListParams, opts ...ClientOption) (*ListOK, error)

	Query(params *QueryParams, opts ...ClientOption) (*QueryOK, error)

	Submit(params *SubmitParams, opts ...ClientOption) (*SubmitOK, 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 job API client.

type DeleteBadRequest 

type DeleteBadRequest struct {
	Payload *DeleteBadRequestBody
}
DeleteBadRequest describes a response with status code 400, with default header values.

DeleteBadRequest delete bad request

func NewDeleteBadRequest 

func NewDeleteBadRequest() *DeleteBadRequest

NewDeleteBadRequest creates a DeleteBadRequest with default headers values

func (*DeleteBadRequest) Error 

func (o *DeleteBadRequest) Error() string

func (*DeleteBadRequest) GetPayload 

func (o *DeleteBadRequest) GetPayload() *DeleteBadRequestBody

type DeleteBadRequestBody 

type DeleteBadRequestBody struct {

	// message
	// Required: true
	Message *string `json:"message"`
}

DeleteBadRequestBody delete bad request body swagger:model DeleteBadRequestBody

func (*DeleteBadRequestBody) ContextValidate 

func (o *DeleteBadRequestBody) ContextValidate(ctx context.Context, formats strfmt.Registry) error

ContextValidate validates this delete bad request body based on context it is used

func (*DeleteBadRequestBody) MarshalBinary 

func (o *DeleteBadRequestBody) MarshalBinary() ([]byte, error)

MarshalBinary interface implementation

func (*DeleteBadRequestBody) UnmarshalBinary 

func (o *DeleteBadRequestBody) UnmarshalBinary(b []byte) error

UnmarshalBinary interface implementation

func (*DeleteBadRequestBody) Validate 

func (o *DeleteBadRequestBody) Validate(formats strfmt.Registry) error

Validate validates this delete bad request body

type DeleteForbidden 

type DeleteForbidden struct {
	Payload *DeleteForbiddenBody
}
DeleteForbidden describes a response with status code 403, with default header values.

DeleteForbidden delete forbidden

func NewDeleteForbidden 

func NewDeleteForbidden() *DeleteForbidden

NewDeleteForbidden creates a DeleteForbidden with default headers values

func (*DeleteForbidden) Error 

func (o *DeleteForbidden) Error() string

func (*DeleteForbidden) GetPayload 

func (o *DeleteForbidden) GetPayload() *DeleteForbiddenBody

type DeleteForbiddenBody 

type DeleteForbiddenBody struct {

	// message
	// Required: true
	Message *string `json:"message"`
}

DeleteForbiddenBody delete forbidden body swagger:model DeleteForbiddenBody

func (*DeleteForbiddenBody) ContextValidate 

func (o *DeleteForbiddenBody) ContextValidate(ctx context.Context, formats strfmt.Registry) error

ContextValidate validates this delete forbidden body based on context it is used

func (*DeleteForbiddenBody) MarshalBinary 

func (o *DeleteForbiddenBody) MarshalBinary() ([]byte, error)

MarshalBinary interface implementation

func (*DeleteForbiddenBody) UnmarshalBinary 

func (o *DeleteForbiddenBody) UnmarshalBinary(b []byte) error

UnmarshalBinary interface implementation

func (*DeleteForbiddenBody) Validate 

func (o *DeleteForbiddenBody) Validate(formats strfmt.Registry) error

Validate validates this delete forbidden body

type DeleteInternalServerError 

type DeleteInternalServerError struct {
	Payload interface{}
}
DeleteInternalServerError describes a response with status code 500, with default header values.

DeleteInternalServerError delete internal server error

func NewDeleteInternalServerError 

func NewDeleteInternalServerError() *DeleteInternalServerError

NewDeleteInternalServerError creates a DeleteInternalServerError with default headers values

func (*DeleteInternalServerError) Error 

func (o *DeleteInternalServerError) Error() string

func (*DeleteInternalServerError) GetPayload 

func (o *DeleteInternalServerError) GetPayload() interface{}

type DeleteNotFound 

type DeleteNotFound struct {
	Payload *DeleteNotFoundBody
}
DeleteNotFound describes a response with status code 404, with default header values.

DeleteNotFound delete not found

func NewDeleteNotFound 

func NewDeleteNotFound() *DeleteNotFound

NewDeleteNotFound creates a DeleteNotFound with default headers values

func (*DeleteNotFound) Error 

func (o *DeleteNotFound) Error() string

func (*DeleteNotFound) GetPayload 

func (o *DeleteNotFound) GetPayload() *DeleteNotFoundBody

type DeleteNotFoundBody 

type DeleteNotFoundBody struct {

	// error
	// Required: true
	Error *string `json:"error"`

	// status
	// Required: true
	Status *string `json:"status"`
}

DeleteNotFoundBody delete not found body swagger:model DeleteNotFoundBody

func (*DeleteNotFoundBody) ContextValidate 

func (o *DeleteNotFoundBody) ContextValidate(ctx context.Context, formats strfmt.Registry) error

ContextValidate validates this delete not found body based on context it is used

func (*DeleteNotFoundBody) MarshalBinary 

func (o *DeleteNotFoundBody) MarshalBinary() ([]byte, error)

MarshalBinary interface implementation

func (*DeleteNotFoundBody) UnmarshalBinary 

func (o *DeleteNotFoundBody) UnmarshalBinary(b []byte) error

UnmarshalBinary interface implementation

func (*DeleteNotFoundBody) Validate 

func (o *DeleteNotFoundBody) Validate(formats strfmt.Registry) error

Validate validates this delete not found body

type DeleteOK 

type DeleteOK struct {
	Payload string
}
DeleteOK describes a response with status code 200, with default header values.

Delete job succeeded

func NewDeleteOK 

func NewDeleteOK() *DeleteOK

NewDeleteOK creates a DeleteOK with default headers values

func (*DeleteOK) Error 

func (o *DeleteOK) Error() string

func (*DeleteOK) GetPayload 

func (o *DeleteOK) GetPayload() string

type DeleteParams 

type DeleteParams struct {

	/* Urn.

	   Job urn
	*/
	Urn string

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

DeleteParams contains all the parameters to send to the API endpoint 

for the delete operation.

Typically these are written to a http.Request.

func NewDeleteParams 

func NewDeleteParams() *DeleteParams

NewDeleteParams creates a new DeleteParams 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 NewDeleteParamsWithContext 

func NewDeleteParamsWithContext(ctx context.Context) *DeleteParams

NewDeleteParamsWithContext creates a new DeleteParams object with the ability to set a context for a request.

func NewDeleteParamsWithHTTPClient 

func NewDeleteParamsWithHTTPClient(client *http.Client) *DeleteParams

NewDeleteParamsWithHTTPClient creates a new DeleteParams object with the ability to set a custom HTTPClient for a request.

func NewDeleteParamsWithTimeout 

func NewDeleteParamsWithTimeout(timeout time.Duration) *DeleteParams

NewDeleteParamsWithTimeout creates a new DeleteParams object with the ability to set a timeout on a request.

func (*DeleteParams) SetContext 

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

SetContext adds the context to the delete params

func (*DeleteParams) SetDefaults 

func (o *DeleteParams) SetDefaults()

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

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

func (*DeleteParams) SetHTTPClient 

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

SetHTTPClient adds the HTTPClient to the delete params

func (*DeleteParams) SetTimeout 

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

SetTimeout adds the timeout to the delete params

func (*DeleteParams) SetUrn 

func (o *DeleteParams) SetUrn(urn string)

SetUrn adds the urn to the delete params

func (*DeleteParams) WithContext 

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

WithContext adds the context to the delete params

func (*DeleteParams) WithDefaults 

func (o *DeleteParams) WithDefaults() *DeleteParams

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

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

func (*DeleteParams) WithHTTPClient 

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

WithHTTPClient adds the HTTPClient to the delete params

func (*DeleteParams) WithTimeout 

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

WithTimeout adds the timeout to the delete params

func (*DeleteParams) WithUrn 

func (o *DeleteParams) WithUrn(urn string) *DeleteParams

WithUrn adds the urn to the delete params

func (*DeleteParams) WriteToRequest 

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

WriteToRequest writes these params to a swagger request

type DeleteReader 

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

DeleteReader is a Reader for the Delete structure.

func (*DeleteReader) ReadResponse 

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

ReadResponse reads a server response into the received o.

type DeleteUnauthorized 

type DeleteUnauthorized struct {
	Payload interface{}
}
DeleteUnauthorized describes a response with status code 401, with default header values.

DeleteUnauthorized delete unauthorized

func NewDeleteUnauthorized 

func NewDeleteUnauthorized() *DeleteUnauthorized

NewDeleteUnauthorized creates a DeleteUnauthorized with default headers values

func (*DeleteUnauthorized) Error 

func (o *DeleteUnauthorized) Error() string

func (*DeleteUnauthorized) GetPayload 

func (o *DeleteUnauthorized) GetPayload() interface{}

type InputBadRequest 

type InputBadRequest struct {
	Payload *InputBadRequestBody
}
InputBadRequest describes a response with status code 400, with default header values.

InputBadRequest input bad request

func NewInputBadRequest 

func NewInputBadRequest() *InputBadRequest

NewInputBadRequest creates a InputBadRequest with default headers values

func (*InputBadRequest) Error 

func (o *InputBadRequest) Error() string

func (*InputBadRequest) GetPayload 

func (o *InputBadRequest) GetPayload() *InputBadRequestBody

type InputBadRequestBody 

type InputBadRequestBody struct {

	// message
	// Required: true
	Message *string `json:"message"`
}

InputBadRequestBody input bad request body swagger:model InputBadRequestBody

func (*InputBadRequestBody) ContextValidate 

func (o *InputBadRequestBody) ContextValidate(ctx context.Context, formats strfmt.Registry) error

ContextValidate validates this input bad request body based on context it is used

func (*InputBadRequestBody) MarshalBinary 

func (o *InputBadRequestBody) MarshalBinary() ([]byte, error)

MarshalBinary interface implementation

func (*InputBadRequestBody) UnmarshalBinary 

func (o *InputBadRequestBody) UnmarshalBinary(b []byte) error

UnmarshalBinary interface implementation

func (*InputBadRequestBody) Validate 

func (o *InputBadRequestBody) Validate(formats strfmt.Registry) error

Validate validates this input bad request body

type InputForbidden 

type InputForbidden struct {
	Payload *InputForbiddenBody
}
InputForbidden describes a response with status code 403, with default header values.

InputForbidden input forbidden

func NewInputForbidden 

func NewInputForbidden() *InputForbidden

NewInputForbidden creates a InputForbidden with default headers values

func (*InputForbidden) Error 

func (o *InputForbidden) Error() string

func (*InputForbidden) GetPayload 

func (o *InputForbidden) GetPayload() *InputForbiddenBody

type InputForbiddenBody 

type InputForbiddenBody struct {

	// message
	// Required: true
	Message *string `json:"message"`
}

InputForbiddenBody input forbidden body swagger:model InputForbiddenBody

func (*InputForbiddenBody) ContextValidate 

func (o *InputForbiddenBody) ContextValidate(ctx context.Context, formats strfmt.Registry) error

ContextValidate validates this input forbidden body based on context it is used

func (*InputForbiddenBody) MarshalBinary 

func (o *InputForbiddenBody) MarshalBinary() ([]byte, error)

MarshalBinary interface implementation

func (*InputForbiddenBody) UnmarshalBinary 

func (o *InputForbiddenBody) UnmarshalBinary(b []byte) error

UnmarshalBinary interface implementation

func (*InputForbiddenBody) Validate 

func (o *InputForbiddenBody) Validate(formats strfmt.Registry) error

Validate validates this input forbidden body

type InputInternalServerError 

type InputInternalServerError struct {
	Payload interface{}
}
InputInternalServerError describes a response with status code 500, with default header values.

InputInternalServerError input internal server error

func NewInputInternalServerError 

func NewInputInternalServerError() *InputInternalServerError

NewInputInternalServerError creates a InputInternalServerError with default headers values

func (*InputInternalServerError) Error 

func (o *InputInternalServerError) Error() string

func (*InputInternalServerError) GetPayload 

func (o *InputInternalServerError) GetPayload() interface{}

type InputNotFound 

type InputNotFound struct {
	Payload *InputNotFoundBody
}
InputNotFound describes a response with status code 404, with default header values.

InputNotFound input not found

func NewInputNotFound 

func NewInputNotFound() *InputNotFound

NewInputNotFound creates a InputNotFound with default headers values

func (*InputNotFound) Error 

func (o *InputNotFound) Error() string

func (*InputNotFound) GetPayload 

func (o *InputNotFound) GetPayload() *InputNotFoundBody

type InputNotFoundBody 

type InputNotFoundBody struct {

	// error
	// Required: true
	Error *string `json:"error"`

	// status
	// Required: true
	Status *string `json:"status"`
}

InputNotFoundBody input not found body swagger:model InputNotFoundBody

func (*InputNotFoundBody) ContextValidate 

func (o *InputNotFoundBody) ContextValidate(ctx context.Context, formats strfmt.Registry) error

ContextValidate validates this input not found body based on context it is used

func (*InputNotFoundBody) MarshalBinary 

func (o *InputNotFoundBody) MarshalBinary() ([]byte, error)

MarshalBinary interface implementation

func (*InputNotFoundBody) UnmarshalBinary 

func (o *InputNotFoundBody) UnmarshalBinary(b []byte) error

UnmarshalBinary interface implementation

func (*InputNotFoundBody) Validate 

func (o *InputNotFoundBody) Validate(formats strfmt.Registry) error

Validate validates this input not found body

type InputOK 

type InputOK struct {
	Payload *models.Job
}
InputOK describes a response with status code 200, with default header values.

Input job succeeded

func NewInputOK 

func NewInputOK() *InputOK

NewInputOK creates a InputOK with default headers values

func (*InputOK) Error 

func (o *InputOK) Error() string

func (*InputOK) GetPayload 

func (o *InputOK) GetPayload() *models.Job

type InputParams 

type InputParams struct {

	/* Input.

	   Input data
	*/
	Input *models.JobInput

	/* Urn.

	   Job urn
	*/
	Urn string

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

InputParams contains all the parameters to send to the API endpoint 

for the input operation.

Typically these are written to a http.Request.

func NewInputParams 

func NewInputParams() *InputParams

NewInputParams creates a new InputParams 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 NewInputParamsWithContext 

func NewInputParamsWithContext(ctx context.Context) *InputParams

NewInputParamsWithContext creates a new InputParams object with the ability to set a context for a request.

func NewInputParamsWithHTTPClient 

func NewInputParamsWithHTTPClient(client *http.Client) *InputParams

NewInputParamsWithHTTPClient creates a new InputParams object with the ability to set a custom HTTPClient for a request.

func NewInputParamsWithTimeout 

func NewInputParamsWithTimeout(timeout time.Duration) *InputParams

NewInputParamsWithTimeout creates a new InputParams object with the ability to set a timeout on a request.

func (*InputParams) SetContext 

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

SetContext adds the context to the input params

func (*InputParams) SetDefaults 

func (o *InputParams) SetDefaults()

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

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

func (*InputParams) SetHTTPClient 

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

SetHTTPClient adds the HTTPClient to the input params

func (*InputParams) SetInput 

func (o *InputParams) SetInput(input *models.JobInput)

SetInput adds the input to the input params

func (*InputParams) SetTimeout 

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

SetTimeout adds the timeout to the input params

func (*InputParams) SetUrn 

func (o *InputParams) SetUrn(urn string)

SetUrn adds the urn to the input params

func (*InputParams) WithContext 

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

WithContext adds the context to the input params

func (*InputParams) WithDefaults 

func (o *InputParams) WithDefaults() *InputParams

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

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

func (*InputParams) WithHTTPClient 

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

WithHTTPClient adds the HTTPClient to the input params

func (*InputParams) WithInput 

func (o *InputParams) WithInput(input *models.JobInput) *InputParams

WithInput adds the input to the input params

func (*InputParams) WithTimeout 

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

WithTimeout adds the timeout to the input params

func (*InputParams) WithUrn 

func (o *InputParams) WithUrn(urn string) *InputParams

WithUrn adds the urn to the input params

func (*InputParams) WriteToRequest 

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

WriteToRequest writes these params to a swagger request

type InputReader 

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

InputReader is a Reader for the Input structure.

func (*InputReader) ReadResponse 

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

ReadResponse reads a server response into the received o.

type InputUnauthorized 

type InputUnauthorized struct {
	Payload interface{}
}
InputUnauthorized describes a response with status code 401, with default header values.

InputUnauthorized input unauthorized

func NewInputUnauthorized 

func NewInputUnauthorized() *InputUnauthorized

NewInputUnauthorized creates a InputUnauthorized with default headers values

func (*InputUnauthorized) Error 

func (o *InputUnauthorized) Error() string

func (*InputUnauthorized) GetPayload 

func (o *InputUnauthorized) GetPayload() interface{}

type KillBadRequest 

type KillBadRequest struct {
	Payload *KillBadRequestBody
}
KillBadRequest describes a response with status code 400, with default header values.

KillBadRequest kill bad request

func NewKillBadRequest 

func NewKillBadRequest() *KillBadRequest

NewKillBadRequest creates a KillBadRequest with default headers values

func (*KillBadRequest) Error 

func (o *KillBadRequest) Error() string

func (*KillBadRequest) GetPayload 

func (o *KillBadRequest) GetPayload() *KillBadRequestBody

type KillBadRequestBody 

type KillBadRequestBody struct {

	// message
	// Required: true
	Message *string `json:"message"`
}

KillBadRequestBody kill bad request body swagger:model KillBadRequestBody

func (*KillBadRequestBody) ContextValidate 

func (o *KillBadRequestBody) ContextValidate(ctx context.Context, formats strfmt.Registry) error

ContextValidate validates this kill bad request body based on context it is used

func (*KillBadRequestBody) MarshalBinary 

func (o *KillBadRequestBody) MarshalBinary() ([]byte, error)

MarshalBinary interface implementation

func (*KillBadRequestBody) UnmarshalBinary 

func (o *KillBadRequestBody) UnmarshalBinary(b []byte) error

UnmarshalBinary interface implementation

func (*KillBadRequestBody) Validate 

func (o *KillBadRequestBody) Validate(formats strfmt.Registry) error

Validate validates this kill bad request body

type KillForbidden 

type KillForbidden struct {
	Payload *KillForbiddenBody
}
KillForbidden describes a response with status code 403, with default header values.

KillForbidden kill forbidden

func NewKillForbidden 

func NewKillForbidden() *KillForbidden

NewKillForbidden creates a KillForbidden with default headers values

func (*KillForbidden) Error 

func (o *KillForbidden) Error() string

func (*KillForbidden) GetPayload 

func (o *KillForbidden) GetPayload() *KillForbiddenBody

type KillForbiddenBody 

type KillForbiddenBody struct {

	// message
	// Required: true
	Message *string `json:"message"`
}

KillForbiddenBody kill forbidden body swagger:model KillForbiddenBody

func (*KillForbiddenBody) ContextValidate 

func (o *KillForbiddenBody) ContextValidate(ctx context.Context, formats strfmt.Registry) error

ContextValidate validates this kill forbidden body based on context it is used

func (*KillForbiddenBody) MarshalBinary 

func (o *KillForbiddenBody) MarshalBinary() ([]byte, error)

MarshalBinary interface implementation

func (*KillForbiddenBody) UnmarshalBinary 

func (o *KillForbiddenBody) UnmarshalBinary(b []byte) error

UnmarshalBinary interface implementation

func (*KillForbiddenBody) Validate 

func (o *KillForbiddenBody) Validate(formats strfmt.Registry) error

Validate validates this kill forbidden body

type KillInternalServerError 

type KillInternalServerError struct {
	Payload interface{}
}
KillInternalServerError describes a response with status code 500, with default header values.

KillInternalServerError kill internal server error

func NewKillInternalServerError 

func NewKillInternalServerError() *KillInternalServerError

NewKillInternalServerError creates a KillInternalServerError with default headers values

func (*KillInternalServerError) Error 

func (o *KillInternalServerError) Error() string

func (*KillInternalServerError) GetPayload 

func (o *KillInternalServerError) GetPayload() interface{}

type KillNotFound 

type KillNotFound struct {
	Payload *KillNotFoundBody
}
KillNotFound describes a response with status code 404, with default header values.

KillNotFound kill not found

func NewKillNotFound 

func NewKillNotFound() *KillNotFound

NewKillNotFound creates a KillNotFound with default headers values

func (*KillNotFound) Error 

func (o *KillNotFound) Error() string

func (*KillNotFound) GetPayload 

func (o *KillNotFound) GetPayload() *KillNotFoundBody

type KillNotFoundBody 

type KillNotFoundBody struct {

	// error
	// Required: true
	Error *string `json:"error"`

	// status
	// Required: true
	Status *string `json:"status"`
}

KillNotFoundBody kill not found body swagger:model KillNotFoundBody

func (*KillNotFoundBody) ContextValidate 

func (o *KillNotFoundBody) ContextValidate(ctx context.Context, formats strfmt.Registry) error

ContextValidate validates this kill not found body based on context it is used

func (*KillNotFoundBody) MarshalBinary 

func (o *KillNotFoundBody) MarshalBinary() ([]byte, error)

MarshalBinary interface implementation

func (*KillNotFoundBody) UnmarshalBinary 

func (o *KillNotFoundBody) UnmarshalBinary(b []byte) error

UnmarshalBinary interface implementation

func (*KillNotFoundBody) Validate 

func (o *KillNotFoundBody) Validate(formats strfmt.Registry) error

Validate validates this kill not found body

type KillOK 

type KillOK struct {
	Payload *models.Job
}
KillOK describes a response with status code 200, with default header values.

Kill job succeeded

func NewKillOK 

func NewKillOK() *KillOK

NewKillOK creates a KillOK with default headers values

func (*KillOK) Error 

func (o *KillOK) Error() string

func (*KillOK) GetPayload 

func (o *KillOK) GetPayload() *models.Job

type KillParams 

type KillParams struct {

	/* Force.

	   Force kill
	*/
	Force *bool

	/* Urn.

	   Job urn
	*/
	Urn string

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

KillParams contains all the parameters to send to the API endpoint 

for the kill operation.

Typically these are written to a http.Request.

func NewKillParams 

func NewKillParams() *KillParams

NewKillParams creates a new KillParams 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 NewKillParamsWithContext 

func NewKillParamsWithContext(ctx context.Context) *KillParams

NewKillParamsWithContext creates a new KillParams object with the ability to set a context for a request.

func NewKillParamsWithHTTPClient 

func NewKillParamsWithHTTPClient(client *http.Client) *KillParams

NewKillParamsWithHTTPClient creates a new KillParams object with the ability to set a custom HTTPClient for a request.

func NewKillParamsWithTimeout 

func NewKillParamsWithTimeout(timeout time.Duration) *KillParams

NewKillParamsWithTimeout creates a new KillParams object with the ability to set a timeout on a request.

func (*KillParams) SetContext 

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

SetContext adds the context to the kill params

func (*KillParams) SetDefaults 

func (o *KillParams) SetDefaults()

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

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

func (*KillParams) SetForce 

func (o *KillParams) SetForce(force *bool)

SetForce adds the force to the kill params

func (*KillParams) SetHTTPClient 

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

SetHTTPClient adds the HTTPClient to the kill params

func (*KillParams) SetTimeout 

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

SetTimeout adds the timeout to the kill params

func (*KillParams) SetUrn 

func (o *KillParams) SetUrn(urn string)

SetUrn adds the urn to the kill params

func (*KillParams) WithContext 

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

WithContext adds the context to the kill params

func (*KillParams) WithDefaults 

func (o *KillParams) WithDefaults() *KillParams

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

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

func (*KillParams) WithForce 

func (o *KillParams) WithForce(force *bool) *KillParams

WithForce adds the force to the kill params

func (*KillParams) WithHTTPClient 

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

WithHTTPClient adds the HTTPClient to the kill params

func (*KillParams) WithTimeout 

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

WithTimeout adds the timeout to the kill params

func (*KillParams) WithUrn 

func (o *KillParams) WithUrn(urn string) *KillParams

WithUrn adds the urn to the kill params

func (*KillParams) WriteToRequest 

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

WriteToRequest writes these params to a swagger request

type KillReader 

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

KillReader is a Reader for the Kill structure.

func (*KillReader) ReadResponse 

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

ReadResponse reads a server response into the received o.

type KillUnauthorized 

type KillUnauthorized struct {
	Payload interface{}
}
KillUnauthorized describes a response with status code 401, with default header values.

KillUnauthorized kill unauthorized

func NewKillUnauthorized 

func NewKillUnauthorized() *KillUnauthorized

NewKillUnauthorized creates a KillUnauthorized with default headers values

func (*KillUnauthorized) Error 

func (o *KillUnauthorized) Error() string

func (*KillUnauthorized) GetPayload 

func (o *KillUnauthorized) GetPayload() interface{}

type ListBadRequest 

type ListBadRequest struct {
	Payload *ListBadRequestBody
}
ListBadRequest describes a response with status code 400, with default header values.

ListBadRequest list bad request

func NewListBadRequest 

func NewListBadRequest() *ListBadRequest

NewListBadRequest creates a ListBadRequest with default headers values

func (*ListBadRequest) Error 

func (o *ListBadRequest) Error() string

func (*ListBadRequest) GetPayload 

func (o *ListBadRequest) GetPayload() *ListBadRequestBody

type ListBadRequestBody 

type ListBadRequestBody struct {

	// message
	// Required: true
	Message *string `json:"message"`
}

ListBadRequestBody list bad request body swagger:model ListBadRequestBody

func (*ListBadRequestBody) ContextValidate 

func (o *ListBadRequestBody) ContextValidate(ctx context.Context, formats strfmt.Registry) error

ContextValidate validates this list bad request body based on context it is used

func (*ListBadRequestBody) MarshalBinary 

func (o *ListBadRequestBody) MarshalBinary() ([]byte, error)

MarshalBinary interface implementation

func (*ListBadRequestBody) UnmarshalBinary 

func (o *ListBadRequestBody) UnmarshalBinary(b []byte) error

UnmarshalBinary interface implementation

func (*ListBadRequestBody) Validate 

func (o *ListBadRequestBody) Validate(formats strfmt.Registry) error

Validate validates this list bad request body

type ListForbidden 

type ListForbidden struct {
	Payload *ListForbiddenBody
}
ListForbidden describes a response with status code 403, with default header values.

ListForbidden list forbidden

func NewListForbidden 

func NewListForbidden() *ListForbidden

NewListForbidden creates a ListForbidden with default headers values

func (*ListForbidden) Error 

func (o *ListForbidden) Error() string

func (*ListForbidden) GetPayload 

func (o *ListForbidden) GetPayload() *ListForbiddenBody

type ListForbiddenBody 

type ListForbiddenBody struct {

	// message
	// Required: true
	Message *string `json:"message"`
}

ListForbiddenBody list forbidden body swagger:model ListForbiddenBody

func (*ListForbiddenBody) ContextValidate 

func (o *ListForbiddenBody) ContextValidate(ctx context.Context, formats strfmt.Registry) error

ContextValidate validates this list forbidden body based on context it is used

func (*ListForbiddenBody) MarshalBinary 

func (o *ListForbiddenBody) MarshalBinary() ([]byte, error)

MarshalBinary interface implementation

func (*ListForbiddenBody) UnmarshalBinary 

func (o *ListForbiddenBody) UnmarshalBinary(b []byte) error

UnmarshalBinary interface implementation

func (*ListForbiddenBody) Validate 

func (o *ListForbiddenBody) Validate(formats strfmt.Registry) error

Validate validates this list forbidden body

type ListInternalServerError 

type ListInternalServerError struct {
	Payload interface{}
}
ListInternalServerError describes a response with status code 500, with default header values.

ListInternalServerError list internal server error

func NewListInternalServerError 

func NewListInternalServerError() *ListInternalServerError

NewListInternalServerError creates a ListInternalServerError with default headers values

func (*ListInternalServerError) Error 

func (o *ListInternalServerError) Error() string

func (*ListInternalServerError) GetPayload 

func (o *ListInternalServerError) GetPayload() interface{}

type ListNotFound 

type ListNotFound struct {
	Payload *ListNotFoundBody
}
ListNotFound describes a response with status code 404, with default header values.

ListNotFound list not found

func NewListNotFound 

func NewListNotFound() *ListNotFound

NewListNotFound creates a ListNotFound with default headers values

func (*ListNotFound) Error 

func (o *ListNotFound) Error() string

func (*ListNotFound) GetPayload 

func (o *ListNotFound) GetPayload() *ListNotFoundBody

type ListNotFoundBody 

type ListNotFoundBody struct {

	// error
	// Required: true
	Error *string `json:"error"`

	// status
	// Required: true
	Status *string `json:"status"`
}

ListNotFoundBody list not found body swagger:model ListNotFoundBody

func (*ListNotFoundBody) ContextValidate 

func (o *ListNotFoundBody) ContextValidate(ctx context.Context, formats strfmt.Registry) error

ContextValidate validates this list not found body based on context it is used

func (*ListNotFoundBody) MarshalBinary 

func (o *ListNotFoundBody) MarshalBinary() ([]byte, error)

MarshalBinary interface implementation

func (*ListNotFoundBody) UnmarshalBinary 

func (o *ListNotFoundBody) UnmarshalBinary(b []byte) error

UnmarshalBinary interface implementation

func (*ListNotFoundBody) Validate 

func (o *ListNotFoundBody) Validate(formats strfmt.Registry) error

Validate validates this list not found body

type ListOK 

type ListOK struct {
	Payload []*models.Job
}
ListOK describes a response with status code 200, with default header values.

List jobs succeeded

func NewListOK 

func NewListOK() *ListOK

NewListOK creates a ListOK with default headers values

func (*ListOK) Error 

func (o *ListOK) Error() string

func (*ListOK) GetPayload 

func (o *ListOK) GetPayload() []*models.Job

type ListParams 

type ListParams struct {

	/* Operation.

	   Operation
	*/
	Operation *string

	/* Plugin.

	   Plugin
	*/
	Plugin *string

	/* StartTimeBegin.

	   Start time range begin

	   Format: int64
	*/
	StartTimeBegin *int64

	/* StartTimeEnd.

	   Start time range end

	   Format: int64
	*/
	StartTimeEnd *int64

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

ListParams contains all the parameters to send to the API endpoint 

for the list operation.

Typically these are written to a http.Request.

func NewListParams 

func NewListParams() *ListParams

NewListParams creates a new ListParams 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 NewListParamsWithContext 

func NewListParamsWithContext(ctx context.Context) *ListParams

NewListParamsWithContext creates a new ListParams object with the ability to set a context for a request.

func NewListParamsWithHTTPClient 

func NewListParamsWithHTTPClient(client *http.Client) *ListParams

NewListParamsWithHTTPClient creates a new ListParams object with the ability to set a custom HTTPClient for a request.

func NewListParamsWithTimeout 

func NewListParamsWithTimeout(timeout time.Duration) *ListParams

NewListParamsWithTimeout creates a new ListParams object with the ability to set a timeout on a request.

func (*ListParams) SetContext 

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

SetContext adds the context to the list params

func (*ListParams) SetDefaults 

func (o *ListParams) SetDefaults()

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

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

func (*ListParams) SetHTTPClient 

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

SetHTTPClient adds the HTTPClient to the list params

func (*ListParams) SetOperation 

func (o *ListParams) SetOperation(operation *string)

SetOperation adds the operation to the list params

func (*ListParams) SetPlugin 

func (o *ListParams) SetPlugin(plugin *string)

SetPlugin adds the plugin to the list params

func (*ListParams) SetStartTimeBegin 

func (o *ListParams) SetStartTimeBegin(startTimeBegin *int64)

SetStartTimeBegin adds the startTimeBegin to the list params

func (*ListParams) SetStartTimeEnd 

func (o *ListParams) SetStartTimeEnd(startTimeEnd *int64)

SetStartTimeEnd adds the startTimeEnd to the list params

func (*ListParams) SetTimeout 

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

SetTimeout adds the timeout to the list params

func (*ListParams) WithContext 

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

WithContext adds the context to the list params

func (*ListParams) WithDefaults 

func (o *ListParams) WithDefaults() *ListParams

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

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

func (*ListParams) WithHTTPClient 

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

WithHTTPClient adds the HTTPClient to the list params

func (*ListParams) WithOperation 

func (o *ListParams) WithOperation(operation *string) *ListParams

WithOperation adds the operation to the list params

func (*ListParams) WithPlugin 

func (o *ListParams) WithPlugin(plugin *string) *ListParams

WithPlugin adds the plugin to the list params

func (*ListParams) WithStartTimeBegin 

func (o *ListParams) WithStartTimeBegin(startTimeBegin *int64) *ListParams

WithStartTimeBegin adds the startTimeBegin to the list params

func (*ListParams) WithStartTimeEnd 

func (o *ListParams) WithStartTimeEnd(startTimeEnd *int64) *ListParams

WithStartTimeEnd adds the startTimeEnd to the list params

func (*ListParams) WithTimeout 

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

WithTimeout adds the timeout to the list params

func (*ListParams) WriteToRequest 

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

WriteToRequest writes these params to a swagger request

type ListReader 

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

ListReader is a Reader for the List structure.

func (*ListReader) ReadResponse 

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

ReadResponse reads a server response into the received o.

type ListUnauthorized 

type ListUnauthorized struct {
	Payload interface{}
}
ListUnauthorized describes a response with status code 401, with default header values.

ListUnauthorized list unauthorized

func NewListUnauthorized 

func NewListUnauthorized() *ListUnauthorized

NewListUnauthorized creates a ListUnauthorized with default headers values

func (*ListUnauthorized) Error 

func (o *ListUnauthorized) Error() string

func (*ListUnauthorized) GetPayload 

func (o *ListUnauthorized) GetPayload() interface{}

type QueryBadRequest 

type QueryBadRequest struct {
	Payload *QueryBadRequestBody
}
QueryBadRequest describes a response with status code 400, with default header values.

QueryBadRequest query bad request

func NewQueryBadRequest 

func NewQueryBadRequest() *QueryBadRequest

NewQueryBadRequest creates a QueryBadRequest with default headers values

func (*QueryBadRequest) Error 

func (o *QueryBadRequest) Error() string

func (*QueryBadRequest) GetPayload 

func (o *QueryBadRequest) GetPayload() *QueryBadRequestBody

type QueryBadRequestBody 

type QueryBadRequestBody struct {

	// message
	// Required: true
	Message *string `json:"message"`
}

QueryBadRequestBody query bad request body swagger:model QueryBadRequestBody

func (*QueryBadRequestBody) ContextValidate 

func (o *QueryBadRequestBody) ContextValidate(ctx context.Context, formats strfmt.Registry) error

ContextValidate validates this query bad request body based on context it is used

func (*QueryBadRequestBody) MarshalBinary 

func (o *QueryBadRequestBody) MarshalBinary() ([]byte, error)

MarshalBinary interface implementation

func (*QueryBadRequestBody) UnmarshalBinary 

func (o *QueryBadRequestBody) UnmarshalBinary(b []byte) error

UnmarshalBinary interface implementation

func (*QueryBadRequestBody) Validate 

func (o *QueryBadRequestBody) Validate(formats strfmt.Registry) error

Validate validates this query bad request body

type QueryForbidden 

type QueryForbidden struct {
	Payload *QueryForbiddenBody
}
QueryForbidden describes a response with status code 403, with default header values.

QueryForbidden query forbidden

func NewQueryForbidden 

func NewQueryForbidden() *QueryForbidden

NewQueryForbidden creates a QueryForbidden with default headers values

func (*QueryForbidden) Error 

func (o *QueryForbidden) Error() string

func (*QueryForbidden) GetPayload 

func (o *QueryForbidden) GetPayload() *QueryForbiddenBody

type QueryForbiddenBody 

type QueryForbiddenBody struct {

	// message
	// Required: true
	Message *string `json:"message"`
}

QueryForbiddenBody query forbidden body swagger:model QueryForbiddenBody

func (*QueryForbiddenBody) ContextValidate 

func (o *QueryForbiddenBody) ContextValidate(ctx context.Context, formats strfmt.Registry) error

ContextValidate validates this query forbidden body based on context it is used

func (*QueryForbiddenBody) MarshalBinary 

func (o *QueryForbiddenBody) MarshalBinary() ([]byte, error)

MarshalBinary interface implementation

func (*QueryForbiddenBody) UnmarshalBinary 

func (o *QueryForbiddenBody) UnmarshalBinary(b []byte) error

UnmarshalBinary interface implementation

func (*QueryForbiddenBody) Validate 

func (o *QueryForbiddenBody) Validate(formats strfmt.Registry) error

Validate validates this query forbidden body

type QueryInternalServerError 

type QueryInternalServerError struct {
	Payload interface{}
}
QueryInternalServerError describes a response with status code 500, with default header values.

QueryInternalServerError query internal server error

func NewQueryInternalServerError 

func NewQueryInternalServerError() *QueryInternalServerError

NewQueryInternalServerError creates a QueryInternalServerError with default headers values

func (*QueryInternalServerError) Error 

func (o *QueryInternalServerError) Error() string

func (*QueryInternalServerError) GetPayload 

func (o *QueryInternalServerError) GetPayload() interface{}

type QueryNotFound 

type QueryNotFound struct {
	Payload *QueryNotFoundBody
}
QueryNotFound describes a response with status code 404, with default header values.

QueryNotFound query not found

func NewQueryNotFound 

func NewQueryNotFound() *QueryNotFound

NewQueryNotFound creates a QueryNotFound with default headers values

func (*QueryNotFound) Error 

func (o *QueryNotFound) Error() string

func (*QueryNotFound) GetPayload 

func (o *QueryNotFound) GetPayload() *QueryNotFoundBody

type QueryNotFoundBody 

type QueryNotFoundBody struct {

	// error
	// Required: true
	Error *string `json:"error"`

	// status
	// Required: true
	Status *string `json:"status"`
}

QueryNotFoundBody query not found body swagger:model QueryNotFoundBody

func (*QueryNotFoundBody) ContextValidate 

func (o *QueryNotFoundBody) ContextValidate(ctx context.Context, formats strfmt.Registry) error

ContextValidate validates this query not found body based on context it is used

func (*QueryNotFoundBody) MarshalBinary 

func (o *QueryNotFoundBody) MarshalBinary() ([]byte, error)

MarshalBinary interface implementation

func (*QueryNotFoundBody) UnmarshalBinary 

func (o *QueryNotFoundBody) UnmarshalBinary(b []byte) error

UnmarshalBinary interface implementation

func (*QueryNotFoundBody) Validate 

func (o *QueryNotFoundBody) Validate(formats strfmt.Registry) error

Validate validates this query not found body

type QueryOK 

type QueryOK struct {
	Payload *models.Job
}
QueryOK describes a response with status code 200, with default header values.

Query job succeeded

func NewQueryOK 

func NewQueryOK() *QueryOK

NewQueryOK creates a QueryOK with default headers values

func (*QueryOK) Error 

func (o *QueryOK) Error() string

func (*QueryOK) GetPayload 

func (o *QueryOK) GetPayload() *models.Job

type QueryParams 

type QueryParams struct {

	/* OutputLineLimit.

	   Output lines limit

	   Format: int32
	   Default: 10
	*/
	OutputLineLimit *int32

	/* OutputLineStart.

	   Output line start

	   Format: int32
	*/
	OutputLineStart *int32

	/* Urn.

	   Job urn
	*/
	Urn string

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

QueryParams contains all the parameters to send to the API endpoint 

for the query operation.

Typically these are written to a http.Request.

func NewQueryParams 

func NewQueryParams() *QueryParams

NewQueryParams creates a new QueryParams 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 NewQueryParamsWithContext 

func NewQueryParamsWithContext(ctx context.Context) *QueryParams

NewQueryParamsWithContext creates a new QueryParams object with the ability to set a context for a request.

func NewQueryParamsWithHTTPClient 

func NewQueryParamsWithHTTPClient(client *http.Client) *QueryParams

NewQueryParamsWithHTTPClient creates a new QueryParams object with the ability to set a custom HTTPClient for a request.

func NewQueryParamsWithTimeout 

func NewQueryParamsWithTimeout(timeout time.Duration) *QueryParams

NewQueryParamsWithTimeout creates a new QueryParams object with the ability to set a timeout on a request.

func (*QueryParams) SetContext 

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

SetContext adds the context to the query params

func (*QueryParams) SetDefaults 

func (o *QueryParams) SetDefaults()

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

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

func (*QueryParams) SetHTTPClient 

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

SetHTTPClient adds the HTTPClient to the query params

func (*QueryParams) SetOutputLineLimit 

func (o *QueryParams) SetOutputLineLimit(outputLineLimit *int32)

SetOutputLineLimit adds the outputLineLimit to the query params

func (*QueryParams) SetOutputLineStart 

func (o *QueryParams) SetOutputLineStart(outputLineStart *int32)

SetOutputLineStart adds the outputLineStart to the query params

func (*QueryParams) SetTimeout 

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

SetTimeout adds the timeout to the query params

func (*QueryParams) SetUrn 

func (o *QueryParams) SetUrn(urn string)

SetUrn adds the urn to the query params

func (*QueryParams) WithContext 

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

WithContext adds the context to the query params

func (*QueryParams) WithDefaults 

func (o *QueryParams) WithDefaults() *QueryParams

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

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

func (*QueryParams) WithHTTPClient 

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

WithHTTPClient adds the HTTPClient to the query params

func (*QueryParams) WithOutputLineLimit 

func (o *QueryParams) WithOutputLineLimit(outputLineLimit *int32) *QueryParams

WithOutputLineLimit adds the outputLineLimit to the query params

func (*QueryParams) WithOutputLineStart 

func (o *QueryParams) WithOutputLineStart(outputLineStart *int32) *QueryParams

WithOutputLineStart adds the outputLineStart to the query params

func (*QueryParams) WithTimeout 

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

WithTimeout adds the timeout to the query params

func (*QueryParams) WithUrn 

func (o *QueryParams) WithUrn(urn string) *QueryParams

WithUrn adds the urn to the query params

func (*QueryParams) WriteToRequest 

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

WriteToRequest writes these params to a swagger request

type QueryReader 

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

QueryReader is a Reader for the Query structure.

func (*QueryReader) ReadResponse 

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

ReadResponse reads a server response into the received o.

type QueryUnauthorized 

type QueryUnauthorized struct {
	Payload interface{}
}
QueryUnauthorized describes a response with status code 401, with default header values.

QueryUnauthorized query unauthorized

func NewQueryUnauthorized 

func NewQueryUnauthorized() *QueryUnauthorized

NewQueryUnauthorized creates a QueryUnauthorized with default headers values

func (*QueryUnauthorized) Error 

func (o *QueryUnauthorized) Error() string

func (*QueryUnauthorized) GetPayload 

func (o *QueryUnauthorized) GetPayload() interface{}

type SubmitBadRequest 

type SubmitBadRequest struct {
	Payload *SubmitBadRequestBody
}
SubmitBadRequest describes a response with status code 400, with default header values.

SubmitBadRequest submit bad request

func NewSubmitBadRequest 

func NewSubmitBadRequest() *SubmitBadRequest

NewSubmitBadRequest creates a SubmitBadRequest with default headers values

func (*SubmitBadRequest) Error 

func (o *SubmitBadRequest) Error() string

func (*SubmitBadRequest) GetPayload 

func (o *SubmitBadRequest) GetPayload() *SubmitBadRequestBody

type SubmitBadRequestBody 

type SubmitBadRequestBody struct {

	// message
	// Required: true
	Message *string `json:"message"`
}

SubmitBadRequestBody submit bad request body swagger:model SubmitBadRequestBody

func (*SubmitBadRequestBody) ContextValidate 

func (o *SubmitBadRequestBody) ContextValidate(ctx context.Context, formats strfmt.Registry) error

ContextValidate validates this submit bad request body based on context it is used

func (*SubmitBadRequestBody) MarshalBinary 

func (o *SubmitBadRequestBody) MarshalBinary() ([]byte, error)

MarshalBinary interface implementation

func (*SubmitBadRequestBody) UnmarshalBinary 

func (o *SubmitBadRequestBody) UnmarshalBinary(b []byte) error

UnmarshalBinary interface implementation

func (*SubmitBadRequestBody) Validate 

func (o *SubmitBadRequestBody) Validate(formats strfmt.Registry) error

Validate validates this submit bad request body

type SubmitForbidden 

type SubmitForbidden struct {
	Payload *SubmitForbiddenBody
}
SubmitForbidden describes a response with status code 403, with default header values.

SubmitForbidden submit forbidden

func NewSubmitForbidden 

func NewSubmitForbidden() *SubmitForbidden

NewSubmitForbidden creates a SubmitForbidden with default headers values

func (*SubmitForbidden) Error 

func (o *SubmitForbidden) Error() string

func (*SubmitForbidden) GetPayload 

func (o *SubmitForbidden) GetPayload() *SubmitForbiddenBody

type SubmitForbiddenBody 

type SubmitForbiddenBody struct {

	// message
	// Required: true
	Message *string `json:"message"`
}

SubmitForbiddenBody submit forbidden body swagger:model SubmitForbiddenBody

func (*SubmitForbiddenBody) ContextValidate 

func (o *SubmitForbiddenBody) ContextValidate(ctx context.Context, formats strfmt.Registry) error

ContextValidate validates this submit forbidden body based on context it is used

func (*SubmitForbiddenBody) MarshalBinary 

func (o *SubmitForbiddenBody) MarshalBinary() ([]byte, error)

MarshalBinary interface implementation

func (*SubmitForbiddenBody) UnmarshalBinary 

func (o *SubmitForbiddenBody) UnmarshalBinary(b []byte) error

UnmarshalBinary interface implementation

func (*SubmitForbiddenBody) Validate 

func (o *SubmitForbiddenBody) Validate(formats strfmt.Registry) error

Validate validates this submit forbidden body

type SubmitInternalServerError 

type SubmitInternalServerError struct {
	Payload interface{}
}
SubmitInternalServerError describes a response with status code 500, with default header values.

SubmitInternalServerError submit internal server error

func NewSubmitInternalServerError 

func NewSubmitInternalServerError() *SubmitInternalServerError

NewSubmitInternalServerError creates a SubmitInternalServerError with default headers values

func (*SubmitInternalServerError) Error 

func (o *SubmitInternalServerError) Error() string

func (*SubmitInternalServerError) GetPayload 

func (o *SubmitInternalServerError) GetPayload() interface{}

type SubmitNotFound 

type SubmitNotFound struct {
	Payload *SubmitNotFoundBody
}
SubmitNotFound describes a response with status code 404, with default header values.

SubmitNotFound submit not found

func NewSubmitNotFound 

func NewSubmitNotFound() *SubmitNotFound

NewSubmitNotFound creates a SubmitNotFound with default headers values

func (*SubmitNotFound) Error 

func (o *SubmitNotFound) Error() string

func (*SubmitNotFound) GetPayload 

func (o *SubmitNotFound) GetPayload() *SubmitNotFoundBody

type SubmitNotFoundBody 

type SubmitNotFoundBody struct {

	// error
	// Required: true
	Error *string `json:"error"`

	// status
	// Required: true
	Status *string `json:"status"`
}

SubmitNotFoundBody submit not found body swagger:model SubmitNotFoundBody

func (*SubmitNotFoundBody) ContextValidate 

func (o *SubmitNotFoundBody) ContextValidate(ctx context.Context, formats strfmt.Registry) error

ContextValidate validates this submit not found body based on context it is used

func (*SubmitNotFoundBody) MarshalBinary 

func (o *SubmitNotFoundBody) MarshalBinary() ([]byte, error)

MarshalBinary interface implementation

func (*SubmitNotFoundBody) UnmarshalBinary 

func (o *SubmitNotFoundBody) UnmarshalBinary(b []byte) error

UnmarshalBinary interface implementation

func (*SubmitNotFoundBody) Validate 

func (o *SubmitNotFoundBody) Validate(formats strfmt.Registry) error

Validate validates this submit not found body

type SubmitOK 

type SubmitOK struct {
	Payload []*models.Job
}
SubmitOK describes a response with status code 200, with default header values.

Submit job succeeded

func NewSubmitOK 

func NewSubmitOK() *SubmitOK

NewSubmitOK creates a SubmitOK with default headers values

func (*SubmitOK) Error 

func (o *SubmitOK) Error() string

func (*SubmitOK) GetPayload 

func (o *SubmitOK) GetPayload() []*models.Job

type SubmitParams 

type SubmitParams struct {

	/* Spec.

	   Job spec
	*/
	Spec []*models.JobSpec

	/* Wait.

	   Wait until job finished
	*/
	Wait *bool

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

SubmitParams contains all the parameters to send to the API endpoint 

for the submit operation.

Typically these are written to a http.Request.

func NewSubmitParams 

func NewSubmitParams() *SubmitParams

NewSubmitParams creates a new SubmitParams 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 NewSubmitParamsWithContext 

func NewSubmitParamsWithContext(ctx context.Context) *SubmitParams

NewSubmitParamsWithContext creates a new SubmitParams object with the ability to set a context for a request.

func NewSubmitParamsWithHTTPClient 

func NewSubmitParamsWithHTTPClient(client *http.Client) *SubmitParams

NewSubmitParamsWithHTTPClient creates a new SubmitParams object with the ability to set a custom HTTPClient for a request.

func NewSubmitParamsWithTimeout 

func NewSubmitParamsWithTimeout(timeout time.Duration) *SubmitParams

NewSubmitParamsWithTimeout creates a new SubmitParams object with the ability to set a timeout on a request.

func (*SubmitParams) SetContext 

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

SetContext adds the context to the submit params

func (*SubmitParams) SetDefaults 

func (o *SubmitParams) SetDefaults()

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

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

func (*SubmitParams) SetHTTPClient 

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

SetHTTPClient adds the HTTPClient to the submit params

func (*SubmitParams) SetSpec 

func (o *SubmitParams) SetSpec(spec []*models.JobSpec)

SetSpec adds the spec to the submit params

func (*SubmitParams) SetTimeout 

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

SetTimeout adds the timeout to the submit params

func (*SubmitParams) SetWait 

func (o *SubmitParams) SetWait(wait *bool)

SetWait adds the wait to the submit params

func (*SubmitParams) WithContext 

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

WithContext adds the context to the submit params

func (*SubmitParams) WithDefaults 

func (o *SubmitParams) WithDefaults() *SubmitParams

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

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

func (*SubmitParams) WithHTTPClient 

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

WithHTTPClient adds the HTTPClient to the submit params

func (*SubmitParams) WithSpec 

func (o *SubmitParams) WithSpec(spec []*models.JobSpec) *SubmitParams

WithSpec adds the spec to the submit params

func (*SubmitParams) WithTimeout 

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

WithTimeout adds the timeout to the submit params

func (*SubmitParams) WithWait 

func (o *SubmitParams) WithWait(wait *bool) *SubmitParams

WithWait adds the wait to the submit params

func (*SubmitParams) WriteToRequest 

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

WriteToRequest writes these params to a swagger request

type SubmitReader 

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

SubmitReader is a Reader for the Submit structure.

func (*SubmitReader) ReadResponse 

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

ReadResponse reads a server response into the received o.

type SubmitUnauthorized 

type SubmitUnauthorized struct {
	Payload interface{}
}
SubmitUnauthorized describes a response with status code 401, with default header values.

SubmitUnauthorized submit unauthorized

func NewSubmitUnauthorized 

func NewSubmitUnauthorized() *SubmitUnauthorized

NewSubmitUnauthorized creates a SubmitUnauthorized with default headers values

func (*SubmitUnauthorized) Error 

func (o *SubmitUnauthorized) Error() string

func (*SubmitUnauthorized) GetPayload 

func (o *SubmitUnauthorized) GetPayload() interface{}

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.