Sha256: 7d460326ea242dad742d6326b8a9ab4729cdd48e01a3d8790bde90bce1070c24
Contents?: true
Size: 1.32 KB
Versions: 11
Compression:
Stored size: 1.32 KB
Contents
# frozen_string_literal: true
module Karafka
module Web
module Tracking
module Consumers
module Contracts
# Contract for the job reporting details
class Job < Web::Contracts::Base
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 || val == -1001) }
required(:last_offset) { |val| val.is_a?(Integer) && (val >= 0 || val == -1001) }
required(:committed_offset) { |val| val.is_a?(Integer) }
required(:messages) { |val| val.is_a?(Integer) && val >= 0 }
required(:type) { |val| %w[consume revoked shutdown].include?(val) }
required(:tags) { |val| val.is_a?(Karafka::Core::Taggable::Tags) }
# -1 can be here for workless flows
required(:consumption_lag) { |val| val.is_a?(Integer) && (val >= 0 || val == -1) }
required(:processing_lag) { |val| val.is_a?(Integer) && (val >= 0 || val == -1) }
end
end
end
end
end
end
Version data entries
11 entries across 11 versions & 1 rubygems