Class: Datadog::ContextFlush::Partial

Inherits:
Object
  • Object
show all
Defined in:
lib/ddtrace/context_flush.rb

Overview

Performs partial trace flushing to avoid large traces residing in memory for too long

Direct Known Subclasses

Datadog::CI::ContextFlush::Partial

Constant Summary collapse

DEFAULT_MIN_SPANS_FOR_PARTIAL_FLUSH =

Start flushing partial trace after this many active spans in one trace

500

Instance Method Summary collapse

Constructor Details

#initialize(options = {}) ⇒ Partial

Returns a new instance of Partial.



29
30
31
 
# File 'lib/ddtrace/context_flush.rb', line 29

def initialize(options = {})
  @min_spans_for_partial = options.fetch(:min_spans_before_partial_flush, DEFAULT_MIN_SPANS_FOR_PARTIAL_FLUSH)
end

Instance Method Details

#consume!(context) ⇒ Array<Span>

Consumes and returns completed or partially completed traces from the provided context, if any.

Partially completed traces, where not all spans have finished, will only be returned if there are at least @min_spans_for_partial finished spans.

Any spans consumed are removed from context as a side effect.

Returns:

  • (Array<Span>) —

    partial or complete trace to be flushed, or nil if no spans are finished



43
44
45
46
47
48
49
50
 
# File 'lib/ddtrace/context_flush.rb', line 43

def consume!(context)
  trace, sampled = get_trace(context)

  return nil unless sampled
  return trace if trace && !trace.empty?

  partial_trace(context)
end