public class SourceOperations extends DescribableImpl
CatalogFrameworkImpl
.
This class contains two delegated source methods and methods to support them. No operations/support methods should be added to this class except in support of CFI source operations.
Constructor and Description |
---|
SourceOperations(FrameworkProperties frameworkProperties) |
Modifier and Type | Method and Description |
---|---|
void |
bind(CatalogProvider catalogProvider)
Invoked by blueprint when a
CatalogProvider is created and bound to this
CatalogFramework instance. |
void |
bind(StorageProvider storageProvider)
Invoked by blueprint when a
StorageProvider is created and bound to this
CatalogFramework instance. |
CatalogProvider |
getCatalog() |
Set<String> |
getSourceIds(boolean fanoutEnabled) |
SourceInfoResponse |
getSourceInfo(SourceInfoRequest sourceInfoRequest,
boolean fanoutEnabled) |
StorageProvider |
getStorage() |
void |
unbind(CatalogProvider catalogProvider)
Invoked by blueprint when a
CatalogProvider is deleted and unbound from this
CatalogFramework instance. |
void |
unbind(StorageProvider storageProvider)
Invoked by blueprint when a
StorageProvider is deleted and unbound from this
CatalogFramework instance. |
getDescription, getId, getOrganization, getTitle, getVersion, setDescription, setId, setOrganization, setShortname, setTitle, setVersion
public SourceOperations(FrameworkProperties frameworkProperties)
public void bind(CatalogProvider catalogProvider)
CatalogProvider
is created and bound to this
CatalogFramework instance.
The local catalog provider will be set to the first item in the List
of
CatalogProvider
s bound to this CatalogFramework.
catalogProvider
- the CatalogProvider
being bound to this CatalogFramework
instancepublic void unbind(CatalogProvider catalogProvider)
CatalogProvider
is deleted and unbound from this
CatalogFramework instance.
The local catalog provider will be reset to the new first item in the List
of CatalogProvider
s bound to this CatalogFramework. If this list of catalog providers
is currently empty, then the local catalog provider will be set to null
.
catalogProvider
- the CatalogProvider
being unbound from this CatalogFramework
instancepublic void bind(StorageProvider storageProvider)
StorageProvider
is created and bound to this
CatalogFramework instance.
The local storage provider will be set to the first item in the List
of StorageProvider
s bound to this CatalogFramework.
storageProvider
- the CatalogProvider
being bound to this CatalogFramework
instancepublic void unbind(StorageProvider storageProvider)
StorageProvider
is deleted and unbound from this
CatalogFramework instance.
The local storage provider will be reset to the new first item in the List
of StorageProvider
s bound to this CatalogFramework. If this list of storage providers is
currently empty, then the local storage provider will be set to null
.
storageProvider
- the StorageProvider
being unbound from this CatalogFramework
instancepublic CatalogProvider getCatalog()
public StorageProvider getStorage()
public SourceInfoResponse getSourceInfo(SourceInfoRequest sourceInfoRequest, boolean fanoutEnabled) throws SourceUnavailableException
SourceUnavailableException
This work is licensed under a Creative Commons Attribution 4.0 International License.