actor

Type Members

1. class DeleteClusterActor extends BaseCommandActor

   

2. case class DeleteClusterActorConfig(curator: CuratorFramework, baseDeleteClustersZKPath: String, baseClustersZKPath: String, baseConfigsZKPath: String, updatePeriod: FiniteDuration = 10 seconds, deletionBatchSize: Int = 2) extends Product with Serializable

   

3. class KafkaManagerActor extends BaseQueryCommandActor with CuratorAwareActor with BaseZkPath

   

4. case class KafkaManagerActorConfig(curatorConfig: CuratorConfig, baseZkPath: String = KafkaManagerActor.ZkRoot, pinnedDispatcherName: String = "pinned-dispatcher", startDelayMillis: Long = 1000, threadPoolSize: Int = 2, mutexTimeoutMillis: Int = 4000, maxQueueSize: Int = 100, kafkaManagerUpdatePeriod: FiniteDuration = 10 seconds, deleteClusterUpdatePeriod: FiniteDuration = 10 seconds, deletionBatchSize: Int = 2, clusterActorsAskTimeoutMillis: Int = 2000, simpleConsumerSocketTimeoutMillis: Int = 10000, defaultTuning: ClusterTuning, consumerProperties: Option[Properties]) extends Product with Serializable