| AbstractQueryExecutorSelectByTagAsync Method |
TBD
Namespace:
Akka.Persistence.Sql.Common.Journal
Assembly:
Akka.Persistence.Sql.Common (in Akka.Persistence.Sql.Common.dll) Version: 1.0.0.0 (1.0.0.0)
Syntax public virtual Task<long> SelectByTagAsync(
DbConnection connection,
CancellationToken cancellationToken,
string tag,
long fromOffset,
long toOffset,
long max,
Action<ReplayedTaggedMessage> callback
)
abstract SelectByTagAsync :
connection : DbConnection *
cancellationToken : CancellationToken *
tag : string *
fromOffset : int64 *
toOffset : int64 *
max : int64 *
callback : Action<ReplayedTaggedMessage> -> Task<int64>
override SelectByTagAsync :
connection : DbConnection *
cancellationToken : CancellationToken *
tag : string *
fromOffset : int64 *
toOffset : int64 *
max : int64 *
callback : Action<ReplayedTaggedMessage> -> Task<int64>
Parameters
- connection
- Type: System.Data.CommonDbConnection
TBD - cancellationToken
- Type: System.ThreadingCancellationToken
TBD - tag
- Type: SystemString
TBD - fromOffset
- Type: SystemInt64
TBD - toOffset
- Type: SystemInt64
TBD - max
- Type: SystemInt64
TBD - callback
- Type: SystemActionReplayedTaggedMessage
TBD
Return Value
Type:
TaskInt64TBD
Implements
IJournalQueryExecutorSelectByTagAsync(DbConnection, CancellationToken, String, Int64, Int64, Int64, ActionReplayedTaggedMessage)See Also