Module: EventRouter
- Defined in:
- lib/event_router.rb,
lib/event_router/error.rb,
lib/event_router/event.rb,
lib/event_router/version.rb,
lib/event_router/publisher.rb,
lib/event_router/serializer.rb,
lib/event_router/destination.rb,
lib/event_router/configuration.rb,
lib/event_router/serializers/oj.rb,
lib/event_router/serializers/base.rb,
lib/event_router/serializers/json.rb,
lib/event_router/delivery_adapters/base.rb,
lib/event_router/delivery_adapters/sync.rb,
lib/event_router/delivery_adapters/sidekiq.rb,
lib/event_router/errors/required_option_error.rb,
lib/event_router/errors/unsupported_option_error.rb,
lib/event_router/delivery_adapters/jobs/sidekiq_event_delivery_job.rb
Defined Under Namespace
Modules: DeliveryAdapters, Errors, Publisher, Serializer, Serializers
Classes: Configuration, Destination, Error, Event
Constant Summary
collapse
- VERSION =
'0.1.0'
Class Method Summary
collapse
Class Method Details
.configuration ⇒ Object
28
29
30
|
# File 'lib/event_router.rb', line 28
def configuration
@configuration ||= Configuration.new
end
|
32
33
34
|
# File 'lib/event_router.rb', line 32
def configure
yield configuration if block_given?
end
|
.deserialize(payload, adapter: EventRouter.configuration.serializer_adapter) ⇒ Object
24
25
26
|
# File 'lib/event_router.rb', line 24
def deserialize(payload, adapter: EventRouter.configuration.serializer_adapter)
EventRouter::Serializer.deserialize(payload, adapter: adapter)
end
|
.publish(events, adapter: EventRouter.configuration.delivery_adapter) ⇒ Object
16
17
18
|
# File 'lib/event_router.rb', line 16
def publish(events, adapter: EventRouter.configuration.delivery_adapter)
EventRouter::Publisher.publish(events, adapter: adapter)
end
|
.serialize(event, adapter: EventRouter.configuration.serializer_adapter) ⇒ Object
20
21
22
|
# File 'lib/event_router.rb', line 20
def serialize(event, adapter: EventRouter.configuration.serializer_adapter)
EventRouter::Serializer.serialize(event, adapter: adapter)
end
|