Modifier and Type | Class and Description |
---|---|
class |
BulkUdpService |
Modifier and Type | Interface and Description |
---|---|
interface |
ClusterService
The cluster service allowing to both register for cluster state events (
ClusterStateListener )
and submit state update tasks (ClusterStateUpdateTask . |
Modifier and Type | Class and Description |
---|---|
class |
RoutingService
A
RoutingService listens to clusters state. |
Modifier and Type | Class and Description |
---|---|
class |
InternalClusterService |
Modifier and Type | Class and Description |
---|---|
class |
AbstractLifecycleComponent<T> |
Modifier and Type | Interface and Description |
---|---|
interface |
Discovery
A pluggable module allowing to implement discovery of other nodes, publishing of the cluster
state to all nodes, electing a master of the cluster that raises cluster state change
events.
|
Modifier and Type | Class and Description |
---|---|
class |
DiscoveryService |
Modifier and Type | Class and Description |
---|---|
class |
LocalDiscovery |
Modifier and Type | Class and Description |
---|---|
class |
ZenDiscovery |
Modifier and Type | Interface and Description |
---|---|
interface |
ZenPing |
Modifier and Type | Class and Description |
---|---|
class |
ZenPingService |
Modifier and Type | Class and Description |
---|---|
class |
MulticastZenPing |
Modifier and Type | Class and Description |
---|---|
class |
UnicastZenPing |
Modifier and Type | Interface and Description |
---|---|
interface |
Gateway |
Modifier and Type | Class and Description |
---|---|
class |
GatewayService |
Modifier and Type | Class and Description |
---|---|
class |
LocalGateway |
Modifier and Type | Class and Description |
---|---|
class |
NoneGateway |
Modifier and Type | Interface and Description |
---|---|
interface |
HttpServerTransport |
Modifier and Type | Class and Description |
---|---|
class |
HttpServer |
Modifier and Type | Class and Description |
---|---|
class |
NettyHttpServerTransport |
Modifier and Type | Class and Description |
---|---|
class |
IndicesService |
Modifier and Type | Class and Description |
---|---|
class |
CircuitBreakerService
Interface for Circuit Breaker services, which provide breakers to classes
that load field data.
|
class |
HierarchyCircuitBreakerService
CircuitBreakerService that attempts to redistribute space between breakers
if tripped
|
class |
NoneCircuitBreakerService
Class that returns a breaker that never breaks
|
Modifier and Type | Class and Description |
---|---|
class |
IndicesClusterStateService |
Modifier and Type | Class and Description |
---|---|
class |
IndexingMemoryController |
Modifier and Type | Class and Description |
---|---|
class |
IndicesTTLService
A node level service that delete expired docs on node primary shards.
|
Modifier and Type | Class and Description |
---|---|
class |
MonitorService |
Modifier and Type | Class and Description |
---|---|
class |
JvmMonitorService |
Modifier and Type | Method and Description |
---|---|
Collection<Class<? extends LifecycleComponent>> |
AbstractPlugin.services()
Defaults to return an empty list.
|
Collection<Class<? extends LifecycleComponent>> |
PluginsService.services() |
Collection<Class<? extends LifecycleComponent>> |
Plugin.services()
Node level services that will be automatically started/stopped/closed.
|
Modifier and Type | Interface and Description |
---|---|
interface |
Repository
Snapshot repository interface.
|
Modifier and Type | Class and Description |
---|---|
class |
BlobStoreRepository
BlobStore - based implementation of Snapshot Repository
This repository works with any
BlobStore implementation. |
Modifier and Type | Class and Description |
---|---|
class |
FsRepository
Shared file system implementation of the BlobStoreRepository
Shared file system repository supports the following settings
location Path to the root of repository. |
Modifier and Type | Class and Description |
---|---|
class |
URLRepository
Read-only URL-based implementation of the BlobStoreRepository
This repository supports the following settings
url URL to the root of repository. |
Modifier and Type | Class and Description |
---|---|
class |
RestController |
Modifier and Type | Class and Description |
---|---|
class |
RiversManager |
class |
RiversService |
Modifier and Type | Class and Description |
---|---|
class |
RiverClusterService |
Modifier and Type | Class and Description |
---|---|
class |
RiversRouter |
Modifier and Type | Class and Description |
---|---|
class |
SearchService |
Modifier and Type | Class and Description |
---|---|
class |
SnapshotsService
Service responsible for creating snapshots
A typical snapshot creating process looks like this:
On the master node the
SnapshotsService.createSnapshot(SnapshotRequest, CreateSnapshotListener) is called and makes sure that no snapshots is currently running
and registers the new snapshot in cluster state
When cluster state is updated the SnapshotsService.beginSnapshot(ClusterState, SnapshotMetaData.Entry, boolean, CreateSnapshotListener) method
kicks in and initializes the snapshot in the repository and then populates list of shards that needs to be snapshotted in cluster state
Each data node is watching for these shards and when new shards scheduled for snapshotting appear in the cluster state, data nodes
start processing them through SnapshotsService.processIndexShardSnapshots(SnapshotMetaData) method
Once shard snapshot is created data node updates state of the shard in the cluster state using the SnapshotsService.updateIndexShardSnapshotStatus(UpdateIndexShardSnapshotStatusRequest) method
When last shard is completed master node in SnapshotsService.innerUpdateSnapshotState(org.elasticsearch.snapshots.SnapshotsService.UpdateIndexShardSnapshotStatusRequest) method marks the snapshot as completed
After cluster state is updated, the SnapshotsService.endSnapshot(SnapshotMetaData.Entry) finalizes snapshot in the repository,
notifies all SnapshotsService.snapshotCompletionListeners that snapshot is completed, and finally calls SnapshotsService.removeSnapshotFromClusterState(SnapshotId, SnapshotInfo, Throwable) to remove snapshot from cluster state
|
Modifier and Type | Interface and Description |
---|---|
interface |
Transport |
Modifier and Type | Class and Description |
---|---|
class |
TransportService |
Modifier and Type | Class and Description |
---|---|
class |
LocalTransport |
Modifier and Type | Class and Description |
---|---|
class |
NettyTransport
There are 4 types of connections per node, low/med/high/ping.
|
Modifier and Type | Class and Description |
---|---|
class |
TribeService
The tribe service holds a list of node clients connected to a list of tribe members, and uses their
cluster state events to update this local node cluster state with the merged view of it.
|
Modifier and Type | Class and Description |
---|---|
class |
ResourceWatcherService
Generic resource watcher service
Other elasticsearch services can register their resource watchers with this service using
ResourceWatcherService.add(ResourceWatcher)
method. |
Copyright © 2009–2015. All rights reserved.