Module: TableSync

Extended by:
Memery
Defined in:
lib/table_sync.rb,
lib/table_sync/dsl.rb,
lib/table_sync/config.rb,
lib/table_sync/errors.rb,
lib/table_sync/version.rb,
lib/table_sync/event_actions.rb,
lib/table_sync/config_decorator.rb

Defined Under Namespace

Modules: DSL, EventActions, Instrument, InstrumentAdapter, Model, NamingResolver, ORMAdapter Classes: BasePublisher, BatchPublisher, Config, ConfigDecorator, DestroyError, Publisher, ReceivingHandler, UndefinedConfig, UnprovidedEventTargetKeysError, UpsertError

Constant Summary collapse

Error = 
Class.new(StandardError)
VERSION = 
"1.12.1"

Class Attribute Summary collapse

Class Method Summary collapse

Class Attribute Details

.batch_publishing_job_class_callable ⇒ Object

Returns the value of attribute batch_publishing_job_class_callable.



34
35
36
 
# File 'lib/table_sync.rb', line 34

def batch_publishing_job_class_callable
  @batch_publishing_job_class_callable
end

.exchange_name ⇒ Object

Returns the value of attribute exchange_name.



36
37
38
 
# File 'lib/table_sync.rb', line 36

def exchange_name
  @exchange_name
end

.notifier ⇒ Object

Returns the value of attribute notifier.



38
39
40
 
# File 'lib/table_sync.rb', line 38

def notifier
  @notifier
end

.publishing_job_class_callable ⇒ Object

Returns the value of attribute publishing_job_class_callable.



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

def publishing_job_class_callable
  @publishing_job_class_callable
end

.routing_key_callable ⇒ Object

Returns the value of attribute routing_key_callable.



35
36
37
 
# File 'lib/table_sync.rb', line 35

def routing_key_callable
  @routing_key_callable
end

.routing_metadata_callable ⇒ Object

Returns the value of attribute routing_metadata_callable.



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

def routing_metadata_callable
  @routing_metadata_callable
end

Class Method Details

.orm=(val) ⇒ Object 



44
45
46
47
 
# File 'lib/table_sync.rb', line 44

def orm=(val)
  clear_memery_cache!
  @orm = val
end

.sync(*args) ⇒ Object 



40
41
42
 
# File 'lib/table_sync.rb', line 40

def sync(*args)
  orm.setup_sync(*args)
end