< Back
 

# Packages

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

  Definition Classes
    kafka
-  package model
  Definition Classes
    manager
- ActorModel
- ClusterConfig
- ClusterContext
- ClusterTuning
- CuratorConfig
- KafkaVersion
- Kafka_0_10_0_0
- Kafka_0_10_0_1
- Kafka_0_10_1_0
- Kafka_0_10_1_1
- Kafka_0_10_2_0
- Kafka_0_10_2_1
- Kafka_0_11_0_0
- Kafka_0_11_0_2
- Kafka_0_8_1_1
- Kafka_0_8_2_0
- Kafka_0_8_2_1
- Kafka_0_8_2_2
- Kafka_0_9_0_0
- Kafka_0_9_0_1
- Kafka_1_0_0
- Kafka_1_0_1
- Kafka_1_1_0
- Kafka_1_1_1
- Kafka_2_0_0
- Kafka_2_1_0
- Kafka_2_1_1
- Kafka_2_2_0
- PLAINTEXT
- PLAINTEXTSASL
- SASL_MECHANISM_GSSAPI
- SASL_MECHANISM_PLAIN
- SASL_MECHANISM_SCRAM256
- SASL_MECHANISM_SCRAM512
- SASL_PLAINTEXT
- SASL_SSL
- SASLmechanism
- SSL
- SecurityProtocol

o

kafka.manager.model

# ActorModel 

###

#### object ActorModel

Linear Supertypes
AnyRef, Any
 
Ordering

1. Alphabetic
2. By Inheritance

Inherited

1. ActorModel
2. AnyRef
3. Any

1. Hide All
2. Show All

Visibility

1. Public
2. All

### 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], replicationFactor: Option[Int] = None) 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, List[MemberMetadata])]) 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

### 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.  final def asInstanceOf[T0]: T0
   Definition Classes
     Any
5.  def clone(): AnyRef
   Attributes
     protected[java.lang]
   Definition Classes
     AnyRef
   Annotations
     @native() @throws( ... )
6.  final def eq(arg0: AnyRef): Boolean
   Definition Classes
     AnyRef
7.  def equals(arg0: Any): Boolean
   Definition Classes
     AnyRef → Any
8.  def finalize(): Unit
   Attributes
     protected[java.lang]
   Definition Classes
     AnyRef
   Annotations
     @throws( classOf[java.lang.Throwable] )
9.  final def getClass(): Class[_]
   Definition Classes
     AnyRef → Any
   Annotations
     @native()
10.  def hashCode(): Int
    Definition Classes
      AnyRef → Any
    Annotations
      @native()
11.  final def isInstanceOf[T0]: Boolean
    Definition Classes
      Any
12.  final def ne(arg0: AnyRef): Boolean
    Definition Classes
      AnyRef
13.  final def notify(): Unit
    Definition Classes
      AnyRef
    Annotations
      @native()
14.  final def notifyAll(): Unit
    Definition Classes
      AnyRef
    Annotations
      @native()
15.  final def synchronized[T0](arg0: ⇒ T0): T0
    Definition Classes
      AnyRef
16.  def toString(): String
    Definition Classes
      AnyRef → Any
17.  final def wait(): Unit
    Definition Classes
      AnyRef
    Annotations
      @throws( ... )
18.  final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
      AnyRef
    Annotations
      @throws( ... )
19.  final def wait(arg0: Long): Unit
    Definition Classes
      AnyRef
    Annotations
      @native() @throws( ... )
20.  object BVForceUpdate extends CommandRequest with Product with Serializable
21.  object BVGetBrokerMetrics extends BVRequest with Product with Serializable
22.  object BVGetConsumerIdentities extends BVRequest with Product with Serializable
23.  object BVGetTopicConsumerMap extends BVRequest with Product with Serializable
24.  object BVGetTopicIdentities extends BVRequest with Product with Serializable
25.  object BVGetViews extends BVRequest with Product with Serializable
26.  object BrokerIdentity extends Logging with Serializable
27.  object BrokerMetrics extends Serializable
28.  object CMGetClusterContext extends QueryRequest with Product with Serializable
29.  object CMGetView extends QueryRequest with Product with Serializable
30.  object CMShutdown extends CommandRequest with Product with Serializable
31.  object ConsumedTopicState extends Serializable
32.  object ConsumerIdentity extends Logging with Serializable
33.  object ConsumerType
34.  object DCUpdateState extends CommandRequest with Product with Serializable
35.  object KMGetActiveClusters extends QueryRequest with Product with Serializable
36.  object KMGetAllClusters extends QueryRequest with Product with Serializable
37.  object KMPruneClusters extends CommandRequest with Product with Serializable
38.  object KMShutdown extends CommandRequest with Product with Serializable
39.  object KMShutdownComplete extends CommandResponse with Product with Serializable
40.  object KMUpdateState extends CommandRequest with Product with Serializable
41.  object KSGetBrokers extends KSRequest with Product with Serializable
42.  object KSGetConsumers extends KSRequest with Product with Serializable
43.  object KSGetPreferredLeaderElection extends KSRequest with Product with Serializable
44.  object KSGetReassignPartition extends KSRequest with Product with Serializable
45.  object KSGetTopics extends KSRequest with Product with Serializable
46.  object KSGetTopicsLastUpdateMillis extends KSRequest with Product with Serializable
47.  object KafkaManagedConsumer extends ConsumerType with Product with Serializable
48.  object LKSGetLogkafkaLogkafkaIds extends LKSRequest with Product with Serializable
49.  object LKVForceUpdate extends CommandRequest with Product with Serializable
50.  object LKVGetLogkafkaIdentities extends LKVRequest with Product with Serializable
51.  object LogkafkaIdentity extends Logging with Serializable
52.  object PartitionOffsetsCapture extends Serializable
53.  object TopicIdentity extends Logging with Serializable
54.  object TopicPartitionIdentity extends Logging with Serializable
55.  object ZKManagedConsumer extends ConsumerType with Product with Serializable

### Inherited from AnyRef

### Inherited from Any

### Ungrouped