Class: Sequent::Configuration
- Inherits:
-
Object
- Object
- Sequent::Configuration
- Defined in:
- lib/sequent/configuration.rb
Constant Summary collapse
- DEFAULT_VERSIONS_TABLE_NAME =
'sequent_versions'
- DEFAULT_REPLAYED_IDS_TABLE_NAME =
'sequent_replayed_ids'
- DEFAULT_MIGRATION_SQL_FILES_DIRECTORY =
'db/tables'
- DEFAULT_DATABASE_CONFIG_DIRECTORY =
'db'
- DEFAULT_VIEW_SCHEMA_NAME =
'view_schema'
- DEFAULT_EVENT_STORE_SCHEMA_NAME =
'sequent_schema'
- MIGRATIONS_CLASS_NAME =
'Sequent::Migrations::Projectors'
- DEFAULT_NUMBER_OF_REPLAY_PROCESSES =
4
- DEFAULT_OFFLINE_REPLAY_PERSISTOR_CLASS =
Sequent::Core::Persistors::ActiveRecordPersistor
- DEFAULT_ONLINE_REPLAY_PERSISTOR_CLASS =
Sequent::Core::Persistors::ActiveRecordPersistor
- DEFAULT_EVENT_RECORD_HOOKS_CLASS =
Sequent::Core::EventRecordHooks
Instance Attribute Summary collapse
-
#aggregate_repository ⇒ Object
Returns the value of attribute aggregate_repository.
-
#command_filters ⇒ Object
Returns the value of attribute command_filters.
-
#command_handlers ⇒ Object
Returns the value of attribute command_handlers.
-
#command_service ⇒ Object
Returns the value of attribute command_service.
-
#database_config_directory ⇒ Object
Returns the value of attribute database_config_directory.
-
#disable_event_handlers ⇒ Object
Returns the value of attribute disable_event_handlers.
-
#event_handlers ⇒ Object
Returns the value of attribute event_handlers.
-
#event_publisher ⇒ Object
Returns the value of attribute event_publisher.
-
#event_record_class ⇒ Object
Returns the value of attribute event_record_class.
-
#event_record_hooks_class ⇒ Object
Returns the value of attribute event_record_hooks_class.
-
#event_store ⇒ Object
Returns the value of attribute event_store.
-
#event_store_schema_name ⇒ Object
Returns the value of attribute event_store_schema_name.
-
#logger ⇒ Object
Returns the value of attribute logger.
-
#migration_sql_files_directory ⇒ Object
Returns the value of attribute migration_sql_files_directory.
-
#migrations_class_name ⇒ Object
Returns the value of attribute migrations_class_name.
-
#number_of_replay_processes ⇒ Object
Returns the value of attribute number_of_replay_processes.
-
#offline_replay_persistor_class ⇒ Object
Returns the value of attribute offline_replay_persistor_class.
-
#online_replay_persistor_class ⇒ Object
Returns the value of attribute online_replay_persistor_class.
-
#replayed_ids_table_name ⇒ Object
Returns the value of attribute replayed_ids_table_name.
-
#snapshot_event_class ⇒ Object
Returns the value of attribute snapshot_event_class.
-
#stream_record_class ⇒ Object
Returns the value of attribute stream_record_class.
-
#transaction_provider ⇒ Object
Returns the value of attribute transaction_provider.
-
#uuid_generator ⇒ Object
Returns the value of attribute uuid_generator.
-
#versions_table_name ⇒ Object
Returns the value of attribute versions_table_name.
-
#view_schema_name ⇒ Object
Returns the value of attribute view_schema_name.
Class Method Summary collapse
Instance Method Summary collapse
-
#initialize ⇒ Configuration
constructor
A new instance of Configuration.
Constructor Details
#initialize ⇒ Configuration
Returns a new instance of Configuration.
76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 |
# File 'lib/sequent/configuration.rb', line 76 def initialize self.command_handlers = [] self.command_filters = [] self.event_handlers = [] self.aggregate_repository = Sequent::Core::AggregateRepository.new self.event_store = Sequent::Core::EventStore.new self.command_service = Sequent::Core::CommandService.new self.event_record_class = Sequent::Core::EventRecord self.stream_record_class = Sequent::Core::StreamRecord self.snapshot_event_class = Sequent::Core::SnapshotEvent self.transaction_provider = Sequent::Core::Transactions::ActiveRecordTransactionProvider.new self.uuid_generator = Sequent::Core::RandomUuidGenerator self.event_publisher = Sequent::Core::EventPublisher.new self.disable_event_handlers = false self.versions_table_name = DEFAULT_VERSIONS_TABLE_NAME self.replayed_ids_table_name = DEFAULT_REPLAYED_IDS_TABLE_NAME self.migration_sql_files_directory = DEFAULT_MIGRATION_SQL_FILES_DIRECTORY self.view_schema_name = DEFAULT_VIEW_SCHEMA_NAME self.event_store_schema_name = DEFAULT_EVENT_STORE_SCHEMA_NAME self.migrations_class_name = MIGRATIONS_CLASS_NAME self.number_of_replay_processes = DEFAULT_NUMBER_OF_REPLAY_PROCESSES self.event_record_hooks_class = DEFAULT_EVENT_RECORD_HOOKS_CLASS self.offline_replay_persistor_class = DEFAULT_OFFLINE_REPLAY_PERSISTOR_CLASS self.online_replay_persistor_class = DEFAULT_ONLINE_REPLAY_PERSISTOR_CLASS self.database_config_directory = DEFAULT_DATABASE_CONFIG_DIRECTORY self.logger = Logger.new(STDOUT).tap {|l| l.level = Logger::INFO } end |
Instance Attribute Details
#aggregate_repository ⇒ Object
Returns the value of attribute aggregate_repository.
29 30 31 |
# File 'lib/sequent/configuration.rb', line 29 def aggregate_repository @aggregate_repository end |
#command_filters ⇒ Object
Returns the value of attribute command_filters.
41 42 43 |
# File 'lib/sequent/configuration.rb', line 41 def command_filters @command_filters end |
#command_handlers ⇒ Object
Returns the value of attribute command_handlers.
41 42 43 |
# File 'lib/sequent/configuration.rb', line 41 def command_handlers @command_handlers end |
#command_service ⇒ Object
Returns the value of attribute command_service.
31 32 33 |
# File 'lib/sequent/configuration.rb', line 31 def command_service @command_service end |
#database_config_directory ⇒ Object
Returns the value of attribute database_config_directory.
52 53 54 |
# File 'lib/sequent/configuration.rb', line 52 def database_config_directory @database_config_directory end |
#disable_event_handlers ⇒ Object
Returns the value of attribute disable_event_handlers.
48 49 50 |
# File 'lib/sequent/configuration.rb', line 48 def disable_event_handlers @disable_event_handlers end |
#event_handlers ⇒ Object
Returns the value of attribute event_handlers.
44 45 46 |
# File 'lib/sequent/configuration.rb', line 44 def event_handlers @event_handlers end |
#event_publisher ⇒ Object
Returns the value of attribute event_publisher.
31 32 33 |
# File 'lib/sequent/configuration.rb', line 31 def event_publisher @event_publisher end |
#event_record_class ⇒ Object
Returns the value of attribute event_record_class.
31 32 33 |
# File 'lib/sequent/configuration.rb', line 31 def event_record_class @event_record_class end |
#event_record_hooks_class ⇒ Object
Returns the value of attribute event_record_hooks_class.
39 40 41 |
# File 'lib/sequent/configuration.rb', line 39 def event_record_hooks_class @event_record_hooks_class end |
#event_store ⇒ Object
Returns the value of attribute event_store.
31 32 33 |
# File 'lib/sequent/configuration.rb', line 31 def event_store @event_store end |
#event_store_schema_name ⇒ Object
Returns the value of attribute event_store_schema_name.
52 53 54 |
# File 'lib/sequent/configuration.rb', line 52 def event_store_schema_name @event_store_schema_name end |
#logger ⇒ Object
Returns the value of attribute logger.
50 51 52 |
# File 'lib/sequent/configuration.rb', line 50 def logger @logger end |
#migration_sql_files_directory ⇒ Object
Returns the value of attribute migration_sql_files_directory.
52 53 54 |
# File 'lib/sequent/configuration.rb', line 52 def migration_sql_files_directory @migration_sql_files_directory end |
#migrations_class_name ⇒ Object
Returns the value of attribute migrations_class_name.
60 61 62 |
# File 'lib/sequent/configuration.rb', line 60 def migrations_class_name @migrations_class_name end |
#number_of_replay_processes ⇒ Object
Returns the value of attribute number_of_replay_processes.
52 53 54 |
# File 'lib/sequent/configuration.rb', line 52 def number_of_replay_processes @number_of_replay_processes end |
#offline_replay_persistor_class ⇒ Object
Returns the value of attribute offline_replay_persistor_class.
52 53 54 |
# File 'lib/sequent/configuration.rb', line 52 def offline_replay_persistor_class @offline_replay_persistor_class end |
#online_replay_persistor_class ⇒ Object
Returns the value of attribute online_replay_persistor_class.
52 53 54 |
# File 'lib/sequent/configuration.rb', line 52 def online_replay_persistor_class @online_replay_persistor_class end |
#replayed_ids_table_name ⇒ Object
Returns the value of attribute replayed_ids_table_name.
60 61 62 |
# File 'lib/sequent/configuration.rb', line 60 def replayed_ids_table_name @replayed_ids_table_name end |
#snapshot_event_class ⇒ Object
Returns the value of attribute snapshot_event_class.
31 32 33 |
# File 'lib/sequent/configuration.rb', line 31 def snapshot_event_class @snapshot_event_class end |
#stream_record_class ⇒ Object
Returns the value of attribute stream_record_class.
31 32 33 |
# File 'lib/sequent/configuration.rb', line 31 def stream_record_class @stream_record_class end |
#transaction_provider ⇒ Object
Returns the value of attribute transaction_provider.
31 32 33 |
# File 'lib/sequent/configuration.rb', line 31 def transaction_provider @transaction_provider end |
#uuid_generator ⇒ Object
Returns the value of attribute uuid_generator.
46 47 48 |
# File 'lib/sequent/configuration.rb', line 46 def uuid_generator @uuid_generator end |
#versions_table_name ⇒ Object
Returns the value of attribute versions_table_name.
60 61 62 |
# File 'lib/sequent/configuration.rb', line 60 def versions_table_name @versions_table_name end |
#view_schema_name ⇒ Object
Returns the value of attribute view_schema_name.
52 53 54 |
# File 'lib/sequent/configuration.rb', line 52 def view_schema_name @view_schema_name end |
Class Method Details
.instance ⇒ Object
64 65 66 |
# File 'lib/sequent/configuration.rb', line 64 def self.instance @instance ||= new end |
.reset ⇒ Object
68 69 70 |
# File 'lib/sequent/configuration.rb', line 68 def self.reset @instance = new end |
.restore(configuration) ⇒ Object
72 73 74 |
# File 'lib/sequent/configuration.rb', line 72 def self.restore(configuration) @instance = configuration end |