| 278 | } |
| 279 | |
| 280 | type queueAdapter struct { |
| 281 | queue *queue.Queue[ptrace.Traces] |
| 282 | } |
| 283 | |
| 284 | func (a queueAdapter) ForwardTraces(ctx context.Context, traces ptrace.Traces) error { |
| 285 | return a.queue.Push(ctx, traces) |
nothing calls this directly
no outgoing calls
no test coverage detected