| 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.