Module: EventStoreClient

Extended by:
Dry::Configurable
Defined in:
lib/event_store_client.rb,
lib/event_store_client/event.rb,
lib/event_store_client/types.rb,
lib/event_store_client/broker.rb,
lib/event_store_client/client.rb,
lib/event_store_client/mapper.rb,
lib/event_store_client/version.rb,
lib/event_store_client/subscription.rb,
lib/event_store_client/configuration.rb,
lib/event_store_client/store_adapter.rb,
lib/event_store_client/subscriptions.rb,
lib/event_store_client/data_decryptor.rb,
lib/event_store_client/data_encryptor.rb,
lib/event_store_client/mapper/default.rb,
lib/event_store_client/mapper/encrypted.rb,
lib/event_store_client/deserialized_event.rb,
lib/event_store_client/encryption_metadata.rb,
lib/event_store_client/store_adapter/in_memory.rb,
lib/event_store_client/store_adapter/api/client.rb,
lib/event_store_client/store_adapter/api/connection.rb,
lib/event_store_client/store_adapter/api/request_method.rb

Defined Under Namespace

Modules: Mapper, StoreAdapter, Types Classes: Broker, Client, DataDecryptor, DataEncryptor, DeserializedEvent, EncryptionMetadata, Event, Subscription, Subscriptions

Constant Summary collapse

VERSION = 
'0.2.6'

Class Method Summary collapse

Class Method Details

.adapter ⇒ Object 



33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
 
# File 'lib/event_store_client/configuration.rb', line 33

def self.adapter
  case config.adapter
  when :api
    StoreAdapter::Api::Client.new(
      config.eventstore_url,
      per_page: config.per_page,
      mapper: config.mapper,
      connection_options: {}
    )
  else
    StoreAdapter::InMemory.new(
      mapper: config.mapper, per_page: config.per_page
    )
  end
end

.configure {|config| ... } ⇒ Object

Yields:

  • (config) 


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

def self.configure
  yield(config) if block_given?
end