org.diirt.datasource

Class CompositeDataSource

java.lang.Object

org.diirt.datasource.DataSource

org.diirt.datasource.CompositeDataSource

public class CompositeDataSource
extends DataSource

A data source that can dispatch a request to multiple different data sources.

Author:

carcassi

Constructor Summary

Constructors

Constructor and Description
CompositeDataSource() Creates a new CompositeDataSource.

Method Summary

Modifier and Type	Method and Description
void	close() Closes all DataSources that are registered in the composite.
void	connectRead(ReadRecipe readRecipe) Connects to a set of channels based on the given recipe.
void	connectWrite(WriteRecipe writeRecipe) Prepares the channels defined in the write recipe for writes.
protected ChannelHandler	createChannel(String channelName) Creates a channel handler for the given name.
void	disconnectRead(ReadRecipe readRecipe) Disconnects the set of channels given by the recipe.
void	disconnectWrite(WriteRecipe writeRecipe) Releases the resources associated with the given write recipe.
Map<String,ChannelHandler>	getChannels() Returns the channel handlers for this data source.
CompositeDataSourceConfiguration	getConfiguration() The configuration used for the composite data source.
Map<String,DataSourceProvider>	getDataSourceProviders() Returns the data source providers registered to this composite data source.
Map<String,DataSource>	getDataSources() Returns the data sources used by this composite data source.
void	putDataSource(DataSourceProvider dataSourceProvider) Adds/replaces the data source corresponding to the given name.
void	putDataSource(String name, DataSource dataSource) Adds/replaces the data source corresponding to the given name.
void	setConfiguration(CompositeDataSourceConfiguration conf) Changes the composite data source configuration.

Methods inherited from class org.diirt.datasource.DataSource

channelHandlerLookupName, channelHandlerRegisterName, isWriteable, write

Methods inherited from class java.lang.Object

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

Constructor Detail

CompositeDataSource

public CompositeDataSource()

Creates a new CompositeDataSource.

Method Detail

getConfiguration

public CompositeDataSourceConfiguration getConfiguration()

The configuration used for the composite data source.

Returns:

the configuration; can't be null

setConfiguration

public void setConfiguration(CompositeDataSourceConfiguration conf)

Changes the composite data source configuration.

NOTE: the configuration should be changed before any channel is opened. The result of later changes is not well defined.

Parameters:

conf - the new configuration; can't be null

putDataSource

public void putDataSource(String name,
                          DataSource dataSource)

Adds/replaces the data source corresponding to the given name.

Parameters:

name - the name of the data source

dataSource - the data source to add/replace

putDataSource

public void putDataSource(DataSourceProvider dataSourceProvider)

Adds/replaces the data source corresponding to the given name.

Parameters:

dataSourceProvider - the data source to add/replace

getDataSources

public Map<String,DataSource> getDataSources()

Returns the data sources used by this composite data source.

Returns only the data sources that have been created.

Returns:

the registered data sources

getDataSourceProviders

public Map<String,DataSourceProvider> getDataSourceProviders()

Returns the data source providers registered to this composite data source.

Returns all registered data sources.

Returns:

the registered data source providers

connectRead

public void connectRead(ReadRecipe readRecipe)

Description copied from class: DataSource

Connects to a set of channels based on the given recipe.

The data source must update the value caches relative to each channel. Before updating any cache, it must lock the collector relative to that cache and after any update it must notify the collector.

Overrides:

connectRead in class DataSource

Parameters:

readRecipe - the instructions for the data connection

disconnectRead

public void disconnectRead(ReadRecipe readRecipe)

Description copied from class: DataSource

Disconnects the set of channels given by the recipe.

The disconnect call is guaranteed to be given the same object, so that the recipe itself can be used as a key in a map to retrieve the list of resources needed to be closed.

Overrides:

disconnectRead in class DataSource

Parameters:

readRecipe - the instructions for the data connection

connectWrite

public void connectWrite(WriteRecipe writeRecipe)

Description copied from class: DataSource

Prepares the channels defined in the write recipe for writes.

If these are channels over the network, it will create the network connections with the underlying libraries.

Overrides:

connectWrite in class DataSource

Parameters:

writeRecipe - the recipe that will contain the write data

disconnectWrite

public void disconnectWrite(WriteRecipe writeRecipe)

Description copied from class: DataSource

Releases the resources associated with the given write recipe.

Will close network channels and deallocate memory needed.

Overrides:

disconnectWrite in class DataSource

Parameters:

writeRecipe - the recipe that will no longer be used

createChannel

protected ChannelHandler createChannel(String channelName)

Description copied from class: DataSource

Creates a channel handler for the given name. In the simplest case, this is the only method a data source needs to implement.

Specified by:

createChannel in class DataSource

Parameters:

channelName - the name for a new channel

Returns:

a new handler

close

public void close()

Closes all DataSources that are registered in the composite.

Overrides:

close in class DataSource

getChannels

public Map<String,ChannelHandler> getChannels()

Description copied from class: DataSource

Returns the channel handlers for this data source.

Overrides:

getChannels in class DataSource

Returns:

an unmodifiable collection