Skip to content

Latest commit

 

History

History
84 lines (59 loc) · 2.66 KB

README.md

File metadata and controls

84 lines (59 loc) · 2.66 KB

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();