model

Type Members

case class ClusterConfig(name: String, curatorConfig: CuratorConfig, enabled: Boolean, version: KafkaVersion, jmxEnabled: Boolean, jmxUser: Option[String], jmxPass: Option[String], jmxSsl: Boolean, pollConsumers: Boolean, filterConsumers: Boolean, logkafkaEnabled: Boolean, activeOffsetCacheEnabled: Boolean, displaySizeEnabled: Boolean, tuning: Option[ClusterTuning], securityProtocol: SecurityProtocol) extends Product with Serializable
case class ClusterContext(clusterFeatures: ClusterFeatures, config: ClusterConfig) extends Product with Serializable
case class ClusterTuning(brokerViewUpdatePeriodSeconds: Option[Int], clusterManagerThreadPoolSize: Option[Int], clusterManagerThreadPoolQueueSize: Option[Int], kafkaCommandThreadPoolSize: Option[Int], kafkaCommandThreadPoolQueueSize: Option[Int], logkafkaCommandThreadPoolSize: Option[Int], logkafkaCommandThreadPoolQueueSize: Option[Int], logkafkaUpdatePeriodSeconds: Option[Int], partitionOffsetCacheTimeoutSecs: Option[Int], brokerViewThreadPoolSize: Option[Int], brokerViewThreadPoolQueueSize: Option[Int], offsetCacheThreadPoolSize: Option[Int], offsetCacheThreadPoolQueueSize: Option[Int], kafkaAdminClientThreadPoolSize: Option[Int], kafkaAdminClientThreadPoolQueueSize: Option[Int]) extends Product with Serializable
case class CuratorConfig(zkConnect: String, zkMaxRetry: Int = 100, baseSleepTimeMs: Int = 100, maxSleepTimeMs: Int = 1000) extends Product with Serializable
sealed trait KafkaVersion extends AnyRef
sealed trait SecurityProtocol extends AnyRef

Value Members

object ActorModel
object ClusterConfig extends Serializable
object ClusterTuning extends Serializable
object KafkaVersion
object Kafka_0_10_0_0 extends KafkaVersion with Product with Serializable
object Kafka_0_10_0_1 extends KafkaVersion with Product with Serializable
object Kafka_0_10_1_0 extends KafkaVersion with Product with Serializable
object Kafka_0_10_1_1 extends KafkaVersion with Product with Serializable
object Kafka_0_10_2_0 extends KafkaVersion with Product with Serializable
object Kafka_0_10_2_1 extends KafkaVersion with Product with Serializable
object Kafka_0_11_0_0 extends KafkaVersion with Product with Serializable
object Kafka_0_11_0_2 extends KafkaVersion with Product with Serializable
object Kafka_0_8_1_1 extends KafkaVersion with Product with Serializable
object Kafka_0_8_2_0 extends KafkaVersion with Product with Serializable
object Kafka_0_8_2_1 extends KafkaVersion with Product with Serializable
object Kafka_0_8_2_2 extends KafkaVersion with Product with Serializable
object Kafka_0_9_0_0 extends KafkaVersion with Product with Serializable
object Kafka_0_9_0_1 extends KafkaVersion with Product with Serializable
object Kafka_1_0_0 extends KafkaVersion with Product with Serializable
object Kafka_1_0_1 extends KafkaVersion with Product with Serializable
object Kafka_1_1_0 extends KafkaVersion with Product with Serializable
object PLAINTEXT extends SecurityProtocol with Product with Serializable
object SASL_PLAINTEXT extends SecurityProtocol with Product with Serializable
object SASL_SSL extends SecurityProtocol with Product with Serializable
object SSL extends SecurityProtocol with Product with Serializable
object SecurityProtocol
def fieldExtended[A](name: String)(json: JValue)(implicit arg0: org.json4s.scalaz.JsonScalaz.JSONR[A]): org.json4s.scalaz.JsonScalaz.Result[A]

package model

Type Members

case class ClusterContext(clusterFeatures: ClusterFeatures, config: ClusterConfig) extends Product with Serializable

case class CuratorConfig(zkConnect: String, zkMaxRetry: Int = 100, baseSleepTimeMs: Int = 100, maxSleepTimeMs: Int = 1000) extends Product with Serializable

sealed trait KafkaVersion extends AnyRef

sealed trait SecurityProtocol extends AnyRef

Value Members

object ActorModel

object ClusterConfig extends Serializable

object ClusterTuning extends Serializable

object KafkaVersion

object Kafka_0_10_0_0 extends KafkaVersion with Product with Serializable

object Kafka_0_10_0_1 extends KafkaVersion with Product with Serializable

object Kafka_0_10_1_0 extends KafkaVersion with Product with Serializable

object Kafka_0_10_1_1 extends KafkaVersion with Product with Serializable

object Kafka_0_10_2_0 extends KafkaVersion with Product with Serializable

object Kafka_0_10_2_1 extends KafkaVersion with Product with Serializable

object Kafka_0_11_0_0 extends KafkaVersion with Product with Serializable

object Kafka_0_11_0_2 extends KafkaVersion with Product with Serializable

object Kafka_0_8_1_1 extends KafkaVersion with Product with Serializable

object Kafka_0_8_2_0 extends KafkaVersion with Product with Serializable

object Kafka_0_8_2_1 extends KafkaVersion with Product with Serializable

object Kafka_0_8_2_2 extends KafkaVersion with Product with Serializable

object Kafka_0_9_0_0 extends KafkaVersion with Product with Serializable

object Kafka_0_9_0_1 extends KafkaVersion with Product with Serializable

object Kafka_1_0_0 extends KafkaVersion with Product with Serializable

object Kafka_1_0_1 extends KafkaVersion with Product with Serializable

object Kafka_1_1_0 extends KafkaVersion with Product with Serializable

object PLAINTEXT extends SecurityProtocol with Product with Serializable

object SASL_PLAINTEXT extends SecurityProtocol with Product with Serializable

object SASL_SSL extends SecurityProtocol with Product with Serializable

object SSL extends SecurityProtocol with Product with Serializable

object SecurityProtocol

def fieldExtended[A](name: String)(json: JValue)(implicit arg0: org.json4s.scalaz.JsonScalaz.JSONR[A]): org.json4s.scalaz.JsonScalaz.Result[A]

Inherited from AnyRef

Inherited from Any

Ungrouped