Object/Class

akka.cluster.fastfailover

FastFailover

Related Docs: class FastFailover | package fastfailover

Permalink

object FastFailover extends ExtensionId[FastFailover] with ExtensionIdProvider

Linear Supertypes
Content Hierarchy
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. FastFailover
  2. ExtensionIdProvider
  3. ExtensionId
  4. AnyRef
  5. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Type Members

  1. final case class Attempt(entityId: String, attempt: Int, msg: Msg) extends Product with Serializable

    Permalink

    Sent to a fast failover routee to ask it to attempt the operation for the given message.

    Sent to a fast failover routee to ask it to attempt the operation for the given message.

    attempt

    The attempt number, this should be sent back with the Heartbeat and Result messages.

    msg

    The message.

  2. type EntityId = String

    Permalink

    The entity id.

  3. type ExtractEntityId = PartialFunction[Msg, (EntityId, Msg)]

    Permalink

    Interface of the partial function used by FastFailoverActor to extract an entity id and the message to send to the entity from an incoming message.

    Interface of the partial function used by FastFailoverActor to extract an entity id and the message to send to the entity from an incoming message. The implementation is application specific. If the partial function does not match the message will be unhandled, i.e. posted as Unhandled messages on the event stream. Note that the extracted message does not have to be the same as the incoming message to support wrapping in message envelope that is unwrapped before sending to the entity actor.

  4. trait FailureDirective extends AnyRef

    Permalink

    A failure directive.

  5. type FailureStrategy = PartialFunction[Throwable, FailureDirective]

    Permalink

    A strategy for deciding whether an error should cause the operation to fail or failover.

    A strategy for deciding whether an error should cause the operation to fail or failover.

    The default, for any errors that this function isn't defined for, is to failover.

  6. final case class Heartbeat(attempt: Int) extends DeadLetterSuppression with Product with Serializable

    Permalink

    A heartbeat.

    A heartbeat. These should be sent at the configured heartbeat interval back to the requester.

    attempt

    The attempt number that came in the first Attempt message.

  7. trait MessageExtractor extends AnyRef

    Permalink

    Java API: Interface of functions to extract entity id and the message to send to the entity from an incoming message.

  8. type Msg = Any

    Permalink

    The messages that a fast failover actor handles.

  9. final case class Result(attempt: Int, msg: Status) extends DeadLetterSuppression with Product with Serializable

    Permalink

    The result of an attempt.

    The result of an attempt.

    attempt

    The attempt number that came in the Attempt message.

    msg

    The result.

Value Members

  1. final def !=(arg0: Any): Boolean

    Permalink
    Definition Classes
    AnyRef → Any
  2. final def ##(): Int

    Permalink
    Definition Classes
    AnyRef → Any
  3. final def ==(arg0: Any): Boolean

    Permalink
    Definition Classes
    AnyRef → Any
  4. object Fail extends FailureDirective with Product with Serializable

    Permalink

    An error should cause the operation to fail.

  5. object Failover extends FailureDirective with Product with Serializable

    Permalink

    An error should cause the operation to failover.

  6. def apply(system: ActorSystem): FastFailover

    Permalink
    Definition Classes
    ExtensionId
  7. final def asInstanceOf[T0]: T0

    Permalink
    Definition Classes
    Any
  8. def clone(): AnyRef

    Permalink
    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  9. def createExtension(system: ExtendedActorSystem): FastFailover

    Permalink
    Definition Classes
    FastFailover → ExtensionId
  10. final def eq(arg0: AnyRef): Boolean

    Permalink
    Definition Classes
    AnyRef
  11. final def equals(other: Any): Boolean

    Permalink
    Definition Classes
    ExtensionId → AnyRef → Any
  12. def extractEntityId: ExtractEntityId

    Permalink

    Extract entity id function to use with cluster sharding.

    Extract entity id function to use with cluster sharding.

    Provided for convenience

  13. def extractShardId(numShards: Int): (Msg) ⇒ String

    Permalink

    Extract shard id function to use with cluster sharding.

    Extract shard id function to use with cluster sharding.

    Provided for convenience.

  14. def fail: Fail.type

    Permalink

    Java API: An error should cause the operation to fail.

  15. def failover: Failover.type

    Permalink

    Java API: An error should cause the operation to failover.

  16. def finalize(): Unit

    Permalink
    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( classOf[java.lang.Throwable] )
  17. def get(system: ActorSystem): FastFailover

    Permalink
    Definition Classes
    FastFailover → ExtensionId
  18. final def getClass(): Class[_]

    Permalink
    Definition Classes
    AnyRef → Any
  19. final def hashCode(): Int

    Permalink
    Definition Classes
    ExtensionId → AnyRef → Any
  20. final def isInstanceOf[T0]: Boolean

    Permalink
    Definition Classes
    Any
  21. def lookup(): FastFailover.type

    Permalink
    Definition Classes
    FastFailover → ExtensionIdProvider
  22. final def ne(arg0: AnyRef): Boolean

    Permalink
    Definition Classes
    AnyRef
  23. final def notify(): Unit

    Permalink
    Definition Classes
    AnyRef
  24. final def notifyAll(): Unit

    Permalink
    Definition Classes
    AnyRef
  25. final def synchronized[T0](arg0: ⇒ T0): T0

    Permalink
    Definition Classes
    AnyRef
  26. def toString(): String

    Permalink
    Definition Classes
    AnyRef → Any
  27. final def wait(): Unit

    Permalink
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  28. final def wait(arg0: Long, arg1: Int): Unit

    Permalink
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  29. final def wait(arg0: Long): Unit

    Permalink
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )

Inherited from ExtensionIdProvider

Inherited from ExtensionId[FastFailover]

Inherited from AnyRef

Inherited from Any

Ungrouped