KafkaBatcher.Collector.State (kafka_batcher v1.1.1)

Describes the state of KafkaBatcher.Collector and functions working with it

Summary

Types

t()

Functions

add_events(state, events)

Types

t()

@type t() :: %KafkaBatcher.Collector.State{
  collect_by_partition: boolean(),
  collector: atom() | nil,
  config: Keyword.t(),
  last_check_timestamp: non_neg_integer() | nil,
  locked?: boolean(),
  partitions_count: pos_integer() | nil,
  ready?: boolean(),
  timer_ref: :timer.tref() | nil,
  topic_name: String.t() | nil
}

Functions

add_events(state, events)

@spec add_events(t(), [KafkaBatcher.Collector.Utils.event()]) ::
  {:ok, t()} | {:error, term(), t()}