ex_rocketmq

defmodule ExRocketmq.ProcessQueue.State do
  @moduledoc false

  alias ExRocketmq.Consumer
  alias ExRocketmq.Models.BrokerData
  alias ExRocketmq.Models.MessageQueue
  alias ExRocketmq.Processor
  alias ExRocketmq.Typespecs

  defstruct client_id: "",
            group_name: "",
            mq: nil,
            buff_manager: nil,
            buff: nil,
            broker_data: nil,
            processor: nil,
            consume_batch_size: 32,
            trace_enable: false,
            max_reconsume_times: 3,
            rt: 0,
            ok_cnt: 0,
            failed_cnt: 0

  @type t :: %__MODULE__{
          client_id: String.t(),
          group_name: Typespecs.group_name(),
          mq: MessageQueue.t(),
          buff_manager: Consumer.BuffManager.t(),
          buff: Consumer.Buff.t(),
          broker_data: BrokerData.t(),
          processor: Processor.t(),
          consume_batch_size: non_neg_integer(),
          trace_enable: boolean(),
          max_reconsume_times: non_neg_integer(),
          rt: non_neg_integer(),
          ok_cnt: non_neg_integer(),
          failed_cnt: non_neg_integer()
        }
end