ActorModel

Type Members

1. case class ActorErrorResponse(msg: String, throwableOption: Option[Throwable] = None) extends ActorResponse with Product with Serializable

   

2. trait ActorRequest extends AnyRef

   

3. trait ActorResponse extends AnyRef

   

4. case class BVGetBrokerTopicPartitionSizes(topic: String) extends BVRequest with Product with Serializable

   

5. case class BVGetTopicMetrics(topic: String) extends BVRequest with Product with Serializable

   

6. case class BVGetView(id: Int) extends BVRequest with Product with Serializable

   

7. sealed trait BVRequest extends QueryRequest

   

8. case class BVUpdateBrokerMetrics(id: Int, metric: BrokerMetrics) extends CommandRequest with Product with Serializable

   

9. case class BVUpdateBrokerTopicPartitionSizes(id: Int, logInfo: Map[String, Map[Int, LogInfo]]) extends CommandRequest with Product with Serializable

   

10. case class BVUpdateTopicMetricsForBroker(id: Int, metrics: IndexedSeq[(String, BrokerMetrics)]) extends CommandRequest with Product with Serializable

    

11. case class BVView(topicPartitions: Map[TopicIdentity, BrokerTopicInfo], clusterContext: ClusterContext, metrics: Option[BrokerMetrics] = None, messagesPerSecCountHistory: Option[Queue[BrokerMessagesPerSecCount]] = None, stats: Option[BrokerClusterStats] = None) extends QueryResponse with Product with Serializable

    

12. case class BrokerClusterStats(perMessages: BigDecimal, perIncoming: BigDecimal, perOutgoing: BigDecimal) extends Product with Serializable

    

13. case class BrokerIdentity(id: Int, host: String, jmxPort: Int, secure: Boolean, nonSecure: Boolean, endpoints: Map[SecurityProtocol, Int]) extends Product with Serializable

    

14. case class BrokerList(list: IndexedSeq[BrokerIdentity], clusterContext: ClusterContext) extends QueryResponse with Product with Serializable

    

15. case class BrokerMessagesPerSecCount(date: DateTime, count: Long) extends Product with Serializable

    

16. case class BrokerMetrics(bytesInPerSec: MeterMetric, bytesOutPerSec: MeterMetric, bytesRejectedPerSec: MeterMetric, failedFetchRequestsPerSec: MeterMetric, failedProduceRequestsPerSec: MeterMetric, messagesInPerSec: MeterMetric, oSystemMetrics: OSMetric, size: SegmentsMetric) extends Product with Serializable

    

17. case class BrokerTopicInfo(partitions: IndexedSeq[Int], partitionsAsLeader: IndexedSeq[Int]) extends Product with Serializable

    

18. case class BrokerTopicPartitions(id: Int, partitions: IndexedSeq[Int], isSkewed: Boolean, leaders: IndexedSeq[Int], isLeaderSkewed: Boolean) extends Product with Serializable

    

19. case class CMAddMultipleTopicsPartitions(topicsAndReplicas: Seq[(String, Map[Int, Seq[Int]])], brokers: Set[Int], partitions: Int, readVersions: Map[String, Int]) extends CommandRequest with Product with Serializable

    

20. case class CMAddTopicPartitions(topic: String, brokers: Seq[Int], partitions: Int, partitionReplicaList: Map[Int, Seq[Int]], readVersion: Int) extends CommandRequest with Product with Serializable

    

21. case class CMCommandResult(result: Try[ClusterContext]) extends CommandResponse with Product with Serializable

    

22. case class CMCommandResults(result: IndexedSeq[Try[Unit]]) extends CommandResponse with Product with Serializable

    

23. case class CMConsumedTopic(ctIdentity: Try[ConsumedTopicState]) extends QueryResponse with Product with Serializable

    

24. case class CMConsumerIdentity(consumerIdentity: Try[ConsumerIdentity]) extends QueryResponse with Product with Serializable

    

25. case class CMCreateLogkafka(logkafka_id: String, log_path: String, config: Properties = new Properties) extends CommandRequest with Product with Serializable

    

26. case class CMCreateTopic(topic: String, partitions: Int, replicationFactor: Int, config: Properties = new Properties) extends CommandRequest with Product with Serializable

    

27. case class CMDeleteLogkafka(logkafka_id: String, log_path: String) extends CommandRequest with Product with Serializable

    

28. case class CMDeleteTopic(topic: String) extends CommandRequest with Product with Serializable

    

29. case class CMGeneratePartitionAssignments(topics: Set[String], brokers: Set[Int]) extends CommandRequest with Product with Serializable

    

30. case class CMGetConsumedTopicState(consumer: String, topic: String, consumerType: ConsumerType) extends QueryRequest with Product with Serializable

    

31. case class CMGetConsumerIdentity(consumer: String, consumerType: ConsumerType) extends QueryRequest with Product with Serializable

    

32. case class CMGetGeneratedPartitionAssignments(topic: String) extends QueryRequest with Product with Serializable

    

33. case class CMGetLogkafkaIdentity(logkafka_id: String) extends QueryRequest with Product with Serializable

    

34. case class CMGetTopicIdentity(topic: String) extends QueryRequest with Product with Serializable

    

35. case class CMLogkafkaIdentity(logkafkaIdentity: Try[LogkafkaIdentity]) extends QueryResponse with Product with Serializable

    

36. case class CMManualPartitionAssignments(assignments: List[(String, List[(Int, List[Int])])]) extends CommandRequest with Product with Serializable

    

37. case class CMRunPreferredLeaderElection(topics: Set[String]) extends CommandRequest with Product with Serializable

    

38. case class CMRunReassignPartition(topics: Set[String], forceSet: Set[ForceReassignmentCommand]) extends CommandRequest with Product with Serializable

    

39. case class CMTopicIdentity(topicIdentity: Try[TopicIdentity]) extends QueryResponse with Product with Serializable

    

40. case class CMUpdateLogkafkaConfig(logkafka_id: String, log_path: String, config: Properties, checkConfig: Boolean = true) extends CommandRequest with Product with Serializable

    

41. case class CMUpdateTopicConfig(topic: String, config: Properties, readVersion: Int) extends CommandRequest with Product with Serializable

    

42. case class CMView(topicsCount: Int, brokersCount: Int, clusterContext: ClusterContext) extends QueryResponse with Product with Serializable

    

43. trait CommandRequest extends ActorRequest

    

44. trait CommandResponse extends ActorResponse

    

45. case class ConsumedTopicDescription(consumer: String, topic: String, numPartitions: Int, topicDescription: Option[TopicDescription], partitionOwners: Option[Map[Int, String]], partitionOffsets: Option[Map[Int, Long]]) extends Product with Serializable

    

46. case class ConsumedTopicState(consumerGroup: String, topic: String, numPartitions: Int, partitionLatestOffsets: Map[Int, Long], partitionOwners: Map[Int, String], partitionOffsets: Map[Int, Long], clusterContext: ClusterContext) extends Product with Serializable

    

47. case class ConsumerDescription(consumer: String, topics: Map[String, ConsumedTopicDescription], consumerType: ConsumerType) extends QueryResponse with Product with Serializable

    

48. case class ConsumerDescriptions(descriptions: IndexedSeq[ConsumerDescription], lastUpdateMillis: Long) extends QueryResponse with Product with Serializable

    

49. case class ConsumerIdentity(consumerGroup: String, consumerType: ConsumerType, topicMap: Map[String, ConsumedTopicState], clusterContext: ClusterContext) extends Product with Serializable

    

50. case class ConsumerList(list: IndexedSeq[ConsumerNameAndType], clusterContext: ClusterContext) extends QueryResponse with Product with Serializable

    

51. case class ConsumerNameAndType(name: String, consumerType: ConsumerType) extends Product with Serializable

    

52. sealed trait ConsumerType extends AnyRef

    

53. case class GeneratedPartitionAssignments(topic: String, assignments: Map[Int, Seq[Int]], nonExistentBrokers: Set[Int]) extends Product with Serializable

    

54. case class KAGetGroupSummary(groupList: Seq[String], enqueue: Queue[(String, GroupMetadata)]) extends QueryRequest with Product with Serializable

    

55. sealed trait KARequest extends QueryRequest

    

56. case class KCAddMultipleTopicsPartitions(topicsAndReplicas: Seq[(String, Map[Int, Seq[Int]])], brokers: Set[Int], partitions: Int, readVersions: Map[String, Int]) extends CommandRequest with Product with Serializable

    

57. case class KCAddTopicPartitions(topic: String, brokers: Set[Int], partitions: Int, partitionReplicaList: Map[Int, Seq[Int]], readVersion: Int) extends CommandRequest with Product with Serializable

    

58. case class KCCommandResult(result: Try[Unit]) extends CommandResponse with Product with Serializable

    

59. case class KCCreateTopic(topic: String, brokers: Set[Int], partitions: Int, replicationFactor: Int, config: Properties) extends CommandRequest with Product with Serializable

    

60. case class KCDeleteTopic(topic: String) extends CommandRequest with Product with Serializable

    

61. case class KCPreferredReplicaLeaderElection(topicAndPartition: Set[TopicAndPartition]) extends CommandRequest with Product with Serializable

    

62. case class KCReassignPartition(currentTopicIdentity: Map[String, TopicIdentity], generatedTopicIdentity: Map[String, TopicIdentity], forceSet: Set[ForceReassignmentCommand]) extends CommandRequest with Product with Serializable

    

63. case class KCUpdateTopicConfig(topic: String, config: Properties, readVersion: Int) extends CommandRequest with Product with Serializable

    

64. case class KMAddCluster(config: ClusterConfig) extends CommandRequest with Product with Serializable

    

65. case class KMClusterCommandRequest(clusterName: String, request: CommandRequest) extends CommandRequest with Product with Serializable

    

66. case class KMClusterConfigResult(result: Try[ClusterConfig]) extends QueryResponse with Product with Serializable

    

67. case class KMClusterList(active: IndexedSeq[ClusterConfig], pending: IndexedSeq[ClusterConfig]) extends QueryResponse with Product with Serializable

    

68. case class KMClusterQueryRequest(clusterName: String, request: QueryRequest) extends QueryRequest with Product with Serializable

    

69. case class KMCommandResult(result: Try[Unit]) extends CommandResponse with Product with Serializable

    

70. case class KMDeleteCluster(clusterName: String) extends CommandRequest with Product with Serializable

    

71. case class KMDisableCluster(clusterName: String) extends CommandRequest with Product with Serializable

    

72. case class KMEnableCluster(clusterName: String) extends CommandRequest with Product with Serializable

    

73. case class KMGetClusterConfig(clusterName: String) extends QueryRequest with Product with Serializable

    

74. case class KMQueryResult(result: IndexedSeq[ClusterConfig]) extends QueryResponse with Product with Serializable

    

75. case class KMUpdateCluster(config: ClusterConfig) extends CommandRequest with Product with Serializable

    

76. case class KSEndPreferredLeaderElection(millis: Long) extends CommandRequest with Product with Serializable

    

77. case class KSEndReassignPartition(millis: Long) extends CommandRequest with Product with Serializable

    

78. case class KSGetAllConsumerDescriptions(lastUpdateMillis: Option[Long] = None) extends KSRequest with Product with Serializable

    

79. case class KSGetAllTopicDescriptions(lastUpdateMillis: Option[Long] = None) extends KSRequest with Product with Serializable

    

80. case class KSGetBrokerState(id: String) extends KSRequest with Product with Serializable

    

81. case class KSGetConsumedTopicDescription(consumer: String, topic: String, consumerType: ConsumerType) extends KSRequest with Product with Serializable

    

82. case class KSGetConsumerDescription(consumer: String, consumerType: ConsumerType) extends KSRequest with Product with Serializable

    

83. case class KSGetConsumerDescriptions(consumers: Set[String]) extends KSRequest with Product with Serializable

    

84. case class KSGetTopicConfig(topic: String) extends KSRequest with Product with Serializable

    

85. case class KSGetTopicDescription(topic: String) extends KSRequest with Product with Serializable

    

86. case class KSGetTopicDescriptions(topics: Set[String]) extends KSRequest with Product with Serializable

    

87. sealed trait KSRequest extends QueryRequest

    

88. case class KSUpdatePreferredLeaderElection(millis: Long, json: String) extends CommandRequest with Product with Serializable

    

89. case class KSUpdateReassignPartition(millis: Long, json: String) extends CommandRequest with Product with Serializable

    

90. case class LKCCommandResult(result: Try[Unit]) extends CommandResponse with Product with Serializable

    

91. case class LKCCreateLogkafka(logkafka_id: String, log_path: String, config: Properties, logkafkaConfig: Option[LogkafkaConfig]) extends CommandRequest with Product with Serializable

    

92. case class LKCDeleteLogkafka(logkafka_id: String, log_path: String, logkafkaConfig: Option[LogkafkaConfig]) extends CommandRequest with Product with Serializable

    

93. case class LKCUpdateLogkafkaConfig(logkafka_id: String, log_path: String, config: Properties, logkafkaConfig: Option[LogkafkaConfig], checkConfig: Boolean = true) extends CommandRequest with Product with Serializable

    

94. case class LKSGetAllLogkafkaClients(lastUpdateMillis: Option[Long] = None) extends LKSRequest with Product with Serializable

    

95. case class LKSGetAllLogkafkaConfigs(lastUpdateMillis: Option[Long] = None) extends LKSRequest with Product with Serializable

    

96. case class LKSGetLogkafkaClient(logkafka_id: String) extends LKSRequest with Product with Serializable

    

97. case class LKSGetLogkafkaClients(logkafka_ids: Set[String]) extends LKSRequest with Product with Serializable

    

98. case class LKSGetLogkafkaConfig(logkafka_id: String) extends LKSRequest with Product with Serializable

    

99. case class LKSGetLogkafkaConfigs(logkafka_ids: Set[String]) extends LKSRequest with Product with Serializable

    

100. sealed trait LKSRequest extends QueryRequest

     

101. sealed trait LKVRequest extends QueryRequest

     

102. case class LogkafkaClient(logkafka_id: String, client: Option[String]) extends QueryResponse with Product with Serializable

     

103. case class LogkafkaClients(clients: IndexedSeq[LogkafkaClient], lastUpdateMillis: Long) extends QueryResponse with Product with Serializable

     

104. case class LogkafkaConfig(logkafka_id: String, config: Option[String]) extends QueryResponse with Product with Serializable

     

105. case class LogkafkaConfigs(configs: IndexedSeq[LogkafkaConfig], lastUpdateMillis: Long) extends QueryResponse with Product with Serializable

     

106. case class LogkafkaIdentity(logkafka_id: String, active: Boolean, identityMap: Map[String, (Option[Map[String, String]], Option[Map[String, String]])]) extends Product with Serializable

     

107. case class LogkafkaLogkafkaIdList(list: IndexedSeq[String], deleteSet: Set[String]) extends QueryResponse with Product with Serializable

     

108. case class PartitionOffsetsCapture(updateTimeMillis: Long, offsetsMap: Map[Int, Long]) extends Product with Serializable

     

109. case class PreferredReplicaElection(startTime: DateTime, topicAndPartition: Set[TopicAndPartition], endTime: Option[DateTime], clusterContext: ClusterContext) extends QueryResponse with Product with Serializable

     

110. trait QueryRequest extends ActorRequest

     

111. trait QueryResponse extends ActorResponse

     

112. case class ReassignPartitions(startTime: DateTime, partitionsToBeReassigned: Map[TopicAndPartition, Seq[Int]], endTime: Option[DateTime], clusterContext: ClusterContext) extends QueryResponse with Product with Serializable

     

113. case class TopicConfig(topic: String, config: Option[(Int, String)]) extends QueryResponse with Product with Serializable

     

114. case class TopicDescription(topic: String, description: (Int, String), partitionState: Option[Map[String, String]], partitionOffsets: PartitionOffsetsCapture, config: Option[(Int, String)]) extends QueryResponse with Product with Serializable

     

115. case class TopicDescriptions(descriptions: IndexedSeq[TopicDescription], lastUpdateMillis: Long) extends QueryResponse with Product with Serializable

     

116. case class TopicIdentity(topic: String, readVersion: Int, partitions: Int, partitionsIdentity: Map[Int, TopicPartitionIdentity], numBrokers: Int, configReadVersion: Int, config: List[(String, String)], clusterContext: ClusterContext, metrics: Option[BrokerMetrics] = None, size: Option[String] = None) extends Product with Serializable

     

117. case class TopicList(list: IndexedSeq[String], deleteSet: Set[String], clusterContext: ClusterContext) extends QueryResponse with Product with Serializable

     

118. case class TopicPartitionIdentity(partNum: Int, leader: Int, latestOffset: Option[Long], rateOfChange: Option[Double], isr: Seq[Int], replicas: Seq[Int], isPreferredLeader: Boolean = false, isUnderReplicated: Boolean = false, leaderSize: Option[Long] = None, size: Option[String] = None) extends Product with Serializable