Module: TableSync

Extended by:
Memery, Plugins::AccessMixin
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, Plugins Classes: AlreadyRegisteredPluginError, BasePublisher, BatchPublisher, Config, ConfigDecorator, DestroyError, Publisher, ReceivingHandler, UndefinedConfig, UnprovidedEventTargetKeysError, UnregisteredPluginError, UpsertError

Constant Summary collapse

Error = 
Class.new(StandardError)
PluginError =

Since:

  • 2.2.0

Class.new(Error)
VERSION = 
"2.3.0"

Class Attribute Summary collapse

Class Method Summary collapse

Methods included from Plugins::AccessMixin

loaded_plugins, plugin, plugins, register_plugin

Class Attribute Details

.batch_publishing_job_class_callable ⇒ Object

Returns the value of attribute batch_publishing_job_class_callable.



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

def batch_publishing_job_class_callable
  @batch_publishing_job_class_callable
end

.exchange_name ⇒ Object

Returns the value of attribute exchange_name.



42
43
44
 
# File 'lib/table_sync.rb', line 42

def exchange_name
  @exchange_name
end

.notifier ⇒ Object

Returns the value of attribute notifier.



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

def notifier
  @notifier
end

.publishing_job_class_callable ⇒ Object

Returns the value of attribute publishing_job_class_callable.



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

def publishing_job_class_callable
  @publishing_job_class_callable
end

.routing_key_callable ⇒ Object

Returns the value of attribute routing_key_callable.



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

def routing_key_callable
  @routing_key_callable
end

.routing_metadata_callable ⇒ Object

Returns the value of attribute routing_metadata_callable.



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

def routing_metadata_callable
  @routing_metadata_callable
end

Class Method Details

.orm=(val) ⇒ Object 



50
51
52
53
 
# File 'lib/table_sync.rb', line 50

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

.sync(klass, **opts) ⇒ Object 



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

def sync(klass, **opts)
  orm.setup_sync(klass, opts)
end