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

Defined in:

exporters/unbuffered_exporter.cr

Constructors

Instance Method Summary

Constructor Detail

def self.new(*_junk, **_kwjunk) #

def self.new(&) #

Instance Method Detail

def do_reap #

def export(elements : Array(Elements)) #

def export(element : Elements) #

abstract def handle(elements : Array(Elements)) #

def handle(element) #

def inject_telemetry_attributes(element) #

def loop_and_receive #

def reaped? #

def start #