Sha256: 098e3f9bae4c70b51367ff0b331edc6a96c3ab7bd6d246baa60c50c6def7cfac
Contents?: true
Size: 542 Bytes
Versions: 13
Compression:
Stored size: 542 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_stored) { |val| val.is_a?(Integer) }
required(:lag) { |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
13 entries across 13 versions & 1 rubygems