Package dev.getelements.elements.rt

Class SimpleIndexContext

java.lang.Object

dev.getelements.elements.rt.SimpleIndexContext

All Implemented Interfaces:

IndexContext

public class SimpleIndexContext
extends Object
implements IndexContext

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	SimpleIndexContext.SimpleIndexContextUnlink

Nested classes/interfaces inherited from interface dev.getelements.elements.rt.IndexContext

IndexContext.Listing, IndexContext.Unlink

Constructor Summary

Constructors

Constructor	Description
SimpleIndexContext()

Method Summary

Modifier and Type	Method	Description
ExecutorService	getExecutorService()
ExecutorServiceFactory<ExecutorService>	getExecutorServiceFactory()
ResourceService	getResourceService()
void	linkAsync(ResourceId resourceId, Path destination, Consumer<Void> success, Consumer<Throwable> failure)	Links a single ResourceId to a Path destination.
void	linkPathAsync(Path source, Path destination, Consumer<Void> success, Consumer<Throwable> failure)	Links a single Path to a Path destination.
void	listAsync(Path path, Consumer<List<IndexContext.Listing>> success, Consumer<Throwable> failure)	Fetches a IndexContext.Listing of all Paths and assocaited ResourceId instances which match the provided Path.
void	setExecutorServiceFactory(ExecutorServiceFactory<ExecutorService> executorServiceFactory)
void	setResourceService(ResourceService resourceService)
void	start()	Starts this IndexContext.
void	stop()	Stops this IndexContext.
void	unlinkAsync(Path path, Consumer<IndexContext.Unlink> success, Consumer<Throwable> failure)	Unlinks the provided Path and if this is the last Path reference to a ResourceId, then the cluster will remove and destroy the associated Resource.

Methods inherited from class java.lang.Object

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

Methods inherited from interface dev.getelements.elements.rt.IndexContext

link, linkPath, list, unlink

Constructor Details

SimpleIndexContext

public SimpleIndexContext()

Method Details

start

public void start()

Description copied from interface: IndexContext

Starts this IndexContext.

Specified by:

start in interface IndexContext

stop

public void stop()

Description copied from interface: IndexContext

Stops this IndexContext.

Specified by:

stop in interface IndexContext

listAsync

public void listAsync(Path path,
 Consumer<List<IndexContext.Listing>> success,
 Consumer<Throwable> failure)

Description copied from interface: IndexContext

Fetches a IndexContext.Listing of all Paths and assocaited ResourceId instances which match the provided Path. Unlike other methods for linking and unlinking, the provided Path may be a wildcard as determined by Path.isWildcard(). The supplied List should represent a complete buffering of all IndexContext.Listing instances matching the Path.

Specified by:

listAsync in interface IndexContext

Parameters:

path - the Path to match

success - a Consumer which receives an instance of IndexContext.Listing

failure - a Consumer which receives an exception indicating a failure reason.

linkAsync

public void linkAsync(ResourceId resourceId,
 Path destination,
 Consumer<Void> success,
 Consumer<Throwable> failure)

Description copied from interface: IndexContext

Links a single ResourceId to a Path destination.

Specified by:

linkAsync in interface IndexContext

Parameters:

resourceId - the source ResourceId to link

destination - the Path of the destination to link

success - a Consumer which will be called on successful completion

failure - a Consumer which will be called on a failure

linkPathAsync

public void linkPathAsync(Path source,
 Path destination,
 Consumer<Void> success,
 Consumer<Throwable> failure)

Description copied from interface: IndexContext

Links a single Path to a Path destination.

Specified by:

linkPathAsync in interface IndexContext

Parameters:

source - the source Path to link

destination - the Path of the destination to link

success - a Consumer which will be called on successful completion

failure - a Consumer which will be called on a failure

unlinkAsync

public void unlinkAsync(Path path,
 Consumer<IndexContext.Unlink> success,
 Consumer<Throwable> failure)

Description copied from interface: IndexContext

Unlinks the provided Path and if this is the last Path reference to a ResourceId, then the cluster will remove and destroy the associated Resource. Further details on the operation can be obtained through the IndexContext.Unlink interface. If the result is a complete removal, then this will have the same end result as ResourceContext.destroy(ResourceId) or ResourceContext.destroyAsync(Consumer, Consumer, ResourceId).

Specified by:

unlinkAsync in interface IndexContext

Parameters:

path - the path to unlink

success - a Consumer<IndexContext.Unlink> to receive the successful operation

failure - a Consumer<Throwable> to receive an exception if one was generated

getExecutorService

public ExecutorService getExecutorService()

getExecutorServiceFactory

public ExecutorServiceFactory<ExecutorService> getExecutorServiceFactory()

setExecutorServiceFactory

@Inject
public void setExecutorServiceFactory(@Named("dev.getelements.elements.rt.executor")
 ExecutorServiceFactory<ExecutorService> executorServiceFactory)

getResourceService

public ResourceService getResourceService()

setResourceService

@Inject
public void setResourceService(ResourceService resourceService)