Sha256: bced833f24e622400b26401e643047b4675728ed9dcbc05ff772a67e09835264
Contents?: true
Size: 1.09 KB
Versions: 19
Compression:
Stored size: 1.09 KB
Contents
# frozen_string_literal: true
module Karafka
module Web
module Ui
module Models
# Model used for accessing watermark offsets
class WatermarkOffsets < Lib::HashProxy
class << self
# Retrieve watermark offsets for given topic partition
#
# @param topic_id [String]
# @param partition_id [Integer]
# @return [WatermarkOffsets]
def find(topic_id, partition_id)
offsets = ::Karafka::Admin.read_watermark_offsets(topic_id, partition_id)
new(
low: offsets.first,
high: offsets.last
)
end
end
# @return [Boolean] true if given partition never had any messages and is empty
def empty?
low.zero? && high.zero?
end
# @return [Boolean] true if given partition had data but all of it was removed due
# to log retention and compaction policies
def cleaned?
!empty? && low == high
end
end
end
end
end
end
Version data entries
19 entries across 19 versions & 1 rubygems