class NewRelic::Agent::InfiniteTracing::SuspendedStreamingBuffer
Public Class Methods
new(max_size = DEFAULT_QUEUE_SIZE)
click to toggle source
# File lib/infinite_tracing/suspended_streaming_buffer.rb, line 16 def initialize max_size = DEFAULT_QUEUE_SIZE @empty_buffer = NewRelic::EMPTY_ARRAY end
Public Instance Methods
<<(segment)
click to toggle source
updates the seen metric and discards the segment
# File lib/infinite_tracing/suspended_streaming_buffer.rb, line 21 def << segment NewRelic::Agent.increment_metric SPANS_SEEN_METRIC end
close_queue()
click to toggle source
# File lib/infinite_tracing/suspended_streaming_buffer.rb, line 29 def close_queue # NOOP end
Also aliased as: flush_queue
enumerator()
click to toggle source
# File lib/infinite_tracing/suspended_streaming_buffer.rb, line 34 def enumerator @empty_buffer end
transfer(new_buffer)
click to toggle source
# File lib/infinite_tracing/suspended_streaming_buffer.rb, line 25 def transfer new_buffer # NOOP end