Sha256: 2402bd866b0f5c16815337057e683928f45ad7073cbbb7116d47ea0f5e2556e6
Contents?: true
Size: 1.35 KB
Versions: 42
Compression:
Stored size: 1.35 KB
Contents
# encoding: utf-8
# EventBuffer is intended to be an abstract base class. It should not be
# instantiated directly. Subclasses should define an `append_event` method
# looking something like this:
#
# def append_event(x)
# <attempt to append>
# if append_success?
# return x
# else
# return nil
# end
# end
module OneApm
module Agent
class EventBuffer
attr_reader :capacity
def initialize(capacity)
@capacity = capacity
@items = []
@seen = 0
end
def reset!
@items = []
@seen = 0
end
def capacity=(new_capacity)
@capacity = new_capacity
old_items = @items
@items = []
old_seen = @seen
old_items.each { |i| append(i) }
@seen = old_seen
end
def append(x)
@seen += 1
append_event(x)
end
def <<(x)
append(x)
self # return self for method chaining
end
def full?
@items.size >= @capacity
end
def size
@items.size
end
def note_dropped
@seen += 1
end
def num_seen
@seen
end
def num_dropped
@seen - @items.size
end
def sample_rate
@seen > 0 ? (size.to_f / @seen) : 0.0
end
def to_a
@items.dup
end
end
end
end
Version data entries
42 entries across 42 versions & 1 rubygems