module PgConduit

Constants

VERSION

Public Class Methods

db_to_db(src, dest) click to toggle source

Create a new DB -> DB Pipe

@param src [String,Hash] Source database connection params @param dest [String,Hash] Destination database connection params @return [PgConduit::Pipe]

# File lib/pg_conduit.rb, line 22
def db_to_db(src, dest)
  connections   = Connections.new src, dest
  query_stream  = QueryStream.new connections.src_pool
  db_writer     = DBWriter.new connections.dest_pool

  Pipe.new from: query_stream, to: db_writer
end
db_to_file(src, dest) click to toggle source

Create a new DB -> File Pipe

@param src [String,Hash] Source database connection params @param dest [Sting,Pathname] Path to destination file @return [PgConduit::Pipe]

# File lib/pg_conduit.rb, line 35
def db_to_file(src, dest)
  pool          = Connections.init_pool src
  query_stream  = QueryStream.new pool
  file_writer   = FileWriter.new dest

  Pipe.new from: query_stream, to: file_writer
end
db_to_null(src) click to toggle source

Create a new DB -> Null pipe

@param src [String,Hash] Source database connection params @return [PgConduit::Pipe]

# File lib/pg_conduit.rb, line 59
def db_to_null(src)
  pool          = Connections.init_pool src
  query_stream  = QueryStream.new pool
  stdout_writer = NullWriter.new

  Pipe.new from: query_stream, to: stdout_writer
end
db_to_stdout(src) click to toggle source

Create a new DB -> STDOUT Pipe

@param src [String,Hash] Source database connection params @return [PgConduit::Pipe]

# File lib/pg_conduit.rb, line 47
def db_to_stdout(src)
  pool          = Connections.init_pool src
  query_stream  = QueryStream.new pool
  stdout_writer = STDOUTWriter.new

  Pipe.new from: query_stream, to: stdout_writer
end