Package org.odpi.openmetadata.governanceservers.integrationdaemonservices.server.spring

Class IntegrationDaemonResource

java.lang.Object
org.odpi.openmetadata.governanceservers.integrationdaemonservices.server.spring.IntegrationDaemonResource
@RestController @RequestMapping("/servers/{serverName}/open-metadata/integration-daemon") public class IntegrationDaemonResource extends Object
IntegrationDaemonResource provides the server-side catcher for REST calls using Spring. The integration daemon server routes these requests to the named integration services.

  • Constructor Details

    • IntegrationDaemonResource

      public IntegrationDaemonResource()

  • Method Details

    • validateConnector

      @GetMapping(path="/validate-connector/{connectorProviderClassName}") public ConnectorReportResponse validateConnector(@PathVariable String serverName, @PathVariable String connectorProviderClassName, @RequestParam(required=false) String delegatingUserId)
      Validate the connector and return its connector type. The engine service does not need to be running in the integration daemon in order for this call to be successful. It only needs to be registered with the integration daemon.
      Parameters:
      serverName - integration daemon server name
      delegatingUserId - external userId making request
      connectorProviderClassName - name of a specific connector or null for all connectors
      Returns:
      connector type or InvalidParameterException the connector provider class name is not a valid connector fo this service UserNotAuthorizedException user not authorized to issue this request PropertyServerException there was a problem detected by the integration service

    • getIntegrationDaemonStatus

      @GetMapping(path="/status") public IntegrationDaemonStatusResponse getIntegrationDaemonStatus(@PathVariable String serverName, @RequestParam(required=false) String delegatingUserId)
      Return the status of each of the integration services and integration groups running in the integration daemon.
      Parameters:
      serverName - integration daemon name
      delegatingUserId - external userId making request
      Returns:
      list of statuses - one for each assigned integration services or integration group InvalidParameterException one of the parameters is null or invalid or UserNotAuthorizedException user not authorized to issue this request or PropertyServerException there was a problem detected by the integration daemon.

    • getConfigurationProperties

      @GetMapping(path="/integration-connectors/{connectorName}/configuration-properties") public PropertiesResponse getConfigurationProperties(@PathVariable String serverName, @PathVariable String connectorName, @RequestParam(required=false) String delegatingUserId)
      Retrieve the configuration properties of the named integration connector running in the integration daemon.
      Parameters:
      serverName - integration daemon server name
      delegatingUserId - external userId making request
      connectorName - name of a specific connector
      Returns:
      properties map or InvalidParameterException one of the parameters is null or invalid or UserNotAuthorizedException user not authorized to issue this request or PropertyServerException there was a problem detected by the integration service.

    • updateConfigurationProperties

      @PostMapping(path="/integration-connectors/configuration-properties") public VoidResponse updateConfigurationProperties(@PathVariable String serverName, @RequestParam(required=false) String delegatingUserId, @RequestBody ConnectorConfigPropertiesRequestBody requestBody)
      Update the configuration properties of the integration connectors, or specific integration connector if a connector name is supplied. This update is in memory and will not persist over a server restart.
      Parameters:
      serverName - integration daemon server name
      delegatingUserId - external userId making request
      requestBody - name of a specific connector or null for all connectors and the properties to change
      Returns:
      void or InvalidParameterException one of the parameters is null or invalid or UserNotAuthorizedException user not authorized to issue this request or PropertyServerException there was a problem detected by the integration service.

    • updateEndpointNetworkAddress

      @PostMapping(path="/integration-connectors/{connectorName}/endpoint-network-address") public VoidResponse updateEndpointNetworkAddress(@PathVariable String serverName, @PathVariable String connectorName, @RequestParam(required=false) String delegatingUserId, @RequestBody StringRequestBody requestBody)
      Update the endpoint network address for a specific integration connector. This update is in memory and will not persist over a server restart.
      Parameters:
      serverName - integration daemon server name
      delegatingUserId - external userId making request
      connectorName - name of a specific connector
      requestBody - name of a specific connector or null for all connectors and the properties to change
      Returns:
      void or InvalidParameterException one of the parameters is null or invalid or UserNotAuthorizedException user not authorized to issue this request or PropertyServerException there was a problem detected by the integration service.

    • updateConnectorConnection

      @PostMapping(path="/integration-connectors/{connectorName}/connection") public VoidResponse updateConnectorConnection(@PathVariable String serverName, @PathVariable String connectorName, @RequestParam(required=false) String delegatingUserId, @RequestBody Connection requestBody)
      Update the connection for a specific integration connector. This update is in memory and will not persist over a server restart.
      Parameters:
      serverName - integration daemon server name
      delegatingUserId - external userId making request
      connectorName - name of a specific connector
      requestBody - new connection object
      Returns:
      void or InvalidParameterException one of the parameters is null or invalid or UserNotAuthorizedException user not authorized to issue this request or PropertyServerException there was a problem detected by the integration service.

    • refreshConnectors

      @PostMapping(path="/integration-connectors/refresh") public VoidResponse refreshConnectors(@PathVariable String serverName, @RequestParam(required=false) String delegatingUserId, @RequestBody(required=false) NameRequestBody requestBody)
      Issue a refresh() request on all connectors running in the integration daemon, or a specific connector if the connector name is specified.
      Parameters:
      serverName - integration daemon server name
      delegatingUserId - external userId making request
      requestBody - optional name of the connector to target - if no connector name is specified, all connectors managed by this integration service are refreshed.
      Returns:
      void or InvalidParameterException one of the parameters is null or invalid or UserNotAuthorizedException user not authorized to issue this request or PropertyServerException there was a problem detected by the integration daemon.

    • restartConnectors

      @PostMapping(path="/integration-connectors/restart") public VoidResponse restartConnectors(@PathVariable String serverName, @RequestParam(required=false) String delegatingUserId, @RequestBody(required=false) NameRequestBody requestBody)
      Restart all connectors running in the integration daemon, or restart a specific connector if the connector name is specified.
      Parameters:
      serverName - integration daemon server name
      delegatingUserId - external userId making request
      requestBody - optional name of the connector to target - if no connector name is specified, all connectors managed by this integration service are refreshed.
      Returns:
      void or InvalidParameterException one of the parameters is null or invalid or UserNotAuthorizedException user not authorized to issue this request or PropertyServerException there was a problem detected by the integration daemon.

    • getIntegrationGroupSummary

      @GetMapping(path="/integration-groups/{integrationGroupName}/summary") public IntegrationGroupSummaryResponse getIntegrationGroupSummary(@PathVariable String serverName, @PathVariable String integrationGroupName, @RequestParam(required=false) String delegatingUserId)
      Retrieve the description and status of the requested integration group.
      Parameters:
      serverName - integration daemon server name
      delegatingUserId - external userId making request
      integrationGroupName - name of integration group of interest
      Returns:
      list of statuses - on for each assigned integration groups or InvalidParameterException one of the parameters is null or invalid or UserNotAuthorizedException user not authorized to issue this request or

    • getIntegrationGroupSummaries

      @GetMapping(path="/integration-groups/summary") public IntegrationGroupSummariesResponse getIntegrationGroupSummaries(@PathVariable String serverName, @RequestParam(required=false) String delegatingUserId)
      Return a summary of each of the integration groups running in the integration daemon.
      Parameters:
      serverName - integration daemon server name
      delegatingUserId - external userId making request
      Returns:
      list of statuses - one for each assigned integration groups InvalidParameterException one of the parameters is null or invalid or UserNotAuthorizedException user not authorized to issue this request or

    • refreshIntegrationGroupConfig

      @GetMapping(path="/integration-groups/{integrationGroupName}/refresh-config") public VoidResponse refreshIntegrationGroupConfig(@PathVariable String serverName, @PathVariable String integrationGroupName, @RequestParam(required=false) String delegatingUserId)
      Request that the integration group refresh its configuration by calling the metadata access server. Changes to the connector configuration will result in the affected connectors being restarted. This request is useful if the metadata access server has an outage, particularly while the integration daemon is initializing. This request just ensures that the latest configuration is in use.
      Parameters:
      serverName - name of the governance server
      delegatingUserId - external userId making request
      integrationGroupName - unique name of the integration group
      Returns:
      void or InvalidParameterException one of the parameters is null or invalid or UserNotAuthorizedException user not authorized to issue this request or IntegrationGroupException there was a problem detected by the integration group.