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/error_handler.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/adapters/in_memory.rb,
lib/event_store_client/deserialized_event.rb,
lib/event_store_client/encryption_metadata.rb,
lib/event_store_client/adapters/grpc/client.rb,
lib/event_store_client/adapters/http/client.rb,
lib/event_store_client/catch_up_subscription.rb,
lib/event_store_client/catch_up_subscriptions.rb,
lib/event_store_client/adapters/grpc/connection.rb,
lib/event_store_client/adapters/http/connection.rb,
lib/event_store_client/adapters/http/request_method.rb,
lib/event_store_client/value_objects/read_direction.rb,
lib/event_store_client/adapters/grpc/commands/command.rb,
lib/event_store_client/adapters/http/commands/command.rb,
lib/event_store_client/adapters/grpc/command_registrar.rb,
lib/event_store_client/adapters/grpc/commands/streams/read.rb,
lib/event_store_client/adapters/http/commands/streams/read.rb,
lib/event_store_client/adapters/grpc/commands/streams/append.rb,
lib/event_store_client/adapters/grpc/commands/streams/delete.rb,
lib/event_store_client/adapters/http/commands/streams/append.rb,
lib/event_store_client/adapters/http/commands/streams/delete.rb,
lib/event_store_client/adapters/grpc/commands/streams/link_to.rb,
lib/event_store_client/adapters/http/commands/streams/link_to.rb,
lib/event_store_client/adapters/grpc/commands/streams/read_all.rb,
lib/event_store_client/adapters/grpc/commands/streams/subscribe.rb,
lib/event_store_client/adapters/grpc/commands/streams/tombstone.rb,
lib/event_store_client/adapters/http/commands/streams/tombstone.rb,
lib/event_store_client/adapters/grpc/commands/projections/create.rb,
lib/event_store_client/adapters/grpc/commands/projections/delete.rb,
lib/event_store_client/adapters/grpc/commands/projections/update.rb,
lib/event_store_client/adapters/http/commands/projections/create.rb,
lib/event_store_client/adapters/http/commands/projections/update.rb,
lib/event_store_client/adapters/http/commands/persistent_subscriptions/ack.rb,
lib/event_store_client/adapters/grpc/commands/persistent_subscriptions/read.rb,
lib/event_store_client/adapters/http/commands/persistent_subscriptions/read.rb,
lib/event_store_client/adapters/grpc/commands/persistent_subscriptions/create.rb,
lib/event_store_client/adapters/grpc/commands/persistent_subscriptions/delete.rb,
lib/event_store_client/adapters/grpc/commands/persistent_subscriptions/update.rb,
lib/event_store_client/adapters/http/commands/persistent_subscriptions/create.rb,
lib/event_store_client/adapters/grpc/commands/persistent_subscriptions/settings_schema.rb

Defined Under Namespace

Modules: Configuration, GRPC, HTTP, Mapper, Types Classes: Broker, CatchUpSubscription, CatchUpSubscriptions, Client, DataDecryptor, DataEncryptor, DeserializedEvent, EncryptionMetadata, ErrorHandler, Event, InMemory, ReadDirection, Subscription, Subscriptions

Constant Summary collapse

VERSION = 
'1.4.9'

Class Method Summary collapse

Class Method Details

.adapter ⇒ Object 



47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
 
# File 'lib/event_store_client/configuration.rb', line 47

def self.adapter
  @adapter =
    case config.adapter
    when :http
      require 'event_store_client/adapters/http'
      HTTP::Client.new
    when :grpc
      require 'event_store_client/adapters/grpc'
      GRPC::Client.new
    else
      require 'event_store_client/adapters/in_memory'
      InMemory.new(
        mapper: config.mapper, per_page: config.per_page
      )
    end
end

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

Yields:

  • (config) 


43
44
45
 
# File 'lib/event_store_client/configuration.rb', line 43

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