Interface ISnapshotQueryExecutor

TBD

Namespace: Akka.Persistence.Sql.Common.Snapshot
Assembly: Akka.Persistence.Sqlite.dll
Syntax
public interface ISnapshotQueryExecutor

Properties

| Improve this Doc View Source

Configuration

Configuration settings for the current query executor.

Declaration
QueryConfiguration Configuration { get; }
Property Value
Type Description
QueryConfiguration

Methods

| Improve this Doc View Source

CreateTableAsync(DbConnection, CancellationToken)

TBD

Declaration
Task CreateTableAsync(DbConnection connection, CancellationToken cancellationToken)
Parameters
Type Name Description
DbConnection connection

TBD
CancellationToken cancellationToken

TBD
Returns
Type Description
Task

TBD
| Improve this Doc View Source

DeleteAsync(DbConnection, CancellationToken, String, Int64, Nullable<DateTime>)

Deletes a single snapshot identified by it's persistent actor's persistenceId, sequenceNr and timestamp.

Declaration
Task DeleteAsync(DbConnection connection, CancellationToken cancellationToken, string persistenceId, long sequenceNr, DateTime? timestamp)
Parameters
Type Name Description
DbConnection connection

TBD
CancellationToken cancellationToken

TBD
String persistenceId

TBD
Int64 sequenceNr

TBD
Nullable<DateTime> timestamp

TBD
Returns
Type Description
Task

TBD
| Improve this Doc View Source

DeleteBatchAsync(DbConnection, CancellationToken, String, Int64, DateTime)

Deletes all snapshot matching persistent actor's persistenceId as well as upper (inclusive) bounds of the both maxSequenceNr and maxTimestamp.

Declaration
Task DeleteBatchAsync(DbConnection connection, CancellationToken cancellationToken, string persistenceId, long maxSequenceNr, DateTime maxTimestamp)
Parameters
Type Name Description
DbConnection connection

TBD
CancellationToken cancellationToken

TBD
String persistenceId

TBD
Int64 maxSequenceNr

TBD
DateTime maxTimestamp

TBD
Returns
Type Description
Task

TBD
| Improve this Doc View Source

InsertAsync(DbConnection, CancellationToken, Object, SnapshotMetadata)

Inserts a single snapshot represented by provided SnapshotEntry instance.

Declaration
Task InsertAsync(DbConnection connection, CancellationToken cancellationToken, object snapshot, SnapshotMetadata metadata)
Parameters
Type Name Description
DbConnection connection

TBD
CancellationToken cancellationToken

TBD
Object snapshot

TBD
SnapshotMetadata metadata

TBD
Returns
Type Description
Task

TBD
| Improve this Doc View Source

SelectSnapshotAsync(DbConnection, CancellationToken, String, Int64, DateTime)

Selects a single snapshot identified by persistent actor's persistenceId, matching upper (inclusive) bounds of both maxSequenceNr and maxTimestamp. In case, when more than one snapshot matches specified criteria, one with the highest sequence number will be selected.

Declaration
Task<SelectedSnapshot> SelectSnapshotAsync(DbConnection connection, CancellationToken cancellationToken, string persistenceId, long maxSequenceNr, DateTime maxTimestamp)
Parameters
Type Name Description
DbConnection connection

TBD
CancellationToken cancellationToken

TBD
String persistenceId

TBD
Int64 maxSequenceNr

TBD
DateTime maxTimestamp

TBD
Returns
Type Description
Task<SelectedSnapshot>

TBD

Extension Methods