< Back
 

# Packages

-  package root
  Definition Classes
    root
-  package kafka
  Definition Classes
    root
-  package manager

  Definition Classes
    kafka
-  package actor
  Definition Classes
    manager
-  package cluster

  Created by hiral on 12/1/15.

  Created by hiral on 12/1/15.

  Definition Classes
    actor
- DeleteClusterActor
- DeleteClusterActorConfig
- KafkaManagerActor
- KafkaManagerActorConfig

c

kafka.manager.actor

# KafkaManagerActor 

###
Companion object KafkaManagerActor

#### class KafkaManagerActor extends BaseQueryCommandActor with CuratorAwareActor with BaseZkPath

Linear Supertypes
BaseZkPath, CuratorAwareActor, BaseQueryCommandActor, BaseActor, ActorLogging, Actor, AnyRef, Any
 
Ordering

1. Alphabetic
2. By Inheritance

Inherited

1. KafkaManagerActor
2. BaseZkPath
3. CuratorAwareActor
4. BaseQueryCommandActor
5. BaseActor
6. ActorLogging
7. Actor
8. AnyRef
9. Any

1. Hide All
2. Show All

Visibility

1. Public
2. All

### Instance Constructors

1.  new KafkaManagerActor(kafkaManagerConfig: KafkaManagerActorConfig)

### Type Members

1.  type Receive = PartialFunction[Any, Unit]
   Definition Classes
     Actor

### 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.  def aroundPostRestart(reason: Throwable): Unit
   Attributes
     protected[akka]
   Definition Classes
     Actor
   Annotations
     @InternalApi()
5.  def aroundPostStop(): Unit
   Attributes
     protected[akka]
   Definition Classes
     Actor
   Annotations
     @InternalApi()
6.  def aroundPreRestart(reason: Throwable, message: Option[Any]): Unit
   Attributes
     protected[akka]
   Definition Classes
     Actor
   Annotations
     @InternalApi()
7.  def aroundPreStart(): Unit
   Attributes
     protected[akka]
   Definition Classes
     Actor
   Annotations
     @InternalApi()
8.  def aroundReceive(receive: akka.actor.Actor.Receive, msg: Any): Unit
   Attributes
     protected[akka]
   Definition Classes
     Actor
   Annotations
     @InternalApi()
9.  final def asInstanceOf[T0]: T0
   Definition Classes
     Any
10.  def baseZkPath: String
    Definition Classes
      KafkaManagerActor → BaseZkPath
11.  def clone(): AnyRef
    Attributes
      protected[java.lang]
    Definition Classes
      AnyRef
    Annotations
      @native() @throws( ... )
12.  implicit val context: ActorContext
    Definition Classes
      Actor
13.  val curator: CuratorFramework
    Attributes
      protected[this]
    Definition Classes
      CuratorAwareActor
14.  def curatorConfig: CuratorConfig
    Definition Classes
      KafkaManagerActor → CuratorAwareActor
15.  final def eq(arg0: AnyRef): Boolean
    Definition Classes
      AnyRef
16.  def equals(arg0: Any): Boolean
    Definition Classes
      AnyRef → Any
17.  def finalize(): Unit
    Attributes
      protected[java.lang]
    Definition Classes
      AnyRef
    Annotations
      @throws( classOf[java.lang.Throwable] )
18.  final def getClass(): Class[_]
    Definition Classes
      AnyRef → Any
    Annotations
      @native()
19.  def getCurator(config: CuratorConfig): CuratorFramework
    Attributes
      protected
    Definition Classes
      CuratorAwareActor
20.  def hashCode(): Int
    Definition Classes
      AnyRef → Any
    Annotations
      @native()
21.  final def isInstanceOf[T0]: Boolean
    Definition Classes
      Any
22.  def log: LoggingAdapter
    Definition Classes
      ActorLogging
23.  final def ne(arg0: AnyRef): Boolean
    Definition Classes
      AnyRef
24.  final def notify(): Unit
    Definition Classes
      AnyRef
    Annotations
      @native()
25.  final def notifyAll(): Unit
    Definition Classes
      AnyRef
    Annotations
      @native()
26.  def postRestart(reason: Throwable): Unit
    Definition Classes
      Actor
    Annotations
      @throws( classOf[java.lang.Exception] )
27.  def postStop(): Unit
    Definition Classes
      KafkaManagerActor → CuratorAwareActor → BaseQueryCommandActor → BaseActor → Actor
    Annotations
      @throws( classOf[Exception] )
28.  def preRestart(reason: Throwable, message: Option[Any]): Unit
    Definition Classes
      KafkaManagerActor → BaseQueryCommandActor → BaseActor → Actor
    Annotations
      @throws( classOf[Exception] )
29.  def preStart(): Unit
    Definition Classes
      KafkaManagerActor → BaseQueryCommandActor → BaseActor → Actor
    Annotations
      @throws( classOf[Exception] )
30.  final def processActorRequest(request: ActorRequest): Unit
    Definition Classes
      BaseQueryCommandActor → BaseActor
31.  def processActorResponse(response: ActorResponse): Unit
    Definition Classes
      KafkaManagerActor → BaseActor
32.  def processCommandRequest(request: CommandRequest): Unit
    Definition Classes
      KafkaManagerActor → BaseQueryCommandActor
33.  def processQueryRequest(request: QueryRequest): Unit
    Definition Classes
      KafkaManagerActor → BaseQueryCommandActor
34.  final def receive: Receive
    Definition Classes
      BaseActor → Actor
35.  implicit final val self: ActorRef
    Definition Classes
      Actor
36.  final def sender(): ActorRef
    Definition Classes
      Actor
37.  var shutdown: Boolean
    Definition Classes
      BaseActor
38.  def supervisorStrategy: SupervisorStrategy
    Definition Classes
      Actor
39.  final def synchronized[T0](arg0: ⇒ T0): T0
    Definition Classes
      AnyRef
40.  def toString(): String
    Definition Classes
      AnyRef → Any
41.  def unhandled(message: Any): Unit
    Definition Classes
      Actor
42.  final def wait(): Unit
    Definition Classes
      AnyRef
    Annotations
      @throws( ... )
43.  final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
      AnyRef
    Annotations
      @throws( ... )
44.  final def wait(arg0: Long): Unit
    Definition Classes
      AnyRef
    Annotations
      @native() @throws( ... )
45.  def zkPath(path: String): String
    Attributes
      protected
    Definition Classes
      BaseZkPath
46.  def zkPathFrom(parent: String, child: String): String
    Attributes
      protected
    Definition Classes
      BaseZkPath

### Inherited from BaseZkPath

### Inherited from CuratorAwareActor

### Inherited from BaseQueryCommandActor

### Inherited from BaseActor

### Inherited from ActorLogging

### Inherited from Actor

### Inherited from AnyRef

### Inherited from Any

### Ungrouped