Sha256: 776276341a5f6777d7ea8dc6b1b740b7381cd892cfb7d408268caa2e2bb3b6af

Contents?: true

Size: 1.06 KB

Versions: 11

Compression:

Stored size: 1.06 KB

Contents

# encoding: utf-8
# This file is distributed under New Relic's license terms.
# See https://github.com/newrelic/newrelic-ruby-agent/blob/main/LICENSE for complete details.
# frozen_string_literal: true

# The SuspendedStreamingBuffer class discards pushed segments and records 
# the seen metric.  This buffer is installed when the gRPC server returns 
# UNIMPLEMENTED (status 12) code as a signal to not reconnect to the server.
module NewRelic::Agent
  module InfiniteTracing
    class SuspendedStreamingBuffer
      include Constants
      extend Forwardable
      def_delegators :@empty_buffer, :empty?, :push

      def initialize max_size = DEFAULT_QUEUE_SIZE
        @empty_buffer = NewRelic::EMPTY_ARRAY
      end

      # updates the seen metric and discards the segment
      def << segment
        NewRelic::Agent.increment_metric SPANS_SEEN_METRIC
      end

      def transfer new_buffer
        # NOOP
      end

      def close_queue
        # NOOP
      end
      alias :flush_queue :close_queue
      
      def enumerator
        @empty_buffer
      end
    end
  end
end

Version data entries

11 entries across 11 versions & 1 rubygems

Version Path
newrelic-infinite_tracing-8.2.0 lib/infinite_tracing/suspended_streaming_buffer.rb
newrelic-infinite_tracing-8.1.0 lib/infinite_tracing/suspended_streaming_buffer.rb
newrelic-infinite_tracing-8.0.0 lib/infinite_tracing/suspended_streaming_buffer.rb
newrelic-infinite_tracing-7.2.0 lib/infinite_tracing/suspended_streaming_buffer.rb
newrelic-infinite_tracing-7.1.0 lib/infinite_tracing/suspended_streaming_buffer.rb
newrelic-infinite_tracing-7.0.0 lib/infinite_tracing/suspended_streaming_buffer.rb
newrelic-infinite_tracing-6.15.0 lib/infinite_tracing/suspended_streaming_buffer.rb
newrelic-infinite_tracing-6.14.0 lib/infinite_tracing/suspended_streaming_buffer.rb
newrelic-infinite_tracing-6.13.1 lib/infinite_tracing/suspended_streaming_buffer.rb
newrelic-infinite_tracing-6.13.0 lib/infinite_tracing/suspended_streaming_buffer.rb
newrelic-infinite_tracing-6.12.0.367 lib/infinite_tracing/suspended_streaming_buffer.rb