Module: Cumulus::Kinesis::Loader

Includes:: Common::BaseLoader

Defined in:: lib/kinesis/loader/Loader.rb

Constant Summary collapse

@@streams_dir =

Configuration.instance.kinesis.directory

Class Method Summary collapse

.streams ⇒ Object

Methods included from Common::BaseLoader

load_file, resource, resources, template

Class Method Details

.streams ⇒ `Object`



13
14
15

# File 'lib/kinesis/loader/Loader.rb', line 13

def self.streams
  Common::BaseLoader::resources(@@streams_dir, &StreamConfig.method(:new))
end