Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type WorkflowRegistry ¶
type WorkflowRegistry struct {
// contains filtered or unexported fields
}
WorkflowRegistry 工作流注册
func NewWorkflowRegistry ¶
func NewWorkflowRegistry( workflowRepo repository.WorkflowRepository, versionRepo repository.WorkflowVersionRepository, ) *WorkflowRegistry
func (*WorkflowRegistry) Register ¶
func (r *WorkflowRegistry) Register(def *definition.WorkflowDefinition)
func (*WorkflowRegistry) RegisterAndSync ¶
func (r *WorkflowRegistry) RegisterAndSync(ctx context.Context, def *definition.WorkflowDefinition) error
RegisterAndSync 注册工作流并立即持久化（workflow + 最新 version）。 与 Register + Sync 的两段式不同，供 Runtime 门面在运行期逐个注册使用； 重复注册同名工作流返回错误而非 panic。
Source Files
Click to show internal directories.
Click to hide internal directories.