Sha256: ba2f94d37d491d33731c435f26c7fb29de25f0d6f2b720e945da953295b4aac0

Contents?: true

Size: 301 Bytes

Versions: 1

Compression:

Stored size: 301 Bytes

Contents

# frozen_string_literal: true

module Karafka
  module Pro
    module Processing
      # Pro coordinator that provides extra orchestration methods useful for parallel processing
      # within the same partition
      class Coordinator < ::Karafka::Processing::Coordinator
      end
    end
  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version Path
karafka-2.0.0.beta5 lib/karafka/pro/processing/coordinator.rb