Sha256: 871485a9db31b79fd4c8eda1981fdc9b3e255ba9ef499958c7f9515e6e011a57
Contents?: true
Size: 1.51 KB
Versions: 11
Compression:
Stored size: 1.51 KB
Contents
# frozen_string_literal: true
module Karafka
module Web
module Tracking
module Consumers
module Contracts
# Partition metrics required for web to operate
class Partition < Web::Contracts::Base
configure
required(:id) { |val| val.is_a?(Integer) && val >= 0 }
required(:lag) { |val| val.is_a?(Integer) }
required(:lag_d) { |val| val.is_a?(Integer) }
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(:committed_offset_fd) { |val| val.is_a?(Integer) && val >= 0 }
required(:stored_offset) { |val| val.is_a?(Integer) }
required(:stored_offset_fd) { |val| val.is_a?(Integer) && val >= 0 }
required(:fetch_state) { |val| val.is_a?(String) && !val.empty? }
required(:poll_state) { |val| val.is_a?(String) && !val.empty? }
required(:hi_offset) { |val| val.is_a?(Integer) }
required(:hi_offset_fd) { |val| val.is_a?(Integer) && val >= 0 }
required(:lo_offset) { |val| val.is_a?(Integer) }
required(:eof_offset) { |val| val.is_a?(Integer) }
required(:ls_offset) { |val| val.is_a?(Integer) }
required(:ls_offset_d) { |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
11 entries across 11 versions & 1 rubygems