-ifndef(EREDIS_STREAMS_TELEMETRY_EVENTS_HRL).

-define(EREDIS_STREAMS_TELEMETRY_EVENTS_HRL, true).

-include_lib("teleprom/include/telemetry.hrl").

%
% Events definition
%
-define(EREDIS_STREAMS_APP, eredis_streams).
-define(STREAM_EVENT(Event), [?EREDIS_STREAMS_APP] ++ Event).

%
% Positive events
%
-define(EREDIS_STREAMS_APP_START, ?STREAM_EVENT([app, start])).
-define(EREDIS_STREAMS_APP_STOP, ?STREAM_EVENT([app, stop])).

%
-define(EREDIS_STREAMS_WORKER_INIT, ?STREAM_EVENT([worker, init])).
-define(EREDIS_STREAMS_WORKER_TERMINATE, ?STREAM_EVENT([worker, terminate])).
-define(EREDIS_STREAMS_WORKER_READY, ?STREAM_EVENT([worker, ready])).
-define(EREDIS_STREAMS_WORKER_TICK, ?STREAM_EVENT([worker, tick])).
-define(EREDIS_STREAMS_WORKER_HANDLE_MESSAGE, ?STREAM_EVENT([worker, handle, message])).
-define(EREDIS_STREAMS_FAILOVER_INIT, ?STREAM_EVENT([failover, init])).
-define(EREDIS_STREAMS_FAILOVER_TERMINATE, ?STREAM_EVENT([failover, terminate])).
-define(EREDIS_STREAMS_FAILOVER_READY, ?STREAM_EVENT([failover, ready])).
-define(EREDIS_STREAMS_FAILOVER_TICK, ?STREAM_EVENT([failover, tick])).
-define(EREDIS_STREAMS_FAILOVER_HANDLE_MESSAGE, ?STREAM_EVENT([failover, handle, message])).

%
-define(
  EREDIS_STREAMS_POSITIVE_TELEMETRY_EVENTS,
  [
    % app events
    ?EREDIS_STREAMS_APP_START,
    ?EREDIS_STREAMS_APP_STOP,
    % worker events
    ?EREDIS_STREAMS_WORKER_INIT,
    ?EREDIS_STREAMS_WORKER_TERMINATE,
    ?EREDIS_STREAMS_WORKER_READY,
    ?EREDIS_STREAMS_WORKER_TICK,
    ?EREDIS_STREAMS_WORKER_HANDLE_MESSAGE,
    % failover events
    ?EREDIS_STREAMS_FAILOVER_INIT,
    ?EREDIS_STREAMS_FAILOVER_TERMINATE,
    ?EREDIS_STREAMS_FAILOVER_READY,
    ?EREDIS_STREAMS_FAILOVER_TICK,
    ?EREDIS_STREAMS_FAILOVER_HANDLE_MESSAGE
  ]
).

%
% Negative events
%
-define(EREDIS_STREAMS_ERROR, ?STREAM_EVENT([error])).

%
-define(EREDIS_STREAMS_NEGATIVE_TELEMETRY_EVENTS, [?EREDIS_STREAMS_ERROR]).

%
% All events
%
-define(
  EREDIS_STREAMS_ALL_TELEMETRY_EVENTS,
  ?EREDIS_STREAMS_POSITIVE_TELEMETRY_EVENTS ++ ?EREDIS_STREAMS_NEGATIVE_TELEMETRY_EVENTS
).

%
-endif.