Versions in this module Expand all Collapse all v0 v0.1.4 Jun 20, 2023 v0.1.3 Apr 24, 2023 v0.1.2 Apr 24, 2023 v0.1.1 Oct 23, 2022 Changes in this version + const DefaultReadTimeoutSecond + const DefaultRedisUrl + const DefaultRetryCount + const DefaultTraceUrl + const DefaultWebServerPort + const DefaultWorkerConcurrency + const DefaultWriteTimeoutSecond + type FlowService struct + DataStore sdk.DataStore + DebugEnabled bool + EnableMonitoring bool + Flows map[string]runtime.FlowDefinitionHandler + Logger sdk.Logger + OpenTraceUrl string + Port int + RedisURL string + RequestAuthEnabled bool + RequestAuthSharedSecret string + RequestReadTimeout time.Duration + RequestWriteTimeout time.Duration + RetryCount int + WorkerConcurrency int + func (fs *FlowService) ConfigureDefault() + func (fs *FlowService) Execute(flowName string, req *Request) error + func (fs *FlowService) Pause(flowName string, requestId string) error + func (fs *FlowService) Register(flowName string, handler runtime.FlowDefinitionHandler) error + func (fs *FlowService) Resume(flowName string, requestId string) error + func (fs *FlowService) Start() error + func (fs *FlowService) StartServer() error + func (fs *FlowService) StartWorker() error + func (fs *FlowService) Stop(flowName string, requestId string) error + type Request struct + Body []byte + Header map[string][]string + Query map[string][]string + RequestId string
Go to main page