KafkaStateActor

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

5. def aroundPostStop(): Unit

   

   Attributes

   protected[akka]

   Definition Classes

   Actor

6. def aroundPreRestart(reason: Throwable, message: Option[Any]): Unit

   

   Attributes

   protected[akka]

   Definition Classes

   Actor

7. def aroundPreStart(): Unit

   

   Attributes

   protected[akka]

   Definition Classes

   Actor

8. def aroundReceive(receive: akka.actor.Actor.Receive, msg: Any): Unit

   

   Attributes

   protected[akka]

   Definition Classes

   Actor

9. final def asInstanceOf[T0]: T0

   

   Definition Classes

   Any

10. implicit val cf: ClusterFeatures

    

    Attributes

    protected

11. def clone(): AnyRef

    

    Attributes

    protected[java.lang]

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

12. implicit lazy val clusterConfig: ClusterConfig

    

    Attributes

    protected

    Definition Classes

    BaseClusterActor

13. implicit val clusterContext: ClusterContext

    

    Attributes

    protected

    Definition Classes

    KafkaStateActor → BaseClusterActor

14. implicit lazy val clusterFeatures: ClusterFeatures

    

    Attributes

    protected

    Definition Classes

    BaseClusterActor

15. implicit val context: ActorContext

    

    Definition Classes

    Actor

16. final def eq(arg0: AnyRef): Boolean

    

    Definition Classes

    AnyRef

17. def equals(arg0: Any): Boolean

    

    Definition Classes

    AnyRef → Any

18. def finalize(): Unit

    

    Attributes

    protected[java.lang]

    Definition Classes

    AnyRef

    Annotations

    @throws( classOf[java.lang.Throwable] )

19. final def getClass(): Class[_]

    

    Definition Classes

    AnyRef → Any

20. def getPartitionLeaders(topic: String): Option[List[(Int, Option[BrokerIdentity])]]

    

21. def getTopicDescription(topic: String, interactive: Boolean): Option[TopicDescription]

    

22. def getTopicPartitionOffsetsNotFuture(topic: String, interactive: Boolean): PartitionOffsetsCapture

    

23. def getTopicZookeeperData(topic: String): Option[(Int, String)]

    

24. def hasCapacityFor(taskCount: Int): Boolean

    

    Attributes

    protected

    Definition Classes

    LongRunningPoolActor

25. def hashCode(): Int

    

    Definition Classes

    AnyRef → Any

26. final def isInstanceOf[T0]: Boolean

    

    Definition Classes

    Any

27. def log: LoggingAdapter

    

    Definition Classes

    ActorLogging

28. def longRunning[T](fn: ⇒ Future[T])(implicit ec: ExecutionContext, ct: ClassTag[T]): Unit

    

    Attributes

    protected

    Definition Classes

    LongRunningPoolActor

29. val longRunningExecutionContext: ExecutionContextExecutor

    

    Attributes

    protected

    Definition Classes

    LongRunningPoolActor

30. val longRunningExecutor: ThreadPoolExecutor

    

    Attributes

    protected

    Definition Classes

    LongRunningPoolActor

31. def longRunningPoolConfig: LongRunningPoolConfig

    

    Attributes

    protected

    Definition Classes

    KafkaStateActor → LongRunningPoolActor

32. def longRunningQueueFull(): Unit

    

    Attributes

    protected

    Definition Classes

    KafkaStateActor → LongRunningPoolActor

33. final def ne(arg0: AnyRef): Boolean

    

    Definition Classes

    AnyRef

34. final def notify(): Unit

    

    Definition Classes

    AnyRef

35. final def notifyAll(): Unit

    

    Definition Classes

    AnyRef

36. def postRestart(reason: Throwable): Unit

    

    Definition Classes

    Actor

    Annotations

    @throws( classOf[java.lang.Exception] )

37. def postStop(): Unit

    

    Definition Classes

    KafkaStateActor → LongRunningPoolActor → BaseQueryCommandActor → BaseActor → Actor

    Annotations

    @throws( classOf[Exception] )

38. def preRestart(reason: Throwable, message: Option[Any]): Unit

    

    Definition Classes

    KafkaStateActor → BaseQueryCommandActor → BaseActor → Actor

    Annotations

    @throws( classOf[Exception] )

39. def preStart(): Unit

    

    Definition Classes

    KafkaStateActor → BaseQueryCommandActor → BaseActor → Actor

    Annotations

    @throws( classOf[Exception] )

40. final def processActorRequest(request: ActorRequest): Unit

    

    Definition Classes

    BaseQueryCommandActor → BaseActor

41. def processActorResponse(response: ActorResponse): Unit

    

    Definition Classes

    KafkaStateActor → BaseActor

42. def processCommandRequest(request: CommandRequest): Unit

    

    Definition Classes

    KafkaStateActor → BaseQueryCommandActor

43. def processQueryRequest(request: QueryRequest): Unit

    

    Definition Classes

    KafkaStateActor → BaseQueryCommandActor

44. final def receive: Receive

    

    Definition Classes

    BaseActor → Actor

45. implicit final val self: ActorRef

    

    Definition Classes

    Actor

46. final def sender(): ActorRef

    

    Definition Classes

    Actor

47. var shutdown: Boolean

    

    Definition Classes

    BaseActor

48. def startTopicOffsetGetter(): Unit

    

49. def stopTopicOffsetGetter(): Unit

    

50. def supervisorStrategy: SupervisorStrategy

    

    Definition Classes

    Actor

51. final def synchronized[T0](arg0: ⇒ T0): T0

    

    Definition Classes

    AnyRef

52. def toString(): String

    

    Definition Classes

    AnyRef → Any

53. def unhandled(message: Any): Unit

    

    Definition Classes

    Actor

54. final def wait(): Unit

    

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

55. final def wait(arg0: Long, arg1: Int): Unit

    

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

56. final def wait(arg0: Long): Unit

    

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )