Constructor and Description |
---|
DruidServer(DruidNode node,
DruidServerConfig config,
String type) |
Modifier and Type | Method and Description |
---|---|
void |
ServiceAnnouncer.announce(DruidNode node) |
void |
NoopServiceAnnouncer.announce(DruidNode node) |
void |
CuratorServiceAnnouncer.announce(DruidNode service) |
void |
ServiceAnnouncer.unannounce(DruidNode node) |
void |
NoopServiceAnnouncer.unannounce(DruidNode node) |
void |
CuratorServiceAnnouncer.unannounce(DruidNode service) |
Modifier and Type | Method and Description |
---|---|
CuratorServiceAnnouncer |
DiscoveryModule.getServiceAnnouncer(CuratorServiceAnnouncer announcer,
com.google.inject.Injector injector,
Set<io.druid.guice.KeyHolder<DruidNode>> nodesToAnnounce,
com.metamx.common.lifecycle.Lifecycle lifecycle) |
static void |
DiscoveryModule.registerKey(com.google.inject.Binder binder,
com.google.inject.Key<DruidNode> key)
Requests that the keyed DruidNode instance be injected and published as part of the lifecycle.
|
Modifier and Type | Method and Description |
---|---|
static com.google.inject.multibindings.Multibinder<io.druid.guice.KeyHolder<DruidNode>> |
DruidBinders.discoveryAnnouncementBinder(com.google.inject.Binder binder) |
Modifier and Type | Method and Description |
---|---|
DruidServerMetadata |
StorageNodeModule.getMetadata(DruidNode node,
NodeTypeConfig nodeType,
DruidServerConfig config) |
Constructor and Description |
---|
ForkingTaskRunner(ForkingTaskRunnerConfig config,
TaskConfig taskConfig,
WorkerConfig workerConfig,
Properties props,
io.druid.tasklogs.TaskLogPusher taskLogPusher,
com.fasterxml.jackson.databind.ObjectMapper jsonMapper,
DruidNode node) |
ForkingTaskRunnerFactory(ForkingTaskRunnerConfig config,
TaskConfig taskConfig,
WorkerConfig workerConfig,
Properties props,
com.fasterxml.jackson.databind.ObjectMapper jsonMapper,
io.druid.tasklogs.TaskLogPusher persistentTaskLogs,
DruidNode node) |
TaskMaster(TaskQueueConfig taskQueueConfig,
TaskLockbox taskLockbox,
TaskStorage taskStorage,
TaskActionClientFactory taskActionClientFactory,
DruidNode node,
IndexerZkConfig zkPaths,
TaskRunnerFactory runnerFactory,
ResourceManagementSchedulerFactory managementSchedulerFactory,
org.apache.curator.framework.CuratorFramework curator,
ServiceAnnouncer serviceAnnouncer,
com.metamx.emitter.service.ServiceEmitter emitter) |
Constructor and Description |
---|
ServiceAnnouncingChatHandlerProvider(DruidNode node,
ServiceAnnouncer serviceAnnouncer) |
Constructor and Description |
---|
DruidClusterBridge(com.fasterxml.jackson.databind.ObjectMapper jsonMapper,
DruidClusterBridgeConfig config,
ZkPathsConfig zkPathsConfig,
DruidServerMetadata druidServerMetadata,
com.metamx.common.concurrent.ScheduledExecutorFactory scheduledExecutorFactory,
DruidNode self,
org.apache.curator.framework.CuratorFramework curator,
AtomicReference<org.apache.curator.framework.recipes.leader.LeaderLatch> leaderLatch,
BridgeZkCoordinator bridgeZkCoordinator,
Announcer announcer,
AbstractDataSegmentAnnouncer dataSegmentAnnouncer,
ServerInventoryView serverInventoryView) |
Constructor and Description |
---|
DruidBroker(ServerInventoryView serverInventoryView,
DruidNode self,
ServiceAnnouncer serviceAnnouncer) |
Constructor and Description |
---|
DruidCoordinator(DruidCoordinatorConfig config,
ZkPathsConfig zkPaths,
JacksonConfigManager configManager,
MetadataSegmentManager metadataSegmentManager,
ServerInventoryView serverInventoryView,
MetadataRuleManager metadataRuleManager,
org.apache.curator.framework.CuratorFramework curator,
com.metamx.emitter.service.ServiceEmitter emitter,
com.metamx.common.concurrent.ScheduledExecutorFactory scheduledExecutorFactory,
IndexingServiceClient indexingServiceClient,
LoadQueueTaskMaster taskMaster,
ServiceAnnouncer serviceAnnouncer,
DruidNode self) |
Modifier and Type | Method and Description |
---|---|
com.metamx.emitter.service.ServiceEmitter |
EmitterModule.getServiceEmitter(com.google.common.base.Supplier<DruidNode> configSupplier,
com.metamx.emitter.core.Emitter emitter) |
Modifier and Type | Method and Description |
---|---|
org.eclipse.jetty.server.Server |
JettyServerModule.getServer(com.google.inject.Injector injector,
com.metamx.common.lifecycle.Lifecycle lifecycle,
DruidNode node,
ServerConfig config) |
Copyright © 2011–2015. All rights reserved.