Sha256: 8f3788f4d7365999a76aebb12c9fdd575c41a00d3cfab76669471102175e3a62

Contents?: true

Size: 620 Bytes

Versions: 10

Compression:

Stored size: 620 Bytes

Contents

# frozen_string_literal: true

# @note This class is part of the new Client implementation that is intended
#   to become the new default in the next major release of this library.
class StatsD::Instrument::CaptureSink
  attr_reader :parent, :datagrams, :datagram_class

  def initialize(parent:, datagram_class: StatsD::Instrument::Datagram)
    @parent = parent
    @datagram_class = datagram_class
    @datagrams = []
  end

  def sample?(_sample_rate)
    true
  end

  def <<(datagram)
    @datagrams << datagram_class.new(datagram)
    parent << datagram
    self
  end

  def clear
    @datagrams.clear
  end
end

Version data entries

10 entries across 10 versions & 1 rubygems

Version Path
statsd-instrument-3.0.0 lib/statsd/instrument/capture_sink.rb
statsd-instrument-3.0.0.pre2 lib/statsd/instrument/capture_sink.rb
statsd-instrument-2.9.2 lib/statsd/instrument/capture_sink.rb
statsd-instrument-3.0.0.pre1 lib/statsd/instrument/capture_sink.rb
statsd-instrument-2.9.1 lib/statsd/instrument/capture_sink.rb
statsd-instrument-2.9.0 lib/statsd/instrument/capture_sink.rb
statsd-instrument-2.8.0 lib/statsd/instrument/capture_sink.rb
statsd-instrument-2.7.1 lib/statsd/instrument/capture_sink.rb
statsd-instrument-2.7.0 lib/statsd/instrument/capture_sink.rb
statsd-instrument-2.6.0 lib/statsd/instrument/capture_sink.rb