Module: Karafka::Web::Processing::Consumers::Aggregators::State::Steps

Defined in:

lib/karafka/web/processing/consumers/aggregators/state/steps/base.rb,
lib/karafka/web/processing/consumers/aggregators/state/steps/register_process.rb,
lib/karafka/web/processing/consumers/aggregators/state/steps/increment_counters.rb,
lib/karafka/web/processing/consumers/aggregators/state/steps/refresh_current_stats.rb,
lib/karafka/web/processing/consumers/aggregators/state/steps/evict_expired_processes.rb

Overview

Namespace for all individual State pipeline step classes.

Each step is a small, isolated class that enriches the shared Context in place. Unlike Ui::Models::Status::Checks, steps here are unconditional and strictly ordered (see State::STEPS) - there is no dependency/halting DSL, each step just mutates the context so the next step sees the enriched result.

Defined Under Namespace

Classes: Base, EvictExpiredProcesses, IncrementCounters, RefreshCurrentStats, RegisterProcess