Module: Wal

Defined in:
lib/wal.rb,
lib/wal/runner.rb,
lib/wal/railtie.rb,
lib/wal/version.rb,
lib/wal/watcher.rb,
lib/wal/migration.rb,
lib/wal/replicator.rb,
lib/wal/noop_watcher.rb,
lib/wal/record_watcher.rb,
lib/wal/logging_watcher.rb,
lib/wal/streaming_watcher.rb,
lib/wal/generators/migration.rb,
lib/wal/active_record_context_extension.rb

Defined Under Namespace

Modules: ActiveRecordContextExtension, ChangeEvent, Generators, Migration, TableName, Watcher Classes: BeginTransactionEvent, CommitTransactionEvent, DeleteEvent, InsertEvent, LoggingWatcher, NoopWatcher, Railtie, RecordWatcher, Replicator, Runner, StreamingWatcher, UpdateEvent

Constant Summary collapse

VERSION = 
"0.0.35"

Class Attribute Summary collapse

Class Method Summary collapse

Class Attribute Details

.hooks ⇒ Object

Returns the value of attribute hooks.



19
20
21
 
# File 'lib/wal.rb', line 19

def hooks
  @hooks
end

.logger ⇒ Object

Returns the value of attribute logger.



18
19
20
 
# File 'lib/wal.rb', line 18

def logger
  @logger
end

Class Method Details

.after_fork(&block) ⇒ Object 



41
42
43
 
# File 'lib/wal.rb', line 41

def after_fork(&block)
  hooks[:after_fork] = block
end

.before_fork(&block) ⇒ Object 



37
38
39
 
# File 'lib/wal.rb', line 37

def before_fork(&block)
  hooks[:before_fork] = block
end

.configure {|_self| ... } ⇒ Object

Yields:

  • (_self)

Yield Parameters:

  • _self (Wal) —

    the object that the method was called on



46
47
48
 
# File 'lib/wal.rb', line 46

def self.configure(&block)
  yield self
end

.on_slot_error(&block) ⇒ Object 



33
34
35
 
# File 'lib/wal.rb', line 33

def on_slot_error(&block)
  hooks[:on_slot_error] = block
end

.on_slot_finished(&block) ⇒ Object 



29
30
31
 
# File 'lib/wal.rb', line 29

def on_slot_finished(&block)
  hooks[:on_slot_finished] = block
end