class OpenTelemetry::Exporter::Http

Defined in:

exporters/http.cr

Constructors

Class Method Summary

Instance Method Summary

Instance methods inherited from class OpenTelemetry::Exporter::BufferedBase

handle(elements : Array(Elements)) handle

Instance methods inherited from module OpenTelemetry::Exporter::BufferedExporter

batch_interval batch_interval, batch_interval=(batch_interval) batch_interval=, batch_latency batch_latency, batch_latency=(batch_latency) batch_latency=, batch_threshold batch_threshold, batch_threshold=(batch_threshold) batch_threshold=, loop_and_receive loop_and_receive

Instance methods inherited from module OpenTelemetry::Exporter::UnbufferedExporter

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

Constructor methods inherited from module OpenTelemetry::Exporter::UnbufferedExporter

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

Constructor Detail

def self.new(endpoint : String | Nil | URI = nil, _headers : HTTP::Headers | Nil = nil, _clients : DB::Pool(HTTP::Client) | Nil = nil, *_junk, **_kwjunk) #

[View source]
def self.new(&) #

[View source]

Class Method Detail

def self.normalized_traces_endpoint_uri(endpoint_uri : String) #

TODO Once we support more than just traces, how this all works will have to be revised.


[View source]
def self.normalized_traces_endpoint_uri(endpoint_uri : URI) #

[View source]

Instance Method Detail

def clients : DB::Pool(HTTP::Client) #

[View source]
def clients=(clients : DB::Pool(HTTP::Client)) #

[View source]
def collate(elements) #

[View source]
def endpoint : URI #

[View source]
def endpoint=(uri : URI) #

[View source]
def endpoint=(uri : String) #

[View source]
def endpoint_uri : URI #

[View source]
def endpoint_uri=(endpoint_uri : URI) #

[View source]
def generate_payload(request) #

[View source]
def handle(elements : Array(Elements)) #

[View source]
def headers : HTTP::Headers #

[View source]
def headers=(headers : HTTP::Headers) #

[View source]
def initialize_client_pool #

[View source]
def setup_standard_headers(headers) #

For other HTTP based protocols, such as gRPC, this method should be overridden to set the appropriate protocol specific headers.


[View source]
def user_agent #

[View source]