(_ context.Context, e slog.SinkEntry)
| 290 | var _ slog.Sink = &Tunnel{} |
| 291 | |
| 292 | func (t *Tunnel) LogEntry(_ context.Context, e slog.SinkEntry) { |
| 293 | msg := &TunnelMessage{ |
| 294 | Msg: &TunnelMessage_Log{ |
| 295 | Log: sinkEntryToPb(e), |
| 296 | }, |
| 297 | } |
| 298 | select { |
| 299 | case <-t.updater.ctx.Done(): |
| 300 | return |
| 301 | case <-t.ctx.Done(): |
| 302 | return |
| 303 | case t.sendCh <- msg: |
| 304 | } |
| 305 | } |
| 306 | |
| 307 | func (*Tunnel) Sync() {} |
| 308 |
nothing calls this directly
no test coverage detected