Sha256: 5fdc93f5e4db7c0fe8a91acba4c9be936d1a3dff85eff05f35d967a2b5b8ef4e
Contents?: true
Size: 1001 Bytes
Versions: 10
Compression:
Stored size: 1001 Bytes
Contents
# frozen_string_literal: true
module Karafka
module Web
module Tracking
module Consumers
module Contracts
# Contract for the job reporting details
class Job < BaseContract
configure
required(:consumer) { |val| val.is_a?(String) }
required(:consumer_group) { |val| val.is_a?(String) }
required(:started_at) { |val| val.is_a?(Float) && val >= 0 }
required(:topic) { |val| val.is_a?(String) }
required(:partition) { |val| val.is_a?(Integer) && val >= 0 }
required(:first_offset) { |val| val.is_a?(Integer) && val >= 0 }
required(:last_offset) { |val| val.is_a?(Integer) && val >= 0 }
required(:comitted_offset) { |val| val.is_a?(Integer) }
required(:type) { |val| %w[consume revoked shutdown].include?(val) }
required(:tags) { |val| val.is_a?(Karafka::Core::Taggable::Tags) }
end
end
end
end
end
end
Version data entries
10 entries across 10 versions & 1 rubygems