class Kcl::Types::InitializationInput
Container for the parameters to the RecordProcessor's method.
Attributes
extended_sequence_number[R]
shard_id[R]
Public Class Methods
new(shard_id, extended_sequence_number)
click to toggle source
@param [String] shard_id
@param [Kcl::Types::ExtendedSequenceNumber] extended_sequence_number
# File lib/kcl/types/initialization_input.rb, line 8 def initialize(shard_id, extended_sequence_number) @shard_id = shard_id @extended_sequence_number = extended_sequence_number end