Package

kafka.manager

logkafka

Permalink

package logkafka

Visibility
  1. Public
  2. All

Type Members

  1. class LogkafkaCommandActor extends BaseCommandActor with LongRunningPoolActor

    Permalink
  2. case class LogkafkaCommandActorConfig(curator: CuratorFramework, longRunningPoolConfig: LongRunningPoolConfig, askTimeoutMillis: Long = 400, clusterContext: ClusterContext) extends Product with Serializable

    Permalink

  3. class LogkafkaStateActor extends BaseQueryCommandActor

    Permalink
  4. class LogkafkaViewCacheActor extends BaseActor with LongRunningPoolActor

    Permalink
  5. case class LogkafkaViewCacheActorConfig(logkafkaStateActorPath: ActorPath, clusterContext: ClusterContext, longRunningPoolConfig: LongRunningPoolConfig, updatePeriod: FiniteDuration = 10 seconds) extends Product with Serializable

    Permalink

Ungrouped