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
flush_queue()
Alias for: close_queue
transfer(new_buffer) click to toggle source
# File lib/infinite_tracing/suspended_streaming_buffer.rb, line 25
def transfer new_buffer
  # NOOP
end