Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type WorkflowService ¶
type WorkflowService = *workflowService
func NewWorkflowService ¶
func NewWorkflowService(dbClient *rdb.DBClient, innerQueue queue.InnerMessageQueue, conf *config.SkyflowConfig) (WorkflowService, error)
Directories
¶
| Path | Synopsis |
|---|---|
|
package executor provides the main executor for workflow event processing.
|
package executor provides the main executor for workflow event processing. |
|
package expression show how to evaluate a boolean expression in workflow
|
package expression show how to evaluate a boolean expression in workflow |
|
stepfunction
stepfunction stepfunction style expression evaluator
|
stepfunction stepfunction style expression evaluator |
|
Description: This package contains the parser service and configuration for the state machine parser.
|
Description: This package contains the parser service and configuration for the state machine parser. |
|
states
Package states implements the State behavior for the workflow states are the basic step in the workflow, they can be combined to form a complex workflow
|
Package states implements the State behavior for the workflow states are the basic step in the workflow, they can be combined to form a complex workflow |
|
persistent object for workflow
|
persistent object for workflow |
|
lock
加锁服务, 可以使用DB /Redis or 其他资源服务完成加锁需求
|
加锁服务, 可以使用DB /Redis or 其他资源服务完成加锁需求 |
|
queue
package queue define the queue interface and message type for workflow
|
package queue define the queue interface and message type for workflow |
|
package template
|
package template |
Click to show internal directories.
Click to hide internal directories.