Class: Sequent::Configuration

Inherits:
Object
  • Object
show all
Defined in:
lib/sequent/configuration.rb

Constant Summary collapse

DEFAULT_VERSIONS_TABLE_NAME = 
'sequent_versions'
DEFAULT_MIGRATION_SQL_FILES_DIRECTORY = 
'db/tables'
DEFAULT_DATABASE_CONFIG_DIRECTORY = 
'db'
DEFAULT_DATABASE_SCHEMA_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
DEFAULT_STRICT_CHECK_ATTRIBUTES_ON_APPLY_EVENTS = 
false
DEFAULT_ERROR_LOCALE_RESOLVER = 
-> { I18n.locale || :en }
DEFAULT_TIME_PRECISION = 
ActiveSupport::JSON::Encoding.time_precision

Instance Attribute Summary collapse

Class Method Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize ⇒ Configuration

Returns a new instance of Configuration.



87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
 
# File 'lib/sequent/configuration.rb', line 87

def initialize
  self.command_handlers = []
  self.command_filters = []
  self.event_handlers = []
  self.command_middleware = Sequent::Core::Middleware::Chain.new

  self.aggregate_repository = Sequent::Core::AggregateRepository.new
  self.event_store_cache_event_types = true
  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.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.database_schema_directory = DEFAULT_DATABASE_SCHEMA_DIRECTORY
  self.strict_check_attributes_on_apply_events = DEFAULT_STRICT_CHECK_ATTRIBUTES_ON_APPLY_EVENTS

  self.logger = Logger.new(STDOUT).tap { |l| l.level = Logger::INFO }
  self.error_locale_resolver = DEFAULT_ERROR_LOCALE_RESOLVER

  self.enable_multiple_database_support = false
  self.primary_database_role = :writing
  self.primary_database_key = :primary

  self.time_precision = DEFAULT_TIME_PRECISION

  self.enable_autoregistration = false
end

Instance Attribute Details

#aggregate_repository ⇒ Object

Returns the value of attribute aggregate_repository.



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

def aggregate_repository
  @aggregate_repository
end

#command_filters ⇒ Object

Returns the value of attribute command_filters.



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

def command_filters
  @command_filters
end

#command_handlers ⇒ Object

Returns the value of attribute command_handlers.



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

def command_handlers
  @command_handlers
end

#command_middleware ⇒ Object

Returns the value of attribute command_middleware.



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

def command_middleware
  @command_middleware
end

#command_service ⇒ Object

Returns the value of attribute command_service.



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

def command_service
  @command_service
end

#database_config_directory ⇒ Object

Returns the value of attribute database_config_directory.



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

def database_config_directory
  @database_config_directory
end

#database_schema_directory ⇒ Object

Returns the value of attribute database_schema_directory.



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

def database_schema_directory
  @database_schema_directory
end

#disable_event_handlers ⇒ Object

Returns the value of attribute disable_event_handlers.



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

def disable_event_handlers
  @disable_event_handlers
end

#enable_autoregistration ⇒ Object

Returns the value of attribute enable_autoregistration.



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

def enable_autoregistration
  @enable_autoregistration
end

#enable_multiple_database_support ⇒ Object

Returns the value of attribute enable_multiple_database_support.



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

def enable_multiple_database_support
  @enable_multiple_database_support
end

#error_locale_resolver ⇒ Object

Returns the value of attribute error_locale_resolver.



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

def error_locale_resolver
  @error_locale_resolver
end

#event_handlers ⇒ Object

Returns the value of attribute event_handlers.



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

def event_handlers
  @event_handlers
end

#event_publisher ⇒ Object

Returns the value of attribute event_publisher.



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

def event_publisher
  @event_publisher
end

#event_record_class ⇒ Object

Returns the value of attribute event_record_class.



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

def event_record_class
  @event_record_class
end

#event_record_hooks_class ⇒ Object

Returns the value of attribute event_record_hooks_class.



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

def event_record_hooks_class
  @event_record_hooks_class
end

#event_store ⇒ Object

Returns the value of attribute event_store.



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

def event_store
  @event_store
end

#event_store_cache_event_types ⇒ Object

Returns the value of attribute event_store_cache_event_types.



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

def event_store_cache_event_types
  @event_store_cache_event_types
end

#event_store_schema_name ⇒ Object

Returns the value of attribute event_store_schema_name.



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

def event_store_schema_name
  @event_store_schema_name
end

#logger ⇒ Object

Returns the value of attribute logger.



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

def logger
  @logger
end

#migration_sql_files_directory ⇒ Object

Returns the value of attribute migration_sql_files_directory.



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

def migration_sql_files_directory
  @migration_sql_files_directory
end

#migrations_class_name ⇒ Object

Returns the value of attribute migrations_class_name.



69
70
71
 
# File 'lib/sequent/configuration.rb', line 69

def migrations_class_name
  @migrations_class_name
end

#number_of_replay_processes ⇒ Object

Returns the value of attribute number_of_replay_processes.



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

def number_of_replay_processes
  @number_of_replay_processes
end

#offline_replay_persistor_class ⇒ Object

Returns the value of attribute offline_replay_persistor_class.



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

def offline_replay_persistor_class
  @offline_replay_persistor_class
end

#online_replay_persistor_class ⇒ Object

Returns the value of attribute online_replay_persistor_class.



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

def online_replay_persistor_class
  @online_replay_persistor_class
end

#primary_database_key ⇒ Object

Returns the value of attribute primary_database_key.



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

def primary_database_key
  @primary_database_key
end

#primary_database_role ⇒ Object

Returns the value of attribute primary_database_role.



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

def primary_database_role
  @primary_database_role
end

#snapshot_event_class ⇒ Object

Returns the value of attribute snapshot_event_class.



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

def snapshot_event_class
  @snapshot_event_class
end

#stream_record_class ⇒ Object

Returns the value of attribute stream_record_class.



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

def stream_record_class
  @stream_record_class
end

#strict_check_attributes_on_apply_events ⇒ Object

Returns the value of attribute strict_check_attributes_on_apply_events.



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

def strict_check_attributes_on_apply_events
  @strict_check_attributes_on_apply_events
end

#time_precision ⇒ Object

Returns the value of attribute time_precision.



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

def time_precision
  @time_precision
end

#transaction_provider ⇒ Object

Returns the value of attribute transaction_provider.



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

def transaction_provider
  @transaction_provider
end

#uuid_generator ⇒ Object

Returns the value of attribute uuid_generator.



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

def uuid_generator
  @uuid_generator
end

#versions_table_name ⇒ Object

Returns the value of attribute versions_table_name.



69
70
71
 
# File 'lib/sequent/configuration.rb', line 69

def versions_table_name
  @versions_table_name
end

#view_schema_name ⇒ Object

Returns the value of attribute view_schema_name.



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

def view_schema_name
  @view_schema_name
end

Class Method Details

.instance ⇒ Object 



72
73
74
 
# File 'lib/sequent/configuration.rb', line 72

def self.instance
  @instance ||= new
end

.reset ⇒ Object

Create a new instance of Configuration



77
78
79
 
# File 'lib/sequent/configuration.rb', line 77

def self.reset
  @instance = new
end

.restore(configuration) ⇒ Object

Restore the given Configuration

Parameters:



83
84
85
 
# File 'lib/sequent/configuration.rb', line 83

def self.restore(configuration)
  @instance = configuration
end

Instance Method Details

#can_use_multiple_databases? ⇒ Boolean

Returns:



131
132
133
 
# File 'lib/sequent/configuration.rb', line 131

def can_use_multiple_databases?
  enable_multiple_database_support && ActiveRecord.version > Gem::Version.new('6.1.0')
end