View Source NLdoc.Stream.ConsumerServer (NLdoc.Stream v1.0.0)

A GenServer responsible for managing message consumption and forwarding events to the calling Plug process.

Summary

offset_opt()

opt()

state()

Returns a specification to start this module under a supervisor.

start_link(opts)

@type filter_value_opt() :: {:filter_value, String.t() | nil}

@type offset_opt() :: {:offset, integer() | :first | nil}

@type opt() :: offset_opt() | filter_value_opt()

@type state() :: %{
  caller: pid(),
  id: String.t(),
  channel: AMQP.Channel.t(),
  queue: String.t(),
  consumer_tag: String.t()
}

Returns a specification to start this module under a supervisor.

@spec start_link(keyword()) :: GenServer.on_start()