| 1138 | } |
| 1139 | |
| 1140 | type tunnelUpdater struct { |
| 1141 | errChan chan error |
| 1142 | logger slog.Logger |
| 1143 | client WorkspaceUpdatesClient |
| 1144 | coordCtrl *TunnelSrcCoordController |
| 1145 | dnsHostsSetter DNSHostsSetter |
| 1146 | updateHandler UpdatesHandler |
| 1147 | ownerUsername string |
| 1148 | recvLoopDone chan struct{} |
| 1149 | dnsNameOptions DNSNameOptions |
| 1150 | |
| 1151 | sync.Mutex |
| 1152 | workspaces map[uuid.UUID]*Workspace |
| 1153 | closed bool |
| 1154 | } |
| 1155 | |
| 1156 | func (t *tunnelUpdater) Close(ctx context.Context) error { |
| 1157 | t.Lock() |
nothing calls this directly
no outgoing calls
no test coverage detected