(ctx context.Context)
| 265 | } |
| 266 | |
| 267 | func (l *queueList) shutdown(ctx context.Context) error { |
| 268 | var errs []error |
| 269 | for forwarderName, q := range l.forwarderNameToQueue { |
| 270 | if err := q.Shutdown(ctx); err != nil { |
| 271 | errs = append(errs, fmt.Errorf("failed to shutdown queue for forwarder=%s: %w", forwarderName, err)) |
| 272 | } |
| 273 | |
| 274 | delete(l.forwarderNameToQueue, forwarderName) |
| 275 | } |
| 276 | |
| 277 | return multierr.Combine(errs...) |
| 278 | } |
| 279 | |
| 280 | type queueAdapter struct { |
| 281 | queue *queue.Queue[ptrace.Traces] |