Function NewCoordinatorActor

pkg/workflow/actor_engine.go:261–266

NewCoordinatorActor 创建协调器

(engine *ActorEngine)

// NewCoordinatorActor 创建协调器
func NewCoordinatorActor(engine *ActorEngine) *CoordinatorActor {
	return &CoordinatorActor{
		engine:           engine,
		runningWorkflows: make(map[string]*workflowState),
	}
}

// Receive 处理消息
func (c *CoordinatorActor) Receive(ctx *actor.Context, msg actor.Message) {