Sha256: ffed563082b866179eea0b3b88d4d24c739ceaeef42dc4d3d410eb9fcbb29b68
Contents?: true
Size: 490 Bytes
Versions: 6
Compression:
Stored size: 490 Bytes
Contents
# frozen_string_literal: true
module Karafka
module Processing
# Namespace for all the jobs that are suppose to run in workers.
module Jobs
# Base class for all the jobs types that are suppose to run in workers threads.
class Base
extend Forwardable
# @note Since one job has always one executer, we use the jobs id and group id as reference
def_delegators :executor, :id, :group_id
attr_reader :executor
end
end
end
end
Version data entries
6 entries across 6 versions & 1 rubygems