object AkkaCluster extends Serializable
- Alphabetic
- By Inheritance
- AkkaCluster
- Serializable
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Value Members
- final def !=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def ##: Int
- Definition Classes
- AnyRef → Any
- final def ==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def asInstanceOf[T0]: T0
- Definition Classes
- Any
- def clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @IntrinsicCandidate() @native()
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def equals(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef → Any
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @IntrinsicCandidate() @native()
- def hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @IntrinsicCandidate() @native()
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- def managedResource[F[_]](createActorSystem: => ActorSystem[_], catsEffectReleaseTimeout: Duration = 5.seconds, akkaReleaseTimeout: Duration = 5.seconds)(implicit arg0: Async[F], arg1: Logger[F]): Resource[F, AkkaCluster[F]]
Create a resource that manages the lifetime of an Akka actor system with cluster sharding extension.
Create a resource that manages the lifetime of an Akka actor system with cluster sharding extension. The actor system is created when the resource is acquired and shutdown when the resource is released.
- createActorSystem
Actor system creator. It is recommended to use the IO execution context (
IO.executionContext
) for the actor system, as it supports Akka operation and it's simpler to have a single application execution context- catsEffectReleaseTimeout
Maximum amount of time Akka coordinated shutdown is allowed to wait for cats-effect to finish, typically when Akka initiates shutdown following a SBR decision. This value should not be higher than the actual timeout for
before-service-unbind
phase of Akka coordinated shutdown. See Akka coordinated shutdown documentation to learn how to configure the timeouts of individual phases. Default (5 seconds) is the same as the default-phase-timeout of Akka coordinated shutdown.- akkaReleaseTimeout
Maximum amount of time to wait for the actor system to terminate during resource release (5 seconds by default).
- See also
Some elements borrowed from https://alexn.org/blog/2023/04/17/integrating-akka-with-cats-effect-3/
- final def ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- final def notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @IntrinsicCandidate() @native()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @IntrinsicCandidate() @native()
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- def toString(): String
- Definition Classes
- AnyRef → Any
- final def wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- final def wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException]) @native()
- final def wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
Deprecated Value Members
- def finalize(): Unit
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.Throwable]) @Deprecated
- Deprecated
(Since version 9)