Contents

module Kcl
  module RecordProcessor
    def init _shared_id; end

    def process_records _records, _checkpointer; end

    def shutdown _checkpointer, _reason; end

    def run
      Process.new(self).run
    end
  end
end

Version data entries

2 entries across 2 versions & 1 rubygems

Version	Path
amazon-kinesis-client-ruby-0.0.3	lib/kcl/record_processor.rb
amazon-kinesis-client-ruby-0.0.1	lib/kcl/record_processor.rb