Method bufferLogs

agent/boundarylogproxy/proxy.go:213–222

(ctx context.Context, req *agentproto.ReportBoundaryLogsRequest)

}

func (s *Server) bufferLogs(ctx context.Context, req *agentproto.ReportBoundaryLogsRequest) {
	select {
	case s.logs <- req:
	default:
		s.logger.Warn(ctx, "dropping boundary logs, buffer full",
			slog.F("log_count", len(req.Logs)))
		s.metrics.batchesDropped.WithLabelValues(droppedReasonBufferFull).Inc()
		s.metrics.logsDropped.WithLabelValues(droppedReasonBufferFull).Add(float64(len(req.Logs)))
	}
}

// Close stops the server and blocks until resources have been cleaned up.
// It must be called after Start.