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, Model, ORMAdapter Classes: BasePublisher, BatchPublisher, Config, ConfigDecorator, DestroyError, Publisher, ReceivingHandler, UndefinedConfig, UpsertError

Constant Summary collapse

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

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.



30
31
32
 
# File 'lib/table_sync.rb', line 30

def batch_publishing_job_class_callable
  @batch_publishing_job_class_callable
end

.exchange_name ⇒ Object

Returns the value of attribute exchange_name.



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

def exchange_name
  @exchange_name
end

.publishing_job_class_callable ⇒ Object

Returns the value of attribute publishing_job_class_callable.



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

def publishing_job_class_callable
  @publishing_job_class_callable
end

.routing_key_callable ⇒ Object

Returns the value of attribute routing_key_callable.



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

def routing_key_callable
  @routing_key_callable
end

.routing_metadata_callable ⇒ Object

Returns the value of attribute routing_metadata_callable.



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

def routing_metadata_callable
  @routing_metadata_callable
end

Class Method Details

.orm=(val) ⇒ Object 



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

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

.sync(*args) ⇒ Object 



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

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