Module: EventStoreClient

Defined in:
lib/event_store_client/utils.rb,
lib/event_store_client.rb,
lib/event_store_client/config.rb,
lib/event_store_client/errors.rb,
lib/event_store_client/mapper.rb,
lib/event_store_client/version.rb,
lib/event_store_client/connection/url.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/serializer/json.rb,
lib/event_store_client/mapper/encrypted.rb,
lib/event_store_client/serialized_event.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/event_class_resolver.rb,
lib/event_store_client/connection/url_parser.rb,
lib/event_store_client/adapters/grpc/discover.rb,
lib/event_store_client/adapters/grpc/connection.rb,
lib/event_store_client/serializer/event_serializer.rb,
lib/event_store_client/adapters/grpc/cluster/member.rb,
lib/event_store_client/extensions/options_extension.rb,
lib/event_store_client/serializer/event_deserializer.rb,
lib/event_store_client/adapters/grpc/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/grpc/cluster/gossip_discover.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/grpc/commands/streams/link_to.rb,
lib/event_store_client/adapters/grpc/cluster/secure_connection.rb,
lib/event_store_client/adapters/grpc/cluster/queryless_discover.rb,
lib/event_store_client/adapters/grpc/commands/streams/subscribe.rb,
lib/event_store_client/adapters/grpc/cluster/insecure_connection.rb,
lib/event_store_client/adapters/grpc/commands/gossip/cluster_info.rb,
lib/event_store_client/adapters/grpc/commands/streams/hard_delete.rb,
lib/event_store_client/adapters/grpc/options/streams/read_options.rb,
lib/event_store_client/adapters/grpc/options/streams/write_options.rb,
lib/event_store_client/adapters/grpc/shared/options/filter_options.rb,
lib/event_store_client/adapters/grpc/shared/options/stream_options.rb,
lib/event_store_client/adapters/grpc/commands/streams/read_paginated.rb,
lib/event_store_client/adapters/grpc/shared/streams/process_response.rb,
lib/event_store_client/adapters/grpc/commands/streams/append_multiple.rb,
lib/event_store_client/adapters/grpc/shared/streams/process_responses.rb,
lib/event_store_client/adapters/grpc/commands/streams/link_to_multiple.rb

Overview

rubocop:disable Naming/PredicateName

Defined Under Namespace

Modules: Connection, Extensions, GRPC, Mapper, Serializer Classes: Config, DataDecryptor, DataEncryptor, DeserializedEvent, EncryptionMetadata, Error, EventClassResolver, SerializedEvent, StreamDeletionError, StreamNotFoundError, Utils, WrongExpectedVersionError

Constant Summary collapse

VERSION = 
'3.2.0'

Class Method Summary collapse

Class Method Details

.client(config_name: :default) ⇒ EventStore::GRPC::Client

Parameters:

  • config_name (Symbol, String) (defaults to: :default)

Returns:

  • (EventStore::GRPC::Client) 


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

def client(config_name: :default)
  GRPC::Client.new(_config(config_name))
end

.config(name = :default) ⇒ EventStoreClient::Config

Parameters:

  • name (Symbol, String) (defaults to: :default)

Returns:



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

def config(name = :default)
  @config[name] ||= Config.new(name: name)
end

.configure(name: :default) {|config(name)| ... } ⇒ Object

Parameters:

  • name (Symbol, String) (defaults to: :default)

Yields:



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

def configure(name: :default)
  yield(config(name)) if block_given?
end

.init_default_config ⇒ void

This method returns an undefined value.



47
48
49
 
# File 'lib/event_store_client.rb', line 47

def init_default_config
  @config = { default: Config.new }
end