v1

Documentation

Index

• Constants
• type FlowService
  • 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

Constants

const (
	DefaultTraceUrl           = "localhost:5775"
	DefaultRedisUrl           = "localhost:6379"
	DefaultWorkerConcurrency  = 2
	DefaultWebServerPort      = 8080
	DefaultReadTimeoutSecond  = 120
	DefaultWriteTimeoutSecond = 120
)

Types

type FlowService

type FlowService struct {
	Port                    int
	RedisURL                string
	RedisPassword           string
	RequestAuthSharedSecret string
	RequestAuthEnabled      bool
	WorkerConcurrency       int
	RetryCount              int
	Flows                   map[string]runtime.FlowDefinitionHandler
	RequestReadTimeout      time.Duration
	RequestWriteTimeout     time.Duration
	OpenTraceUrl            string
	DataStore               sdk.DataStore
	Logger                  sdk.Logger
	EnableMonitoring        bool
	DebugEnabled            bool
	// contains filtered or unexported fields
}

func (*FlowService) ConfigureDefault

func (fs *FlowService) ConfigureDefault()

ConfigureDefault 将默认配置填写fs对象（如果没有设置的情况）

func (*FlowService) Execute

func (fs *FlowService) Execute(flowName string, req *Request) error

func (*FlowService) Pause

func (fs *FlowService) Pause(flowName string, requestId string) error

func (*FlowService) Register

func (fs *FlowService) Register(flowName string, handler runtime.FlowDefinitionHandler) error

Register 注册一个flow服务流 参数： flowName：自定义流名称 handler: 该流需要执行的handler

func (*FlowService) Resume

func (fs *FlowService) Resume(flowName string, requestId string) error

func (*FlowService) Start

func (fs *FlowService) Start() error

Start 开启

func (*FlowService) StartServer

func (fs *FlowService) StartServer() error

func (*FlowService) StartWorker

func (fs *FlowService) StartWorker() error

func (*FlowService) Stop

func (fs *FlowService) Stop(flowName string, requestId string) error

type Request

type Request struct {
	Body      []byte
	RequestId string
	Query     map[string][]string
	Header    map[string][]string
}