Class: Mammoth::FanoutDeliveryWorker

Inherits:
Object
  • Object
show all
Defined in:
lib/mammoth/fanout_delivery_worker.rb

Overview

Delivers one CDC work item to multiple destination-specific workers.

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(delivery_workers) ⇒ FanoutDeliveryWorker

Returns a new instance of FanoutDeliveryWorker.

Parameters:

Raises:



9
10
11
12
13
 
# File 'lib/mammoth/fanout_delivery_worker.rb', line 9

def initialize(delivery_workers)
  raise ConfigurationError, "at least one destination is required" if delivery_workers.empty?

  @delivery_workers = delivery_workers
end

Instance Attribute Details

#delivery_workers ⇒ Object (readonly)

Returns the value of attribute delivery_workers.



6
7
8
 
# File 'lib/mammoth/fanout_delivery_worker.rb', line 6

def delivery_workers
  @delivery_workers
end

Instance Method Details

#deliver(event) ⇒ Hash

Deliver an event to every configured destination.

Parameters:

  • event (Hash, #to_h) —

    normalized event

Returns:

  • (Hash) —

    aggregate fanout summary



19
20
21
 
# File 'lib/mammoth/fanout_delivery_worker.rb', line 19

def deliver(event)
  fanout(:deliver, event)
end

#deliver_to(destination_name, event) ⇒ Hash

Deliver an event to one configured destination.

Parameters:

  • destination_name (String) —

    destination name

  • event (Hash, #to_h) —

    normalized event

Returns:

  • (Hash) —

    destination delivery summary



36
37
38
 
# File 'lib/mammoth/fanout_delivery_worker.rb', line 36

def deliver_to(destination_name, event)
  worker_for(destination_name).deliver(event)
end

#deliver_transaction(envelope) ⇒ Hash

Deliver a transaction envelope to every configured destination.

Parameters:

  • envelope (#events, #transaction_id) —

    CDC transaction envelope

Returns:

  • (Hash) —

    aggregate fanout summary



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

def deliver_transaction(envelope)
  fanout(:deliver_transaction, envelope)
end

#deliver_transaction_to(destination_name, envelope) ⇒ Hash

Deliver a transaction envelope to one configured destination.

Parameters:

  • destination_name (String) —

    destination name

  • envelope (#events, #transaction_id) —

    CDC transaction envelope

Returns:

  • (Hash) —

    destination delivery summary



45
46
47
 
# File 'lib/mammoth/fanout_delivery_worker.rb', line 45

def deliver_transaction_to(destination_name, envelope)
  worker_for(destination_name).deliver_transaction(envelope)
end