operations

package
v0.9.8 Latest Latest
Warning

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

Go to latest
Published: Aug 2, 2024 License: Apache-2.0 Imports: 19 Imported by: 0

Documentation ¶

Index ¶

Constants ¶

View Source
const GetHealthBadRequestCode int = 400

GetHealthBadRequestCode is the HTTP code returned for type GetHealthBadRequest

View Source
const GetHealthOKCode int = 200

GetHealthOKCode is the HTTP code returned for type GetHealthOK

View Source
const GetJobErrorBadRequestCode int = 400

GetJobErrorBadRequestCode is the HTTP code returned for type GetJobErrorBadRequest

View Source
const GetJobErrorOKCode int = 200

GetJobErrorOKCode is the HTTP code returned for type GetJobErrorOK

View Source
const GetJobRunDebugMessageBadRequestCode int = 400

GetJobRunDebugMessageBadRequestCode is the HTTP code returned for type GetJobRunDebugMessageBadRequest

View Source
const GetJobRunDebugMessageOKCode int = 200

GetJobRunDebugMessageOKCode is the HTTP code returned for type GetJobRunDebugMessageOK

View Source
const GetJobRunErrorBadRequestCode int = 400

GetJobRunErrorBadRequestCode is the HTTP code returned for type GetJobRunErrorBadRequest

View Source
const GetJobRunErrorOKCode int = 200

GetJobRunErrorOKCode is the HTTP code returned for type GetJobRunErrorOK

View Source
const GetJobSpecBadRequestCode int = 400

GetJobSpecBadRequestCode is the HTTP code returned for type GetJobSpecBadRequest

View Source
const GetJobSpecOKCode int = 200

GetJobSpecOKCode is the HTTP code returned for type GetJobSpecOK

View Source
const GetJobsBadRequestCode int = 400

GetJobsBadRequestCode is the HTTP code returned for type GetJobsBadRequest

View Source
const GetJobsOKCode int = 200

GetJobsOKCode is the HTTP code returned for type GetJobsOK

View Source
const GroupJobsBadRequestCode int = 400

GroupJobsBadRequestCode is the HTTP code returned for type GroupJobsBadRequest

View Source
const GroupJobsOKCode int = 200

GroupJobsOKCode is the HTTP code returned for type GroupJobsOK

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type GetHealth ¶

type GetHealth struct {
	Context *middleware.Context
	Handler GetHealthHandler
}
GetHealth swagger:route GET /health getHealth

GetHealth get health API

func NewGetHealth ¶

func NewGetHealth(ctx *middleware.Context, handler GetHealthHandler) *GetHealth

NewGetHealth creates a new http.Handler for the get health operation

func (*GetHealth) ServeHTTP ¶

func (o *GetHealth) ServeHTTP(rw http.ResponseWriter, r *http.Request)

type GetHealthBadRequest ¶

type GetHealthBadRequest struct {

	/*
	  In: Body
	*/
	Payload string `json:"body,omitempty"`
}

GetHealthBadRequest Error response

swagger:response getHealthBadRequest

func NewGetHealthBadRequest ¶

func NewGetHealthBadRequest() *GetHealthBadRequest

NewGetHealthBadRequest creates GetHealthBadRequest with default headers values

func (*GetHealthBadRequest) SetPayload ¶

func (o *GetHealthBadRequest) SetPayload(payload string)

SetPayload sets the payload to the get health bad request response

func (*GetHealthBadRequest) WithPayload ¶

func (o *GetHealthBadRequest) WithPayload(payload string) *GetHealthBadRequest

WithPayload adds the payload to the get health bad request response

func (*GetHealthBadRequest) WriteResponse ¶

func (o *GetHealthBadRequest) WriteResponse(rw http.ResponseWriter, producer runtime.Producer)

WriteResponse to the client

type GetHealthHandler ¶

type GetHealthHandler interface {
	Handle(GetHealthParams) middleware.Responder
}

GetHealthHandler interface for that can handle valid get health params

type GetHealthHandlerFunc ¶

type GetHealthHandlerFunc func(GetHealthParams) middleware.Responder

GetHealthHandlerFunc turns a function with the right signature into a get health handler

func (GetHealthHandlerFunc) Handle ¶

Handle executing the request and returning a response

type GetHealthOK ¶

type GetHealthOK struct {

	/*
	  In: Body
	*/
	Payload string `json:"body,omitempty"`
}

GetHealthOK OK

swagger:response getHealthOK

func NewGetHealthOK ¶

func NewGetHealthOK() *GetHealthOK

NewGetHealthOK creates GetHealthOK with default headers values

func (*GetHealthOK) SetPayload ¶

func (o *GetHealthOK) SetPayload(payload string)

SetPayload sets the payload to the get health o k response

func (*GetHealthOK) WithPayload ¶

func (o *GetHealthOK) WithPayload(payload string) *GetHealthOK

WithPayload adds the payload to the get health o k response

func (*GetHealthOK) WriteResponse ¶

func (o *GetHealthOK) WriteResponse(rw http.ResponseWriter, producer runtime.Producer)

WriteResponse to the client

type GetHealthParams ¶

type GetHealthParams struct {

	// HTTP Request Object
	HTTPRequest *http.Request `json:"-"`
}

GetHealthParams contains all the bound params for the get health operation typically these are obtained from a http.Request

swagger:parameters GetHealth

func NewGetHealthParams ¶

func NewGetHealthParams() GetHealthParams

NewGetHealthParams creates a new GetHealthParams object

There are no default values defined in the spec.

func (*GetHealthParams) BindRequest ¶

func (o *GetHealthParams) BindRequest(r *http.Request, route *middleware.MatchedRoute) error

BindRequest both binds and validates a request, it assumes that complex things implement a Validatable(strfmt.Registry) error interface for simple values it will use straight method calls.

To ensure default values, the struct must have been initialized with NewGetHealthParams() beforehand.

type GetHealthURL ¶

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

GetHealthURL generates an URL for the get health operation

func (*GetHealthURL) Build ¶

func (o *GetHealthURL) Build() (*url.URL, error)

Build a url path and query string

func (*GetHealthURL) BuildFull ¶

func (o *GetHealthURL) BuildFull(scheme, host string) (*url.URL, error)

BuildFull builds a full url with scheme, host, path and query string

func (*GetHealthURL) Must ¶

func (o *GetHealthURL) Must(u *url.URL, err error) *url.URL

Must is a helper function to panic when the url builder returns an error

func (*GetHealthURL) SetBasePath ¶

func (o *GetHealthURL) SetBasePath(bp string)

SetBasePath sets the base path for this url builder, only required when it's different from the base path specified in the swagger spec. When the value of the base path is an empty string

func (*GetHealthURL) String ¶

func (o *GetHealthURL) String() string

String returns the string representation of the path with query string

func (*GetHealthURL) StringFull ¶

func (o *GetHealthURL) StringFull(scheme, host string) string

StringFull returns the string representation of a complete url

func (*GetHealthURL) WithBasePath ¶

func (o *GetHealthURL) WithBasePath(bp string) *GetHealthURL

WithBasePath sets the base path for this url builder, only required when it's different from the base path specified in the swagger spec. When the value of the base path is an empty string

type GetJobError ¶ added in v0.8.3

type GetJobError struct {
	Context *middleware.Context
	Handler GetJobErrorHandler
}
GetJobError swagger:route POST /api/v1/jobError getJobError

GetJobError get job error API

func NewGetJobError ¶ added in v0.8.3

func NewGetJobError(ctx *middleware.Context, handler GetJobErrorHandler) *GetJobError

NewGetJobError creates a new http.Handler for the get job error operation

func (*GetJobError) ServeHTTP ¶ added in v0.8.3

func (o *GetJobError) ServeHTTP(rw http.ResponseWriter, r *http.Request)

type GetJobErrorBadRequest ¶ added in v0.8.3

type GetJobErrorBadRequest struct {

	/*
	  In: Body
	*/
	Payload *models.Error `json:"body,omitempty"`
}

GetJobErrorBadRequest Error response

swagger:response getJobErrorBadRequest

func NewGetJobErrorBadRequest ¶ added in v0.8.3

func NewGetJobErrorBadRequest() *GetJobErrorBadRequest

NewGetJobErrorBadRequest creates GetJobErrorBadRequest with default headers values

func (*GetJobErrorBadRequest) SetPayload ¶ added in v0.8.3

func (o *GetJobErrorBadRequest) SetPayload(payload *models.Error)

SetPayload sets the payload to the get job error bad request response

func (*GetJobErrorBadRequest) WithPayload ¶ added in v0.8.3

func (o *GetJobErrorBadRequest) WithPayload(payload *models.Error) *GetJobErrorBadRequest

WithPayload adds the payload to the get job error bad request response

func (*GetJobErrorBadRequest) WriteResponse ¶ added in v0.8.3

func (o *GetJobErrorBadRequest) WriteResponse(rw http.ResponseWriter, producer runtime.Producer)

WriteResponse to the client

type GetJobErrorBody ¶ added in v0.8.3

type GetJobErrorBody struct {

	// job Id
	// Required: true
	JobID string `json:"jobId"`
}

GetJobErrorBody get job error body

swagger:model GetJobErrorBody

func (*GetJobErrorBody) ContextValidate ¶ added in v0.8.3

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

ContextValidate validates this get job error body based on context it is used

func (*GetJobErrorBody) MarshalBinary ¶ added in v0.8.3

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

MarshalBinary interface implementation

func (*GetJobErrorBody) UnmarshalBinary ¶ added in v0.8.3

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

UnmarshalBinary interface implementation

func (*GetJobErrorBody) Validate ¶ added in v0.8.3

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

Validate validates this get job error body

type GetJobErrorDefault ¶ added in v0.8.3

type GetJobErrorDefault struct {

	/*
	  In: Body
	*/
	Payload *models.Error `json:"body,omitempty"`
	// contains filtered or unexported fields
}

GetJobErrorDefault Error response

swagger:response getJobErrorDefault

func NewGetJobErrorDefault ¶ added in v0.8.3

func NewGetJobErrorDefault(code int) *GetJobErrorDefault

NewGetJobErrorDefault creates GetJobErrorDefault with default headers values

func (*GetJobErrorDefault) SetPayload ¶ added in v0.8.3

func (o *GetJobErrorDefault) SetPayload(payload *models.Error)

SetPayload sets the payload to the get job error default response

func (*GetJobErrorDefault) SetStatusCode ¶ added in v0.8.3

func (o *GetJobErrorDefault) SetStatusCode(code int)

SetStatusCode sets the status to the get job error default response

func (*GetJobErrorDefault) WithPayload ¶ added in v0.8.3

func (o *GetJobErrorDefault) WithPayload(payload *models.Error) *GetJobErrorDefault

WithPayload adds the payload to the get job error default response

func (*GetJobErrorDefault) WithStatusCode ¶ added in v0.8.3

func (o *GetJobErrorDefault) WithStatusCode(code int) *GetJobErrorDefault

WithStatusCode adds the status to the get job error default response

func (*GetJobErrorDefault) WriteResponse ¶ added in v0.8.3

func (o *GetJobErrorDefault) WriteResponse(rw http.ResponseWriter, producer runtime.Producer)

WriteResponse to the client

type GetJobErrorHandler ¶ added in v0.8.3

type GetJobErrorHandler interface {
	Handle(GetJobErrorParams) middleware.Responder
}

GetJobErrorHandler interface for that can handle valid get job error params

type GetJobErrorHandlerFunc ¶ added in v0.8.3

type GetJobErrorHandlerFunc func(GetJobErrorParams) middleware.Responder

GetJobErrorHandlerFunc turns a function with the right signature into a get job error handler

func (GetJobErrorHandlerFunc) Handle ¶ added in v0.8.3

Handle executing the request and returning a response

type GetJobErrorOK ¶ added in v0.8.3

type GetJobErrorOK struct {

	/*
	  In: Body
	*/
	Payload *GetJobErrorOKBody `json:"body,omitempty"`
}

GetJobErrorOK Returns error for specific job (if present)

swagger:response getJobErrorOK

func NewGetJobErrorOK ¶ added in v0.8.3

func NewGetJobErrorOK() *GetJobErrorOK

NewGetJobErrorOK creates GetJobErrorOK with default headers values

func (*GetJobErrorOK) SetPayload ¶ added in v0.8.3

func (o *GetJobErrorOK) SetPayload(payload *GetJobErrorOKBody)

SetPayload sets the payload to the get job error o k response

func (*GetJobErrorOK) WithPayload ¶ added in v0.8.3

func (o *GetJobErrorOK) WithPayload(payload *GetJobErrorOKBody) *GetJobErrorOK

WithPayload adds the payload to the get job error o k response

func (*GetJobErrorOK) WriteResponse ¶ added in v0.8.3

func (o *GetJobErrorOK) WriteResponse(rw http.ResponseWriter, producer runtime.Producer)

WriteResponse to the client

type GetJobErrorOKBody ¶ added in v0.8.3

type GetJobErrorOKBody struct {

	// Error for job
	ErrorString string `json:"errorString,omitempty"`
}

GetJobErrorOKBody get job error o k body

swagger:model GetJobErrorOKBody

func (*GetJobErrorOKBody) ContextValidate ¶ added in v0.8.3

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

ContextValidate validates this get job error o k body based on context it is used

func (*GetJobErrorOKBody) MarshalBinary ¶ added in v0.8.3

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

MarshalBinary interface implementation

func (*GetJobErrorOKBody) UnmarshalBinary ¶ added in v0.8.3

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

UnmarshalBinary interface implementation

func (*GetJobErrorOKBody) Validate ¶ added in v0.8.3

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

Validate validates this get job error o k body

type GetJobErrorParams ¶ added in v0.8.3

type GetJobErrorParams struct {

	// HTTP Request Object
	HTTPRequest *http.Request `json:"-"`

	/*
	  Required: true
	  In: body
	*/
	GetJobErrorRequest GetJobErrorBody
}

GetJobErrorParams contains all the bound params for the get job error operation typically these are obtained from a http.Request

swagger:parameters getJobError

func NewGetJobErrorParams ¶ added in v0.8.3

func NewGetJobErrorParams() GetJobErrorParams

NewGetJobErrorParams creates a new GetJobErrorParams object

There are no default values defined in the spec.

func (*GetJobErrorParams) BindRequest ¶ added in v0.8.3

func (o *GetJobErrorParams) BindRequest(r *http.Request, route *middleware.MatchedRoute) error

BindRequest both binds and validates a request, it assumes that complex things implement a Validatable(strfmt.Registry) error interface for simple values it will use straight method calls.

To ensure default values, the struct must have been initialized with NewGetJobErrorParams() beforehand.

type GetJobErrorURL ¶ added in v0.8.3

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

GetJobErrorURL generates an URL for the get job error operation

func (*GetJobErrorURL) Build ¶ added in v0.8.3

func (o *GetJobErrorURL) Build() (*url.URL, error)

Build a url path and query string

func (*GetJobErrorURL) BuildFull ¶ added in v0.8.3

func (o *GetJobErrorURL) BuildFull(scheme, host string) (*url.URL, error)

BuildFull builds a full url with scheme, host, path and query string

func (*GetJobErrorURL) Must ¶ added in v0.8.3

func (o *GetJobErrorURL) Must(u *url.URL, err error) *url.URL

Must is a helper function to panic when the url builder returns an error

func (*GetJobErrorURL) SetBasePath ¶ added in v0.8.3

func (o *GetJobErrorURL) SetBasePath(bp string)

SetBasePath sets the base path for this url builder, only required when it's different from the base path specified in the swagger spec. When the value of the base path is an empty string

func (*GetJobErrorURL) String ¶ added in v0.8.3

func (o *GetJobErrorURL) String() string

String returns the string representation of the path with query string

func (*GetJobErrorURL) StringFull ¶ added in v0.8.3

func (o *GetJobErrorURL) StringFull(scheme, host string) string

StringFull returns the string representation of a complete url

func (*GetJobErrorURL) WithBasePath ¶ added in v0.8.3

func (o *GetJobErrorURL) WithBasePath(bp string) *GetJobErrorURL

WithBasePath sets the base path for this url builder, only required when it's different from the base path specified in the swagger spec. When the value of the base path is an empty string

type GetJobRunDebugMessage ¶ added in v0.5.0

type GetJobRunDebugMessage struct {
	Context *middleware.Context
	Handler GetJobRunDebugMessageHandler
}
GetJobRunDebugMessage swagger:route POST /api/v1/jobRunDebugMessage getJobRunDebugMessage

GetJobRunDebugMessage get job run debug message API

func NewGetJobRunDebugMessage ¶ added in v0.5.0

func NewGetJobRunDebugMessage(ctx *middleware.Context, handler GetJobRunDebugMessageHandler) *GetJobRunDebugMessage

NewGetJobRunDebugMessage creates a new http.Handler for the get job run debug message operation

func (*GetJobRunDebugMessage) ServeHTTP ¶ added in v0.5.0

func (o *GetJobRunDebugMessage) ServeHTTP(rw http.ResponseWriter, r *http.Request)

type GetJobRunDebugMessageBadRequest ¶ added in v0.5.0

type GetJobRunDebugMessageBadRequest struct {

	/*
	  In: Body
	*/
	Payload *models.Error `json:"body,omitempty"`
}

GetJobRunDebugMessageBadRequest Error response

swagger:response getJobRunDebugMessageBadRequest

func NewGetJobRunDebugMessageBadRequest ¶ added in v0.5.0

func NewGetJobRunDebugMessageBadRequest() *GetJobRunDebugMessageBadRequest

NewGetJobRunDebugMessageBadRequest creates GetJobRunDebugMessageBadRequest with default headers values

func (*GetJobRunDebugMessageBadRequest) SetPayload ¶ added in v0.5.0

func (o *GetJobRunDebugMessageBadRequest) SetPayload(payload *models.Error)

SetPayload sets the payload to the get job run debug message bad request response

func (*GetJobRunDebugMessageBadRequest) WithPayload ¶ added in v0.5.0

WithPayload adds the payload to the get job run debug message bad request response

func (*GetJobRunDebugMessageBadRequest) WriteResponse ¶ added in v0.5.0

func (o *GetJobRunDebugMessageBadRequest) WriteResponse(rw http.ResponseWriter, producer runtime.Producer)

WriteResponse to the client

type GetJobRunDebugMessageBody ¶ added in v0.5.0

type GetJobRunDebugMessageBody struct {

	// run Id
	// Required: true
	RunID string `json:"runId"`
}

GetJobRunDebugMessageBody get job run debug message body

swagger:model GetJobRunDebugMessageBody

func (*GetJobRunDebugMessageBody) ContextValidate ¶ added in v0.5.0

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

ContextValidate validates this get job run debug message body based on context it is used

func (*GetJobRunDebugMessageBody) MarshalBinary ¶ added in v0.5.0

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

MarshalBinary interface implementation

func (*GetJobRunDebugMessageBody) UnmarshalBinary ¶ added in v0.5.0

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

UnmarshalBinary interface implementation

func (*GetJobRunDebugMessageBody) Validate ¶ added in v0.5.0

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

Validate validates this get job run debug message body

type GetJobRunDebugMessageDefault ¶ added in v0.5.0

type GetJobRunDebugMessageDefault struct {

	/*
	  In: Body
	*/
	Payload *models.Error `json:"body,omitempty"`
	// contains filtered or unexported fields
}

GetJobRunDebugMessageDefault Error response

swagger:response getJobRunDebugMessageDefault

func NewGetJobRunDebugMessageDefault ¶ added in v0.5.0

func NewGetJobRunDebugMessageDefault(code int) *GetJobRunDebugMessageDefault

NewGetJobRunDebugMessageDefault creates GetJobRunDebugMessageDefault with default headers values

func (*GetJobRunDebugMessageDefault) SetPayload ¶ added in v0.5.0

func (o *GetJobRunDebugMessageDefault) SetPayload(payload *models.Error)

SetPayload sets the payload to the get job run debug message default response

func (*GetJobRunDebugMessageDefault) SetStatusCode ¶ added in v0.5.0

func (o *GetJobRunDebugMessageDefault) SetStatusCode(code int)

SetStatusCode sets the status to the get job run debug message default response

func (*GetJobRunDebugMessageDefault) WithPayload ¶ added in v0.5.0

WithPayload adds the payload to the get job run debug message default response

func (*GetJobRunDebugMessageDefault) WithStatusCode ¶ added in v0.5.0

WithStatusCode adds the status to the get job run debug message default response

func (*GetJobRunDebugMessageDefault) WriteResponse ¶ added in v0.5.0

func (o *GetJobRunDebugMessageDefault) WriteResponse(rw http.ResponseWriter, producer runtime.Producer)

WriteResponse to the client

type GetJobRunDebugMessageHandler ¶ added in v0.5.0

type GetJobRunDebugMessageHandler interface {
	Handle(GetJobRunDebugMessageParams) middleware.Responder
}

GetJobRunDebugMessageHandler interface for that can handle valid get job run debug message params

type GetJobRunDebugMessageHandlerFunc ¶ added in v0.5.0

type GetJobRunDebugMessageHandlerFunc func(GetJobRunDebugMessageParams) middleware.Responder

GetJobRunDebugMessageHandlerFunc turns a function with the right signature into a get job run debug message handler

func (GetJobRunDebugMessageHandlerFunc) Handle ¶ added in v0.5.0

Handle executing the request and returning a response

type GetJobRunDebugMessageOK ¶ added in v0.5.0

type GetJobRunDebugMessageOK struct {

	/*
	  In: Body
	*/
	Payload *GetJobRunDebugMessageOKBody `json:"body,omitempty"`
}

GetJobRunDebugMessageOK Returns debug message for specific job run (if present)

swagger:response getJobRunDebugMessageOK

func NewGetJobRunDebugMessageOK ¶ added in v0.5.0

func NewGetJobRunDebugMessageOK() *GetJobRunDebugMessageOK

NewGetJobRunDebugMessageOK creates GetJobRunDebugMessageOK with default headers values

func (*GetJobRunDebugMessageOK) SetPayload ¶ added in v0.5.0

func (o *GetJobRunDebugMessageOK) SetPayload(payload *GetJobRunDebugMessageOKBody)

SetPayload sets the payload to the get job run debug message o k response

func (*GetJobRunDebugMessageOK) WithPayload ¶ added in v0.5.0

WithPayload adds the payload to the get job run debug message o k response

func (*GetJobRunDebugMessageOK) WriteResponse ¶ added in v0.5.0

func (o *GetJobRunDebugMessageOK) WriteResponse(rw http.ResponseWriter, producer runtime.Producer)

WriteResponse to the client

type GetJobRunDebugMessageOKBody ¶ added in v0.5.0

type GetJobRunDebugMessageOKBody struct {

	// Debug message for individual job run
	ErrorString string `json:"errorString,omitempty"`
}

GetJobRunDebugMessageOKBody get job run debug message o k body

swagger:model GetJobRunDebugMessageOKBody

func (*GetJobRunDebugMessageOKBody) ContextValidate ¶ added in v0.5.0

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

ContextValidate validates this get job run debug message o k body based on context it is used

func (*GetJobRunDebugMessageOKBody) MarshalBinary ¶ added in v0.5.0

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

MarshalBinary interface implementation

func (*GetJobRunDebugMessageOKBody) UnmarshalBinary ¶ added in v0.5.0

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

UnmarshalBinary interface implementation

func (*GetJobRunDebugMessageOKBody) Validate ¶ added in v0.5.0

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

Validate validates this get job run debug message o k body

type GetJobRunDebugMessageParams ¶ added in v0.5.0

type GetJobRunDebugMessageParams struct {

	// HTTP Request Object
	HTTPRequest *http.Request `json:"-"`

	/*
	  Required: true
	  In: body
	*/
	GetJobRunDebugMessageRequest GetJobRunDebugMessageBody
}

GetJobRunDebugMessageParams contains all the bound params for the get job run debug message operation typically these are obtained from a http.Request

swagger:parameters getJobRunDebugMessage

func NewGetJobRunDebugMessageParams ¶ added in v0.5.0

func NewGetJobRunDebugMessageParams() GetJobRunDebugMessageParams

NewGetJobRunDebugMessageParams creates a new GetJobRunDebugMessageParams object

There are no default values defined in the spec.

func (*GetJobRunDebugMessageParams) BindRequest ¶ added in v0.5.0

BindRequest both binds and validates a request, it assumes that complex things implement a Validatable(strfmt.Registry) error interface for simple values it will use straight method calls.

To ensure default values, the struct must have been initialized with NewGetJobRunDebugMessageParams() beforehand.

type GetJobRunDebugMessageURL ¶ added in v0.5.0

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

GetJobRunDebugMessageURL generates an URL for the get job run debug message operation

func (*GetJobRunDebugMessageURL) Build ¶ added in v0.5.0

func (o *GetJobRunDebugMessageURL) Build() (*url.URL, error)

Build a url path and query string

func (*GetJobRunDebugMessageURL) BuildFull ¶ added in v0.5.0

func (o *GetJobRunDebugMessageURL) BuildFull(scheme, host string) (*url.URL, error)

BuildFull builds a full url with scheme, host, path and query string

func (*GetJobRunDebugMessageURL) Must ¶ added in v0.5.0

func (o *GetJobRunDebugMessageURL) Must(u *url.URL, err error) *url.URL

Must is a helper function to panic when the url builder returns an error

func (*GetJobRunDebugMessageURL) SetBasePath ¶ added in v0.5.0

func (o *GetJobRunDebugMessageURL) SetBasePath(bp string)

SetBasePath sets the base path for this url builder, only required when it's different from the base path specified in the swagger spec. When the value of the base path is an empty string

func (*GetJobRunDebugMessageURL) String ¶ added in v0.5.0

func (o *GetJobRunDebugMessageURL) String() string

String returns the string representation of the path with query string

func (*GetJobRunDebugMessageURL) StringFull ¶ added in v0.5.0

func (o *GetJobRunDebugMessageURL) StringFull(scheme, host string) string

StringFull returns the string representation of a complete url

func (*GetJobRunDebugMessageURL) WithBasePath ¶ added in v0.5.0

WithBasePath sets the base path for this url builder, only required when it's different from the base path specified in the swagger spec. When the value of the base path is an empty string

type GetJobRunError ¶

type GetJobRunError struct {
	Context *middleware.Context
	Handler GetJobRunErrorHandler
}
GetJobRunError swagger:route POST /api/v1/jobRunError getJobRunError

GetJobRunError get job run error API

func NewGetJobRunError ¶

func NewGetJobRunError(ctx *middleware.Context, handler GetJobRunErrorHandler) *GetJobRunError

NewGetJobRunError creates a new http.Handler for the get job run error operation

func (*GetJobRunError) ServeHTTP ¶

func (o *GetJobRunError) ServeHTTP(rw http.ResponseWriter, r *http.Request)

type GetJobRunErrorBadRequest ¶

type GetJobRunErrorBadRequest struct {

	/*
	  In: Body
	*/
	Payload *models.Error `json:"body,omitempty"`
}

GetJobRunErrorBadRequest Error response

swagger:response getJobRunErrorBadRequest

func NewGetJobRunErrorBadRequest ¶

func NewGetJobRunErrorBadRequest() *GetJobRunErrorBadRequest

NewGetJobRunErrorBadRequest creates GetJobRunErrorBadRequest with default headers values

func (*GetJobRunErrorBadRequest) SetPayload ¶

func (o *GetJobRunErrorBadRequest) SetPayload(payload *models.Error)

SetPayload sets the payload to the get job run error bad request response

func (*GetJobRunErrorBadRequest) WithPayload ¶

WithPayload adds the payload to the get job run error bad request response

func (*GetJobRunErrorBadRequest) WriteResponse ¶

func (o *GetJobRunErrorBadRequest) WriteResponse(rw http.ResponseWriter, producer runtime.Producer)

WriteResponse to the client

type GetJobRunErrorBody ¶

type GetJobRunErrorBody struct {

	// run Id
	// Required: true
	RunID string `json:"runId"`
}

GetJobRunErrorBody get job run error body

swagger:model GetJobRunErrorBody

func (*GetJobRunErrorBody) ContextValidate ¶

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

ContextValidate validates this get job run error body based on context it is used

func (*GetJobRunErrorBody) MarshalBinary ¶

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

MarshalBinary interface implementation

func (*GetJobRunErrorBody) UnmarshalBinary ¶

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

UnmarshalBinary interface implementation

func (*GetJobRunErrorBody) Validate ¶

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

Validate validates this get job run error body

type GetJobRunErrorDefault ¶

type GetJobRunErrorDefault struct {

	/*
	  In: Body
	*/
	Payload *models.Error `json:"body,omitempty"`
	// contains filtered or unexported fields
}

GetJobRunErrorDefault Error response

swagger:response getJobRunErrorDefault

func NewGetJobRunErrorDefault ¶

func NewGetJobRunErrorDefault(code int) *GetJobRunErrorDefault

NewGetJobRunErrorDefault creates GetJobRunErrorDefault with default headers values

func (*GetJobRunErrorDefault) SetPayload ¶

func (o *GetJobRunErrorDefault) SetPayload(payload *models.Error)

SetPayload sets the payload to the get job run error default response

func (*GetJobRunErrorDefault) SetStatusCode ¶

func (o *GetJobRunErrorDefault) SetStatusCode(code int)

SetStatusCode sets the status to the get job run error default response

func (*GetJobRunErrorDefault) WithPayload ¶

func (o *GetJobRunErrorDefault) WithPayload(payload *models.Error) *GetJobRunErrorDefault

WithPayload adds the payload to the get job run error default response

func (*GetJobRunErrorDefault) WithStatusCode ¶

func (o *GetJobRunErrorDefault) WithStatusCode(code int) *GetJobRunErrorDefault

WithStatusCode adds the status to the get job run error default response

func (*GetJobRunErrorDefault) WriteResponse ¶

func (o *GetJobRunErrorDefault) WriteResponse(rw http.ResponseWriter, producer runtime.Producer)

WriteResponse to the client

type GetJobRunErrorHandler ¶

type GetJobRunErrorHandler interface {
	Handle(GetJobRunErrorParams) middleware.Responder
}

GetJobRunErrorHandler interface for that can handle valid get job run error params

type GetJobRunErrorHandlerFunc ¶

type GetJobRunErrorHandlerFunc func(GetJobRunErrorParams) middleware.Responder

GetJobRunErrorHandlerFunc turns a function with the right signature into a get job run error handler

func (GetJobRunErrorHandlerFunc) Handle ¶

Handle executing the request and returning a response

type GetJobRunErrorOK ¶

type GetJobRunErrorOK struct {

	/*
	  In: Body
	*/
	Payload *GetJobRunErrorOKBody `json:"body,omitempty"`
}

GetJobRunErrorOK Returns error for specific job run (if present)

swagger:response getJobRunErrorOK

func NewGetJobRunErrorOK ¶

func NewGetJobRunErrorOK() *GetJobRunErrorOK

NewGetJobRunErrorOK creates GetJobRunErrorOK with default headers values

func (*GetJobRunErrorOK) SetPayload ¶

func (o *GetJobRunErrorOK) SetPayload(payload *GetJobRunErrorOKBody)

SetPayload sets the payload to the get job run error o k response

func (*GetJobRunErrorOK) WithPayload ¶

func (o *GetJobRunErrorOK) WithPayload(payload *GetJobRunErrorOKBody) *GetJobRunErrorOK

WithPayload adds the payload to the get job run error o k response

func (*GetJobRunErrorOK) WriteResponse ¶

func (o *GetJobRunErrorOK) WriteResponse(rw http.ResponseWriter, producer runtime.Producer)

WriteResponse to the client

type GetJobRunErrorOKBody ¶

type GetJobRunErrorOKBody struct {

	// Error for individual job run
	ErrorString string `json:"errorString,omitempty"`
}

GetJobRunErrorOKBody get job run error o k body

swagger:model GetJobRunErrorOKBody

func (*GetJobRunErrorOKBody) ContextValidate ¶

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

ContextValidate validates this get job run error o k body based on context it is used

func (*GetJobRunErrorOKBody) MarshalBinary ¶

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

MarshalBinary interface implementation

func (*GetJobRunErrorOKBody) UnmarshalBinary ¶

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

UnmarshalBinary interface implementation

func (*GetJobRunErrorOKBody) Validate ¶

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

Validate validates this get job run error o k body

type GetJobRunErrorParams ¶

type GetJobRunErrorParams struct {

	// HTTP Request Object
	HTTPRequest *http.Request `json:"-"`

	/*
	  Required: true
	  In: body
	*/
	GetJobRunErrorRequest GetJobRunErrorBody
}

GetJobRunErrorParams contains all the bound params for the get job run error operation typically these are obtained from a http.Request

swagger:parameters getJobRunError

func NewGetJobRunErrorParams ¶

func NewGetJobRunErrorParams() GetJobRunErrorParams

NewGetJobRunErrorParams creates a new GetJobRunErrorParams object

There are no default values defined in the spec.

func (*GetJobRunErrorParams) BindRequest ¶

func (o *GetJobRunErrorParams) BindRequest(r *http.Request, route *middleware.MatchedRoute) error

BindRequest both binds and validates a request, it assumes that complex things implement a Validatable(strfmt.Registry) error interface for simple values it will use straight method calls.

To ensure default values, the struct must have been initialized with NewGetJobRunErrorParams() beforehand.

type GetJobRunErrorURL ¶

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

GetJobRunErrorURL generates an URL for the get job run error operation

func (*GetJobRunErrorURL) Build ¶

func (o *GetJobRunErrorURL) Build() (*url.URL, error)

Build a url path and query string

func (*GetJobRunErrorURL) BuildFull ¶

func (o *GetJobRunErrorURL) BuildFull(scheme, host string) (*url.URL, error)

BuildFull builds a full url with scheme, host, path and query string

func (*GetJobRunErrorURL) Must ¶

func (o *GetJobRunErrorURL) Must(u *url.URL, err error) *url.URL

Must is a helper function to panic when the url builder returns an error

func (*GetJobRunErrorURL) SetBasePath ¶

func (o *GetJobRunErrorURL) SetBasePath(bp string)

SetBasePath sets the base path for this url builder, only required when it's different from the base path specified in the swagger spec. When the value of the base path is an empty string

func (*GetJobRunErrorURL) String ¶

func (o *GetJobRunErrorURL) String() string

String returns the string representation of the path with query string

func (*GetJobRunErrorURL) StringFull ¶

func (o *GetJobRunErrorURL) StringFull(scheme, host string) string

StringFull returns the string representation of a complete url

func (*GetJobRunErrorURL) WithBasePath ¶

func (o *GetJobRunErrorURL) WithBasePath(bp string) *GetJobRunErrorURL

WithBasePath sets the base path for this url builder, only required when it's different from the base path specified in the swagger spec. When the value of the base path is an empty string

type GetJobSpec ¶

type GetJobSpec struct {
	Context *middleware.Context
	Handler GetJobSpecHandler
}
GetJobSpec swagger:route POST /api/v1/jobSpec getJobSpec

GetJobSpec get job spec API

func NewGetJobSpec ¶

func NewGetJobSpec(ctx *middleware.Context, handler GetJobSpecHandler) *GetJobSpec

NewGetJobSpec creates a new http.Handler for the get job spec operation

func (*GetJobSpec) ServeHTTP ¶

func (o *GetJobSpec) ServeHTTP(rw http.ResponseWriter, r *http.Request)

type GetJobSpecBadRequest ¶

type GetJobSpecBadRequest struct {

	/*
	  In: Body
	*/
	Payload *models.Error `json:"body,omitempty"`
}

GetJobSpecBadRequest Error response

swagger:response getJobSpecBadRequest

func NewGetJobSpecBadRequest ¶

func NewGetJobSpecBadRequest() *GetJobSpecBadRequest

NewGetJobSpecBadRequest creates GetJobSpecBadRequest with default headers values

func (*GetJobSpecBadRequest) SetPayload ¶

func (o *GetJobSpecBadRequest) SetPayload(payload *models.Error)

SetPayload sets the payload to the get job spec bad request response

func (*GetJobSpecBadRequest) WithPayload ¶

func (o *GetJobSpecBadRequest) WithPayload(payload *models.Error) *GetJobSpecBadRequest

WithPayload adds the payload to the get job spec bad request response

func (*GetJobSpecBadRequest) WriteResponse ¶

func (o *GetJobSpecBadRequest) WriteResponse(rw http.ResponseWriter, producer runtime.Producer)

WriteResponse to the client

type GetJobSpecBody ¶

type GetJobSpecBody struct {

	// job Id
	// Required: true
	JobID string `json:"jobId"`
}

GetJobSpecBody get job spec body

swagger:model GetJobSpecBody

func (*GetJobSpecBody) ContextValidate ¶

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

ContextValidate validates this get job spec body based on context it is used

func (*GetJobSpecBody) MarshalBinary ¶

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

MarshalBinary interface implementation

func (*GetJobSpecBody) UnmarshalBinary ¶

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

UnmarshalBinary interface implementation

func (*GetJobSpecBody) Validate ¶

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

Validate validates this get job spec body

type GetJobSpecDefault ¶

type GetJobSpecDefault struct {

	/*
	  In: Body
	*/
	Payload *models.Error `json:"body,omitempty"`
	// contains filtered or unexported fields
}

GetJobSpecDefault Error response

swagger:response getJobSpecDefault

func NewGetJobSpecDefault ¶

func NewGetJobSpecDefault(code int) *GetJobSpecDefault

NewGetJobSpecDefault creates GetJobSpecDefault with default headers values

func (*GetJobSpecDefault) SetPayload ¶

func (o *GetJobSpecDefault) SetPayload(payload *models.Error)

SetPayload sets the payload to the get job spec default response

func (*GetJobSpecDefault) SetStatusCode ¶

func (o *GetJobSpecDefault) SetStatusCode(code int)

SetStatusCode sets the status to the get job spec default response

func (*GetJobSpecDefault) WithPayload ¶

func (o *GetJobSpecDefault) WithPayload(payload *models.Error) *GetJobSpecDefault

WithPayload adds the payload to the get job spec default response

func (*GetJobSpecDefault) WithStatusCode ¶

func (o *GetJobSpecDefault) WithStatusCode(code int) *GetJobSpecDefault

WithStatusCode adds the status to the get job spec default response

func (*GetJobSpecDefault) WriteResponse ¶

func (o *GetJobSpecDefault) WriteResponse(rw http.ResponseWriter, producer runtime.Producer)

WriteResponse to the client

type GetJobSpecHandler ¶

type GetJobSpecHandler interface {
	Handle(GetJobSpecParams) middleware.Responder
}

GetJobSpecHandler interface for that can handle valid get job spec params

type GetJobSpecHandlerFunc ¶

type GetJobSpecHandlerFunc func(GetJobSpecParams) middleware.Responder

GetJobSpecHandlerFunc turns a function with the right signature into a get job spec handler

func (GetJobSpecHandlerFunc) Handle ¶

Handle executing the request and returning a response

type GetJobSpecOK ¶

type GetJobSpecOK struct {

	/*
	  In: Body
	*/
	Payload *GetJobSpecOKBody `json:"body,omitempty"`
}

GetJobSpecOK Returns raw Job spec

swagger:response getJobSpecOK

func NewGetJobSpecOK ¶

func NewGetJobSpecOK() *GetJobSpecOK

NewGetJobSpecOK creates GetJobSpecOK with default headers values

func (*GetJobSpecOK) SetPayload ¶

func (o *GetJobSpecOK) SetPayload(payload *GetJobSpecOKBody)

SetPayload sets the payload to the get job spec o k response

func (*GetJobSpecOK) WithPayload ¶

func (o *GetJobSpecOK) WithPayload(payload *GetJobSpecOKBody) *GetJobSpecOK

WithPayload adds the payload to the get job spec o k response

func (*GetJobSpecOK) WriteResponse ¶

func (o *GetJobSpecOK) WriteResponse(rw http.ResponseWriter, producer runtime.Producer)

WriteResponse to the client

type GetJobSpecOKBody ¶

type GetJobSpecOKBody struct {

	// Job Spec object
	Job interface{} `json:"job,omitempty"`
}

GetJobSpecOKBody get job spec o k body

swagger:model GetJobSpecOKBody

func (*GetJobSpecOKBody) ContextValidate ¶

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

ContextValidate validates this get job spec o k body based on context it is used

func (*GetJobSpecOKBody) MarshalBinary ¶

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

MarshalBinary interface implementation

func (*GetJobSpecOKBody) UnmarshalBinary ¶

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

UnmarshalBinary interface implementation

func (*GetJobSpecOKBody) Validate ¶

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

Validate validates this get job spec o k body

type GetJobSpecParams ¶

type GetJobSpecParams struct {

	// HTTP Request Object
	HTTPRequest *http.Request `json:"-"`

	/*
	  Required: true
	  In: body
	*/
	GetJobSpecRequest GetJobSpecBody
}

GetJobSpecParams contains all the bound params for the get job spec operation typically these are obtained from a http.Request

swagger:parameters getJobSpec

func NewGetJobSpecParams ¶

func NewGetJobSpecParams() GetJobSpecParams

NewGetJobSpecParams creates a new GetJobSpecParams object

There are no default values defined in the spec.

func (*GetJobSpecParams) BindRequest ¶

func (o *GetJobSpecParams) BindRequest(r *http.Request, route *middleware.MatchedRoute) error

BindRequest both binds and validates a request, it assumes that complex things implement a Validatable(strfmt.Registry) error interface for simple values it will use straight method calls.

To ensure default values, the struct must have been initialized with NewGetJobSpecParams() beforehand.

type GetJobSpecURL ¶

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

GetJobSpecURL generates an URL for the get job spec operation

func (*GetJobSpecURL) Build ¶

func (o *GetJobSpecURL) Build() (*url.URL, error)

Build a url path and query string

func (*GetJobSpecURL) BuildFull ¶

func (o *GetJobSpecURL) BuildFull(scheme, host string) (*url.URL, error)

BuildFull builds a full url with scheme, host, path and query string

func (*GetJobSpecURL) Must ¶

func (o *GetJobSpecURL) Must(u *url.URL, err error) *url.URL

Must is a helper function to panic when the url builder returns an error

func (*GetJobSpecURL) SetBasePath ¶

func (o *GetJobSpecURL) SetBasePath(bp string)

SetBasePath sets the base path for this url builder, only required when it's different from the base path specified in the swagger spec. When the value of the base path is an empty string

func (*GetJobSpecURL) String ¶

func (o *GetJobSpecURL) String() string

String returns the string representation of the path with query string

func (*GetJobSpecURL) StringFull ¶

func (o *GetJobSpecURL) StringFull(scheme, host string) string

StringFull returns the string representation of a complete url

func (*GetJobSpecURL) WithBasePath ¶

func (o *GetJobSpecURL) WithBasePath(bp string) *GetJobSpecURL

WithBasePath sets the base path for this url builder, only required when it's different from the base path specified in the swagger spec. When the value of the base path is an empty string

type GetJobs ¶

type GetJobs struct {
	Context *middleware.Context
	Handler GetJobsHandler
}
GetJobs swagger:route POST /api/v1/jobs getJobs

GetJobs get jobs API

func NewGetJobs ¶

func NewGetJobs(ctx *middleware.Context, handler GetJobsHandler) *GetJobs

NewGetJobs creates a new http.Handler for the get jobs operation

func (*GetJobs) ServeHTTP ¶

func (o *GetJobs) ServeHTTP(rw http.ResponseWriter, r *http.Request)

type GetJobsBadRequest ¶

type GetJobsBadRequest struct {

	/*
	  In: Body
	*/
	Payload *models.Error `json:"body,omitempty"`
}

GetJobsBadRequest Error response

swagger:response getJobsBadRequest

func NewGetJobsBadRequest ¶

func NewGetJobsBadRequest() *GetJobsBadRequest

NewGetJobsBadRequest creates GetJobsBadRequest with default headers values

func (*GetJobsBadRequest) SetPayload ¶

func (o *GetJobsBadRequest) SetPayload(payload *models.Error)

SetPayload sets the payload to the get jobs bad request response

func (*GetJobsBadRequest) WithPayload ¶

func (o *GetJobsBadRequest) WithPayload(payload *models.Error) *GetJobsBadRequest

WithPayload adds the payload to the get jobs bad request response

func (*GetJobsBadRequest) WriteResponse ¶

func (o *GetJobsBadRequest) WriteResponse(rw http.ResponseWriter, producer runtime.Producer)

WriteResponse to the client

type GetJobsBody ¶

type GetJobsBody struct {

	// Only include jobs in active job sets
	ActiveJobSets bool `json:"activeJobSets,omitempty"`

	// Filters to apply to jobs.
	// Required: true
	Filters []*models.Filter `json:"filters"`

	// Ordering to apply to jobs.
	// Required: true
	Order *models.Order `json:"order"`

	// First elements to ignore from the full set of results. Used for pagination.
	Skip int64 `json:"skip,omitempty"`

	// Number of jobs to fetch.
	Take int64 `json:"take,omitempty"`
}

GetJobsBody get jobs body

swagger:model GetJobsBody

func (*GetJobsBody) ContextValidate ¶

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

ContextValidate validate this get jobs body based on the context it is used

func (*GetJobsBody) MarshalBinary ¶

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

MarshalBinary interface implementation

func (*GetJobsBody) UnmarshalBinary ¶

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

UnmarshalBinary interface implementation

func (*GetJobsBody) Validate ¶

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

Validate validates this get jobs body

type GetJobsDefault ¶

type GetJobsDefault struct {

	/*
	  In: Body
	*/
	Payload *models.Error `json:"body,omitempty"`
	// contains filtered or unexported fields
}

GetJobsDefault Error response

swagger:response getJobsDefault

func NewGetJobsDefault ¶

func NewGetJobsDefault(code int) *GetJobsDefault

NewGetJobsDefault creates GetJobsDefault with default headers values

func (*GetJobsDefault) SetPayload ¶

func (o *GetJobsDefault) SetPayload(payload *models.Error)

SetPayload sets the payload to the get jobs default response

func (*GetJobsDefault) SetStatusCode ¶

func (o *GetJobsDefault) SetStatusCode(code int)

SetStatusCode sets the status to the get jobs default response

func (*GetJobsDefault) WithPayload ¶

func (o *GetJobsDefault) WithPayload(payload *models.Error) *GetJobsDefault

WithPayload adds the payload to the get jobs default response

func (*GetJobsDefault) WithStatusCode ¶

func (o *GetJobsDefault) WithStatusCode(code int) *GetJobsDefault

WithStatusCode adds the status to the get jobs default response

func (*GetJobsDefault) WriteResponse ¶

func (o *GetJobsDefault) WriteResponse(rw http.ResponseWriter, producer runtime.Producer)

WriteResponse to the client

type GetJobsHandler ¶

type GetJobsHandler interface {
	Handle(GetJobsParams) middleware.Responder
}

GetJobsHandler interface for that can handle valid get jobs params

type GetJobsHandlerFunc ¶

type GetJobsHandlerFunc func(GetJobsParams) middleware.Responder

GetJobsHandlerFunc turns a function with the right signature into a get jobs handler

func (GetJobsHandlerFunc) Handle ¶

Handle executing the request and returning a response

type GetJobsOK ¶

type GetJobsOK struct {

	/*
	  In: Body
	*/
	Payload *GetJobsOKBody `json:"body,omitempty"`
}

GetJobsOK Returns jobs from API

swagger:response getJobsOK

func NewGetJobsOK ¶

func NewGetJobsOK() *GetJobsOK

NewGetJobsOK creates GetJobsOK with default headers values

func (*GetJobsOK) SetPayload ¶

func (o *GetJobsOK) SetPayload(payload *GetJobsOKBody)

SetPayload sets the payload to the get jobs o k response

func (*GetJobsOK) WithPayload ¶

func (o *GetJobsOK) WithPayload(payload *GetJobsOKBody) *GetJobsOK

WithPayload adds the payload to the get jobs o k response

func (*GetJobsOK) WriteResponse ¶

func (o *GetJobsOK) WriteResponse(rw http.ResponseWriter, producer runtime.Producer)

WriteResponse to the client

type GetJobsOKBody ¶

type GetJobsOKBody struct {

	// List of jobs found
	Jobs []*models.Job `json:"jobs"`
}

GetJobsOKBody get jobs o k body

swagger:model GetJobsOKBody

func (*GetJobsOKBody) ContextValidate ¶

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

ContextValidate validate this get jobs o k body based on the context it is used

func (*GetJobsOKBody) MarshalBinary ¶

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

MarshalBinary interface implementation

func (*GetJobsOKBody) UnmarshalBinary ¶

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

UnmarshalBinary interface implementation

func (*GetJobsOKBody) Validate ¶

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

Validate validates this get jobs o k body

type GetJobsParams ¶

type GetJobsParams struct {

	// HTTP Request Object
	HTTPRequest *http.Request `json:"-"`

	/*The backend to use for this request.
	  In: query
	*/
	Backend *string
	/*
	  Required: true
	  In: body
	*/
	GetJobsRequest GetJobsBody
}

GetJobsParams contains all the bound params for the get jobs operation typically these are obtained from a http.Request

swagger:parameters getJobs

func NewGetJobsParams ¶

func NewGetJobsParams() GetJobsParams

NewGetJobsParams creates a new GetJobsParams object

There are no default values defined in the spec.

func (*GetJobsParams) BindRequest ¶

func (o *GetJobsParams) BindRequest(r *http.Request, route *middleware.MatchedRoute) error

BindRequest both binds and validates a request, it assumes that complex things implement a Validatable(strfmt.Registry) error interface for simple values it will use straight method calls.

To ensure default values, the struct must have been initialized with NewGetJobsParams() beforehand.

type GetJobsURL ¶

type GetJobsURL struct {
	Backend *string
	// contains filtered or unexported fields
}

GetJobsURL generates an URL for the get jobs operation

func (*GetJobsURL) Build ¶

func (o *GetJobsURL) Build() (*url.URL, error)

Build a url path and query string

func (*GetJobsURL) BuildFull ¶

func (o *GetJobsURL) BuildFull(scheme, host string) (*url.URL, error)

BuildFull builds a full url with scheme, host, path and query string

func (*GetJobsURL) Must ¶

func (o *GetJobsURL) Must(u *url.URL, err error) *url.URL

Must is a helper function to panic when the url builder returns an error

func (*GetJobsURL) SetBasePath ¶

func (o *GetJobsURL) SetBasePath(bp string)

SetBasePath sets the base path for this url builder, only required when it's different from the base path specified in the swagger spec. When the value of the base path is an empty string

func (*GetJobsURL) String ¶

func (o *GetJobsURL) String() string

String returns the string representation of the path with query string

func (*GetJobsURL) StringFull ¶

func (o *GetJobsURL) StringFull(scheme, host string) string

StringFull returns the string representation of a complete url

func (*GetJobsURL) WithBasePath ¶

func (o *GetJobsURL) WithBasePath(bp string) *GetJobsURL

WithBasePath sets the base path for this url builder, only required when it's different from the base path specified in the swagger spec. When the value of the base path is an empty string

type GroupJobs ¶

type GroupJobs struct {
	Context *middleware.Context
	Handler GroupJobsHandler
}
GroupJobs swagger:route POST /api/v1/jobGroups groupJobs

GroupJobs group jobs API

func NewGroupJobs ¶

func NewGroupJobs(ctx *middleware.Context, handler GroupJobsHandler) *GroupJobs

NewGroupJobs creates a new http.Handler for the group jobs operation

func (*GroupJobs) ServeHTTP ¶

func (o *GroupJobs) ServeHTTP(rw http.ResponseWriter, r *http.Request)

type GroupJobsBadRequest ¶

type GroupJobsBadRequest struct {

	/*
	  In: Body
	*/
	Payload *models.Error `json:"body,omitempty"`
}

GroupJobsBadRequest Error response

swagger:response groupJobsBadRequest

func NewGroupJobsBadRequest ¶

func NewGroupJobsBadRequest() *GroupJobsBadRequest

NewGroupJobsBadRequest creates GroupJobsBadRequest with default headers values

func (*GroupJobsBadRequest) SetPayload ¶

func (o *GroupJobsBadRequest) SetPayload(payload *models.Error)

SetPayload sets the payload to the group jobs bad request response

func (*GroupJobsBadRequest) WithPayload ¶

func (o *GroupJobsBadRequest) WithPayload(payload *models.Error) *GroupJobsBadRequest

WithPayload adds the payload to the group jobs bad request response

func (*GroupJobsBadRequest) WriteResponse ¶

func (o *GroupJobsBadRequest) WriteResponse(rw http.ResponseWriter, producer runtime.Producer)

WriteResponse to the client

type GroupJobsBody ¶

type GroupJobsBody struct {

	// Only include jobs in active job sets
	ActiveJobSets bool `json:"activeJobSets,omitempty"`

	// Additional fields to compute aggregates on
	// Required: true
	Aggregates []string `json:"aggregates"`

	// Filters to apply to jobs before grouping.
	// Required: true
	Filters []*models.Filter `json:"filters"`

	// grouped field
	// Required: true
	GroupedField *GroupJobsParamsBodyGroupedField `json:"groupedField"`

	// Ordering to apply to job groups.
	// Required: true
	Order *models.Order `json:"order"`

	// First elements to ignore from the full set of results. Used for pagination.
	Skip int64 `json:"skip,omitempty"`

	// Number of job groups to fetch.
	Take int64 `json:"take,omitempty"`
}

GroupJobsBody group jobs body

swagger:model GroupJobsBody

func (*GroupJobsBody) ContextValidate ¶

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

ContextValidate validate this group jobs body based on the context it is used

func (*GroupJobsBody) MarshalBinary ¶

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

MarshalBinary interface implementation

func (*GroupJobsBody) UnmarshalBinary ¶

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

UnmarshalBinary interface implementation

func (*GroupJobsBody) Validate ¶

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

Validate validates this group jobs body

type GroupJobsDefault ¶

type GroupJobsDefault struct {

	/*
	  In: Body
	*/
	Payload *models.Error `json:"body,omitempty"`
	// contains filtered or unexported fields
}

GroupJobsDefault Error response

swagger:response groupJobsDefault

func NewGroupJobsDefault ¶

func NewGroupJobsDefault(code int) *GroupJobsDefault

NewGroupJobsDefault creates GroupJobsDefault with default headers values

func (*GroupJobsDefault) SetPayload ¶

func (o *GroupJobsDefault) SetPayload(payload *models.Error)

SetPayload sets the payload to the group jobs default response

func (*GroupJobsDefault) SetStatusCode ¶

func (o *GroupJobsDefault) SetStatusCode(code int)

SetStatusCode sets the status to the group jobs default response

func (*GroupJobsDefault) WithPayload ¶

func (o *GroupJobsDefault) WithPayload(payload *models.Error) *GroupJobsDefault

WithPayload adds the payload to the group jobs default response

func (*GroupJobsDefault) WithStatusCode ¶

func (o *GroupJobsDefault) WithStatusCode(code int) *GroupJobsDefault

WithStatusCode adds the status to the group jobs default response

func (*GroupJobsDefault) WriteResponse ¶

func (o *GroupJobsDefault) WriteResponse(rw http.ResponseWriter, producer runtime.Producer)

WriteResponse to the client

type GroupJobsHandler ¶

type GroupJobsHandler interface {
	Handle(GroupJobsParams) middleware.Responder
}

GroupJobsHandler interface for that can handle valid group jobs params

type GroupJobsHandlerFunc ¶

type GroupJobsHandlerFunc func(GroupJobsParams) middleware.Responder

GroupJobsHandlerFunc turns a function with the right signature into a group jobs handler

func (GroupJobsHandlerFunc) Handle ¶

Handle executing the request and returning a response

type GroupJobsOK ¶

type GroupJobsOK struct {

	/*
	  In: Body
	*/
	Payload *GroupJobsOKBody `json:"body,omitempty"`
}

GroupJobsOK Returns job groups from API

swagger:response groupJobsOK

func NewGroupJobsOK ¶

func NewGroupJobsOK() *GroupJobsOK

NewGroupJobsOK creates GroupJobsOK with default headers values

func (*GroupJobsOK) SetPayload ¶

func (o *GroupJobsOK) SetPayload(payload *GroupJobsOKBody)

SetPayload sets the payload to the group jobs o k response

func (*GroupJobsOK) WithPayload ¶

func (o *GroupJobsOK) WithPayload(payload *GroupJobsOKBody) *GroupJobsOK

WithPayload adds the payload to the group jobs o k response

func (*GroupJobsOK) WriteResponse ¶

func (o *GroupJobsOK) WriteResponse(rw http.ResponseWriter, producer runtime.Producer)

WriteResponse to the client

type GroupJobsOKBody ¶

type GroupJobsOKBody struct {

	// List of Job groups
	// Required: true
	Groups []*models.Group `json:"groups"`
}

GroupJobsOKBody group jobs o k body

swagger:model GroupJobsOKBody

func (*GroupJobsOKBody) ContextValidate ¶

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

ContextValidate validate this group jobs o k body based on the context it is used

func (*GroupJobsOKBody) MarshalBinary ¶

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

MarshalBinary interface implementation

func (*GroupJobsOKBody) UnmarshalBinary ¶

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

UnmarshalBinary interface implementation

func (*GroupJobsOKBody) Validate ¶

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

Validate validates this group jobs o k body

type GroupJobsParams ¶

type GroupJobsParams struct {

	// HTTP Request Object
	HTTPRequest *http.Request `json:"-"`

	/*The backend to use for this request.
	  In: query
	*/
	Backend *string
	/*
	  Required: true
	  In: body
	*/
	GroupJobsRequest GroupJobsBody
}

GroupJobsParams contains all the bound params for the group jobs operation typically these are obtained from a http.Request

swagger:parameters groupJobs

func NewGroupJobsParams ¶

func NewGroupJobsParams() GroupJobsParams

NewGroupJobsParams creates a new GroupJobsParams object

There are no default values defined in the spec.

func (*GroupJobsParams) BindRequest ¶

func (o *GroupJobsParams) BindRequest(r *http.Request, route *middleware.MatchedRoute) error

BindRequest both binds and validates a request, it assumes that complex things implement a Validatable(strfmt.Registry) error interface for simple values it will use straight method calls.

To ensure default values, the struct must have been initialized with NewGroupJobsParams() beforehand.

type GroupJobsParamsBodyGroupedField ¶ added in v0.3.70

type GroupJobsParamsBodyGroupedField struct {

	// Field or annotation key to group by
	// Required: true
	Field string `json:"field"`

	// is annotation
	IsAnnotation bool `json:"isAnnotation,omitempty"`
}

GroupJobsParamsBodyGroupedField group jobs params body grouped field

swagger:model GroupJobsParamsBodyGroupedField

func (*GroupJobsParamsBodyGroupedField) ContextValidate ¶ added in v0.3.70

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

ContextValidate validates this group jobs params body grouped field based on context it is used

func (*GroupJobsParamsBodyGroupedField) MarshalBinary ¶ added in v0.3.70

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

MarshalBinary interface implementation

func (*GroupJobsParamsBodyGroupedField) UnmarshalBinary ¶ added in v0.3.70

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

UnmarshalBinary interface implementation

func (*GroupJobsParamsBodyGroupedField) Validate ¶ added in v0.3.70

Validate validates this group jobs params body grouped field

type GroupJobsURL ¶

type GroupJobsURL struct {
	Backend *string
	// contains filtered or unexported fields
}

GroupJobsURL generates an URL for the group jobs operation

func (*GroupJobsURL) Build ¶

func (o *GroupJobsURL) Build() (*url.URL, error)

Build a url path and query string

func (*GroupJobsURL) BuildFull ¶

func (o *GroupJobsURL) BuildFull(scheme, host string) (*url.URL, error)

BuildFull builds a full url with scheme, host, path and query string

func (*GroupJobsURL) Must ¶

func (o *GroupJobsURL) Must(u *url.URL, err error) *url.URL

Must is a helper function to panic when the url builder returns an error

func (*GroupJobsURL) SetBasePath ¶

func (o *GroupJobsURL) SetBasePath(bp string)

SetBasePath sets the base path for this url builder, only required when it's different from the base path specified in the swagger spec. When the value of the base path is an empty string

func (*GroupJobsURL) String ¶

func (o *GroupJobsURL) String() string

String returns the string representation of the path with query string

func (*GroupJobsURL) StringFull ¶

func (o *GroupJobsURL) StringFull(scheme, host string) string

StringFull returns the string representation of a complete url

func (*GroupJobsURL) WithBasePath ¶

func (o *GroupJobsURL) WithBasePath(bp string) *GroupJobsURL

WithBasePath sets the base path for this url builder, only required when it's different from the base path specified in the swagger spec. When the value of the base path is an empty string

type LookoutAPI ¶

type LookoutAPI struct {
	Middleware func(middleware.Builder) http.Handler

	// BasicAuthenticator generates a runtime.Authenticator from the supplied basic auth function.
	// It has a default implementation in the security package, however you can replace it for your particular usage.
	BasicAuthenticator func(security.UserPassAuthentication) runtime.Authenticator

	// APIKeyAuthenticator generates a runtime.Authenticator from the supplied token auth function.
	// It has a default implementation in the security package, however you can replace it for your particular usage.
	APIKeyAuthenticator func(string, string, security.TokenAuthentication) runtime.Authenticator

	// BearerAuthenticator generates a runtime.Authenticator from the supplied bearer token auth function.
	// It has a default implementation in the security package, however you can replace it for your particular usage.
	BearerAuthenticator func(string, security.ScopedTokenAuthentication) runtime.Authenticator

	// JSONConsumer registers a consumer for the following mime types:
	//   - application/json
	JSONConsumer runtime.Consumer

	// JSONProducer registers a producer for the following mime types:
	//   - application/json
	JSONProducer runtime.Producer
	// TxtProducer registers a producer for the following mime types:
	//   - text/plain
	TxtProducer runtime.Producer

	// GetHealthHandler sets the operation handler for the get health operation
	GetHealthHandler GetHealthHandler
	// GetJobErrorHandler sets the operation handler for the get job error operation
	GetJobErrorHandler GetJobErrorHandler
	// GetJobRunDebugMessageHandler sets the operation handler for the get job run debug message operation
	GetJobRunDebugMessageHandler GetJobRunDebugMessageHandler
	// GetJobRunErrorHandler sets the operation handler for the get job run error operation
	GetJobRunErrorHandler GetJobRunErrorHandler
	// GetJobSpecHandler sets the operation handler for the get job spec operation
	GetJobSpecHandler GetJobSpecHandler
	// GetJobsHandler sets the operation handler for the get jobs operation
	GetJobsHandler GetJobsHandler
	// GroupJobsHandler sets the operation handler for the group jobs operation
	GroupJobsHandler GroupJobsHandler

	// ServeError is called when an error is received, there is a default handler
	// but you can set your own with this
	ServeError func(http.ResponseWriter, *http.Request, error)

	// PreServerShutdown is called before the HTTP(S) server is shutdown
	// This allows for custom functions to get executed before the HTTP(S) server stops accepting traffic
	PreServerShutdown func()

	// ServerShutdown is called when the HTTP(S) server is shut down and done
	// handling all active connections and does not accept connections any more
	ServerShutdown func()

	// Custom command line argument groups with their descriptions
	CommandLineOptionsGroups []swag.CommandLineOptionsGroup

	// User defined logger function.
	Logger func(string, ...interface{})
	// contains filtered or unexported fields
}

LookoutAPI the lookout API

func NewLookoutAPI ¶

func NewLookoutAPI(spec *loads.Document) *LookoutAPI

NewLookoutAPI creates a new Lookout instance

func (*LookoutAPI) AddMiddlewareFor ¶

func (o *LookoutAPI) AddMiddlewareFor(method, path string, builder middleware.Builder)

AddMiddlewareFor adds a http middleware to existing handler

func (*LookoutAPI) AuthenticatorsFor ¶

func (o *LookoutAPI) AuthenticatorsFor(schemes map[string]spec.SecurityScheme) map[string]runtime.Authenticator

AuthenticatorsFor gets the authenticators for the specified security schemes

func (*LookoutAPI) Authorizer ¶

func (o *LookoutAPI) Authorizer() runtime.Authorizer

Authorizer returns the registered authorizer

func (*LookoutAPI) ConsumersFor ¶

func (o *LookoutAPI) ConsumersFor(mediaTypes []string) map[string]runtime.Consumer

ConsumersFor gets the consumers for the specified media types. MIME type parameters are ignored here.

func (*LookoutAPI) Context ¶

func (o *LookoutAPI) Context() *middleware.Context

Context returns the middleware context for the lookout API

func (*LookoutAPI) DefaultConsumes ¶

func (o *LookoutAPI) DefaultConsumes() string

DefaultConsumes returns the default consumes media type

func (*LookoutAPI) DefaultProduces ¶

func (o *LookoutAPI) DefaultProduces() string

DefaultProduces returns the default produces media type

func (*LookoutAPI) Formats ¶

func (o *LookoutAPI) Formats() strfmt.Registry

Formats returns the registered string formats

func (*LookoutAPI) HandlerFor ¶

func (o *LookoutAPI) HandlerFor(method, path string) (http.Handler, bool)

HandlerFor gets a http.Handler for the provided operation method and path

func (*LookoutAPI) Init ¶

func (o *LookoutAPI) Init()

Init allows you to just initialize the handler cache, you can then recompose the middleware as you see fit

func (*LookoutAPI) ProducersFor ¶

func (o *LookoutAPI) ProducersFor(mediaTypes []string) map[string]runtime.Producer

ProducersFor gets the producers for the specified media types. MIME type parameters are ignored here.

func (*LookoutAPI) RegisterConsumer ¶

func (o *LookoutAPI) RegisterConsumer(mediaType string, consumer runtime.Consumer)

RegisterConsumer allows you to add (or override) a consumer for a media type.

func (*LookoutAPI) RegisterFormat ¶

func (o *LookoutAPI) RegisterFormat(name string, format strfmt.Format, validator strfmt.Validator)

RegisterFormat registers a custom format validator

func (*LookoutAPI) RegisterProducer ¶

func (o *LookoutAPI) RegisterProducer(mediaType string, producer runtime.Producer)

RegisterProducer allows you to add (or override) a producer for a media type.

func (*LookoutAPI) Serve ¶

func (o *LookoutAPI) Serve(builder middleware.Builder) http.Handler

Serve creates a http handler to serve the API over HTTP can be used directly in http.ListenAndServe(":8000", api.Serve(nil))

func (*LookoutAPI) ServeErrorFor ¶

func (o *LookoutAPI) ServeErrorFor(operationID string) func(http.ResponseWriter, *http.Request, error)

ServeErrorFor gets a error handler for a given operation id

func (*LookoutAPI) SetDefaultConsumes ¶

func (o *LookoutAPI) SetDefaultConsumes(mediaType string)

SetDefaultConsumes returns the default consumes media type

func (*LookoutAPI) SetDefaultProduces ¶

func (o *LookoutAPI) SetDefaultProduces(mediaType string)

SetDefaultProduces sets the default produces media type

func (*LookoutAPI) SetSpec ¶

func (o *LookoutAPI) SetSpec(spec *loads.Document)

SetSpec sets a spec that will be served for the clients.

func (*LookoutAPI) UseRedoc ¶

func (o *LookoutAPI) UseRedoc()

UseRedoc for documentation at /docs

func (*LookoutAPI) UseSwaggerUI ¶

func (o *LookoutAPI) UseSwaggerUI()

UseSwaggerUI for documentation at /docs

func (*LookoutAPI) Validate ¶

func (o *LookoutAPI) Validate() error

Validate validates the registrations in the LookoutAPI

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL