Versions in this module Expand all Collapse all v1 v1.0.0 Jan 15, 2024 Changes in this version + const RefFlow + type FlowTesterFactory struct + func (s *FlowTesterFactory) NewService(config *service.Config) (service.Service, error) + type RequestProcessor struct + func NewRequestProcessor() *RequestProcessor + func (rp *RequestProcessor) RestartFlow(restartRequest *RestartRequest) (results map[string]interface{}, err error) + func (rp *RequestProcessor) ResumeFlow(resumeRequest *ResumeRequest) (results map[string]interface{}, err error) + func (rp *RequestProcessor) StartFlow(startRequest *StartRequest) (results map[string]interface{}, err error) + type RestFlowTester struct + func (ft *RestFlowTester) Name() string + func (ft *RestFlowTester) RestartFlow(w http.ResponseWriter, r *http.Request, _ httprouter.Params) + func (ft *RestFlowTester) ResumeFlow(w http.ResponseWriter, r *http.Request, _ httprouter.Params) + func (ft *RestFlowTester) Start() error + func (ft *RestFlowTester) StartFlow(w http.ResponseWriter, r *http.Request, _ httprouter.Params) + func (ft *RestFlowTester) Status(w http.ResponseWriter, r *http.Request, _ httprouter.Params) + func (ft *RestFlowTester) Stop() error + type RestartRequest struct + Data map[string]interface{} + InitialState *instance.IndependentInstance + Interceptor *support.Interceptor + Patch *support.Patch + type ResumeRequest struct + Data map[string]interface{} + Interceptor *support.Interceptor + Patch *support.Patch + State *instance.IndependentInstance + type Server struct + func NewServer(addr string, handler http.Handler) *Server + func (s *Server) InstanceID() string + func (s *Server) IsStarted() bool + func (s *Server) Start() error + func (s *Server) Stop() error + func (s *Server) WaitStop(timeout time.Duration) error + type StartRequest struct + Attrs map[string]interface{} + Data map[string]interface{} + FlowURI string + Interceptor *support.Interceptor + Patch *support.Patch + ReplyTo string
Go to main page