(workspaceID uuid.UUID, a *Agent)
| 1386 | } |
| 1387 | |
| 1388 | func (t *tunnelUpdater) upsertAgentLocked(workspaceID uuid.UUID, a *Agent) error { |
| 1389 | w, ok := t.workspaces[workspaceID] |
| 1390 | if !ok { |
| 1391 | return xerrors.Errorf("workspace %s not found", workspaceID) |
| 1392 | } |
| 1393 | w.agents[a.ID] = a |
| 1394 | return nil |
| 1395 | } |
| 1396 | |
| 1397 | func (t *tunnelUpdater) deleteAgentLocked(workspaceID, id uuid.UUID) (*Agent, error) { |
| 1398 | w, ok := t.workspaces[workspaceID] |