c

scredis.io

AbstractAkkaConnection

abstract class AbstractAkkaConnection extends Connection with LazyLogging

Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. AbstractAkkaConnection
  2. LazyLogging
  3. Connection
  4. AnyRef
  5. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Instance Constructors

  1. new AbstractAkkaConnection(system: ActorSystem, host: String, port: Int, authOpt: Option[AuthConfig], database: Int, nameOpt: Option[String], decodersCount: Int, receiveTimeoutOpt: Option[FiniteDuration], connectTimeout: FiniteDuration, maxWriteBatchSize: Int, tcpSendBufferSizeHint: Int, tcpReceiveBufferSizeHint: Int, akkaListenerDispatcherPath: String, akkaIODispatcherPath: String, akkaDecoderDispatcherPath: String)

Abstract Value Members

  1. abstract val listenerActor: ActorRef
    Attributes
    protected

Concrete Value Members

  1. final def !=(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  2. final def ##: Int
    Definition Classes
    AnyRef → Any
  3. final def ==(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  4. val akkaDecoderDispatcherPath: String
    Attributes
    protected
  5. val akkaIODispatcherPath: String
    Attributes
    protected
  6. val akkaListenerDispatcherPath: String
    Attributes
    protected
  7. final def asInstanceOf[T0]: T0
    Definition Classes
    Any
  8. var authOpt: Option[AuthConfig]
    Attributes
    protected
  9. def awaitTermination(timeout: Duration = Duration.Inf): Unit

    Waits for all the internal actors to be shutdown.

    Waits for all the internal actors to be shutdown.

    timeout

    amount of time to wait

    Note

    This method is usually called after issuing a QUIT command

  10. def clone(): AnyRef
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.CloneNotSupportedException]) @native()
  11. val connectTimeout: FiniteDuration
    Attributes
    protected
  12. var database: Int
    Attributes
    protected
  13. val decodersCount: Int
    Attributes
    protected
  14. implicit val dispatcher: ExecutionContext
    Definition Classes
    AbstractAkkaConnection → Connection
  15. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  16. def equals(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef → Any
  17. def finalize(): Unit
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.Throwable])
  18. def getAuthOpt: Option[AuthConfig]
    Attributes
    protected
  19. final def getClass(): Class[_ <: AnyRef]
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  20. def getDatabase: Int
    Attributes
    protected
  21. def getNameOpt: Option[String]
    Attributes
    protected
  22. def hashCode(): Int
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  23. val host: String
  24. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  25. var isShuttingDown: Boolean
    Attributes
    protected
  26. def isTerminated: Boolean
  27. lazy val logger: Logger
    Attributes
    protected
    Definition Classes
    LazyLogging
    Annotations
    @transient()
  28. val maxWriteBatchSize: Int
    Attributes
    protected
  29. var nameOpt: Option[String]
    Attributes
    protected
  30. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  31. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  32. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  33. val port: Int
  34. val receiveTimeoutOpt: Option[FiniteDuration]
    Attributes
    protected
  35. final def synchronized[T0](arg0: => T0): T0
    Definition Classes
    AnyRef
  36. val system: ActorSystem
    Attributes
    protected
  37. val tcpReceiveBufferSizeHint: Int
    Attributes
    protected
  38. val tcpSendBufferSizeHint: Int
    Attributes
    protected
  39. def toString(): String
    Definition Classes
    AnyRef → Any
  40. def updateState(request: Request[_]): Unit
    Attributes
    protected
  41. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  42. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  43. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException]) @native()
  44. def watchTermination(): Unit
    Attributes
    protected

Inherited from LazyLogging

Inherited from Connection

Inherited from AnyRef

Inherited from Any

Ungrouped