Versions in this module Expand all Collapse all v0 v0.5.1 Feb 1, 2018 Changes in this version + const ENV_ENABLED + const ENV_SETTING_PORT + const ENV_SETTING_SR_HOST + const FLOW_REF + func DefaultConfig() *util.ServiceConfig + type RequestProcessor struct + func NewRequestProcessor() *RequestProcessor + func (rp *RequestProcessor) RestartFlow(restartRequest *RestartRequest) (results map[string]*data.Attribute, err error) + func (rp *RequestProcessor) ResumeFlow(resumeRequest *ResumeRequest) (results map[string]*data.Attribute, err error) + func (rp *RequestProcessor) StartFlow(startRequest *StartRequest) (results map[string]*data.Attribute, err error) + type RestEngineTester struct + func NewRestEngineTester(config *util.ServiceConfig) *RestEngineTester + func (et *RestEngineTester) Enabled() bool + func (et *RestEngineTester) Name() string + func (et *RestEngineTester) RestartFlow(w http.ResponseWriter, r *http.Request, _ httprouter.Params) + func (et *RestEngineTester) ResumeFlow(w http.ResponseWriter, r *http.Request, _ httprouter.Params) + func (et *RestEngineTester) Start() error + func (et *RestEngineTester) StartFlow(w http.ResponseWriter, r *http.Request, _ httprouter.Params) + func (et *RestEngineTester) Status(w http.ResponseWriter, r *http.Request, _ httprouter.Params) + func (et *RestEngineTester) Stop() error + type RestartRequest struct + Data map[string]interface{} + InitialState *instance.Instance + Interceptor *support.Interceptor + Patch *support.Patch + type ResumeRequest struct + Data map[string]interface{} + Interceptor *support.Interceptor + Patch *support.Patch + State *instance.Instance + 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 []*data.Attribute + Data map[string]interface{} + FlowURI string + Interceptor *support.Interceptor + Patch *support.Patch + ReplyTo string + type TesterProvider struct + func NewExtensionProvider() *TesterProvider + func (fp *TesterProvider) GetFlowModel() *model.FlowModel + func (fp *TesterProvider) GetFlowProvider() provider.Provider + func (fp *TesterProvider) GetFlowTester() *RestEngineTester + func (fp *TesterProvider) GetLinkExprManagerFactory() definition.LinkExprManagerFactory + func (fp *TesterProvider) GetMapperFactory() definition.MapperFactory + func (fp *TesterProvider) GetStateRecorder() instance.StateRecorder