Type Members

1.  trait Command extends AnyRef
2.  final case class CurrentFilter(streamId: String, criteria: Seq[FilterCriteria]) extends Product with Serializable
3.  final case class EntityIdOffset(entityId: String, seqNr: Long) extends Product with Serializable
4.  final case class ExcludeEntityIds(entityIds: Set[String]) extends FilterCriteria with Product with Serializable

   Exclude events for entities with the given entity ids, unless there is a matching include filter that overrides the exclude.

5.  final case class ExcludeRegexEntityIds(matching: Set[String]) extends FilterCriteria with Product with Serializable

   Exclude events for entities with entity ids matching the given regular expressions, unless there is a matching include filter that overrides the exclude.

6.  final case class ExcludeTags(tags: Set[String]) extends FilterCriteria with Product with Serializable

   Exclude events with any of the given tags, unless there is a matching include filter that overrides the exclude.

7.  sealed trait FilterCriteria extends AnyRef
8.  final case class GetFilter(streamId: String, replyTo: ActorRef[CurrentFilter]) extends Command with Product with Serializable
9.  final case class IncludeEntityIds(entityOffsets: Set[EntityIdOffset]) extends FilterCriteria with Product with Serializable

   Include events for entities with the given entity ids.

   Include events for entities with the given entity ids. A matching include overrides a matching exclude.

   For the given entity ids a seqNr can be defined to replay all events for the entity from the sequence number (inclusive). If seqNr is 0 events will not be replayed.

10.  final case class IncludeRegexEntityIds(matching: Set[String]) extends FilterCriteria with Product with Serializable

    Include events for entities with entity ids matching the given regular expressions.

    Include events for entities with entity ids matching the given regular expressions. A matching include overrides a matching exclude.

11.  final case class IncludeTags(tags: Set[String]) extends FilterCriteria with Product with Serializable

    Include events with any of the given tags.

    Include events with any of the given tags. A matching include overrides a matching exclude.

12.  final case class IncludeTopics(expressions: Set[String]) extends FilterCriteria with Product with Serializable

    Include events with any of the given matching topics.

    Include events with any of the given matching topics. A matching include overrides a matching exclude.

    Topic match expression according to MQTT specification, including wildcards. The topic of an event is defined by a tag with certain prefix, see topic-tag-prefix configuration.

13.  final case class PersistenceIdOffset(persistenceIdId: String, seqNr: Long) extends Product with Serializable
14.  sealed trait RemoveCriteria extends FilterCriteria
15.  final case class RemoveExcludeEntityIds(entityIds: Set[String]) extends RemoveCriteria with Product with Serializable

    Remove a previously added ExcludeEntityIds.

16.  final case class RemoveExcludeRegexEntityIds(matching: Set[String]) extends RemoveCriteria with Product with Serializable

    Remove a previously added ExcludeRegexEntityIds.

17.  final case class RemoveExcludeTags(tags: Set[String]) extends RemoveCriteria with Product with Serializable

    Remove a previously added ExcludeTags.

18.  final case class RemoveIncludeEntityIds(entityIds: Set[String]) extends RemoveCriteria with Product with Serializable

    Remove a previously added IncludeEntityIds.

19.  final case class RemoveIncludeRegexEntityIds(matching: Set[String]) extends RemoveCriteria with Product with Serializable

    Remove a previously added IncludeRegexEntityIds.

20.  final case class RemoveIncludeTags(tags: Set[String]) extends FilterCriteria with Product with Serializable

    Remove a previously added IncludeTags.

21.  final case class RemoveIncludeTopics(expressions: Set[String]) extends FilterCriteria with Product with Serializable

    Remove a previously added IncludeTopics.

22.  final class Replay extends Product2[String, Set[PersistenceIdOffset]] with SubscriberCommand with Serializable

    Explicit request to replay events for given entities.

    Explicit request to replay events for given entities.

    Use the replayCorrelationId from the GrpcReadJournal.

23.  final case class ReplayPersistenceId(persistenceIdOffset: PersistenceIdOffset, filterAfterSeqNr: Long) extends Product with Serializable
24.  final class ReplayWithFilter extends Product2[String, Set[ReplayPersistenceId]] with SubscriberCommand with Serializable

    Explicit request to replay events for given entities.

    Explicit request to replay events for given entities.

    Use the replayCorrelationId from the GrpcReadJournal.

25.  sealed trait SubscriberCommand extends Command
26.  final case class UpdateFilter(streamId: String, criteria: Seq[FilterCriteria]) extends SubscriberCommand with Product with Serializable

    Add or remove filter criteria.

    Add or remove filter criteria.

    Exclude criteria are evaluated first. If no matching exclude criteria the event is emitted. If an exclude criteria is matching the include criteria are evaluated. If no matching include criteria the event is discarded. If matching include criteria the event is emitted.