👁 Image
Akka.Persistence.SqlServer.Hosting 1.5.37

Akka.Persistence.SqlServer.Hosting

Akka.Hosting extension methods to add Akka.Persistence.SqlServer to an ActorSystem

Akka.Persistence.SqlServer Extension Methods

WithSqlServerPersistence() Method

public static AkkaConfigurationBuilder WithSqlServerPersistence(
 this AkkaConfigurationBuilder builder,
 string connectionString,
 PersistenceMode mode = PersistenceMode.Both, 
 Action<AkkaPersistenceJournalBuilder>? configurator = null,
 bool autoInitialize = true);

public static AkkaConfigurationBuilder WithSqlServerPersistence(
 this AkkaConfigurationBuilder builder,
 Action<SqlServerJournalOptions>? journalConfigurator = null,
 Action<SqlServerSnapshotOptions>? snapshotConfigurator = null,
 Action<AkkaPersistenceJournalBuilder>? configurator = null);

public static AkkaConfigurationBuilder WithSqlServerPersistence(
 this AkkaConfigurationBuilder builder,
 SqlServerJournalOptions? journalOptions = null,
 SqlServerSnapshotOptions? snapshotOptions = null,
 Action<AkkaPersistenceJournalBuilder>? configurator = null);

Parameters

• connectionString string

  Connection string used for database access.

• mode PersistenceMode

  Determines which settings should be added by this method call.

  • PersistenceMode.Journal: Only add the journal settings
  • PersistenceMode.SnapshotStore: Only add the snapshot store settings
  • PersistenceMode.Both: Add both journal and snapshot store settings

• configurator Action<AkkaPersistenceJournalBuilder>

  An Action delegate used to configure an AkkaPersistenceJournalBuilder instance. Used to configure Event Adapters

• journalConfigurator Action<SqlServerJournalOptions>

  An Action delegate to configure a SqlServerJournalOptions instance.

• snapshotConfigurator Action<SqlServerSnapshotOptions>

  An Action delegate to configure a SqlServerSnapshotOptions instance.

• journalOptions SqlServerJournalOptions

  An SqlServerJournalOptions instance to configure the SqlServer journal.

• snapshotOptions SqlServerSnapshotOptions

  An SqlServerSnapshotOptions instance to configure the SqlServer snapshot store.

Example

using var host = new HostBuilder()
 .ConfigureServices((context, services) =>
 {
 services.AddAkka("ecsBootstrapDemo", (builder, provider) =>
 {
 builder
 .WithRemoting("localhost", 8110)
 .WithClustering()
 .WithSqlServerPersistence("your-sqlserver-connection-string");
 });
 }).Build();

await host.RunAsync();