Method List

Classes Methods Files

Search:

#+ PgEventstore::Extensions::OptionsExtension::Options
#== PgEventstore::Event
#== PgEventstore::Stream
#== PgEventstore::Subscription
#== PgEventstore::Extensions::OptionsExtension::Option
#== PgEventstore::Extensions::OptionsExtension::Options
#== PgEventstore::SubscriptionsSet
#[] PgEventstore::Extensions::OptionsExtension::Options
#_collection PgEventstore::Web::Paginator::EventsCollection
#_start PgEventstore::BasicRunner
#acts_as_configurable PgEventstore::Extensions::ActsAsConfigurable
#add_global_position_direction PgEventstore::QueryBuilders::IndexBasedEventsFiltering
#add_limit PgEventstore::QueryBuilders::IndexBasedEventsFiltering
#alias_type PG::BasicTypeRegistry
#alive? PgEventstore::Web::Subscriptions::Helpers
all_stream PgEventstore::Stream
#all_stream? PgEventstore::Stream
#append_to_stream PgEventstore::Client
#args PgEventstore::CLI::Parsers::BaseParser
#as_json PgEventstore::Error
#ascending? PgEventstore::QueryBuilders::BasicFiltering::ClassMethods
assert! PgEventstore::Utils
assert_node_role! PgEventstore::Utils
#assign_attributes PgEventstore::Subscription
#assign_attributes PgEventstore::SubscriptionsSet
#association PgEventstore::Web::Subscriptions::SubscriptionsToSetAssociation
#async PgEventstore::AsyncRunner
async_api= PG::Connection
#async_connect_or_reset PG::Connection
#async_recover PgEventstore::BasicRunner
async_send_api= PG::Connection
#attributes PgEventstore::Chunks::SubscriptionEventsIndexChunk::RawEventWithSubscriptionPosition
#available_configs PgEventstore::Extensions::ActsAsConfigurable::Configurable
#average_event_processing_time PgEventstore::Subscription
#backend_key PG::Connection
#backend_pid PG::Connection
banner PgEventstore::CLI::Parsers::BaseParser
banner PgEventstore::CLI::Parsers::DefaultParser
banner PgEventstore::CLI::Parsers::SubscriptionParser
benchmark PgEventstore::Utils
#block PG::Connection
#build_path PgEventstore::Web::Paginator::Helpers
#build_starting_id_link PgEventstore::Web::Paginator::Helpers
#call PgEventstore::EventClassResolver
#call PgEventstore::ReplicaSubscriptionHandler
#call _Callback
#call _EventModifier
#call _RawEventHandler
#call _RestartTerminator
#call _RawEventsHandler
#call _EventClassResolver
#call _SubscriptionHandler
#call _FailedSubscriptionNotifier
callbacks PgEventstore::CLI
callbacks PgEventstore::SubscriptionsManager
#cancel PG::Connection
#causation_id PgEventstore::Event
causation_marker PgEventstore::Middleware::EventTracing
#caused_by PgEventstore::Event
#change_state PgEventstore::BasicRunner
#check_socket PG::Connection
#chunk_query_interval PgEventstore::Subscription
clean_up_data PgEventstore::TestHelpers
clean_up_db PgEventstore::TestHelpers
clean_up_partitions PgEventstore::TestHelpers
clean_up_subscription_functions PgEventstore::TestHelpers
#clear PgEventstore::Callbacks
client PgEventstore
#coders_for PG::BasicTypeRegistry
#collection PgEventstore::Web::Paginator::BaseCollection
#collection PgEventstore::Web::Paginator::EventsCollection
#collection PgEventstore::Web::Paginator::MarkersCollection
#collection PgEventstore::Web::Paginator::StreamsCollection
#collection PgEventstore::Web::Paginator::StreamIdsCollection
#collection PgEventstore::Web::Paginator::EventTypesCollection
#collection PgEventstore::Web::Paginator::StreamNamesCollection
#collection PgEventstore::Web::Paginator::StreamContextsCollection
#colored_state PgEventstore::Web::Subscriptions::Helpers
#compute_context_filter PgEventstore::Web::Paginator::StreamContextsCollection
#compute_event_type_filter PgEventstore::Web::Paginator::EventTypesCollection
#compute_read_api_chunks_repo PgEventstore::IndexFilteringQueries
#compute_stream_name_filter PgEventstore::Web::Paginator::StreamNamesCollection
#config PgEventstore::Client
#config PgEventstore::Maintenance
#config PgEventstore::Extensions::ActsAsConfigurable::Configurable
#config PgEventstore::SubscriptionsManager
#config_name PgEventstore::Web::Paginator::BaseCollection
#config_name PgEventstore::SubscriptionsManager
#configure PgEventstore::Extensions::ActsAsConfigurable::Configurable
conndefaults PG::Connection
#conndefaults PG::Connection
conndefaults_hash PG::Connection
#conndefaults_hash PG::Connection
connect_hash_to_string PG::Connection
#connect_poll PG::Connection
connect_start PG::Connection
#connection PgEventstore::Client
#connection PgEventstore::Maintenance
#connection PgEventstore::Web::Paginator::BaseCollection
#connection PgEventstore::Extensions::ActsAsConfigurable::Configurable
#connection PgEventstore::IndexFilteringQueries
#connection PgEventstore::Web::Subscriptions::Subscriptions
#connection PgEventstore::Web::Subscriptions::SetCollection
#connection PgEventstore::SubscriptionsManager
#connection PgEventstore::Web::Subscriptions::SubscriptionsSet
#connection PgEventstore::Extensions::UsingConnectionExtension::ClassMethods
#connection PgEventstore::ReplicaSubscriptionHandler
#connection PgEventstore::Web::Subscriptions::WithState::Subscriptions
#connection PgEventstore::Web::Subscriptions::WithState::SetCollection
#connection PgEventstore::Web::Subscriptions::WithState::SubscriptionsSet
#connection_needs_password PG::Connection
#connection_options PgEventstore::Config
#connection_options PgEventstore::Extensions::ActsAsConfigurable::Configurable
#connection_pool_size PgEventstore::Config
#connection_pool_timeout PgEventstore::Config
#connection_used_password PG::Connection
#conninfo PG::Connection
#conninfo_hash PG::Connection
conninfo_parse PG::Connection
#consume_input PG::Connection
#context PgEventstore::Stream
#context PgEventstore::Partition
#copy_data PG::Connection
#correlation_id PgEventstore::Event
correlation_marker PgEventstore::Middleware::EventTracing
#count PgEventstore::Web::Paginator::BaseCollection
create PgEventstore::SubscriptionsSet
#create_consumer PgEventstore::EventsProcessorConsumer::ClassMethods
#create_replication PgEventstore::SubscriptionsManager
#created_at PgEventstore::Event
#created_at PgEventstore::Subscription
#created_at PgEventstore::SubscriptionsSet
#current_no_stream PgEventstore::WrongExpectedRevisionError
#current_position PgEventstore::Subscription
#current_revision PgEventstore::WrongExpectedTypesRevisionError::Verdict
#data PgEventstore::Event
#db PG::Connection
#decoder_for_get_copy_data PG::Connection
#decoder_for_get_copy_data= PG::Connection
#deconstruct PgEventstore::Stream
#deconstruct_keys PgEventstore::Stream
deep_dup PgEventstore::Utils
deep_transform_keys PgEventstore::Utils
#define_callback PgEventstore::Callbacks
#define_callback PgEventstore::Extensions::CallbacksExtension
#delegate_change_state_cbx PgEventstore::BasicRunner
#delete PgEventstore::SubscriptionsSet
#delete_all_subscriptions_url PgEventstore::Web::Subscriptions::Helpers
#delete_event PgEventstore::Maintenance
#delete_event_url PgEventstore::Web::Subscriptions::Helpers
#delete_stream PgEventstore::Maintenance
#delete_stream_url PgEventstore::Web::Subscriptions::Helpers
deprecation_warning PgEventstore::Utils
#descending? PgEventstore::QueryBuilders::BasicFiltering::ClassMethods
#describe_portal PG::Connection
#describe_prepared PG::Connection
#description PgEventstore::FeatureMarker
#deserialize PgEventstore::Middleware
#deserialize PgEventstore::Middleware::EventTracing
#deserialize PgEventstore::IndexFilteringQueries
#deserializer PgEventstore::SubscriptionsManager
#destination_replica_queries PgEventstore::ReplicaSubscriptionHandler
#direction PgEventstore::QueryBuilders::ReadCursor::StreamCursor::RegularStreamCursor
#direction PgEventstore::QueryBuilders::ReadCursor::StreamCursor::AllStreamCursor
#direction_operator PgEventstore::Web::Paginator::MarkersCollection
#direction_operator PgEventstore::Web::Paginator::StreamIdsCollection
#direction_operator PgEventstore::Web::Paginator::EventTypesCollection
#direction_operator PgEventstore::Web::Paginator::StreamNamesCollection
#direction_operator PgEventstore::Web::Paginator::StreamContextsCollection
#discard_current_connection PgEventstore::Connection
#discard_results PG::Connection
#dup PgEventstore::Event
#dup PgEventstore::Subscription
#dup PgEventstore::Extensions::OptionsExtension::Options
#dup PgEventstore::SubscriptionsSet
#each PgEventstore::Extensions::OptionsExtension::Options
#empty_characters_fallback PgEventstore::Web::Paginator::Helpers
#encoder_for_put_copy_data PG::Connection
#encoder_for_put_copy_data= PG::Connection
encrypt_password PG::Connection
#encrypt_password PG::Connection
#enter_pipeline_mode PG::Connection
#eql? PgEventstore::Stream
#eql? PgEventstore::Subscription
#eql? PgEventstore::Extensions::OptionsExtension::Option
#eql? PgEventstore::SubscriptionsSet
error_info PgEventstore::Utils
#error_message PG::Connection
escape_bytea PG::Connection
#escape_bytea PG::Connection
#escape_identifier PG::Connection
#escape_literal PG::Connection
escape_string PG::Connection
#escape_string PG::Connection
#establish_connection PgEventstore::Connection
#estimate_count PgEventstore::Web::Paginator::EventsCollection
#estimate_count PgEventstore::Web::Paginator::StreamsCollection
#event PgEventstore::NotPersistedEventError
#event_class_resolver PgEventstore::Config
#event_descr PgEventstore::WrongExpectedTypesRevisionError
#event_deserializer PgEventstore::Client
#event_global_position PgEventstore::Web::Paginator::EventsCollection
#event_is_absent PgEventstore::WrongExpectedTypesRevisionError
#event_is_present PgEventstore::WrongExpectedTypesRevisionError
#event_marker_path PgEventstore::Web::Paginator::Helpers
#event_marker_queries PgEventstore::Client
#event_queries PgEventstore::Client
#event_revision_does_not_match PgEventstore::WrongExpectedTypesRevisionError
#event_subscription_position_queries PgEventstore::Client
#event_type PgEventstore::WrongExpectedTypesRevisionError::Verdict
#event_type PgEventstore::Partition
#event_type PgEventstore::Commands::RevisionCheck::ExpectedRevision::EventTypeRevision
#event_type PgEventstore::Commands::RevisionCheck::ExpectedRevision::EventTypeRevisionWithMarkers
#event_type_partition_id PgEventstore::EventGlobalIndex::SubscriptionRepr
#event_type_partition_id PgEventstore::EventGlobalIndex::ReadApiRepr
#event_type_partition_id PgEventstore::EventGlobalIndex::WriteApiRepr
#event_types PgEventstore::MissingPartitions
#events_global_index_queries PgEventstore::Client
#events_global_index_queries PgEventstore::Maintenance
#events_subscription_position_update_interval PgEventstore::Config
#eventstore_role PgEventstore::Config
#exec PgEventstore::QueryStrategy::Foreground
#exec PG::Connection
#exec_params PgEventstore::QueryStrategy::Foreground
#exec_params PG::Connection
#exec_prepared PG::Connection
execute PgEventstore::CLI
#exit_pipeline_mode PG::Connection
#expand_event_types PgEventstore::IndexFilteringQueries
#expected_markers PgEventstore::WrongExpectedTypesRevisionError::Verdict
#expected_no_stream PgEventstore::WrongExpectedRevisionError
#expected_revision PgEventstore::WrongExpectedRevisionError
#expected_revision PgEventstore::WrongExpectedTypesRevisionError::Verdict
#expected_revision PgEventstore::Commands::RevisionCheck::ExpectedRevision::EventTypeRevision
#expected_revision PgEventstore::Commands::RevisionCheck::ExpectedRevision::EventTypeRevisionWithMarkers
#expected_revision PgEventstore::Commands::RevisionCheck::ExpectedRevision::MarkersRevision
#expected_stream_exists PgEventstore::WrongExpectedRevisionError
#external_encoding PG::Connection
#extra PgEventstore::WrappedException
#failed_subscription_notifier PgEventstore::Config
#feature_markers PgEventstore::Event
#fetch_grouped_indexes_for_read_api PgEventstore::IndexFilteringQueries
#fetch_indexes_for_read_api PgEventstore::IndexFilteringQueries
#fetch_indexes_for_revision_validation PgEventstore::IndexFilteringQueries
#field_name_type PG::Connection
#field_name_type= PG::Connection
#field_names_as PG::Result
#finish PG::Connection
#finished? PG::Connection
#first_page_link PgEventstore::Web::Paginator::Helpers
#flush PG::Connection
#flush_data= PG::Connection
#from_position PgEventstore::QueryBuilders::ReadCursor::StreamCursor::AllStreamCursor
#from_revision PgEventstore::QueryBuilders::ReadCursor::StreamCursor::RegularStreamCursor
#get_client_encoding PG::Connection
#get_copy_data PG::Connection
#get_last_result PG::Connection
#get_result PG::Connection
#global_position PgEventstore::Event
#global_position PgEventstore::EventGlobalIndex::SubscriptionRepr
#global_position PgEventstore::EventGlobalIndex::ReadApiRepr
#global_position PgEventstore::EventGlobalIndex::WriteApiRepr
#global_position PgEventstore::Web::Paginator::EventsCollection
#hash PgEventstore::Event
#hash PgEventstore::Stream
#hash PgEventstore::Subscription
#hash PgEventstore::Extensions::OptionsExtension::Option
#hash PgEventstore::SubscriptionsSet
#host PG::Connection
#hostaddr PG::Connection
#id PgEventstore::Event
#id PgEventstore::RecordNotFound
#id PgEventstore::Partition
#id PgEventstore::Subscription
#id PgEventstore::SubscriptionsSet
#include? PgEventstore::Extensions::OptionsExtension::Options
included PgEventstore::Extensions::OptionsExtension
included PgEventstore::Extensions::CallbacksExtension
#index_filtering_queries PgEventstore::Client
#init_default_values PgEventstore::Extensions::OptionsExtension
#init_default_values PgEventstore::Event
#init_default_values PgEventstore::Config
#init_default_values PgEventstore::Subscription
#init_default_values PgEventstore::SubscriptionsSet
#init_pool PgEventstore::Connection
#init_recovery_ripper PgEventstore::BasicRunner
#init_variables PgEventstore::Extensions::ActsAsConfigurable::Configurable
#initialize PgEventstore::Client
#initialize PgEventstore::StreamNotFoundError
#initialize PgEventstore::SystemStreamError
#initialize PgEventstore::WrongExpectedRevisionError
#initialize PgEventstore::WrongExpectedTypesRevisionError
#initialize PgEventstore::RecordNotFound
#initialize PgEventstore::SubscriptionAlreadyLockedError
#initialize PgEventstore::WrongLockIdError
#initialize PgEventstore::NotPersistedEventError
#initialize PgEventstore::MissingPartitions
#initialize PgEventstore::TooManyRecordsToLockError
#initialize PgEventstore::WrappedException
#initialize PgEventstore::Stream
#initialize PgEventstore::Callbacks
#initialize PgEventstore::Connection
#initialize PgEventstore::Maintenance
#initialize PgEventstore::AsyncRunner
#initialize PgEventstore::BasicConfig
#initialize PgEventstore::CLI::Parsers::BaseParser
#initialize PgEventstore::QueryStrategy::Foreground
#initialize PgEventstore::BasicRunner
#initialize PgEventstore::Extensions::OptionsExtension::Option
#initialize PgEventstore::Extensions::OptionsExtension::Options
#initialize PgEventstore::Extensions::OptionsExtension
#initialize PgEventstore::Web::Paginator::BaseCollection
#initialize PgEventstore::IndexFilteringQueries
#initialize PgEventstore::Web::Subscriptions::Subscriptions
#initialize PgEventstore::Web::Subscriptions::SetCollection
#initialize PgEventstore::SubscriptionsManager
#initialize PgEventstore::Web::Subscriptions::SubscriptionsSet
#initialize PgEventstore::ReplicaSubscriptionHandler
#initialize PgEventstore::Web::Subscriptions::WithState::Subscriptions
#initialize PgEventstore::QueryBuilders::IndexBasedEventsFiltering
#initialize PgEventstore::Web::Subscriptions::WithState::SetCollection
#initialize PgEventstore::Web::Subscriptions::WithState::SubscriptionsSet
#initialize PgEventstore::Web::Subscriptions::SubscriptionsToSetAssociation
#initialize PgEventstore::Event
#initialize PG::BasicTypeRegistry
#initialize PgEventstore::Subscription
#initialize PgEventstore::SubscriptionsSet
#initialize PgEventstore::Web::Paginator::EventTypesCollection
#inspect PG::Result
#inspect PG::Connection
#internal_encoding PG::Connection
#internal_encoding= PG::Connection
#is_busy PG::Connection
#isnonblocking PG::Connection
isthreadsafe PG::Connection
#jobs_size PgEventstore::AsyncRunner
#last_chunk_fed_at PgEventstore::Subscription
#last_chunk_greatest_position PgEventstore::Subscription
#last_error PgEventstore::Subscription
#last_error PgEventstore::SubscriptionsSet
#last_error_occurred_at PgEventstore::Subscription
#last_error_occurred_at PgEventstore::SubscriptionsSet
#last_restarted_at PgEventstore::Subscription
#last_restarted_at PgEventstore::SubscriptionsSet
#link PgEventstore::Event
#link? PgEventstore::Event
#link_global_position PgEventstore::Event
#link_partition_id PgEventstore::Event
#link_to PgEventstore::Client
#lo_close PG::Connection
#lo_creat PG::Connection
#lo_create PG::Connection
#lo_export PG::Connection
#lo_import PG::Connection
#lo_lseek PG::Connection
#lo_open PG::Connection
#lo_read PG::Connection
#lo_tell PG::Connection
#lo_truncate PG::Connection
#lo_unlink PG::Connection
#lo_write PG::Connection
#lock! PgEventstore::Subscription
#lock_id PgEventstore::SubscriptionAlreadyLockedError
#lock_id PgEventstore::WrongLockIdError
#locked_by PgEventstore::Subscription
logger PgEventstore
#logger PgEventstore
maintainable PgEventstore::Config::NodeRole
maintenance PgEventstore
#maintenance_queries PgEventstore::Maintenance
#make_empty_pgresult PG::Connection
#map_types! PG::Result
#marker PgEventstore::FeatureMarker
#markers PgEventstore::Event
#markers PgEventstore::Commands::RevisionCheck::ExpectedRevision::EventTypeRevisionWithMarkers
#markers PgEventstore::Commands::RevisionCheck::ExpectedRevision::MarkersRevision
#max_count PgEventstore::Config
#max_count PgEventstore::QueryBuilders::ReadCursor::StreamCursor::RegularStreamCursor
#max_count PgEventstore::QueryBuilders::ReadCursor::StreamCursor::AllStreamCursor
#max_events_to_replicate PgEventstore::Config
#max_restarts_number PgEventstore::Subscription
#max_restarts_number PgEventstore::SubscriptionsSet
#metadata PgEventstore::Event
#metadata PgEventstore::Extensions::OptionsExtension::Option
#middlewares PgEventstore::Client
#middlewares PgEventstore::Config
missing_implementation! PgEventstore::Utils
#multiple PgEventstore::Client
#mutex PgEventstore::Extensions::ActsAsConfigurable::Configurable
#name PgEventstore::SubscriptionAlreadyLockedError
#name PgEventstore::WrongLockIdError
#name PgEventstore::BasicConfig
#name PgEventstore::Subscription
#name PgEventstore::Extensions::OptionsExtension::Option
#name PgEventstore::SubscriptionsSet
#names PgEventstore::Web::Subscriptions::SetCollection
#names PgEventstore::Web::Subscriptions::WithState::SetCollection
new PG::Connection
#next_page_link PgEventstore::Web::Paginator::Helpers
#next_page_starting_id PgEventstore::Web::Paginator::BaseCollection
#next_page_starting_id PgEventstore::Web::Paginator::EventsCollection
#next_page_starting_id PgEventstore::Web::Paginator::MarkersCollection
#next_page_starting_id PgEventstore::Web::Paginator::StreamsCollection
#next_page_starting_id PgEventstore::Web::Paginator::StreamIdsCollection
#next_page_starting_id PgEventstore::Web::Paginator::EventTypesCollection
#next_page_starting_id PgEventstore::Web::Paginator::StreamNamesCollection
#next_page_starting_id PgEventstore::Web::Paginator::StreamContextsCollection
#notifies PG::Connection
#number_of_records PgEventstore::TooManyRecordsToLockError
#number_with_delimiter PgEventstore::Web::Paginator::Helpers
#options PgEventstore::CLI::Parsers::BaseParser
#options PgEventstore::Subscription
#options PgEventstore::Extensions::OptionsExtension::Options
#options PgEventstore::Web::Paginator::BaseCollection
#options PG::Connection
#options_hash PgEventstore::Extensions::OptionsExtension
#options_hash PgEventstore::Event
#options_hash PgEventstore::Config
#options_hash PgEventstore::Subscription
#options_hash PgEventstore::SubscriptionsSet
#order PgEventstore::Web::Paginator::BaseCollection
#original_exception PgEventstore::WrappedException
original_global_position PgEventstore::Utils
#parameter_status PG::Connection
#parent_context_partition_id PgEventstore::Partition
#parent_stream_name_partition_id PgEventstore::Partition
#parse PgEventstore::CLI::Parsers::BaseParser
parse_connect_args PG::Connection
#parse_data PgEventstore::Extensions::BaseCommandExtension::ClassMethods
#partition_queries PgEventstore::Client
#partition_queries PgEventstore::IndexFilteringQueries
#pass PG::Connection
#per_page PgEventstore::Web::Paginator::BaseCollection
#per_page_url PgEventstore::Web::Paginator::Helpers
#pg_type_registry PgEventstore::Connection
#pg_uri PgEventstore::Config
ping PG::Connection
ping_all PgEventstore::Subscription
#pipeline_status PG::Connection
#pipeline_sync PG::Connection
#pool_size PgEventstore::Connection
#pool_timeout PgEventstore::Connection
#port PG::Connection
positional_vars PgEventstore::Utils
#prepare PG::Connection
#prev_page_starting_id PgEventstore::Web::Paginator::BaseCollection
#prev_page_starting_id PgEventstore::Web::Paginator::EventsCollection
#prev_page_starting_id PgEventstore::Web::Paginator::StreamsCollection
#previous_page_link PgEventstore::Web::Paginator::Helpers
#protocol_version PG::Connection
#purpose PgEventstore::FeatureMarker
#put_copy_data PG::Connection
#put_copy_end PG::Connection
quote_connstr PG::Connection
quote_ident PG::Connection
#quote_ident PG::Connection
range_to_slice PgEventstore::Utils
#read PgEventstore::Client
#read_grouped PgEventstore::Client
#read_paginated PgEventstore::Client
read_pid PgEventstore::Utils
#read_streams PgEventstore::Client
#read_streams_paginated PgEventstore::Client
#readonly! PgEventstore::Extensions::OptionsExtension
#readonly! PgEventstore::Event
#readonly! PgEventstore::Config
#readonly! PgEventstore::Subscription
#readonly! PgEventstore::SubscriptionsSet
#readonly? PgEventstore::Extensions::OptionsExtension
#readonly? PgEventstore::Event
#readonly? PgEventstore::Config
#readonly? PgEventstore::Subscription
#readonly? PgEventstore::SubscriptionsSet
#readonly_error PgEventstore::Extensions::OptionsExtension
#readonly_error PgEventstore::Event
#readonly_error PgEventstore::Config
#readonly_error PgEventstore::Subscription
#readonly_error PgEventstore::SubscriptionsSet
#records_to_sql PgEventstore::ReplicaSubscriptionHandler
#recover PgEventstore::RunnerRecoveryStrategy
#recoverable PgEventstore::BasicRunner
#recovers? PgEventstore::RunnerRecoveryStrategy
#recovery_strategies PgEventstore::SubscriptionsManager
#register_coder PG::BasicTypeRegistry
#register_default_types PG::BasicTypeRegistry
#register_type PG::BasicTypeRegistry
#regular_count PgEventstore::Web::Paginator::EventsCollection
#regular_count PgEventstore::Web::Paginator::StreamsCollection
#reject_already_processed PgEventstore::ReplicaSubscriptionHandler
#reload PgEventstore::Subscription
#reload PgEventstore::SubscriptionsSet
#remove_callback PgEventstore::Callbacks
remove_file PgEventstore::Utils
#replica_connection PgEventstore::ReplicaSubscriptionHandler
#replica_transaction_queries PgEventstore::ReplicaSubscriptionHandler
#reset PG::Connection
#reset_poll PG::Connection
#reset_runtime_attributes PgEventstore::Subscription
#reset_start PG::Connection
#reset_start2 PG::Connection
#resolve_link_tos_url PgEventstore::Web::Paginator::Helpers
#restart_count PgEventstore::Subscription
#restart_count PgEventstore::SubscriptionsSet
#restore PgEventstore::BasicRunner
#reverse_order PgEventstore::QueryBuilders::BasicFiltering::ClassMethods
#revision PgEventstore::WrongExpectedRevisionError
#revision PgEventstore::Commands::RevisionCheck::CurrentRevision::StreamRevision
#revision PgEventstore::Commands::RevisionCheck::ExpectedRevision::StreamRevision
#revision_descr PgEventstore::WrongExpectedTypesRevisionError
#revisions PgEventstore::Commands::RevisionCheck::CurrentRevision::EventTypeRevisions
#revisions PgEventstore::Commands::RevisionCheck::ExpectedRevision::EventTypeRevisions
#run PgEventstore::AsyncRunner
#run_after_callbacks PgEventstore::Callbacks
#run_around_callbacks PgEventstore::Callbacks
#run_before_callbacks PgEventstore::Callbacks
#run_callbacks PgEventstore::Callbacks
#run_cli_callbacks PgEventstore::SubscriptionsManager
#run_once PgEventstore::AsyncRunner
#select_middlewares PgEventstore::SubscriptionsManager
#send_describe_portal PG::Connection
#send_describe_prepared PG::Connection
#send_flush_request PG::Connection
#send_prepare PG::Connection
#send_query PG::Connection
#send_query_params PG::Connection
#send_query_prepared PG::Connection
#sequence_number PgEventstore::EventGlobalIndex::RevisionCheckRepr
#sequence_number PgEventstore::Commands::RevisionCheck::ExpectedRevision::EventTypeRevision
#sequence_number PgEventstore::Commands::RevisionCheck::ExpectedRevision::EventTypeRevisionWithMarkers
#sequence_number PgEventstore::Commands::RevisionCheck::ExpectedRevision::MarkersRevision
#serialize PgEventstore::Middleware
#serialize PgEventstore::Middleware::EventTracing
#server_version PG::Connection
#set PgEventstore::SubscriptionAlreadyLockedError
#set PgEventstore::WrongLockIdError
#set PgEventstore::Subscription
#set_client_encoding PG::Connection
#set_default_encoding PG::Connection
#set_error_context_visibility PG::Connection
#set_error_verbosity PG::Connection
#set_notice_processor PG::Connection
#set_notice_receiver PG::Connection
#set_single_row_mode PG::Connection
#setnonblocking PG::Connection
#setup_handler PgEventstore::Extensions::CallbackHandlersExtension::ClassMethods
#shutdown PgEventstore::Connection
#socket PG::Connection
#socket_io PG::Connection
#sort_url PgEventstore::Web::Paginator::Helpers
#source_replica_queries PgEventstore::ReplicaSubscriptionHandler
sql_builder_for_estimate_count PgEventstore::QueryBuilders::IndexBasedEventsFiltering
sql_builder_for_event_type_revision_validation PgEventstore::QueryBuilders::IndexBasedEventsFiltering
sql_builder_for_event_type_with_markers_revision_validation PgEventstore::QueryBuilders::IndexBasedEventsFiltering
sql_builder_for_markers_revision_validation PgEventstore::QueryBuilders::IndexBasedEventsFiltering
sql_builder_for_read_common PgEventstore::QueryBuilders::IndexBasedEventsFiltering
sql_builder_for_read_grouped PgEventstore::QueryBuilders::IndexBasedEventsFiltering
sql_builder_for_subscriptions PgEventstore::QueryBuilders::IndexBasedEventsFiltering
#ssl_attribute PG::Connection
#ssl_attribute_names PG::Connection
#ssl_attributes PG::Connection
#ssl_in_use? PG::Connection
#start PgEventstore::BasicRunner
#start PgEventstore::SubscriptionsManager
#start! PgEventstore::SubscriptionsManager
#starting_id PgEventstore::Web::Paginator::BaseCollection
#starting_position PgEventstore::Stream
#starting_position PgEventstore::Web::Paginator::StreamsCollection
#state PgEventstore::BasicRunner
#state PgEventstore::Subscription
#state PgEventstore::SubscriptionsSet
#status PG::Connection
#stop PgEventstore::BasicRunner
#stop_async PgEventstore::BasicRunner
#stream PgEventstore::Event
#stream PgEventstore::StreamNotFoundError
#stream PgEventstore::SystemStreamError
#stream PgEventstore::WrongExpectedRevisionError
#stream PgEventstore::WrongExpectedTypesRevisionError
#stream PgEventstore::MissingPartitions
#stream PgEventstore::TooManyRecordsToLockError
#stream_descr PgEventstore::WrongExpectedRevisionError
#stream_descr PgEventstore::WrongExpectedTypesRevisionError
#stream_id PgEventstore::Stream
#stream_name PgEventstore::Stream
#stream_name PgEventstore::Partition
#stream_path PgEventstore::Web::Paginator::Helpers
#stream_revision PgEventstore::Event
#stream_revision PgEventstore::Client
#stream_revision PgEventstore::Stream
#stream_revision PgEventstore::EventGlobalIndex::WriteApiRepr
#stream_revision PgEventstore::EventGlobalIndex::RevisionCheckRepr
#streams_global_index_queries PgEventstore::Client
#subscribe PgEventstore::SubscriptionsManager
#subscription_cmd PgEventstore::Web::Subscriptions::Helpers
#subscription_cmd_url PgEventstore::Web::Subscriptions::Helpers
#subscription_graceful_shutdown_timeout PgEventstore::Config
#subscription_max_retries PgEventstore::Config
#subscription_position PgEventstore::EventGlobalIndex::SubscriptionRepr
#subscription_position PgEventstore::Chunks::SubscriptionCheckpointChunk::Checkpoint
#subscription_position PgEventstore::Chunks::SubscriptionEventsIndexChunk::RawEventWithSubscriptionPosition
#subscription_pull_interval PgEventstore::Config
subscription_queries PgEventstore::Subscription
#subscription_queries PgEventstore::Subscription
#subscription_queries PgEventstore::Web::Subscriptions::Subscriptions
#subscription_queries PgEventstore::Web::Subscriptions::SetCollection
#subscription_queries PgEventstore::Web::Subscriptions::WithState::Subscriptions
#subscription_queries PgEventstore::Web::Subscriptions::WithState::SetCollection
#subscription_restart_terminator PgEventstore::Config
#subscription_retries_interval PgEventstore::Config
#subscriptions PgEventstore::Web::Subscriptions::Subscriptions
#subscriptions PgEventstore::SubscriptionsManager
#subscriptions PgEventstore::Web::Subscriptions::WithState::Subscriptions
#subscriptions PgEventstore::Web::Subscriptions::SubscriptionsToSetAssociation
subscriptions_manager PgEventstore
#subscriptions_set PgEventstore::SubscriptionsManager
#subscriptions_set PgEventstore::Web::Subscriptions::SubscriptionsSet
#subscriptions_set PgEventstore::Web::Subscriptions::WithState::SubscriptionsSet
#subscriptions_set PgEventstore::Web::Subscriptions::SubscriptionsToSetAssociation
#subscriptions_set_cmd PgEventstore::Web::Subscriptions::Helpers
#subscriptions_set_cmd_url PgEventstore::Web::Subscriptions::Helpers
#subscriptions_set_max_retries PgEventstore::Config
#subscriptions_set_queries PgEventstore::SubscriptionsSet
#subscriptions_set_queries PgEventstore::Web::Subscriptions::SetCollection
#subscriptions_set_queries PgEventstore::Web::Subscriptions::SubscriptionsSet
#subscriptions_set_queries PgEventstore::Web::Subscriptions::WithState::SubscriptionsSet
#subscriptions_set_retries_interval PgEventstore::Config
#subscriptions_state PgEventstore::Web::Subscriptions::Helpers
#subscriptions_state_url PgEventstore::Web::Subscriptions::Helpers
#subscriptions_url PgEventstore::Web::Subscriptions::Helpers
#suitable_strategy PgEventstore::BasicRunner
#sync_cancel PG::Connection
sync_connect PG::Connection
#sync_describe_portal PG::Connection
#sync_describe_prepared PG::Connection
#sync_encrypt_password PG::Connection
#sync_exec PG::Connection
#sync_exec_params PG::Connection
#sync_exec_prepared PG::Connection
#sync_flush PG::Connection
#sync_get_copy_data PG::Connection
#sync_get_last_result PG::Connection
#sync_get_result PG::Connection
#sync_isnonblocking PG::Connection
sync_ping PG::Connection
#sync_prepare PG::Connection
#sync_put_copy_data PG::Connection
#sync_put_copy_end PG::Connection
#sync_reset PG::Connection
#sync_set_client_encoding PG::Connection
#sync_setnonblocking PG::Connection
#synchronize PgEventstore::BasicRunner
#system? PgEventstore::Event
system_stream PgEventstore::Stream
#table_name PgEventstore::RecordNotFound
#table_name PgEventstore::Partition
#time PgEventstore::EventsSubscriptionPositionWorker::ReindexTime
#time_between_restarts PgEventstore::Subscription
#time_between_restarts PgEventstore::SubscriptionsSet
#to_h PgEventstore::Error
#to_hash PgEventstore::Stream
#to_position PgEventstore::QueryBuilders::ReadCursor::StreamCursor::AllStreamCursor
#to_revision PgEventstore::QueryBuilders::ReadCursor::StreamCursor::RegularStreamCursor
#to_sql_builder PgEventstore::QueryBuilders::IndexBasedEventsFiltering
#to_subscription_position_attrs PgEventstore::EventGlobalIndex::SubscriptionRepr
#to_table_name PgEventstore::QueryBuilders::IndexBasedEventsFiltering
#total_count PgEventstore::Web::Paginator::Helpers
#total_count PgEventstore::Web::Paginator::BaseCollection
#total_count PgEventstore::Web::Paginator::EventsCollection
#total_count PgEventstore::Web::Paginator::StreamsCollection
#total_processed_events PgEventstore::Subscription
#trace PG::Connection
#transaction PG::Connection
#transaction_queries PgEventstore::Client
#transaction_queries PgEventstore::Maintenance
#transaction_status PG::Connection
#tty PG::Connection
#type PgEventstore::Event
#type_map_for_queries PG::Connection
#type_map_for_queries= PG::Connection
#type_map_for_results PG::Connection
#type_map_for_results= PG::Connection
underscore_str PgEventstore::Utils
unescape_bytea PG::Connection
#unescape_bytea PG::Connection
#unmatched_stream_revision PgEventstore::WrongExpectedRevisionError
#untrace PG::Connection
unwrap_exception PgEventstore::Utils
#update PgEventstore::Subscription
#update PgEventstore::SubscriptionsSet
#updated_at PgEventstore::Subscription
#updated_at PgEventstore::SubscriptionsSet
#uri PgEventstore::Connection
#user PG::Connection
#user_friendly_message PgEventstore::WrongExpectedRevisionError
#user_friendly_message PgEventstore::WrongExpectedTypesRevisionError
#user_friendly_message PgEventstore::RecordNotFound
#user_friendly_message PgEventstore::SubscriptionAlreadyLockedError
#user_friendly_message PgEventstore::WrongLockIdError
#user_friendly_message PgEventstore::NotPersistedEventError
#user_friendly_message PgEventstore::TooManyRecordsToLockError
#using_connection PgEventstore::Extensions::UsingConnectionExtension::ClassMethods
#validate_subscription_cmd PgEventstore::Web::Subscriptions::Helpers
#validate_subscriptions_set_cmd PgEventstore::Web::Subscriptions::Helpers
#verdict PgEventstore::WrongExpectedRevisionError
#verdict PgEventstore::WrongExpectedTypesRevisionError::Verdict
#verdicts PgEventstore::WrongExpectedTypesRevisionError
#wait_for_finish PgEventstore::BasicRunner
#wait_for_notify PG::Connection
#with PgEventstore::Connection
#within_state PgEventstore::BasicRunner
wrap_exception PgEventstore::Utils
writable PgEventstore::Config::NodeRole
write_to_file PgEventstore::Utils