(status *codec.BoundaryStatus)
| 202 | } |
| 203 | |
| 204 | func (s *Server) recordBoundaryStatus(status *codec.BoundaryStatus) { |
| 205 | if n := status.DroppedChannelFull; n > 0 { |
| 206 | s.metrics.logsDropped.WithLabelValues(droppedReasonBoundaryChannelFull).Add(float64(n)) |
| 207 | } |
| 208 | if n := status.DroppedBatchFull; n > 0 { |
| 209 | s.metrics.logsDropped.WithLabelValues(droppedReasonBoundaryBatchFull).Add(float64(n)) |
| 210 | } |
| 211 | } |
| 212 | |
| 213 | func (s *Server) bufferLogs(ctx context.Context, req *agentproto.ReportBoundaryLogsRequest) { |
| 214 | select { |
no test coverage detected