Class: Karafka::Pro::Processing::ConsumerGroups::JobsBuilder

Inherits:
Karafka::Processing::ConsumerGroups::JobsBuilder show all
Defined in:
lib/karafka/pro/processing/consumer_groups/jobs_builder.rb

Overview

Pro jobs builder that supports lrj

Instance Method Summary collapse

Methods inherited from Karafka::Processing::ConsumerGroups::JobsBuilder

#shutdown

Instance Method Details

#consume(executor, messages) ⇒ Karafka::Processing::ConsumerGroups::Jobs::Consume, Karafka::Pro::Processing::ConsumerGroups::Jobs::ConsumeNonBlocking

Parameters:

Returns:



47
48
49
50
51
52
53
 
# File 'lib/karafka/pro/processing/consumer_groups/jobs_builder.rb', line 47

def consume(executor, messages)
  if executor.topic.long_running_job?
    Jobs::ConsumeNonBlocking.new(executor, messages)
  else
    super
  end
end

#eofed(executor) ⇒ Karafka::Processing::ConsumerGroups::Jobs::Eofed, Karafka::Pro::Processing::ConsumerGroups::Jobs::EofedNonBlocking

Parameters:

Returns:



59
60
61
62
63
64
65
 
# File 'lib/karafka/pro/processing/consumer_groups/jobs_builder.rb', line 59

def eofed(executor)
  if executor.topic.long_running_job?
    Jobs::EofedNonBlocking.new(executor)
  else
    super
  end
end

#idle(executor) ⇒ Object

Parameters:



38
39
40
 
# File 'lib/karafka/pro/processing/consumer_groups/jobs_builder.rb', line 38

def idle(executor)
  Karafka::Processing::ConsumerGroups::Jobs::Idle.new(executor)
end

#periodic(executor) ⇒ Karafka::Pro::Processing::ConsumerGroups::Jobs::Periodic, Karafka::Pro::Processing::ConsumerGroups::Jobs::PeriodicNonBlocking

Parameters:

Returns:



84
85
86
87
88
89
90
 
# File 'lib/karafka/pro/processing/consumer_groups/jobs_builder.rb', line 84

def periodic(executor)
  if executor.topic.long_running_job?
    Jobs::PeriodicNonBlocking.new(executor)
  else
    Jobs::Periodic.new(executor)
  end
end

#revoked(executor) ⇒ Karafka::Processing::ConsumerGroups::Jobs::Revoked, Karafka::Pro::Processing::ConsumerGroups::Jobs::RevokedNonBlocking

Parameters:

Returns:



72
73
74
75
76
77
78
 
# File 'lib/karafka/pro/processing/consumer_groups/jobs_builder.rb', line 72

def revoked(executor)
  if executor.topic.long_running_job?
    Jobs::RevokedNonBlocking.new(executor)
  else
    super
  end
end