processdriver

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
  • func (r CancelProcessWorkflowResponse) Failed() error
• type GetProcessWorkflowRequest
• type GetProcessWorkflowResponse
  • func (r GetProcessWorkflowResponse) Failed() error
• type ListProcessesWorkflowRequest
• type ListProcessesWorkflowResponse
  • func (r ListProcessesWorkflowResponse) Failed() error
• type LogProcessEventWorkflowRequest
• type LogProcessEventWorkflowResponse
  • func (r LogProcessEventWorkflowResponse) Failed() error
• type LogProcessWorkflowRequest
• type LogProcessWorkflowResponse
  • func (r LogProcessWorkflowResponse) Failed() error
• type SignalProcessWorkflowRequest
• type SignalProcessWorkflowResponse
  • func (r SignalProcessWorkflowResponse) Failed() error
• type WorkflowEndpoints
  • func MakeWorkflowEndpoints(service process.WorkflowService, middleware ...endpoint.Middleware) WorkflowEndpoints

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

type GetProcessWorkflowResponse struct {
	Process pipeline.Process
	Err     error
}

GetProcessWorkflowResponse is a response struct for GetProcess endpoint.

func (GetProcessWorkflowResponse) Failed

func (r GetProcessWorkflowResponse) Failed() error

type ListProcessesWorkflowRequest

type ListProcessesWorkflowRequest struct {
	Query pipeline.Process
}

ListProcessesWorkflowRequest is a request struct for ListProcesses endpoint.

type ListProcessesWorkflowResponse

type ListProcessesWorkflowResponse struct {
	Processes []pipeline.Process
	Err       error
}

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

type LogProcessWorkflowRequest struct {
	Proc pipeline.Process
}

LogProcessWorkflowRequest is a request struct for LogProcess endpoint.

type LogProcessWorkflowResponse

type LogProcessWorkflowResponse struct {
	Process pipeline.Process
	Err     error
}

LogProcessWorkflowResponse is a response struct for LogProcess endpoint.

func (LogProcessWorkflowResponse) Failed

func (r LogProcessWorkflowResponse) Failed() error

type SignalProcessWorkflowRequest

type SignalProcessWorkflowRequest struct {
	Id     string
	Signal string
	Value  interface{}
}

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.