module OpenTelemetry::Exporter::UnbufferedExporter

Overview

This module provides the base implementation for building exporters. It provides a Channel into which data elements to be exported are sent. It also defines a #start method that will create a fiber which will listen on this channel for data waiting to be exported. That fiber will consume the element, and pass it to a #handle method for actual dispatch. It is expected that subclasses will override at least the #handle method with their own functionality.

Direct including types

• OpenTelemetry::Exporter::Base
• OpenTelemetry::Exporter::BufferedExporter

Defined in:

exporters/unbuffered_exporter.cr

Constructors

• .new(*_junk, **_kwjunk)
• .new(&)

Instance Method Summary

• #do_reap
• #export(elements : Array(Elements))
• #export(element : Elements)
• #handle(elements : Array(Elements))
• #handle(element)
• #inject_telemetry_attributes(element)
• #loop_and_receive
• #reaped?
• #start

Constructor Detail

Instance Method Detail