Package org.elasticsearch.repositories

Class RepositoriesService

java.lang.Object

org.elasticsearch.common.component.AbstractComponent

org.elasticsearch.repositories.RepositoriesService

All Implemented Interfaces:

ClusterStateApplier

public class RepositoriesService
extends AbstractComponent
implements ClusterStateApplier

Service responsible for maintaining and providing access to snapshot repositories on nodes.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	RepositoriesService.RegisterRepositoryRequest	Register repository request
static class	RepositoriesService.UnregisterRepositoryRequest	Unregister repository request
static class	RepositoriesService.VerifyResponse	Verify repository request

Field Summary

Fields inherited from class org.elasticsearch.common.component.AbstractComponent

deprecationLogger, logger, settings

Constructor Summary

Constructors

Constructor	Description
RepositoriesService(Settings settings, ClusterService clusterService, TransportService transportService, java.util.Map<java.lang.String,Repository.Factory> typesRegistry, ThreadPool threadPool)

Method Summary

Modifier and Type	Method	Description
void	applyClusterState(ClusterChangedEvent event)	Checks if new repositories appeared in or disappeared from cluster metadata and updates current list of repositories accordingly.
void	registerRepository(RepositoriesService.RegisterRepositoryRequest request, ActionListener<ClusterStateUpdateResponse> listener)	Registers new repository in the cluster
Repository	repository(java.lang.String repositoryName)	Returns registered repository
void	unregisterRepository(RepositoriesService.UnregisterRepositoryRequest request, ActionListener<ClusterStateUpdateResponse> listener)	Unregisters repository in the cluster
void	verifyRepository(java.lang.String repositoryName, ActionListener<RepositoriesService.VerifyResponse> listener)

Methods inherited from class org.elasticsearch.common.component.AbstractComponent

nodeName

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

RepositoriesService

@Inject
public RepositoriesService(Settings settings,
                           ClusterService clusterService,
                           TransportService transportService,
                           java.util.Map<java.lang.String,Repository.Factory> typesRegistry,
                           ThreadPool threadPool)

Method Detail

registerRepository

public void registerRepository(RepositoriesService.RegisterRepositoryRequest request,
                               ActionListener<ClusterStateUpdateResponse> listener)

Registers new repository in the cluster

This method can be only called on the master node. It tries to create a new repository on the master and if it was successful it adds new repository to cluster metadata.

Parameters:

request - register repository request

listener - register repository listener

unregisterRepository

public void unregisterRepository(RepositoriesService.UnregisterRepositoryRequest request,
                                 ActionListener<ClusterStateUpdateResponse> listener)

Unregisters repository in the cluster

This method can be only called on the master node. It removes repository information from cluster metadata.

Parameters:

request - unregister repository request

listener - unregister repository listener

verifyRepository

public void verifyRepository(java.lang.String repositoryName,
                             ActionListener<RepositoriesService.VerifyResponse> listener)

applyClusterState

public void applyClusterState(ClusterChangedEvent event)

Checks if new repositories appeared in or disappeared from cluster metadata and updates current list of repositories accordingly.

Specified by:

applyClusterState in interface ClusterStateApplier

Parameters:

event - cluster changed event

repository

public Repository repository(java.lang.String repositoryName)

Returns registered repository

This method is called only on the master node

Parameters:

repositoryName - repository name

Returns:

registered repository

Throws:

RepositoryMissingException - if repository with such name isn't registered