Module: Karafka::Processing

Defined in:

lib/karafka/processing/executor.rb,
lib/karafka/processing/result.rb,
lib/karafka/processing/worker.rb,
lib/karafka/processing/jobs/base.rb,
lib/karafka/processing/jobs/idle.rb,
lib/karafka/processing/jobs/eofed.rb,
lib/karafka/processing/jobs_queue.rb,
lib/karafka/processing/coordinator.rb,
lib/karafka/processing/partitioner.rb,
lib/karafka/processing/timed_queue.rb,
lib/karafka/processing/jobs/consume.rb,
lib/karafka/processing/jobs/revoked.rb,
lib/karafka/processing/jobs_builder.rb,
lib/karafka/processing/jobs/shutdown.rb,
lib/karafka/processing/workers_batch.rb,
lib/karafka/processing/strategies/dlq.rb,
lib/karafka/processing/strategies/mom.rb,
lib/karafka/processing/strategies/base.rb,
lib/karafka/processing/executors_buffer.rb,
lib/karafka/processing/strategies/aj_mom.rb,
lib/karafka/processing/strategy_selector.rb,
lib/karafka/processing/schedulers/default.rb,
lib/karafka/processing/strategies/default.rb,
lib/karafka/processing/strategies/dlq_mom.rb,
lib/karafka/processing/coordinators_buffer.rb,
lib/karafka/processing/expansions_selector.rb,
lib/karafka/processing/strategies/aj_dlq_mom.rb,
lib/karafka/processing/inline_insights/tracker.rb,
lib/karafka/processing/inline_insights/consumer.rb,
lib/karafka/processing/inline_insights/listener.rb

Overview

Namespace that encapsulates all the logic related to processing data.

Defined Under Namespace

Modules: InlineInsights, Jobs, Schedulers, Strategies Classes: Coordinator, CoordinatorsBuffer, Executor, ExecutorsBuffer, ExpansionsSelector, JobsBuilder, JobsQueue, Partitioner, Result, StrategySelector, TimedQueue, Worker, WorkersBatch