Module: PgEventstore

Extended by:: Extensions::ActsAsConfigurable

Defined in:: lib/pg_eventstore.rb,
lib/pg_eventstore/cli.rb,
lib/pg_eventstore/web.rb,
lib/pg_eventstore/event.rb,
lib/pg_eventstore/utils.rb,
lib/pg_eventstore/chunks.rb,
lib/pg_eventstore/client.rb,
lib/pg_eventstore/config.rb,
lib/pg_eventstore/errors.rb,
lib/pg_eventstore/stream.rb,
lib/pg_eventstore/queries.rb,
lib/pg_eventstore/version.rb,
lib/pg_eventstore/callbacks.rb,
lib/pg_eventstore/partition.rb,
lib/pg_eventstore/raw_event.rb,
lib/pg_eventstore/connection.rb,
lib/pg_eventstore/middleware.rb,
lib/pg_eventstore/maintenance.rb,
lib/pg_eventstore/sql_builder.rb,
lib/pg_eventstore/async_runner.rb,
lib/pg_eventstore/basic_config.rb,
lib/pg_eventstore/chunks/chunk.rb,
lib/pg_eventstore/event_marker.rb,
lib/pg_eventstore/commands/read.rb,
lib/pg_eventstore/pg_connection.rb,
lib/pg_eventstore/cli/exit_codes.rb,
lib/pg_eventstore/feature_marker.rb,
lib/pg_eventstore/query_strategy.rb,
lib/pg_eventstore/commands/append.rb,
lib/pg_eventstore/web/application.rb,
lib/pg_eventstore/abstract_command.rb,
lib/pg_eventstore/commands/link_to.rb,
lib/pg_eventstore/event_serializer.rb,
lib/pg_eventstore/chunks/repository.rb,
lib/pg_eventstore/commands/multiple.rb,
lib/pg_eventstore/event_deserializer.rb,
lib/pg_eventstore/event_global_index.rb,
lib/pg_eventstore/event_marker_index.rb,
lib/pg_eventstore/rspec/test_helpers.rb,
lib/pg_eventstore/synchronized_array.rb,
lib/pg_eventstore/stream_global_index.rb,
lib/pg_eventstore/event_class_resolver.rb,
lib/pg_eventstore/query_strategy/async.rb,
lib/pg_eventstore/commands/delete_event.rb,
lib/pg_eventstore/commands/read_grouped.rb,
lib/pg_eventstore/commands/read_streams.rb,
lib/pg_eventstore/queries/event_queries.rb,
lib/pg_eventstore/web/paginator/helpers.rb,
lib/pg_eventstore/commands/delete_stream.rb,
lib/pg_eventstore/queries/links_resolver.rb,
lib/pg_eventstore/cli/parsers/base_parser.rb,
lib/pg_eventstore/queries/replica_queries.rb,
lib/pg_eventstore/commands/stream_revision.rb,
lib/pg_eventstore/middleware/event_tracing.rb,
lib/pg_eventstore/cli/commands/base_command.rb,
lib/pg_eventstore/cli/commands/help_command.rb,
lib/pg_eventstore/queries/partition_queries.rb,
lib/pg_eventstore/query_strategy/foreground.rb,
lib/pg_eventstore/web/subscriptions/helpers.rb,
lib/pg_eventstore/cli/parsers/default_parser.rb,
lib/pg_eventstore/subscriptions/basic_runner.rb,
lib/pg_eventstore/subscriptions/runner_state.rb,
lib/pg_eventstore/subscriptions/subscription.rb,
lib/pg_eventstore/cli/parser_options/metadata.rb,
lib/pg_eventstore/extensions/options_defaults.rb,
lib/pg_eventstore/queries/maintenance_queries.rb,
lib/pg_eventstore/queries/transaction_queries.rb,
lib/pg_eventstore/extensions/options_extension.rb,
lib/pg_eventstore/queries/event_marker_queries.rb,
lib/pg_eventstore/web/paginator/base_collection.rb,
lib/pg_eventstore/extensions/callbacks_extension.rb,
lib/pg_eventstore/query_builders/basic_filtering.rb,
lib/pg_eventstore/subscriptions/commands_handler.rb,
lib/pg_eventstore/subscriptions/events_processor.rb,
lib/pg_eventstore/cli/parser_options/base_options.rb,
lib/pg_eventstore/cli/parsers/subscription_parser.rb,
lib/pg_eventstore/commands/read_streams_paginated.rb,
lib/pg_eventstore/extensions/acts_as_configurable.rb,
lib/pg_eventstore/queries/index_filtering_queries.rb,
lib/pg_eventstore/query_builders/events_filtering.rb,
lib/pg_eventstore/subscriptions/subscriptions_set.rb,
lib/pg_eventstore/web/paginator/events_collection.rb,
lib/pg_eventstore/web/subscriptions/subscriptions.rb,
lib/pg_eventstore/cli/try_unlock_subscriptions_set.rb,
lib/pg_eventstore/web/paginator/markers_collection.rb,
lib/pg_eventstore/web/paginator/streams_collection.rb,
lib/pg_eventstore/web/subscriptions/set_collection.rb,
lib/pg_eventstore/chunks/replica_events_index_chunk.rb,
lib/pg_eventstore/query_builders/filters/collection.rb,
lib/pg_eventstore/query_builders/filters/filter_row.rb,
lib/pg_eventstore/subscriptions/subscription_feeder.rb,
lib/pg_eventstore/subscriptions/subscription_runner.rb,
lib/pg_eventstore/chunks/read_api_events_index_chunk.rb,
lib/pg_eventstore/cli/parser_options/default_options.rb,
lib/pg_eventstore/cli/try_to_delete_subscriptions_set.rb,
lib/pg_eventstore/queries/events_global_index_queries.rb,
lib/pg_eventstore/query_builders/partitions_filtering.rb,
lib/pg_eventstore/subscriptions/subscriptions_manager.rb,
lib/pg_eventstore/web/paginator/stream_ids_collection.rb,
lib/pg_eventstore/web/subscriptions/subscriptions_set.rb,
lib/pg_eventstore/chunks/subscription_checkpoint_chunk.rb,
lib/pg_eventstore/queries/streams_global_index_queries.rb,
lib/pg_eventstore/query_builders/filters/marker_filter.rb,
lib/pg_eventstore/query_builders/filters/stream_filter.rb,
lib/pg_eventstore/web/paginator/event_types_collection.rb,
lib/pg_eventstore/commands/system_stream_read_paginated.rb,
lib/pg_eventstore/extensions/using_connection_extension.rb,
lib/pg_eventstore/subscriptions/subscriptions_lifecycle.rb,
lib/pg_eventstore/web/paginator/stream_names_collection.rb,
lib/pg_eventstore/chunks/subscription_events_index_chunk.rb,
lib/pg_eventstore/commands/regular_stream_read_paginated.rb,
lib/pg_eventstore/extensions/callback_handlers_extension.rb,
lib/pg_eventstore/query_builders/event_markers_filtering.rb,
lib/pg_eventstore/subscriptions/runner_recovery_strategy.rb,
lib/pg_eventstore/cli/commands/stop_subscriptions_command.rb,
lib/pg_eventstore/cli/parser_options/subscription_options.rb,
lib/pg_eventstore/cli/wait_for_subscriptions_set_shutdown.rb,
lib/pg_eventstore/subscriptions/events_processor_consumer.rb,
lib/pg_eventstore/cli/commands/start_subscriptions_command.rb,
lib/pg_eventstore/commands/revision_check/current_revision.rb,
lib/pg_eventstore/query_builders/filters/event_type_filter.rb,
lib/pg_eventstore/query_builders/filters/marker_filter_row.rb,
lib/pg_eventstore/query_builders/read_cursor/stream_cursor.rb,
lib/pg_eventstore/subscriptions/subscription_feed_strategy.rb,
lib/pg_eventstore/web/paginator/stream_contexts_collection.rb,
lib/pg_eventstore/commands/revision_check/expected_revision.rb,
lib/pg_eventstore/subscriptions/replica_subscription_runner.rb,
lib/pg_eventstore/subscriptions/subscription_runners_feeder.rb,
lib/pg_eventstore/subscriptions/subscriptions_set_lifecycle.rb,
lib/pg_eventstore/subscriptions/queries/subscription_queries.rb,
lib/pg_eventstore/subscriptions/replica_subscription_handler.rb,
lib/pg_eventstore/subscriptions/subscription_feeder_commands.rb,
lib/pg_eventstore/subscriptions/subscription_runner_commands.rb,
lib/pg_eventstore/web/subscriptions/with_state/subscriptions.rb,
lib/pg_eventstore/commands/event_modifiers/prepare_link_event.rb,
lib/pg_eventstore/query_builders/index_based_events_filtering.rb,
lib/pg_eventstore/web/subscriptions/with_state/set_collection.rb,
lib/pg_eventstore/query_builders/event_markers_index_filtering.rb,
lib/pg_eventstore/query_builders/events_global_index_filtering.rb,
lib/pg_eventstore/query_builders/subscription_events_filtering.rb,
lib/pg_eventstore/commands/revision_check/stream_revision_check.rb,
lib/pg_eventstore/query_builders/streams_global_index_filtering.rb,
lib/pg_eventstore/commands/event_modifiers/prepare_regular_event.rb,
lib/pg_eventstore/subscriptions/events_processor_consumer/single.rb,
lib/pg_eventstore/subscriptions/subscription_handler_performance.rb,
lib/pg_eventstore/web/subscriptions/with_state/subscriptions_set.rb,
lib/pg_eventstore/subscriptions/events_processor_consumer/replica.rb,
lib/pg_eventstore/subscriptions/extensions/base_command_extension.rb,
lib/pg_eventstore/subscriptions/queries/subscriptions_set_queries.rb,
lib/pg_eventstore/subscriptions/subscription_feeder_commands/base.rb,
lib/pg_eventstore/subscriptions/subscription_feeder_commands/ping.rb,
lib/pg_eventstore/subscriptions/subscription_feeder_commands/stop.rb,
lib/pg_eventstore/subscriptions/subscription_runner_commands/base.rb,
lib/pg_eventstore/subscriptions/subscription_runner_commands/stop.rb,
lib/pg_eventstore/subscriptions/events_processor_consumer/multiple.rb,
lib/pg_eventstore/subscriptions/subscription_runner_commands/start.rb,
lib/pg_eventstore/cli/commands/callback_handlers/start_cmd_handlers.rb,
lib/pg_eventstore/subscriptions/events_subscription_position_worker.rb,
lib/pg_eventstore/commands/revision_check/stream_revision_comparison.rb,
lib/pg_eventstore/subscriptions/queries/subscription_command_queries.rb,
lib/pg_eventstore/subscriptions/subscription_feeder_commands/restore.rb,
lib/pg_eventstore/subscriptions/subscription_runner_commands/restore.rb,
lib/pg_eventstore/web/subscriptions/subscriptions_to_set_association.rb,
lib/pg_eventstore/subscriptions/subscription_feeder_commands/stop_all.rb,
lib/pg_eventstore/subscriptions/subscription_feeder_commands/start_all.rb,
lib/pg_eventstore/query_builders/event_subscription_positions_filtering.rb,
lib/pg_eventstore/subscriptions/subscription_feed_strategies/collection.rb,
lib/pg_eventstore/commands/revision_check/event_type_revisions_comparison.rb,
lib/pg_eventstore/subscriptions/extensions/command_class_lookup_extension.rb,
lib/pg_eventstore/subscriptions/queries/subscriptions_set_command_queries.rb,
lib/pg_eventstore/subscriptions/callback_handlers/commands_handler_handlers.rb,
lib/pg_eventstore/subscriptions/callback_handlers/events_processor_handlers.rb,
lib/pg_eventstore/subscriptions/queries/event_subscription_position_queries.rb,
lib/pg_eventstore/subscriptions/subscription_runner_commands/reset_position.rb,
lib/pg_eventstore/subscriptions/command_handlers/subscription_feeder_commands.rb,
lib/pg_eventstore/subscriptions/runner_recovery_strategies/restore_connection.rb,
lib/pg_eventstore/subscriptions/callback_handlers/subscription_feeder_handlers.rb,
lib/pg_eventstore/subscriptions/callback_handlers/subscription_runner_handlers.rb,
lib/pg_eventstore/subscriptions/command_handlers/subscription_runners_commands.rb,
lib/pg_eventstore/subscriptions/subscription_feed_strategies/index_read_strategy.rb,
lib/pg_eventstore/subscriptions/subscription_feed_strategies/replication_strategy.rb,
lib/pg_eventstore/subscriptions/runner_recovery_strategies/restore_subscription_feeder.rb,
lib/pg_eventstore/subscriptions/runner_recovery_strategies/restore_subscription_runner.rb,
lib/pg_eventstore/subscriptions/callback_handlers/events_subscription_position_worker_handlers.rb,
sig/pg_eventstore.rbs,
sig/pg_eventstore/cli.rbs,
sig/pg_eventstore/event.rbs,
sig/pg_eventstore/utils.rbs,
sig/pg_eventstore/client.rbs,
sig/pg_eventstore/config.rbs,
sig/pg_eventstore/errors.rbs,
sig/pg_eventstore/stream.rbs,
sig/pg_eventstore/queries.rbs,
sig/pg_eventstore/version.rbs,
sig/pg_eventstore/callbacks.rbs,
sig/pg_eventstore/partition.rbs,
sig/pg_eventstore/raw_event.rbs,
sig/pg_eventstore/connection.rbs,
sig/pg_eventstore/middleware.rbs,
sig/pg_eventstore/maintenance.rbs,
sig/pg_eventstore/sql_builder.rbs,
sig/pg_eventstore/async_runner.rbs,
sig/pg_eventstore/basic_config.rbs,
sig/pg_eventstore/chunks/chunk.rbs,
sig/pg_eventstore/event_marker.rbs,
sig/pg_eventstore/commands/read.rbs,
sig/pg_eventstore/pg_connection.rbs,
sig/pg_eventstore/cli/exit_codes.rbs,
sig/pg_eventstore/feature_marker.rbs,
sig/pg_eventstore/query_strategy.rbs,
sig/pg_eventstore/commands/append.rbs,
sig/pg_eventstore/web/application.rbs,
sig/pg_eventstore/abstract_command.rbs,
sig/pg_eventstore/commands/link_to.rbs,
sig/pg_eventstore/event_serializer.rbs,
sig/pg_eventstore/chunks/repository.rbs,
sig/pg_eventstore/commands/multiple.rbs,
sig/pg_eventstore/event_deserializer.rbs,
sig/pg_eventstore/event_global_index.rbs,
sig/pg_eventstore/event_marker_index.rbs,
sig/pg_eventstore/synchronized_array.rbs,
sig/pg_eventstore/stream_global_index.rbs,
sig/pg_eventstore/event_class_resolver.rbs,
sig/pg_eventstore/query_strategy/async.rbs,
sig/pg_eventstore/commands/delete_event.rbs,
sig/pg_eventstore/commands/read_grouped.rbs,
sig/pg_eventstore/commands/read_streams.rbs,
sig/pg_eventstore/queries/event_queries.rbs,
sig/pg_eventstore/web/paginator/helpers.rbs,
sig/pg_eventstore/commands/delete_stream.rbs,
sig/pg_eventstore/middleware/event_trace.rbs,
sig/pg_eventstore/queries/links_resolver.rbs,
sig/pg_eventstore/cli/parsers/base_parser.rbs,
sig/pg_eventstore/queries/replica_queries.rbs,
sig/pg_eventstore/commands/stream_revision.rbs,
sig/pg_eventstore/cli/commands/base_command.rbs,
sig/pg_eventstore/cli/commands/help_command.rbs,
sig/pg_eventstore/queries/partition_queries.rbs,
sig/pg_eventstore/query_strategy/foreground.rbs,
sig/pg_eventstore/web/subscriptions/helpers.rbs,
sig/pg_eventstore/cli/parsers/default_parser.rbs,
sig/pg_eventstore/subscriptions/basic_runner.rbs,
sig/pg_eventstore/subscriptions/runner_state.rbs,
sig/pg_eventstore/subscriptions/subscription.rbs,
sig/pg_eventstore/cli/parser_options/metadata.rbs,
sig/pg_eventstore/extensions/options_defaults.rbs,
sig/pg_eventstore/queries/maintenance_queries.rbs,
sig/pg_eventstore/queries/transaction_queries.rbs,
sig/pg_eventstore/extensions/options_extension.rbs,
sig/pg_eventstore/queries/event_marker_queries.rbs,
sig/pg_eventstore/web/paginator/base_collection.rbs,
sig/pg_eventstore/extensions/callbacks_extension.rbs,
sig/pg_eventstore/query_builders/basic_filtering.rbs,
sig/pg_eventstore/subscriptions/commands_handler.rbs,
sig/pg_eventstore/subscriptions/events_processor.rbs,
sig/pg_eventstore/cli/parser_options/base_options.rbs,
sig/pg_eventstore/cli/parsers/subscription_parser.rbs,
sig/pg_eventstore/commands/read_streams_paginated.rbs,
sig/pg_eventstore/extensions/acts_as_configurable.rbs,
sig/pg_eventstore/queries/index_filtering_queries.rbs,
sig/pg_eventstore/subscriptions/subscriptions_set.rbs,
sig/pg_eventstore/web/paginator/events_collection.rbs,
sig/pg_eventstore/web/subscriptions/subscriptions.rbs,
sig/pg_eventstore/cli/try_unlock_subscriptions_set.rbs,
sig/pg_eventstore/web/paginator/markers_collection.rbs,
sig/pg_eventstore/web/paginator/streams_collection.rbs,
sig/pg_eventstore/web/subscriptions/set_collection.rbs,
sig/pg_eventstore/chunks/replica_events_index_chunk.rbs,
sig/pg_eventstore/query_builders/filters/collection.rbs,
sig/pg_eventstore/query_builders/filters/filter_row.rbs,
sig/pg_eventstore/subscriptions/subscription_feeder.rbs,
sig/pg_eventstore/subscriptions/subscription_runner.rbs,
sig/pg_eventstore/chunks/read_api_events_index_chunk.rbs,
sig/pg_eventstore/cli/parser_options/default_options.rbs,
sig/pg_eventstore/cli/try_to_delete_subscriptions_set.rbs,
sig/pg_eventstore/queries/events_global_index_queries.rbs,
sig/pg_eventstore/query_builders/partitions_filtering.rbs,
sig/pg_eventstore/subscriptions/subscriptions_manager.rbs,
sig/pg_eventstore/web/paginator/stream_ids_collection.rbs,
sig/pg_eventstore/web/subscriptions/subscriptions_set.rbs,
sig/pg_eventstore/chunks/subscription_checkpoint_chunk.rbs,
sig/pg_eventstore/queries/streams_global_index_queries.rbs,
sig/pg_eventstore/query_builders/filters/marker_filter.rbs,
sig/pg_eventstore/query_builders/filters/stream_filter.rbs,
sig/pg_eventstore/web/paginator/event_types_collection.rbs,
sig/pg_eventstore/commands/system_stream_read_paginated.rbs,
sig/pg_eventstore/extensions/using_connection_extension.rbs,
sig/pg_eventstore/query_builders/events_filtering_query.rbs,
sig/pg_eventstore/subscriptions/subscriptions_lifecycle.rbs,
sig/pg_eventstore/web/paginator/stream_names_collection.rbs,
sig/pg_eventstore/chunks/subscription_events_index_chunk.rbs,
sig/pg_eventstore/commands/regular_stream_read_paginated.rbs,
sig/pg_eventstore/extensions/callback_handlers_extension.rbs,
sig/pg_eventstore/query_builders/event_markers_filtering.rbs,
sig/pg_eventstore/subscriptions/runner_recovery_strategy.rbs,
sig/pg_eventstore/cli/commands/stop_subscriptions_command.rbs,
sig/pg_eventstore/cli/parser_options/subscription_options.rbs,
sig/pg_eventstore/cli/wait_for_subscriptions_set_shutdown.rbs,
sig/pg_eventstore/subscriptions/events_processor_consumer.rbs,
sig/pg_eventstore/cli/commands/start_subscriptions_command.rbs,
sig/pg_eventstore/commands/revision_check/current_revision.rbs,
sig/pg_eventstore/query_builders/filters/event_type_filter.rbs,
sig/pg_eventstore/query_builders/filters/marker_filter_row.rbs,
sig/pg_eventstore/query_builders/read_cursor/stream_cursor.rbs,
sig/pg_eventstore/subscriptions/subscription_feed_strategy.rbs,
sig/pg_eventstore/web/paginator/stream_contexts_collection.rbs,
sig/pg_eventstore/commands/revision_check/expected_revision.rbs,
sig/pg_eventstore/subscriptions/replica_subscription_runner.rbs,
sig/pg_eventstore/subscriptions/subscription_runners_feeder.rbs,
sig/pg_eventstore/subscriptions/subscriptions_set_lifecycle.rbs,
sig/pg_eventstore/subscriptions/queries/subscription_queries.rbs,
sig/pg_eventstore/subscriptions/replica_subscription_handler.rbs,
sig/pg_eventstore/subscriptions/subscription_feeder_commands.rbs,
sig/pg_eventstore/subscriptions/subscription_runner_commands.rbs,
sig/pg_eventstore/web/subscriptions/with_state/subscriptions.rbs,
sig/pg_eventstore/commands/event_modifiers/prepare_link_event.rbs,
sig/pg_eventstore/query_builders/index_based_events_filtering.rbs,
sig/pg_eventstore/web/subscriptions/with_state/set_collection.rbs,
sig/pg_eventstore/query_builders/event_markers_index_filtering.rbs,
sig/pg_eventstore/query_builders/events_global_index_filtering.rbs,
sig/pg_eventstore/query_builders/subscription_events_filtering.rbs,
sig/pg_eventstore/commands/revision_check/stream_revision_check.rbs,
sig/pg_eventstore/query_builders/streams_global_index_filtering.rbs,
sig/pg_eventstore/commands/event_modifiers/prepare_regular_event.rbs,
sig/pg_eventstore/subscriptions/events_processor_consumer/single.rbs,
sig/pg_eventstore/subscriptions/subscription_handler_performance.rbs,
sig/pg_eventstore/web/subscriptions/with_state/subscriptions_set.rbs,
sig/pg_eventstore/subscriptions/events_processor_consumer/replica.rbs,
sig/pg_eventstore/subscriptions/extensions/base_command_extension.rbs,
sig/pg_eventstore/subscriptions/queries/subscriptions_set_queries.rbs,
sig/pg_eventstore/subscriptions/subscription_feeder_commands/base.rbs,
sig/pg_eventstore/subscriptions/subscription_feeder_commands/ping.rbs,
sig/pg_eventstore/subscriptions/subscription_feeder_commands/stop.rbs,
sig/pg_eventstore/subscriptions/subscription_runner_commands/base.rbs,
sig/pg_eventstore/subscriptions/subscription_runner_commands/stop.rbs,
sig/pg_eventstore/subscriptions/events_processor_consumer/multiple.rbs,
sig/pg_eventstore/subscriptions/subscription_runner_commands/start.rbs,
sig/pg_eventstore/cli/commands/callback_handlers/start_cmd_handlers.rbs,
sig/pg_eventstore/subscriptions/event_subscription_position_queries.rbs,
sig/pg_eventstore/subscriptions/events_subscription_position_worker.rbs,
sig/pg_eventstore/commands/revision_check/stream_revision_comparison.rbs,
sig/pg_eventstore/subscriptions/queries/subscription_command_queries.rbs,
sig/pg_eventstore/subscriptions/subscription_feeder_commands/restore.rbs,
sig/pg_eventstore/subscriptions/subscription_runner_commands/restore.rbs,
sig/pg_eventstore/web/subscriptions/subscriptions_to_set_association.rbs,
sig/pg_eventstore/subscriptions/subscription_feed_strategy/collection.rbs,
sig/pg_eventstore/subscriptions/subscription_feeder_commands/stop_all.rbs,
sig/pg_eventstore/subscriptions/subscription_feeder_commands/start_all.rbs,
sig/pg_eventstore/query_builders/event_subscription_positions_filtering.rbs,
sig/pg_eventstore/commands/revision_check/event_type_revisions_comparison.rbs,
sig/pg_eventstore/subscriptions/extensions/command_class_lookup_extension.rbs,
sig/pg_eventstore/subscriptions/queries/subscriptions_set_command_queries.rbs,
sig/pg_eventstore/subscriptions/callback_handlers/commands_handler_handlers.rbs,
sig/pg_eventstore/subscriptions/callback_handlers/events_processor_handlers.rbs,
sig/pg_eventstore/subscriptions/subscription_runner_commands/reset_position.rbs,
sig/pg_eventstore/subscriptions/command_handlers/subscription_feeder_commands.rbs,
sig/pg_eventstore/subscriptions/runner_recovery_strategies/restore_connection.rbs,
sig/pg_eventstore/subscriptions/callback_handlers/subscription_feeder_handlers.rbs,
sig/pg_eventstore/subscriptions/callback_handlers/subscription_runner_handlers.rbs,
sig/pg_eventstore/subscriptions/command_handlers/subscription_runners_commands.rbs,
sig/pg_eventstore/subscriptions/subscription_feed_strategy/index_read_strategy.rbs,
sig/pg_eventstore/subscriptions/subscription_feed_strategy/replication_strategy.rbs,
sig/pg_eventstore/subscriptions/runner_recovery_strategies/restore_subscription_feeder.rbs,
sig/pg_eventstore/subscriptions/runner_recovery_strategies/restore_subscription_runner.rbs,
sig/pg_eventstore/subscriptions/callback_handlers/events_subscription_position_worker_handlers.rbs,
ext/pg_eventstore_ext/pg_eventstore_ext.c

Defined Under Namespace

Modules: CLI, CommandHandlers, Commands, Extensions, Middleware, QueryBuilders, RunnerRecoveryStrategies, RunnerRecoveryStrategy, TestHelpers, Web Classes: AsyncRunner, BasicConfig, BasicRunner, Callbacks, Client, Config, Connection, EmptyChunkFedError, Error, Event, EventClassResolver, FeatureMarker, IndexFilteringQueries, Maintenance, MissingPartitions, NotPersistedEventError, NotSupportedError, Partition, RecordNotFound, ReplicaSubscriptionHandler, Stream, StreamNotFoundError, Subscription, SubscriptionAlreadyLockedError, SubscriptionsManager, SubscriptionsSet, SystemStreamError, TooManyRecordsToLockError, Utils, WrappedException, WrongExpectedRevisionError, WrongExpectedTypesRevisionError, WrongLockIdError

Constant Summary collapse

VERSION = Returns: (String)

'3.0.1'

Class Attribute Summary collapse

.logger ⇒ Logger^?

Instance Attribute Summary collapse

#logger ⇒ Object
Returns the value of attribute logger.

Class Method Summary collapse

.client(name = DEFAULT_CONFIG) ⇒ PgEventstore::Client
.maintenance(name = DEFAULT_CONFIG) ⇒ PgEventstore::Maintenance
.subscriptions_manager(config_name = DEFAULT_CONFIG, subscription_set:, max_retries: nil, retries_interval: nil, force_lock: false) ⇒ PgEventstore::SubscriptionsManager

Methods included from Extensions::ActsAsConfigurable

acts_as_configurable

Class Attribute Details

.logger ⇒ `Logger`^?

Returns:

(Logger, nil)



47
48
49

# File 'lib/pg_eventstore.rb', line 47

def logger
  @logger
end

Instance Attribute Details

#logger ⇒ `Object`

Returns the value of attribute logger.

Returns:

(Object)



4
5
6

# File 'sig/pg_eventstore.rbs', line 4

def logger
  @logger
end

Class Method Details

.client(name = DEFAULT_CONFIG) ⇒ `PgEventstore::Client`

Parameters:

name (Symbol) (defaults to: DEFAULT_CONFIG)

Returns:

(PgEventstore::Client)



68
69
70

# File 'lib/pg_eventstore.rb', line 68

def client(name = DEFAULT_CONFIG)
  Client.new(config(name))
end

.maintenance(name = DEFAULT_CONFIG) ⇒ `PgEventstore::Maintenance`

Parameters:

name (Symbol) (defaults to: DEFAULT_CONFIG)

Returns:

(PgEventstore::Maintenance)



74
75
76

# File 'lib/pg_eventstore.rb', line 74

def maintenance(name = DEFAULT_CONFIG)
  Maintenance.new(config(name))
end

.subscriptions_manager(config_name = DEFAULT_CONFIG, subscription_set:, max_retries: nil, retries_interval: nil, force_lock: false) ⇒ `PgEventstore::SubscriptionsManager`

Parameters:

config_name (Symbol) (defaults to: DEFAULT_CONFIG)
subscription_set (String)
max_retries (Integer, nil) (defaults to: nil) —
max number of retries of failed SubscriptionsSet
retries_interval (Integer, nil) (defaults to: nil) —
a delay between retries of failed SubscriptionsSet
force_lock (Boolean) (defaults to: false) —
whether to force-lock subscriptions

Returns:

(PgEventstore::SubscriptionsManager)

# File 'lib/pg_eventstore.rb', line 55

def subscriptions_manager(config_name = DEFAULT_CONFIG, subscription_set:, max_retries: nil, retries_interval: nil,
                          force_lock: false)
  SubscriptionsManager.new(
    config: config(config_name),
    set_name: subscription_set,
    max_retries:,
    retries_interval:,
    force_lock:
  )
end

Module: PgEventstore

Defined Under Namespace

Constant Summary collapse

Class Attribute Summary collapse

Instance Attribute Summary collapse

Class Method Summary collapse

Methods included from Extensions::ActsAsConfigurable

Class Attribute Details

.logger ⇒ Logger?

Instance Attribute Details

#logger ⇒ Object

Class Method Details

.client(name = DEFAULT_CONFIG) ⇒ PgEventstore::Client

.maintenance(name = DEFAULT_CONFIG) ⇒ PgEventstore::Maintenance

.subscriptions_manager(config_name = DEFAULT_CONFIG, subscription_set:, max_retries: nil, retries_interval: nil, force_lock: false) ⇒ PgEventstore::SubscriptionsManager

.logger ⇒ `Logger`^?

#logger ⇒ `Object`

.client(name = DEFAULT_CONFIG) ⇒ `PgEventstore::Client`

.maintenance(name = DEFAULT_CONFIG) ⇒ `PgEventstore::Maintenance`

.subscriptions_manager(config_name = DEFAULT_CONFIG, subscription_set:, max_retries: nil, retries_interval: nil, force_lock: false) ⇒ `PgEventstore::SubscriptionsManager`