Documentation
¶
Index ¶
- func MakeCancelProcessWorkflowEndpoint(service process.WorkflowService) endpoint.Endpoint
- func MakeGetProcessWorkflowEndpoint(service process.WorkflowService) endpoint.Endpoint
- func MakeListProcessesWorkflowEndpoint(service process.WorkflowService) endpoint.Endpoint
- func MakeLogProcessEventWorkflowEndpoint(service process.WorkflowService) endpoint.Endpoint
- func MakeLogProcessWorkflowEndpoint(service process.WorkflowService) endpoint.Endpoint
- func MakeSignalProcessWorkflowEndpoint(service process.WorkflowService) endpoint.Endpoint
- func RegisterHTTPHandlers(endpoints WorkflowEndpoints, router *mux.Router, ...)
- type CancelProcessWorkflowRequest
- type CancelProcessWorkflowResponse
- type GetProcessWorkflowRequest
- type GetProcessWorkflowResponse
- type ListProcessesWorkflowRequest
- type ListProcessesWorkflowResponse
- type LogProcessEventWorkflowRequest
- type LogProcessEventWorkflowResponse
- type LogProcessWorkflowRequest
- type LogProcessWorkflowResponse
- type SignalProcessWorkflowRequest
- type SignalProcessWorkflowResponse
- type WorkflowEndpoints
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func MakeCancelProcessWorkflowEndpoint ¶
func MakeCancelProcessWorkflowEndpoint(service process.WorkflowService) endpoint.Endpoint
MakeCancelProcessWorkflowEndpoint returns an endpoint for the matching method of the underlying service.
func MakeGetProcessWorkflowEndpoint ¶
func MakeGetProcessWorkflowEndpoint(service process.WorkflowService) endpoint.Endpoint
MakeGetProcessWorkflowEndpoint returns an endpoint for the matching method of the underlying service.
func MakeListProcessesWorkflowEndpoint ¶
func MakeListProcessesWorkflowEndpoint(service process.WorkflowService) endpoint.Endpoint
MakeListProcessesWorkflowEndpoint returns an endpoint for the matching method of the underlying service.
func MakeLogProcessEventWorkflowEndpoint ¶
func MakeLogProcessEventWorkflowEndpoint(service process.WorkflowService) endpoint.Endpoint
MakeLogProcessEventWorkflowEndpoint returns an endpoint for the matching method of the underlying service.
func MakeLogProcessWorkflowEndpoint ¶
func MakeLogProcessWorkflowEndpoint(service process.WorkflowService) endpoint.Endpoint
MakeLogProcessWorkflowEndpoint returns an endpoint for the matching method of the underlying service.
func MakeSignalProcessWorkflowEndpoint ¶
func MakeSignalProcessWorkflowEndpoint(service process.WorkflowService) endpoint.Endpoint
MakeSignalProcessWorkflowEndpoint returns an endpoint for the matching method of the underlying service.
func RegisterHTTPHandlers ¶
func RegisterHTTPHandlers(endpoints WorkflowEndpoints, router *mux.Router, options ...kithttp.ServerOption)
RegisterHTTPHandlers mounts all of the service endpoints into an http.Handler.
Types ¶
type CancelProcessWorkflowRequest ¶
type CancelProcessWorkflowRequest struct {
Id string
}
CancelProcessWorkflowRequest is a request struct for CancelProcess endpoint.
type CancelProcessWorkflowResponse ¶
type CancelProcessWorkflowResponse struct {
Err error
}
CancelProcessWorkflowResponse is a response struct for CancelProcess endpoint.
func (CancelProcessWorkflowResponse) Failed ¶
func (r CancelProcessWorkflowResponse) Failed() error
type GetProcessWorkflowRequest ¶
type GetProcessWorkflowRequest struct {
Id string
}
GetProcessWorkflowRequest is a request struct for GetProcess endpoint.
type GetProcessWorkflowResponse ¶
GetProcessWorkflowResponse is a response struct for GetProcess endpoint.
func (GetProcessWorkflowResponse) Failed ¶
func (r GetProcessWorkflowResponse) Failed() error
type ListProcessesWorkflowRequest ¶
ListProcessesWorkflowRequest is a request struct for ListProcesses endpoint.
type ListProcessesWorkflowResponse ¶
ListProcessesWorkflowResponse is a response struct for ListProcesses endpoint.
func (ListProcessesWorkflowResponse) Failed ¶
func (r ListProcessesWorkflowResponse) Failed() error
type LogProcessEventWorkflowRequest ¶
type LogProcessEventWorkflowRequest struct {
Proc pipeline.ProcessEvent
}
LogProcessEventWorkflowRequest is a request struct for LogProcessEvent endpoint.
type LogProcessEventWorkflowResponse ¶
type LogProcessEventWorkflowResponse struct {
ProcessEvent pipeline.ProcessEvent
Err error
}
LogProcessEventWorkflowResponse is a response struct for LogProcessEvent endpoint.
func (LogProcessEventWorkflowResponse) Failed ¶
func (r LogProcessEventWorkflowResponse) Failed() error
type LogProcessWorkflowRequest ¶
LogProcessWorkflowRequest is a request struct for LogProcess endpoint.
type LogProcessWorkflowResponse ¶
LogProcessWorkflowResponse is a response struct for LogProcess endpoint.
func (LogProcessWorkflowResponse) Failed ¶
func (r LogProcessWorkflowResponse) Failed() error
type SignalProcessWorkflowRequest ¶
SignalProcessWorkflowRequest is a request struct for SignalProcess endpoint.
type SignalProcessWorkflowResponse ¶
type SignalProcessWorkflowResponse struct {
Err error
}
SignalProcessWorkflowResponse is a response struct for SignalProcess endpoint.
func (SignalProcessWorkflowResponse) Failed ¶
func (r SignalProcessWorkflowResponse) Failed() error
type WorkflowEndpoints ¶
type WorkflowEndpoints struct {
CancelProcess endpoint.Endpoint
GetProcess endpoint.Endpoint
ListProcesses endpoint.Endpoint
LogProcess endpoint.Endpoint
LogProcessEvent endpoint.Endpoint
SignalProcess endpoint.Endpoint
}
WorkflowEndpoints collects all of the endpoints that compose the underlying service. It's meant to be used as a helper struct, to collect all of the endpoints into a single parameter.
func MakeWorkflowEndpoints ¶
func MakeWorkflowEndpoints(service process.WorkflowService, middleware ...endpoint.Middleware) WorkflowEndpoints
MakeWorkflowEndpoints returns a(n) WorkflowEndpoints struct where each endpoint invokes the corresponding method on the provided service.
Source Files