Module: TableSync

Defined in:
lib/table_sync.rb,
lib/table_sync/utils.rb,
lib/table_sync/errors.rb,
lib/table_sync/version.rb,
lib/table_sync/receiving.rb,
lib/table_sync/publishing.rb

Defined Under Namespace

Modules: Instrument, InstrumentAdapter, NamingResolver, Publishing, Receiving, Utils Classes: AlreadyRegisteredPluginError, DataError, DestroyError, InterfaceError, UnregisteredPluginError, UpsertError, WrongOptionValue

Constant Summary collapse

Error = 
Class.new(StandardError)
PluginError =

Since:

  • 2.2.0

Class.new(Error)
UndefinedEvent = 
Class.new(Error)
ORMNotSupported = 
Class.new(Error)
VERSION = 
"5.1.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.



23
24
25
 
# File 'lib/table_sync.rb', line 23

def batch_publishing_job_class_callable
  @batch_publishing_job_class_callable
end

.exchange_name ⇒ Object

Returns the value of attribute exchange_name.



25
26
27
 
# File 'lib/table_sync.rb', line 25

def exchange_name
  @exchange_name
end

.notifier ⇒ Object

Returns the value of attribute notifier.



27
28
29
 
# File 'lib/table_sync.rb', line 27

def notifier
  @notifier
end

.orm ⇒ Object

Returns the value of attribute orm.



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

def orm
  @orm
end

.publishing_adapter ⇒ Object (readonly)

Returns the value of attribute publishing_adapter.



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

def publishing_adapter
  @publishing_adapter
end

.publishing_job_class_callable ⇒ Object

Returns the value of attribute publishing_job_class_callable.



22
23
24
 
# File 'lib/table_sync.rb', line 22

def publishing_job_class_callable
  @publishing_job_class_callable
end

.receiving_model ⇒ Object (readonly)

Returns the value of attribute receiving_model.



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

def receiving_model
  @receiving_model
end

.routing_key_callable ⇒ Object

Returns the value of attribute routing_key_callable.



24
25
26
 
# File 'lib/table_sync.rb', line 24

def routing_key_callable
  @routing_key_callable
end

.routing_metadata_callable ⇒ Object

Returns the value of attribute routing_metadata_callable.



26
27
28
 
# File 'lib/table_sync.rb', line 26

def routing_metadata_callable
  @routing_metadata_callable
end

Class Method Details

.sync(klass, **opts) ⇒ Object 



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

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