< Summary

Information

Class:	Elsa.Diagnostics.OpenTelemetry.Providers.InMemory.RingBuffer<T>
Assembly:	Elsa.Diagnostics.OpenTelemetry
File(s):	/home/runner/work/elsa-core/elsa-core/src/modules/Elsa.Diagnostics.OpenTelemetry/Providers/InMemory/RingBuffer.cs

Line coverage

95%

Branch coverage

75%

Method coverage

Feature is only available for sponsors

Metrics

Method	Branch coverage	Crap Score	Cyclomatic complexity	Line coverage
.ctor(...)	50%	2	2	85.71%
get_DroppedCount()	100%	1	1	100%
Add(...)	100%	2	2	100%
Snapshot()	100%	1	1	100%

#	Line	Line coverage
	`1`	`namespace Elsa.Diagnostics.OpenTelemetry.Providers.InMemory;`
	`2`
	`3`	`public class RingBuffer<T>`
	`4`	`{`
65	`5`	`private readonly Queue<T> _items = new();`
65	`6`	`private readonly object _lock = new();`
	`7`	`private readonly int _capacity;`
	`8`	`private long _droppedCount;`
	`9`
65	`10`	`public RingBuffer(int capacity)`
	`11`	`{`
65	`12`	`if (capacity <= 0)`
0	`13`	`throw new ArgumentOutOfRangeException(nameof(capacity), "Capacity must be greater than zero.");`
	`14`
65	`15`	`_capacity = capacity;`
65	`16`	`}`
	`17`
	`18`	`public long DroppedCount`
	`19`	`{`
	`20`	`get`
	`21`	`{`
16	`22`	`lock (_lock)`
16	`23`	`return _droppedCount;`
16	`24`	`}`
	`25`	`}`
	`26`
	`27`	`public void Add(T item)`
	`28`	`{`
29	`29`	`lock (_lock)`
	`30`	`{`
29	`31`	`if (_items.Count == _capacity)`
	`32`	`{`
2	`33`	`_items.Dequeue();`
2	`34`	`_droppedCount++;`
	`35`	`}`
	`36`
29	`37`	`_items.Enqueue(item);`
29	`38`	`}`
29	`39`	`}`
	`40`
	`41`	`public IReadOnlyCollection<T> Snapshot()`
	`42`	`{`
22	`43`	`lock (_lock)`
22	`44`	`return _items.ToList();`
22	`45`	`}`
	`46`	`}`