Click or drag to resize
Akka.NETSqlReadJournalAllPersistenceIds Method

AllPersistenceIds is used for retrieving all `persistenceIds` of all persistent actors.

The returned event stream is unordered and you can expect different order for multiple executions of the query.

The stream is not completed when it reaches the end of the currently used `persistenceIds`, but it continues to push new `persistenceIds` when new persistent actors are created. Corresponding query that is completed when it reaches the end of the currently currently used `persistenceIds` is provided by CurrentPersistenceIds.

The SQL write journal is notifying the query side as soon as new `persistenceIds` are created and there is no periodic polling or batching involved in this query.

The stream is completed with failure if there is a failure in executing the query in the backend journal.

Namespace:  Akka.Persistence.Query.Sql
Assembly:  Akka.Persistence.Query.Sql (in Akka.Persistence.Query.Sql.dll) Version: 1.0.0.0 (1.0.0.0)
Syntax
Copy
public Source<string, NotUsed> AllPersistenceIds()

Return Value

Type: SourceString, NotUsed

[Missing <returns> documentation for "M:Akka.Persistence.Query.Sql.SqlReadJournal.AllPersistenceIds"]

Implements

IAllPersistenceIdsQueryAllPersistenceIds
See Also