Table of Contents - kcl-rb-1.0.0 Documentation
Classes and Modules
- Kcl
- Kcl::Checkpointer
- Kcl::Checkpoints
- Kcl::Checkpoints::Sentinel
- Kcl::Config
- Kcl::Errors
- Kcl::Errors::CheckpointNotFoundError
- Kcl::Errors::IllegalArgumentError
- Kcl::Errors::LeaseNotAquiredError
- Kcl::Errors::SequenceNumberNotFoundError
- Kcl::Logger
- Kcl::Proxies
- Kcl::Proxies::DynamoDbProxy
- Kcl::Proxies::KinesisProxy
- Kcl::RecordProcessor
- Kcl::RecordProcessorFactory
- Kcl::Types
- Kcl::Types::ExtendedSequenceNumber
- Kcl::Types::InitializationInput
- Kcl::Types::RecordsInput
- Kcl::Types::ShutdownInput
- Kcl::Worker
- Kcl::Workers
- Kcl::Workers::Consumer
- Kcl::Workers::RecordCheckpointer
- Kcl::Workers::ShardInfo
- Kcl::Workers::ShutdownReason
Methods
- ::config — Kcl
- ::configure — Kcl
- ::digits? — Kcl::Types::ExtendedSequenceNumber
- ::digits_or_sentinel? — Kcl::Types::ExtendedSequenceNumber
- ::latest — Kcl::Types::ExtendedSequenceNumber
- ::logger — Kcl
- ::new — Kcl::Checkpointer
- ::new — Kcl::Config
- ::new — Kcl::Proxies::DynamoDbProxy
- ::new — Kcl::Proxies::KinesisProxy
- ::new — Kcl::Types::ExtendedSequenceNumber
- ::new — Kcl::Types::InitializationInput
- ::new — Kcl::Types::RecordsInput
- ::new — Kcl::Types::ShutdownInput
- ::new — Kcl::Worker
- ::new — Kcl::Workers::Consumer
- ::new — Kcl::Workers::RecordCheckpointer
- ::new — Kcl::Workers::ShardInfo
- ::run — Kcl::Worker
- ::sentinel? — Kcl::Types::ExtendedSequenceNumber
- ::shard_end — Kcl::Types::ExtendedSequenceNumber
- ::trim_horizon — Kcl::Types::ExtendedSequenceNumber
- #after_initialize — Kcl::RecordProcessor
- #available_lease_shard? — Kcl::Worker
- #checkpointer — Kcl::Worker
- #cleanup — Kcl::Worker
- #completed? — Kcl::Workers::ShardInfo
- #conditional_update_item — Kcl::Proxies::DynamoDbProxy
- #consume! — Kcl::Workers::Consumer
- #consume_shards! — Kcl::Worker
- #create_initialize_input — Kcl::Workers::Consumer
- #create_processor — Kcl::RecordProcessorFactory
- #create_records_input — Kcl::Workers::Consumer
- #create_shutdown_input — Kcl::Workers::Consumer
- #create_table — Kcl::Proxies::DynamoDbProxy
- #delete_table — Kcl::Proxies::DynamoDbProxy
- #equals — Kcl::Types::ExtendedSequenceNumber
- #exists? — Kcl::Proxies::DynamoDbProxy
- #fetch_checkpoint — Kcl::Checkpointer
- #get_item — Kcl::Proxies::DynamoDbProxy
- #get_records — Kcl::Proxies::KinesisProxy
- #get_shard_iterator — Kcl::Proxies::KinesisProxy
- #kinesis — Kcl::Worker
- #lease — Kcl::Checkpointer
- #lease_owner — Kcl::Workers::ShardInfo
- #lease_owner= — Kcl::Workers::ShardInfo
- #process_records — Kcl::RecordProcessor
- #put_item — Kcl::Proxies::DynamoDbProxy
- #put_record — Kcl::Proxies::KinesisProxy
- #remove_item — Kcl::Proxies::DynamoDbProxy
- #remove_lease — Kcl::Checkpointer
- #remove_lease_owner — Kcl::Checkpointer
- #shards — Kcl::Proxies::KinesisProxy
- #shutdown — Kcl::RecordProcessor
- #shutdown — Kcl::Worker
- #start — Kcl::Worker
- #start_shard_iterator — Kcl::Workers::Consumer
- #sync_shards! — Kcl::Worker
- #to_h — Kcl::Workers::ShardInfo
- #trap_signals — Kcl::Worker
- #update_checkpoint — Kcl::Checkpointer
- #update_checkpoint — Kcl::Workers::RecordCheckpointer
- #update_item — Kcl::Proxies::DynamoDbProxy
- #value — Kcl::Types::ExtendedSequenceNumber