%% The contents of this file are subject to the Mozilla Public License
%% Version 2.0 (the "License"); you may not use this file except in
%% compliance with the License. You may obtain a copy of the License
%% at https://www.mozilla.org/en-US/MPL/2.0/
%%
%% Software distributed under the License is distributed on an "AS IS"
%% basis, WITHOUT WARRANTY OF ANY KIND, either express or implied. See
%% the License for the specific language governing rights and
%% limitations under the License.
%%
%% The Original Code is RabbitMQ.
%%
%% The Initial Developer of the Original Code is Pivotal Software, Inc.
%% Copyright (c) 2007-2024 Broadcom. All Rights Reserved. The term “Broadcom” refers to Broadcom Inc. and/or its subsidiaries. All rights reserved.
%%

-include_lib("rabbit/include/rabbit_global_counters.hrl").

-define(TABLE_CONSUMER, rabbit_stream_consumer_created).
-define(TABLE_PUBLISHER, rabbit_stream_publisher_created).

-define(STREAM_DOES_NOT_EXIST, ?NUM_PROTOCOL_COUNTERS + 1).
-define(SUBSCRIPTION_ID_ALREADY_EXISTS, ?NUM_PROTOCOL_COUNTERS + 2).
-define(SUBSCRIPTION_ID_DOES_NOT_EXIST, ?NUM_PROTOCOL_COUNTERS + 3).
-define(STREAM_ALREADY_EXISTS, ?NUM_PROTOCOL_COUNTERS + 4).
-define(STREAM_NOT_AVAILABLE, ?NUM_PROTOCOL_COUNTERS + 5).
-define(SASL_MECHANISM_NOT_SUPPORTED, ?NUM_PROTOCOL_COUNTERS + 6).
-define(AUTHENTICATION_FAILURE, ?NUM_PROTOCOL_COUNTERS + 7).
-define(SASL_ERROR, ?NUM_PROTOCOL_COUNTERS + 8).
-define(SASL_CHALLENGE, ?NUM_PROTOCOL_COUNTERS + 9).
-define(SASL_AUTHENTICATION_FAILURE_LOOPBACK, ?NUM_PROTOCOL_COUNTERS + 10).
-define(VHOST_ACCESS_FAILURE, ?NUM_PROTOCOL_COUNTERS + 11).
-define(UNKNOWN_FRAME, ?NUM_PROTOCOL_COUNTERS + 12).
-define(FRAME_TOO_LARGE, ?NUM_PROTOCOL_COUNTERS + 13).
-define(INTERNAL_ERROR, ?NUM_PROTOCOL_COUNTERS + 14).
-define(ACCESS_REFUSED, ?NUM_PROTOCOL_COUNTERS + 15).
-define(PRECONDITION_FAILED, ?NUM_PROTOCOL_COUNTERS + 16).
-define(PUBLISHER_DOES_NOT_EXIST, ?NUM_PROTOCOL_COUNTERS + 17).

-define(PROTOCOL_COUNTERS,
        [
         {
          stream_error_stream_does_not_exist_total, ?STREAM_DOES_NOT_EXIST, counter,
          "Total number of commands rejected with stream does not exist error"
         },
         {
          stream_error_subscription_id_already_exists_total, ?SUBSCRIPTION_ID_ALREADY_EXISTS, counter,
          "Total number of commands failed with subscription id already exists"
         },
         {
          stream_error_subscription_id_does_not_exist_total, ?SUBSCRIPTION_ID_DOES_NOT_EXIST, counter,
          "Total number of commands failed with subscription id does not exist"
         },
         {
          stream_error_stream_already_exists_total, ?STREAM_ALREADY_EXISTS, counter,
          "Total number of commands failed with stream already exists"
         },
         {
          stream_error_stream_not_available_total, ?STREAM_NOT_AVAILABLE, counter,
          "Total number of commands failed with stream not available"
         },
         {
          stream_error_sasl_mechanism_not_supported_total, ?SASL_MECHANISM_NOT_SUPPORTED, counter,
          "Total number of commands failed with sasl mechanism not supported"
         },
         {
          stream_error_authentication_failure_total, ?AUTHENTICATION_FAILURE, counter,
          "Total number of commands failed with authentication failure"
         },
         {
          stream_error_sasl_error_total, ?SASL_ERROR, counter,
          "Total number of commands failed with sasl error"
         },
         {
          stream_error_sasl_challenge_total, ?SASL_CHALLENGE, counter,
          "Total number of commands failed with sasl challenge"
         },
         {
          stream_error_sasl_authentication_failure_loopback_total, ?SASL_AUTHENTICATION_FAILURE_LOOPBACK, counter,
          "Total number of commands failed with sasl authentication failure loopback"
         },
         {
          stream_error_vhost_access_failure_total, ?VHOST_ACCESS_FAILURE, counter,
          "Total number of commands failed with vhost access failure"
         },
         {
          stream_error_unknown_frame_total, ?UNKNOWN_FRAME, counter,
          "Total number of commands failed with unknown frame"
         },
         {
          stream_error_frame_too_large_total, ?FRAME_TOO_LARGE, counter,
          "Total number of commands failed with frame too large"
         },
         {
          stream_error_internal_error_total, ?INTERNAL_ERROR, counter,
          "Total number of commands failed with internal error"
         },
         {
          stream_error_access_refused_total, ?ACCESS_REFUSED, counter,
          "Total number of commands failed with access refused"
         },
         {
          stream_error_precondition_failed_total, ?PRECONDITION_FAILED, counter,
          "Total number of commands failed with precondition failed"
         },
         {
          stream_error_publisher_does_not_exist_total, ?PUBLISHER_DOES_NOT_EXIST, counter,
          "Total number of commands failed with publisher does not exist"
         }
        ]).
