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