Class OMAGServerAdminServices
java.lang.Object
org.odpi.openmetadata.adminservices.server.OMAGServerAdminServices
OMAGServerAdminServices provides part of the server-side implementation of the administrative interface for
an Open Metadata and Governance (OMAG) Server. In particular, this class supports the configuration
of the server name, server type and organization name. It also supports the setting up of the
Open Metadata Repository Services' local repository and cohort.
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptionaddAuditLogDestination
(String userId, String serverName, Connection auditLogDestination) Set up the list of audit log destinations.addCohortRegistration
(String userId, String serverName, String cohortName, CohortTopicStructure cohortTopicStructure, Map<String, Object> configurationProperties) Enable registration of server to an open metadata repository cohort.addConsoleAuditLogDestination
(String userId, String serverName, List<String> supportedSeverities) Set up the console (stdout) audit log destination for the server.addEventTopicAuditLogDestination
(String userId, String serverName, String topicName, List<String> supportedSeverities) Set up the File based audit log destination for the server.addFileAuditLogDestination
(String userId, String serverName, String directoryName, List<String> supportedSeverities) Set up the File based audit log destination for the server.addPostgreSQLAuditLogDestination
(String userId, String serverName, Map<String, Object> storageProperties) Set up the JDBC based audit log destination for the server.addSLF4JAuditLogDestination
(String userId, String serverName, List<String> supportedSeverities) Set up the SLF4J audit log destination for the server.addStartUpOpenMetadataArchiveFile
(String userId, String serverName, String fileName) Add a new open metadata archive to load at startup.clearAuditLogDestination
(String userId, String serverName, String suppliedConnectionName) Delete an audit log destination connection, that is identified with the supplied destination connection name.clearAuditLogDestinations
(String userId, String serverName) Clear the list of audit log destinations.clearCohortConfig
(String userId, String serverName, String cohortName) Set up the mode for an open metadata repository cohort.clearLocalRepositoryConfig
(String userId, String serverName) Remove all configuration for a local repository.clearOMAGServerConfig
(String userId, String serverName) Remove the configuration for the server.clearOpenMetadataArchives
(String userId, String serverName) Clear the list of open metadata archives for loading at server startup.deleteEventBus
(String userId, String serverName) Delete the current configuration for the event bus.deployOMAGServerConfig
(String userId, String serverName, URLRequestBody destinationPlatform) Push the configuration for the server to another OMAG Server Platform.getAuditLogDestinations
(String userId, String serverName) Return the list of audit log destinations.getBasicServerProperties
(String userId, String serverName) Set up the basic server properties in a single request.getCohortConfig
(String userId, String serverName, String cohortName) Return the current configuration for a cohort.getCohortTopicName
(String userId, String serverName, String cohortName) Retrieve the topic name that is used by this server to contact the other members of the open metadata repository cohort.getDedicatedCohortTopicNames
(String userId, String serverName, String cohortName) Retrieve the current topic names for the three dedicated topics of the cohort.getEventBus
(String userId, String serverName) Return the current configuration for the event bus.getLocalMetadataCollectionId
(String userId, String serverName) Return the local metadata collection id.getLocalMetadataCollectionName
(String userId, String serverName) Return the local metadata collection id.getLocalRepositoryConfig
(String userId, String serverName) Return the configuration for the local repository.getOpenMetadataArchives
(String userId, String serverName) Return the list of open metadata archives.getServerTypeClassification
(String userId, String serverName) Return the derived server type that is created from the classification of the server configuration.getStoredConfiguration
(String userId, String serverName) Return the complete set of configuration properties in use by the server.overrideCohortTopicName
(String userId, String serverName, String cohortName, String topicName) Change the topic name that is used by this server to contact the other members of the open metadata repository cohort.overrideInstancesCohortTopicName
(String userId, String serverName, String cohortName, String topicName) Change the topic name that is used by this server to exchange metadata instances with the other members of the open metadata repository cohort.overrideRegistrationCohortTopicName
(String userId, String serverName, String cohortName, String topicName) Change the topic name that is used by this server to register members in the open metadata repository cohort.overrideTypesCohortTopicName
(String userId, String serverName, String cohortName, String topicName) Change the topic name that is used by this server to verify type consistency with the other members of the open metadata repository cohort.resetRemoteCohortURL
(String userId, String serverName, URLRequestBody requestBody) Update the URL broadcast across the cohort to allow other members to issue queries to this repository.retrieveAllServerConfigs
(String userId) Return the stored configuration documents stored on the platformsetAuditLogDestinations
(String userId, String serverName, List<Connection> auditLogDestinations) Set up the list of audit log destinations.setBasicServerProperties
(String userId, String serverName, ServerPropertiesRequestBody requestBody) Set up the basic server properties in a single request.setCohortConfig
(String userId, String serverName, String cohortName, CohortConfig cohortConfig) Set up the configuration properties for a cohort.setDefaultAuditLog
(String userId, String serverName, NullRequestBody requestBody) Set up the default audit log for the server.setEventBus
(String userId, String serverName, String connectorProvider, String topicURLRoot, Map<String, Object> configurationProperties) Set up the default event bus for embedding in event-driven connector.Set up a graph store as the local repository.setInMemLocalRepository
(String userId, String serverName, NullRequestBody requestBody) Set up an in memory local repository.setLocalMetadataCollectionId
(String userId, String serverName, String metadataCollectionId) Return the local metadata collection id.setLocalMetadataCollectionName
(String userId, String serverName, String localMetadataCollectionName) Set up the local metadata collection name.setLocalRepositoryConfig
(String userId, String serverName, LocalRepositoryConfig localRepositoryConfig) Set up the configuration for the local repository.setMaxPageSize
(String userId, String serverName, int maxPageSize) Set an upper limit in the page size that can be requested on a REST call to the server.setNoRepositoryMode
(String userId, String serverName) Remove all configuration for a local repository.setOMAGServerConfig
(String userId, String serverName, OMAGServerConfig omagServerConfig) Set up the configuration properties for an OMAG Server in a single command.setOpenMetadataArchives
(String userId, String serverName, List<Connection> openMetadataArchives) Set up the list of open metadata archives.setOrganizationName
(String userId, String serverName, String name) Set up the name of the organization that is running this server.setPluginRepositoryConnection
(String userId, String serverName, String connectorProvider, Map<String, Object> additionalProperties) Provide the connection to the local repository.setPluginRepositoryConnection
(String userId, String serverName, Connection connection) Provide the connection to the local repository - used when the local repository mode is set to plugin repository.Set up a PostgreSQL Database Schema as the local repository.setReadOnlyLocalRepository
(String userId, String serverName) Set up a read only store as the local repository.setRepositoryProxyConnection
(String userId, String serverName, String connectorProvider, Map<String, Object> additionalProperties) Provide the connection to the local repository.setRepositoryProxyConnection
(String userId, String serverName, Connection connection) Provide the connection to the local repository - used when the local repository mode is set to repository proxy.setRepositoryProxyEventMapper
(String userId, String serverName, String connectorProvider, String eventSource, Map<String, Object> additionalProperties) Provide the connection to the local repository's event mapper if needed.setRepositoryProxyEventMapper
(String userId, String serverName, Connection connection) Provide the connection to the local repository's event mapper if needed.setServerDescription
(String userId, String serverName, String description) Set up the description of this server.setServerPassword
(String userId, String serverName, String serverPassword) Set up the user id to use when there is no external user driving the work (for example when processing events from another server).setServerRootURL
(String userId, String serverName, URLRequestBody requestBody) Set up the root URL for this server that is used to construct full URL paths to calls for this server's REST interfaces that is used by other members of the cohorts that this server connects to.setServerType
(String userId, String serverName, String typeName) Set up the descriptive type of the server.setServerURLRoot
(String userId, String serverName, String url) Deprecated.setServerUserId
(String userId, String serverName, String serverUserId) Set up the user id to use when there is no external user driving the work (for example when processing events from another server).setXTDBInMemRepository
(String userId, String serverName, NullRequestBody requestBody) Set up an XTDB store as the local repository.setXTDBLocalKVRepository
(String userId, String serverName, NullRequestBody requestBody) Set up an XTDB store as the local repository.Set up an XTDB store as the local repository.updateAuditLogDestination
(String userId, String serverName, String suppliedConnectionName, Connection suppliedConnection) Update an audit log destination connection that is identified with the supplied destination connection name with the supplied connection object.
-
Constructor Details
-
OMAGServerAdminServices
public OMAGServerAdminServices()
-
-
Method Details
-
getServerTypeClassification
public ServerTypeClassificationResponse getServerTypeClassification(String userId, String serverName) Return the derived server type that is created from the classification of the server configuration.- Parameters:
userId
- user that is issuing the request.serverName
- local server name.- Returns:
- server type classification response or OMAGNotAuthorizedException the supplied userId is not authorized to issue this command or OMAGInvalidParameterException invalid serverName or serverType parameter.
-
setServerType
Set up the descriptive type of the server. This value is added to distributed events to make it easier to understand the source of events. The default value is "Open Metadata and Governance Server".- Parameters:
userId
- user that is issuing the request.serverName
- local server name.typeName
- short description for the type of server.- Returns:
- void response or OMAGNotAuthorizedException the supplied userId is not authorized to issue this command or OMAGInvalidParameterException invalid serverName or serverType parameter.
-
setOrganizationName
Set up the name of the organization that is running this server. This value is added to distributed events to make it easier to understand the source of events. The default value is null.- Parameters:
userId
- user that is issuing the request.serverName
- local server name.name
- String name of the organization.- Returns:
- void response or OMAGNotAuthorizedException the supplied userId is not authorized to issue this command or OMAGInvalidParameterException invalid serverName or organizationName parameter.
-
setServerDescription
Set up the description of this server. The default value is null.- Parameters:
userId
- user that is issuing the request.serverName
- local server description.description
- String description of the server.- Returns:
- void response or OMAGNotAuthorizedException the supplied userId is not authorized to issue this command or OMAGInvalidParameterException invalid serverName or organizationName parameter.
-
setServerUserId
Set up the user id to use when there is no external user driving the work (for example when processing events from another server).- Parameters:
userId
- user that is issuing the request.serverName
- local server name.serverUserId
- String user is for the server.- Returns:
- void response or OMAGNotAuthorizedException the supplied userId is not authorized to issue this command or OMAGInvalidParameterException invalid serverName or serverURLRoot parameter.
-
setServerPassword
Set up the user id to use when there is no external user driving the work (for example when processing events from another server).- Parameters:
userId
- user that is issuing the request.serverName
- local server name.serverPassword
- String password for the server.- Returns:
- void response or OMAGNotAuthorizedException the supplied userId is not authorized to issue this command or OMAGInvalidParameterException invalid serverName or serverURLRoot parameter.
-
setMaxPageSize
Set an upper limit in the page size that can be requested on a REST call to the server. The default value is 1000.- Parameters:
userId
- - user that is issuing the request.serverName
- - local server name.maxPageSize
- - max number of elements that can be returned on a request.- Returns:
- void response or OMAGNotAuthorizedException the supplied userId is not authorized to issue this command or OMAGInvalidParameterException invalid serverName or maxPageSize parameter.
-
setBasicServerProperties
public VoidResponse setBasicServerProperties(String userId, String serverName, ServerPropertiesRequestBody requestBody) Set up the basic server properties in a single request.- Parameters:
userId
- user that is issuing the request.serverName
- local server name.requestBody
- property details- Returns:
- void response or OMAGNotAuthorizedException the supplied userId is not authorized to issue this command or OMAGInvalidParameterException invalid serverName or maxPageSize parameter.
-
getBasicServerProperties
Set up the basic server properties in a single request.- Parameters:
userId
- user that is issuing the request.serverName
- local server name.- Returns:
- properties response or OMAGNotAuthorizedException the supplied userId is not authorized to issue this command or OMAGInvalidParameterException invalid serverName or maxPageSize parameter.
-
setEventBus
public VoidResponse setEventBus(String userId, String serverName, String connectorProvider, String topicURLRoot, Map<String, Object> configurationProperties) Set up the default event bus for embedding in event-driven connector. The resulting connector will be used in the OMRS Topic Connector for each cohort, the in and out topics for each Access Service and the local repositories event mapper. When the event bus is configured, it is used only on future configuration. It does not affect existing configuration.- Parameters:
userId
- user that is issuing the request.serverName
- local server name.connectorProvider
- connector provider for the event bus (if it is null then Kafka is assumed).topicURLRoot
- the common root of the topics used by the open metadata server.configurationProperties
- property name/value pairs used to configure the connection to the event bus connector- Returns:
- void response or OMAGNotAuthorizedException the supplied userId is not authorized to issue this command or OMAGConfigurationErrorException it is too late to configure the event bus - other configuration already exists or OMAGInvalidParameterException invalid serverName parameter.
-
getEventBus
Return the current configuration for the event bus.- Parameters:
userId
- user that is issuing the request.serverName
- local server name.- Returns:
- event bus config response or OMAGNotAuthorizedException the supplied userId is not authorized to issue this command or OMAGConfigurationErrorException it is too late to configure the event bus - other configuration already exists or OMAGInvalidParameterException invalid serverName parameter.
-
deleteEventBus
Delete the current configuration for the event bus.- Parameters:
userId
- user that is issuing the request.serverName
- local server name.- Returns:
- void or OMAGNotAuthorizedException the supplied userId is not authorized to issue this command or OMAGConfigurationErrorException it is too late to configure the event bus - other configuration already exists or OMAGInvalidParameterException invalid serverName parameter.
-
setServerURLRoot
Deprecated.Set up the root URL for this server that is used to construct full URL paths to calls for this server's REST interfaces that is used by other members of the cohorts that this server connects to. The default value is "localhost:9443". ServerURLRoot is used during the configuration of the local repository. If called after the local repository is configured, it has no effect.- Parameters:
userId
- user that is issuing the request.serverName
- local server name.url
- String url.- Returns:
- void response or OMAGNotAuthorizedException the supplied userId is not authorized to issue this command or OMAGInvalidParameterException invalid serverName or serverURLRoot parameter.
-
setServerRootURL
Set up the root URL for this server that is used to construct full URL paths to calls for this server's REST interfaces that is used by other members of the cohorts that this server connects to. The default value is "localhost:9443". ServerURLRoot is used during the configuration of the local repository. If called after the local repository is configured, it has no effect.- Parameters:
userId
- user that is issuing the request.serverName
- local server name.requestBody
- String url.- Returns:
- void response or OMAGNotAuthorizedException the supplied userId is not authorized to issue this command or OMAGInvalidParameterException invalid serverName or serverURLRoot parameter or OMAGConfigurationErrorException unusual state in the admin server.
-
setDefaultAuditLog
public VoidResponse setDefaultAuditLog(String userId, String serverName, NullRequestBody requestBody) Set up the default audit log for the server.- Parameters:
userId
- user that is issuing the request.serverName
- local server name.requestBody
- null request body- Returns:
- void response or OMAGNotAuthorizedException the supplied userId is not authorized to issue this command or OMAGInvalidParameterException invalid serverName or null userId parameter.
-
addConsoleAuditLogDestination
public VoidResponse addConsoleAuditLogDestination(String userId, String serverName, List<String> supportedSeverities) Set up the console (stdout) audit log destination for the server.- Parameters:
userId
- user that is issuing the request.serverName
- local server name.supportedSeverities
- list of severities that should be logged to this destination (empty list means all)- Returns:
- void response or OMAGNotAuthorizedException the supplied userId is not authorized to issue this command or OMAGInvalidParameterException invalid serverName or null userId parameter.
-
addSLF4JAuditLogDestination
public VoidResponse addSLF4JAuditLogDestination(String userId, String serverName, List<String> supportedSeverities) Set up the SLF4J audit log destination for the server.- Parameters:
userId
- user that is issuing the request.serverName
- local server name.supportedSeverities
- list of severities that should be logged to this destination (empty list means all)- Returns:
- void response or OMAGNotAuthorizedException the supplied userId is not authorized to issue this command or OMAGInvalidParameterException invalid serverName or null userId parameter.
-
addFileAuditLogDestination
public VoidResponse addFileAuditLogDestination(String userId, String serverName, String directoryName, List<String> supportedSeverities) Set up the File based audit log destination for the server.- Parameters:
userId
- user that is issuing the request.serverName
- local server name.directoryName
- name of directorysupportedSeverities
- list of severities that should be logged to this destination (empty list means all)- Returns:
- void response or OMAGNotAuthorizedException the supplied userId is not authorized to issue this command or OMAGInvalidParameterException invalid serverName or null userId parameter.
-
addPostgreSQLAuditLogDestination
public VoidResponse addPostgreSQLAuditLogDestination(String userId, String serverName, Map<String, Object> storageProperties) Set up the JDBC based audit log destination for the server.- Parameters:
userId
- user that is issuing the request.serverName
- local server name.storageProperties
- properties used to configure access to the database- Returns:
- void response or OMAGNotAuthorizedException the supplied userId is not authorized to issue this command or OMAGInvalidParameterException invalid serverName or null userId parameter.
-
addEventTopicAuditLogDestination
public VoidResponse addEventTopicAuditLogDestination(String userId, String serverName, String topicName, List<String> supportedSeverities) Set up the File based audit log destination for the server.- Parameters:
userId
- user that is issuing the request.serverName
- local server name.topicName
- name of topicsupportedSeverities
- list of severities that should be logged to this destination (empty list means all)- Returns:
- void response or OMAGNotAuthorizedException the supplied userId is not authorized to issue this command or OMAGInvalidParameterException invalid serverName or null userId parameter.
-
addStartUpOpenMetadataArchiveFile
public VoidResponse addStartUpOpenMetadataArchiveFile(String userId, String serverName, String fileName) Add a new open metadata archive to load at startup.- Parameters:
userId
- user that is issuing the request.serverName
- local server name.fileName
- name of the open metadata archive file.- Returns:
- void response or OMAGNotAuthorizedException the supplied userId is not authorized to issue this command or OMAGInvalidParameterException invalid serverName or fileName parameter.
-
setInMemLocalRepository
public VoidResponse setInMemLocalRepository(String userId, String serverName, NullRequestBody requestBody) Set up an in memory local repository. This repository uses hashmaps to store content. It is useful for demos, testing and POCs.- Parameters:
userId
- user that is issuing the request.serverName
- local server name.requestBody
- null request body- Returns:
- void response or OMAGNotAuthorizedException the supplied userId is not authorized to issue this command or OMAGInvalidParameterException invalid serverName or localRepositoryMode parameter.
-
setGraphLocalRepository
public VoidResponse setGraphLocalRepository(String userId, String serverName, Map<String, Object> storageProperties) Set up a graph store as the local repository.- Parameters:
userId
- user that is issuing the request.serverName
- local server name.storageProperties
- properties used to configure Egeria Graph DB- Returns:
- void response or OMAGNotAuthorizedException the supplied userId is not authorized to issue this command or OMAGConfigurationErrorException the event bus has not been configured or OMAGInvalidParameterException invalid serverName or localRepositoryMode parameter.
-
setPostgresLocalRepository
public VoidResponse setPostgresLocalRepository(String userId, String serverName, Map<String, Object> storageProperties) Set up a PostgreSQL Database Schema as the local repository.- Parameters:
userId
- user that is issuing the request.serverName
- local server name.storageProperties
- properties used to configure Egeria Graph DB- Returns:
- void response or OMAGNotAuthorizedException the supplied userId is not authorized to issue this command or OMAGConfigurationErrorException the event bus has not been configured or OMAGInvalidParameterException invalid serverName or localRepositoryMode parameter.
-
setXTDBInMemRepository
public VoidResponse setXTDBInMemRepository(String userId, String serverName, NullRequestBody requestBody) Set up an XTDB store as the local repository. This store uses XTDB to provide a historical metadata repository that operates in memory. This version of the XTDB repository is designed for testing.- Parameters:
userId
- user that is issuing the request.serverName
- local server name.requestBody
- null request body- Returns:
- void response or OMAGNotAuthorizedException the supplied userId is not authorized to issue this command or OMAGConfigurationErrorException the event bus has not been configured or OMAGInvalidParameterException invalid serverName or localRepositoryMode parameter.
-
setXTDBLocalKVRepository
public VoidResponse setXTDBLocalKVRepository(String userId, String serverName, NullRequestBody requestBody) Set up an XTDB store as the local repository. This store uses XTDB with RocksDB KV store to provide a high performance historical metadata repository.- Parameters:
userId
- user that is issuing the request.serverName
- local server name.requestBody
- null request body- Returns:
- void response or OMAGNotAuthorizedException the supplied userId is not authorized to issue this command or OMAGConfigurationErrorException the event bus has not been configured or OMAGInvalidParameterException invalid serverName or localRepositoryMode parameter.
-
setXTDBLocalRepository
public VoidResponse setXTDBLocalRepository(String userId, String serverName, Map<String, Object> storageProperties) Set up an XTDB store as the local repository. This store uses XTDB to provide a high performance historical metadata repository. It is scalable with different back ends and can be run in a HA context with multiple versions of the same server deployed to the same repository.- Parameters:
userId
- user that is issuing the request.serverName
- local server name.storageProperties
- properties used to configure the back end storage for the graph- Returns:
- void response or OMAGNotAuthorizedException the supplied userId is not authorized to issue this command or OMAGConfigurationErrorException the event bus has not been configured or OMAGInvalidParameterException invalid serverName or localRepositoryMode parameter.
-
setReadOnlyLocalRepository
Set up a read only store as the local repository.- Parameters:
userId
- user that is issuing the request.serverName
- local server name.- Returns:
- void response or OMAGNotAuthorizedException the supplied userId is not authorized to issue this command or OMAGConfigurationErrorException the event bus has not been configured or OMAGInvalidParameterException invalid serverName or localRepositoryMode parameter.
-
setNoRepositoryMode
Remove all configuration for a local repository. This is the default setting. This call can be used to remove subsequent local repository configuration.- Parameters:
userId
- user that is issuing the request.serverName
- local server name.- Returns:
- void response or OMAGNotAuthorizedException the supplied userId is not authorized to issue this command or OMAGInvalidParameterException invalid serverName or localRepositoryMode parameter.
-
setPluginRepositoryConnection
public VoidResponse setPluginRepositoryConnection(String userId, String serverName, Connection connection) Provide the connection to the local repository - used when the local repository mode is set to plugin repository.- Parameters:
userId
- user that is issuing the request.serverName
- local server name.connection
- connection to the OMRS repository connector.- Returns:
- void response or OMAGNotAuthorizedException the supplied userId is not authorized to issue this command or OMAGInvalidParameterException invalid serverName or repositoryProxyConnection parameter or
-
setPluginRepositoryConnection
public VoidResponse setPluginRepositoryConnection(String userId, String serverName, String connectorProvider, Map<String, Object> additionalProperties) Provide the connection to the local repository. This is used when the local repository mode is set to plugin repository.- Parameters:
userId
- user that is issuing the request.serverName
- local server name.connectorProvider
- connector provider class name to the OMRS repository connector.additionalProperties
- additional parameters to pass to the repository connector- Returns:
- void response or OMAGNotAuthorizedException the supplied userId is not authorized to issue this command or OMAGInvalidParameterException invalid serverName or repositoryProxyConnection parameter or OMAGConfigurationErrorException the local repository mode has not been set.
-
setRepositoryProxyConnection
public VoidResponse setRepositoryProxyConnection(String userId, String serverName, Connection connection) Provide the connection to the local repository - used when the local repository mode is set to repository proxy.- Parameters:
userId
- user that is issuing the request.serverName
- local server name.connection
- connection to the OMRS repository connector.- Returns:
- void response or OMAGNotAuthorizedException the supplied userId is not authorized to issue this command or OMAGInvalidParameterException invalid serverName or repositoryProxyConnection parameter or
-
setRepositoryProxyConnection
public VoidResponse setRepositoryProxyConnection(String userId, String serverName, String connectorProvider, Map<String, Object> additionalProperties) Provide the connection to the local repository. This is used when the local repository mode is set to repository proxy.- Parameters:
userId
- user that is issuing the request.serverName
- local server name.connectorProvider
- connector provider class name to the OMRS repository connector.additionalProperties
- additional parameters to pass to the repository connector- Returns:
- void response or OMAGNotAuthorizedException the supplied userId is not authorized to issue this command or OMAGInvalidParameterException invalid serverName or repositoryProxyConnection parameter or OMAGConfigurationErrorException the local repository mode has not been set.
-
setRepositoryProxyEventMapper
public VoidResponse setRepositoryProxyEventMapper(String userId, String serverName, Connection connection) Provide the connection to the local repository's event mapper if needed. The default value is null which means no event mapper. An event mapper is needed if the local repository has additional APIs that can change the metadata in the repository without going through the open metadata and governance services.- Parameters:
userId
- user that is issuing the request.serverName
- local server name.connection
- connection to the OMRS repository event mapper.- Returns:
- void response OMAGNotAuthorizedException the supplied userId is not authorized to issue this command or OMAGInvalidParameterException invalid serverName or localRepositoryEventMapper parameter or OMAGConfigurationErrorException the local repository mode has not been set
-
setRepositoryProxyEventMapper
public VoidResponse setRepositoryProxyEventMapper(String userId, String serverName, String connectorProvider, String eventSource, Map<String, Object> additionalProperties) Provide the connection to the local repository's event mapper if needed. The default value is null which means no event mapper. An event mapper is needed if the local repository has additional APIs that can change the metadata in the repository without going through the open metadata and governance services.- Parameters:
userId
- user that is issuing the request.serverName
- local server name.connectorProvider
- Java class name of the connector provider for the OMRS repository event mapper.eventSource
- topic name or URL to the native event source.additionalProperties
- additional properties for the event mapper connection- Returns:
- void response or OMAGNotAuthorizedException the supplied userId is not authorized to issue this command or OMAGInvalidParameterException invalid serverName or localRepositoryEventMapper parameter or OMAGConfigurationErrorException the event bus is not set.
-
getLocalMetadataCollectionId
Return the local metadata collection id. If the local repository is not configured then the invalid parameter exception is returned.- Parameters:
userId
- user that is issuing the request.serverName
- local server name.- Returns:
- guid response or OMAGNotAuthorizedException the supplied userId is not authorized to issue this command or OMAGInvalidParameterException invalid serverName or name parameter or OMAGConfigurationErrorException the event bus is not set.
-
setLocalMetadataCollectionId
public VoidResponse setLocalMetadataCollectionId(String userId, String serverName, String metadataCollectionId) Return the local metadata collection id. If the local repository is not configured then the invalid parameter exception is returned.- Parameters:
userId
- user that is issuing the request.serverName
- local server name.metadataCollectionId
- new value for the metadata collection id- Returns:
- guid response or OMAGNotAuthorizedException the supplied userId is not authorized to issue this command or OMAGInvalidParameterException invalid serverName or name parameter or OMAGConfigurationErrorException the event bus is not set.
-
getLocalMetadataCollectionName
Return the local metadata collection id. If the local repository is not configured then the invalid parameter exception is returned.- Parameters:
userId
- user that is issuing the request.serverName
- local server name.- Returns:
- guid response or OMAGNotAuthorizedException the supplied userId is not authorized to issue this command or OMAGInvalidParameterException invalid serverName or name parameter or OMAGConfigurationErrorException the event bus is not set.
-
setLocalMetadataCollectionName
public VoidResponse setLocalMetadataCollectionName(String userId, String serverName, String localMetadataCollectionName) Set up the local metadata collection name. If this is not set then the default value is the local server name.- Parameters:
userId
- user that is issuing the request.serverName
- local server name.localMetadataCollectionName
- metadata collection name- Returns:
- void response or OMAGNotAuthorizedException the supplied userId is not authorized to issue this command or OMAGInvalidParameterException invalid serverName or name parameter or OMAGConfigurationErrorException the event bus is not set.
-
addCohortRegistration
public VoidResponse addCohortRegistration(String userId, String serverName, String cohortName, CohortTopicStructure cohortTopicStructure, Map<String, Object> configurationProperties) Enable registration of server to an open metadata repository cohort. This is a group of open metadata repositories that are sharing metadata. An OMAG server can connect to zero, one or more cohorts. Each cohort needs a unique name. The members of the cohort use a shared topic to exchange registration information and events related to changes in their supported metadata types and instances. They are also able to query each other's metadata directly through REST calls.- Parameters:
userId
- user that is issuing the requestserverName
- local server namecohortName
- name of the cohortcohortTopicStructure
- the style of cohort topic set up to useconfigurationProperties
- additional properties for the cohort- Returns:
- void response or OMAGNotAuthorizedException the supplied userId is not authorized to issue this command or OMAGInvalidParameterException invalid serverName, cohortName or serviceMode parameter. OMAGConfigurationErrorException the event bus is not set.
-
getCohortTopicName
Retrieve the topic name that is used by this server to contact the other members of the open metadata repository cohort. This call can only be made once the cohort is set up with addCohortRegistration().- Parameters:
userId
- user that is issuing the request.serverName
- local server name.cohortName
- name of the cohort.- Returns:
- string response or OMAGNotAuthorizedException the supplied userId is not authorized to issue this command or OMAGInvalidParameterException invalid serverName or cohortName parameter. OMAGConfigurationErrorException the cohort is not setup, or set up in a non-standard way.
-
getDedicatedCohortTopicNames
public DedicatedTopicListResponse getDedicatedCohortTopicNames(String userId, String serverName, String cohortName) Retrieve the current topic names for the three dedicated topics of the cohort. This call can only be made once the cohort is set up with addCohortRegistration().- Parameters:
userId
- user that is issuing the request.serverName
- local server name.cohortName
- name of the cohort.- Returns:
- list of topics response or OMAGNotAuthorizedException the supplied userId is not authorized to issue this command or OMAGInvalidParameterException invalid serverName or cohortName parameter. OMAGConfigurationErrorException the cohort is not setup, or set up in a non-standard way.
-
overrideCohortTopicName
public VoidResponse overrideCohortTopicName(String userId, String serverName, String cohortName, String topicName) Change the topic name that is used by this server to contact the other members of the open metadata repository cohort. Note this name needs to be configured to same in all members of a cohort.- Parameters:
userId
- user that is issuing the request.serverName
- local server name.cohortName
- name of the cohort.topicName
- new topic name- Returns:
- void response or OMAGNotAuthorizedException the supplied userId is not authorized to issue this command or OMAGInvalidParameterException invalid serverName or cohortName parameter. OMAGConfigurationErrorException the cohort is not setup, or set up in a non-standard way.
-
overrideRegistrationCohortTopicName
public VoidResponse overrideRegistrationCohortTopicName(String userId, String serverName, String cohortName, String topicName) Change the topic name that is used by this server to register members in the open metadata repository cohort. Note this name needs to be configured to same in all members of a cohort.- Parameters:
userId
- user that is issuing the request.serverName
- local server name.cohortName
- name of the cohort.topicName
- new topic name- Returns:
- void response or OMAGNotAuthorizedException the supplied userId is not authorized to issue this command or OMAGInvalidParameterException invalid serverName or cohortName parameter. OMAGConfigurationErrorException the cohort is not setup, or set up in a non-standard way.
-
overrideTypesCohortTopicName
public VoidResponse overrideTypesCohortTopicName(String userId, String serverName, String cohortName, String topicName) Change the topic name that is used by this server to verify type consistency with the other members of the open metadata repository cohort. Note this name needs to be configured to same in all members of a cohort.- Parameters:
userId
- user that is issuing the request.serverName
- local server name.cohortName
- name of the cohort.topicName
- new topic name- Returns:
- void response or OMAGNotAuthorizedException the supplied userId is not authorized to issue this command or OMAGInvalidParameterException invalid serverName or cohortName parameter. OMAGConfigurationErrorException the cohort is not setup, or set up in a non-standard way.
-
overrideInstancesCohortTopicName
public VoidResponse overrideInstancesCohortTopicName(String userId, String serverName, String cohortName, String topicName) Change the topic name that is used by this server to exchange metadata instances with the other members of the open metadata repository cohort. Note this name needs to be configured to same in all members of a cohort.- Parameters:
userId
- user that is issuing the request.serverName
- local server name.cohortName
- name of the cohort.topicName
- new topic name- Returns:
- void response or OMAGNotAuthorizedException the supplied userId is not authorized to issue this command or OMAGInvalidParameterException invalid serverName or cohortName parameter. OMAGConfigurationErrorException the cohort is not setup, or set up in a non-standard way.
-
addAuditLogDestination
public VoidResponse addAuditLogDestination(String userId, String serverName, Connection auditLogDestination) Set up the list of audit log destinations. These destinations are expressed as Connection objects to the connectors that will handle the audit log records.- Parameters:
userId
- user that is issuing the request.serverName
- local server name.auditLogDestination
- connection object for audit log destination- Returns:
- void response or OMAGNotAuthorizedException the supplied userId is not authorized to issue this command or OMAGInvalidParameterException invalid serverName.
-
updateAuditLogDestination
public VoidResponse updateAuditLogDestination(String userId, String serverName, String suppliedConnectionName, Connection suppliedConnection) Update an audit log destination connection that is identified with the supplied destination connection name with the supplied connection object. It is possible to supply a suppliedConnectionName that matches an existing connection and the new connection specifies a different qualifiedName. in this way it is possible to rename Connections.- Parameters:
userId
- user that is issuing the request.serverName
- local server name.suppliedConnectionName
- name of the audit log destination to be updatedsuppliedConnection
- connection object that defines the audit log destination- Returns:
- void response or OMAGNotAuthorizedException the supplied userId is not authorized to issue this command or OMAGInvalidParameterException invalid serverName or suppliedConnectionName parameter.
-
clearAuditLogDestination
public VoidResponse clearAuditLogDestination(String userId, String serverName, String suppliedConnectionName) Delete an audit log destination connection, that is identified with the supplied destination connection name.- Parameters:
userId
- user that is issuing the request.serverName
- local server name.suppliedConnectionName
- qualified name of the audit log destination to be deleted- Returns:
- void response or OMAGNotAuthorizedException the supplied userId is not authorized to issue this command or OMAGInvalidParameterException invalid serverName or suppliedConnectionName parameter.
-
setAuditLogDestinations
public VoidResponse setAuditLogDestinations(String userId, String serverName, List<Connection> auditLogDestinations) Set up the list of audit log destinations. These destinations are expressed as Connection objects to the connectors that will handle the audit log records.- Parameters:
userId
- user that is issuing the request.serverName
- local server name.auditLogDestinations
- list of connection objects- Returns:
- void response or OMAGNotAuthorizedException the supplied userId is not authorized to issue this command or OMAGInvalidParameterException invalid serverName.
-
getAuditLogDestinations
Return the list of audit log destinations. These destinations are expressed as Connection objects to the connectors that will handle the audit log records.- Parameters:
userId
- user that is issuing the request.serverName
- local server name.- Returns:
- connection list response or OMAGNotAuthorizedException the supplied userId is not authorized to issue this command or OMAGInvalidParameterException invalid serverName.
-
clearAuditLogDestinations
Clear the list of audit log destinations. These destinations are expressed as Connection objects to the connectors that will handle the audit log records.- Parameters:
userId
- user that is issuing the request.serverName
- local server name.- Returns:
- void response or OMAGNotAuthorizedException the supplied userId is not authorized to issue this command or OMAGInvalidParameterException invalid serverName.
-
setOpenMetadataArchives
public VoidResponse setOpenMetadataArchives(String userId, String serverName, List<Connection> openMetadataArchives) Set up the list of open metadata archives. These are open metadata types and instances that are loaded at repository start up.- Parameters:
userId
- user that is issuing the request.serverName
- local server name.openMetadataArchives
- list of connection objects- Returns:
- void response or OMAGNotAuthorizedException the supplied userId is not authorized to issue this command or OMAGInvalidParameterException invalid serverName.
-
getOpenMetadataArchives
Return the list of open metadata archives. These are open metadata types and instances that are loaded at repository start up.- Parameters:
userId
- user that is issuing the request.serverName
- local server name.- Returns:
- connection list response or OMAGNotAuthorizedException the supplied userId is not authorized to issue this command or OMAGInvalidParameterException invalid serverName.
-
clearOpenMetadataArchives
Clear the list of open metadata archives for loading at server startup.- Parameters:
userId
- user that is issuing the request.serverName
- local server name.- Returns:
- void response or OMAGNotAuthorizedException the supplied userId is not authorized to issue this command or OMAGInvalidParameterException invalid serverName.
-
setLocalRepositoryConfig
public VoidResponse setLocalRepositoryConfig(String userId, String serverName, LocalRepositoryConfig localRepositoryConfig) Set up the configuration for the local repository. This overrides the current values.- Parameters:
userId
- user that is issuing the request.serverName
- local server name.localRepositoryConfig
- configuration properties for the local repository.- Returns:
- void response or OMAGNotAuthorizedException the supplied userId is not authorized to issue this command or OMAGInvalidParameterException invalid serverName or localRepositoryConfig parameter.
-
getLocalRepositoryConfig
Return the configuration for the local repository. This overrides the current values.- Parameters:
userId
- user that is issuing the request.serverName
- local server name.- Returns:
- local repository config response or OMAGNotAuthorizedException the supplied userId is not authorized to issue this command or OMAGInvalidParameterException invalid serverName.
-
clearLocalRepositoryConfig
Remove all configuration for a local repository. The default is no local repository. This call can be used to remove subsequent local repository configuration.- Parameters:
userId
- user that is issuing the request.serverName
- local server name.- Returns:
- void response or OMAGNotAuthorizedException the supplied userId is not authorized to issue this command or OMAGInvalidParameterException invalid serverName or localRepositoryMode parameter.
-
resetRemoteCohortURL
public VoidResponse resetRemoteCohortURL(String userId, String serverName, URLRequestBody requestBody) Update the URL broadcast across the cohort to allow other members to issue queries to this repository. This method is needed to reconfigure a server that has moved from one platform to another. Once the URL is updated, and the server restarted, it will broadcast its new URL to the rest of the cohort.- Parameters:
userId
- user that is issuing the request.serverName
- local server name.requestBody
- String url.- Returns:
- void response or OMAGNotAuthorizedException the supplied userId is not authorized to issue this command or OMAGInvalidParameterException invalid serverName or serverURLRoot parameter or OMAGConfigurationErrorException unusual state in the admin server.
-
setCohortConfig
public VoidResponse setCohortConfig(String userId, String serverName, String cohortName, CohortConfig cohortConfig) Set up the configuration properties for a cohort. This may reconfigure an existing cohort or create a cohort. Use setCohortMode to delete a cohort.- Parameters:
userId
- user that is issuing the requestserverName
- local server namecohortName
- name of the cohortcohortConfig
- configuration for the cohort- Returns:
- void response or OMAGNotAuthorizedException the supplied userId is not authorized to issue this command or OMAGInvalidParameterException invalid serverName, cohortName or cohortConfig parameter.
-
getCohortConfig
Return the current configuration for a cohort.- Parameters:
userId
- user that is issuing the request.serverName
- local server name.cohortName
- name of the cohort.- Returns:
- cohort config response or OMAGNotAuthorizedException the supplied userId is not authorized to issue this command or OMAGInvalidParameterException invalid serverName, cohortName or serviceMode parameter. OMAGConfigurationErrorException the event bus is not set.
-
clearCohortConfig
Set up the mode for an open metadata repository cohort. This is a group of open metadata repositories that are sharing metadata. An OMAG server can connect to zero, one or more cohorts. Each cohort needs a unique name. The members of the cohort use a shared topic to exchange registration information and events related to changes in their supported metadata types and instances. They are also able to query each other's metadata directly through REST calls.- Parameters:
userId
- user that is issuing the request.serverName
- local server name.cohortName
- name of the cohort.- Returns:
- void response or OMAGNotAuthorizedException the supplied userId is not authorized to issue this command or OMAGInvalidParameterException invalid serverName, cohortName or serviceMode parameter.
-
setOMAGServerConfig
public VoidResponse setOMAGServerConfig(String userId, String serverName, OMAGServerConfig omagServerConfig) Set up the configuration properties for an OMAG Server in a single command.- Parameters:
userId
- user that is issuing the requestserverName
- local server nameomagServerConfig
- configuration for the server- Returns:
- void response or OMAGNotAuthorizedException the supplied userId is not authorized to issue this command or OMAGInvalidParameterException invalid serverName or OMAGServerConfig parameter.
-
deployOMAGServerConfig
public VoidResponse deployOMAGServerConfig(String userId, String serverName, URLRequestBody destinationPlatform) Push the configuration for the server to another OMAG Server Platform.- Parameters:
userId
- user that is issuing the requestserverName
- local server namedestinationPlatform
- location of the platform where the config is to be deployed to- Returns:
- void response or OMAGNotAuthorizedException the supplied userId is not authorized to issue this command or OMAGConfigurationErrorException there is a problem using the supplied configuration or OMAGInvalidParameterException invalid serverName or destinationPlatform parameter.
-
getStoredConfiguration
Return the complete set of configuration properties in use by the server.- Parameters:
userId
- user that is issuing the requestserverName
- local server name- Returns:
- OMAGServerConfig properties or OMAGNotAuthorizedException the supplied userId is not authorized to issue this command or OMAGInvalidParameterException invalid serverName parameter.
-
retrieveAllServerConfigs
Return the stored configuration documents stored on the platform- Parameters:
userId
- user that is issuing the request- Returns:
- OMAGServerConfigs properties or OMAGNotAuthorizedException the supplied userId is not authorized to issue this command or OMAGInvalidParameterException invalid parameter occurred while processing.
-
clearOMAGServerConfig
Remove the configuration for the server.- Parameters:
userId
- user that is issuing the requestserverName
- local server name- Returns:
- void or OMAGNotAuthorizedException the supplied userId is not authorized to issue this command or OMAGInvalidParameterException invalid serverName parameter.
-