Sha256: adb5861dbe49605a0f6aef8c65fd64833a86d11d0b3c65b6f1de3a92ded6de21

Contents?: true

Size: 450 Bytes

Versions: 28

Compression:

Stored size: 450 Bytes

Contents

# frozen_string_literal: true

module Karafka
  module Web
    module Processing
      module Consumers
        module Contracts
          # State process details contract
          class Process < Web::Contracts::Base
            configure

            required(:dispatched_at) { |val| val.is_a?(Numeric) && val.positive? }
            required(:offset) { |val| val.is_a?(Integer) && val >= 0 }
          end
        end
      end
    end
  end
end

Version data entries

28 entries across 28 versions & 1 rubygems

Version Path
karafka-web-0.10.4 lib/karafka/web/processing/consumers/contracts/process.rb
karafka-web-0.10.3 lib/karafka/web/processing/consumers/contracts/process.rb
karafka-web-0.10.2 lib/karafka/web/processing/consumers/contracts/process.rb
karafka-web-0.10.1 lib/karafka/web/processing/consumers/contracts/process.rb
karafka-web-0.10.0 lib/karafka/web/processing/consumers/contracts/process.rb
karafka-web-0.10.0.rc2 lib/karafka/web/processing/consumers/contracts/process.rb
karafka-web-0.10.0.rc1 lib/karafka/web/processing/consumers/contracts/process.rb
karafka-web-0.10.0.beta1 lib/karafka/web/processing/consumers/contracts/process.rb
karafka-web-0.9.1 lib/karafka/web/processing/consumers/contracts/process.rb
karafka-web-0.9.0 lib/karafka/web/processing/consumers/contracts/process.rb
karafka-web-0.9.0.rc3 lib/karafka/web/processing/consumers/contracts/process.rb
karafka-web-0.9.0.rc2 lib/karafka/web/processing/consumers/contracts/process.rb
karafka-web-0.9.0.rc1 lib/karafka/web/processing/consumers/contracts/process.rb
karafka-web-0.8.2 lib/karafka/web/processing/consumers/contracts/process.rb
karafka-web-0.8.1 lib/karafka/web/processing/consumers/contracts/process.rb
karafka-web-0.8.0 lib/karafka/web/processing/consumers/contracts/process.rb
karafka-web-0.8.0.rc1 lib/karafka/web/processing/consumers/contracts/process.rb
karafka-web-0.7.10 lib/karafka/web/processing/consumers/contracts/process.rb
karafka-web-0.7.9 lib/karafka/web/processing/consumers/contracts/process.rb
karafka-web-0.7.8 lib/karafka/web/processing/consumers/contracts/process.rb