Sha256: 26b69293419319ab30e2b86db9b0f4ba746f18ca99ccd979883f70acf3795081

Contents?: true

Size: 516 Bytes

Versions: 7

Compression:

Stored size: 516 Bytes

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