operations

package
v0.3.46 Latest Latest
Warning

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

 Go to latest Published: Jan 23, 2023 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 

func (fn GetHealthHandlerFunc) Handle(params GetHealthParams) middleware.Responder

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 

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

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 

func (fn GetJobRunErrorHandlerFunc) Handle(params GetJobRunErrorParams) middleware.Responder

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 

func (fn GetJobSpecHandlerFunc) Handle(params GetJobSpecParams) middleware.Responder

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 {

	// 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.
	// Required: true
	Skip *int64 `json:"skip"`

	// Number of jobs to fetch.
	// Required: true
	Take int64 `json:"take"`
}

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 

func (fn GetJobsHandlerFunc) Handle(params GetJobsParams) middleware.Responder

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 {

	// Total number of jobs
	Count int64 `json:"count,omitempty"`

	// 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:"-"`

	/*
	  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 {
	// 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 {

	// 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"`

	// Field to group jobs by
	// Required: true
	// Min Length: 1
	GroupedField string `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.
	// Required: true
	Skip *int64 `json:"skip"`

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

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 

func (fn GroupJobsHandlerFunc) Handle(params GroupJobsParams) middleware.Responder

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 {

	// Total number of groups
	Count int64 `json:"count,omitempty"`

	// 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:"-"`

	/*
	  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 GroupJobsURL 

type GroupJobsURL struct {
	// 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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.