Class: TransactionalOutbox::Database::Adapters::Interface

Inherits:

Object

• Object
• TransactionalOutbox::Database::Adapters::Interface

Defined in:

lib/transactional_outbox/database/adapters/interface.rb

Direct Known Subclasses

Base

Instance Method Summary

• #delete_events(_ids) ⇒ Object
• #fetch_events(_queue_name, _batch_size) ⇒ Object
• #fetch_queues ⇒ Object
• #insert_events(_attributes) ⇒ Object
• #move_to_processing(_ids) ⇒ Object
• #transaction(*_options) ⇒ Object

Instance Method Details

#delete_events(_ids) ⇒ Object

Raises:

• (NotImplementedError)

# File 'lib/transactional_outbox/database/adapters/interface.rb', line 10

def delete_events(_ids) = raise NotImplementedError

#fetch_events(_queue_name, _batch_size) ⇒ Object

Raises:

• (NotImplementedError)

# File 'lib/transactional_outbox/database/adapters/interface.rb', line 9

def fetch_events(_queue_name, _batch_size) = raise NotImplementedError

#fetch_queues ⇒ Object

Raises:

• (NotImplementedError)

# File 'lib/transactional_outbox/database/adapters/interface.rb', line 11

def fetch_queues = raise NotImplementedError

#insert_events(_attributes) ⇒ Object

Raises:

• (NotImplementedError)

# File 'lib/transactional_outbox/database/adapters/interface.rb', line 8

def insert_events(_attributes) = raise NotImplementedError

#move_to_processing(_ids) ⇒ Object

Raises:

• (NotImplementedError)

# File 'lib/transactional_outbox/database/adapters/interface.rb', line 12

def move_to_processing(_ids) = raise NotImplementedError

#transaction(*_options) ⇒ Object

Raises:

• (NotImplementedError)

# File 'lib/transactional_outbox/database/adapters/interface.rb', line 7

def transaction(*_options, &) = raise NotImplementedError