Sha256: 4facc2cac6a1f23913df04236148ec84e60c19253b85a73be06ba61127df2e12

Contents?: true

Size: 486 Bytes

Versions: 14

Compression:

Stored size: 486 Bytes

Contents

# frozen_string_literal: true

module Karafka
  module Web
    module Processing
      module Consumers
        module Contracts
          # Topic metrics checks
          class TopicStats < Web::Contracts::Base
            configure

            required(:lag_hybrid) { |val| val.is_a?(Integer) }
            required(:pace) { |val| val.is_a?(Integer) }
            required(:ls_offset_fd) { |val| val.is_a?(Integer) && val >= 0 }
          end
        end
      end
    end
  end
end

Version data entries

14 entries across 14 versions & 1 rubygems

Version Path
karafka-web-0.10.3 lib/karafka/web/processing/consumers/contracts/topic_stats.rb
karafka-web-0.10.2 lib/karafka/web/processing/consumers/contracts/topic_stats.rb
karafka-web-0.10.1 lib/karafka/web/processing/consumers/contracts/topic_stats.rb
karafka-web-0.10.0 lib/karafka/web/processing/consumers/contracts/topic_stats.rb
karafka-web-0.10.0.rc2 lib/karafka/web/processing/consumers/contracts/topic_stats.rb
karafka-web-0.10.0.rc1 lib/karafka/web/processing/consumers/contracts/topic_stats.rb
karafka-web-0.10.0.beta1 lib/karafka/web/processing/consumers/contracts/topic_stats.rb
karafka-web-0.9.1 lib/karafka/web/processing/consumers/contracts/topic_stats.rb
karafka-web-0.9.0 lib/karafka/web/processing/consumers/contracts/topic_stats.rb
karafka-web-0.9.0.rc3 lib/karafka/web/processing/consumers/contracts/topic_stats.rb
karafka-web-0.9.0.rc2 lib/karafka/web/processing/consumers/contracts/topic_stats.rb
karafka-web-0.9.0.rc1 lib/karafka/web/processing/consumers/contracts/topic_stats.rb
karafka-web-0.8.2 lib/karafka/web/processing/consumers/contracts/topic_stats.rb
karafka-web-0.8.1 lib/karafka/web/processing/consumers/contracts/topic_stats.rb