Class OpenIntegrationServiceBase
java.lang.Object
org.odpi.openmetadata.frameworks.integration.client.OpenIntegrationClient
org.odpi.openmetadata.frameworkservices.oif.client.OpenIntegrationServiceBase
- Direct Known Subclasses:
OpenIntegrationServiceClient
,OpenIntegrationServiceClient
,OpenIntegrationServiceClient
,OpenIntegrationServiceClient
,OpenIntegrationServiceClient
,OpenIntegrationServiceClient
,OpenIntegrationServiceClient
,OpenIntegrationServiceClient
,OpenIntegrationServiceClient
,OpenIntegrationServiceClient
,OpenIntegrationServiceClient
,OpenIntegrationServiceClient
,OpenIntegrationServiceClient
,OpenIntegrationServiceClient
,OpenIntegrationServiceClient
,OpenIntegrationServiceClient
,OpenIntegrationServiceClient
OpenIntegrationServiceBase supports the open integration interface.
-
Field Summary
Fields inherited from class org.odpi.openmetadata.frameworks.integration.client.OpenIntegrationClient
serverName, serverPlatformURLRoot, serviceURLMarker
-
Constructor Summary
ConstructorDescriptionOpenIntegrationServiceBase
(String serviceURLMarker, String serverName, String serverPlatformURLRoot, int maxPageSize) Create a new client with no authentication embedded in the HTTP request.OpenIntegrationServiceBase
(String serviceURLMarker, String serverName, String serverPlatformURLRoot, String serverUserId, String serverPassword, int maxPageSize) Create a new client that passes userId and password in each HTTP request.OpenIntegrationServiceBase
(String serviceURLMarker, String serverName, String serverPlatformURLRoot, OpenIntegrationRESTClient restClient, int maxPageSize) Create a new client that passes userId and password in each HTTP request. -
Method Summary
Modifier and TypeMethodDescriptionvoid
addCatalogTarget
(String userId, String integrationConnectorGUID, String metadataElementGUID, CatalogTargetProperties properties) Add a catalog target to an integration connector.createMetadataSource
(String userId, String softwareCapabilityTypeName, String classificationName, String qualifiedName, String deployedImplementationType) Create a new metadata element to represent a software capability.getAssetProperties
(String userId, String assetGUID) Returns a comprehensive collection of properties about the requested asset.getCatalogTarget
(String userId, String integrationConnectorGUID, String metadataElementGUID) Retrieve a specific catalog target associated with an integration connector.getCatalogTargets
(String userId, String integrationConnectorGUID, int startingFrom, int maximumResults) Retrieve the identifiers of the metadata elements identified as catalog targets with an integration connector.getConnectorToAsset
(String userId, String assetGUID) Return the connector to the requested asset.getIntegrationReport
(String userId, String reportGUID) Retrieve a specific integration report by unique identifier.getIntegrationReports
(String userId, Date afterCompletionDate, Date beforeStartDate, int startingFrom, int maximumResults) Retrieve the published integration reports.getIntegrationReportsForElement
(String userId, String elementGUID, Date afterCompletionDate, Date beforeStartDate, int startingFrom, int maximumResults) Retrieve the integration reports attached to an element.getMetadataSourceGUID
(String userId, String qualifiedName) Retrieve the unique identifier of the metadata element that represents the metadata source.void
publishIntegrationReport
(String userId, String anchorGUID, String anchorTypeName, IntegrationReportProperties properties) Create a new integration report for an element (identified by anchorGUID).void
removeCatalogTarget
(String userId, String integrationConnectorGUID, String metadataElementGUID) Unregister a catalog target from the integration connector.saveConnection
(String userId, String assetGUID, Connection connection) Returns the unique identifier corresponding to the supplied connection.saveConnection
(String userId, Connection connection) Returns the unique identifier corresponding to the supplied connection.
-
Constructor Details
-
OpenIntegrationServiceBase
public OpenIntegrationServiceBase(String serviceURLMarker, String serverName, String serverPlatformURLRoot, int maxPageSize) throws InvalidParameterException Create a new client with no authentication embedded in the HTTP request.- Parameters:
serviceURLMarker
- the identifier of the access service (for example asset-owner for the Asset Owner OMAS)serverName
- name of the server to connect toserverPlatformURLRoot
- the network address of the server running the OMAS REST servicesmaxPageSize
- maximum value allowed for page size- Throws:
InvalidParameterException
- there is a problem creating the client-side components to issue any REST API calls.
-
OpenIntegrationServiceBase
public OpenIntegrationServiceBase(String serviceURLMarker, String serverName, String serverPlatformURLRoot, String serverUserId, String serverPassword, int maxPageSize) throws InvalidParameterException Create a new client that passes userId and password in each HTTP request. This is the userId/password of the calling server. The end user's userId is sent on each request.- Parameters:
serviceURLMarker
- the identifier of the access service (for example asset-owner for the Asset Owner OMAS)serverName
- name of the server to connect toserverPlatformURLRoot
- the network address of the server running the OMAS REST servicesserverUserId
- caller's userId embedded in all HTTP requestsserverPassword
- caller's password embedded in all HTTP requestsmaxPageSize
- maximum value allowed for page size- Throws:
InvalidParameterException
- there is a problem creating the client-side components to issue any REST API calls.
-
OpenIntegrationServiceBase
public OpenIntegrationServiceBase(String serviceURLMarker, String serverName, String serverPlatformURLRoot, OpenIntegrationRESTClient restClient, int maxPageSize) throws InvalidParameterException Create a new client that passes userId and password in each HTTP request. This is the userId/password of the calling server. The end user's userId is sent on each request.- Parameters:
serviceURLMarker
- the identifier of the access service (for example asset-owner for the Asset Owner OMAS)serverName
- name of the server to connect toserverPlatformURLRoot
- the network address of the server running the OMAS REST servicesrestClient
- pre-initialized REST clientmaxPageSize
- pre-initialized parameter limit- Throws:
InvalidParameterException
- there is a problem with the information about the remote OMAS
-
-
Method Details
-
getMetadataSourceGUID
public String getMetadataSourceGUID(String userId, String qualifiedName) throws InvalidParameterException, UserNotAuthorizedException, PropertyServerException Retrieve the unique identifier of the metadata element that represents the metadata source.- Specified by:
getMetadataSourceGUID
in classOpenIntegrationClient
- Parameters:
userId
- calling userqualifiedName
- unique name of the metadata source- Returns:
- unique identifier of the metadata source
- Throws:
InvalidParameterException
- the bean properties are invalidUserNotAuthorizedException
- user not authorized to issue this requestPropertyServerException
- problem accessing the property server
-
createMetadataSource
public String createMetadataSource(String userId, String softwareCapabilityTypeName, String classificationName, String qualifiedName, String deployedImplementationType) throws InvalidParameterException, UserNotAuthorizedException, PropertyServerException Create a new metadata element to represent a software capability. This describes the metadata source.- Specified by:
createMetadataSource
in classOpenIntegrationClient
- Parameters:
userId
- calling usersoftwareCapabilityTypeName
- name of software capability type to describe the metadata sourceclassificationName
- optional classification name that refines the type of the software capability.qualifiedName
- unique name for the external sourcedeployedImplementationType
- type of technology- Returns:
- unique identifier of the new metadata element
- Throws:
InvalidParameterException
- one of the parameters is invalidUserNotAuthorizedException
- the user is not authorized to issue this requestPropertyServerException
- there is a problem reported in the open metadata server(s)
-
addCatalogTarget
public void addCatalogTarget(String userId, String integrationConnectorGUID, String metadataElementGUID, CatalogTargetProperties properties) throws InvalidParameterException, UserNotAuthorizedException, PropertyServerException Add a catalog target to an integration connector.- Specified by:
addCatalogTarget
in classOpenIntegrationClient
- Parameters:
userId
- identifier of calling user.integrationConnectorGUID
- unique identifier of the integration service.metadataElementGUID
- unique identifier of the metadata element that is a catalog target.properties
- properties for the relationship.- Throws:
InvalidParameterException
- one of the parameters is null or invalid.UserNotAuthorizedException
- user not authorized to issue this request.PropertyServerException
- problem storing the catalog target definition.
-
getCatalogTarget
public CatalogTarget getCatalogTarget(String userId, String integrationConnectorGUID, String metadataElementGUID) throws InvalidParameterException, UserNotAuthorizedException, PropertyServerException Retrieve a specific catalog target associated with an integration connector.- Specified by:
getCatalogTarget
in classOpenIntegrationClient
- Parameters:
userId
- identifier of calling user.integrationConnectorGUID
- unique identifier of the integration service.metadataElementGUID
- unique identifier of the metadata element that is a catalog target.- Returns:
- details of the integration connector and the elements it is to catalog
- Throws:
InvalidParameterException
- one of the parameters is null or invalid.UserNotAuthorizedException
- user not authorized to issue this request.PropertyServerException
- problem retrieving the integration connector definition.
-
getCatalogTargets
public List<CatalogTarget> getCatalogTargets(String userId, String integrationConnectorGUID, int startingFrom, int maximumResults) throws InvalidParameterException, UserNotAuthorizedException, PropertyServerException Retrieve the identifiers of the metadata elements identified as catalog targets with an integration connector.- Specified by:
getCatalogTargets
in classOpenIntegrationClient
- Parameters:
userId
- identifier of calling user.integrationConnectorGUID
- unique identifier of the integration connector.startingFrom
- initial position in the stored list.maximumResults
- maximum number of definitions to return on this call.- Returns:
- list of named elements
- Throws:
InvalidParameterException
- one of the parameters is null or invalid,UserNotAuthorizedException
- user not authorized to issue this request.PropertyServerException
- problem retrieving the integration connector definition.
-
removeCatalogTarget
public void removeCatalogTarget(String userId, String integrationConnectorGUID, String metadataElementGUID) throws InvalidParameterException, UserNotAuthorizedException, PropertyServerException Unregister a catalog target from the integration connector.- Specified by:
removeCatalogTarget
in classOpenIntegrationClient
- Parameters:
userId
- identifier of calling user.integrationConnectorGUID
- unique identifier of the integration connector.metadataElementGUID
- unique identifier of the metadata element.- Throws:
InvalidParameterException
- one of the parameters is null or invalid.UserNotAuthorizedException
- user not authorized to issue this request.PropertyServerException
- problem accessing/updating the integration connector definition.
-
publishIntegrationReport
public void publishIntegrationReport(String userId, String anchorGUID, String anchorTypeName, IntegrationReportProperties properties) throws InvalidParameterException, UserNotAuthorizedException, PropertyServerException Create a new integration report for an element (identified by anchorGUID).- Specified by:
publishIntegrationReport
in classOpenIntegrationClient
- Parameters:
userId
- calling useranchorGUID
- element to attach the integration report toanchorTypeName
- type of element element to attach the integration report toproperties
- properties of the report- Throws:
InvalidParameterException
- one of the parameters is null or invalid,UserNotAuthorizedException
- user not authorized to issue this request.PropertyServerException
- problem with the metadata server.
-
getIntegrationReport
public IntegrationReport getIntegrationReport(String userId, String reportGUID) throws InvalidParameterException, UserNotAuthorizedException, PropertyServerException Retrieve a specific integration report by unique identifier.- Specified by:
getIntegrationReport
in classOpenIntegrationClient
- Parameters:
userId
- calling userreportGUID
- unique identifier of the integration report- Returns:
- report or null
- Throws:
InvalidParameterException
- one of the parameters is null or invalid,UserNotAuthorizedException
- user not authorized to issue this request.PropertyServerException
- problem with the metadata server.
-
getIntegrationReportsForElement
public List<IntegrationReport> getIntegrationReportsForElement(String userId, String elementGUID, Date afterCompletionDate, Date beforeStartDate, int startingFrom, int maximumResults) throws InvalidParameterException, UserNotAuthorizedException, PropertyServerException Retrieve the integration reports attached to an element. The list can be filtered by start and completion date of the report along with the paging options if there are many integration reports.- Specified by:
getIntegrationReportsForElement
in classOpenIntegrationClient
- Parameters:
userId
- calling userelementGUID
- calling userafterCompletionDate
- restrict reports to those that completed after the requested time (null for any completion time).beforeStartDate
- restrict reports to those that started before the requested time (null for any start time).startingFrom
- initial position in the stored list.maximumResults
- maximum number of definitions to return on this call.- Returns:
- list of qualifying reports
- Throws:
InvalidParameterException
- one of the parameters is null or invalid,UserNotAuthorizedException
- user not authorized to issue this request.PropertyServerException
- problem with the metadata server.
-
getIntegrationReports
public List<IntegrationReport> getIntegrationReports(String userId, Date afterCompletionDate, Date beforeStartDate, int startingFrom, int maximumResults) throws InvalidParameterException, UserNotAuthorizedException, PropertyServerException Retrieve the published integration reports. The list can be filtered by start and completion date of the report along with the paging options if there are many integration reports.- Specified by:
getIntegrationReports
in classOpenIntegrationClient
- Parameters:
userId
- calling userafterCompletionDate
- restrict reports to those that completed after the requested time (null for any completion time).beforeStartDate
- restrict reports to those that started before the requested time (null for any start time).startingFrom
- initial position in the stored list.maximumResults
- maximum number of definitions to return on this call.- Returns:
- list of qualifying reports
- Throws:
InvalidParameterException
- one of the parameters is null or invalid,UserNotAuthorizedException
- user not authorized to issue this request.PropertyServerException
- problem with the metadata server.
-
saveConnection
public String saveConnection(String userId, Connection connection) throws InvalidParameterException, PropertyServerException, UserNotAuthorizedException, ConnectionCheckedException, ConnectorCheckedException Returns the unique identifier corresponding to the supplied connection.- Specified by:
saveConnection
in classOpenIntegrationClient
- Parameters:
connection
- the connection object that contains the properties needed to create the connection.- Returns:
- guid
- Throws:
InvalidParameterException
- one of the parameters is null or invalid.PropertyServerException
- there is a problem retrieving the asset properties from the property servers.UserNotAuthorizedException
- the requesting user is not authorized to issue this request.ConnectionCheckedException
- there are errors in the configuration of the connection which is preventing the creation of a connector.ConnectorCheckedException
- there are errors in the initialization of the connector.
-
saveConnection
public String saveConnection(String userId, String assetGUID, Connection connection) throws InvalidParameterException, PropertyServerException, UserNotAuthorizedException, ConnectionCheckedException, ConnectorCheckedException Returns the unique identifier corresponding to the supplied connection.- Specified by:
saveConnection
in classOpenIntegrationClient
- Parameters:
assetGUID
- the unique identifier of an asset to attach the connection toconnection
- the connection object that contains the properties needed to create the connection.- Returns:
- guid
- Throws:
InvalidParameterException
- one of the parameters is null or invalid.PropertyServerException
- there is a problem retrieving the asset properties from the property servers.UserNotAuthorizedException
- the requesting user is not authorized to issue this request.ConnectionCheckedException
- there are errors in the configuration of the connection which is preventing the creation of a connector.ConnectorCheckedException
- there are errors in the initialization of the connector.
-
getAssetProperties
public AssetUniverse getAssetProperties(String userId, String assetGUID) throws InvalidParameterException, PropertyServerException, UserNotAuthorizedException Returns a comprehensive collection of properties about the requested asset.- Specified by:
getAssetProperties
in classOpenIntegrationClient
- Parameters:
assetGUID
- the unique identifier of an asset to attach the connection to- Returns:
- a comprehensive collection of properties about the asset.
- Throws:
InvalidParameterException
- one of the parameters is null or invalid.PropertyServerException
- there is a problem retrieving the asset properties from the property servers.UserNotAuthorizedException
- the requesting user is not authorized to issue this request.
-
getConnectorToAsset
public Connector getConnectorToAsset(String userId, String assetGUID) throws InvalidParameterException, PropertyServerException, UserNotAuthorizedException, ConnectionCheckedException, ConnectorCheckedException Return the connector to the requested asset.- Specified by:
getConnectorToAsset
in classOpenIntegrationClient
- Parameters:
assetGUID
- the unique identifier of an asset to attach the connection to- Returns:
- Open Connector Framework (OCF) connector
- Throws:
InvalidParameterException
- the asset guid is not recognized or the userId is nullConnectionCheckedException
- there are errors in the configuration of the connection which is preventing the creation of a connector.ConnectorCheckedException
- there are errors in the initialization of the connector.UserNotAuthorizedException
- the user is not authorized to access the asset and/or connection needed to create the connector.PropertyServerException
- there was a problem in the store whether the asset/connection properties are kept.
-