Documentation ¶
Index ¶
- type Client
- func (a *Client) Delete(params *DeleteParams, opts ...ClientOption) (*DeleteOK, error)
- func (a *Client) Input(params *InputParams, opts ...ClientOption) (*InputOK, error)
- func (a *Client) Kill(params *KillParams, opts ...ClientOption) (*KillOK, error)
- func (a *Client) List(params *ListParams, opts ...ClientOption) (*ListOK, error)
- func (a *Client) Query(params *QueryParams, opts ...ClientOption) (*QueryOK, error)
- func (a *Client) SetTransport(transport runtime.ClientTransport)
- func (a *Client) Submit(params *SubmitParams, opts ...ClientOption) (*SubmitOK, error)
- type ClientOption
- type ClientService
- type DeleteBadRequest
- type DeleteBadRequestBody
- type DeleteForbidden
- type DeleteForbiddenBody
- type DeleteInternalServerError
- type DeleteNotFound
- type DeleteNotFoundBody
- type DeleteOK
- type DeleteParams
- func (o *DeleteParams) SetContext(ctx context.Context)
- func (o *DeleteParams) SetDefaults()
- func (o *DeleteParams) SetHTTPClient(client *http.Client)
- func (o *DeleteParams) SetTimeout(timeout time.Duration)
- func (o *DeleteParams) SetUrn(urn string)
- func (o *DeleteParams) WithContext(ctx context.Context) *DeleteParams
- func (o *DeleteParams) WithDefaults() *DeleteParams
- func (o *DeleteParams) WithHTTPClient(client *http.Client) *DeleteParams
- func (o *DeleteParams) WithTimeout(timeout time.Duration) *DeleteParams
- func (o *DeleteParams) WithUrn(urn string) *DeleteParams
- func (o *DeleteParams) WriteToRequest(r runtime.ClientRequest, reg strfmt.Registry) error
- type DeleteReader
- type DeleteUnauthorized
- type InputBadRequest
- type InputBadRequestBody
- type InputForbidden
- type InputForbiddenBody
- type InputInternalServerError
- type InputNotFound
- type InputNotFoundBody
- type InputOK
- type InputParams
- func (o *InputParams) SetContext(ctx context.Context)
- func (o *InputParams) SetDefaults()
- func (o *InputParams) SetHTTPClient(client *http.Client)
- func (o *InputParams) SetInput(input *models.JobInput)
- func (o *InputParams) SetTimeout(timeout time.Duration)
- func (o *InputParams) SetUrn(urn string)
- func (o *InputParams) WithContext(ctx context.Context) *InputParams
- func (o *InputParams) WithDefaults() *InputParams
- func (o *InputParams) WithHTTPClient(client *http.Client) *InputParams
- func (o *InputParams) WithInput(input *models.JobInput) *InputParams
- func (o *InputParams) WithTimeout(timeout time.Duration) *InputParams
- func (o *InputParams) WithUrn(urn string) *InputParams
- func (o *InputParams) WriteToRequest(r runtime.ClientRequest, reg strfmt.Registry) error
- type InputReader
- type InputUnauthorized
- type KillBadRequest
- type KillBadRequestBody
- type KillForbidden
- type KillForbiddenBody
- type KillInternalServerError
- type KillNotFound
- type KillNotFoundBody
- type KillOK
- type KillParams
- func (o *KillParams) SetContext(ctx context.Context)
- func (o *KillParams) SetDefaults()
- func (o *KillParams) SetForce(force *bool)
- func (o *KillParams) SetHTTPClient(client *http.Client)
- func (o *KillParams) SetTimeout(timeout time.Duration)
- func (o *KillParams) SetUrn(urn string)
- func (o *KillParams) WithContext(ctx context.Context) *KillParams
- func (o *KillParams) WithDefaults() *KillParams
- func (o *KillParams) WithForce(force *bool) *KillParams
- func (o *KillParams) WithHTTPClient(client *http.Client) *KillParams
- func (o *KillParams) WithTimeout(timeout time.Duration) *KillParams
- func (o *KillParams) WithUrn(urn string) *KillParams
- func (o *KillParams) WriteToRequest(r runtime.ClientRequest, reg strfmt.Registry) error
- type KillReader
- type KillUnauthorized
- type ListBadRequest
- type ListBadRequestBody
- type ListForbidden
- type ListForbiddenBody
- type ListInternalServerError
- type ListNotFound
- type ListNotFoundBody
- type ListOK
- type ListParams
- func (o *ListParams) SetContext(ctx context.Context)
- func (o *ListParams) SetDefaults()
- func (o *ListParams) SetHTTPClient(client *http.Client)
- func (o *ListParams) SetOperation(operation *string)
- func (o *ListParams) SetPlugin(plugin *string)
- func (o *ListParams) SetStartTimeBegin(startTimeBegin *int64)
- func (o *ListParams) SetStartTimeEnd(startTimeEnd *int64)
- func (o *ListParams) SetTimeout(timeout time.Duration)
- func (o *ListParams) WithContext(ctx context.Context) *ListParams
- func (o *ListParams) WithDefaults() *ListParams
- func (o *ListParams) WithHTTPClient(client *http.Client) *ListParams
- func (o *ListParams) WithOperation(operation *string) *ListParams
- func (o *ListParams) WithPlugin(plugin *string) *ListParams
- func (o *ListParams) WithStartTimeBegin(startTimeBegin *int64) *ListParams
- func (o *ListParams) WithStartTimeEnd(startTimeEnd *int64) *ListParams
- func (o *ListParams) WithTimeout(timeout time.Duration) *ListParams
- func (o *ListParams) WriteToRequest(r runtime.ClientRequest, reg strfmt.Registry) error
- type ListReader
- type ListUnauthorized
- type QueryBadRequest
- type QueryBadRequestBody
- type QueryForbidden
- type QueryForbiddenBody
- type QueryInternalServerError
- type QueryNotFound
- type QueryNotFoundBody
- type QueryOK
- type QueryParams
- func (o *QueryParams) SetContext(ctx context.Context)
- func (o *QueryParams) SetDefaults()
- func (o *QueryParams) SetHTTPClient(client *http.Client)
- func (o *QueryParams) SetOutputLineLimit(outputLineLimit *int32)
- func (o *QueryParams) SetOutputLineStart(outputLineStart *int32)
- func (o *QueryParams) SetTimeout(timeout time.Duration)
- func (o *QueryParams) SetUrn(urn string)
- func (o *QueryParams) WithContext(ctx context.Context) *QueryParams
- func (o *QueryParams) WithDefaults() *QueryParams
- func (o *QueryParams) WithHTTPClient(client *http.Client) *QueryParams
- func (o *QueryParams) WithOutputLineLimit(outputLineLimit *int32) *QueryParams
- func (o *QueryParams) WithOutputLineStart(outputLineStart *int32) *QueryParams
- func (o *QueryParams) WithTimeout(timeout time.Duration) *QueryParams
- func (o *QueryParams) WithUrn(urn string) *QueryParams
- func (o *QueryParams) WriteToRequest(r runtime.ClientRequest, reg strfmt.Registry) error
- type QueryReader
- type QueryUnauthorized
- type SubmitBadRequest
- type SubmitBadRequestBody
- type SubmitForbidden
- type SubmitForbiddenBody
- type SubmitInternalServerError
- type SubmitNotFound
- type SubmitNotFoundBody
- type SubmitOK
- type SubmitParams
- func (o *SubmitParams) SetContext(ctx context.Context)
- func (o *SubmitParams) SetDefaults()
- func (o *SubmitParams) SetHTTPClient(client *http.Client)
- func (o *SubmitParams) SetSpec(spec []*models.JobSpec)
- func (o *SubmitParams) SetTimeout(timeout time.Duration)
- func (o *SubmitParams) SetWait(wait *bool)
- func (o *SubmitParams) WithContext(ctx context.Context) *SubmitParams
- func (o *SubmitParams) WithDefaults() *SubmitParams
- func (o *SubmitParams) WithHTTPClient(client *http.Client) *SubmitParams
- func (o *SubmitParams) WithSpec(spec []*models.JobSpec) *SubmitParams
- func (o *SubmitParams) WithTimeout(timeout time.Duration) *SubmitParams
- func (o *SubmitParams) WithWait(wait *bool) *SubmitParams
- func (o *SubmitParams) WriteToRequest(r runtime.ClientRequest, reg strfmt.Registry) error
- type SubmitReader
- type SubmitUnauthorized
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 ¶
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
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 ¶
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
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 ¶
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
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) GetPayload ¶
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 {
}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 ¶
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
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 ¶
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
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 ¶
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
type InputOK ¶
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) GetPayload ¶
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 {
}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 ¶
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
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 ¶
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
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 ¶
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
type KillOK ¶
KillOK describes a response with status code 200, with default header values.
Kill job succeeded
func (*KillOK) GetPayload ¶
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 {
}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 ¶
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
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 ¶
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
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 ¶
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
type ListOK ¶
ListOK describes a response with status code 200, with default header values.
List jobs succeeded
func (*ListOK) GetPayload ¶
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 {
}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 ¶
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
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 ¶
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
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 ¶
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
type QueryOK ¶
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) GetPayload ¶
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 {
}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 ¶
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
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 ¶
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
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 ¶
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
type SubmitOK ¶
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) GetPayload ¶
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 {
}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{}