Table of Contents - bricolage-streamingload-0.17.2 Documentation
Classes and Modules
- Bricolage
- Bricolage::ObjectMessage
- Bricolage::SQSClientWrapper
- Bricolage::SQSDataSource
- Bricolage::SQSDataSource::DeleteMessageBuffer
- Bricolage::SQSDataSource::DeleteMessageBuffer::Entry
- Bricolage::SQSDataSource::MessageHandler
- Bricolage::SQSMessage
- Bricolage::SQSMock
- Bricolage::SQSMock::Client
- Bricolage::SQSMock::DeleteMessageBatchResponse
- Bricolage::SQSMock::Message
- Bricolage::SQSMock::ReceiveMessageResponse
- Bricolage::SQSMock::Response
- Bricolage::SQSMock::SendMessageResponse
- Bricolage::StreamingLoad
- Bricolage::StreamingLoad::AlertingLogger
- Bricolage::StreamingLoad::CheckPointDispatcherMessage
- Bricolage::StreamingLoad::Chunk
- Bricolage::StreamingLoad::ChunkBuffer
- Bricolage::StreamingLoad::ChunkRouter
- Bricolage::StreamingLoad::ChunkRouter::Route
- Bricolage::StreamingLoad::ChunkRoutingFailed
- Bricolage::StreamingLoad::ControlConnectionFailed
- Bricolage::StreamingLoad::DataConnectionFailed
- Bricolage::StreamingLoad::DispatchDispatcherMessage
- Bricolage::StreamingLoad::Dispatcher
- Bricolage::StreamingLoad::DispatcherMessage
- Bricolage::StreamingLoad::DispatcherOptions
- Bricolage::StreamingLoad::FlushTableDispatcherMessage
- Bricolage::StreamingLoad::IncomingChunk
- Bricolage::StreamingLoad::Job
- Bricolage::StreamingLoad::Job::ControlConnection
- Bricolage::StreamingLoad::Job::ControlConnection::TaskInfo
- Bricolage::StreamingLoad::Job::DataConnection
- Bricolage::StreamingLoad::JobCancelled
- Bricolage::StreamingLoad::JobDefered
- Bricolage::StreamingLoad::JobDuplicated
- Bricolage::StreamingLoad::JobParams
- Bricolage::StreamingLoad::LoadTask
- Bricolage::StreamingLoad::LoadTaskLogger
- Bricolage::StreamingLoad::LoaderMessage
- Bricolage::StreamingLoad::ManifestFile
- Bricolage::StreamingLoad::NoopJob
- Bricolage::StreamingLoad::S3ObjectDispatcherMessage
- Bricolage::StreamingLoad::ShutdownDispatcherMessage
- Bricolage::StreamingLoad::StreamingLoadV3Job
- Bricolage::StreamingLoad::StreamingLoadV3LoaderMessage
- Bricolage::StreamingLoad::TaskHandler
- Bricolage::StreamingLoad::TaskHandlerOptions
- Bricolage::UnknownSQSMessage
Methods
- ::_main — Bricolage::StreamingLoad::Dispatcher
- ::create — Bricolage::SQSMessage
- ::create — Bricolage::StreamingLoad::ShutdownDispatcherMessage
- ::create — Bricolage::StreamingLoad::CheckPointDispatcherMessage
- ::create — Bricolage::StreamingLoad::FlushTableDispatcherMessage
- ::create — Bricolage::StreamingLoad::DispatchDispatcherMessage
- ::create — Bricolage::StreamingLoad::StreamingLoadV3LoaderMessage
- ::create — Bricolage::StreamingLoad::ManifestFile
- ::create_pid_file — Bricolage::StreamingLoad::Dispatcher
- ::create_pid_file — Bricolage::StreamingLoad::TaskHandler
- ::declarations — Bricolage::StreamingLoad::StreamingLoadV3Job
- ::def_mock_method — Bricolage::SQSMock::Client
- ::default_load_options — Bricolage::StreamingLoad::StreamingLoadV3Job
- ::find_job_file — Bricolage::StreamingLoad::JobParams
- ::for_config — Bricolage::StreamingLoad::ChunkRouter
- ::for_load_task — Bricolage::StreamingLoad::StreamingLoadV3LoaderMessage
- ::for_sqs_record — Bricolage::SQSMessage
- ::for_sqs_result — Bricolage::SQSMessage
- ::get_concrete_class — Bricolage::StreamingLoad::DispatcherMessage
- ::get_concrete_class — Bricolage::StreamingLoad::LoaderMessage
- ::get_event_time — Bricolage::SQSMessage
- ::load — Bricolage::StreamingLoad::JobParams
- ::load_bricolage_job — Bricolage::StreamingLoad::JobParams
- ::main — Bricolage::StreamingLoad::Dispatcher
- ::main — Bricolage::StreamingLoad::TaskHandler
- ::new — Bricolage::SQSDataSource
- ::new — Bricolage::SQSDataSource::DeleteMessageBuffer
- ::new — Bricolage::SQSDataSource::DeleteMessageBuffer::Entry
- ::new — Bricolage::SQSClientWrapper
- ::new — Bricolage::SQSMessage
- ::new — Bricolage::ObjectMessage
- ::new — Bricolage::SQSMock::Client
- ::new — Bricolage::SQSMock::Response
- ::new — Bricolage::SQSMock::ReceiveMessageResponse
- ::new — Bricolage::SQSMock::SendMessageResponse
- ::new — Bricolage::SQSMock::DeleteMessageBatchResponse
- ::new — Bricolage::SQSMock::Message
- ::new — Bricolage::StreamingLoad::AlertingLogger
- ::new — Bricolage::StreamingLoad::Chunk
- ::new — Bricolage::StreamingLoad::ChunkBuffer
- ::new — Bricolage::StreamingLoad::ChunkRouter
- ::new — Bricolage::StreamingLoad::ChunkRouter::Route
- ::new — Bricolage::StreamingLoad::Dispatcher
- ::new — Bricolage::StreamingLoad::DispatcherOptions
- ::new — Bricolage::StreamingLoad::IncomingChunk
- ::new — Bricolage::StreamingLoad::Job
- ::new — Bricolage::StreamingLoad::Job::DataConnection
- ::new — Bricolage::StreamingLoad::Job::ControlConnection
- ::new — Bricolage::StreamingLoad::JobParams
- ::new — Bricolage::StreamingLoad::StreamingLoadV3Job
- ::new — Bricolage::StreamingLoad::LoadTask
- ::new — Bricolage::StreamingLoad::LoadTaskLogger
- ::new — Bricolage::StreamingLoad::ManifestFile
- ::new — Bricolage::StreamingLoad::TaskHandler
- ::new — Bricolage::StreamingLoad::NoopJob
- ::new — Bricolage::StreamingLoad::TaskHandlerOptions
- ::new_alerting_logger — Bricolage::StreamingLoad::TaskHandler
- ::new_logger — Bricolage::StreamingLoad::Dispatcher
- ::new_logger — Bricolage::StreamingLoad::TaskHandler
- ::new_mock — Bricolage::SQSDataSource
- ::new_seq — Bricolage::SQSMock::Message
- ::open — Bricolage::StreamingLoad::Job::DataConnection
- ::open — Bricolage::StreamingLoad::Job::ControlConnection
- ::parameters — Bricolage::StreamingLoad::StreamingLoadV3Job
- ::parse_sqs_record — Bricolage::SQSMessage
- ::parse_sqs_record — Bricolage::UnknownSQSMessage
- ::parse_sqs_record — Bricolage::StreamingLoad::ShutdownDispatcherMessage
- ::parse_sqs_record — Bricolage::StreamingLoad::CheckPointDispatcherMessage
- ::parse_sqs_record — Bricolage::StreamingLoad::FlushTableDispatcherMessage
- ::parse_sqs_record — Bricolage::StreamingLoad::S3ObjectDispatcherMessage
- ::parse_sqs_record — Bricolage::StreamingLoad::StreamingLoadV3LoaderMessage
- ::resolve_schema — Bricolage::StreamingLoad::JobParams
- ::s3_object_created_event — Bricolage::SQSMock::Message
- ::successful — Bricolage::SQSMock::Response
- ::successful — Bricolage::SQSMock::ReceiveMessageResponse
- ::successful — Bricolage::SQSMock::SendMessageResponse
- ::with_body — Bricolage::SQSMock::Message
- #abort_job — Bricolage::StreamingLoad::Job::ControlConnection
- #add_failure_for — Bricolage::SQSMock::DeleteMessageBatchResponse
- #add_success_for — Bricolage::SQSMock::DeleteMessageBatchResponse
- #after_message_batch — Bricolage::SQSDataSource::MessageHandler
- #after_message_batch — Bricolage::StreamingLoad::Dispatcher
- #begin_job — Bricolage::StreamingLoad::Job::ControlConnection
- #bind — Bricolage::StreamingLoad::StreamingLoadV3Job
- #body — Bricolage::SQSMessage
- #body — Bricolage::SQSMock::Message
- #body — Bricolage::StreamingLoad::FlushTableDispatcherMessage
- #body — Bricolage::StreamingLoad::StreamingLoadV3LoaderMessage
- #body_object — Bricolage::SQSMock::Message
- #call_handler_method — Bricolage::SQSDataSource::MessageHandler
- #chunk — Bricolage::StreamingLoad::S3ObjectDispatcherMessage
- #client — Bricolage::SQSDataSource
- #commit_duplicated_job — Bricolage::StreamingLoad::Job::ControlConnection
- #commit_job — Bricolage::StreamingLoad::Job::ControlConnection
- #content — Bricolage::StreamingLoad::LoadTaskLogger
- #content — Bricolage::StreamingLoad::ManifestFile
- #create_temporary — Bricolage::StreamingLoad::ManifestFile
- #created_event? — Bricolage::StreamingLoad::S3ObjectDispatcherMessage
- #credential_string — Bricolage::StreamingLoad::ManifestFile
- #ctl_bucket — Bricolage::StreamingLoad::JobParams
- #daemon? — Bricolage::StreamingLoad::DispatcherOptions
- #daemon? — Bricolage::StreamingLoad::TaskHandlerOptions
- #data? — Bricolage::StreamingLoad::DispatcherMessage
- #data? — Bricolage::StreamingLoad::S3ObjectDispatcherMessage
- #data? — Bricolage::StreamingLoad::LoaderMessage
- #delete — Bricolage::StreamingLoad::ManifestFile
- #delete_message — Bricolage::SQSDataSource
- #delete_message — Bricolage::SQSClientWrapper
- #delete_message_async — Bricolage::SQSDataSource
- #delete_message_batch — Bricolage::SQSClientWrapper
- #delete_message_buffer — Bricolage::SQSDataSource
- #dest_table — Bricolage::StreamingLoad::JobParams
- #dispatch_tasks — Bricolage::StreamingLoad::Dispatcher
- #do_handle_checkpoint — Bricolage::StreamingLoad::Dispatcher
- #do_handle_dispatch — Bricolage::StreamingLoad::Dispatcher
- #do_load — Bricolage::StreamingLoad::Job
- #ds — Bricolage::StreamingLoad::JobParams
- #empty? — Bricolage::SQSDataSource::DeleteMessageBuffer
- #enable_work_table? — Bricolage::StreamingLoad::JobParams
- #event_loop — Bricolage::StreamingLoad::Dispatcher
- #event_loop — Bricolage::StreamingLoad::TaskHandler
- #event_time — Bricolage::StreamingLoad::IncomingChunk
- #exception — Bricolage::StreamingLoad::AlertingLogger
- #execute — Bricolage::StreamingLoad::Job
- #execute — Bricolage::StreamingLoad::NoopJob
- #execute_copy — Bricolage::StreamingLoad::Job::DataConnection
- #execute_task — Bricolage::StreamingLoad::Job
- #execute_task — Bricolage::StreamingLoad::NoopJob
- #execute_task_by_id — Bricolage::StreamingLoad::TaskHandler
- #failed! — Bricolage::SQSDataSource::DeleteMessageBuffer::Entry
- #failure_count — Bricolage::StreamingLoad::Job::ControlConnection::TaskInfo
- #fix_job_status — Bricolage::StreamingLoad::Job::ControlConnection
- #fix_last_job_status — Bricolage::StreamingLoad::Job::ControlConnection::TaskInfo
- #flush — Bricolage::SQSDataSource::DeleteMessageBuffer
- #flush_all — Bricolage::StreamingLoad::ChunkBuffer
- #flush_force — Bricolage::SQSDataSource::DeleteMessageBuffer
- #flush_partial — Bricolage::StreamingLoad::ChunkBuffer
- #flush_stream — Bricolage::StreamingLoad::ChunkBuffer
- #force? — Bricolage::StreamingLoad::StreamingLoadV3LoaderMessage
- #force? — Bricolage::StreamingLoad::TaskHandlerOptions
- #full? — Bricolage::SQSDataSource::DeleteMessageBuffer
- #get_component — Bricolage::StreamingLoad::ChunkRouter::Route
- #get_job_status — Bricolage::StreamingLoad::Job::DataConnection
- #handle — Bricolage::SQSDataSource::MessageHandler
- #handle_checkpoint — Bricolage::StreamingLoad::Dispatcher
- #handle_data — Bricolage::StreamingLoad::Dispatcher
- #handle_dispatch — Bricolage::StreamingLoad::Dispatcher
- #handle_flushtable — Bricolage::StreamingLoad::Dispatcher
- #handle_messages — Bricolage::SQSDataSource
- #handle_shutdown — Bricolage::StreamingLoad::Dispatcher
- #handle_streaming_load_v3 — Bricolage::StreamingLoad::TaskHandler
- #handle_unknown — Bricolage::SQSDataSource::MessageHandler
- #handle_unknown — Bricolage::StreamingLoad::Dispatcher
- #handle_unknown — Bricolage::StreamingLoad::TaskHandler
- #handleable? — Bricolage::SQSDataSource::MessageHandler
- #handler_method — Bricolage::SQSDataSource::MessageHandler
- #init_message — Bricolage::UnknownSQSMessage
- #init_message — Bricolage::StreamingLoad::ShutdownDispatcherMessage
- #init_message — Bricolage::StreamingLoad::CheckPointDispatcherMessage
- #init_message — Bricolage::StreamingLoad::FlushTableDispatcherMessage
- #init_message — Bricolage::StreamingLoad::DispatchDispatcherMessage
- #init_message — Bricolage::StreamingLoad::S3ObjectDispatcherMessage
- #init_message — Bricolage::StreamingLoad::StreamingLoadV3LoaderMessage
- #initiate_terminate — Bricolage::SQSDataSource
- #insert_dup_object — Bricolage::StreamingLoad::ChunkBuffer
- #insert_handler_wait — Bricolage::SQSDataSource
- #insert_object — Bricolage::StreamingLoad::ChunkBuffer
- #insert_task_objects — Bricolage::StreamingLoad::ChunkBuffer
- #insert_tasks — Bricolage::StreamingLoad::ChunkBuffer
- #insert_tasks_for_stream — Bricolage::StreamingLoad::ChunkBuffer
- #issuable? — Bricolage::SQSDataSource::DeleteMessageBuffer::Entry
- #job_class — Bricolage::StreamingLoad::TaskHandler
- #key — Bricolage::StreamingLoad::LoadTaskLogger
- #last_job_id — Bricolage::StreamingLoad::Job::ControlConnection::TaskInfo
- #load_jobs — Bricolage::StreamingLoad::Job::ControlConnection
- #load_object_urls — Bricolage::StreamingLoad::Job::ControlConnection
- #load_objects — Bricolage::StreamingLoad::Job::DataConnection
- #load_options_string — Bricolage::StreamingLoad::JobParams
- #load_task — Bricolage::StreamingLoad::Job::ControlConnection
- #load_tasks — Bricolage::StreamingLoad::ChunkBuffer
- #load_tasks_by_id — Bricolage::StreamingLoad::ChunkBuffer
- #load_with_work_table — Bricolage::StreamingLoad::Job::DataConnection
- #log — Bricolage::StreamingLoad::LoadTaskLogger
- #log_task_ids — Bricolage::StreamingLoad::ChunkBuffer
- #match — Bricolage::StreamingLoad::ChunkRouter::Route
- #message_type — Bricolage::UnknownSQSMessage
- #message_type — Bricolage::StreamingLoad::DispatcherMessage
- #message_type — Bricolage::StreamingLoad::S3ObjectDispatcherMessage
- #message_type — Bricolage::StreamingLoad::LoaderMessage
- #name — Bricolage::StreamingLoad::ManifestFile
- #new_job — Bricolage::StreamingLoad::TaskHandler
- #next_retry_interval — Bricolage::SQSDataSource::DeleteMessageBuffer::Entry
- #noop? — Bricolage::StreamingLoad::TaskHandlerOptions
- #open — Bricolage::StreamingLoad::Job::DataConnection
- #open — Bricolage::StreamingLoad::Job::ControlConnection
- #parse — Bricolage::StreamingLoad::DispatcherOptions
- #parse — Bricolage::StreamingLoad::TaskHandlerOptions
- #poll — Bricolage::SQSDataSource
- #polling_loop — Bricolage::SQSDataSource
- #process_async_delete — Bricolage::SQSDataSource
- #process_async_delete_force — Bricolage::SQSDataSource
- #put — Bricolage::SQSDataSource
- #put — Bricolage::SQSDataSource::DeleteMessageBuffer
- #put — Bricolage::StreamingLoad::ManifestFile
- #receive_message — Bricolage::SQSClientWrapper
- #receive_messages — Bricolage::SQSDataSource
- #request_params — Bricolage::SQSDataSource::DeleteMessageBuffer::Entry
- #route — Bricolage::StreamingLoad::ChunkRouter
- #save — Bricolage::StreamingLoad::ChunkBuffer
- #send_event — Bricolage::SQSDataSource
- #send_message — Bricolage::SQSDataSource
- #send_message — Bricolage::SQSClientWrapper
- #send_object — Bricolage::SQSDataSource
- #set_dispatch_timer — Bricolage::StreamingLoad::Dispatcher
- #size — Bricolage::SQSDataSource::DeleteMessageBuffer
- #sql_source — Bricolage::StreamingLoad::JobParams
- #successful? — Bricolage::SQSMock::Response
- #suppress_sql_logging — Bricolage::StreamingLoad::ChunkBuffer
- #terminating? — Bricolage::SQSDataSource
- #too_many_failure? — Bricolage::SQSDataSource::DeleteMessageBuffer::Entry
- #trap_signals — Bricolage::SQSDataSource
- #unknown_state? — Bricolage::StreamingLoad::Job::ControlConnection::TaskInfo
- #update_loaded_flag — Bricolage::StreamingLoad::Job::ControlConnection
- #update_task_objects — Bricolage::StreamingLoad::ChunkBuffer
- #url — Bricolage::StreamingLoad::S3ObjectDispatcherMessage
- #url — Bricolage::StreamingLoad::ManifestFile
- #usage — Bricolage::StreamingLoad::DispatcherOptions
- #usage — Bricolage::StreamingLoad::TaskHandlerOptions
- #wait_for_connection — Bricolage::StreamingLoad::Job
- #warn_slow_task_generation — Bricolage::StreamingLoad::ChunkBuffer
- #work_table — Bricolage::StreamingLoad::JobParams
- #write_job_result — Bricolage::StreamingLoad::Job::ControlConnection
- #write_load_log — Bricolage::StreamingLoad::Job::DataConnection