Instead of providing a module, a bundle, a bridge or similar framework integration prooph/event-store ships with interop factories.
The concept behind these factories (see src/Container folder) is simple but powerful. It allows us to provide you with bootstrapping logic for the event store and related components
without the need to rely on a specific framework. However, the factories have three requirements.
config in the container.Note: Don't worry, if your environment doesn't provide these requirements, you can always bootstrap the components by hand. Just look at the factories for inspiration in this case.
If the requirements are met you just need to add a new section in your application config ...
[
'prooph' => [
'event_store' => [
'default' => [
'wrap_action_event_emitter' => true,
'metadata_enrichers' => [
// The factory will get the metadata enrichers and inject them in the MetadataEnricherPlugin.
// Note: you can obtain the same result by instanciating the plugin yourself
// and pass it to the 'plugin' section bellow.
'metadata_enricher_1',
'metadata_enricher_2',
// ...
],
'plugins' => [
//And again the factory will use each service id to get the plugin from the container
//Plugin::attachToEventStore($eventStore) is then invoked by the factory so your plugins
// get attached automatically
//Awesome, isn't it?
'plugin_1_service_id',
'plugin_2_service_id',
//...
],
'connection' => 'my_pdo_connection', // service id for the used pdo connection
'persistence_strategy' => MariaDbSingleStreamStrategy::class, // service id for the used persistance strategy
'load_batch_size' => 1000, // how many events a query should return in one batch, defaults to 1000
'event_streams_table' => 'event_streams', // event stream table to use, defaults to `event_streams`
'message_factory' => FQCNMessageFactory::class, // message factory to use, defauls to `FQCNMessageFactory::class`
],
],
],
'dependencies' => [
'factories' => [
'MariaDbEventStore' => [
\Prooph\EventStore\Container\MariaDbEventStoreFactory::class,
'default',
],
],
],
//... other application config here
]
$eventStore = $container->get('MariaDbEventStore');
[
'prooph' => [
'projection_manager' => [
'default' => [
'event_store' => 'MariaDbEventStore',
'connection' => 'my_pdo_connection', // service id for the used pdo connection
'event_streams_table' => 'event_streams', // event stream table to use, defaults to `event_streams`
'projections_table' => 'projections', // projection table to use, defaults to `projections`
],
],
],
'dependencies' => [
'factories' => [
'MariaDbProjectionManager' => [
\Prooph\EventStore\Container\MariaDbProjectionManagerFactory::class,
'default',
],
],
],
//... other application config here
]
$projectionManager = $container->get('MariaDbProjectionManager');
If the requirements are met you just need to add a new section in your application config ...
[
'prooph' => [
'event_store' => [
'default' => [
'wrap_action_event_emitter' => true,
'metadata_enrichers' => [
// The factory will get the metadata enrichers and inject them in the MetadataEnricherPlugin.
// Note: you can obtain the same result by instanciating the plugin yourself
// and pass it to the 'plugin' section bellow.
'metadata_enricher_1',
'metadata_enricher_2',
// ...
],
'plugins' => [
//And again the factory will use each service id to get the plugin from the container
//Plugin::attachToEventStore($eventStore) is then invoked by the factory so your plugins
// get attached automatically
//Awesome, isn't it?
'plugin_1_service_id',
'plugin_2_service_id',
//...
],
'connection' => 'my_pdo_connection', // service id for the used pdo connection
'persistence_strategy' => MySqlSingleStreamStrategy::class, // service id for the used persistance strategy
'load_batch_size' => 1000, // how many events a query should return in one batch, defaults to 1000
'event_streams_table' => 'event_streams', // event stream table to use, defaults to `event_streams`
'message_factory' => FQCNMessageFactory::class, // message factory to use, defauls to `FQCNMessageFactory::class`
],
],
],
'dependencies' => [
'factories' => [
'MySqlEventStore' => [
\Prooph\EventStore\Container\MySqlEventStoreFactory::class,
'default',
],
],
],
//... other application config here
]
$eventStore = $container->get('MySqlEventStore');
[
'prooph' => [
'projection_manager' => [
'default' => [
'event_store' => 'MySqlEventStore',
'connection' => 'my_pdo_connection', // service id for the used pdo connection
'event_streams_table' => 'event_streams', // event stream table to use, defaults to `event_streams`
'projections_table' => 'projections', // projection table to use, defaults to `projections`
],
],
],
'dependencies' => [
'factories' => [
'MySqlProjectionManager' => [
\Prooph\EventStore\Container\MySqlProjectionManagerFactory::class,
'default',
],
],
],
//... other application config here
]
$projectionManager = $container->get('MySqlProjectionManager');
If the requirements are met you just need to add a new section in your application config ...
[
'prooph' => [
'event_store' => [
'default' => [
'wrap_action_event_emitter' => true,
'metadata_enrichers' => [
// The factory will get the metadata enrichers and inject them in the MetadataEnricherPlugin.
// Note: you can obtain the same result by instanciating the plugin yourself
// and pass it to the 'plugin' section bellow.
'metadata_enricher_1',
'metadata_enricher_2',
// ...
],
'plugins' => [
//And again the factory will use each service id to get the plugin from the container
//Plugin::attachToEventStore($eventStore) is then invoked by the factory so your plugins
// get attached automatically
//Awesome, isn't it?
'plugin_1_service_id',
'plugin_2_service_id',
//...
],
'connection' => 'my_pdo_connection', // service id for the used pdo connection
'persistence_strategy' => PostgresSingleStreamStrategy::class, // service id for the used persistance strategy
'load_batch_size' => 1000, // how many events a query should return in one batch, defaults to 1000
'event_streams_table' => 'event_streams', // event stream table to use, defaults to `event_streams`
'message_factory' => FQCNMessageFactory::class, // message factory to use, defauls to `FQCNMessageFactory::class`
],
],
],
'dependencies' => [
'factories' => [
'PostgresEventStore' => [
\Prooph\EventStore\Container\PostgresEventStoreFactory::class,
'default',
],
],
],
//... other application config here
]
$eventStore = $container->get('PostgresEventStore');
[
'prooph' => [
'projection_manager' => [
'default' => [
'event_store' => 'PostgresEventStore',
'connection' => 'my_pdo_connection', // service id for the used pdo connection
'event_streams_table' => 'event_streams', // event stream table to use, defaults to `event_streams`
'projections_table' => 'projections', // projection table to use, defaults to `projections`
],
],
],
'dependencies' => [
'factories' => [
'PostgresProjectionManager' => [
\Prooph\EventStore\Container\PostgresProjectionManagerFactory::class,
'default',
],
],
],
//... other application config here
]
$projectionManager = $container->get('PostgresProjectionManager');
[
'prooph' => [
'pdo_connection' => [
'default' => [
'schema', // one of mysql or pgsql
'user', // username to use
'password', // password to use
'port', // port to use
'host' => '127.0.0.1', // host name, defaults to `127.0.0.1`
'dbname' => 'event_store', // database name, defaults to `event_store`
'charset' => 'utf8', // chartset, defaults to `UTF-8`,
],
],
],
'dependencies' => [
'factories' => [
'my_pdo_connection' => [
\Prooph\EventStore\Container\PdoConnectionFactory::class,
'default',
],
],
],
//... other application config here
]
$pdoConnection = $container->get('my_pdo_connection');