AbstractResourceManagerTestCase.MockFederation (Blazegraph Database Platform 2.1.5 API)

java.lang.Object
- com.bigdata.resources.AbstractResourceManagerTestCase.MockFederation

All Implemented Interfaces:

ICounterSetAccess, IGISTManager, IIndexManager, IIndexStore, IBigdataFederation<AbstractResourceManagerTestCase.MockMetadataService>, IFederationDelegate<AbstractResourceManagerTestCase.MockMetadataService>

Enclosing class:

AbstractResourceManagerTestCase
```
protected class AbstractResourceManagerTestCase.MockFederation
extends Object
implements IBigdataFederation<AbstractResourceManagerTestCase.MockMetadataService>
```
A minimal implementation of only those methods actually utilized by the ResourceManager during the unit tests.

Version:

$Id$

Author:

Bryan Thompson

Constructor Summary

Constructors
Modifier Constructor and Description

protected AbstractResourceManagerTestCase.MockFederation()

Constructors
Modifier	Constructor and Description
`protected`	`AbstractResourceManagerTestCase.MockFederation()`

Method Summary

Methods
Modifier and Type	Method and Description
`ScheduledFuture<?>`	`addScheduledTask(Runnable task, long initialDelay, long delay, TimeUnit unit)` Adds a task which will run until canceled, until it throws an exception, or until the service is shutdown.
`void`	`destroy()` Destroys all discovered services belonging to the federation and their persistent data and disconnects from the federation.
`void`	`didStart()` Invoked by the `AbstractFederation` once the deferred startup tasks are executed.
`void`	`dropIndex(String name)` Drop a scale-out index.
`IDataService`	`getAnyDataService()` Return ANY `IDataService` which has been (or could be) discovered and which is part of the connected federation.
`IBigdataClient`	`getClient()` Return the client object that was used to connect to the federation.
`boolean`	`getCollectPlatformStatistics()` `true` iff performance counters will be collected for the platform on which the client is running.
`boolean`	`getCollectQueueStatistics()` `true` iff statistics will be collected for work queues.
`CounterSet`	`getCounters()` The `CounterSet` which the client will use report its statistics to the `ILoadBalancerService`.
`IDataService`	`getDataService(UUID serviceUUID)` Resolve the service identifier to an `IDataService`.
`IDataService`	`getDataServiceByName(String name)` Return an `IDataService` joined with this `IBigdataFederation` and having the specified service name.
`IDataService[]`	`getDataServices(UUID[] uuid)` Return an array of `IDataService` references that is correlated with the given array of `IDataService` `UUID`s.
`UUID[]`	`getDataServiceUUIDs(int maxCount)` Return an array UUIDs for `IDataService`s.
`ExecutorService`	`getExecutorService()` A thread pool that may be used by clients to parallelize operations against the federation.
`BigdataFileSystem`	`getGlobalFileSystem()` Return the global file system used to store block-structured files and their metadata and as a source and sink for map/reduce processing.
`SparseRowStore`	`getGlobalRowStore()` Return an unisolated view of the global `SparseRowStore` used to store named property sets.
`SparseRowStore`	`getGlobalRowStore(long timestamp)` Return a view of the global `SparseRowStore` used to store named property sets as of the specified timestamp.
`CounterSet`	`getHostCounterSet()` The node in `IBigdataFederation.getCounters()` corresponding to the root of the host on which the client or service is executing.
`int`	`getHttpdPort()` The port on which the optional httpd service will be run.
`String`	`getHttpdURL()` The URL that may be used to access the local httpd service for this client or service.
`IClientIndex`	`getIndex(String name, long timestamp)` Obtain a view on a partitioned index.
`IKeyBuilder`	`getKeyBuilder()`
`long`	`getLastCommitTime()` Return the last commit time for the federation (the timestamp of the most recent commit point across all `IDataService`s).
`ILoadBalancerService`	`getLoadBalancerService()` Return the load balancer service (or a proxy for that service).
`IMetadataIndex`	`getMetadataIndex(String name, long timestamp)` Return a read-only view of the index partitions for the named scale-out index.
`IMetadataService`	`getMetadataService()` Return the metadata service (or a proxy for the metadata service).
`IResourceLocator`	`getResourceLocator()` Return the default locator for resources that are logical index containers (relations and relation containers).
`IResourceLockService`	`getResourceLockService()` The service that may be used to acquire synchronous distributed locks without deadlock detection.
`AbstractResourceManagerTestCase.MockMetadataService`	`getService()` Return the client or service.
`String`	`getServiceCounterPathPrefix()` The path prefix under which all of the client or service's counters are located.
`CounterSet`	`getServiceCounterSet()` The node in `IBigdataFederation.getCounters()` corresponding to the root of the client or service connected using this federation.
`Class`	`getServiceIface()` Return the class or interface that is the most interesting facet of the client and which will be used to identify this client in the performance counters reported to the `ILoadBalancerService`.
`String`	`getServiceName()` Return a name for the service.
`UUID`	`getServiceUUID()` The `UUID` assigned to the `IBigdataClient` or `AbstractService`.
`TemporaryStore`	`getTempStore()` A factory for `TemporaryStore`s.
`ITransactionService`	`getTransactionService()` Return the `ITransactionService` (or a proxy for that service).
`Iterator<String>`	`indexNameScan(String prefix, long timestamp)` Iterator visits the names of all indices spanned by the given prefix.
`boolean`	`isDistributed()` Return `true` iff the federation is distributed (uses RMI and is running, at least in principle, across more than one host/JVM).
`boolean`	`isGroupCommit()` Return true if the index manager supports group commit semantics.
`boolean`	`isJiniFederation()` Convenience method to return whether the Federation is a Jini Federation.
`boolean`	`isScaleOut()` Return `true` iff the federation supports scale-out indices (supports key-range partitioned indices).
`boolean`	`isServiceReady()` Return `true` iff the service is ready to start.
`boolean`	`isStable()` Return `true` iff the federation is backed by "stable" (vs transient) storage.
`AbstractHTTPD`	`newHttpd(int httpdPort, ICounterSetAccess access)` Create a new `AbstractHTTPD` instance.
`void`	`reattachDynamicCounters()` Offers the service an opportunity to dynamically detach and re-attach performance counters.
`void`	`registerIndex(IndexMetadata metadata)` Register a scale-out index.
`UUID`	`registerIndex(IndexMetadata metadata, byte[][] separatorKeys, UUID[] dataServiceUUIDs)` Register and statically partition a scale-out index.
`UUID`	`registerIndex(IndexMetadata metadata, UUID dataServiceUUID)` Register a scale-out index and assign the initial index partition to the specified data service.
`void`	`serviceJoin(IService service, UUID serviceUUID)` Notice that the service has been discovered.
`void`	`serviceLeave(UUID serviceUUID)` Notice that the service is no longer available.

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

- Constructor Detail
  - AbstractResourceManagerTestCase.MockFederation
```
protected AbstractResourceManagerTestCase.MockFederation()
```
- Method Detail
  - getService
```
public AbstractResourceManagerTestCase.MockMetadataService getService()
```
    Description copied from interface: IFederationDelegate
    
    Return the client or service.
    
    Specified by:
    
    getService in interface IFederationDelegate<AbstractResourceManagerTestCase.MockMetadataService>
  - destroy
```
public void destroy()
```
    Description copied from interface: IBigdataFederation
    
    Destroys all discovered services belonging to the federation and their persistent data and disconnects from the federation.
    
    Specified by:
    
    destroy in interface IIndexStore
    
    Specified by:
    
    destroy in interface IBigdataFederation<AbstractResourceManagerTestCase.MockMetadataService>
  - dropIndex
```
public void dropIndex(String name)
```
    Description copied from interface: IBigdataFederation
    
    Drop a scale-out index.
    
    Specified by:
    
    dropIndex in interface IGISTManager
    
    Specified by:
    
    dropIndex in interface IBigdataFederation<AbstractResourceManagerTestCase.MockMetadataService>
    
    Parameters:
    name - The index name.
  - getAnyDataService
```
public IDataService getAnyDataService()
```
    Description copied from interface: IBigdataFederation
    
    Return ANY IDataService which has been (or could be) discovered and which is part of the connected federation.
    Note: This method is here as a failsafe when the ILoadBalancerService is not available.
    
    Specified by:
    
    getAnyDataService in interface IBigdataFederation<AbstractResourceManagerTestCase.MockMetadataService>
    
    Returns:
    null if there are NO known IDataServices.
  - getClient
```
public IBigdataClient getClient()
```
    Description copied from interface: IBigdataFederation
    
    Return the client object that was used to connect to the federation.
    
    Specified by:
    
    getClient in interface IBigdataFederation<AbstractResourceManagerTestCase.MockMetadataService>
  - getServiceCounterPathPrefix
```
public String getServiceCounterPathPrefix()
```
    Description copied from interface: IBigdataFederation
    
    The path prefix under which all of the client or service's counters are located. The returned path prefix is terminated by an ICounterSet.pathSeparator.
    
    Specified by:
    
    getServiceCounterPathPrefix in interface IBigdataFederation<AbstractResourceManagerTestCase.MockMetadataService>
    
    See Also:
    IBigdataFederation.getServiceCounterSet()
  - getCounters
```
public CounterSet getCounters()
```
    Description copied from interface: IBigdataFederation
    
    The CounterSet which the client will use report its statistics to the ILoadBalancerService.
    Note: Applications MAY add their own counters (within a suitable namespace) to the returned CounterSet in order to report their own performance data to the ILoadBalancerService.
    
    Specified by:
    
    getCounters in interface ICounterSetAccess
    
    Specified by:
    
    getCounters in interface IBigdataFederation<AbstractResourceManagerTestCase.MockMetadataService>
    
    See Also:
    IBigdataFederation.getServiceCounterSet(), IBigdataFederation.getServiceCounterPathPrefix()
  - getDataService
```
public IDataService getDataService(UUID serviceUUID)
```
    Description copied from interface: IBigdataFederation
    
    Resolve the service identifier to an IDataService.
    Note: Whether the returned object is a proxy or the service implementation depends on whether the federation is embedded (in process) or distributed (networked).
    
    Specified by:
    
    getDataService in interface IBigdataFederation<AbstractResourceManagerTestCase.MockMetadataService>
    
    Parameters:
    serviceUUID - The identifier for a IDataService.
    
    Returns:
    The IDataService or null iff the IDataService could not be discovered from its identifier.
  - getDataServiceUUIDs
```
public UUID[] getDataServiceUUIDs(int maxCount)
```
    Description copied from interface: IBigdataFederation
    
    Return an array UUIDs for IDataServices.
    
    Specified by:
    
    getDataServiceUUIDs in interface IBigdataFederation<AbstractResourceManagerTestCase.MockMetadataService>
    
    Parameters:
    maxCount - The maximum #of data services whose UUIDs will be returned. When zero (0) the UUID for all known data services will be returned.
    
    Returns:
    An array of UUIDs for data services.
  - getExecutorService
```
public ExecutorService getExecutorService()
```
    Description copied from interface: IBigdataFederation
    
    A thread pool that may be used by clients to parallelize operations against the federation. This thread pool is automatically used by the ClientIndexView.
    
    Specified by:
    
    getExecutorService in interface IIndexStore
    
    Specified by:
    
    getExecutorService in interface IBigdataFederation<AbstractResourceManagerTestCase.MockMetadataService>
  - getGlobalRowStore
```
public SparseRowStore getGlobalRowStore()
```
    Description copied from interface: IIndexStore
    
    Return an unisolated view of the global SparseRowStore used to store named property sets.
    
    Specified by:
    
    getGlobalRowStore in interface IIndexStore
    
    See Also:
    GlobalRowStoreSchema
  - getGlobalRowStore
```
public SparseRowStore getGlobalRowStore(long timestamp)
```
    Description copied from interface: IIndexStore
    
    Return a view of the global SparseRowStore used to store named property sets as of the specified timestamp.
    The SparseRowStore only permits ITx.UNISOLATED writes, so you MUST specify ITx.UNISOLATED as the timestamp if you intend to write on the global row store!
    You can request the most recent committed state of the global row store by specifying ITx.READ_COMMITTED.
    
    Specified by:
    
    getGlobalRowStore in interface IIndexStore
    
    Parameters:
    timestamp - The timestamp of the view.
    
    Returns:
    The global row store view -or- null if no view exists as of that timestamp.
  - getIndex
```
public IClientIndex getIndex(String name,
                    long timestamp)
```
    Description copied from interface: IBigdataFederation
    
    Obtain a view on a partitioned index.
    
    Specified by:
    
    getIndex in interface IIndexManager
    
    Specified by:
    
    getIndex in interface IBigdataFederation<AbstractResourceManagerTestCase.MockMetadataService>
    
    Parameters:
    name - The index name.
    timestamp - A transaction identifier, ITx.UNISOLATED for the unisolated index view, ITx.READ_COMMITTED, or timestamp for a historical view no later than the specified timestamp.
    
    Returns:
    The index or null if the index does not exist.
    See Also:
    IGISTLocalManager.getIndexLocal(String, long)
  - getKeyBuilder
```
public IKeyBuilder getKeyBuilder()
```
  - getLoadBalancerService
```
public ILoadBalancerService getLoadBalancerService()
```
    Description copied from interface: IBigdataFederation
    
    Return the load balancer service (or a proxy for that service).
    
    Specified by:
    
    getLoadBalancerService in interface IBigdataFederation<AbstractResourceManagerTestCase.MockMetadataService>
    
    Returns:
    The service -or- null if the service has not been discovered.
  - getMetadataIndex
```
public IMetadataIndex getMetadataIndex(String name,
                              long timestamp)
```
    Description copied from interface: IBigdataFederation
    
    Return a read-only view of the index partitions for the named scale-out index.
    
    Specified by:
    
    getMetadataIndex in interface IBigdataFederation<AbstractResourceManagerTestCase.MockMetadataService>
    
    Parameters:
    name - The name of the scale-out index.
    
    Returns:
    The IMetadataIndex for the named scale-out index -or- null iff there is no such scale-out index.
  - getMetadataService
```
public IMetadataService getMetadataService()
```
    Description copied from interface: IBigdataFederation
    
    Return the metadata service (or a proxy for the metadata service).
    
    Specified by:
    
    getMetadataService in interface IBigdataFederation<AbstractResourceManagerTestCase.MockMetadataService>
    
    Returns:
    The service -or- null if the service has not been discovered.
  - getTransactionService
```
public ITransactionService getTransactionService()
```
    Description copied from interface: IBigdataFederation
    
    Return the ITransactionService (or a proxy for that service).
    
    Specified by:
    
    getTransactionService in interface IBigdataFederation<AbstractResourceManagerTestCase.MockMetadataService>
    
    Returns:
    The service -or- null if the service has not been discovered.
  - isDistributed
```
public boolean isDistributed()
```
    Description copied from interface: IBigdataFederation
    
    Return true iff the federation is distributed (uses RMI and is running, at least in principle, across more than one host/JVM).
    
    Specified by:
    
    isDistributed in interface IBigdataFederation<AbstractResourceManagerTestCase.MockMetadataService>
  - isScaleOut
```
public boolean isScaleOut()
```
    Description copied from interface: IBigdataFederation
    
    Return true iff the federation supports scale-out indices (supports key-range partitioned indices). Note that a true return does NOT imply that the federation is running in a distributed environment, just that it uses the scale-out index architecture. A false return indicates that IBigdataFederation.getMetadataService() WILL NOT return a IMetadataService since key-range partitioned indices are NOT supported.
    
    Specified by:
    
    isScaleOut in interface IBigdataFederation<AbstractResourceManagerTestCase.MockMetadataService>
    
    See Also:
    IndexMetadata
  - isStable
```
public boolean isStable()
```
    Description copied from interface: IBigdataFederation
    
    Return true iff the federation is backed by "stable" (vs transient) storage. Most federation deployments are stable in this sense, but it is possible to create federation instances backed solely by transient storage and those instances will report false here. This is most typically done for testing purposes using a LocalDataServiceFederation or an EmbeddedFederation.
    
    Specified by:
    
    isStable in interface IBigdataFederation<AbstractResourceManagerTestCase.MockMetadataService>
  - isGroupCommit
```
public boolean isGroupCommit()
```
    Description copied from interface: IIndexManager
    
    Return true if the index manager supports group commit semantics.
    
    Specified by:
    
    isGroupCommit in interface IIndexManager
    
    See Also:
    (NSS GROUP COMMIT)
  - getLastCommitTime
```
public long getLastCommitTime()
```
    Description copied from interface: IBigdataFederation
    
    Return the last commit time for the federation (the timestamp of the most recent commit point across all IDataServices).
    This is useful for ITx.READ_COMMITTED operations that need to use a consistent timestamp across a series of DataServices or a series of requests against a single DataService that must use a consistent view.
    
    Specified by:
    
    getLastCommitTime in interface IIndexStore
    
    Specified by:
    
    getLastCommitTime in interface IBigdataFederation<AbstractResourceManagerTestCase.MockMetadataService>
    
    Returns:
    The timestamp of the most recent commit on the store or 0L iff there have been no commits.
    See Also:
    IRootBlockView.getLastCommitTime()
  - registerIndex
```
public void registerIndex(IndexMetadata metadata)
```
    Description copied from interface: IBigdataFederation
    
    Register a scale-out index.
    
    Specified by:
    
    registerIndex in interface IGISTManager
    
    Specified by:
    
    registerIndex in interface IBigdataFederation<AbstractResourceManagerTestCase.MockMetadataService>
    
    Parameters:
    metadata - The metadata template used to create component indices for BTrees this scale-out index (this also specifies the name of the scale-out index).
    See Also:
    IGISTLocalManager.getIndexLocal(String, long)
  - registerIndex
```
public UUID registerIndex(IndexMetadata metadata,
                 UUID dataServiceUUID)
```
    Description copied from interface: IBigdataFederation
    
    Register a scale-out index and assign the initial index partition to the specified data service.
    
    Specified by:
    
    registerIndex in interface IBigdataFederation<AbstractResourceManagerTestCase.MockMetadataService>
    
    Parameters:
    metadata - The metadata template used to create component indices for BTrees this scale-out index (this also specifies the name of the scale-out index).
    dataServiceUUID - The data service identifier (optional). When null, a data service will be selected automatically. If IndexMetadata.Options#INITIAL_DATA_SERVICE was specified, then the identified service will be used. Otherwise an underutilized service will be selected using the ILoadBalancerService.
    
    Returns:
    The UUID of the registered index.
    See Also:
    IndexMetadata.Options#INITIAL_DATA_SERVICE
  - registerIndex
```
public UUID registerIndex(IndexMetadata metadata,
                 byte[][] separatorKeys,
                 UUID[] dataServiceUUIDs)
```
    Description copied from interface: IBigdataFederation
    
    Register and statically partition a scale-out index.
    
    Specified by:
    
    registerIndex in interface IBigdataFederation<AbstractResourceManagerTestCase.MockMetadataService>
    
    Parameters:
    metadata - The metadata template used to create component indices for BTrees this scale-out index (this also specifies the name of the scale-out index).
    separatorKeys - The array of separator keys. Each separator key is interpreted as an unsigned byte[]. The first entry MUST be an empty byte[]. The entries MUST be in sorted order.
    dataServiceUUIDs - The array of data services onto which each partition defined by a separator key will be mapped (optional). When given, the #of entries in this array MUST agree with the #of entries in the separatorKeys array and all entries must be non-null. When not given, the index partitions will be auto-assigned to the discovered data services.
    
    Returns:
    The UUID of the scale-out index.
  - getResourceLocator
```
public IResourceLocator getResourceLocator()
```
    Description copied from interface: IIndexStore
    
    Return the default locator for resources that are logical index containers (relations and relation containers).
    
    Specified by:
    
    getResourceLocator in interface IIndexStore
  - getResourceLockService
```
public IResourceLockService getResourceLockService()
```
    Description copied from interface: IIndexStore
    
    The service that may be used to acquire synchronous distributed locks without deadlock detection.
    
    Specified by:
    
    getResourceLockService in interface IIndexStore
  - getGlobalFileSystem
```
public BigdataFileSystem getGlobalFileSystem()
```
    Description copied from interface: IIndexStore
    
    Return the global file system used to store block-structured files and their metadata and as a source and sink for map/reduce processing.
    
    Specified by:
    
    getGlobalFileSystem in interface IIndexStore
    
    See Also:
    BigdataFileSystem
  - getTempStore
```
public TemporaryStore getTempStore()
```
    Description copied from interface: IIndexStore
    
    A factory for TemporaryStores. TemporaryStores are thread-safe and may be used by multiple processes at once. Old TemporaryStores are eventually retired by the factory and their storage is reclaimed once they are finalized (after they are no longer in use by any process). The decision to retire a TemporaryStore is either made implicitly, when it is no longer weakly reachable, or explicitly, when it has grown large enough that no new processes should begin using that TemporaryStore. In the latter case, the TemporaryStore will remain available to the process(es) using it and a new TemporaryStore will be allocated and made available to the caller.
    It is important that processes do not hold a hard reference to a TemporaryStore beyond the end of the process as that will prevent the TemporaryStore from being finalized. Holding reference to an AbstractBTree created on a TemporaryStore is equivalent to holding a hard reference to the TemporaryStore itself since the AbstractBTree holds onto the backing IRawStore using a hard reference.
    
    Specified by:
    
    getTempStore in interface IIndexStore
    
    Returns:
    A TemporaryStore.
  - getHttpdURL
```
public String getHttpdURL()
```
    Description copied from interface: IBigdataFederation
    
    The URL that may be used to access the local httpd service for this client or service.
    
    Specified by:
    
    getHttpdURL in interface IBigdataFederation<AbstractResourceManagerTestCase.MockMetadataService>
    
    Returns:
    The URL -or- null if the httpd service is not running.
  - getServiceCounterSet
```
public CounterSet getServiceCounterSet()
```
    Description copied from interface: IBigdataFederation
    
    The node in IBigdataFederation.getCounters() corresponding to the root of the client or service connected using this federation.
    
    Specified by:
    
    getServiceCounterSet in interface IBigdataFederation<AbstractResourceManagerTestCase.MockMetadataService>
  - getDataServiceByName
```
public IDataService getDataServiceByName(String name)
```
    Description copied from interface: IBigdataFederation
    
    Return an IDataService joined with this IBigdataFederation and having the specified service name. Services that are not joined will not be discovered.
    Note: At least some service fabrics (such as jini) do not enforce a uniqueness constraint on the service name(s). In such cases an arbitrary IDataService method the other requirements will be returned. It is the responsibility of the administrator to ensure that each IDataService is assigned a distinct service name.
    
    Specified by:
    
    getDataServiceByName in interface IBigdataFederation<AbstractResourceManagerTestCase.MockMetadataService>
    
    Parameters:
    name - The service name.
    
    Returns:
    A service assigned that name -or- null if none is joined with the IBigdataFederation at this time.
  - getDataServices
```
public IDataService[] getDataServices(UUID[] uuid)
```
    Description copied from interface: IBigdataFederation
    
    Return an array of IDataService references that is correlated with the given array of IDataService UUIDs.
    Note: This method will also resolve the UUID of an IMetadataService.
    
    Specified by:
    
    getDataServices in interface IBigdataFederation<AbstractResourceManagerTestCase.MockMetadataService>
    
    Returns:
    The (meta)data service proxies.
  - didStart
```
public void didStart()
```
    Description copied from interface: IFederationDelegate
    
    Invoked by the AbstractFederation once the deferred startup tasks are executed. Services may use this event to perform additional initialization.
    
    Specified by:
    
    didStart in interface IFederationDelegate<AbstractResourceManagerTestCase.MockMetadataService>
  - getServiceIface
```
public Class getServiceIface()
```
    Description copied from interface: IFederationDelegate
    
    Return the class or interface that is the most interesting facet of the client and which will be used to identify this client in the performance counters reported to the ILoadBalancerService.
    
    Specified by:
    
    getServiceIface in interface IFederationDelegate<AbstractResourceManagerTestCase.MockMetadataService>
    
    Returns:
    The class or interface and never null.
  - getServiceName
```
public String getServiceName()
```
    Description copied from interface: IFederationDelegate
    
    Return a name for the service. It is up to administrators to ensure that service names are unique.
    
    Specified by:
    
    getServiceName in interface IFederationDelegate<AbstractResourceManagerTestCase.MockMetadataService>
    
    Returns:
    A name for the service.
  - getServiceUUID
```
public UUID getServiceUUID()
```
    Description copied from interface: IFederationDelegate
    
    The UUID assigned to the IBigdataClient or AbstractService.
    
    Specified by:
    
    getServiceUUID in interface IFederationDelegate<AbstractResourceManagerTestCase.MockMetadataService>
    
    See Also:
    AbstractService.setServiceUUID(UUID)
  - isServiceReady
```
public boolean isServiceReady()
```
    Description copied from interface: IFederationDelegate
    
    Return true iff the service is ready to start.
    
    Specified by:
    
    isServiceReady in interface IFederationDelegate<AbstractResourceManagerTestCase.MockMetadataService>
  - newHttpd
```
public AbstractHTTPD newHttpd(int httpdPort,
                     ICounterSetAccess access)
                       throws IOException
```
    Description copied from interface: IFederationDelegate
    
    Create a new AbstractHTTPD instance.
    
    Specified by:
    
    newHttpd in interface IFederationDelegate<AbstractResourceManagerTestCase.MockMetadataService>
    
    access - Used to materialize the CounterSet that will be served up.
    
    Returns:
    The httpd daemon.
    
    Throws:
    
    IOException
  - reattachDynamicCounters
```
public void reattachDynamicCounters()
```
    Description copied from interface: IFederationDelegate
    
    Offers the service an opportunity to dynamically detach and re-attach performance counters. This can be invoked either in response to an http GET or the periodic reporting of performance counters to the ILoadBalancerService. In general, implementations should limit the frequency of update, e.g., to no more than once a second.
    Note: For most purposes, this has been replaced by ICounterSetAccess which is now passed into CounterSetHTTPD. That provides the necessary indirection for periodic refresh of the performance counters. The CounterSetHTTPD now also handles the limitation on the update frequency for the materialized counters.
    However, there are still some counters which need to be dynamically reattached. For example, any counter set which is dynamic in its structure, such as the DirectBufferPool.
    
    Specified by:
    
    reattachDynamicCounters in interface IFederationDelegate<AbstractResourceManagerTestCase.MockMetadataService>
  - serviceJoin
```
public void serviceJoin(IService service,
               UUID serviceUUID)
```
    Description copied from interface: IFederationDelegate
    
    Notice that the service has been discovered. This notice will be generated the first time the service is discovered by a given IBigdataClient.
    
    Specified by:
    
    serviceJoin in interface IFederationDelegate<AbstractResourceManagerTestCase.MockMetadataService>
    
    Parameters:
    service - The service.
    serviceUUID - The service UUID.
  - serviceLeave
```
public void serviceLeave(UUID serviceUUID)
```
    Description copied from interface: IFederationDelegate
    
    Notice that the service is no longer available. This notice will be generated once for a given IBigdataClient when the service is no longer available from any of its service registrars.
    
    Specified by:
    
    serviceLeave in interface IFederationDelegate<AbstractResourceManagerTestCase.MockMetadataService>
    
    Parameters:
    serviceUUID - The service UUID.
  - getHostCounterSet
```
public CounterSet getHostCounterSet()
```
    Description copied from interface: IBigdataFederation
    
    The node in IBigdataFederation.getCounters() corresponding to the root of the host on which the client or service is executing.
    
    Specified by:
    
    getHostCounterSet in interface IBigdataFederation<AbstractResourceManagerTestCase.MockMetadataService>
  - addScheduledTask
```
public ScheduledFuture<?> addScheduledTask(Runnable task,
                                  long initialDelay,
                                  long delay,
                                  TimeUnit unit)
```
    Description copied from interface: IIndexStore
    
    Adds a task which will run until canceled, until it throws an exception, or until the service is shutdown.
    
    Specified by:
    
    addScheduledTask in interface IIndexStore
    
    Parameters:
    task - The task.
    initialDelay - The initial delay.
    delay - The delay between invocations.
    unit - The units for the delay parameters.
    
    Returns:
    The ScheduledFuture for that task.
  - getCollectPlatformStatistics
```
public boolean getCollectPlatformStatistics()
```
    Description copied from interface: IIndexStore
    
    true iff performance counters will be collected for the platform on which the client is running.
    
    Specified by:
    
    getCollectPlatformStatistics in interface IIndexStore
  - getCollectQueueStatistics
```
public boolean getCollectQueueStatistics()
```
    Description copied from interface: IIndexStore
    
    true iff statistics will be collected for work queues.
    
    Specified by:
    
    getCollectQueueStatistics in interface IIndexStore
  - getHttpdPort
```
public int getHttpdPort()
```
    Description copied from interface: IIndexStore
    
    The port on which the optional httpd service will be run. The httpd service exposes statistics about the client, its work queues, the platform on which it is running, etc. If this is ZERO (0), then the port will be chosen randomly.
    
    Specified by:
    
    getHttpdPort in interface IIndexStore
  - indexNameScan
```
public Iterator<String> indexNameScan(String prefix,
                             long timestamp)
```
    Description copied from interface: IGISTManager
    
    Iterator visits the names of all indices spanned by the given prefix.
    
    Specified by:
    
    indexNameScan in interface IGISTManager
    
    Parameters:
    prefix - The prefix (optional). When given, this MUST include a . if you want to restrict the scan to only those indices in a given namespace. Otherwise you can find indices in kb2 if you provide the prefix kb where both kb and kb2 are namespaces since the indices spanned by kb would include both kb.xyz and kb2.xyx.
    timestamp - A timestamp which represents either a possible commit time on the store or a read-only transaction identifier.
    
    Returns:
    An iterator visiting those index names.
  - isJiniFederation
```
public boolean isJiniFederation()
```
    Description copied from interface: IBigdataFederation
    
    Convenience method to return whether the Federation is a Jini Federation. Created in BLZG-1370 to factor our bigdata-jini dependency. This should return true IFF the instance is backed by a com.bigdata.service.jini.JiniFederation.
    
    Specified by:
    
    isJiniFederation in interface IBigdataFederation<AbstractResourceManagerTestCase.MockMetadataService>
    
    Returns:

Class AbstractResourceManagerTestCase.MockFederation

Constructor Summary

Method Summary

Methods inherited from class java.lang.Object

Constructor Detail

AbstractResourceManagerTestCase.MockFederation

Method Detail

getService

destroy

dropIndex

getAnyDataService

getClient

getServiceCounterPathPrefix

getCounters

getDataService

getDataServiceUUIDs

getExecutorService

getGlobalRowStore

getGlobalRowStore

getIndex

getKeyBuilder

getLoadBalancerService

getMetadataIndex

getMetadataService

getTransactionService

isDistributed

isScaleOut

isStable

isGroupCommit

getLastCommitTime

registerIndex

registerIndex

registerIndex

getResourceLocator

getResourceLockService

getGlobalFileSystem

getTempStore

getHttpdURL

getServiceCounterSet

getDataServiceByName

getDataServices

didStart

getServiceIface

getServiceName

getServiceUUID

isServiceReady

newHttpd

reattachDynamicCounters

serviceJoin

serviceLeave

getHostCounterSet

addScheduledTask

getCollectPlatformStatistics

getCollectQueueStatistics

getHttpdPort

indexNameScan

isJiniFederation