operations

package
v0.4.47 Latest Latest
Warning

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

Go to latest
Published: Apr 28, 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 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 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
	// 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