Method Receive

pkg/workflow/actor_engine.go:269–292

Receive 处理消息

(ctx *actor.Context, msg actor.Message)

// Receive 处理消息
func (c *CoordinatorActor) Receive(ctx *actor.Context, msg actor.Message) {
	switch m := msg.(type) {
	case *actor.Started:
		wfLog.Info(context.Background(), "coordinator started", nil)

	case *ExecuteWorkflowMsg:
		c.handleExecuteWorkflow(ctx, m)

	case *NodeCompletedMsg:
		c.handleNodeCompleted(ctx, m)

	case *NodeFailedMsg:
		c.handleNodeFailed(ctx, m)

	case *CancelWorkflowMsg:
		c.handleCancelWorkflow(ctx, m)

	case *actor.Terminated:
		c.handleTerminated(ctx, m)

	case *actor.Stopping:
		c.handleStopping(ctx)
	}
}

// handleExecuteWorkflow 处理工作流执行请求
func (c *CoordinatorActor) handleExecuteWorkflow(ctx *actor.Context, msg *ExecuteWorkflowMsg) {