(ctx context.Context, isLocal bool)
| 153 | } |
| 154 | |
| 155 | func (s *sourceManager) start(ctx context.Context, isLocal bool) { |
| 156 | s.refreshStatus(ctx) |
| 157 | |
| 158 | go s.run(ctx, isLocal) |
| 159 | } |
| 160 | |
| 161 | func (s *sourceManager) run(ctx context.Context, isLocal bool) { |
| 162 | // make sure we run in a detached context, which ignores outside cancellation and deadline. |
no test coverage detected