Package

akka.persistence.multidc

internal

Permalink

package internal

Content Hierarchy
Visibility
  1. Public
  2. All

Type Members

  1. trait CassandraReplicatedStatements extends CassandraStatements

    Permalink
  2. class CommandHandlerImpl[Command, Event, State] extends CommandHandler[Command, Event, State] with CommandHandler[Command, Event, State]

    Permalink

    Command handlers and optional functions for other signals, e.g.

    Command handlers and optional functions for other signals, e.g. Termination messages if watch is used. CommandHandlerImpl is an immutable class.

    Annotations
    @DoNotInherit()
  3. sealed abstract class EffectImpl[+Event, State] extends Effect[Event, State] with Effect[Event, State]

    Permalink
    Annotations
    @DoNotInherit()
  4. class MultiDcConfig extends AnyRef

    Permalink
  5. final case class NotificationSettings(readInterval: FiniteDuration, writeInterval: FiniteDuration, writeAggregationSize: Int, maxBacktrackingBuckets: Int, publishDelay: FiniteDuration, additionalRandomPublishDelay: FiniteDuration, keyspace: Option[String], replicationStrategy: Option[String], table: String, compactionStrategy: CassandraCompactionStrategy, gcGraceSeconds: Long, ttl: Long, readConsistency: ConsistencyLevel, writeConsistency: ConsistencyLevel, readRetries: Int, writeRetries: Int, fetchSize: Int) extends Product with Serializable

    Permalink
  6. final class NotificationTimeBucket extends AnyRef

    Permalink
  7. sealed trait Persist[+Event, State] extends EffectImpl[Event, State]

    Permalink

    A command handler returns a Persist directive that defines what event or events to persist.

    A command handler returns a Persist directive that defines what event or events to persist. Use the thenPersist, thenPersistAll methods of the context that is passed to the command handler function to create the Persist directive.

    Additional side effects after successful persist can be performed in the callback andThen

    Annotations
    @DoNotInherit()

Value Members

  1. object NotificationReader

    Permalink
  2. object NotificationTimeBucket

    Permalink

Ungrouped