class Kcl::Types::ShutdownInput
Container for the parameters to the IRecordProcessor's method.
Attributes
record_checkpointer[R]
shutdown_reason[R]
Public Class Methods
new(shutdown_reason, record_checkpointer)
click to toggle source
@param [Kcl::Worker::ShutdownReason] shutdown_reason
@param [Kcl::Workers::RecordCheckpointer] record_checkpointer
# File lib/kcl/types/shutdown_input.rb, line 8 def initialize(shutdown_reason, record_checkpointer) @shutdown_reason = shutdown_reason @record_checkpointer = record_checkpointer end