Sha256: 91cb3a4158b166112fe7ba95d5388fd1ba96fc797973dca1c2e07c837e28b320
Contents?: true
Size: 414 Bytes
Versions: 45
Compression:
Stored size: 414 Bytes
Contents
# frozen_string_literal: true
module Karafka
# Namespace for all different backends Karafka supports
module Backends
# Backend that just runs stuff asap without any scheduling
module Inline
private
# Executes consume code immediately (without enqueuing)
def process
Karafka.monitor.instrument('backends.inline.process', caller: self) { consume }
end
end
end
end
Version data entries
45 entries across 45 versions & 1 rubygems