Packages

opentelemetry_experimental

0.1.0
0.5.1 0.5.0 0.4.0 0.3.0 0.2.0 0.1.0

Implementation of unstable OpenTelemetry signals

HexDocs

Current section

Files

Jump to
Readme
6 Versions
3 Dependencies
Dependants
Files
Activity
opentelemetry_experimental src otel_aggregation.erl
Raw

src/otel_aggregation.erl 

-module(otel_aggregation).



-export([default_mapping/0,

         temporality_mapping/0,

         instrument_temporality/1]).



-include_lib("opentelemetry_api_experimental/include/otel_metrics.hrl").

-include("otel_metrics.hrl").



-type temporality() :: ?AGGREGATION_TEMPORALITY_UNSPECIFIED |

                       ?AGGREGATION_TEMPORALITY_DELTA |

                       ?AGGREGATION_TEMPORALITY_CUMULATIVE.



%% -type t() :: drop | sum | last_value | histogram.

-type t() :: otel_aggregation_drop:t() | otel_aggregation_sum:t() |

             otel_aggregation_last_value:t() | otel_aggregation_histogram_explicit:t().



-export_type([t/0,

              temporality/0]).



-spec default_mapping() -> #{otel_instrument:kind() => module()}.

default_mapping() ->

    #{?KIND_COUNTER => otel_aggregation_sum,

      ?KIND_OBSERVABLE_COUNTER => otel_aggregation_sum,

      ?KIND_HISTOGRAM => otel_aggregation_histogram_explicit,

      ?KIND_OBSERVABLE_GAUGE => otel_aggregation_last_value,

      ?KIND_UPDOWN_COUNTER => otel_aggregation_sum,

      ?KIND_OBSERVABLE_UPDOWNCOUNTER => otel_aggregation_sum}.



temporality_mapping() ->

    #{?KIND_COUNTER =>?AGGREGATION_TEMPORALITY_DELTA,

      ?KIND_OBSERVABLE_COUNTER => ?AGGREGATION_TEMPORALITY_CUMULATIVE,

      ?KIND_UPDOWN_COUNTER => ?AGGREGATION_TEMPORALITY_DELTA,

      ?KIND_OBSERVABLE_UPDOWNCOUNTER => ?AGGREGATION_TEMPORALITY_CUMULATIVE,

      ?KIND_HISTOGRAM => ?AGGREGATION_TEMPORALITY_UNSPECIFIED,

      ?KIND_OBSERVABLE_GAUGE => ?AGGREGATION_TEMPORALITY_UNSPECIFIED}.



instrument_temporality(#instrument{kind=?KIND_COUNTER}) ->

    ?AGGREGATION_TEMPORALITY_DELTA;

instrument_temporality(#instrument{kind=?KIND_OBSERVABLE_COUNTER}) ->

    ?AGGREGATION_TEMPORALITY_CUMULATIVE;

instrument_temporality(#instrument{kind=?KIND_UPDOWN_COUNTER}) ->

    ?AGGREGATION_TEMPORALITY_DELTA;

instrument_temporality(#instrument{kind=?KIND_OBSERVABLE_UPDOWNCOUNTER}) ->

    ?AGGREGATION_TEMPORALITY_CUMULATIVE;

instrument_temporality(#instrument{kind=?KIND_HISTOGRAM}) ->

    ?AGGREGATION_TEMPORALITY_UNSPECIFIED;

instrument_temporality(#instrument{kind=?KIND_OBSERVABLE_GAUGE}) ->

    ?AGGREGATION_TEMPORALITY_UNSPECIFIED.