Method RunForwarder

agent/boundarylogproxy/proxy.go:100–122

RunForwarder drains the log buffer and forwards logs to coderd. It blocks until ctx is canceled.

(ctx context.Context, sender Reporter)

// RunForwarder drains the log buffer and forwards logs to coderd.
// It blocks until ctx is canceled.
func (s *Server) RunForwarder(ctx context.Context, sender Reporter) error {
	s.logger.Debug(ctx, "boundary log forwarder started")

	for {
		select {
		case <-ctx.Done():
			return ctx.Err()
		case req := <-s.logs:
			_, err := sender.ReportBoundaryLogs(ctx, req)
			if err != nil {
				s.logger.Warn(ctx, "failed to forward boundary logs",
					slog.Error(err),
					slog.F("log_count", len(req.Logs)))
				s.metrics.batchesDropped.WithLabelValues(droppedReasonForwardFailed).Inc()
				s.metrics.logsDropped.WithLabelValues(droppedReasonForwardFailed).Add(float64(len(req.Logs)))
				// Continue forwarding other logs. The current batch is lost,
				// but the socket stays alive.
				continue
			}
			s.metrics.batchesForwarded.Inc()
		}
	}
}

func (s *Server) acceptLoop(ctx context.Context) {
	defer s.wg.Done()