Sha256: 11d136ccabf17a1a37ffb0d8be1fe613846fcd2bd4a7e990ec5d7a8ec474e063
Contents?: true
Size: 633 Bytes
Versions: 17
Compression:
Stored size: 633 Bytes
Contents
# frozen_string_literal: true
module Karafka
module Web
module Tracking
module Consumers
module Contracts
# Partition metrics required for web to operate
class Partition < BaseContract
configure
required(:id) { |val| val.is_a?(Integer) && val >= 0 }
required(:lag_stored) { |val| val.is_a?(Integer) }
required(:lag_stored_d) { |val| val.is_a?(Integer) }
required(:committed_offset) { |val| val.is_a?(Integer) }
required(:stored_offset) { |val| val.is_a?(Integer) }
end
end
end
end
end
end
Version data entries
17 entries across 17 versions & 1 rubygems