Method deadLetterHandler

pkg/actor/system.go:703–718

deadLetterHandler 死信处理器

()

// deadLetterHandler 死信处理器
func (s *System) deadLetterHandler() {
	defer s.wg.Done()

	for {
		select {
		case <-s.ctx.Done():
			return
		case env := <-s.deadLetters:
			actorLog.Warn(context.Background(), "dead letter: message could not be delivered", map[string]any{
				"msg_kind":  env.message.Kind(),
				"target_id": env.target.ID,
				"sender":    env.sender,
			})
		}
	}
}

// Stats 获取统计信息
func (s *System) Stats() *SystemStats {