Module: Karafka::Web::Processing

Defined in:

lib/karafka/web/processing/consumer.rb,
lib/karafka/web/processing/publisher.rb,
lib/karafka/web/processing/consumers/state.rb,
lib/karafka/web/processing/consumers/metrics.rb,
lib/karafka/web/processing/time_series_tracker.rb,
lib/karafka/web/processing/consumers/schema_manager.rb,
lib/karafka/web/processing/consumers/contracts/state.rb,
lib/karafka/web/processing/consumers/aggregators/base.rb,
lib/karafka/web/processing/consumers/aggregators/state.rb,
lib/karafka/web/processing/consumers/contracts/metrics.rb,
lib/karafka/web/processing/consumers/contracts/process.rb,
lib/karafka/web/processing/consumers/aggregators/metrics.rb,
lib/karafka/web/processing/consumers/contracts/topic_stats.rb,
lib/karafka/web/processing/consumers/contracts/aggregated_stats.rb

Overview

Namespace used to encapsulate all the components needed to process the states data and store it back in Kafka

Defined Under Namespace

Modules: Consumers Classes: Consumer, Publisher, TimeSeriesTracker