updateStateFromEvent 根据事件更新 Agent 状态
(event any)
| 176 | |
| 177 | // updateStateFromEvent 根据事件更新 Agent 状态 |
| 178 | func (r *RemoteAgent) updateStateFromEvent(event any) { |
| 179 | r.mu.Lock() |
| 180 | defer r.mu.Unlock() |
| 181 | |
| 182 | switch e := event.(type) { |
| 183 | case *types.MonitorStateChangedEvent: |
| 184 | r.state = e.State |
| 185 | case *types.ProgressDoneEvent: |
| 186 | r.state = types.StateIdle |
| 187 | case *types.MonitorErrorEvent: |
| 188 | if e.Severity == "fatal" { |
| 189 | r.state = types.StateFailed |
| 190 | } |
| 191 | } |
| 192 | } |
| 193 | |
| 194 | // Close 关闭 RemoteAgent |
| 195 | func (r *RemoteAgent) Close() error { |