handleTerminated 处理 Actor 终止通知
(ctx *actor.Context, msg *actor.Terminated)
| 568 | |
| 569 | // handleTerminated 处理 Actor 终止通知 |
| 570 | func (c *CoordinatorActor) handleTerminated(ctx *actor.Context, msg *actor.Terminated) { |
| 571 | wfLog.Debug(context.Background(), "actor terminated", map[string]any{"actor_id": msg.Who.ID}) |
| 572 | } |
| 573 | |
| 574 | // handleStopping 处理停止 |
| 575 | func (c *CoordinatorActor) handleStopping(ctx *actor.Context) { |