Class SqlSnapshotStore

Abstract snapshot store implementation, customized to work with SQL-based persistence providers.

Inheritance
Object
ActorBase
SnapshotStore
SqlSnapshotStore
SqliteSnapshotStore
Implements
Inherited Members
Namespace: Akka.Persistence.Sql.Common.Snapshot
Assembly: Akka.Persistence.Sql.Common.dll
Syntax
public abstract class SqlSnapshotStore : SnapshotStore, IInternalActor, IWithUnboundedStash, IWithUnrestrictedStash, IActorStash, IRequiresMessageQueue<IUnboundedDequeBasedMessageQueueSemantics>

Constructors

| Improve this Doc View Source

SqlSnapshotStore(Config)

Initializes a new instance of the SqlSnapshotStore class.

Declaration
protected SqlSnapshotStore(Config config)
Parameters
Type Name Description
Config config

The configuration used to configure the snapshot store.

Fields

| Improve this Doc View Source

Settings

Declaration
protected readonly SnapshotStoreSettings Settings
Field Value
Type Description
SnapshotStoreSettings

Properties

| Improve this Doc View Source

Log

TBD

Declaration
protected ILoggingAdapter Log { get; }
Property Value
Type Description
ILoggingAdapter
| Improve this Doc View Source

QueryExecutor

Query executor used to convert snapshot store related operations into corresponding SQL queries.

Declaration
public abstract ISnapshotQueryExecutor QueryExecutor { get; }
Property Value
Type Description
ISnapshotQueryExecutor
| Improve this Doc View Source

Stash

TBD

Declaration
public IStash Stash { get; set; }
Property Value
Type Description
IStash

Methods

| Improve this Doc View Source

CreateDbConnection()

Returns a new instance of database connection.

Declaration
public DbConnection CreateDbConnection()
Returns
Type Description
DbConnection

TBD
| Improve this Doc View Source

CreateDbConnection(String)

Returns a new instance of database connection.

Declaration
protected abstract DbConnection CreateDbConnection(string connectionString)
Parameters
Type Name Description
String connectionString

TBD
Returns
Type Description
DbConnection

TBD
| Improve this Doc View Source

DeleteAsync(SnapshotMetadata)

TBD

Declaration
protected override async Task DeleteAsync(SnapshotMetadata metadata)
Parameters
Type Name Description
SnapshotMetadata metadata

TBD
Returns
Type Description
Task

TBD
Overrides
| Improve this Doc View Source

DeleteAsync(String, SnapshotSelectionCriteria)

TBD

Declaration
protected override async Task DeleteAsync(string persistenceId, SnapshotSelectionCriteria criteria)
Parameters
Type Name Description
String persistenceId

TBD
SnapshotSelectionCriteria criteria

TBD
Returns
Type Description
Task

TBD
Overrides
| Improve this Doc View Source

GetConnectionString()

TBD

Declaration
protected virtual string GetConnectionString()
Returns
Type Description
String

TBD
| Improve this Doc View Source

LoadAsync(String, SnapshotSelectionCriteria)

Asynchronously loads snapshot with the highest sequence number for a persistent actor/view matching specified criteria.

Declaration
protected override async Task<SelectedSnapshot> LoadAsync(string persistenceId, SnapshotSelectionCriteria criteria)
Parameters
Type Name Description
String persistenceId

TBD
SnapshotSelectionCriteria criteria

TBD
Returns
Type Description
Task<SelectedSnapshot>

TBD
Overrides
| Improve this Doc View Source

PostStop()

TBD

Declaration
protected override void PostStop()
Overrides
| Improve this Doc View Source

PreStart()

TBD

Declaration
protected override void PreStart()
Overrides
| Improve this Doc View Source

SaveAsync(SnapshotMetadata, Object)

Asynchronously stores a snapshot with metadata as record in SQL table.

Declaration
protected override async Task SaveAsync(SnapshotMetadata metadata, object snapshot)
Parameters
Type Name Description
SnapshotMetadata metadata

TBD
Object snapshot

TBD
Returns
Type Description
Task

TBD
Overrides

Implements

Extension Methods