Contents

# frozen_string_literal: true

module Jaeger
  module Reporters
    class RemoteReporter
      class Buffer
        def initialize
          @buffer = []
          @mutex = Mutex.new
        end

        def <<(element)
          @mutex.synchronize do
            @buffer << element
            true
          end
        end

        def retrieve
          @mutex.synchronize do
            elements = @buffer.dup
            @buffer.clear
            elements
          end
        end
      end
    end
  end
end

Version data entries

7 entries across 7 versions & 3 rubygems

Version	Path
dox-jaeger-client-2.0.0	lib/jaeger/reporters/remote_reporter/buffer.rb
jaeger-client-with-ruby-32-support-2.0.0	lib/jaeger/reporters/remote_reporter/buffer.rb
jaeger-client-1.3.0	lib/jaeger/reporters/remote_reporter/buffer.rb
jaeger-client-1.2.0	lib/jaeger/reporters/remote_reporter/buffer.rb
jaeger-client-1.1.0	lib/jaeger/reporters/remote_reporter/buffer.rb
jaeger-client-1.0.0	lib/jaeger/reporters/remote_reporter/buffer.rb
jaeger-client-0.10.0	lib/jaeger/reporters/remote_reporter/buffer.rb