opentelemetry_experimental

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

-define(DEFAULT_METER_PROVIDER, otel_meter_provider_default).

-record(meter,
        {
         module                  :: module() | '_',
         instrumentation_scope   :: opentelemetry:instrumentation_scope() | undefined,
         provider                :: atom() | '_',
         instruments_tab         :: ets:table() | '_',
         streams_tab             :: ets:table() | '_',
         metrics_tab             :: ets:table() | '_',
         exemplars_tab           :: ets:table() | '_'
        }).

-record(measurement,
        {
         instrument :: otel_instrument:t(),
         value :: number(),
         attributes :: opentelemetry:attributes_map()
        }).

-record(drop_aggregation, {}).

-record(sum_aggregation,
        {
         %% TODO: attributes should be a tuple of just the values, sorted by attribute name
         key :: otel_aggregation:key() | undefined,
         start_time :: integer(), %% | undefined,
         checkpoint :: number(), %% | undefined | {'+', '$2', '$3'} | {'+', '$3', '$4'},
         previous_checkpoint :: number(), %% | undefined | {'+', '$5', '$6'},
         int_value :: number(), %% | undefined | {'+', '$3', {const, number()}},
         float_value :: number() %% | undefined | {'+', '$4', {const, number()}}
        }).

-record(last_value_aggregation,
        {
         %% TODO: attributes should be a tuple of just the values, sorted by attribute name
         key :: otel_aggregation:key() | undefined,
         checkpoint :: number(),
         value :: number() | undefined,
         start_time :: integer()
        }).


-record(explicit_histogram_checkpoint,
        {
         bucket_counts :: match_spec(counters:counters_ref()) | undefined,
         min :: number() | undefined,
         max :: number() | undefined,
         sum :: number() | undefined,
         start_time :: number() | undefined
        }).

-record(explicit_histogram_aggregation,
        {
         %% TODO: attributes should be a tuple of just the values, sorted by attribute name
         key :: otel_aggregation:key() | undefined,
         start_time :: integer() | undefined,
         %% instrument_temporality :: otel_aggregation:temporality(),
         %% default: [0.0, 5.0, 10.0, 25.0, 50.0, 75.0, 100.0, 250.0, 500.0, 1000.0]
         explicit_bucket_boundaries :: match_spec([float()]) | undefined,
         record_min_max :: match_spec(boolean()) | undefined,
         checkpoint :: match_spec(#explicit_histogram_checkpoint{}) | {#explicit_histogram_checkpoint{}} | undefined,
         bucket_counts :: counters:counters_ref() | match_spec(undefined),
         min :: infinity | number() | undefined,
         max :: number() | undefined,
         sum :: number() | undefined
        }).

-record(datapoint,
        {
         attributes :: opentelemetry:attributes_map(),
         start_time :: integer(),
         time :: integer(),
         value :: number(),
         exemplars :: list() | undefined,
         flags :: integer() %% uint32
        }).

-record(sum,
        {
         datapoints :: [#datapoint{}],
         aggregation_temporality :: otel_instrument:temporality(),
         is_monotonic :: boolean()
        }).

-record(gauge,
        {
         datapoints :: [#datapoint{}]
        }).

-record(histogram_datapoint,
        {
         attributes :: opentelemetry:attributes_map(),
         start_time :: integer() | {const, eqwalizer:dynamic()}  | undefined,
         time :: integer(),
         count :: number(),
         sum :: float() | integer() | undefined,
         bucket_counts :: list(),
         explicit_bounds :: match_spec([float()]) | undefined,
         exemplars :: list(),
         flags :: integer(),
         min ::  infinity | integer() | undefined,
         max :: integer() | undefined
        }).

-record(histogram,
       {
        datapoints :: [#histogram_datapoint{}],
        aggregation_temporality :: otel_instrument:temporality()
       }).

-record(metric,
        {
         name :: otel_view:name(),
         scope :: opentelemetry:instrumentation_scope() | undefined,
         description :: otel_instrument:description(),
         unit :: otel_instrument:unit(),
         data :: #sum{} | #gauge{} | #histogram{}
        }).