Module: CouchdbToSql

Extended by:
LoggingLibrary::Loggable
Defined in:
lib/couchdb_to_sql.rb,
lib/couchdb_to_sql/schema.rb,
lib/couchdb_to_sql/changes.rb,
lib/couchdb_to_sql/table_builder.rb,
lib/couchdb_to_sql/table_operator.rb,
lib/couchdb_to_sql/table_destroyer.rb,
lib/couchdb_to_sql/document_handler.rb,
lib/couchdb_to_sql/table_deleted_marker.rb

Defined Under Namespace

Classes: Changes, DocumentHandler, Schema, TableBuilder, TableDeletedMarker, TableDestroyer, TableOperator

Constant Summary collapse

Error = 
Class.new(StandardError)
InvalidDataError = 
Class.new(Error)
COUCHDB_TO_SQL_SEQUENCES_TABLE = 
:_couchdb_to_sql_sequences

Class Method Summary collapse

Class Method Details

.changes(database, &block) ⇒ Object 



31
32
33
 
# File 'lib/couchdb_to_sql.rb', line 31

def changes(database, &block)
  (@changes ||= []) << Changes.new(database, &block)
end

.start ⇒ Object 



35
36
37
38
39
40
41
 
# File 'lib/couchdb_to_sql.rb', line 35

def start
  threads = []
  @changes.each do |changes|
    threads << Thread.new(changes, &:start)
  end
  threads.each(&:join)
end