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