kafka
.
manager
logkafka
package
logkafka
Visibility
Public
All
Type Members
class
LogkafkaCommandActor
extends
BaseCommandActor
with
LongRunningPoolActor
case class
LogkafkaCommandActorConfig
(
curator:
CuratorFramework
,
longRunningPoolConfig:
LongRunningPoolConfig
,
askTimeoutMillis:
Long
=
400
,
clusterContext:
ClusterContext
)
extends
Product
with
Serializable
class
LogkafkaStateActor
extends
BaseQueryCommandActor
class
LogkafkaViewCacheActor
extends
BaseActor
with
LongRunningPoolActor
case class
LogkafkaViewCacheActorConfig
(
logkafkaStateActorPath:
ActorPath
,
clusterContext:
ClusterContext
,
longRunningPoolConfig:
LongRunningPoolConfig
,
updatePeriod:
FiniteDuration
=
10 seconds
)
extends
Product
with
Serializable
Ungrouped