Sha256: fb38fde1aefc96333c512001b08764db2970a44d251993c521720b4b1d568978
Contents?: true
Size: 646 Bytes
Versions: 4
Compression:
Stored size: 646 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 < Tracking::Contracts::Base
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
4 entries across 4 versions & 1 rubygems