Table of Contents - fluent-plugin-in-kinesis-0.0.2 Documentation
Classes and Modules
- FluentPluginKinesis
- FluentPluginKinesis::InputFilter
- KinesisShard
- KinesisShard::MemoryStateStore
- KinesisShard::StateStore
- KinesisSupervisor
Methods
- ::new — KinesisShard::StateStore
- ::new — KinesisShard::MemoryStateStore
- #configure — FluentPluginKinesis::InputFilter
- #emit_records — KinesisShard
- #get_shard_ids — KinesisSupervisor
- #get_shard_iterator_info — KinesisShard
- #load_client — FluentPluginKinesis::InputFilter
- #load_json_file — KinesisShard::StateStore
- #load_records_thread — KinesisShard
- #load_sequence_number — KinesisShard::StateStore
- #load_sequence_number — KinesisShard::MemoryStateStore
- #sequence — KinesisShard
- #shutdown — FluentPluginKinesis::InputFilter
- #start — FluentPluginKinesis::InputFilter
- #supervisor_thread — KinesisSupervisor
- #thread_kill — KinesisSupervisor
- #update — KinesisShard::StateStore
- #update — KinesisShard::MemoryStateStore
- #update_maping — KinesisSupervisor