Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var RunFlowValidator = jio.Object().Keys(jio.K{ "primaryRequestArgs": jio.Object().Keys(jio.K{ "namespace": jio.String().Required(), "name": jio.String().Required(), "version": jio.Number().Integer().Required(), }), "requestArgs": jio.Object().Required(), "requestTags": jio.Array().Required(), })
RunFlowValidator ...
Functions ¶
This section is empty.
Types ¶
type HTTPError ¶
type HTTPError struct {
ErrorCode int `json:"error_code"`
Message string `json:"message"`
UserMessage string `json:"user_message"`
}
HTTPError data model for http error
type Handler ¶
type Handler struct {
// contains filtered or unexported fields
}
Handler handles http rest requests
func CreateHandler ¶
CreateHandler create a new http rest handler
func (*Handler) NewFlowHandler ¶
NewFlowHandler add route for flow
func (*Handler) NewHealthCheckHandler ¶
func (h *Handler) NewHealthCheckHandler()
NewHealthCheckHandler add route for healthcheck
type PipelineFlowHandler ¶
type PipelineFlowHandler struct {
// contains filtered or unexported fields
}
PipelineFlowHandler ...
type SingleProcessorFlowHandler ¶
type SingleProcessorFlowHandler struct {
// contains filtered or unexported fields
}
SingleProcessorFlowHandler ...
func (SingleProcessorFlowHandler) Run ¶
func (h SingleProcessorFlowHandler) Run() http.HandlerFunc
Run ...
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.