Function AgentActorGetStatus

pkg/agent/actor.go:574–587

AgentActorGetStatus 获取 Agent 状态

(pid *actor.PID, timeout time.Duration)

// AgentActorGetStatus 获取 Agent 状态
func AgentActorGetStatus(pid *actor.PID, timeout time.Duration) (*types.AgentStatus, error) {
	replyCh := make(chan *types.AgentStatus, 1)

	pid.Tell(&GetStatusMsg{
		ReplyTo: replyCh,
	})

	select {
	case status := <-replyCh:
		return status, nil
	case <-time.After(timeout):
		return nil, fmt.Errorf("get status timed out after %v", timeout)
	}
}