t() View Source

t() :: %Rill.Consumer{
  batch_size: pos_integer(),
  condition: nil | term(),
  handlers: [module()],
  identifier: String.t(),
  messages: [
    %Rill.MessageStore.MessageData.Read{
      data: term(),
      global_position: term(),
      id: term(),
      metadata: term(),
      position: term(),
      stream_name: term(),
      time: term(),
      type: term()
    }
  ],
  poll_interval_milliseconds: pos_integer(),
  position: pos_integer(),
  session: nil | Rill.Session.t(),
  stream_name: Rill.MessageStore.StreamName.t(),
  timer_ref: nil | term()
}