Module: TableSync::Instrument

Extended by:: Instrument

Included in:: Instrument

Defined in:: lib/table_sync/instrument.rb

Constant Summary collapse

NOTIFIER_REQUIRED_ARGS =

i[table schema event count direction].freeze

Instance Method Summary collapse

#notify(**args) ⇒ Object

Instance Method Details

#notify(**args) ⇒ `Object`

Raises:

(TableSync::InvalidConfig)

# File 'lib/table_sync/instrument.rb', line 8

def notify(**args)
  return unless TableSync.notify?
  raise(TableSync::InvalidConfig, error_message) if TableSync.notifier.nil?
  validate_args!(**args)

  TableSync.notifier.notify(**args)
end