/**
 * Data Integration API
 * Use the Data Integration API to organize your data integration projects, create data flows, pipelines and tasks, and then publish, schedule, and run tasks that extract, transform, and load data. For more information, see [Data Integration](https://docs.oracle.com/iaas/data-integration/home.htm).
 * OpenAPI spec version: 20200430
 * Contact: di_dis_ww_grp@oracle.com
 *
 * NOTE: This class is auto generated by OracleSDKGenerator.
 * Do not edit the class manually.
 *
 * Copyright (c) 2020, 2022, Oracle and/or its affiliates.  All rights reserved.
 * This software is dual-licensed to you under the Universal Permissive License (UPL) 1.0 as shown at https://oss.oracle.com/licenses/upl or Apache License 2.0 as shown at http://www.apache.org/licenses/LICENSE-2.0. You may choose either license.
 */ import common = require ( "oci-common" ) ; import * as requests from "./request" ; import * as model from "./model" ; import * as responses from "./response" ; import { paginateRecords , paginateResponses } from "oci-common" ; import { DataIntegrationWaiter } from "./dataintegration-waiter" ; import { composeResponse , composeRequest , GenericRetrier } from "oci-common" ; export enum DataIntegrationApiKeys { } /**
 * This service client uses  common . CircuitBreaker . DefaultConfiguration for all the operations by default if no circuit breaker configuration is defined by the user.
  export class DataIntegrationClient { protected static serviceEndpointTemplate = "https://dataintegration.{region}.oci.{secondLevelDomain}" ; protected "_endpoint" : string = "" ; protected "_defaultHeaders" : any = { } ; protected "_waiters" : DataIntegrationWaiter ; protected "_clientConfiguration" : common . ClientConfiguration ; protected _circuitBreaker = null ; protected _httpClient : common . HttpClient ; constructor ( params , clientConfiguration ? ) { const requestSigner = params . authenticationDetailsProvider ? new common . DefaultRequestSigner ( params . authenticationDetailsProvider ) : null ; if ( clientConfiguration ) { this . _clientConfiguration = clientConfiguration ; this . _circuitBreaker = clientConfiguration . circuitBreaker ? clientConfiguration . circuitBreaker ! . circuit : null ; } const specCircuitBreakerEnabled = true ; if ( ! this . _circuitBreaker && common . utils . isCircuitBreakerSystemEnabled ( clientConfiguration ! ) && ( specCircuitBreakerEnabled || common . CircuitBreaker . DefaultCircuitBreakerOverriden ) ) { this . _circuitBreaker = new common . CircuitBreaker ( ) . circuit ; } this . _httpClient = params . httpClient || new common . FetchHttpClient ( requestSigner , this . _circuitBreaker ) ; if ( params . authenticationDetailsProvider && common . isRegionProvider ( params . authenticationDetailsProvider ) ) { const provider = params . authenticationDetailsProvider ; if ( provider . getRegion ( ) ) { this . region = provider . getRegion ( ) ; } } } /**
     * Get the endpoint that is being used to call (ex, https://www.example.com).
     */ public get endpoint ( ) { return this . _endpoint ; } param endpoint public set endpoint ( endpoint ) { this . _endpoint = endpoint ; this . _endpoint = this . _endpoint + "/20200430" ; if ( this . logger ) this . logger . info ( `DataIntegrationClient endpoint set to ${ this . _endpoint }` ) ; } public get logger ( ) { return common . LOG . logger ; } /**
     * Sets the region to call (ex, Region.US_PHOENIX_1).
     * Note, this will call  {@link #endpoint(String) endpoint} after resolving the endpoint.
     *  param region public set region ( region ) { this . endpoint = common . EndpointBuilder . createEndpointFromRegion ( DataIntegrationClient . serviceEndpointTemplate , region ) ; } /**
     * Sets the regionId to call (ex, 'us-phoenix-1').
     *
     * Note, this will first try to map the region ID to a known Region and call  {@link #region(Region) region} .
     * If no known Region could be determined, it will create an endpoint assuming its in default Realm OC1
     * and then call  {@link #endpoint(String) endpoint} .
     *  param regionId public set regionId ( regionId ) { this . endpoint = common . EndpointBuilder . createEndpointFromRegionId ( DataIntegrationClient . serviceEndpointTemplate , regionId ) ; } param config return public createWaiters ( config ? ) { this . _waiters = new DataIntegrationWaiter ( this , config ) ; return this . _waiters ; } return public getWaiters ( ) { if ( this . _waiters ) { return this . _waiters ; } throw Error ( "Waiters do not exist. Please create waiters." ) ; } param ChangeCompartmentRequest return throws example Click  https to see how to use ChangeCompartment API.
      public async changeCompartment ( changeCompartmentRequest ) { if ( this . logger ) this . logger . debug ( "Calling operation DataIntegrationClient#changeCompartment." ) ; const pathParams = { "{workspaceId}" : changeCompartmentRequest . workspaceId } ; const queryParams = { } ; let headerParams = { "Content-Type" : common . Constants . APPLICATION_JSON , "if-match" : changeCompartmentRequest . ifMatch , "opc-request-id" : changeCompartmentRequest . opcRequestId , "opc-retry-token" : changeCompartmentRequest . opcRetryToken } ; const specRetryConfiguration = common . NoRetryConfigurationDetails ; const retrier = GenericRetrier . createPreferredRetrier ( this . _clientConfiguration ? this . _clientConfiguration . retryConfiguration : undefined , changeCompartmentRequest . retryConfiguration , specRetryConfiguration ) ; if ( this . logger ) retrier . logger = this . logger ; const request = await composeRequest ( { baseEndpoint : this . _endpoint , defaultHeaders : this . _defaultHeaders , path : "/workspaces/{workspaceId}/actions/changeCompartment" , method : "POST" , bodyContent : common . ObjectSerializer . serialize ( changeCompartmentRequest . changeCompartmentDetails , "ChangeCompartmentDetails" , model . ChangeCompartmentDetails . getJsonObj ) , pathParams : pathParams , headerParams : headerParams , queryParams : queryParams } ) ; try { const response = await retrier . makeServiceCall ( this . _httpClient , request ) ; const sdkResponse = composeResponse ( { responseObject : < responses . ChangeCompartmentResponse > { } , responseHeaders : [ { value : response . headers . get ( "opc-request-id" ) , key : "opcRequestId" , dataType : "string" } , { value : response . headers . get ( "opc-work-request-id" ) , key : "opcWorkRequestId" , dataType : "string" } ] } ) ; return sdkResponse ; } catch ( err ) { throw err ; } } param CreateApplicationRequest return throws example Click  https to see how to use CreateApplication API.
      public async createApplication ( createApplicationRequest ) { if ( this . logger ) this . logger . debug ( "Calling operation DataIntegrationClient#createApplication." ) ; const pathParams = { "{workspaceId}" : createApplicationRequest . workspaceId } ; const queryParams = { } ; let headerParams = { "Content-Type" : common . Constants . APPLICATION_JSON , "opc-request-id" : createApplicationRequest . opcRequestId , "opc-retry-token" : createApplicationRequest . opcRetryToken } ; const specRetryConfiguration = common . NoRetryConfigurationDetails ; const retrier = GenericRetrier . createPreferredRetrier ( this . _clientConfiguration ? this . _clientConfiguration . retryConfiguration : undefined , createApplicationRequest . retryConfiguration , specRetryConfiguration ) ; if ( this . logger ) retrier . logger = this . logger ; const request = await composeRequest ( { baseEndpoint : this . _endpoint , defaultHeaders : this . _defaultHeaders , path : "/workspaces/{workspaceId}/applications" , method : "POST" , bodyContent : common . ObjectSerializer . serialize ( createApplicationRequest . createApplicationDetails , "CreateApplicationDetails" , model . CreateApplicationDetails . getJsonObj ) , pathParams : pathParams , headerParams : headerParams , queryParams : queryParams } ) ; try { const response = await retrier . makeServiceCall ( this . _httpClient , request ) ; const sdkResponse = composeResponse ( { responseObject : < responses . CreateApplicationResponse > { } , body : await response . json ( ) , bodyKey : "application" , bodyModel : model . Application , type : "model.Application" , responseHeaders : [ { value : response . headers . get ( "etag" ) , key : "etag" , dataType : "string" } , { value : response . headers . get ( "opc-request-id" ) , key : "opcRequestId" , dataType : "string" } ] } ) ; return sdkResponse ; } catch ( err ) { throw err ; } } param CreateConnectionRequest return throws example Click  https to see how to use CreateConnection API.
      public async createConnection ( createConnectionRequest ) { if ( this . logger ) this . logger . debug ( "Calling operation DataIntegrationClient#createConnection." ) ; const pathParams = { "{workspaceId}" : createConnectionRequest . workspaceId } ; const queryParams = { } ; let headerParams = { "Content-Type" : common . Constants . APPLICATION_JSON , "opc-request-id" : createConnectionRequest . opcRequestId , "opc-retry-token" : createConnectionRequest . opcRetryToken } ; const specRetryConfiguration = common . NoRetryConfigurationDetails ; const retrier = GenericRetrier . createPreferredRetrier ( this . _clientConfiguration ? this . _clientConfiguration . retryConfiguration : undefined , createConnectionRequest . retryConfiguration , specRetryConfiguration ) ; if ( this . logger ) retrier . logger = this . logger ; const request = await composeRequest ( { baseEndpoint : this . _endpoint , defaultHeaders : this . _defaultHeaders , path : "/workspaces/{workspaceId}/connections" , method : "POST" , bodyContent : common . ObjectSerializer . serialize ( createConnectionRequest . createConnectionDetails , "CreateConnectionDetails" , model . CreateConnectionDetails . getJsonObj ) , pathParams : pathParams , headerParams : headerParams , queryParams : queryParams } ) ; try { const response = await retrier . makeServiceCall ( this . _httpClient , request ) ; const sdkResponse = composeResponse ( { responseObject : < responses . CreateConnectionResponse > { } , body : await response . json ( ) , bodyKey : "connection" , bodyModel : model . Connection , type : "model.Connection" , responseHeaders : [ { value : response . headers . get ( "etag" ) , key : "etag" , dataType : "string" } , { value : response . headers . get ( "opc-request-id" ) , key : "opcRequestId" , dataType : "string" } ] } ) ; return sdkResponse ; } catch ( err ) { throw err ; } } param CreateConnectionValidationRequest return throws example Click  https to see how to use CreateConnectionValidation API.
      public async createConnectionValidation ( createConnectionValidationRequest ) { if ( this . logger ) this . logger . debug ( "Calling operation DataIntegrationClient#createConnectionValidation." ) ; const pathParams = { "{workspaceId}" : createConnectionValidationRequest . workspaceId } ; const queryParams = { } ; let headerParams = { "Content-Type" : common . Constants . APPLICATION_JSON , "opc-request-id" : createConnectionValidationRequest . opcRequestId , "opc-retry-token" : createConnectionValidationRequest . opcRetryToken } ; const specRetryConfiguration = common . NoRetryConfigurationDetails ; const retrier = GenericRetrier . createPreferredRetrier ( this . _clientConfiguration ? this . _clientConfiguration . retryConfiguration : undefined , createConnectionValidationRequest . retryConfiguration , specRetryConfiguration ) ; if ( this . logger ) retrier . logger = this . logger ; const request = await composeRequest ( { baseEndpoint : this . _endpoint , defaultHeaders : this . _defaultHeaders , path : "/workspaces/{workspaceId}/connectionValidations" , method : "POST" , bodyContent : common . ObjectSerializer . serialize ( createConnectionValidationRequest . createConnectionValidationDetails , "CreateConnectionValidationDetails" , model . CreateConnectionValidationDetails . getJsonObj ) , pathParams : pathParams , headerParams : headerParams , queryParams : queryParams } ) ; try { const response = await retrier . makeServiceCall ( this . _httpClient , request ) ; const sdkResponse = composeResponse ( { responseObject : < responses . CreateConnectionValidationResponse > { } , body : await response . json ( ) , bodyKey : "connectionValidation" , bodyModel : model . ConnectionValidation , type : "model.ConnectionValidation" , responseHeaders : [ { value : response . headers . get ( "etag" ) , key : "etag" , dataType : "string" } , { value : response . headers . get ( "opc-request-id" ) , key : "opcRequestId" , dataType : "string" } ] } ) ; return sdkResponse ; } catch ( err ) { throw err ; } } param CreateDataAssetRequest return throws example Click  https to see how to use CreateDataAsset API.
      public async createDataAsset ( createDataAssetRequest ) { if ( this . logger ) this . logger . debug ( "Calling operation DataIntegrationClient#createDataAsset." ) ; const pathParams = { "{workspaceId}" : createDataAssetRequest . workspaceId } ; const queryParams = { } ; let headerParams = { "Content-Type" : common . Constants . APPLICATION_JSON , "opc-request-id" : createDataAssetRequest . opcRequestId , "opc-retry-token" : createDataAssetRequest . opcRetryToken } ; const specRetryConfiguration = common . NoRetryConfigurationDetails ; const retrier = GenericRetrier . createPreferredRetrier ( this . _clientConfiguration ? this . _clientConfiguration . retryConfiguration : undefined , createDataAssetRequest . retryConfiguration , specRetryConfiguration ) ; if ( this . logger ) retrier . logger = this . logger ; const request = await composeRequest ( { baseEndpoint : this . _endpoint , defaultHeaders : this . _defaultHeaders , path : "/workspaces/{workspaceId}/dataAssets" , method : "POST" , bodyContent : common . ObjectSerializer . serialize ( createDataAssetRequest . createDataAssetDetails , "CreateDataAssetDetails" , model . CreateDataAssetDetails . getJsonObj ) , pathParams : pathParams , headerParams : headerParams , queryParams : queryParams } ) ; try { const response = await retrier . makeServiceCall ( this . _httpClient , request ) ; const sdkResponse = composeResponse ( { responseObject : < responses . CreateDataAssetResponse > { } , body : await response . json ( ) , bodyKey : "dataAsset" , bodyModel : model . DataAsset , type : "model.DataAsset" , responseHeaders : [ { value : response . headers . get ( "etag" ) , key : "etag" , dataType : "string" } , { value : response . headers . get ( "opc-request-id" ) , key : "opcRequestId" , dataType : "string" } ] } ) ; return sdkResponse ; } catch ( err ) { throw err ; } } param CreateDataFlowRequest return throws example Click  https to see how to use CreateDataFlow API.
      public async createDataFlow ( createDataFlowRequest ) { if ( this . logger ) this . logger . debug ( "Calling operation DataIntegrationClient#createDataFlow." ) ; const pathParams = { "{workspaceId}" : createDataFlowRequest . workspaceId } ; const queryParams = { } ; let headerParams = { "Content-Type" : common . Constants . APPLICATION_JSON , "opc-retry-token" : createDataFlowRequest . opcRetryToken , "opc-request-id" : createDataFlowRequest . opcRequestId } ; const specRetryConfiguration = common . NoRetryConfigurationDetails ; const retrier = GenericRetrier . createPreferredRetrier ( this . _clientConfiguration ? this . _clientConfiguration . retryConfiguration : undefined , createDataFlowRequest . retryConfiguration , specRetryConfiguration ) ; if ( this . logger ) retrier . logger = this . logger ; const request = await composeRequest ( { baseEndpoint : this . _endpoint , defaultHeaders : this . _defaultHeaders , path : "/workspaces/{workspaceId}/dataFlows" , method : "POST" , bodyContent : common . ObjectSerializer . serialize ( createDataFlowRequest . createDataFlowDetails , "CreateDataFlowDetails" , model . CreateDataFlowDetails . getJsonObj ) , pathParams : pathParams , headerParams : headerParams , queryParams : queryParams } ) ; try { const response = await retrier . makeServiceCall ( this . _httpClient , request ) ; const sdkResponse = composeResponse ( { responseObject : < responses . CreateDataFlowResponse > { } , body : await response . json ( ) , bodyKey : "dataFlow" , bodyModel : model . DataFlow , type : "model.DataFlow" , responseHeaders : [ { value : response . headers . get ( "etag" ) , key : "etag" , dataType : "string" } , { value : response . headers . get ( "opc-request-id" ) , key : "opcRequestId" , dataType : "string" } ] } ) ; return sdkResponse ; } catch ( err ) { throw err ; } } param CreateDataFlowValidationRequest return throws example Click  https to see how to use CreateDataFlowValidation API.
      public async createDataFlowValidation ( createDataFlowValidationRequest ) { if ( this . logger ) this . logger . debug ( "Calling operation DataIntegrationClient#createDataFlowValidation." ) ; const pathParams = { "{workspaceId}" : createDataFlowValidationRequest . workspaceId } ; const queryParams = { } ; let headerParams = { "Content-Type" : common . Constants . APPLICATION_JSON , "opc-request-id" : createDataFlowValidationRequest . opcRequestId , "opc-retry-token" : createDataFlowValidationRequest . opcRetryToken } ; const specRetryConfiguration = common . NoRetryConfigurationDetails ; const retrier = GenericRetrier . createPreferredRetrier ( this . _clientConfiguration ? this . _clientConfiguration . retryConfiguration : undefined , createDataFlowValidationRequest . retryConfiguration , specRetryConfiguration ) ; if ( this . logger ) retrier . logger = this . logger ; const request = await composeRequest ( { baseEndpoint : this . _endpoint , defaultHeaders : this . _defaultHeaders , path : "/workspaces/{workspaceId}/dataFlowValidations" , method : "POST" , bodyContent : common . ObjectSerializer . serialize ( createDataFlowValidationRequest . createDataFlowValidationDetails , "CreateDataFlowValidationDetails" , model . CreateDataFlowValidationDetails . getJsonObj ) , pathParams : pathParams , headerParams : headerParams , queryParams : queryParams } ) ; try { const response = await retrier . makeServiceCall ( this . _httpClient , request ) ; const sdkResponse = composeResponse ( { responseObject : < responses . CreateDataFlowValidationResponse > { } , body : await response . json ( ) , bodyKey : "dataFlowValidation" , bodyModel : model . DataFlowValidation , type : "model.DataFlowValidation" , responseHeaders : [ { value : response . headers . get ( "etag" ) , key : "etag" , dataType : "string" } , { value : response . headers . get ( "opc-request-id" ) , key : "opcRequestId" , dataType : "string" } ] } ) ; return sdkResponse ; } catch ( err ) { throw err ; } } param CreateEntityShapeRequest return throws example Click  https to see how to use CreateEntityShape API.
      public async createEntityShape ( createEntityShapeRequest ) { if ( this . logger ) this . logger . debug ( "Calling operation DataIntegrationClient#createEntityShape." ) ; const pathParams = { "{workspaceId}" : createEntityShapeRequest . workspaceId , "{connectionKey}" : createEntityShapeRequest . connectionKey , "{schemaResourceName}" : createEntityShapeRequest . schemaResourceName } ; const queryParams = { } ; let headerParams = { "Content-Type" : common . Constants . APPLICATION_JSON , "opc-request-id" : createEntityShapeRequest . opcRequestId , "opc-retry-token" : createEntityShapeRequest . opcRetryToken , "if-match" : createEntityShapeRequest . ifMatch } ; const specRetryConfiguration = common . NoRetryConfigurationDetails ; const retrier = GenericRetrier . createPreferredRetrier ( this . _clientConfiguration ? this . _clientConfiguration . retryConfiguration : undefined , createEntityShapeRequest . retryConfiguration , specRetryConfiguration ) ; if ( this . logger ) retrier . logger = this . logger ; const request = await composeRequest ( { baseEndpoint : this . _endpoint , defaultHeaders : this . _defaultHeaders , path : "/workspaces/{workspaceId}/connections/{connectionKey}/schemas/{schemaResourceName}/entityShapes" , method : "POST" , bodyContent : common . ObjectSerializer . serialize ( createEntityShapeRequest . createEntityShapeDetails , "CreateEntityShapeDetails" , model . CreateEntityShapeDetails . getJsonObj ) , pathParams : pathParams , headerParams : headerParams , queryParams : queryParams } ) ; try { const response = await retrier . makeServiceCall ( this . _httpClient , request ) ; const sdkResponse = composeResponse ( { responseObject : < responses . CreateEntityShapeResponse > { } , body : await response . json ( ) , bodyKey : "entityShape" , bodyModel : model . EntityShape , type : "model.EntityShape" , responseHeaders : [ { value : response . headers . get ( "opc-request-id" ) , key : "opcRequestId" , dataType : "string" } ] } ) ; return sdkResponse ; } catch ( err ) { throw err ; } } param CreateExternalPublicationRequest return throws example Click  https to see how to use CreateExternalPublication API.
      public async createExternalPublication ( createExternalPublicationRequest ) { if ( this . logger ) this . logger . debug ( "Calling operation DataIntegrationClient#createExternalPublication." ) ; const pathParams = { "{workspaceId}" : createExternalPublicationRequest . workspaceId , "{taskKey}" : createExternalPublicationRequest . taskKey } ; const queryParams = { } ; let headerParams = { "Content-Type" : common . Constants . APPLICATION_JSON , "opc-request-id" : createExternalPublicationRequest . opcRequestId , "opc-retry-token" : createExternalPublicationRequest . opcRetryToken } ; const specRetryConfiguration = common . NoRetryConfigurationDetails ; const retrier = GenericRetrier . createPreferredRetrier ( this . _clientConfiguration ? this . _clientConfiguration . retryConfiguration : undefined , createExternalPublicationRequest . retryConfiguration , specRetryConfiguration ) ; if ( this . logger ) retrier . logger = this . logger ; const request = await composeRequest ( { baseEndpoint : this . _endpoint , defaultHeaders : this . _defaultHeaders , path : "/workspaces/{workspaceId}/tasks/{taskKey}/externalPublications" , method : "POST" , bodyContent : common . ObjectSerializer . serialize ( createExternalPublicationRequest . createExternalPublicationDetails , "CreateExternalPublicationDetails" , model . CreateExternalPublicationDetails . getJsonObj ) , pathParams : pathParams , headerParams : headerParams , queryParams : queryParams } ) ; try { const response = await retrier . makeServiceCall ( this . _httpClient , request ) ; const sdkResponse = composeResponse ( { responseObject : < responses . CreateExternalPublicationResponse > { } , body : await response . json ( ) , bodyKey : "externalPublication" , bodyModel : model . ExternalPublication , type : "model.ExternalPublication" , responseHeaders : [ { value : response . headers . get ( "etag" ) , key : "etag" , dataType : "string" } , { value : response . headers . get ( "opc-request-id" ) , key : "opcRequestId" , dataType : "string" } ] } ) ; return sdkResponse ; } catch ( err ) { throw err ; } } param CreateExternalPublicationValidationRequest return throws example Click  https to see how to use CreateExternalPublicationValidation API.
      public async createExternalPublicationValidation ( createExternalPublicationValidationRequest ) { if ( this . logger ) this . logger . debug ( "Calling operation DataIntegrationClient#createExternalPublicationValidation." ) ; const pathParams = { "{workspaceId}" : createExternalPublicationValidationRequest . workspaceId , "{taskKey}" : createExternalPublicationValidationRequest . taskKey } ; const queryParams = { } ; let headerParams = { "Content-Type" : common . Constants . APPLICATION_JSON , "opc-request-id" : createExternalPublicationValidationRequest . opcRequestId , "opc-retry-token" : createExternalPublicationValidationRequest . opcRetryToken } ; const specRetryConfiguration = common . NoRetryConfigurationDetails ; const retrier = GenericRetrier . createPreferredRetrier ( this . _clientConfiguration ? this . _clientConfiguration . retryConfiguration : undefined , createExternalPublicationValidationRequest . retryConfiguration , specRetryConfiguration ) ; if ( this . logger ) retrier . logger = this . logger ; const request = await composeRequest ( { baseEndpoint : this . _endpoint , defaultHeaders : this . _defaultHeaders , path : "/workspaces/{workspaceId}/tasks/{taskKey}/externalPublicationValidations" , method : "POST" , bodyContent : common . ObjectSerializer . serialize ( createExternalPublicationValidationRequest . createExternalPublicationValidationDetails , "CreateExternalPublicationValidationDetails" , model . CreateExternalPublicationValidationDetails . getJsonObj ) , pathParams : pathParams , headerParams : headerParams , queryParams : queryParams } ) ; try { const response = await retrier . makeServiceCall ( this . _httpClient , request ) ; const sdkResponse = composeResponse ( { responseObject : < responses . CreateExternalPublicationValidationResponse > { } , body : await response . json ( ) , bodyKey : "externalPublicationValidation" , bodyModel : model . ExternalPublicationValidation , type : "model.ExternalPublicationValidation" , responseHeaders : [ { value : response . headers . get ( "etag" ) , key : "etag" , dataType : "string" } , { value : response . headers . get ( "opc-request-id" ) , key : "opcRequestId" , dataType : "string" } ] } ) ; return sdkResponse ; } catch ( err ) { throw err ; } } param CreateFolderRequest return throws example Click  https to see how to use CreateFolder API.
      public async createFolder ( createFolderRequest ) { if ( this . logger ) this . logger . debug ( "Calling operation DataIntegrationClient#createFolder." ) ; const pathParams = { "{workspaceId}" : createFolderRequest . workspaceId } ; const queryParams = { } ; let headerParams = { "Content-Type" : common . Constants . APPLICATION_JSON , "opc-retry-token" : createFolderRequest . opcRetryToken , "opc-request-id" : createFolderRequest . opcRequestId } ; const specRetryConfiguration = common . NoRetryConfigurationDetails ; const retrier = GenericRetrier . createPreferredRetrier ( this . _clientConfiguration ? this . _clientConfiguration . retryConfiguration : undefined , createFolderRequest . retryConfiguration , specRetryConfiguration ) ; if ( this . logger ) retrier . logger = this . logger ; const request = await composeRequest ( { baseEndpoint : this . _endpoint , defaultHeaders : this . _defaultHeaders , path : "/workspaces/{workspaceId}/folders" , method : "POST" , bodyContent : common . ObjectSerializer . serialize ( createFolderRequest . createFolderDetails , "CreateFolderDetails" , model . CreateFolderDetails . getJsonObj ) , pathParams : pathParams , headerParams : headerParams , queryParams : queryParams } ) ; try { const response = await retrier . makeServiceCall ( this . _httpClient , request ) ; const sdkResponse = composeResponse ( { responseObject : < responses . CreateFolderResponse > { } , body : await response . json ( ) , bodyKey : "folder" , bodyModel : model . Folder , type : "model.Folder" , responseHeaders : [ { value : response . headers . get ( "etag" ) , key : "etag" , dataType : "string" } , { value : response . headers . get ( "opc-request-id" ) , key : "opcRequestId" , dataType : "string" } ] } ) ; return sdkResponse ; } catch ( err ) { throw err ; } } param CreateFunctionLibraryRequest return throws example Click  https to see how to use CreateFunctionLibrary API.
      public async createFunctionLibrary ( createFunctionLibraryRequest ) { if ( this . logger ) this . logger . debug ( "Calling operation DataIntegrationClient#createFunctionLibrary." ) ; const pathParams = { "{workspaceId}" : createFunctionLibraryRequest . workspaceId } ; const queryParams = { } ; let headerParams = { "Content-Type" : common . Constants . APPLICATION_JSON , "opc-retry-token" : createFunctionLibraryRequest . opcRetryToken , "opc-request-id" : createFunctionLibraryRequest . opcRequestId } ; const specRetryConfiguration = common . NoRetryConfigurationDetails ; const retrier = GenericRetrier . createPreferredRetrier ( this . _clientConfiguration ? this . _clientConfiguration . retryConfiguration : undefined , createFunctionLibraryRequest . retryConfiguration , specRetryConfiguration ) ; if ( this . logger ) retrier . logger = this . logger ; const request = await composeRequest ( { baseEndpoint : this . _endpoint , defaultHeaders : this . _defaultHeaders , path : "/workspaces/{workspaceId}/functionLibraries" , method : "POST" , bodyContent : common . ObjectSerializer . serialize ( createFunctionLibraryRequest . createFunctionLibraryDetails , "CreateFunctionLibraryDetails" , model . CreateFunctionLibraryDetails . getJsonObj ) , pathParams : pathParams , headerParams : headerParams , queryParams : queryParams } ) ; try { const response = await retrier . makeServiceCall ( this . _httpClient , request ) ; const sdkResponse = composeResponse ( { responseObject : < responses . CreateFunctionLibraryResponse > { } , body : await response . json ( ) , bodyKey : "functionLibrary" , bodyModel : model . FunctionLibrary , type : "model.FunctionLibrary" , responseHeaders : [ { value : response . headers . get ( "etag" ) , key : "etag" , dataType : "string" } , { value : response . headers . get ( "opc-request-id" ) , key : "opcRequestId" , dataType : "string" } ] } ) ; return sdkResponse ; } catch ( err ) { throw err ; } } param CreatePatchRequest return throws example Click  https to see how to use CreatePatch API.
      public async createPatch ( createPatchRequest ) { if ( this . logger ) this . logger . debug ( "Calling operation DataIntegrationClient#createPatch." ) ; const pathParams = { "{workspaceId}" : createPatchRequest . workspaceId , "{applicationKey}" : createPatchRequest . applicationKey } ; const queryParams = { } ; let headerParams = { "Content-Type" : common . Constants . APPLICATION_JSON , "opc-request-id" : createPatchRequest . opcRequestId , "opc-retry-token" : createPatchRequest . opcRetryToken } ; const specRetryConfiguration = common . NoRetryConfigurationDetails ; const retrier = GenericRetrier . createPreferredRetrier ( this . _clientConfiguration ? this . _clientConfiguration . retryConfiguration : undefined , createPatchRequest . retryConfiguration , specRetryConfiguration ) ; if ( this . logger ) retrier . logger = this . logger ; const request = await composeRequest ( { baseEndpoint : this . _endpoint , defaultHeaders : this . _defaultHeaders , path : "/workspaces/{workspaceId}/applications/{applicationKey}/patches" , method : "POST" , bodyContent : common . ObjectSerializer . serialize ( createPatchRequest . createPatchDetails , "CreatePatchDetails" , model . CreatePatchDetails . getJsonObj ) , pathParams : pathParams , headerParams : headerParams , queryParams : queryParams } ) ; try { const response = await retrier . makeServiceCall ( this . _httpClient , request ) ; const sdkResponse = composeResponse ( { responseObject : < responses . CreatePatchResponse > { } , body : await response . json ( ) , bodyKey : "patch" , bodyModel : model . Patch , type : "model.Patch" , responseHeaders : [ { value : response . headers . get ( "etag" ) , key : "etag" , dataType : "string" } , { value : response . headers . get ( "opc-request-id" ) , key : "opcRequestId" , dataType : "string" } ] } ) ; return sdkResponse ; } catch ( err ) { throw err ; } } param CreatePipelineRequest return throws example Click  https to see how to use CreatePipeline API.
      public async createPipeline ( createPipelineRequest ) { if ( this . logger ) this . logger . debug ( "Calling operation DataIntegrationClient#createPipeline." ) ; const pathParams = { "{workspaceId}" : createPipelineRequest . workspaceId } ; const queryParams = { } ; let headerParams = { "Content-Type" : common . Constants . APPLICATION_JSON , "opc-retry-token" : createPipelineRequest . opcRetryToken , "opc-request-id" : createPipelineRequest . opcRequestId } ; const specRetryConfiguration = common . NoRetryConfigurationDetails ; const retrier = GenericRetrier . createPreferredRetrier ( this . _clientConfiguration ? this . _clientConfiguration . retryConfiguration : undefined , createPipelineRequest . retryConfiguration , specRetryConfiguration ) ; if ( this . logger ) retrier . logger = this . logger ; const request = await composeRequest ( { baseEndpoint : this . _endpoint , defaultHeaders : this . _defaultHeaders , path : "/workspaces/{workspaceId}/pipelines" , method : "POST" , bodyContent : common . ObjectSerializer . serialize ( createPipelineRequest . createPipelineDetails , "CreatePipelineDetails" , model . CreatePipelineDetails . getJsonObj ) , pathParams : pathParams , headerParams : headerParams , queryParams : queryParams } ) ; try { const response = await retrier . makeServiceCall ( this . _httpClient , request ) ; const sdkResponse = composeResponse ( { responseObject : < responses . CreatePipelineResponse > { } , body : await response . json ( ) , bodyKey : "pipeline" , bodyModel : model . Pipeline , type : "model.Pipeline" , responseHeaders : [ { value : response . headers . get ( "etag" ) , key : "etag" , dataType : "string" } , { value : response . headers . get ( "opc-request-id" ) , key : "opcRequestId" , dataType : "string" } ] } ) ; return sdkResponse ; } catch ( err ) { throw err ; } } param CreatePipelineValidationRequest return throws example Click  https to see how to use CreatePipelineValidation API.
      public async createPipelineValidation ( createPipelineValidationRequest ) { if ( this . logger ) this . logger . debug ( "Calling operation DataIntegrationClient#createPipelineValidation." ) ; const pathParams = { "{workspaceId}" : createPipelineValidationRequest . workspaceId } ; const queryParams = { } ; let headerParams = { "Content-Type" : common . Constants . APPLICATION_JSON , "opc-request-id" : createPipelineValidationRequest . opcRequestId , "opc-retry-token" : createPipelineValidationRequest . opcRetryToken } ; const specRetryConfiguration = common . NoRetryConfigurationDetails ; const retrier = GenericRetrier . createPreferredRetrier ( this . _clientConfiguration ? this . _clientConfiguration . retryConfiguration : undefined , createPipelineValidationRequest . retryConfiguration , specRetryConfiguration ) ; if ( this . logger ) retrier . logger = this . logger ; const request = await composeRequest ( { baseEndpoint : this . _endpoint , defaultHeaders : this . _defaultHeaders , path : "/workspaces/{workspaceId}/pipelineValidations" , method : "POST" , bodyContent : common . ObjectSerializer . serialize ( createPipelineValidationRequest . createPipelineValidationDetails , "CreatePipelineValidationDetails" , model . CreatePipelineValidationDetails . getJsonObj ) , pathParams : pathParams , headerParams : headerParams , queryParams : queryParams } ) ; try { const response = await retrier . makeServiceCall ( this . _httpClient , request ) ; const sdkResponse = composeResponse ( { responseObject : < responses . CreatePipelineValidationResponse > { } , body : await response . json ( ) , bodyKey : "pipelineValidation" , bodyModel : model . PipelineValidation , type : "model.PipelineValidation" , responseHeaders : [ { value : response . headers . get ( "etag" ) , key : "etag" , dataType : "string" } , { value : response . headers . get ( "opc-request-id" ) , key : "opcRequestId" , dataType : "string" } ] } ) ; return sdkResponse ; } catch ( err ) { throw err ; } } param CreateProjectRequest return throws example Click  https to see how to use CreateProject API.
      public async createProject ( createProjectRequest ) { if ( this . logger ) this . logger . debug ( "Calling operation DataIntegrationClient#createProject." ) ; const pathParams = { "{workspaceId}" : createProjectRequest . workspaceId } ; const queryParams = { } ; let headerParams = { "Content-Type" : common . Constants . APPLICATION_JSON , "opc-retry-token" : createProjectRequest . opcRetryToken , "opc-request-id" : createProjectRequest . opcRequestId } ; const specRetryConfiguration = common . NoRetryConfigurationDetails ; const retrier = GenericRetrier . createPreferredRetrier ( this . _clientConfiguration ? this . _clientConfiguration . retryConfiguration : undefined , createProjectRequest . retryConfiguration , specRetryConfiguration ) ; if ( this . logger ) retrier . logger = this . logger ; const request = await composeRequest ( { baseEndpoint : this . _endpoint , defaultHeaders : this . _defaultHeaders , path : "/workspaces/{workspaceId}/projects" , method : "POST" , bodyContent : common . ObjectSerializer . serialize ( createProjectRequest . createProjectDetails , "CreateProjectDetails" , model . CreateProjectDetails . getJsonObj ) , pathParams : pathParams , headerParams : headerParams , queryParams : queryParams } ) ; try { const response = await retrier . makeServiceCall ( this . _httpClient , request ) ; const sdkResponse = composeResponse ( { responseObject : < responses . CreateProjectResponse > { } , body : await response . json ( ) , bodyKey : "project" , bodyModel : model . Project , type : "model.Project" , responseHeaders : [ { value : response . headers . get ( "etag" ) , key : "etag" , dataType : "string" } , { value : response . headers . get ( "opc-request-id" ) , key : "opcRequestId" , dataType : "string" } ] } ) ; return sdkResponse ; } catch ( err ) { throw err ; } } param CreateScheduleRequest return throws example Click  https to see how to use CreateSchedule API.
      public async createSchedule ( createScheduleRequest ) { if ( this . logger ) this . logger . debug ( "Calling operation DataIntegrationClient#createSchedule." ) ; const pathParams = { "{workspaceId}" : createScheduleRequest . workspaceId , "{applicationKey}" : createScheduleRequest . applicationKey } ; const queryParams = { } ; let headerParams = { "Content-Type" : common . Constants . APPLICATION_JSON , "opc-request-id" : createScheduleRequest . opcRequestId , "opc-retry-token" : createScheduleRequest . opcRetryToken } ; const specRetryConfiguration = common . NoRetryConfigurationDetails ; const retrier = GenericRetrier . createPreferredRetrier ( this . _clientConfiguration ? this . _clientConfiguration . retryConfiguration : undefined , createScheduleRequest . retryConfiguration , specRetryConfiguration ) ; if ( this . logger ) retrier . logger = this . logger ; const request = await composeRequest ( { baseEndpoint : this . _endpoint , defaultHeaders : this . _defaultHeaders , path : "/workspaces/{workspaceId}/applications/{applicationKey}/schedules" , method : "POST" , bodyContent : common . ObjectSerializer . serialize ( createScheduleRequest . createScheduleDetails , "CreateScheduleDetails" , model . CreateScheduleDetails . getJsonObj ) , pathParams : pathParams , headerParams : headerParams , queryParams : queryParams } ) ; try { const response = await retrier . makeServiceCall ( this . _httpClient , request ) ; const sdkResponse = composeResponse ( { responseObject : < responses . CreateScheduleResponse > { } , body : await response . json ( ) , bodyKey : "schedule" , bodyModel : model . Schedule , type : "model.Schedule" , responseHeaders : [ { value : response . headers . get ( "opc-request-id" ) , key : "opcRequestId" , dataType : "string" } , { value : response . headers . get ( "etag" ) , key : "etag" , dataType : "string" } ] } ) ; return sdkResponse ; } catch ( err ) { throw err ; } } param CreateTaskRequest return throws example Click  https to see how to use CreateTask API.
      public async createTask ( createTaskRequest ) { if ( this . logger ) this . logger . debug ( "Calling operation DataIntegrationClient#createTask." ) ; const pathParams = { "{workspaceId}" : createTaskRequest . workspaceId } ; const queryParams = { } ; let headerParams = { "Content-Type" : common . Constants . APPLICATION_JSON , "opc-retry-token" : createTaskRequest . opcRetryToken , "opc-request-id" : createTaskRequest . opcRequestId } ; const specRetryConfiguration = common . NoRetryConfigurationDetails ; const retrier = GenericRetrier . createPreferredRetrier ( this . _clientConfiguration ? this . _clientConfiguration . retryConfiguration : undefined , createTaskRequest . retryConfiguration , specRetryConfiguration ) ; if ( this . logger ) retrier . logger = this . logger ; const request = await composeRequest ( { baseEndpoint : this . _endpoint , defaultHeaders : this . _defaultHeaders , path : "/workspaces/{workspaceId}/tasks" , method : "POST" , bodyContent : common . ObjectSerializer . serialize ( createTaskRequest . createTaskDetails , "CreateTaskDetails" , model . CreateTaskDetails . getJsonObj ) , pathParams : pathParams , headerParams : headerParams , queryParams : queryParams } ) ; try { const response = await retrier . makeServiceCall ( this . _httpClient , request ) ; const sdkResponse = composeResponse ( { responseObject : < responses . CreateTaskResponse > { } , body : await response . json ( ) , bodyKey : "task" , bodyModel : model . Task , type : "model.Task" , responseHeaders : [ { value : response . headers . get ( "etag" ) , key : "etag" , dataType : "string" } , { value : response . headers . get ( "opc-request-id" ) , key : "opcRequestId" , dataType : "string" } ] } ) ; return sdkResponse ; } catch ( err ) { throw err ; } } param CreateTaskRunRequest return throws example Click  https to see how to use CreateTaskRun API.
      public async createTaskRun ( createTaskRunRequest ) { if ( this . logger ) this . logger . debug ( "Calling operation DataIntegrationClient#createTaskRun." ) ; const pathParams = { "{workspaceId}" : createTaskRunRequest . workspaceId , "{applicationKey}" : createTaskRunRequest . applicationKey } ; const queryParams = { } ; let headerParams = { "Content-Type" : common . Constants . APPLICATION_JSON , "opc-retry-token" : createTaskRunRequest . opcRetryToken , "opc-request-id" : createTaskRunRequest . opcRequestId } ; const specRetryConfiguration = common . NoRetryConfigurationDetails ; const retrier = GenericRetrier . createPreferredRetrier ( this . _clientConfiguration ? this . _clientConfiguration . retryConfiguration : undefined , createTaskRunRequest . retryConfiguration , specRetryConfiguration ) ; if ( this . logger ) retrier . logger = this . logger ; const request = await composeRequest ( { baseEndpoint : this . _endpoint , defaultHeaders : this . _defaultHeaders , path : "/workspaces/{workspaceId}/applications/{applicationKey}/taskRuns" , method : "POST" , bodyContent : common . ObjectSerializer . serialize ( createTaskRunRequest . createTaskRunDetails , "CreateTaskRunDetails" , model . CreateTaskRunDetails . getJsonObj ) , pathParams : pathParams , headerParams : headerParams , queryParams : queryParams } ) ; try { const response = await retrier . makeServiceCall ( this . _httpClient , request ) ; const sdkResponse = composeResponse ( { responseObject : < responses . CreateTaskRunResponse > { } , body : await response . json ( ) , bodyKey : "taskRun" , bodyModel : model . TaskRun , type : "model.TaskRun" , responseHeaders : [ { value : response . headers . get ( "etag" ) , key : "etag" , dataType : "string" } , { value : response . headers . get ( "opc-request-id" ) , key : "opcRequestId" , dataType : "string" } ] } ) ; return sdkResponse ; } catch ( err ) { throw err ; } } param CreateTaskScheduleRequest return throws example Click  https to see how to use CreateTaskSchedule API.
      public async createTaskSchedule ( createTaskScheduleRequest ) { if ( this . logger ) this . logger . debug ( "Calling operation DataIntegrationClient#createTaskSchedule." ) ; const pathParams = { "{workspaceId}" : createTaskScheduleRequest . workspaceId , "{applicationKey}" : createTaskScheduleRequest . applicationKey } ; const queryParams = { } ; let headerParams = { "Content-Type" : common . Constants . APPLICATION_JSON , "opc-request-id" : createTaskScheduleRequest . opcRequestId , "opc-retry-token" : createTaskScheduleRequest . opcRetryToken } ; const specRetryConfiguration = common . NoRetryConfigurationDetails ; const retrier = GenericRetrier . createPreferredRetrier ( this . _clientConfiguration ? this . _clientConfiguration . retryConfiguration : undefined , createTaskScheduleRequest . retryConfiguration , specRetryConfiguration ) ; if ( this . logger ) retrier . logger = this . logger ; const request = await composeRequest ( { baseEndpoint : this . _endpoint , defaultHeaders : this . _defaultHeaders , path : "/workspaces/{workspaceId}/applications/{applicationKey}/taskSchedules" , method : "POST" , bodyContent : common . ObjectSerializer . serialize ( createTaskScheduleRequest . createTaskScheduleDetails , "CreateTaskScheduleDetails" , model . CreateTaskScheduleDetails . getJsonObj ) , pathParams : pathParams , headerParams : headerParams , queryParams : queryParams } ) ; try { const response = await retrier . makeServiceCall ( this . _httpClient , request ) ; const sdkResponse = composeResponse ( { responseObject : < responses . CreateTaskScheduleResponse > { } , body : await response . json ( ) , bodyKey : "taskSchedule" , bodyModel : model . TaskSchedule , type : "model.TaskSchedule" , responseHeaders : [ { value : response . headers . get ( "opc-request-id" ) , key : "opcRequestId" , dataType : "string" } , { value : response . headers . get ( "etag" ) , key : "etag" , dataType : "string" } ] } ) ; return sdkResponse ; } catch ( err ) { throw err ; } } param CreateTaskValidationRequest return throws example Click  https to see how to use CreateTaskValidation API.
      public async createTaskValidation ( createTaskValidationRequest ) { if ( this . logger ) this . logger . debug ( "Calling operation DataIntegrationClient#createTaskValidation." ) ; const pathParams = { "{workspaceId}" : createTaskValidationRequest . workspaceId } ; const queryParams = { } ; let headerParams = { "Content-Type" : common . Constants . APPLICATION_JSON , "opc-request-id" : createTaskValidationRequest . opcRequestId , "opc-retry-token" : createTaskValidationRequest . opcRetryToken } ; const specRetryConfiguration = common . NoRetryConfigurationDetails ; const retrier = GenericRetrier . createPreferredRetrier ( this . _clientConfiguration ? this . _clientConfiguration . retryConfiguration : undefined , createTaskValidationRequest . retryConfiguration , specRetryConfiguration ) ; if ( this . logger ) retrier . logger = this . logger ; const request = await composeRequest ( { baseEndpoint : this . _endpoint , defaultHeaders : this . _defaultHeaders , path : "/workspaces/{workspaceId}/taskValidations" , method : "POST" , bodyContent : common . ObjectSerializer . serialize ( createTaskValidationRequest . createTaskValidationDetails , "CreateTaskValidationDetails" , model . CreateTaskValidationDetails . getJsonObj ) , pathParams : pathParams , headerParams : headerParams , queryParams : queryParams } ) ; try { const response = await retrier . makeServiceCall ( this . _httpClient , request ) ; const sdkResponse = composeResponse ( { responseObject : < responses . CreateTaskValidationResponse > { } , body : await response . json ( ) , bodyKey : "taskValidation" , bodyModel : model . TaskValidation , type : "model.TaskValidation" , responseHeaders : [ { value : response . headers . get ( "etag" ) , key : "etag" , dataType : "string" } , { value : response . headers . get ( "opc-request-id" ) , key : "opcRequestId" , dataType : "string" } ] } ) ; return sdkResponse ; } catch ( err ) { throw err ; } } param CreateUserDefinedFunctionRequest return throws example Click  https to see how to use CreateUserDefinedFunction API.
      public async createUserDefinedFunction ( createUserDefinedFunctionRequest ) { if ( this . logger ) this . logger . debug ( "Calling operation DataIntegrationClient#createUserDefinedFunction." ) ; const pathParams = { "{workspaceId}" : createUserDefinedFunctionRequest . workspaceId } ; const queryParams = { } ; let headerParams = { "Content-Type" : common . Constants . APPLICATION_JSON , "opc-retry-token" : createUserDefinedFunctionRequest . opcRetryToken , "opc-request-id" : createUserDefinedFunctionRequest . opcRequestId } ; const specRetryConfiguration = common . NoRetryConfigurationDetails ; const retrier = GenericRetrier . createPreferredRetrier ( this . _clientConfiguration ? this . _clientConfiguration . retryConfiguration : undefined , createUserDefinedFunctionRequest . retryConfiguration , specRetryConfiguration ) ; if ( this . logger ) retrier . logger = this . logger ; const request = await composeRequest ( { baseEndpoint : this . _endpoint , defaultHeaders : this . _defaultHeaders , path : "/workspaces/{workspaceId}/userDefinedFunctions" , method : "POST" , bodyContent : common . ObjectSerializer . serialize ( createUserDefinedFunctionRequest . createUserDefinedFunctionDetails , "CreateUserDefinedFunctionDetails" , model . CreateUserDefinedFunctionDetails . getJsonObj ) , pathParams : pathParams , headerParams : headerParams , queryParams : queryParams } ) ; try { const response = await retrier . makeServiceCall ( this . _httpClient , request ) ; const sdkResponse = composeResponse ( { responseObject : < responses . CreateUserDefinedFunctionResponse > { } , body : await response . json ( ) , bodyKey : "userDefinedFunction" , bodyModel : model . UserDefinedFunction , type : "model.UserDefinedFunction" , responseHeaders : [ { value : response . headers . get ( "etag" ) , key : "etag" , dataType : "string" } , { value : response . headers . get ( "opc-request-id" ) , key : "opcRequestId" , dataType : "string" } ] } ) ; return sdkResponse ; } catch ( err ) { throw err ; } } param CreateUserDefinedFunctionValidationRequest return throws example Click  https to see how to use CreateUserDefinedFunctionValidation API.
      public async createUserDefinedFunctionValidation ( createUserDefinedFunctionValidationRequest ) { if ( this . logger ) this . logger . debug ( "Calling operation DataIntegrationClient#createUserDefinedFunctionValidation." ) ; const pathParams = { "{workspaceId}" : createUserDefinedFunctionValidationRequest . workspaceId } ; const queryParams = { } ; let headerParams = { "Content-Type" : common . Constants . APPLICATION_JSON , "opc-request-id" : createUserDefinedFunctionValidationRequest . opcRequestId , "opc-retry-token" : createUserDefinedFunctionValidationRequest . opcRetryToken } ; const specRetryConfiguration = common . NoRetryConfigurationDetails ; const retrier = GenericRetrier . createPreferredRetrier ( this . _clientConfiguration ? this . _clientConfiguration . retryConfiguration : undefined , createUserDefinedFunctionValidationRequest . retryConfiguration , specRetryConfiguration ) ; if ( this . logger ) retrier . logger = this . logger ; const request = await composeRequest ( { baseEndpoint : this . _endpoint , defaultHeaders : this . _defaultHeaders , path : "/workspaces/{workspaceId}/userDefinedFunctionValidations" , method : "POST" , bodyContent : common . ObjectSerializer . serialize ( createUserDefinedFunctionValidationRequest . createUserDefinedFunctionValidationDetails , "CreateUserDefinedFunctionValidationDetails" , model . CreateUserDefinedFunctionValidationDetails . getJsonObj ) , pathParams : pathParams , headerParams : headerParams , queryParams : queryParams } ) ; try { const response = await retrier . makeServiceCall ( this . _httpClient , request ) ; const sdkResponse = composeResponse ( { responseObject : < responses . CreateUserDefinedFunctionValidationResponse > { } , body : await response . json ( ) , bodyKey : "userDefinedFunctionValidation" , bodyModel : model . UserDefinedFunctionValidation , type : "model.UserDefinedFunctionValidation" , responseHeaders : [ { value : response . headers . get ( "etag" ) , key : "etag" , dataType : "string" } , { value : response . headers . get ( "opc-request-id" ) , key : "opcRequestId" , dataType : "string" } ] } ) ; return sdkResponse ; } catch ( err ) { throw err ; } } /**
     * Creates a new Data Integration workspace ready for performing data integration tasks. To retrieve the OCID for the new workspace, use the opc-work-request-id returned by this API and call the  {@link #getWorkRequest(GetWorkRequestRequest) getWorkRequest} API.
     *
     * This operation does not retry by default if the user has not defined a retry configuration.
     *  param CreateWorkspaceRequest return throws example Click  https to see how to use CreateWorkspace API.
      public async createWorkspace ( createWorkspaceRequest ) { if ( this . logger ) this . logger . debug ( "Calling operation DataIntegrationClient#createWorkspace." ) ; const pathParams = { } ; const queryParams = { } ; let headerParams = { "Content-Type" : common . Constants . APPLICATION_JSON , "opc-retry-token" : createWorkspaceRequest . opcRetryToken , "opc-request-id" : createWorkspaceRequest . opcRequestId } ; const specRetryConfiguration = common . NoRetryConfigurationDetails ; const retrier = GenericRetrier . createPreferredRetrier ( this . _clientConfiguration ? this . _clientConfiguration . retryConfiguration : undefined , createWorkspaceRequest . retryConfiguration , specRetryConfiguration ) ; if ( this . logger ) retrier . logger = this . logger ; const request = await composeRequest ( { baseEndpoint : this . _endpoint , defaultHeaders : this . _defaultHeaders , path : "/workspaces" , method : "POST" , bodyContent : common . ObjectSerializer . serialize ( createWorkspaceRequest . createWorkspaceDetails , "CreateWorkspaceDetails" , model . CreateWorkspaceDetails . getJsonObj ) , pathParams : pathParams , headerParams : headerParams , queryParams : queryParams } ) ; try { const response = await retrier . makeServiceCall ( this . _httpClient , request ) ; const sdkResponse = composeResponse ( { responseObject : < responses . CreateWorkspaceResponse > { } , responseHeaders : [ { value : response . headers . get ( "opc-request-id" ) , key : "opcRequestId" , dataType : "string" } , { value : response . headers . get ( "opc-work-request-id" ) , key : "opcWorkRequestId" , dataType : "string" } ] } ) ; return sdkResponse ; } catch ( err ) { throw err ; } } param DeleteApplicationRequest return throws example Click  https to see how to use DeleteApplication API.
      public async deleteApplication ( deleteApplicationRequest ) { if ( this . logger ) this . logger . debug ( "Calling operation DataIntegrationClient#deleteApplication." ) ; const pathParams = { "{workspaceId}" : deleteApplicationRequest . workspaceId , "{applicationKey}" : deleteApplicationRequest . applicationKey } ; const queryParams = { } ; let headerParams = { "Content-Type" : common . Constants . APPLICATION_JSON , "if-match" : deleteApplicationRequest . ifMatch , "opc-request-id" : deleteApplicationRequest . opcRequestId } ; const specRetryConfiguration = common . NoRetryConfigurationDetails ; const retrier = GenericRetrier . createPreferredRetrier ( this . _clientConfiguration ? this . _clientConfiguration . retryConfiguration : undefined , deleteApplicationRequest . retryConfiguration , specRetryConfiguration ) ; if ( this . logger ) retrier . logger = this . logger ; const request = await composeRequest ( { baseEndpoint : this . _endpoint , defaultHeaders : this . _defaultHeaders , path : "/workspaces/{workspaceId}/applications/{applicationKey}" , method : "DELETE" , pathParams : pathParams , headerParams : headerParams , queryParams : queryParams } ) ; try { const response = await retrier . makeServiceCall ( this . _httpClient , request ) ; const sdkResponse = composeResponse ( { responseObject : < responses . DeleteApplicationResponse > { } , responseHeaders : [ { value : response . headers . get ( "opc-request-id" ) , key : "opcRequestId" , dataType : "string" } ] } ) ; return sdkResponse ; } catch ( err ) { throw err ; } } param DeleteConnectionRequest return throws example Click  https to see how to use DeleteConnection API.
      public async deleteConnection ( deleteConnectionRequest ) { if ( this . logger ) this . logger . debug ( "Calling operation DataIntegrationClient#deleteConnection." ) ; const pathParams = { "{workspaceId}" : deleteConnectionRequest . workspaceId , "{connectionKey}" : deleteConnectionRequest . connectionKey } ; const queryParams = { } ; let headerParams = { "Content-Type" : common . Constants . APPLICATION_JSON , "if-match" : deleteConnectionRequest . ifMatch , "opc-request-id" : deleteConnectionRequest . opcRequestId } ; const specRetryConfiguration = common . NoRetryConfigurationDetails ; const retrier = GenericRetrier . createPreferredRetrier ( this . _clientConfiguration ? this . _clientConfiguration . retryConfiguration : undefined , deleteConnectionRequest . retryConfiguration , specRetryConfiguration ) ; if ( this . logger ) retrier . logger = this . logger ; const request = await composeRequest ( { baseEndpoint : this . _endpoint , defaultHeaders : this . _defaultHeaders , path : "/workspaces/{workspaceId}/connections/{connectionKey}" , method : "DELETE" , pathParams : pathParams , headerParams : headerParams , queryParams : queryParams } ) ; try { const response = await retrier . makeServiceCall ( this . _httpClient , request ) ; const sdkResponse = composeResponse ( { responseObject : < responses . DeleteConnectionResponse > { } , responseHeaders : [ { value : response . headers . get ( "opc-request-id" ) , key : "opcRequestId" , dataType : "string" } ] } ) ; return sdkResponse ; } catch ( err ) { throw err ; } } param DeleteConnectionValidationRequest return throws example Click  https to see how to use DeleteConnectionValidation API.
      public async deleteConnectionValidation ( deleteConnectionValidationRequest ) { if ( this . logger ) this . logger . debug ( "Calling operation DataIntegrationClient#deleteConnectionValidation." ) ; const pathParams = { "{workspaceId}" : deleteConnectionValidationRequest . workspaceId , "{connectionValidationKey}" : deleteConnectionValidationRequest . connectionValidationKey } ; const queryParams = { } ; let headerParams = { "Content-Type" : common . Constants . APPLICATION_JSON , "if-match" : deleteConnectionValidationRequest . ifMatch , "opc-request-id" : deleteConnectionValidationRequest . opcRequestId } ; const specRetryConfiguration = common . NoRetryConfigurationDetails ; const retrier = GenericRetrier . createPreferredRetrier ( this . _clientConfiguration ? this . _clientConfiguration . retryConfiguration : undefined , deleteConnectionValidationRequest . retryConfiguration , specRetryConfiguration ) ; if ( this . logger ) retrier . logger = this . logger ; const request = await composeRequest ( { baseEndpoint : this . _endpoint , defaultHeaders : this . _defaultHeaders , path : "/workspaces/{workspaceId}/connectionValidations/{connectionValidationKey}" , method : "DELETE" , pathParams : pathParams , headerParams : headerParams , queryParams : queryParams } ) ; try { const response = await retrier . makeServiceCall ( this . _httpClient , request ) ; const sdkResponse = composeResponse ( { responseObject : < responses . DeleteConnectionValidationResponse > { } , responseHeaders : [ { value : response . headers . get ( "opc-request-id" ) , key : "opcRequestId" , dataType : "string" } ] } ) ; return sdkResponse ; } catch ( err ) { throw err ; } } param DeleteDataAssetRequest return throws example Click  https to see how to use DeleteDataAsset API.
      public async deleteDataAsset ( deleteDataAssetRequest ) { if ( this . logger ) this . logger . debug ( "Calling operation DataIntegrationClient#deleteDataAsset." ) ; const pathParams = { "{workspaceId}" : deleteDataAssetRequest . workspaceId , "{dataAssetKey}" : deleteDataAssetRequest . dataAssetKey } ; const queryParams = { } ; let headerParams = { "Content-Type" : common . Constants . APPLICATION_JSON , "if-match" : deleteDataAssetRequest . ifMatch , "opc-request-id" : deleteDataAssetRequest . opcRequestId } ; const specRetryConfiguration = common . NoRetryConfigurationDetails ; const retrier = GenericRetrier . createPreferredRetrier ( this . _clientConfiguration ? this . _clientConfiguration . retryConfiguration : undefined , deleteDataAssetRequest . retryConfiguration , specRetryConfiguration ) ; if ( this . logger ) retrier . logger = this . logger ; const request = await composeRequest ( { baseEndpoint : this . _endpoint , defaultHeaders : this . _defaultHeaders , path : "/workspaces/{workspaceId}/dataAssets/{dataAssetKey}" , method : "DELETE" , pathParams : pathParams , headerParams : headerParams , queryParams : queryParams } ) ; try { const response = await retrier . makeServiceCall ( this . _httpClient , request ) ; const sdkResponse = composeResponse ( { responseObject : < responses . DeleteDataAssetResponse > { } , responseHeaders : [ { value : response . headers . get ( "opc-request-id" ) , key : "opcRequestId" , dataType : "string" } ] } ) ; return sdkResponse ; } catch ( err ) { throw err ; } } param DeleteDataFlowRequest return throws example Click  https to see how to use DeleteDataFlow API.
      public async deleteDataFlow ( deleteDataFlowRequest ) { if ( this . logger ) this . logger . debug ( "Calling operation DataIntegrationClient#deleteDataFlow." ) ; const pathParams = { "{workspaceId}" : deleteDataFlowRequest . workspaceId , "{dataFlowKey}" : deleteDataFlowRequest . dataFlowKey } ; const queryParams = { } ; let headerParams = { "Content-Type" : common . Constants . APPLICATION_JSON , "if-match" : deleteDataFlowRequest . ifMatch , "opc-request-id" : deleteDataFlowRequest . opcRequestId } ; const specRetryConfiguration = common . NoRetryConfigurationDetails ; const retrier = GenericRetrier . createPreferredRetrier ( this . _clientConfiguration ? this . _clientConfiguration . retryConfiguration : undefined , deleteDataFlowRequest . retryConfiguration , specRetryConfiguration ) ; if ( this . logger ) retrier . logger = this . logger ; const request = await composeRequest ( { baseEndpoint : this . _endpoint , defaultHeaders : this . _defaultHeaders , path : "/workspaces/{workspaceId}/dataFlows/{dataFlowKey}" , method : "DELETE" , pathParams : pathParams , headerParams : headerParams , queryParams : queryParams } ) ; try { const response = await retrier . makeServiceCall ( this . _httpClient , request ) ; const sdkResponse = composeResponse ( { responseObject : < responses . DeleteDataFlowResponse > { } , responseHeaders : [ { value : response . headers . get ( "opc-request-id" ) , key : "opcRequestId" , dataType : "string" } ] } ) ; return sdkResponse ; } catch ( err ) { throw err ; } } param DeleteDataFlowValidationRequest return throws example Click  https to see how to use DeleteDataFlowValidation API.
      public async deleteDataFlowValidation ( deleteDataFlowValidationRequest ) { if ( this . logger ) this . logger . debug ( "Calling operation DataIntegrationClient#deleteDataFlowValidation." ) ; const pathParams = { "{workspaceId}" : deleteDataFlowValidationRequest . workspaceId , "{dataFlowValidationKey}" : deleteDataFlowValidationRequest . dataFlowValidationKey } ; const queryParams = { } ; let headerParams = { "Content-Type" : common . Constants . APPLICATION_JSON , "if-match" : deleteDataFlowValidationRequest . ifMatch , "opc-request-id" : deleteDataFlowValidationRequest . opcRequestId } ; const specRetryConfiguration = common . NoRetryConfigurationDetails ; const retrier = GenericRetrier . createPreferredRetrier ( this . _clientConfiguration ? this . _clientConfiguration . retryConfiguration : undefined , deleteDataFlowValidationRequest . retryConfiguration , specRetryConfiguration ) ; if ( this . logger ) retrier . logger = this . logger ; const request = await composeRequest ( { baseEndpoint : this . _endpoint , defaultHeaders : this . _defaultHeaders , path : "/workspaces/{workspaceId}/dataFlowValidations/{dataFlowValidationKey}" , method : "DELETE" , pathParams : pathParams , headerParams : headerParams , queryParams : queryParams } ) ; try { const response = await retrier . makeServiceCall ( this . _httpClient , request ) ; const sdkResponse = composeResponse ( { responseObject : < responses . DeleteDataFlowValidationResponse > { } , responseHeaders : [ { value : response . headers . get ( "opc-request-id" ) , key : "opcRequestId" , dataType : "string" } ] } ) ; return sdkResponse ; } catch ( err ) { throw err ; } } param DeleteExternalPublicationRequest return throws example Click  https to see how to use DeleteExternalPublication API.
      public async deleteExternalPublication ( deleteExternalPublicationRequest ) { if ( this . logger ) this . logger . debug ( "Calling operation DataIntegrationClient#deleteExternalPublication." ) ; const pathParams = { "{workspaceId}" : deleteExternalPublicationRequest . workspaceId , "{taskKey}" : deleteExternalPublicationRequest . taskKey , "{externalPublicationsKey}" : deleteExternalPublicationRequest . externalPublicationsKey } ; const queryParams = { } ; let headerParams = { "Content-Type" : common . Constants . APPLICATION_JSON , "if-match" : deleteExternalPublicationRequest . ifMatch , "opc-request-id" : deleteExternalPublicationRequest . opcRequestId } ; const specRetryConfiguration = common . NoRetryConfigurationDetails ; const retrier = GenericRetrier . createPreferredRetrier ( this . _clientConfiguration ? this . _clientConfiguration . retryConfiguration : undefined , deleteExternalPublicationRequest . retryConfiguration , specRetryConfiguration ) ; if ( this . logger ) retrier . logger = this . logger ; const request = await composeRequest ( { baseEndpoint : this . _endpoint , defaultHeaders : this . _defaultHeaders , path : "/workspaces/{workspaceId}/tasks/{taskKey}/externalPublications/{externalPublicationsKey}" , method : "DELETE" , pathParams : pathParams , headerParams : headerParams , queryParams : queryParams } ) ; try { const response = await retrier . makeServiceCall ( this . _httpClient , request ) ; const sdkResponse = composeResponse ( { responseObject : < responses . DeleteExternalPublicationResponse > { } , responseHeaders : [ { value : response . headers . get ( "opc-request-id" ) , key : "opcRequestId" , dataType : "string" } ] } ) ; return sdkResponse ; } catch ( err ) { throw err ; } } param DeleteExternalPublicationValidationRequest return throws example Click  https to see how to use DeleteExternalPublicationValidation API.
      public async deleteExternalPublicationValidation ( deleteExternalPublicationValidationRequest ) { if ( this . logger ) this . logger . debug ( "Calling operation DataIntegrationClient#deleteExternalPublicationValidation." ) ; const pathParams = { "{workspaceId}" : deleteExternalPublicationValidationRequest . workspaceId , "{taskKey}" : deleteExternalPublicationValidationRequest . taskKey , "{externalPublicationValidationKey}" : deleteExternalPublicationValidationRequest . externalPublicationValidationKey } ; const queryParams = { } ; let headerParams = { "Content-Type" : common . Constants . APPLICATION_JSON , "if-match" : deleteExternalPublicationValidationRequest . ifMatch , "opc-request-id" : deleteExternalPublicationValidationRequest . opcRequestId } ; const specRetryConfiguration = common . NoRetryConfigurationDetails ; const retrier = GenericRetrier . createPreferredRetrier ( this . _clientConfiguration ? this . _clientConfiguration . retryConfiguration : undefined , deleteExternalPublicationValidationRequest . retryConfiguration , specRetryConfiguration ) ; if ( this . logger ) retrier . logger = this . logger ; const request = await composeRequest ( { baseEndpoint : this . _endpoint , defaultHeaders : this . _defaultHeaders , path : "/workspaces/{workspaceId}/tasks/{taskKey}/externalPublicationValidations/{externalPublicationValidationKey}" , method : "DELETE" , pathParams : pathParams , headerParams : headerParams , queryParams : queryParams } ) ; try { const response = await retrier . makeServiceCall ( this . _httpClient , request ) ; const sdkResponse = composeResponse ( { responseObject : < responses . DeleteExternalPublicationValidationResponse > { } , responseHeaders : [ { value : response . headers . get ( "opc-request-id" ) , key : "opcRequestId" , dataType : "string" } ] } ) ; return sdkResponse ; } catch ( err ) { throw err ; } } param DeleteFolderRequest return throws example Click  https to see how to use DeleteFolder API.
      public async deleteFolder ( deleteFolderRequest ) { if ( this . logger ) this . logger . debug ( "Calling operation DataIntegrationClient#deleteFolder." ) ; const pathParams = { "{workspaceId}" : deleteFolderRequest . workspaceId , "{folderKey}" : deleteFolderRequest . folderKey } ; const queryParams = { } ; let headerParams = { "Content-Type" : common . Constants . APPLICATION_JSON , "if-match" : deleteFolderRequest . ifMatch , "opc-request-id" : deleteFolderRequest . opcRequestId } ; const specRetryConfiguration = common . NoRetryConfigurationDetails ; const retrier = GenericRetrier . createPreferredRetrier ( this . _clientConfiguration ? this . _clientConfiguration . retryConfiguration : undefined , deleteFolderRequest . retryConfiguration , specRetryConfiguration ) ; if ( this . logger ) retrier . logger = this . logger ; const request = await composeRequest ( { baseEndpoint : this . _endpoint , defaultHeaders : this . _defaultHeaders , path : "/workspaces/{workspaceId}/folders/{folderKey}" , method : "DELETE" , pathParams : pathParams , headerParams : headerParams , queryParams : queryParams } ) ; try { const response = await retrier . makeServiceCall ( this . _httpClient , request ) ; const sdkResponse = composeResponse ( { responseObject : < responses . DeleteFolderResponse > { } , responseHeaders : [ { value : response . headers . get ( "opc-request-id" ) , key : "opcRequestId" , dataType : "string" } ] } ) ; return sdkResponse ; } catch ( err ) { throw err ; } } param DeleteFunctionLibraryRequest return throws example Click  https to see how to use DeleteFunctionLibrary API.
      public async deleteFunctionLibrary ( deleteFunctionLibraryRequest ) { if ( this . logger ) this . logger . debug ( "Calling operation DataIntegrationClient#deleteFunctionLibrary." ) ; const pathParams = { "{workspaceId}" : deleteFunctionLibraryRequest . workspaceId , "{functionLibraryKey}" : deleteFunctionLibraryRequest . functionLibraryKey } ; const queryParams = { } ; let headerParams = { "Content-Type" : common . Constants . APPLICATION_JSON , "if-match" : deleteFunctionLibraryRequest . ifMatch , "opc-request-id" : deleteFunctionLibraryRequest . opcRequestId } ; const specRetryConfiguration = common . NoRetryConfigurationDetails ; const retrier = GenericRetrier . createPreferredRetrier ( this . _clientConfiguration ? this . _clientConfiguration . retryConfiguration : undefined , deleteFunctionLibraryRequest . retryConfiguration , specRetryConfiguration ) ; if ( this . logger ) retrier . logger = this . logger ; const request = await composeRequest ( { baseEndpoint : this . _endpoint , defaultHeaders : this . _defaultHeaders , path : "/workspaces/{workspaceId}/functionLibraries/{functionLibraryKey}" , method : "DELETE" , pathParams : pathParams , headerParams : headerParams , queryParams : queryParams } ) ; try { const response = await retrier . makeServiceCall ( this . _httpClient , request ) ; const sdkResponse = composeResponse ( { responseObject : < responses . DeleteFunctionLibraryResponse > { } , responseHeaders : [ { value : response . headers . get ( "opc-request-id" ) , key : "opcRequestId" , dataType : "string" } ] } ) ; return sdkResponse ; } catch ( err ) { throw err ; } } param DeletePatchRequest return throws example Click  https to see how to use DeletePatch API.
      public async deletePatch ( deletePatchRequest ) { if ( this . logger ) this . logger . debug ( "Calling operation DataIntegrationClient#deletePatch." ) ; const pathParams = { "{workspaceId}" : deletePatchRequest . workspaceId , "{applicationKey}" : deletePatchRequest . applicationKey , "{patchKey}" : deletePatchRequest . patchKey } ; const queryParams = { } ; let headerParams = { "Content-Type" : common . Constants . APPLICATION_JSON , "if-match" : deletePatchRequest . ifMatch , "opc-request-id" : deletePatchRequest . opcRequestId } ; const specRetryConfiguration = common . NoRetryConfigurationDetails ; const retrier = GenericRetrier . createPreferredRetrier ( this . _clientConfiguration ? this . _clientConfiguration . retryConfiguration : undefined , deletePatchRequest . retryConfiguration , specRetryConfiguration ) ; if ( this . logger ) retrier . logger = this . logger ; const request = await composeRequest ( { baseEndpoint : this . _endpoint , defaultHeaders : this . _defaultHeaders , path : "/workspaces/{workspaceId}/applications/{applicationKey}/patches/{patchKey}" , method : "DELETE" , pathParams : pathParams , headerParams : headerParams , queryParams : queryParams } ) ; try { const response = await retrier . makeServiceCall ( this . _httpClient , request ) ; const sdkResponse = composeResponse ( { responseObject : < responses . DeletePatchResponse > { } , responseHeaders : [ { value : response . headers . get ( "opc-request-id" ) , key : "opcRequestId" , dataType : "string" } ] } ) ; return sdkResponse ; } catch ( err ) { throw err ; } } param DeletePipelineRequest return throws example Click  https to see how to use DeletePipeline API.
      public async deletePipeline ( deletePipelineRequest ) { if ( this . logger ) this . logger . debug ( "Calling operation DataIntegrationClient#deletePipeline." ) ; const pathParams = { "{workspaceId}" : deletePipelineRequest . workspaceId , "{pipelineKey}" : deletePipelineRequest . pipelineKey } ; const queryParams = { } ; let headerParams = { "Content-Type" : common . Constants . APPLICATION_JSON , "if-match" : deletePipelineRequest . ifMatch , "opc-request-id" : deletePipelineRequest . opcRequestId } ; const specRetryConfiguration = common . NoRetryConfigurationDetails ; const retrier = GenericRetrier . createPreferredRetrier ( this . _clientConfiguration ? this . _clientConfiguration . retryConfiguration : undefined , deletePipelineRequest . retryConfiguration , specRetryConfiguration ) ; if ( this . logger ) retrier . logger = this . logger ; const request = await composeRequest ( { baseEndpoint : this . _endpoint , defaultHeaders : this . _defaultHeaders , path : "/workspaces/{workspaceId}/pipelines/{pipelineKey}" , method : "DELETE" , pathParams : pathParams , headerParams : headerParams , queryParams : queryParams } ) ; try { const response = await retrier . makeServiceCall ( this . _httpClient , request ) ; const sdkResponse = composeResponse ( { responseObject : < responses . DeletePipelineResponse > { } , responseHeaders : [ { value : response . headers . get ( "opc-request-id" ) , key : "opcRequestId" , dataType : "string" } ] } ) ; return sdkResponse ; } catch ( err ) { throw err ; } } param DeletePipelineValidationRequest return throws example Click  https to see how to use DeletePipelineValidation API.
      public async deletePipelineValidation ( deletePipelineValidationRequest ) { if ( this . logger ) this . logger . debug ( "Calling operation DataIntegrationClient#deletePipelineValidation." ) ; const pathParams = { "{workspaceId}" : deletePipelineValidationRequest . workspaceId , "{pipelineValidationKey}" : deletePipelineValidationRequest . pipelineValidationKey } ; const queryParams = { } ; let headerParams = { "Content-Type" : common . Constants . APPLICATION_JSON , "if-match" : deletePipelineValidationRequest . ifMatch , "opc-request-id" : deletePipelineValidationRequest . opcRequestId } ; const specRetryConfiguration = common . NoRetryConfigurationDetails ; const retrier = GenericRetrier . createPreferredRetrier ( this . _clientConfiguration ? this . _clientConfiguration . retryConfiguration : undefined , deletePipelineValidationRequest . retryConfiguration , specRetryConfiguration ) ; if ( this . logger ) retrier . logger = this . logger ; const request = await composeRequest ( { baseEndpoint : this . _endpoint , defaultHeaders : this . _defaultHeaders , path : "/workspaces/{workspaceId}/pipelineValidations/{pipelineValidationKey}" , method : "DELETE" , pathParams : pathParams , headerParams : headerParams , queryParams : queryParams } ) ; try { const response = await retrier . makeServiceCall ( this . _httpClient , request ) ; const sdkResponse = composeResponse ( { responseObject : < responses . DeletePipelineValidationResponse > { } , responseHeaders : [ { value : response . headers . get ( "opc-request-id" ) , key : "opcRequestId" , dataType : "string" } ] } ) ; return sdkResponse ; } catch ( err ) { throw err ; } } param DeleteProjectRequest return throws example Click  https to see how to use DeleteProject API.
      public async deleteProject ( deleteProjectRequest ) { if ( this . logger ) this . logger . debug ( "Calling operation DataIntegrationClient#deleteProject." ) ; const pathParams = { "{workspaceId}" : deleteProjectRequest . workspaceId , "{projectKey}" : deleteProjectRequest . projectKey } ; const queryParams = { } ; let headerParams = { "Content-Type" : common . Constants . APPLICATION_JSON , "if-match" : deleteProjectRequest . ifMatch , "opc-request-id" : deleteProjectRequest . opcRequestId } ; const specRetryConfiguration = common . NoRetryConfigurationDetails ; const retrier = GenericRetrier . createPreferredRetrier ( this . _clientConfiguration ? this . _clientConfiguration . retryConfiguration : undefined , deleteProjectRequest . retryConfiguration , specRetryConfiguration ) ; if ( this . logger ) retrier . logger = this . logger ; const request = await composeRequest ( { baseEndpoint : this . _endpoint , defaultHeaders : this . _defaultHeaders , path : "/workspaces/{workspaceId}/projects/{projectKey}" , method : "DELETE" , pathParams : pathParams , headerParams : headerParams , queryParams : queryParams } ) ; try { const response = await retrier . makeServiceCall ( this . _httpClient , request ) ; const sdkResponse = composeResponse ( { responseObject : < responses . DeleteProjectResponse > { } , responseHeaders : [ { value : response . headers . get ( "opc-request-id" ) , key : "opcRequestId" , dataType : "string" } ] } ) ; return sdkResponse ; } catch ( err ) { throw err ; } } param DeleteScheduleRequest return throws example Click  https to see how to use DeleteSchedule API.
      public async deleteSchedule ( deleteScheduleRequest ) { if ( this . logger ) this . logger . debug ( "Calling operation DataIntegrationClient#deleteSchedule." ) ; const pathParams = { "{workspaceId}" : deleteScheduleRequest . workspaceId , "{applicationKey}" : deleteScheduleRequest . applicationKey , "{scheduleKey}" : deleteScheduleRequest . scheduleKey } ; const queryParams = { } ; let headerParams = { "Content-Type" : common . Constants . APPLICATION_JSON , "if-match" : deleteScheduleRequest . ifMatch , "opc-request-id" : deleteScheduleRequest . opcRequestId } ; const specRetryConfiguration = common . NoRetryConfigurationDetails ; const retrier = GenericRetrier . createPreferredRetrier ( this . _clientConfiguration ? this . _clientConfiguration . retryConfiguration : undefined , deleteScheduleRequest . retryConfiguration , specRetryConfiguration ) ; if ( this . logger ) retrier . logger = this . logger ; const request = await composeRequest ( { baseEndpoint : this . _endpoint , defaultHeaders : this . _defaultHeaders , path : "/workspaces/{workspaceId}/applications/{applicationKey}/schedules/{scheduleKey}" , method : "DELETE" , pathParams : pathParams , headerParams : headerParams , queryParams : queryParams } ) ; try { const response = await retrier . makeServiceCall ( this . _httpClient , request ) ; const sdkResponse = composeResponse ( { responseObject : < responses . DeleteScheduleResponse > { } , responseHeaders : [ { value : response . headers . get ( "opc-request-id" ) , key : "opcRequestId" , dataType : "string" } ] } ) ; return sdkResponse ; } catch ( err ) { throw err ; } } param DeleteTaskRequest return throws example Click  https to see how to use DeleteTask API.
      public async deleteTask ( deleteTaskRequest ) { if ( this . logger ) this . logger . debug ( "Calling operation DataIntegrationClient#deleteTask." ) ; const pathParams = { "{workspaceId}" : deleteTaskRequest . workspaceId , "{taskKey}" : deleteTaskRequest . taskKey } ; const queryParams = { } ; let headerParams = { "Content-Type" : common . Constants . APPLICATION_JSON , "if-match" : deleteTaskRequest . ifMatch , "opc-request-id" : deleteTaskRequest . opcRequestId } ; const specRetryConfiguration = common . NoRetryConfigurationDetails ; const retrier = GenericRetrier . createPreferredRetrier ( this . _clientConfiguration ? this . _clientConfiguration . retryConfiguration : undefined , deleteTaskRequest . retryConfiguration , specRetryConfiguration ) ; if ( this . logger ) retrier . logger = this . logger ; const request = await composeRequest ( { baseEndpoint : this . _endpoint , defaultHeaders : this . _defaultHeaders , path : "/workspaces/{workspaceId}/tasks/{taskKey}" , method : "DELETE" , pathParams : pathParams , headerParams : headerParams , queryParams : queryParams } ) ; try { const response = await retrier . makeServiceCall ( this . _httpClient , request ) ; const sdkResponse = composeResponse ( { responseObject : < responses . DeleteTaskResponse > { } , responseHeaders : [ { value : response . headers . get ( "opc-request-id" ) , key : "opcRequestId" , dataType : "string" } ] } ) ; return sdkResponse ; } catch ( err ) { throw err ; } } param DeleteTaskRunRequest return throws example Click  https to see how to use DeleteTaskRun API.
      public async deleteTaskRun ( deleteTaskRunRequest ) { if ( this . logger ) this . logger . debug ( "Calling operation DataIntegrationClient#deleteTaskRun." ) ; const pathParams = { "{workspaceId}" : deleteTaskRunRequest . workspaceId , "{applicationKey}" : deleteTaskRunRequest . applicationKey , "{taskRunKey}" : deleteTaskRunRequest . taskRunKey } ; const queryParams = { } ; let headerParams = { "Content-Type" : common . Constants . APPLICATION_JSON , "if-match" : deleteTaskRunRequest . ifMatch , "opc-request-id" : deleteTaskRunRequest . opcRequestId } ; const specRetryConfiguration = common . NoRetryConfigurationDetails ; const retrier = GenericRetrier . createPreferredRetrier ( this . _clientConfiguration ? this . _clientConfiguration . retryConfiguration : undefined , deleteTaskRunRequest . retryConfiguration , specRetryConfiguration ) ; if ( this . logger ) retrier . logger = this . logger ; const request = await composeRequest ( { baseEndpoint : this . _endpoint , defaultHeaders : this . _defaultHeaders , path : "/workspaces/{workspaceId}/applications/{applicationKey}/taskRuns/{taskRunKey}" , method : "DELETE" , pathParams : pathParams , headerParams : headerParams , queryParams : queryParams } ) ; try { const response = await retrier . makeServiceCall ( this . _httpClient , request ) ; const sdkResponse = composeResponse ( { responseObject : < responses . DeleteTaskRunResponse > { } , responseHeaders : [ { value : response . headers . get ( "opc-request-id" ) , key : "opcRequestId" , dataType : "string" } ] } ) ; return sdkResponse ; } catch ( err ) { throw err ; } } param DeleteTaskScheduleRequest return throws example Click  https to see how to use DeleteTaskSchedule API.
      public async deleteTaskSchedule ( deleteTaskScheduleRequest ) { if ( this . logger ) this . logger . debug ( "Calling operation DataIntegrationClient#deleteTaskSchedule." ) ; const pathParams = { "{workspaceId}" : deleteTaskScheduleRequest . workspaceId , "{applicationKey}" : deleteTaskScheduleRequest . applicationKey , "{taskScheduleKey}" : deleteTaskScheduleRequest . taskScheduleKey } ; const queryParams = { } ; let headerParams = { "Content-Type" : common . Constants . APPLICATION_JSON , "if-match" : deleteTaskScheduleRequest . ifMatch , "opc-request-id" : deleteTaskScheduleRequest . opcRequestId } ; const specRetryConfiguration = common . NoRetryConfigurationDetails ; const retrier = GenericRetrier . createPreferredRetrier ( this . _clientConfiguration ? this . _clientConfiguration . retryConfiguration : undefined , deleteTaskScheduleRequest . retryConfiguration , specRetryConfiguration ) ; if ( this . logger ) retrier . logger = this . logger ; const request = await composeRequest ( { baseEndpoint : this . _endpoint , defaultHeaders : this . _defaultHeaders , path : "/workspaces/{workspaceId}/applications/{applicationKey}/taskSchedules/{taskScheduleKey}" , method : "DELETE" , pathParams : pathParams , headerParams : headerParams , queryParams : queryParams } ) ; try { const response = await retrier . makeServiceCall ( this . _httpClient , request ) ; const sdkResponse = composeResponse ( { responseObject : < responses . DeleteTaskScheduleResponse > { } , responseHeaders : [ { value : response . headers . get ( "opc-request-id" ) , key : "opcRequestId" , dataType : "string" } ] } ) ; return sdkResponse ; } catch ( err ) { throw err ; } } param DeleteTaskValidationRequest return throws example Click  https to see how to use DeleteTaskValidation API.
      public async deleteTaskValidation ( deleteTaskValidationRequest ) { if ( this . logger ) this . logger . debug ( "Calling operation DataIntegrationClient#deleteTaskValidation." ) ; const pathParams = { "{workspaceId}" : deleteTaskValidationRequest . workspaceId , "{taskValidationKey}" : deleteTaskValidationRequest . taskValidationKey } ; const queryParams = { } ; let headerParams = { "Content-Type" : common . Constants . APPLICATION_JSON , "if-match" : deleteTaskValidationRequest . ifMatch , "opc-request-id" : deleteTaskValidationRequest . opcRequestId } ; const specRetryConfiguration = common . NoRetryConfigurationDetails ; const retrier = GenericRetrier . createPreferredRetrier ( this . _clientConfiguration ? this . _clientConfiguration . retryConfiguration : undefined , deleteTaskValidationRequest . retryConfiguration , specRetryConfiguration ) ; if ( this . logger ) retrier . logger = this . logger ; const request = await composeRequest ( { baseEndpoint : this . _endpoint , defaultHeaders : this . _defaultHeaders , path : "/workspaces/{workspaceId}/taskValidations/{taskValidationKey}" , method : "DELETE" , pathParams : pathParams , headerParams : headerParams , queryParams : queryParams } ) ; try { const response = await retrier . makeServiceCall ( this . _httpClient , request ) ; const sdkResponse = composeResponse ( { responseObject : < responses . DeleteTaskValidationResponse > { } , responseHeaders : [ { value : response . headers . get ( "opc-request-id" ) , key : "opcRequestId" , dataType : "string" } ] } ) ; return sdkResponse ; } catch ( err ) { throw err ; } } param DeleteUserDefinedFunctionRequest return throws example Click  https to see how to use DeleteUserDefinedFunction API.
      public async deleteUserDefinedFunction ( deleteUserDefinedFunctionRequest ) { if ( this . logger ) this . logger . debug ( "Calling operation DataIntegrationClient#deleteUserDefinedFunction." ) ; const pathParams = { "{workspaceId}" : deleteUserDefinedFunctionRequest . workspaceId , "{userDefinedFunctionKey}" : deleteUserDefinedFunctionRequest . userDefinedFunctionKey } ; const queryParams = { } ; let headerParams = { "Content-Type" : common . Constants . APPLICATION_JSON , "if-match" : deleteUserDefinedFunctionRequest . ifMatch , "opc-request-id" : deleteUserDefinedFunctionRequest . opcRequestId } ; const specRetryConfiguration = common . NoRetryConfigurationDetails ; const retrier = GenericRetrier . createPreferredRetrier ( this . _clientConfiguration ? this . _clientConfiguration . retryConfiguration : undefined , deleteUserDefinedFunctionRequest . retryConfiguration , specRetryConfiguration ) ; if ( this . logger ) retrier . logger = this . logger ; const request = await composeRequest ( { baseEndpoint : this . _endpoint , defaultHeaders : this . _defaultHeaders , path : "/workspaces/{workspaceId}/userDefinedFunctions/{userDefinedFunctionKey}" , method : "DELETE" , pathParams : pathParams , headerParams : headerParams , queryParams : queryParams } ) ; try { const response = await retrier . makeServiceCall ( this . _httpClient , request ) ; const sdkResponse = composeResponse ( { responseObject : < responses . DeleteUserDefinedFunctionResponse > { } , responseHeaders : [ { value : response . headers . get ( "opc-request-id" ) , key : "opcRequestId" , dataType : "string" } ] } ) ; return sdkResponse ; } catch ( err ) { throw err ; } } param DeleteUserDefinedFunctionValidationRequest return throws example Click  https to see how to use DeleteUserDefinedFunctionValidation API.
      public async deleteUserDefinedFunctionValidation ( deleteUserDefinedFunctionValidationRequest ) { if ( this . logger ) this . logger . debug ( "Calling operation DataIntegrationClient#deleteUserDefinedFunctionValidation." ) ; const pathParams = { "{workspaceId}" : deleteUserDefinedFunctionValidationRequest . workspaceId , "{userDefinedFunctionValidationKey}" : deleteUserDefinedFunctionValidationRequest . userDefinedFunctionValidationKey } ; const queryParams = { } ; let headerParams = { "Content-Type" : common . Constants . APPLICATION_JSON , "if-match" : deleteUserDefinedFunctionValidationRequest . ifMatch , "opc-request-id" : deleteUserDefinedFunctionValidationRequest . opcRequestId } ; const specRetryConfiguration = common . NoRetryConfigurationDetails ; const retrier = GenericRetrier . createPreferredRetrier ( this . _clientConfiguration ? this . _clientConfiguration . retryConfiguration : undefined , deleteUserDefinedFunctionValidationRequest . retryConfiguration , specRetryConfiguration ) ; if ( this . logger ) retrier . logger = this . logger ; const request = await composeRequest ( { baseEndpoint : this . _endpoint , defaultHeaders : this . _defaultHeaders , path : "/workspaces/{workspaceId}/userDefinedFunctionValidations/{userDefinedFunctionValidationKey}" , method : "DELETE" , pathParams : pathParams , headerParams : headerParams , queryParams : queryParams } ) ; try { const response = await retrier . makeServiceCall ( this . _httpClient , request ) ; const sdkResponse = composeResponse ( { responseObject : < responses . DeleteUserDefinedFunctionValidationResponse > { } , responseHeaders : [ { value : response . headers . get ( "opc-request-id" ) , key : "opcRequestId" , dataType : "string" } ] } ) ; return sdkResponse ; } catch ( err ) { throw err ; } } param DeleteWorkspaceRequest return throws example Click  https to see how to use DeleteWorkspace API.
      public async deleteWorkspace ( deleteWorkspaceRequest ) { if ( this . logger ) this . logger . debug ( "Calling operation DataIntegrationClient#deleteWorkspace." ) ; const pathParams = { "{workspaceId}" : deleteWorkspaceRequest . workspaceId } ; const queryParams = { "quiesceTimeout" : deleteWorkspaceRequest . quiesceTimeout , "isForceOperation" : deleteWorkspaceRequest . isForceOperation } ; let headerParams = { "Content-Type" : common . Constants . APPLICATION_JSON , "if-match" : deleteWorkspaceRequest . ifMatch , "opc-request-id" : deleteWorkspaceRequest . opcRequestId } ; const specRetryConfiguration = common . NoRetryConfigurationDetails ; const retrier = GenericRetrier . createPreferredRetrier ( this . _clientConfiguration ? this . _clientConfiguration . retryConfiguration : undefined , deleteWorkspaceRequest . retryConfiguration , specRetryConfiguration ) ; if ( this . logger ) retrier . logger = this . logger ; const request = await composeRequest ( { baseEndpoint : this . _endpoint , defaultHeaders : this . _defaultHeaders , path : "/workspaces/{workspaceId}" , method : "DELETE" , pathParams : pathParams , headerParams : headerParams , queryParams : queryParams } ) ; try { const response = await retrier . makeServiceCall ( this . _httpClient , request ) ; const sdkResponse = composeResponse ( { responseObject : < responses . DeleteWorkspaceResponse > { } , responseHeaders : [ { value : response . headers . get ( "opc-request-id" ) , key : "opcRequestId" , dataType : "string" } , { value : response . headers . get ( "opc-work-request-id" ) , key : "opcWorkRequestId" , dataType : "string" } ] } ) ; return sdkResponse ; } catch ( err ) { throw err ; } } param GetApplicationRequest return throws example Click  https to see how to use GetApplication API.
      public async getApplication ( getApplicationRequest ) { if ( this . logger ) this . logger . debug ( "Calling operation DataIntegrationClient#getApplication." ) ; const pathParams = { "{workspaceId}" : getApplicationRequest . workspaceId , "{applicationKey}" : getApplicationRequest . applicationKey } ; const queryParams = { } ; let headerParams = { "Content-Type" : common . Constants . APPLICATION_JSON , "opc-request-id" : getApplicationRequest . opcRequestId } ; const specRetryConfiguration = common . NoRetryConfigurationDetails ; const retrier = GenericRetrier . createPreferredRetrier ( this . _clientConfiguration ? this . _clientConfiguration . retryConfiguration : undefined , getApplicationRequest . retryConfiguration , specRetryConfiguration ) ; if ( this . logger ) retrier . logger = this . logger ; const request = await composeRequest ( { baseEndpoint : this . _endpoint , defaultHeaders : this . _defaultHeaders , path : "/workspaces/{workspaceId}/applications/{applicationKey}" , method : "GET" , pathParams : pathParams , headerParams : headerParams , queryParams : queryParams } ) ; try { const response = await retrier . makeServiceCall ( this . _httpClient , request ) ; const sdkResponse = composeResponse ( { responseObject : < responses . GetApplicationResponse > { } , body : await response . json ( ) , bodyKey : "application" , bodyModel : model . Application , type : "model.Application" , responseHeaders : [ { value : response . headers . get ( "etag" ) , key : "etag" , dataType : "string" } , { value : response . headers . get ( "opc-request-id" ) , key : "opcRequestId" , dataType : "string" } ] } ) ; return sdkResponse ; } catch ( err ) { throw err ; } } param GetConnectionRequest return throws example Click  https to see how to use GetConnection API.
      public async getConnection ( getConnectionRequest ) { if ( this . logger ) this . logger . debug ( "Calling operation DataIntegrationClient#getConnection." ) ; const pathParams = { "{workspaceId}" : getConnectionRequest . workspaceId , "{connectionKey}" : getConnectionRequest . connectionKey } ; const queryParams = { } ; let headerParams = { "Content-Type" : common . Constants . APPLICATION_JSON , "opc-request-id" : getConnectionRequest . opcRequestId } ; const specRetryConfiguration = common . NoRetryConfigurationDetails ; const retrier = GenericRetrier . createPreferredRetrier ( this . _clientConfiguration ? this . _clientConfiguration . retryConfiguration : undefined , getConnectionRequest . retryConfiguration , specRetryConfiguration ) ; if ( this . logger ) retrier . logger = this . logger ; const request = await composeRequest ( { baseEndpoint : this . _endpoint , defaultHeaders : this . _defaultHeaders , path : "/workspaces/{workspaceId}/connections/{connectionKey}" , method : "GET" , pathParams : pathParams , headerParams : headerParams , queryParams : queryParams } ) ; try { const response = await retrier . makeServiceCall ( this . _httpClient , request ) ; const sdkResponse = composeResponse ( { responseObject : < responses . GetConnectionResponse > { } , body : await response . json ( ) , bodyKey : "connection" , bodyModel : model . Connection , type : "model.Connection" , responseHeaders : [ { value : response . headers . get ( "etag" ) , key : "etag" , dataType : "string" } , { value : response . headers . get ( "opc-request-id" ) , key : "opcRequestId" , dataType : "string" } ] } ) ; return sdkResponse ; } catch ( err ) { throw err ; } } param GetConnectionValidationRequest return throws example Click  https to see how to use GetConnectionValidation API.
      public async getConnectionValidation ( getConnectionValidationRequest ) { if ( this . logger ) this . logger . debug ( "Calling operation DataIntegrationClient#getConnectionValidation." ) ; const pathParams = { "{workspaceId}" : getConnectionValidationRequest . workspaceId , "{connectionValidationKey}" : getConnectionValidationRequest . connectionValidationKey } ; const queryParams = { } ; let headerParams = { "Content-Type" : common . Constants . APPLICATION_JSON , "opc-request-id" : getConnectionValidationRequest . opcRequestId } ; const specRetryConfiguration = common . NoRetryConfigurationDetails ; const retrier = GenericRetrier . createPreferredRetrier ( this . _clientConfiguration ? this . _clientConfiguration . retryConfiguration : undefined , getConnectionValidationRequest . retryConfiguration , specRetryConfiguration ) ; if ( this . logger ) retrier . logger = this . logger ; const request = await composeRequest ( { baseEndpoint : this . _endpoint , defaultHeaders : this . _defaultHeaders , path : "/workspaces/{workspaceId}/connectionValidations/{connectionValidationKey}" , method : "GET" , pathParams : pathParams , headerParams : headerParams , queryParams : queryParams } ) ; try { const response = await retrier . makeServiceCall ( this . _httpClient , request ) ; const sdkResponse = composeResponse ( { responseObject : < responses . GetConnectionValidationResponse > { } , body : await response . json ( ) , bodyKey : "connectionValidation" , bodyModel : model . ConnectionValidation , type : "model.ConnectionValidation" , responseHeaders : [ { value : response . headers . get ( "etag" ) , key : "etag" , dataType : "string" } , { value : response . headers . get ( "opc-request-id" ) , key : "opcRequestId" , dataType : "string" } ] } ) ; return sdkResponse ; } catch ( err ) { throw err ; } } param GetCountStatisticRequest return throws example Click  https to see how to use GetCountStatistic API.
      public async getCountStatistic ( getCountStatisticRequest ) { if ( this . logger ) this . logger . debug ( "Calling operation DataIntegrationClient#getCountStatistic." ) ; const pathParams = { "{workspaceId}" : getCountStatisticRequest . workspaceId , "{countStatisticKey}" : getCountStatisticRequest . countStatisticKey } ; const queryParams = { } ; let headerParams = { "Content-Type" : common . Constants . APPLICATION_JSON , "opc-request-id" : getCountStatisticRequest . opcRequestId } ; const specRetryConfiguration = common . NoRetryConfigurationDetails ; const retrier = GenericRetrier . createPreferredRetrier ( this . _clientConfiguration ? this . _clientConfiguration . retryConfiguration : undefined , getCountStatisticRequest . retryConfiguration , specRetryConfiguration ) ; if ( this . logger ) retrier . logger = this . logger ; const request = await composeRequest ( { baseEndpoint : this . _endpoint , defaultHeaders : this . _defaultHeaders , path : "/workspaces/{workspaceId}/countStatistics/{countStatisticKey}" , method : "GET" , pathParams : pathParams , headerParams : headerParams , queryParams : queryParams } ) ; try { const response = await retrier . makeServiceCall ( this . _httpClient , request ) ; const sdkResponse = composeResponse ( { responseObject : < responses . GetCountStatisticResponse > { } , body : await response . json ( ) , bodyKey : "countStatistic" , bodyModel : model . CountStatistic , type : "model.CountStatistic" , responseHeaders : [ { value : response . headers . get ( "opc-request-id" ) , key : "opcRequestId" , dataType : "string" } , { value : response . headers . get ( "opc-next-page" ) , key : "opcNextPage" , dataType : "string" } ] } ) ; return sdkResponse ; } catch ( err ) { throw err ; } } param GetDataAssetRequest return throws example Click  https to see how to use GetDataAsset API.
      public async getDataAsset ( getDataAssetRequest ) { if ( this . logger ) this . logger . debug ( "Calling operation DataIntegrationClient#getDataAsset." ) ; const pathParams = { "{workspaceId}" : getDataAssetRequest . workspaceId , "{dataAssetKey}" : getDataAssetRequest . dataAssetKey } ; const queryParams = { } ; let headerParams = { "Content-Type" : common . Constants . APPLICATION_JSON , "opc-request-id" : getDataAssetRequest . opcRequestId } ; const specRetryConfiguration = common . NoRetryConfigurationDetails ; const retrier = GenericRetrier . createPreferredRetrier ( this . _clientConfiguration ? this . _clientConfiguration . retryConfiguration : undefined , getDataAssetRequest . retryConfiguration , specRetryConfiguration ) ; if ( this . logger ) retrier . logger = this . logger ; const request = await composeRequest ( { baseEndpoint : this . _endpoint , defaultHeaders : this . _defaultHeaders , path : "/workspaces/{workspaceId}/dataAssets/{dataAssetKey}" , method : "GET" , pathParams : pathParams , headerParams : headerParams , queryParams : queryParams } ) ; try { const response = await retrier . makeServiceCall ( this . _httpClient , request ) ; const sdkResponse = composeResponse ( { responseObject : < responses . GetDataAssetResponse > { } , body : await response . json ( ) , bodyKey : "dataAsset" , bodyModel : model . DataAsset , type : "model.DataAsset" , responseHeaders : [ { value : response . headers . get ( "etag" ) , key : "etag" , dataType : "string" } , { value : response . headers . get ( "opc-request-id" ) , key : "opcRequestId" , dataType : "string" } ] } ) ; return sdkResponse ; } catch ( err ) { throw err ; } } param GetDataEntityRequest return throws example Click  https to see how to use GetDataEntity API.
      public async getDataEntity ( getDataEntityRequest ) { if ( this . logger ) this . logger . debug ( "Calling operation DataIntegrationClient#getDataEntity." ) ; const pathParams = { "{workspaceId}" : getDataEntityRequest . workspaceId , "{connectionKey}" : getDataEntityRequest . connectionKey , "{schemaResourceName}" : getDataEntityRequest . schemaResourceName , "{dataEntityKey}" : getDataEntityRequest . dataEntityKey } ; const queryParams = { } ; let headerParams = { "Content-Type" : common . Constants . APPLICATION_JSON , "opc-request-id" : getDataEntityRequest . opcRequestId } ; const specRetryConfiguration = common . NoRetryConfigurationDetails ; const retrier = GenericRetrier . createPreferredRetrier ( this . _clientConfiguration ? this . _clientConfiguration . retryConfiguration : undefined , getDataEntityRequest . retryConfiguration , specRetryConfiguration ) ; if ( this . logger ) retrier . logger = this . logger ; const request = await composeRequest ( { baseEndpoint : this . _endpoint , defaultHeaders : this . _defaultHeaders , path : "/workspaces/{workspaceId}/connections/{connectionKey}/schemas/{schemaResourceName}/dataEntities/{dataEntityKey}" , method : "GET" , pathParams : pathParams , headerParams : headerParams , queryParams : queryParams } ) ; try { const response = await retrier . makeServiceCall ( this . _httpClient , request ) ; const sdkResponse = composeResponse ( { responseObject : < responses . GetDataEntityResponse > { } , body : await response . json ( ) , bodyKey : "dataEntity" , bodyModel : model . DataEntity , type : "model.DataEntity" , responseHeaders : [ { value : response . headers . get ( "opc-request-id" ) , key : "opcRequestId" , dataType : "string" } ] } ) ; return sdkResponse ; } catch ( err ) { throw err ; } } param GetDataFlowRequest return throws example Click  https to see how to use GetDataFlow API.
      public async getDataFlow ( getDataFlowRequest ) { if ( this . logger ) this . logger . debug ( "Calling operation DataIntegrationClient#getDataFlow." ) ; const pathParams = { "{workspaceId}" : getDataFlowRequest . workspaceId , "{dataFlowKey}" : getDataFlowRequest . dataFlowKey } ; const queryParams = { "expandReferences" : getDataFlowRequest . expandReferences } ; let headerParams = { "Content-Type" : common . Constants . APPLICATION_JSON , "opc-request-id" : getDataFlowRequest . opcRequestId } ; const specRetryConfiguration = common . NoRetryConfigurationDetails ; const retrier = GenericRetrier . createPreferredRetrier ( this . _clientConfiguration ? this . _clientConfiguration . retryConfiguration : undefined , getDataFlowRequest . retryConfiguration , specRetryConfiguration ) ; if ( this . logger ) retrier . logger = this . logger ; const request = await composeRequest ( { baseEndpoint : this . _endpoint , defaultHeaders : this . _defaultHeaders , path : "/workspaces/{workspaceId}/dataFlows/{dataFlowKey}" , method : "GET" , pathParams : pathParams , headerParams : headerParams , queryParams : queryParams } ) ; try { const response = await retrier . makeServiceCall ( this . _httpClient , request ) ; const sdkResponse = composeResponse ( { responseObject : < responses . GetDataFlowResponse > { } , body : await response . json ( ) , bodyKey : "dataFlow" , bodyModel : model . DataFlow , type : "model.DataFlow" , responseHeaders : [ { value : response . headers . get ( "etag" ) , key : "etag" , dataType : "string" } , { value : response . headers . get ( "opc-request-id" ) , key : "opcRequestId" , dataType : "string" } ] } ) ; return sdkResponse ; } catch ( err ) { throw err ; } } param GetDataFlowValidationRequest return throws example Click  https to see how to use GetDataFlowValidation API.
      public async getDataFlowValidation ( getDataFlowValidationRequest ) { if ( this . logger ) this . logger . debug ( "Calling operation DataIntegrationClient#getDataFlowValidation." ) ; const pathParams = { "{workspaceId}" : getDataFlowValidationRequest . workspaceId , "{dataFlowValidationKey}" : getDataFlowValidationRequest . dataFlowValidationKey } ; const queryParams = { } ; let headerParams = { "Content-Type" : common . Constants . APPLICATION_JSON , "opc-request-id" : getDataFlowValidationRequest . opcRequestId } ; const specRetryConfiguration = common . NoRetryConfigurationDetails ; const retrier = GenericRetrier . createPreferredRetrier ( this . _clientConfiguration ? this . _clientConfiguration . retryConfiguration : undefined , getDataFlowValidationRequest . retryConfiguration , specRetryConfiguration ) ; if ( this . logger ) retrier . logger = this . logger ; const request = await composeRequest ( { baseEndpoint : this . _endpoint , defaultHeaders : this . _defaultHeaders , path : "/workspaces/{workspaceId}/dataFlowValidations/{dataFlowValidationKey}" , method : "GET" , pathParams : pathParams , headerParams : headerParams , queryParams : queryParams } ) ; try { const response = await retrier . makeServiceCall ( this . _httpClient , request ) ; const sdkResponse = composeResponse ( { responseObject : < responses . GetDataFlowValidationResponse > { } , body : await response . json ( ) , bodyKey : "dataFlowValidation" , bodyModel : model . DataFlowValidation , type : "model.DataFlowValidation" , responseHeaders : [ { value : response . headers . get ( "etag" ) , key : "etag" , dataType : "string" } , { value : response . headers . get ( "opc-request-id" ) , key : "opcRequestId" , dataType : "string" } ] } ) ; return sdkResponse ; } catch ( err ) { throw err ; } } param GetDependentObjectRequest return throws example Click  https to see how to use GetDependentObject API.
      public async getDependentObject ( getDependentObjectRequest ) { if ( this . logger ) this . logger . debug ( "Calling operation DataIntegrationClient#getDependentObject." ) ; const pathParams = { "{workspaceId}" : getDependentObjectRequest . workspaceId , "{applicationKey}" : getDependentObjectRequest . applicationKey , "{dependentObjectKey}" : getDependentObjectRequest . dependentObjectKey } ; const queryParams = { } ; let headerParams = { "Content-Type" : common . Constants . APPLICATION_JSON , "opc-request-id" : getDependentObjectRequest . opcRequestId } ; const specRetryConfiguration = common . NoRetryConfigurationDetails ; const retrier = GenericRetrier . createPreferredRetrier ( this . _clientConfiguration ? this . _clientConfiguration . retryConfiguration : undefined , getDependentObjectRequest . retryConfiguration , specRetryConfiguration ) ; if ( this . logger ) retrier . logger = this . logger ; const request = await composeRequest ( { baseEndpoint : this . _endpoint , defaultHeaders : this . _defaultHeaders , path : "/workspaces/{workspaceId}/applications/{applicationKey}/dependentObjects/{dependentObjectKey}" , method : "GET" , pathParams : pathParams , headerParams : headerParams , queryParams : queryParams } ) ; try { const response = await retrier . makeServiceCall ( this . _httpClient , request ) ; const sdkResponse = composeResponse ( { responseObject : < responses . GetDependentObjectResponse > { } , body : await response . json ( ) , bodyKey : "dependentObject" , bodyModel : model . DependentObject , type : "model.DependentObject" , responseHeaders : [ { value : response . headers . get ( "etag" ) , key : "etag" , dataType : "string" } , { value : response . headers . get ( "opc-request-id" ) , key : "opcRequestId" , dataType : "string" } ] } ) ; return sdkResponse ; } catch ( err ) { throw err ; } } param GetExternalPublicationRequest return throws example Click  https to see how to use GetExternalPublication API.
      public async getExternalPublication ( getExternalPublicationRequest ) { if ( this . logger ) this . logger . debug ( "Calling operation DataIntegrationClient#getExternalPublication." ) ; const pathParams = { "{workspaceId}" : getExternalPublicationRequest . workspaceId , "{taskKey}" : getExternalPublicationRequest . taskKey , "{externalPublicationsKey}" : getExternalPublicationRequest . externalPublicationsKey } ; const queryParams = { } ; let headerParams = { "Content-Type" : common . Constants . APPLICATION_JSON , "opc-request-id" : getExternalPublicationRequest . opcRequestId } ; const specRetryConfiguration = common . NoRetryConfigurationDetails ; const retrier = GenericRetrier . createPreferredRetrier ( this . _clientConfiguration ? this . _clientConfiguration . retryConfiguration : undefined , getExternalPublicationRequest . retryConfiguration , specRetryConfiguration ) ; if ( this . logger ) retrier . logger = this . logger ; const request = await composeRequest ( { baseEndpoint : this . _endpoint , defaultHeaders : this . _defaultHeaders , path : "/workspaces/{workspaceId}/tasks/{taskKey}/externalPublications/{externalPublicationsKey}" , method : "GET" , pathParams : pathParams , headerParams : headerParams , queryParams : queryParams } ) ; try { const response = await retrier . makeServiceCall ( this . _httpClient , request ) ; const sdkResponse = composeResponse ( { responseObject : < responses . GetExternalPublicationResponse > { } , body : await response . json ( ) , bodyKey : "externalPublication" , bodyModel : model . ExternalPublication , type : "model.ExternalPublication" , responseHeaders : [ { value : response . headers . get ( "etag" ) , key : "etag" , dataType : "string" } , { value : response . headers . get ( "opc-request-id" ) , key : "opcRequestId" , dataType : "string" } ] } ) ; return sdkResponse ; } catch ( err ) { throw err ; } } param GetExternalPublicationValidationRequest return throws example Click  https to see how to use GetExternalPublicationValidation API.
      public async getExternalPublicationValidation ( getExternalPublicationValidationRequest ) { if ( this . logger ) this . logger . debug ( "Calling operation DataIntegrationClient#getExternalPublicationValidation." ) ; const pathParams = { "{workspaceId}" : getExternalPublicationValidationRequest . workspaceId , "{taskKey}" : getExternalPublicationValidationRequest . taskKey , "{externalPublicationValidationKey}" : getExternalPublicationValidationRequest . externalPublicationValidationKey } ; const queryParams = { } ; let headerParams = { "Content-Type" : common . Constants . APPLICATION_JSON , "opc-request-id" : getExternalPublicationValidationRequest . opcRequestId } ; const specRetryConfiguration = common . NoRetryConfigurationDetails ; const retrier = GenericRetrier . createPreferredRetrier ( this . _clientConfiguration ? this . _clientConfiguration . retryConfiguration : undefined , getExternalPublicationValidationRequest . retryConfiguration , specRetryConfiguration ) ; if ( this . logger ) retrier . logger = this . logger ; const request = await composeRequest ( { baseEndpoint : this . _endpoint , defaultHeaders : this . _defaultHeaders , path : "/workspaces/{workspaceId}/tasks/{taskKey}/externalPublicationValidations/{externalPublicationValidationKey}" , method : "GET" , pathParams : pathParams , headerParams : headerParams , queryParams : queryParams } ) ; try { const response = await retrier . makeServiceCall ( this . _httpClient , request ) ; const sdkResponse = composeResponse ( { responseObject : < responses . GetExternalPublicationValidationResponse > { } , body : await response . json ( ) , bodyKey : "externalPublicationValidation" , bodyModel : model . ExternalPublicationValidation , type : "model.ExternalPublicationValidation" , responseHeaders : [ { value : response . headers . get ( "etag" ) , key : "etag" , dataType : "string" } , { value : response . headers . get ( "opc-request-id" ) , key : "opcRequestId" , dataType : "string" } ] } ) ; return sdkResponse ; } catch ( err ) { throw err ; } } param GetFolderRequest return throws example Click  https to see how to use GetFolder API.
      public async getFolder ( getFolderRequest ) { if ( this . logger ) this . logger . debug ( "Calling operation DataIntegrationClient#getFolder." ) ; const pathParams = { "{workspaceId}" : getFolderRequest . workspaceId , "{folderKey}" : getFolderRequest . folderKey } ; const queryParams = { "projection" : getFolderRequest . projection } ; let headerParams = { "Content-Type" : common . Constants . APPLICATION_JSON , "opc-request-id" : getFolderRequest . opcRequestId } ; const specRetryConfiguration = common . NoRetryConfigurationDetails ; const retrier = GenericRetrier . createPreferredRetrier ( this . _clientConfiguration ? this . _clientConfiguration . retryConfiguration : undefined , getFolderRequest . retryConfiguration , specRetryConfiguration ) ; if ( this . logger ) retrier . logger = this . logger ; const request = await composeRequest ( { baseEndpoint : this . _endpoint , defaultHeaders : this . _defaultHeaders , path : "/workspaces/{workspaceId}/folders/{folderKey}" , method : "GET" , pathParams : pathParams , headerParams : headerParams , queryParams : queryParams } ) ; try { const response = await retrier . makeServiceCall ( this . _httpClient , request ) ; const sdkResponse = composeResponse ( { responseObject : < responses . GetFolderResponse > { } , body : await response . json ( ) , bodyKey : "folder" , bodyModel : model . Folder , type : "model.Folder" , responseHeaders : [ { value : response . headers . get ( "etag" ) , key : "etag" , dataType : "string" } , { value : response . headers . get ( "opc-request-id" ) , key : "opcRequestId" , dataType : "string" } ] } ) ; return sdkResponse ; } catch ( err ) { throw err ; } } param GetFunctionLibraryRequest return throws example Click  https to see how to use GetFunctionLibrary API.
      public async getFunctionLibrary ( getFunctionLibraryRequest ) { if ( this . logger ) this . logger . debug ( "Calling operation DataIntegrationClient#getFunctionLibrary." ) ; const pathParams = { "{workspaceId}" : getFunctionLibraryRequest . workspaceId , "{functionLibraryKey}" : getFunctionLibraryRequest . functionLibraryKey } ; const queryParams = { "projection" : getFunctionLibraryRequest . projection } ; let headerParams = { "Content-Type" : common . Constants . APPLICATION_JSON , "opc-request-id" : getFunctionLibraryRequest . opcRequestId } ; const specRetryConfiguration = common . NoRetryConfigurationDetails ; const retrier = GenericRetrier . createPreferredRetrier ( this . _clientConfiguration ? this . _clientConfiguration . retryConfiguration : undefined , getFunctionLibraryRequest . retryConfiguration , specRetryConfiguration ) ; if ( this . logger ) retrier . logger = this . logger ; const request = await composeRequest ( { baseEndpoint : this . _endpoint , defaultHeaders : this . _defaultHeaders , path : "/workspaces/{workspaceId}/functionLibraries/{functionLibraryKey}" , method : "GET" , pathParams : pathParams , headerParams : headerParams , queryParams : queryParams } ) ; try { const response = await retrier . makeServiceCall ( this . _httpClient , request ) ; const sdkResponse = composeResponse ( { responseObject : < responses . GetFunctionLibraryResponse > { } , body : await response . json ( ) , bodyKey : "functionLibrary" , bodyModel : model . FunctionLibrary , type : "model.FunctionLibrary" , responseHeaders : [ { value : response . headers . get ( "etag" ) , key : "etag" , dataType : "string" } , { value : response . headers . get ( "opc-request-id" ) , key : "opcRequestId" , dataType : "string" } ] } ) ; return sdkResponse ; } catch ( err ) { throw err ; } } param GetPatchRequest return throws example Click  https to see how to use GetPatch API.
      public async getPatch ( getPatchRequest ) { if ( this . logger ) this . logger . debug ( "Calling operation DataIntegrationClient#getPatch." ) ; const pathParams = { "{workspaceId}" : getPatchRequest . workspaceId , "{applicationKey}" : getPatchRequest . applicationKey , "{patchKey}" : getPatchRequest . patchKey } ; const queryParams = { } ; let headerParams = { "Content-Type" : common . Constants . APPLICATION_JSON , "opc-request-id" : getPatchRequest . opcRequestId } ; const specRetryConfiguration = common . NoRetryConfigurationDetails ; const retrier = GenericRetrier . createPreferredRetrier ( this . _clientConfiguration ? this . _clientConfiguration . retryConfiguration : undefined , getPatchRequest . retryConfiguration , specRetryConfiguration ) ; if ( this . logger ) retrier . logger = this . logger ; const request = await composeRequest ( { baseEndpoint : this . _endpoint , defaultHeaders : this . _defaultHeaders , path : "/workspaces/{workspaceId}/applications/{applicationKey}/patches/{patchKey}" , method : "GET" , pathParams : pathParams , headerParams : headerParams , queryParams : queryParams } ) ; try { const response = await retrier . makeServiceCall ( this . _httpClient , request ) ; const sdkResponse = composeResponse ( { responseObject : < responses . GetPatchResponse > { } , body : await response . json ( ) , bodyKey : "patch" , bodyModel : model . Patch , type : "model.Patch" , responseHeaders : [ { value : response . headers . get ( "etag" ) , key : "etag" , dataType : "string" } , { value : response . headers . get ( "opc-request-id" ) , key : "opcRequestId" , dataType : "string" } ] } ) ; return sdkResponse ; } catch ( err ) { throw err ; } } param GetPipelineRequest return throws example Click  https to see how to use GetPipeline API.
      public async getPipeline ( getPipelineRequest ) { if ( this . logger ) this . logger . debug ( "Calling operation DataIntegrationClient#getPipeline." ) ; const pathParams = { "{workspaceId}" : getPipelineRequest . workspaceId , "{pipelineKey}" : getPipelineRequest . pipelineKey } ; const queryParams = { "expandReferences" : getPipelineRequest . expandReferences } ; let headerParams = { "Content-Type" : common . Constants . APPLICATION_JSON , "opc-request-id" : getPipelineRequest . opcRequestId } ; const specRetryConfiguration = common . NoRetryConfigurationDetails ; const retrier = GenericRetrier . createPreferredRetrier ( this . _clientConfiguration ? this . _clientConfiguration . retryConfiguration : undefined , getPipelineRequest . retryConfiguration , specRetryConfiguration ) ; if ( this . logger ) retrier . logger = this . logger ; const request = await composeRequest ( { baseEndpoint : this . _endpoint , defaultHeaders : this . _defaultHeaders , path : "/workspaces/{workspaceId}/pipelines/{pipelineKey}" , method : "GET" , pathParams : pathParams , headerParams : headerParams , queryParams : queryParams } ) ; try { const response = await retrier . makeServiceCall ( this . _httpClient , request ) ; const sdkResponse = composeResponse ( { responseObject : < responses . GetPipelineResponse > { } , body : await response . json ( ) , bodyKey : "pipeline" , bodyModel : model . Pipeline , type : "model.Pipeline" , responseHeaders : [ { value : response . headers . get ( "etag" ) , key : "etag" , dataType : "string" } , { value : response . headers . get ( "opc-request-id" ) , key : "opcRequestId" , dataType : "string" } ] } ) ; return sdkResponse ; } catch ( err ) { throw err ; } } param GetPipelineValidationRequest return throws example Click  https to see how to use GetPipelineValidation API.
      public async getPipelineValidation ( getPipelineValidationRequest ) { if ( this . logger ) this . logger . debug ( "Calling operation DataIntegrationClient#getPipelineValidation." ) ; const pathParams = { "{workspaceId}" : getPipelineValidationRequest . workspaceId , "{pipelineValidationKey}" : getPipelineValidationRequest . pipelineValidationKey } ; const queryParams = { } ; let headerParams = { "Content-Type" : common . Constants . APPLICATION_JSON , "opc-request-id" : getPipelineValidationRequest . opcRequestId } ; const specRetryConfiguration = common . NoRetryConfigurationDetails ; const retrier = GenericRetrier . createPreferredRetrier ( this . _clientConfiguration ? this . _clientConfiguration . retryConfiguration : undefined , getPipelineValidationRequest . retryConfiguration , specRetryConfiguration ) ; if ( this . logger ) retrier . logger = this . logger ; const request = await composeRequest ( { baseEndpoint : this . _endpoint , defaultHeaders : this . _defaultHeaders , path : "/workspaces/{workspaceId}/pipelineValidations/{pipelineValidationKey}" , method : "GET" , pathParams : pathParams , headerParams : headerParams , queryParams : queryParams } ) ; try { const response = await retrier . makeServiceCall ( this . _httpClient , request ) ; const sdkResponse = composeResponse ( { responseObject : < responses . GetPipelineValidationResponse > { } , body : await response . json ( ) , bodyKey : "pipelineValidation" , bodyModel : model . PipelineValidation , type : "model.PipelineValidation" , responseHeaders : [ { value : response . headers . get ( "etag" ) , key : "etag" , dataType : "string" } , { value : response . headers . get ( "opc-request-id" ) , key : "opcRequestId" , dataType : "string" } ] } ) ; return sdkResponse ; } catch ( err ) { throw err ; } } param GetProjectRequest return throws example Click  https to see how to use GetProject API.
      public async getProject ( getProjectRequest ) { if ( this . logger ) this . logger . debug ( "Calling operation DataIntegrationClient#getProject." ) ; const pathParams = { "{workspaceId}" : getProjectRequest . workspaceId , "{projectKey}" : getProjectRequest . projectKey } ; const queryParams = { "projection" : getProjectRequest . projection } ; let headerParams = { "Content-Type" : common . Constants . APPLICATION_JSON , "opc-request-id" : getProjectRequest . opcRequestId } ; const specRetryConfiguration = common . NoRetryConfigurationDetails ; const retrier = GenericRetrier . createPreferredRetrier ( this . _clientConfiguration ? this . _clientConfiguration . retryConfiguration : undefined , getProjectRequest . retryConfiguration , specRetryConfiguration ) ; if ( this . logger ) retrier . logger = this . logger ; const request = await composeRequest ( { baseEndpoint : this . _endpoint , defaultHeaders : this . _defaultHeaders , path : "/workspaces/{workspaceId}/projects/{projectKey}" , method : "GET" , pathParams : pathParams , headerParams : headerParams , queryParams : queryParams } ) ; try { const response = await retrier . makeServiceCall ( this . _httpClient , request ) ; const sdkResponse = composeResponse ( { responseObject : < responses . GetProjectResponse > { } , body : await response . json ( ) , bodyKey : "project" , bodyModel : model . Project , type : "model.Project" , responseHeaders : [ { value : response . headers . get ( "etag" ) , key : "etag" , dataType : "string" } , { value : response . headers . get ( "opc-request-id" ) , key : "opcRequestId" , dataType : "string" } ] } ) ; return sdkResponse ; } catch ( err ) { throw err ; } } param GetPublishedObjectRequest return throws example Click  https to see how to use GetPublishedObject API.
      public async getPublishedObject ( getPublishedObjectRequest ) { if ( this . logger ) this . logger . debug ( "Calling operation DataIntegrationClient#getPublishedObject." ) ; const pathParams = { "{workspaceId}" : getPublishedObjectRequest . workspaceId , "{applicationKey}" : getPublishedObjectRequest . applicationKey , "{publishedObjectKey}" : getPublishedObjectRequest . publishedObjectKey } ; const queryParams = { "expandReferences" : getPublishedObjectRequest . expandReferences } ; let headerParams = { "Content-Type" : common . Constants . APPLICATION_JSON , "opc-request-id" : getPublishedObjectRequest . opcRequestId } ; const specRetryConfiguration = common . NoRetryConfigurationDetails ; const retrier = GenericRetrier . createPreferredRetrier ( this . _clientConfiguration ? this . _clientConfiguration . retryConfiguration : undefined , getPublishedObjectRequest . retryConfiguration , specRetryConfiguration ) ; if ( this . logger ) retrier . logger = this . logger ; const request = await composeRequest ( { baseEndpoint : this . _endpoint , defaultHeaders : this . _defaultHeaders , path : "/workspaces/{workspaceId}/applications/{applicationKey}/publishedObjects/{publishedObjectKey}" , method : "GET" , pathParams : pathParams , headerParams : headerParams , queryParams : queryParams } ) ; try { const response = await retrier . makeServiceCall ( this . _httpClient , request ) ; const sdkResponse = composeResponse ( { responseObject : < responses . GetPublishedObjectResponse > { } , body : await response . json ( ) , bodyKey : "publishedObject" , bodyModel : model . PublishedObject , type : "model.PublishedObject" , responseHeaders : [ { value : response . headers . get ( "etag" ) , key : "etag" , dataType : "string" } , { value : response . headers . get ( "opc-request-id" ) , key : "opcRequestId" , dataType : "string" } ] } ) ; return sdkResponse ; } catch ( err ) { throw err ; } } param GetReferenceRequest return throws example Click  https to see how to use GetReference API.
      public async getReference ( getReferenceRequest ) { if ( this . logger ) this . logger . debug ( "Calling operation DataIntegrationClient#getReference." ) ; const pathParams = { "{workspaceId}" : getReferenceRequest . workspaceId , "{applicationKey}" : getReferenceRequest . applicationKey , "{referenceKey}" : getReferenceRequest . referenceKey } ; const queryParams = { } ; let headerParams = { "Content-Type" : common . Constants . APPLICATION_JSON , "opc-request-id" : getReferenceRequest . opcRequestId } ; const specRetryConfiguration = common . NoRetryConfigurationDetails ; const retrier = GenericRetrier . createPreferredRetrier ( this . _clientConfiguration ? this . _clientConfiguration . retryConfiguration : undefined , getReferenceRequest . retryConfiguration , specRetryConfiguration ) ; if ( this . logger ) retrier . logger = this . logger ; const request = await composeRequest ( { baseEndpoint : this . _endpoint , defaultHeaders : this . _defaultHeaders , path : "/workspaces/{workspaceId}/applications/{applicationKey}/references/{referenceKey}" , method : "GET" , pathParams : pathParams , headerParams : headerParams , queryParams : queryParams } ) ; try { const response = await retrier . makeServiceCall ( this . _httpClient , request ) ; const sdkResponse = composeResponse ( { responseObject : < responses . GetReferenceResponse > { } , body : await response . json ( ) , bodyKey : "reference" , bodyModel : model . Reference , type : "model.Reference" , responseHeaders : [ { value : response . headers . get ( "etag" ) , key : "etag" , dataType : "string" } , { value : response . headers . get ( "opc-request-id" ) , key : "opcRequestId" , dataType : "string" } ] } ) ; return sdkResponse ; } catch ( err ) { throw err ; } } param GetScheduleRequest return throws example Click  https to see how to use GetSchedule API.
      public async getSchedule ( getScheduleRequest ) { if ( this . logger ) this . logger . debug ( "Calling operation DataIntegrationClient#getSchedule." ) ; const pathParams = { "{workspaceId}" : getScheduleRequest . workspaceId , "{applicationKey}" : getScheduleRequest . applicationKey , "{scheduleKey}" : getScheduleRequest . scheduleKey } ; const queryParams = { } ; let headerParams = { "Content-Type" : common . Constants . APPLICATION_JSON , "opc-request-id" : getScheduleRequest . opcRequestId } ; const specRetryConfiguration = common . NoRetryConfigurationDetails ; const retrier = GenericRetrier . createPreferredRetrier ( this . _clientConfiguration ? this . _clientConfiguration . retryConfiguration : undefined , getScheduleRequest . retryConfiguration , specRetryConfiguration ) ; if ( this . logger ) retrier . logger = this . logger ; const request = await composeRequest ( { baseEndpoint : this . _endpoint , defaultHeaders : this . _defaultHeaders , path : "/workspaces/{workspaceId}/applications/{applicationKey}/schedules/{scheduleKey}" , method : "GET" , pathParams : pathParams , headerParams : headerParams , queryParams : queryParams } ) ; try { const response = await retrier . makeServiceCall ( this . _httpClient , request ) ; const sdkResponse = composeResponse ( { responseObject : < responses . GetScheduleResponse > { } , body : await response . json ( ) , bodyKey : "schedule" , bodyModel : model . Schedule , type : "model.Schedule" , responseHeaders : [ { value : response . headers . get ( "etag" ) , key : "etag" , dataType : "string" } , { value : response . headers . get ( "opc-request-id" ) , key : "opcRequestId" , dataType : "string" } ] } ) ; return sdkResponse ; } catch ( err ) { throw err ; } } param GetSchemaRequest return throws example Click  https to see how to use GetSchema API.
      public async getSchema ( getSchemaRequest ) { if ( this . logger ) this . logger . debug ( "Calling operation DataIntegrationClient#getSchema." ) ; const pathParams = { "{workspaceId}" : getSchemaRequest . workspaceId , "{connectionKey}" : getSchemaRequest . connectionKey , "{schemaResourceName}" : getSchemaRequest . schemaResourceName } ; const queryParams = { } ; let headerParams = { "Content-Type" : common . Constants . APPLICATION_JSON , "opc-request-id" : getSchemaRequest . opcRequestId } ; const specRetryConfiguration = common . NoRetryConfigurationDetails ; const retrier = GenericRetrier . createPreferredRetrier ( this . _clientConfiguration ? this . _clientConfiguration . retryConfiguration : undefined , getSchemaRequest . retryConfiguration , specRetryConfiguration ) ; if ( this . logger ) retrier . logger = this . logger ; const request = await composeRequest ( { baseEndpoint : this . _endpoint , defaultHeaders : this . _defaultHeaders , path : "/workspaces/{workspaceId}/connections/{connectionKey}/schemas/{schemaResourceName}" , method : "GET" , pathParams : pathParams , headerParams : headerParams , queryParams : queryParams } ) ; try { const response = await retrier . makeServiceCall ( this . _httpClient , request ) ; const sdkResponse = composeResponse ( { responseObject : < responses . GetSchemaResponse > { } , body : await response . json ( ) , bodyKey : "schema" , bodyModel : model . Schema , type : "model.Schema" , responseHeaders : [ { value : response . headers . get ( "opc-request-id" ) , key : "opcRequestId" , dataType : "string" } ] } ) ; return sdkResponse ; } catch ( err ) { throw err ; } } param GetTaskRequest return throws example Click  https to see how to use GetTask API.
      public async getTask ( getTaskRequest ) { if ( this . logger ) this . logger . debug ( "Calling operation DataIntegrationClient#getTask." ) ; const pathParams = { "{workspaceId}" : getTaskRequest . workspaceId , "{taskKey}" : getTaskRequest . taskKey } ; const queryParams = { "expandReferences" : getTaskRequest . expandReferences } ; let headerParams = { "Content-Type" : common . Constants . APPLICATION_JSON , "opc-request-id" : getTaskRequest . opcRequestId } ; const specRetryConfiguration = common . NoRetryConfigurationDetails ; const retrier = GenericRetrier . createPreferredRetrier ( this . _clientConfiguration ? this . _clientConfiguration . retryConfiguration : undefined , getTaskRequest . retryConfiguration , specRetryConfiguration ) ; if ( this . logger ) retrier . logger = this . logger ; const request = await composeRequest ( { baseEndpoint : this . _endpoint , defaultHeaders : this . _defaultHeaders , path : "/workspaces/{workspaceId}/tasks/{taskKey}" , method : "GET" , pathParams : pathParams , headerParams : headerParams , queryParams : queryParams } ) ; try { const response = await retrier . makeServiceCall ( this . _httpClient , request ) ; const sdkResponse = composeResponse ( { responseObject : < responses . GetTaskResponse > { } , body : await response . json ( ) , bodyKey : "task" , bodyModel : model . Task , type : "model.Task" , responseHeaders : [ { value : response . headers . get ( "etag" ) , key : "etag" , dataType : "string" } , { value : response . headers . get ( "opc-request-id" ) , key : "opcRequestId" , dataType : "string" } ] } ) ; return sdkResponse ; } catch ( err ) { throw err ; } } param GetTaskRunRequest return throws example Click  https to see how to use GetTaskRun API.
      public async getTaskRun ( getTaskRunRequest ) { if ( this . logger ) this . logger . debug ( "Calling operation DataIntegrationClient#getTaskRun." ) ; const pathParams = { "{workspaceId}" : getTaskRunRequest . workspaceId , "{applicationKey}" : getTaskRunRequest . applicationKey , "{taskRunKey}" : getTaskRunRequest . taskRunKey } ; const queryParams = { } ; let headerParams = { "Content-Type" : common . Constants . APPLICATION_JSON , "opc-request-id" : getTaskRunRequest . opcRequestId } ; const specRetryConfiguration = common . NoRetryConfigurationDetails ; const retrier = GenericRetrier . createPreferredRetrier ( this . _clientConfiguration ? this . _clientConfiguration . retryConfiguration : undefined , getTaskRunRequest . retryConfiguration , specRetryConfiguration ) ; if ( this . logger ) retrier . logger = this . logger ; const request = await composeRequest ( { baseEndpoint : this . _endpoint , defaultHeaders : this . _defaultHeaders , path : "/workspaces/{workspaceId}/applications/{applicationKey}/taskRuns/{taskRunKey}" , method : "GET" , pathParams : pathParams , headerParams : headerParams , queryParams : queryParams } ) ; try { const response = await retrier . makeServiceCall ( this . _httpClient , request ) ; const sdkResponse = composeResponse ( { responseObject : < responses . GetTaskRunResponse > { } , body : await response . json ( ) , bodyKey : "taskRun" , bodyModel : model . TaskRun , type : "model.TaskRun" , responseHeaders : [ { value : response . headers . get ( "etag" ) , key : "etag" , dataType : "string" } , { value : response . headers . get ( "opc-request-id" ) , key : "opcRequestId" , dataType : "string" } ] } ) ; return sdkResponse ; } catch ( err ) { throw err ; } } param GetTaskScheduleRequest return throws example Click  https to see how to use GetTaskSchedule API.
      public async getTaskSchedule ( getTaskScheduleRequest ) { if ( this . logger ) this . logger . debug ( "Calling operation DataIntegrationClient#getTaskSchedule." ) ; const pathParams = { "{workspaceId}" : getTaskScheduleRequest . workspaceId , "{applicationKey}" : getTaskScheduleRequest . applicationKey , "{taskScheduleKey}" : getTaskScheduleRequest . taskScheduleKey } ; const queryParams = { } ; let headerParams = { "Content-Type" : common . Constants . APPLICATION_JSON , "opc-request-id" : getTaskScheduleRequest . opcRequestId } ; const specRetryConfiguration = common . NoRetryConfigurationDetails ; const retrier = GenericRetrier . createPreferredRetrier ( this . _clientConfiguration ? this . _clientConfiguration . retryConfiguration : undefined , getTaskScheduleRequest . retryConfiguration , specRetryConfiguration ) ; if ( this . logger ) retrier . logger = this . logger ; const request = await composeRequest ( { baseEndpoint : this . _endpoint , defaultHeaders : this . _defaultHeaders , path : "/workspaces/{workspaceId}/applications/{applicationKey}/taskSchedules/{taskScheduleKey}" , method : "GET" , pathParams : pathParams , headerParams : headerParams , queryParams : queryParams } ) ; try { const response = await retrier . makeServiceCall ( this . _httpClient , request ) ; const sdkResponse = composeResponse ( { responseObject : < responses . GetTaskScheduleResponse > { } , body : await response . json ( ) , bodyKey : "taskSchedule" , bodyModel : model . TaskSchedule , type : "model.TaskSchedule" , responseHeaders : [ { value : response . headers . get ( "etag" ) , key : "etag" , dataType : "string" } , { value : response . headers . get ( "opc-request-id" ) , key : "opcRequestId" , dataType : "string" } ] } ) ; return sdkResponse ; } catch ( err ) { throw err ; } } param GetTaskValidationRequest return throws example Click  https to see how to use GetTaskValidation API.
      public async getTaskValidation ( getTaskValidationRequest ) { if ( this . logger ) this . logger . debug ( "Calling operation DataIntegrationClient#getTaskValidation." ) ; const pathParams = { "{workspaceId}" : getTaskValidationRequest . workspaceId , "{taskValidationKey}" : getTaskValidationRequest . taskValidationKey } ; const queryParams = { } ; let headerParams = { "Content-Type" : common . Constants . APPLICATION_JSON , "opc-request-id" : getTaskValidationRequest . opcRequestId } ; const specRetryConfiguration = common . NoRetryConfigurationDetails ; const retrier = GenericRetrier . createPreferredRetrier ( this . _clientConfiguration ? this . _clientConfiguration . retryConfiguration : undefined , getTaskValidationRequest . retryConfiguration , specRetryConfiguration ) ; if ( this . logger ) retrier . logger = this . logger ; const request = await composeRequest ( { baseEndpoint : this . _endpoint , defaultHeaders : this . _defaultHeaders , path : "/workspaces/{workspaceId}/taskValidations/{taskValidationKey}" , method : "GET" , pathParams : pathParams , headerParams : headerParams , queryParams : queryParams } ) ; try { const response = await retrier . makeServiceCall ( this . _httpClient , request ) ; const sdkResponse = composeResponse ( { responseObject : < responses . GetTaskValidationResponse > { } , body : await response . json ( ) , bodyKey : "taskValidation" , bodyModel : model . TaskValidation , type : "model.TaskValidation" , responseHeaders : [ { value : response . headers . get ( "etag" ) , key : "etag" , dataType : "string" } , { value : response . headers . get ( "opc-request-id" ) , key : "opcRequestId" , dataType : "string" } ] } ) ; return sdkResponse ; } catch ( err ) { throw err ; } } param GetUserDefinedFunctionRequest return throws example Click  https to see how to use GetUserDefinedFunction API.
      public async getUserDefinedFunction ( getUserDefinedFunctionRequest ) { if ( this . logger ) this . logger . debug ( "Calling operation DataIntegrationClient#getUserDefinedFunction." ) ; const pathParams = { "{workspaceId}" : getUserDefinedFunctionRequest . workspaceId , "{userDefinedFunctionKey}" : getUserDefinedFunctionRequest . userDefinedFunctionKey } ; const queryParams = { } ; let headerParams = { "Content-Type" : common . Constants . APPLICATION_JSON , "opc-request-id" : getUserDefinedFunctionRequest . opcRequestId } ; const specRetryConfiguration = common . NoRetryConfigurationDetails ; const retrier = GenericRetrier . createPreferredRetrier ( this . _clientConfiguration ? this . _clientConfiguration . retryConfiguration : undefined , getUserDefinedFunctionRequest . retryConfiguration , specRetryConfiguration ) ; if ( this . logger ) retrier . logger = this . logger ; const request = await composeRequest ( { baseEndpoint : this . _endpoint , defaultHeaders : this . _defaultHeaders , path : "/workspaces/{workspaceId}/userDefinedFunctions/{userDefinedFunctionKey}" , method : "GET" , pathParams : pathParams , headerParams : headerParams , queryParams : queryParams } ) ; try { const response = await retrier . makeServiceCall ( this . _httpClient , request ) ; const sdkResponse = composeResponse ( { responseObject : < responses . GetUserDefinedFunctionResponse > { } , body : await response . json ( ) , bodyKey : "userDefinedFunction" , bodyModel : model . UserDefinedFunction , type : "model.UserDefinedFunction" , responseHeaders : [ { value : response . headers . get ( "etag" ) , key : "etag" , dataType : "string" } , { value : response . headers . get ( "opc-request-id" ) , key : "opcRequestId" , dataType : "string" } ] } ) ; return sdkResponse ; } catch ( err ) { throw err ; } } param GetUserDefinedFunctionValidationRequest return throws example Click  https to see how to use GetUserDefinedFunctionValidation API.
      public async getUserDefinedFunctionValidation ( getUserDefinedFunctionValidationRequest ) { if ( this . logger ) this . logger . debug ( "Calling operation DataIntegrationClient#getUserDefinedFunctionValidation." ) ; const pathParams = { "{workspaceId}" : getUserDefinedFunctionValidationRequest . workspaceId , "{userDefinedFunctionValidationKey}" : getUserDefinedFunctionValidationRequest . userDefinedFunctionValidationKey } ; const queryParams = { } ; let headerParams = { "Content-Type" : common . Constants . APPLICATION_JSON , "opc-request-id" : getUserDefinedFunctionValidationRequest . opcRequestId } ; const specRetryConfiguration = common . NoRetryConfigurationDetails ; const retrier = GenericRetrier . createPreferredRetrier ( this . _clientConfiguration ? this . _clientConfiguration . retryConfiguration : undefined , getUserDefinedFunctionValidationRequest . retryConfiguration , specRetryConfiguration ) ; if ( this . logger ) retrier . logger = this . logger ; const request = await composeRequest ( { baseEndpoint : this . _endpoint , defaultHeaders : this . _defaultHeaders , path : "/workspaces/{workspaceId}/userDefinedFunctionValidations/{userDefinedFunctionValidationKey}" , method : "GET" , pathParams : pathParams , headerParams : headerParams , queryParams : queryParams } ) ; try { const response = await retrier . makeServiceCall ( this . _httpClient , request ) ; const sdkResponse = composeResponse ( { responseObject : < responses . GetUserDefinedFunctionValidationResponse > { } , body : await response . json ( ) , bodyKey : "userDefinedFunctionValidation" , bodyModel : model . UserDefinedFunctionValidation , type : "model.UserDefinedFunctionValidation" , responseHeaders : [ { value : response . headers . get ( "etag" ) , key : "etag" , dataType : "string" } , { value : response . headers . get ( "opc-request-id" ) , key : "opcRequestId" , dataType : "string" } ] } ) ; return sdkResponse ; } catch ( err ) { throw err ; } } param GetWorkRequestRequest return throws example Click  https to see how to use GetWorkRequest API.
      public async getWorkRequest ( getWorkRequestRequest ) { if ( this . logger ) this . logger . debug ( "Calling operation DataIntegrationClient#getWorkRequest." ) ; const pathParams = { "{workRequestId}" : getWorkRequestRequest . workRequestId } ; const queryParams = { } ; let headerParams = { "Content-Type" : common . Constants . APPLICATION_JSON , "opc-request-id" : getWorkRequestRequest . opcRequestId } ; const specRetryConfiguration = common . NoRetryConfigurationDetails ; const retrier = GenericRetrier . createPreferredRetrier ( this . _clientConfiguration ? this . _clientConfiguration . retryConfiguration : undefined , getWorkRequestRequest . retryConfiguration , specRetryConfiguration ) ; if ( this . logger ) retrier . logger = this . logger ; const request = await composeRequest ( { baseEndpoint : this . _endpoint , defaultHeaders : this . _defaultHeaders , path : "/workRequests/{workRequestId}" , method : "GET" , pathParams : pathParams , headerParams : headerParams , queryParams : queryParams } ) ; try { const response = await retrier . makeServiceCall ( this . _httpClient , request ) ; const sdkResponse = composeResponse ( { responseObject : < responses . GetWorkRequestResponse > { } , body : await response . json ( ) , bodyKey : "workRequest" , bodyModel : model . WorkRequest , type : "model.WorkRequest" , responseHeaders : [ { value : response . headers . get ( "etag" ) , key : "etag" , dataType : "string" } , { value : response . headers . get ( "opc-request-id" ) , key : "opcRequestId" , dataType : "string" } , { value : response . headers . get ( "retry-after" ) , key : "retryAfter" , dataType : "number" } ] } ) ; return sdkResponse ; } catch ( err ) { throw err ; } } param GetWorkspaceRequest return throws example Click  https to see how to use GetWorkspace API.
      public async getWorkspace ( getWorkspaceRequest ) { if ( this . logger ) this . logger . debug ( "Calling operation DataIntegrationClient#getWorkspace." ) ; const pathParams = { "{workspaceId}" : getWorkspaceRequest . workspaceId } ; const queryParams = { } ; let headerParams = { "Content-Type" : common . Constants . APPLICATION_JSON , "opc-request-id" : getWorkspaceRequest . opcRequestId } ; const specRetryConfiguration = common . NoRetryConfigurationDetails ; const retrier = GenericRetrier . createPreferredRetrier ( this . _clientConfiguration ? this . _clientConfiguration . retryConfiguration : undefined , getWorkspaceRequest . retryConfiguration , specRetryConfiguration ) ; if ( this . logger ) retrier . logger = this . logger ; const request = await composeRequest ( { baseEndpoint : this . _endpoint , defaultHeaders : this . _defaultHeaders , path : "/workspaces/{workspaceId}" , method : "GET" , pathParams : pathParams , headerParams : headerParams , queryParams : queryParams } ) ; try { const response = await retrier . makeServiceCall ( this . _httpClient , request ) ; const sdkResponse = composeResponse ( { responseObject : < responses . GetWorkspaceResponse > { } , body : await response . json ( ) , bodyKey : "workspace" , bodyModel : model . Workspace , type : "model.Workspace" , responseHeaders : [ { value : response . headers . get ( "etag" ) , key : "etag" , dataType : "string" } , { value : response . headers . get ( "opc-request-id" ) , key : "opcRequestId" , dataType : "string" } ] } ) ; return sdkResponse ; } catch ( err ) { throw err ; } } param ListApplicationsRequest return throws example Click  https to see how to use ListApplications API.
      public async listApplications ( listApplicationsRequest ) { if ( this . logger ) this . logger . debug ( "Calling operation DataIntegrationClient#listApplications." ) ; const pathParams = { "{workspaceId}" : listApplicationsRequest . workspaceId } ; const queryParams = { "name" : listApplicationsRequest . name , "nameContains" : listApplicationsRequest . nameContains , "identifier" : listApplicationsRequest . identifier , "fields" : listApplicationsRequest . fields , "limit" : listApplicationsRequest . limit , "page" : listApplicationsRequest . page , "sortOrder" : listApplicationsRequest . sortOrder , "sortBy" : listApplicationsRequest . sortBy } ; let headerParams = { "Content-Type" : common . Constants . APPLICATION_JSON , "opc-request-id" : listApplicationsRequest . opcRequestId } ; const specRetryConfiguration = common . NoRetryConfigurationDetails ; const retrier = GenericRetrier . createPreferredRetrier ( this . _clientConfiguration ? this . _clientConfiguration . retryConfiguration : undefined , listApplicationsRequest . retryConfiguration , specRetryConfiguration ) ; if ( this . logger ) retrier . logger = this . logger ; const request = await composeRequest ( { baseEndpoint : this . _endpoint , defaultHeaders : this . _defaultHeaders , path : "/workspaces/{workspaceId}/applications" , method : "GET" , pathParams : pathParams , headerParams : headerParams , queryParams : queryParams } ) ; try { const response = await retrier . makeServiceCall ( this . _httpClient , request ) ; const sdkResponse = composeResponse ( { responseObject : < responses . ListApplicationsResponse > { } , body : await response . json ( ) , bodyKey : "applicationSummaryCollection" , bodyModel : model . ApplicationSummaryCollection , type : "model.ApplicationSummaryCollection" , responseHeaders : [ { value : response . headers . get ( "opc-request-id" ) , key : "opcRequestId" , dataType : "string" } , { value : response . headers . get ( "opc-next-page" ) , key : "opcNextPage" , dataType : "string" } , { value : response . headers . get ( "opc-prev-page" ) , key : "opcPrevPage" , dataType : "string" } , { value : response . headers . get ( "opc-total-items" ) , key : "opcTotalItems" , dataType : "number" } ] } ) ; return sdkResponse ; } catch ( err ) { throw err ; } } param ListConnectionValidationsRequest return throws example Click  https to see how to use ListConnectionValidations API.
      public async listConnectionValidations ( listConnectionValidationsRequest ) { if ( this . logger ) this . logger . debug ( "Calling operation DataIntegrationClient#listConnectionValidations." ) ; const pathParams = { "{workspaceId}" : listConnectionValidationsRequest . workspaceId } ; const queryParams = { "key" : listConnectionValidationsRequest . key , "name" : listConnectionValidationsRequest . name , "identifier" : listConnectionValidationsRequest . identifier , "fields" : listConnectionValidationsRequest . fields , "page" : listConnectionValidationsRequest . page , "limit" : listConnectionValidationsRequest . limit , "sortBy" : listConnectionValidationsRequest . sortBy , "sortOrder" : listConnectionValidationsRequest . sortOrder } ; let headerParams = { "Content-Type" : common . Constants . APPLICATION_JSON , "opc-request-id" : listConnectionValidationsRequest . opcRequestId } ; const specRetryConfiguration = common . NoRetryConfigurationDetails ; const retrier = GenericRetrier . createPreferredRetrier ( this . _clientConfiguration ? this . _clientConfiguration . retryConfiguration : undefined , listConnectionValidationsRequest . retryConfiguration , specRetryConfiguration ) ; if ( this . logger ) retrier . logger = this . logger ; const request = await composeRequest ( { baseEndpoint : this . _endpoint , defaultHeaders : this . _defaultHeaders , path : "/workspaces/{workspaceId}/connectionValidations" , method : "GET" , pathParams : pathParams , headerParams : headerParams , queryParams : queryParams } ) ; try { const response = await retrier . makeServiceCall ( this . _httpClient , request ) ; const sdkResponse = composeResponse ( { responseObject : < responses . ListConnectionValidationsResponse > { } , body : await response . json ( ) , bodyKey : "connectionValidationSummaryCollection" , bodyModel : model . ConnectionValidationSummaryCollection , type : "model.ConnectionValidationSummaryCollection" , responseHeaders : [ { value : response . headers . get ( "opc-request-id" ) , key : "opcRequestId" , dataType : "string" } , { value : response . headers . get ( "opc-next-page" ) , key : "opcNextPage" , dataType : "string" } , { value : response . headers . get ( "opc-prev-page" ) , key : "opcPrevPage" , dataType : "string" } , { value : response . headers . get ( "opc-total-items" ) , key : "opcTotalItems" , dataType : "number" } ] } ) ; return sdkResponse ; } catch ( err ) { throw err ; } } param ListConnectionsRequest return throws example Click  https to see how to use ListConnections API.
      public async listConnections ( listConnectionsRequest ) { if ( this . logger ) this . logger . debug ( "Calling operation DataIntegrationClient#listConnections." ) ; const pathParams = { "{workspaceId}" : listConnectionsRequest . workspaceId } ; const queryParams = { "dataAssetKey" : listConnectionsRequest . dataAssetKey , "name" : listConnectionsRequest . name , "page" : listConnectionsRequest . page , "limit" : listConnectionsRequest . limit , "fields" : listConnectionsRequest . fields , "type" : listConnectionsRequest . type , "sortBy" : listConnectionsRequest . sortBy , "sortOrder" : listConnectionsRequest . sortOrder } ; let headerParams = { "Content-Type" : common . Constants . APPLICATION_JSON , "opc-request-id" : listConnectionsRequest . opcRequestId } ; const specRetryConfiguration = common . NoRetryConfigurationDetails ; const retrier = GenericRetrier . createPreferredRetrier ( this . _clientConfiguration ? this . _clientConfiguration . retryConfiguration : undefined , listConnectionsRequest . retryConfiguration , specRetryConfiguration ) ; if ( this . logger ) retrier . logger = this . logger ; const request = await composeRequest ( { baseEndpoint : this . _endpoint , defaultHeaders : this . _defaultHeaders , path : "/workspaces/{workspaceId}/connections" , method : "GET" , pathParams : pathParams , headerParams : headerParams , queryParams : queryParams } ) ; try { const response = await retrier . makeServiceCall ( this . _httpClient , request ) ; const sdkResponse = composeResponse ( { responseObject : < responses . ListConnectionsResponse > { } , body : await response . json ( ) , bodyKey : "connectionSummaryCollection" , bodyModel : model . ConnectionSummaryCollection , type : "model.ConnectionSummaryCollection" , responseHeaders : [ { value : response . headers . get ( "opc-request-id" ) , key : "opcRequestId" , dataType : "string" } , { value : response . headers . get ( "opc-next-page" ) , key : "opcNextPage" , dataType : "string" } , { value : response . headers . get ( "opc-prev-page" ) , key : "opcPrevPage" , dataType : "string" } , { value : response . headers . get ( "opc-total-items" ) , key : "opcTotalItems" , dataType : "number" } ] } ) ; return sdkResponse ; } catch ( err ) { throw err ; } } param ListDataAssetsRequest return throws example Click  https to see how to use ListDataAssets API.
      public async listDataAssets ( listDataAssetsRequest ) { if ( this . logger ) this . logger . debug ( "Calling operation DataIntegrationClient#listDataAssets." ) ; const pathParams = { "{workspaceId}" : listDataAssetsRequest . workspaceId } ; const queryParams = { "page" : listDataAssetsRequest . page , "limit" : listDataAssetsRequest . limit , "fields" : listDataAssetsRequest . fields , "type" : listDataAssetsRequest . type , "sortBy" : listDataAssetsRequest . sortBy , "sortOrder" : listDataAssetsRequest . sortOrder , "name" : listDataAssetsRequest . name } ; let headerParams = { "Content-Type" : common . Constants . APPLICATION_JSON , "opc-request-id" : listDataAssetsRequest . opcRequestId } ; const specRetryConfiguration = common . NoRetryConfigurationDetails ; const retrier = GenericRetrier . createPreferredRetrier ( this . _clientConfiguration ? this . _clientConfiguration . retryConfiguration : undefined , listDataAssetsRequest . retryConfiguration , specRetryConfiguration ) ; if ( this . logger ) retrier . logger = this . logger ; const request = await composeRequest ( { baseEndpoint : this . _endpoint , defaultHeaders : this . _defaultHeaders , path : "/workspaces/{workspaceId}/dataAssets" , method : "GET" , pathParams : pathParams , headerParams : headerParams , queryParams : queryParams } ) ; try { const response = await retrier . makeServiceCall ( this . _httpClient , request ) ; const sdkResponse = composeResponse ( { responseObject : < responses . ListDataAssetsResponse > { } , body : await response . json ( ) , bodyKey : "dataAssetSummaryCollection" , bodyModel : model . DataAssetSummaryCollection , type : "model.DataAssetSummaryCollection" , responseHeaders : [ { value : response . headers . get ( "opc-request-id" ) , key : "opcRequestId" , dataType : "string" } , { value : response . headers . get ( "opc-next-page" ) , key : "opcNextPage" , dataType : "string" } , { value : response . headers . get ( "opc-prev-page" ) , key : "opcPrevPage" , dataType : "string" } , { value : response . headers . get ( "opc-total-items" ) , key : "opcTotalItems" , dataType : "number" } ] } ) ; return sdkResponse ; } catch ( err ) { throw err ; } } param ListDataEntitiesRequest return throws example Click  https to see how to use ListDataEntities API.
      public async listDataEntities ( listDataEntitiesRequest ) { if ( this . logger ) this . logger . debug ( "Calling operation DataIntegrationClient#listDataEntities." ) ; const pathParams = { "{workspaceId}" : listDataEntitiesRequest . workspaceId , "{connectionKey}" : listDataEntitiesRequest . connectionKey , "{schemaResourceName}" : listDataEntitiesRequest . schemaResourceName } ; const queryParams = { "name" : listDataEntitiesRequest . name , "page" : listDataEntitiesRequest . page , "type" : listDataEntitiesRequest . type , "limit" : listDataEntitiesRequest . limit , "fields" : listDataEntitiesRequest . fields , "sortBy" : listDataEntitiesRequest . sortBy , "sortOrder" : listDataEntitiesRequest . sortOrder , "nameList" : listDataEntitiesRequest . nameList , "isPattern" : listDataEntitiesRequest . isPattern } ; let headerParams = { "Content-Type" : common . Constants . APPLICATION_JSON , "opc-request-id" : listDataEntitiesRequest . opcRequestId } ; const specRetryConfiguration = common . NoRetryConfigurationDetails ; const retrier = GenericRetrier . createPreferredRetrier ( this . _clientConfiguration ? this . _clientConfiguration . retryConfiguration : undefined , listDataEntitiesRequest . retryConfiguration , specRetryConfiguration ) ; if ( this . logger ) retrier . logger = this . logger ; const request = await composeRequest ( { baseEndpoint : this . _endpoint , defaultHeaders : this . _defaultHeaders , path : "/workspaces/{workspaceId}/connections/{connectionKey}/schemas/{schemaResourceName}/dataEntities" , method : "GET" , pathParams : pathParams , headerParams : headerParams , queryParams : queryParams } ) ; try { const response = await retrier . makeServiceCall ( this . _httpClient , request ) ; const sdkResponse = composeResponse ( { responseObject : < responses . ListDataEntitiesResponse > { } , body : await response . json ( ) , bodyKey : "dataEntitySummaryCollection" , bodyModel : model . DataEntitySummaryCollection , type : "model.DataEntitySummaryCollection" , responseHeaders : [ { value : response . headers . get ( "opc-request-id" ) , key : "opcRequestId" , dataType : "string" } , { value : response . headers . get ( "opc-next-page" ) , key : "opcNextPage" , dataType : "string" } , { value : response . headers . get ( "opc-prev-page" ) , key : "opcPrevPage" , dataType : "string" } , { value : response . headers . get ( "opc-total-items" ) , key : "opcTotalItems" , dataType : "number" } ] } ) ; return sdkResponse ; } catch ( err ) { throw err ; } } param ListDataFlowValidationsRequest return throws example Click  https to see how to use ListDataFlowValidations API.
      public async listDataFlowValidations ( listDataFlowValidationsRequest ) { if ( this . logger ) this . logger . debug ( "Calling operation DataIntegrationClient#listDataFlowValidations." ) ; const pathParams = { "{workspaceId}" : listDataFlowValidationsRequest . workspaceId } ; const queryParams = { "key" : listDataFlowValidationsRequest . key , "name" : listDataFlowValidationsRequest . name , "identifier" : listDataFlowValidationsRequest . identifier , "fields" : listDataFlowValidationsRequest . fields , "page" : listDataFlowValidationsRequest . page , "limit" : listDataFlowValidationsRequest . limit , "sortBy" : listDataFlowValidationsRequest . sortBy , "sortOrder" : listDataFlowValidationsRequest . sortOrder } ; let headerParams = { "Content-Type" : common . Constants . APPLICATION_JSON , "opc-request-id" : listDataFlowValidationsRequest . opcRequestId } ; const specRetryConfiguration = common . NoRetryConfigurationDetails ; const retrier = GenericRetrier . createPreferredRetrier ( this . _clientConfiguration ? this . _clientConfiguration . retryConfiguration : undefined , listDataFlowValidationsRequest . retryConfiguration , specRetryConfiguration ) ; if ( this . logger ) retrier . logger = this . logger ; const request = await composeRequest ( { baseEndpoint : this . _endpoint , defaultHeaders : this . _defaultHeaders , path : "/workspaces/{workspaceId}/dataFlowValidations" , method : "GET" , pathParams : pathParams , headerParams : headerParams , queryParams : queryParams } ) ; try { const response = await retrier . makeServiceCall ( this . _httpClient , request ) ; const sdkResponse = composeResponse ( { responseObject : < responses . ListDataFlowValidationsResponse > { } , body : await response . json ( ) , bodyKey : "dataFlowValidationSummaryCollection" , bodyModel : model . DataFlowValidationSummaryCollection , type : "model.DataFlowValidationSummaryCollection" , responseHeaders : [ { value : response . headers . get ( "opc-request-id" ) , key : "opcRequestId" , dataType : "string" } , { value : response . headers . get ( "opc-next-page" ) , key : "opcNextPage" , dataType : "string" } , { value : response . headers . get ( "opc-prev-page" ) , key : "opcPrevPage" , dataType : "string" } , { value : response . headers . get ( "opc-total-items" ) , key : "opcTotalItems" , dataType : "number" } ] } ) ; return sdkResponse ; } catch ( err ) { throw err ; } } param ListDataFlowsRequest return throws example Click  https to see how to use ListDataFlows API.
      public async listDataFlows ( listDataFlowsRequest ) { if ( this . logger ) this . logger . debug ( "Calling operation DataIntegrationClient#listDataFlows." ) ; const pathParams = { "{workspaceId}" : listDataFlowsRequest . workspaceId } ; const queryParams = { "folderId" : listDataFlowsRequest . folderId , "fields" : listDataFlowsRequest . fields , "name" : listDataFlowsRequest . name , "identifier" : listDataFlowsRequest . identifier , "limit" : listDataFlowsRequest . limit , "page" : listDataFlowsRequest . page , "sortOrder" : listDataFlowsRequest . sortOrder , "sortBy" : listDataFlowsRequest . sortBy } ; let headerParams = { "Content-Type" : common . Constants . APPLICATION_JSON , "opc-request-id" : listDataFlowsRequest . opcRequestId } ; const specRetryConfiguration = common . NoRetryConfigurationDetails ; const retrier = GenericRetrier . createPreferredRetrier ( this . _clientConfiguration ? this . _clientConfiguration . retryConfiguration : undefined , listDataFlowsRequest . retryConfiguration , specRetryConfiguration ) ; if ( this . logger ) retrier . logger = this . logger ; const request = await composeRequest ( { baseEndpoint : this . _endpoint , defaultHeaders : this . _defaultHeaders , path : "/workspaces/{workspaceId}/dataFlows" , method : "GET" , pathParams : pathParams , headerParams : headerParams , queryParams : queryParams } ) ; try { const response = await retrier . makeServiceCall ( this . _httpClient , request ) ; const sdkResponse = composeResponse ( { responseObject : < responses . ListDataFlowsResponse > { } , body : await response . json ( ) , bodyKey : "dataFlowSummaryCollection" , bodyModel : model . DataFlowSummaryCollection , type : "model.DataFlowSummaryCollection" , responseHeaders : [ { value : response . headers . get ( "opc-request-id" ) , key : "opcRequestId" , dataType : "string" } , { value : response . headers . get ( "opc-next-page" ) , key : "opcNextPage" , dataType : "string" } , { value : response . headers . get ( "opc-prev-page" ) , key : "opcPrevPage" , dataType : "string" } , { value : response . headers . get ( "opc-total-items" ) , key : "opcTotalItems" , dataType : "number" } ] } ) ; return sdkResponse ; } catch ( err ) { throw err ; } } param ListDependentObjectsRequest return throws example Click  https to see how to use ListDependentObjects API.
      public async listDependentObjects ( listDependentObjectsRequest ) { if ( this . logger ) this . logger . debug ( "Calling operation DataIntegrationClient#listDependentObjects." ) ; const pathParams = { "{workspaceId}" : listDependentObjectsRequest . workspaceId , "{applicationKey}" : listDependentObjectsRequest . applicationKey } ; const queryParams = { "fields" : listDependentObjectsRequest . fields , "name" : listDependentObjectsRequest . name , "nameContains" : listDependentObjectsRequest . nameContains , "identifier" : listDependentObjectsRequest . identifier , "type" : listDependentObjectsRequest . type , "typeInSubtree" : listDependentObjectsRequest . typeInSubtree , "limit" : listDependentObjectsRequest . limit , "page" : listDependentObjectsRequest . page , "sortOrder" : listDependentObjectsRequest . sortOrder , "sortBy" : listDependentObjectsRequest . sortBy } ; let headerParams = { "Content-Type" : common . Constants . APPLICATION_JSON , "opc-request-id" : listDependentObjectsRequest . opcRequestId } ; const specRetryConfiguration = common . NoRetryConfigurationDetails ; const retrier = GenericRetrier . createPreferredRetrier ( this . _clientConfiguration ? this . _clientConfiguration . retryConfiguration : undefined , listDependentObjectsRequest . retryConfiguration , specRetryConfiguration ) ; if ( this . logger ) retrier . logger = this . logger ; const request = await composeRequest ( { baseEndpoint : this . _endpoint , defaultHeaders : this . _defaultHeaders , path : "/workspaces/{workspaceId}/applications/{applicationKey}/dependentObjects" , method : "GET" , pathParams : pathParams , headerParams : headerParams , queryParams : queryParams } ) ; try { const response = await retrier . makeServiceCall ( this . _httpClient , request ) ; const sdkResponse = composeResponse ( { responseObject : < responses . ListDependentObjectsResponse > { } , body : await response . json ( ) , bodyKey : "dependentObjectSummaryCollection" , bodyModel : model . DependentObjectSummaryCollection , type : "model.DependentObjectSummaryCollection" , responseHeaders : [ { value : response . headers . get ( "opc-request-id" ) , key : "opcRequestId" , dataType : "string" } , { value : response . headers . get ( "opc-next-page" ) , key : "opcNextPage" , dataType : "string" } , { value : response . headers . get ( "opc-prev-page" ) , key : "opcPrevPage" , dataType : "string" } , { value : response . headers . get ( "opc-total-items" ) , key : "opcTotalItems" , dataType : "number" } ] } ) ; return sdkResponse ; } catch ( err ) { throw err ; } } param ListExternalPublicationValidationsRequest return throws example Click  https to see how to use ListExternalPublicationValidations API.
      public async listExternalPublicationValidations ( listExternalPublicationValidationsRequest ) { if ( this . logger ) this . logger . debug ( "Calling operation DataIntegrationClient#listExternalPublicationValidations." ) ; const pathParams = { "{workspaceId}" : listExternalPublicationValidationsRequest . workspaceId , "{taskKey}" : listExternalPublicationValidationsRequest . taskKey } ; const queryParams = { "fields" : listExternalPublicationValidationsRequest . fields , "name" : listExternalPublicationValidationsRequest . name , "identifier" : listExternalPublicationValidationsRequest . identifier , "page" : listExternalPublicationValidationsRequest . page , "limit" : listExternalPublicationValidationsRequest . limit , "sortOrder" : listExternalPublicationValidationsRequest . sortOrder , "sortBy" : listExternalPublicationValidationsRequest . sortBy } ; let headerParams = { "Content-Type" : common . Constants . APPLICATION_JSON , "opc-request-id" : listExternalPublicationValidationsRequest . opcRequestId } ; const specRetryConfiguration = common . NoRetryConfigurationDetails ; const retrier = GenericRetrier . createPreferredRetrier ( this . _clientConfiguration ? this . _clientConfiguration . retryConfiguration : undefined , listExternalPublicationValidationsRequest . retryConfiguration , specRetryConfiguration ) ; if ( this . logger ) retrier . logger = this . logger ; const request = await composeRequest ( { baseEndpoint : this . _endpoint , defaultHeaders : this . _defaultHeaders , path : "/workspaces/{workspaceId}/tasks/{taskKey}/externalPublicationValidations" , method : "GET" , pathParams : pathParams , headerParams : headerParams , queryParams : queryParams } ) ; try { const response = await retrier . makeServiceCall ( this . _httpClient , request ) ; const sdkResponse = composeResponse ( { responseObject : < responses . ListExternalPublicationValidationsResponse > { } , body : await response . json ( ) , bodyKey : "externalPublicationValidationSummaryCollection" , bodyModel : model . ExternalPublicationValidationSummaryCollection , type : "model.ExternalPublicationValidationSummaryCollection" , responseHeaders : [ { value : response . headers . get ( "opc-request-id" ) , key : "opcRequestId" , dataType : "string" } , { value : response . headers . get ( "opc-next-page" ) , key : "opcNextPage" , dataType : "string" } , { value : response . headers . get ( "opc-prev-page" ) , key : "opcPrevPage" , dataType : "string" } , { value : response . headers . get ( "opc-total-items" ) , key : "opcTotalItems" , dataType : "number" } ] } ) ; return sdkResponse ; } catch ( err ) { throw err ; } } param ListExternalPublicationsRequest return throws example Click  https to see how to use ListExternalPublications API.
      public async listExternalPublications ( listExternalPublicationsRequest ) { if ( this . logger ) this . logger . debug ( "Calling operation DataIntegrationClient#listExternalPublications." ) ; const pathParams = { "{workspaceId}" : listExternalPublicationsRequest . workspaceId , "{taskKey}" : listExternalPublicationsRequest . taskKey } ; const queryParams = { "fields" : listExternalPublicationsRequest . fields , "name" : listExternalPublicationsRequest . name , "limit" : listExternalPublicationsRequest . limit , "page" : listExternalPublicationsRequest . page , "sortOrder" : listExternalPublicationsRequest . sortOrder , "sortBy" : listExternalPublicationsRequest . sortBy } ; let headerParams = { "Content-Type" : common . Constants . APPLICATION_JSON , "opc-request-id" : listExternalPublicationsRequest . opcRequestId } ; const specRetryConfiguration = common . NoRetryConfigurationDetails ; const retrier = GenericRetrier . createPreferredRetrier ( this . _clientConfiguration ? this . _clientConfiguration . retryConfiguration : undefined , listExternalPublicationsRequest . retryConfiguration , specRetryConfiguration ) ; if ( this . logger ) retrier . logger = this . logger ; const request = await composeRequest ( { baseEndpoint : this . _endpoint , defaultHeaders : this . _defaultHeaders , path : "/workspaces/{workspaceId}/tasks/{taskKey}/externalPublications" , method : "GET" , pathParams : pathParams , headerParams : headerParams , queryParams : queryParams } ) ; try { const response = await retrier . makeServiceCall ( this . _httpClient , request ) ; const sdkResponse = composeResponse ( { responseObject : < responses . ListExternalPublicationsResponse > { } , body : await response . json ( ) , bodyKey : "externalPublicationSummaryCollection" , bodyModel : model . ExternalPublicationSummaryCollection , type : "model.ExternalPublicationSummaryCollection" , responseHeaders : [ { value : response . headers . get ( "opc-request-id" ) , key : "opcRequestId" , dataType : "string" } , { value : response . headers . get ( "opc-next-page" ) , key : "opcNextPage" , dataType : "string" } , { value : response . headers . get ( "opc-prev-page" ) , key : "opcPrevPage" , dataType : "string" } , { value : response . headers . get ( "opc-total-items" ) , key : "opcTotalItems" , dataType : "number" } ] } ) ; return sdkResponse ; } catch ( err ) { throw err ; } } param ListFoldersRequest return throws example Click  https to see how to use ListFolders API.
      public async listFolders ( listFoldersRequest ) { if ( this . logger ) this . logger . debug ( "Calling operation DataIntegrationClient#listFolders." ) ; const pathParams = { "{workspaceId}" : listFoldersRequest . workspaceId } ; const queryParams = { "aggregatorKey" : listFoldersRequest . aggregatorKey , "fields" : listFoldersRequest . fields , "name" : listFoldersRequest . name , "nameContains" : listFoldersRequest . nameContains , "identifier" : listFoldersRequest . identifier , "page" : listFoldersRequest . page , "limit" : listFoldersRequest . limit , "sortOrder" : listFoldersRequest . sortOrder , "sortBy" : listFoldersRequest . sortBy } ; let headerParams = { "Content-Type" : common . Constants . APPLICATION_JSON , "opc-request-id" : listFoldersRequest . opcRequestId } ; const specRetryConfiguration = common . NoRetryConfigurationDetails ; const retrier = GenericRetrier . createPreferredRetrier ( this . _clientConfiguration ? this . _clientConfiguration . retryConfiguration : undefined , listFoldersRequest . retryConfiguration , specRetryConfiguration ) ; if ( this . logger ) retrier . logger = this . logger ; const request = await composeRequest ( { baseEndpoint : this . _endpoint , defaultHeaders : this . _defaultHeaders , path : "/workspaces/{workspaceId}/folders" , method : "GET" , pathParams : pathParams , headerParams : headerParams , queryParams : queryParams } ) ; try { const response = await retrier . makeServiceCall ( this . _httpClient , request ) ; const sdkResponse = composeResponse ( { responseObject : < responses . ListFoldersResponse > { } , body : await response . json ( ) , bodyKey : "folderSummaryCollection" , bodyModel : model . FolderSummaryCollection , type : "model.FolderSummaryCollection" , responseHeaders : [ { value : response . headers . get ( "opc-request-id" ) , key : "opcRequestId" , dataType : "string" } , { value : response . headers . get ( "opc-next-page" ) , key : "opcNextPage" , dataType : "string" } , { value : response . headers . get ( "opc-prev-page" ) , key : "opcPrevPage" , dataType : "string" } , { value : response . headers . get ( "opc-total-items" ) , key : "opcTotalItems" , dataType : "number" } ] } ) ; return sdkResponse ; } catch ( err ) { throw err ; } } param ListFunctionLibrariesRequest return throws example Click  https to see how to use ListFunctionLibraries API.
      public async listFunctionLibraries ( listFunctionLibrariesRequest ) { if ( this . logger ) this . logger . debug ( "Calling operation DataIntegrationClient#listFunctionLibraries." ) ; const pathParams = { "{workspaceId}" : listFunctionLibrariesRequest . workspaceId } ; const queryParams = { "aggregatorKey" : listFunctionLibrariesRequest . aggregatorKey , "fields" : listFunctionLibrariesRequest . fields , "name" : listFunctionLibrariesRequest . name , "identifier" : listFunctionLibrariesRequest . identifier , "page" : listFunctionLibrariesRequest . page , "limit" : listFunctionLibrariesRequest . limit , "sortOrder" : listFunctionLibrariesRequest . sortOrder , "sortBy" : listFunctionLibrariesRequest . sortBy } ; let headerParams = { "Content-Type" : common . Constants . APPLICATION_JSON , "opc-request-id" : listFunctionLibrariesRequest . opcRequestId } ; const specRetryConfiguration = common . NoRetryConfigurationDetails ; const retrier = GenericRetrier . createPreferredRetrier ( this . _clientConfiguration ? this . _clientConfiguration . retryConfiguration : undefined , listFunctionLibrariesRequest . retryConfiguration , specRetryConfiguration ) ; if ( this . logger ) retrier . logger = this . logger ; const request = await composeRequest ( { baseEndpoint : this . _endpoint , defaultHeaders : this . _defaultHeaders , path : "/workspaces/{workspaceId}/functionLibraries" , method : "GET" , pathParams : pathParams , headerParams : headerParams , queryParams : queryParams } ) ; try { const response = await retrier . makeServiceCall ( this . _httpClient , request ) ; const sdkResponse = composeResponse ( { responseObject : < responses . ListFunctionLibrariesResponse > { } , body : await response . json ( ) , bodyKey : "functionLibrarySummaryCollection" , bodyModel : model . FunctionLibrarySummaryCollection , type : "model.FunctionLibrarySummaryCollection" , responseHeaders : [ { value : response . headers . get ( "opc-request-id" ) , key : "opcRequestId" , dataType : "string" } , { value : response . headers . get ( "opc-next-page" ) , key : "opcNextPage" , dataType : "string" } , { value : response . headers . get ( "opc-prev-page" ) , key : "opcPrevPage" , dataType : "string" } , { value : response . headers . get ( "opc-total-items" ) , key : "opcTotalItems" , dataType : "number" } ] } ) ; return sdkResponse ; } catch ( err ) { throw err ; } } param ListPatchChangesRequest return throws example Click  https to see how to use ListPatchChanges API.
      public async listPatchChanges ( listPatchChangesRequest ) { if ( this . logger ) this . logger . debug ( "Calling operation DataIntegrationClient#listPatchChanges." ) ; const pathParams = { "{workspaceId}" : listPatchChangesRequest . workspaceId , "{applicationKey}" : listPatchChangesRequest . applicationKey } ; const queryParams = { "name" : listPatchChangesRequest . name , "sincePatch" : listPatchChangesRequest . sincePatch , "toPatch" : listPatchChangesRequest . toPatch , "limit" : listPatchChangesRequest . limit , "page" : listPatchChangesRequest . page , "sortOrder" : listPatchChangesRequest . sortOrder , "sortBy" : listPatchChangesRequest . sortBy } ; let headerParams = { "Content-Type" : common . Constants . APPLICATION_JSON , "opc-request-id" : listPatchChangesRequest . opcRequestId } ; const specRetryConfiguration = common . NoRetryConfigurationDetails ; const retrier = GenericRetrier . createPreferredRetrier ( this . _clientConfiguration ? this . _clientConfiguration . retryConfiguration : undefined , listPatchChangesRequest . retryConfiguration , specRetryConfiguration ) ; if ( this . logger ) retrier . logger = this . logger ; const request = await composeRequest ( { baseEndpoint : this . _endpoint , defaultHeaders : this . _defaultHeaders , path : "/workspaces/{workspaceId}/applications/{applicationKey}/patchChanges" , method : "GET" , pathParams : pathParams , headerParams : headerParams , queryParams : queryParams } ) ; try { const response = await retrier . makeServiceCall ( this . _httpClient , request ) ; const sdkResponse = composeResponse ( { responseObject : < responses . ListPatchChangesResponse > { } , body : await response . json ( ) , bodyKey : "patchChangeSummaryCollection" , bodyModel : model . PatchChangeSummaryCollection , type : "model.PatchChangeSummaryCollection" , responseHeaders : [ { value : response . headers . get ( "opc-request-id" ) , key : "opcRequestId" , dataType : "string" } , { value : response . headers . get ( "opc-next-page" ) , key : "opcNextPage" , dataType : "string" } , { value : response . headers . get ( "opc-prev-page" ) , key : "opcPrevPage" , dataType : "string" } , { value : response . headers . get ( "opc-total-items" ) , key : "opcTotalItems" , dataType : "number" } ] } ) ; return sdkResponse ; } catch ( err ) { throw err ; } } param ListPatchesRequest return throws example Click  https to see how to use ListPatches API.
      public async listPatches ( listPatchesRequest ) { if ( this . logger ) this . logger . debug ( "Calling operation DataIntegrationClient#listPatches." ) ; const pathParams = { "{workspaceId}" : listPatchesRequest . workspaceId , "{applicationKey}" : listPatchesRequest . applicationKey } ; const queryParams = { "name" : listPatchesRequest . name , "identifier" : listPatchesRequest . identifier , "fields" : listPatchesRequest . fields , "limit" : listPatchesRequest . limit , "page" : listPatchesRequest . page , "sortOrder" : listPatchesRequest . sortOrder , "sortBy" : listPatchesRequest . sortBy } ; let headerParams = { "Content-Type" : common . Constants . APPLICATION_JSON , "opc-request-id" : listPatchesRequest . opcRequestId } ; const specRetryConfiguration = common . NoRetryConfigurationDetails ; const retrier = GenericRetrier . createPreferredRetrier ( this . _clientConfiguration ? this . _clientConfiguration . retryConfiguration : undefined , listPatchesRequest . retryConfiguration , specRetryConfiguration ) ; if ( this . logger ) retrier . logger = this . logger ; const request = await composeRequest ( { baseEndpoint : this . _endpoint , defaultHeaders : this . _defaultHeaders , path : "/workspaces/{workspaceId}/applications/{applicationKey}/patches" , method : "GET" , pathParams : pathParams , headerParams : headerParams , queryParams : queryParams } ) ; try { const response = await retrier . makeServiceCall ( this . _httpClient , request ) ; const sdkResponse = composeResponse ( { responseObject : < responses . ListPatchesResponse > { } , body : await response . json ( ) , bodyKey : "patchSummaryCollection" , bodyModel : model . PatchSummaryCollection , type : "model.PatchSummaryCollection" , responseHeaders : [ { value : response . headers . get ( "opc-request-id" ) , key : "opcRequestId" , dataType : "string" } , { value : response . headers . get ( "opc-next-page" ) , key : "opcNextPage" , dataType : "string" } , { value : response . headers . get ( "opc-prev-page" ) , key : "opcPrevPage" , dataType : "string" } , { value : response . headers . get ( "opc-total-items" ) , key : "opcTotalItems" , dataType : "number" } ] } ) ; return sdkResponse ; } catch ( err ) { throw err ; } } param ListPipelineValidationsRequest return throws example Click  https to see how to use ListPipelineValidations API.
      public async listPipelineValidations ( listPipelineValidationsRequest ) { if ( this . logger ) this . logger . debug ( "Calling operation DataIntegrationClient#listPipelineValidations." ) ; const pathParams = { "{workspaceId}" : listPipelineValidationsRequest . workspaceId } ; const queryParams = { "key" : listPipelineValidationsRequest . key , "name" : listPipelineValidationsRequest . name , "identifier" : listPipelineValidationsRequest . identifier , "fields" : listPipelineValidationsRequest . fields , "page" : listPipelineValidationsRequest . page , "limit" : listPipelineValidationsRequest . limit , "sortBy" : listPipelineValidationsRequest . sortBy , "sortOrder" : listPipelineValidationsRequest . sortOrder } ; let headerParams = { "Content-Type" : common . Constants . APPLICATION_JSON , "opc-request-id" : listPipelineValidationsRequest . opcRequestId } ; const specRetryConfiguration = common . NoRetryConfigurationDetails ; const retrier = GenericRetrier . createPreferredRetrier ( this . _clientConfiguration ? this . _clientConfiguration . retryConfiguration : undefined , listPipelineValidationsRequest . retryConfiguration , specRetryConfiguration ) ; if ( this . logger ) retrier . logger = this . logger ; const request = await composeRequest ( { baseEndpoint : this . _endpoint , defaultHeaders : this . _defaultHeaders , path : "/workspaces/{workspaceId}/pipelineValidations" , method : "GET" , pathParams : pathParams , headerParams : headerParams , queryParams : queryParams } ) ; try { const response = await retrier . makeServiceCall ( this . _httpClient , request ) ; const sdkResponse = composeResponse ( { responseObject : < responses . ListPipelineValidationsResponse > { } , body : await response . json ( ) , bodyKey : "pipelineValidationSummaryCollection" , bodyModel : model . PipelineValidationSummaryCollection , type : "model.PipelineValidationSummaryCollection" , responseHeaders : [ { value : response . headers . get ( "opc-request-id" ) , key : "opcRequestId" , dataType : "string" } , { value : response . headers . get ( "opc-next-page" ) , key : "opcNextPage" , dataType : "string" } , { value : response . headers . get ( "opc-prev-page" ) , key : "opcPrevPage" , dataType : "string" } , { value : response . headers . get ( "opc-total-items" ) , key : "opcTotalItems" , dataType : "number" } ] } ) ; return sdkResponse ; } catch ( err ) { throw err ; } } param ListPipelinesRequest return throws example Click  https to see how to use ListPipelines API.
      public async listPipelines ( listPipelinesRequest ) { if ( this . logger ) this . logger . debug ( "Calling operation DataIntegrationClient#listPipelines." ) ; const pathParams = { "{workspaceId}" : listPipelinesRequest . workspaceId } ; const queryParams = { "aggregatorKey" : listPipelinesRequest . aggregatorKey , "fields" : listPipelinesRequest . fields , "name" : listPipelinesRequest . name , "identifier" : listPipelinesRequest . identifier , "limit" : listPipelinesRequest . limit , "page" : listPipelinesRequest . page , "sortOrder" : listPipelinesRequest . sortOrder , "sortBy" : listPipelinesRequest . sortBy } ; let headerParams = { "Content-Type" : common . Constants . APPLICATION_JSON , "opc-request-id" : listPipelinesRequest . opcRequestId } ; const specRetryConfiguration = common . NoRetryConfigurationDetails ; const retrier = GenericRetrier . createPreferredRetrier ( this . _clientConfiguration ? this . _clientConfiguration . retryConfiguration : undefined , listPipelinesRequest . retryConfiguration , specRetryConfiguration ) ; if ( this . logger ) retrier . logger = this . logger ; const request = await composeRequest ( { baseEndpoint : this . _endpoint , defaultHeaders : this . _defaultHeaders , path : "/workspaces/{workspaceId}/pipelines" , method : "GET" , pathParams : pathParams , headerParams : headerParams , queryParams : queryParams } ) ; try { const response = await retrier . makeServiceCall ( this . _httpClient , request ) ; const sdkResponse = composeResponse ( { responseObject : < responses . ListPipelinesResponse > { } , body : await response . json ( ) , bodyKey : "pipelineSummaryCollection" , bodyModel : model . PipelineSummaryCollection , type : "model.PipelineSummaryCollection" , responseHeaders : [ { value : response . headers . get ( "opc-request-id" ) , key : "opcRequestId" , dataType : "string" } , { value : response . headers . get ( "opc-next-page" ) , key : "opcNextPage" , dataType : "string" } , { value : response . headers . get ( "opc-prev-page" ) , key : "opcPrevPage" , dataType : "string" } , { value : response . headers . get ( "opc-total-items" ) , key : "opcTotalItems" , dataType : "number" } ] } ) ; return sdkResponse ; } catch ( err ) { throw err ; } } param ListProjectsRequest return throws example Click  https to see how to use ListProjects API.
      public async listProjects ( listProjectsRequest ) { if ( this . logger ) this . logger . debug ( "Calling operation DataIntegrationClient#listProjects." ) ; const pathParams = { "{workspaceId}" : listProjectsRequest . workspaceId } ; const queryParams = { "fields" : listProjectsRequest . fields , "name" : listProjectsRequest . name , "nameContains" : listProjectsRequest . nameContains , "identifier" : listProjectsRequest . identifier , "page" : listProjectsRequest . page , "limit" : listProjectsRequest . limit , "sortOrder" : listProjectsRequest . sortOrder , "sortBy" : listProjectsRequest . sortBy } ; let headerParams = { "Content-Type" : common . Constants . APPLICATION_JSON , "opc-request-id" : listProjectsRequest . opcRequestId } ; const specRetryConfiguration = common . NoRetryConfigurationDetails ; const retrier = GenericRetrier . createPreferredRetrier ( this . _clientConfiguration ? this . _clientConfiguration . retryConfiguration : undefined , listProjectsRequest . retryConfiguration , specRetryConfiguration ) ; if ( this . logger ) retrier . logger = this . logger ; const request = await composeRequest ( { baseEndpoint : this . _endpoint , defaultHeaders : this . _defaultHeaders , path : "/workspaces/{workspaceId}/projects" , method : "GET" , pathParams : pathParams , headerParams : headerParams , queryParams : queryParams } ) ; try { const response = await retrier . makeServiceCall ( this . _httpClient , request ) ; const sdkResponse = composeResponse ( { responseObject : < responses . ListProjectsResponse > { } , body : await response . json ( ) , bodyKey : "projectSummaryCollection" , bodyModel : model . ProjectSummaryCollection , type : "model.ProjectSummaryCollection" , responseHeaders : [ { value : response . headers . get ( "opc-request-id" ) , key : "opcRequestId" , dataType : "string" } , { value : response . headers . get ( "opc-next-page" ) , key : "opcNextPage" , dataType : "string" } , { value : response . headers . get ( "opc-prev-page" ) , key : "opcPrevPage" , dataType : "string" } , { value : response . headers . get ( "opc-total-items" ) , key : "opcTotalItems" , dataType : "number" } ] } ) ; return sdkResponse ; } catch ( err ) { throw err ; } } param ListPublishedObjectsRequest return throws example Click  https to see how to use ListPublishedObjects API.
      public async listPublishedObjects ( listPublishedObjectsRequest ) { if ( this . logger ) this . logger . debug ( "Calling operation DataIntegrationClient#listPublishedObjects." ) ; const pathParams = { "{workspaceId}" : listPublishedObjectsRequest . workspaceId , "{applicationKey}" : listPublishedObjectsRequest . applicationKey } ; const queryParams = { "fields" : listPublishedObjectsRequest . fields , "name" : listPublishedObjectsRequest . name , "nameStartsWith" : listPublishedObjectsRequest . nameStartsWith , "nameContains" : listPublishedObjectsRequest . nameContains , "identifier" : listPublishedObjectsRequest . identifier , "type" : listPublishedObjectsRequest . type , "typeInSubtree" : listPublishedObjectsRequest . typeInSubtree , "limit" : listPublishedObjectsRequest . limit , "page" : listPublishedObjectsRequest . page , "sortOrder" : listPublishedObjectsRequest . sortOrder , "sortBy" : listPublishedObjectsRequest . sortBy } ; let headerParams = { "Content-Type" : common . Constants . APPLICATION_JSON , "opc-request-id" : listPublishedObjectsRequest . opcRequestId } ; const specRetryConfiguration = common . NoRetryConfigurationDetails ; const retrier = GenericRetrier . createPreferredRetrier ( this . _clientConfiguration ? this . _clientConfiguration . retryConfiguration : undefined , listPublishedObjectsRequest . retryConfiguration , specRetryConfiguration ) ; if ( this . logger ) retrier . logger = this . logger ; const request = await composeRequest ( { baseEndpoint : this . _endpoint , defaultHeaders : this . _defaultHeaders , path : "/workspaces/{workspaceId}/applications/{applicationKey}/publishedObjects" , method : "GET" , pathParams : pathParams , headerParams : headerParams , queryParams : queryParams } ) ; try { const response = await retrier . makeServiceCall ( this . _httpClient , request ) ; const sdkResponse = composeResponse ( { responseObject : < responses . ListPublishedObjectsResponse > { } , body : await response . json ( ) , bodyKey : "publishedObjectSummaryCollection" , bodyModel : model . PublishedObjectSummaryCollection , type : "model.PublishedObjectSummaryCollection" , responseHeaders : [ { value : response . headers . get ( "opc-request-id" ) , key : "opcRequestId" , dataType : "string" } , { value : response . headers . get ( "opc-next-page" ) , key : "opcNextPage" , dataType : "string" } , { value : response . headers . get ( "opc-prev-page" ) , key : "opcPrevPage" , dataType : "string" } , { value : response . headers . get ( "opc-total-items" ) , key : "opcTotalItems" , dataType : "number" } ] } ) ; return sdkResponse ; } catch ( err ) { throw err ; } } param ListReferencesRequest return throws example Click  https to see how to use ListReferences API.
      public async listReferences ( listReferencesRequest ) { if ( this . logger ) this . logger . debug ( "Calling operation DataIntegrationClient#listReferences." ) ; const pathParams = { "{workspaceId}" : listReferencesRequest . workspaceId , "{applicationKey}" : listReferencesRequest . applicationKey } ; const queryParams = { "limit" : listReferencesRequest . limit , "page" : listReferencesRequest . page , "name" : listReferencesRequest . name , "sortOrder" : listReferencesRequest . sortOrder , "sortBy" : listReferencesRequest . sortBy } ; let headerParams = { "Content-Type" : common . Constants . APPLICATION_JSON , "opc-request-id" : listReferencesRequest . opcRequestId } ; const specRetryConfiguration = common . NoRetryConfigurationDetails ; const retrier = GenericRetrier . createPreferredRetrier ( this . _clientConfiguration ? this . _clientConfiguration . retryConfiguration : undefined , listReferencesRequest . retryConfiguration , specRetryConfiguration ) ; if ( this . logger ) retrier . logger = this . logger ; const request = await composeRequest ( { baseEndpoint : this . _endpoint , defaultHeaders : this . _defaultHeaders , path : "/workspaces/{workspaceId}/applications/{applicationKey}/references" , method : "GET" , pathParams : pathParams , headerParams : headerParams , queryParams : queryParams } ) ; try { const response = await retrier . makeServiceCall ( this . _httpClient , request ) ; const sdkResponse = composeResponse ( { responseObject : < responses . ListReferencesResponse > { } , body : await response . json ( ) , bodyKey : "referenceSummaryCollection" , bodyModel : model . ReferenceSummaryCollection , type : "model.ReferenceSummaryCollection" , responseHeaders : [ { value : response . headers . get ( "etag" ) , key : "etag" , dataType : "string" } , { value : response . headers . get ( "opc-request-id" ) , key : "opcRequestId" , dataType : "string" } , { value : response . headers . get ( "opc-next-page" ) , key : "opcNextPage" , dataType : "string" } , { value : response . headers . get ( "opc-prev-page" ) , key : "opcPrevPage" , dataType : "string" } , { value : response . headers . get ( "opc-total-items" ) , key : "opcTotalItems" , dataType : "number" } ] } ) ; return sdkResponse ; } catch ( err ) { throw err ; } } param ListSchedulesRequest return throws example Click  https to see how to use ListSchedules API.
      public async listSchedules ( listSchedulesRequest ) { if ( this . logger ) this . logger . debug ( "Calling operation DataIntegrationClient#listSchedules." ) ; const pathParams = { "{workspaceId}" : listSchedulesRequest . workspaceId , "{applicationKey}" : listSchedulesRequest . applicationKey } ; const queryParams = { "key" : listSchedulesRequest . key , "name" : listSchedulesRequest . name , "identifier" : listSchedulesRequest . identifier , "type" : listSchedulesRequest . type , "page" : listSchedulesRequest . page , "limit" : listSchedulesRequest . limit , "sortBy" : listSchedulesRequest . sortBy , "sortOrder" : listSchedulesRequest . sortOrder } ; let headerParams = { "Content-Type" : common . Constants . APPLICATION_JSON , "opc-request-id" : listSchedulesRequest . opcRequestId } ; const specRetryConfiguration = common . NoRetryConfigurationDetails ; const retrier = GenericRetrier . createPreferredRetrier ( this . _clientConfiguration ? this . _clientConfiguration . retryConfiguration : undefined , listSchedulesRequest . retryConfiguration , specRetryConfiguration ) ; if ( this . logger ) retrier . logger = this . logger ; const request = await composeRequest ( { baseEndpoint : this . _endpoint , defaultHeaders : this . _defaultHeaders , path : "/workspaces/{workspaceId}/applications/{applicationKey}/schedules" , method : "GET" , pathParams : pathParams , headerParams : headerParams , queryParams : queryParams } ) ; try { const response = await retrier . makeServiceCall ( this . _httpClient , request ) ; const sdkResponse = composeResponse ( { responseObject : < responses . ListSchedulesResponse > { } , body : await response . json ( ) , bodyKey : "scheduleSummaryCollection" , bodyModel : model . ScheduleSummaryCollection , type : "model.ScheduleSummaryCollection" , responseHeaders : [ { value : response . headers . get ( "opc-request-id" ) , key : "opcRequestId" , dataType : "string" } , { value : response . headers . get ( "opc-next-page" ) , key : "opcNextPage" , dataType : "string" } , { value : response . headers . get ( "opc-prev-page" ) , key : "opcPrevPage" , dataType : "string" } , { value : response . headers . get ( "opc-total-items" ) , key : "opcTotalItems" , dataType : "number" } ] } ) ; return sdkResponse ; } catch ( err ) { throw err ; } } param ListSchemasRequest return throws example Click  https to see how to use ListSchemas API.
      public async listSchemas ( listSchemasRequest ) { if ( this . logger ) this . logger . debug ( "Calling operation DataIntegrationClient#listSchemas." ) ; const pathParams = { "{workspaceId}" : listSchemasRequest . workspaceId , "{connectionKey}" : listSchemasRequest . connectionKey } ; const queryParams = { "page" : listSchemasRequest . page , "limit" : listSchemasRequest . limit , "fields" : listSchemasRequest . fields , "sortBy" : listSchemasRequest . sortBy , "sortOrder" : listSchemasRequest . sortOrder , "schemaResourceName" : listSchemasRequest . schemaResourceName , "name" : listSchemasRequest . name , "nameList" : listSchemasRequest . nameList } ; let headerParams = { "Content-Type" : common . Constants . APPLICATION_JSON , "opc-request-id" : listSchemasRequest . opcRequestId } ; const specRetryConfiguration = common . NoRetryConfigurationDetails ; const retrier = GenericRetrier . createPreferredRetrier ( this . _clientConfiguration ? this . _clientConfiguration . retryConfiguration : undefined , listSchemasRequest . retryConfiguration , specRetryConfiguration ) ; if ( this . logger ) retrier . logger = this . logger ; const request = await composeRequest ( { baseEndpoint : this . _endpoint , defaultHeaders : this . _defaultHeaders , path : "/workspaces/{workspaceId}/connections/{connectionKey}/schemas" , method : "GET" , pathParams : pathParams , headerParams : headerParams , queryParams : queryParams } ) ; try { const response = await retrier . makeServiceCall ( this . _httpClient , request ) ; const sdkResponse = composeResponse ( { responseObject : < responses . ListSchemasResponse > { } , body : await response . json ( ) , bodyKey : "schemaSummaryCollection" , bodyModel : model . SchemaSummaryCollection , type : "model.SchemaSummaryCollection" , responseHeaders : [ { value : response . headers . get ( "opc-request-id" ) , key : "opcRequestId" , dataType : "string" } , { value : response . headers . get ( "opc-next-page" ) , key : "opcNextPage" , dataType : "string" } , { value : response . headers . get ( "opc-prev-page" ) , key : "opcPrevPage" , dataType : "string" } , { value : response . headers . get ( "opc-total-items" ) , key : "opcTotalItems" , dataType : "number" } ] } ) ; return sdkResponse ; } catch ( err ) { throw err ; } } param ListTaskRunLogsRequest return throws example Click  https to see how to use ListTaskRunLogs API.
      public async listTaskRunLogs ( listTaskRunLogsRequest ) { if ( this . logger ) this . logger . debug ( "Calling operation DataIntegrationClient#listTaskRunLogs." ) ; const pathParams = { "{workspaceId}" : listTaskRunLogsRequest . workspaceId , "{applicationKey}" : listTaskRunLogsRequest . applicationKey , "{taskRunKey}" : listTaskRunLogsRequest . taskRunKey } ; const queryParams = { "page" : listTaskRunLogsRequest . page , "limit" : listTaskRunLogsRequest . limit , "sortOrder" : listTaskRunLogsRequest . sortOrder , "sortBy" : listTaskRunLogsRequest . sortBy } ; let headerParams = { "Content-Type" : common . Constants . APPLICATION_JSON , "opc-request-id" : listTaskRunLogsRequest . opcRequestId } ; const specRetryConfiguration = common . NoRetryConfigurationDetails ; const retrier = GenericRetrier . createPreferredRetrier ( this . _clientConfiguration ? this . _clientConfiguration . retryConfiguration : undefined , listTaskRunLogsRequest . retryConfiguration , specRetryConfiguration ) ; if ( this . logger ) retrier . logger = this . logger ; const request = await composeRequest ( { baseEndpoint : this . _endpoint , defaultHeaders : this . _defaultHeaders , path : "/workspaces/{workspaceId}/applications/{applicationKey}/taskRuns/{taskRunKey}/logs" , method : "GET" , pathParams : pathParams , headerParams : headerParams , queryParams : queryParams } ) ; try { const response = await retrier . makeServiceCall ( this . _httpClient , request ) ; const sdkResponse = composeResponse ( { responseObject : < responses . ListTaskRunLogsResponse > { } , body : await response . json ( ) , bodyKey : "items" , bodyModel : model . TaskRunLogSummary , type : "Array<model.TaskRunLogSummary>" , responseHeaders : [ { value : response . headers . get ( "opc-request-id" ) , key : "opcRequestId" , dataType : "string" } , { value : response . headers . get ( "opc-next-page" ) , key : "opcNextPage" , dataType : "string" } , { value : response . headers . get ( "opc-prev-page" ) , key : "opcPrevPage" , dataType : "string" } , { value : response . headers . get ( "opc-total-items" ) , key : "opcTotalItems" , dataType : "number" } ] } ) ; return sdkResponse ; } catch ( err ) { throw err ; } } param request public listAllTaskRunLogs ( request ) { return paginateRecords ( request , req => this . listTaskRunLogs ( req ) ) ; } param request public listAllTaskRunLogsResponses ( request ) { return paginateResponses ( request , req => this . listTaskRunLogs ( req ) ) ; } param request public listTaskRunLogsRecordIterator ( request ) { return paginateRecords ( request , req => this . listTaskRunLogs ( req ) ) ; } param request public listTaskRunLogsResponseIterator ( request ) { return paginateResponses ( request , req => this . listTaskRunLogs ( req ) ) ; } param ListTaskRunsRequest return throws example Click  https to see how to use ListTaskRuns API.
      public async listTaskRuns ( listTaskRunsRequest ) { if ( this . logger ) this . logger . debug ( "Calling operation DataIntegrationClient#listTaskRuns." ) ; const pathParams = { "{workspaceId}" : listTaskRunsRequest . workspaceId , "{applicationKey}" : listTaskRunsRequest . applicationKey } ; const queryParams = { "key" : listTaskRunsRequest . key , "aggregatorKey" : listTaskRunsRequest . aggregatorKey , "fields" : listTaskRunsRequest . fields , "name" : listTaskRunsRequest . name , "identifier" : listTaskRunsRequest . identifier , "page" : listTaskRunsRequest . page , "limit" : listTaskRunsRequest . limit , "sortOrder" : listTaskRunsRequest . sortOrder , "sortBy" : listTaskRunsRequest . sortBy , "filter" : listTaskRunsRequest . filter , "nameStartsWith" : listTaskRunsRequest . nameStartsWith } ; let headerParams = { "Content-Type" : common . Constants . APPLICATION_JSON , "opc-request-id" : listTaskRunsRequest . opcRequestId } ; const specRetryConfiguration = common . NoRetryConfigurationDetails ; const retrier = GenericRetrier . createPreferredRetrier ( this . _clientConfiguration ? this . _clientConfiguration . retryConfiguration : undefined , listTaskRunsRequest . retryConfiguration , specRetryConfiguration ) ; if ( this . logger ) retrier . logger = this . logger ; const request = await composeRequest ( { baseEndpoint : this . _endpoint , defaultHeaders : this . _defaultHeaders , path : "/workspaces/{workspaceId}/applications/{applicationKey}/taskRuns" , method : "GET" , pathParams : pathParams , headerParams : headerParams , queryParams : queryParams } ) ; try { const response = await retrier . makeServiceCall ( this . _httpClient , request ) ; const sdkResponse = composeResponse ( { responseObject : < responses . ListTaskRunsResponse > { } , body : await response . json ( ) , bodyKey : "taskRunSummaryCollection" , bodyModel : model . TaskRunSummaryCollection , type : "model.TaskRunSummaryCollection" , responseHeaders : [ { value : response . headers . get ( "opc-request-id" ) , key : "opcRequestId" , dataType : "string" } , { value : response . headers . get ( "opc-next-page" ) , key : "opcNextPage" , dataType : "string" } , { value : response . headers . get ( "opc-prev-page" ) , key : "opcPrevPage" , dataType : "string" } , { value : response . headers . get ( "opc-total-items" ) , key : "opcTotalItems" , dataType : "number" } ] } ) ; return sdkResponse ; } catch ( err ) { throw err ; } } param ListTaskSchedulesRequest return throws example Click  https to see how to use ListTaskSchedules API.
      public async listTaskSchedules ( listTaskSchedulesRequest ) { if ( this . logger ) this . logger . debug ( "Calling operation DataIntegrationClient#listTaskSchedules." ) ; const pathParams = { "{workspaceId}" : listTaskSchedulesRequest . workspaceId , "{applicationKey}" : listTaskSchedulesRequest . applicationKey } ; const queryParams = { "key" : listTaskSchedulesRequest . key , "name" : listTaskSchedulesRequest . name , "identifier" : listTaskSchedulesRequest . identifier , "type" : listTaskSchedulesRequest . type , "page" : listTaskSchedulesRequest . page , "limit" : listTaskSchedulesRequest . limit , "sortBy" : listTaskSchedulesRequest . sortBy , "sortOrder" : listTaskSchedulesRequest . sortOrder , "isEnabled" : listTaskSchedulesRequest . isEnabled } ; let headerParams = { "Content-Type" : common . Constants . APPLICATION_JSON , "opc-request-id" : listTaskSchedulesRequest . opcRequestId } ; const specRetryConfiguration = common . NoRetryConfigurationDetails ; const retrier = GenericRetrier . createPreferredRetrier ( this . _clientConfiguration ? this . _clientConfiguration . retryConfiguration : undefined , listTaskSchedulesRequest . retryConfiguration , specRetryConfiguration ) ; if ( this . logger ) retrier . logger = this . logger ; const request = await composeRequest ( { baseEndpoint : this . _endpoint , defaultHeaders : this . _defaultHeaders , path : "/workspaces/{workspaceId}/applications/{applicationKey}/taskSchedules" , method : "GET" , pathParams : pathParams , headerParams : headerParams , queryParams : queryParams } ) ; try { const response = await retrier . makeServiceCall ( this . _httpClient , request ) ; const sdkResponse = composeResponse ( { responseObject : < responses . ListTaskSchedulesResponse > { } , body : await response . json ( ) , bodyKey : "taskScheduleSummaryCollection" , bodyModel : model . TaskScheduleSummaryCollection , type : "model.TaskScheduleSummaryCollection" , responseHeaders : [ { value : response . headers . get ( "opc-request-id" ) , key : "opcRequestId" , dataType : "string" } , { value : response . headers . get ( "opc-next-page" ) , key : "opcNextPage" , dataType : "string" } , { value : response . headers . get ( "opc-prev-page" ) , key : "opcPrevPage" , dataType : "string" } , { value : response . headers . get ( "opc-total-items" ) , key : "opcTotalItems" , dataType : "number" } ] } ) ; return sdkResponse ; } catch ( err ) { throw err ; } } param ListTaskValidationsRequest return throws example Click  https to see how to use ListTaskValidations API.
      public async listTaskValidations ( listTaskValidationsRequest ) { if ( this . logger ) this . logger . debug ( "Calling operation DataIntegrationClient#listTaskValidations." ) ; const pathParams = { "{workspaceId}" : listTaskValidationsRequest . workspaceId } ; const queryParams = { "key" : listTaskValidationsRequest . key , "name" : listTaskValidationsRequest . name , "identifier" : listTaskValidationsRequest . identifier , "fields" : listTaskValidationsRequest . fields , "page" : listTaskValidationsRequest . page , "limit" : listTaskValidationsRequest . limit , "sortBy" : listTaskValidationsRequest . sortBy , "sortOrder" : listTaskValidationsRequest . sortOrder } ; let headerParams = { "Content-Type" : common . Constants . APPLICATION_JSON , "opc-request-id" : listTaskValidationsRequest . opcRequestId } ; const specRetryConfiguration = common . NoRetryConfigurationDetails ; const retrier = GenericRetrier . createPreferredRetrier ( this . _clientConfiguration ? this . _clientConfiguration . retryConfiguration : undefined , listTaskValidationsRequest . retryConfiguration , specRetryConfiguration ) ; if ( this . logger ) retrier . logger = this . logger ; const request = await composeRequest ( { baseEndpoint : this . _endpoint , defaultHeaders : this . _defaultHeaders , path : "/workspaces/{workspaceId}/taskValidations" , method : "GET" , pathParams : pathParams , headerParams : headerParams , queryParams : queryParams } ) ; try { const response = await retrier . makeServiceCall ( this . _httpClient , request ) ; const sdkResponse = composeResponse ( { responseObject : < responses . ListTaskValidationsResponse > { } , body : await response . json ( ) , bodyKey : "taskValidationSummaryCollection" , bodyModel : model . TaskValidationSummaryCollection , type : "model.TaskValidationSummaryCollection" , responseHeaders : [ { value : response . headers . get ( "opc-request-id" ) , key : "opcRequestId" , dataType : "string" } , { value : response . headers . get ( "opc-next-page" ) , key : "opcNextPage" , dataType : "string" } , { value : response . headers . get ( "opc-prev-page" ) , key : "opcPrevPage" , dataType : "string" } , { value : response . headers . get ( "opc-total-items" ) , key : "opcTotalItems" , dataType : "number" } ] } ) ; return sdkResponse ; } catch ( err ) { throw err ; } } param ListTasksRequest return throws example Click  https to see how to use ListTasks API.
      public async listTasks ( listTasksRequest ) { if ( this . logger ) this . logger . debug ( "Calling operation DataIntegrationClient#listTasks." ) ; const pathParams = { "{workspaceId}" : listTasksRequest . workspaceId } ; const queryParams = { "folderId" : listTasksRequest . folderId , "fields" : listTasksRequest . fields , "name" : listTasksRequest . name , "key" : listTasksRequest . key , "identifier" : listTasksRequest . identifier , "type" : listTasksRequest . type , "limit" : listTasksRequest . limit , "page" : listTasksRequest . page , "sortOrder" : listTasksRequest . sortOrder , "sortBy" : listTasksRequest . sortBy } ; let headerParams = { "Content-Type" : common . Constants . APPLICATION_JSON , "opc-request-id" : listTasksRequest . opcRequestId } ; const specRetryConfiguration = common . NoRetryConfigurationDetails ; const retrier = GenericRetrier . createPreferredRetrier ( this . _clientConfiguration ? this . _clientConfiguration . retryConfiguration : undefined , listTasksRequest . retryConfiguration , specRetryConfiguration ) ; if ( this . logger ) retrier . logger = this . logger ; const request = await composeRequest ( { baseEndpoint : this . _endpoint , defaultHeaders : this . _defaultHeaders , path : "/workspaces/{workspaceId}/tasks" , method : "GET" , pathParams : pathParams , headerParams : headerParams , queryParams : queryParams } ) ; try { const response = await retrier . makeServiceCall ( this . _httpClient , request ) ; const sdkResponse = composeResponse ( { responseObject : < responses . ListTasksResponse > { } , body : await response . json ( ) , bodyKey : "taskSummaryCollection" , bodyModel : model . TaskSummaryCollection , type : "model.TaskSummaryCollection" , responseHeaders : [ { value : response . headers . get ( "opc-request-id" ) , key : "opcRequestId" , dataType : "string" } , { value : response . headers . get ( "opc-next-page" ) , key : "opcNextPage" , dataType : "string" } , { value : response . headers . get ( "opc-prev-page" ) , key : "opcPrevPage" , dataType : "string" } , { value : response . headers . get ( "opc-total-items" ) , key : "opcTotalItems" , dataType : "number" } ] } ) ; return sdkResponse ; } catch ( err ) { throw err ; } } param ListUserDefinedFunctionValidationsRequest return throws example Click  https to see how to use ListUserDefinedFunctionValidations API.
      public async listUserDefinedFunctionValidations ( listUserDefinedFunctionValidationsRequest ) { if ( this . logger ) this . logger . debug ( "Calling operation DataIntegrationClient#listUserDefinedFunctionValidations." ) ; const pathParams = { "{workspaceId}" : listUserDefinedFunctionValidationsRequest . workspaceId } ; const queryParams = { "key" : listUserDefinedFunctionValidationsRequest . key , "name" : listUserDefinedFunctionValidationsRequest . name , "identifier" : listUserDefinedFunctionValidationsRequest . identifier , "fields" : listUserDefinedFunctionValidationsRequest . fields , "page" : listUserDefinedFunctionValidationsRequest . page , "limit" : listUserDefinedFunctionValidationsRequest . limit , "sortBy" : listUserDefinedFunctionValidationsRequest . sortBy , "sortOrder" : listUserDefinedFunctionValidationsRequest . sortOrder } ; let headerParams = { "Content-Type" : common . Constants . APPLICATION_JSON , "opc-request-id" : listUserDefinedFunctionValidationsRequest . opcRequestId } ; const specRetryConfiguration = common . NoRetryConfigurationDetails ; const retrier = GenericRetrier . createPreferredRetrier ( this . _clientConfiguration ? this . _clientConfiguration . retryConfiguration : undefined , listUserDefinedFunctionValidationsRequest . retryConfiguration , specRetryConfiguration ) ; if ( this . logger ) retrier . logger = this . logger ; const request = await composeRequest ( { baseEndpoint : this . _endpoint , defaultHeaders : this . _defaultHeaders , path : "/workspaces/{workspaceId}/userDefinedFunctionValidations" , method : "GET" , pathParams : pathParams , headerParams : headerParams , queryParams : queryParams } ) ; try { const response = await retrier . makeServiceCall ( this . _httpClient , request ) ; const sdkResponse = composeResponse ( { responseObject : < responses . ListUserDefinedFunctionValidationsResponse > { } , body : await response . json ( ) , bodyKey : "userDefinedFunctionValidationSummaryCollection" , bodyModel : model . UserDefinedFunctionValidationSummaryCollection , type : "model.UserDefinedFunctionValidationSummaryCollection" , responseHeaders : [ { value : response . headers . get ( "opc-request-id" ) , key : "opcRequestId" , dataType : "string" } , { value : response . headers . get ( "opc-next-page" ) , key : "opcNextPage" , dataType : "string" } , { value : response . headers . get ( "opc-prev-page" ) , key : "opcPrevPage" , dataType : "string" } , { value : response . headers . get ( "opc-total-items" ) , key : "opcTotalItems" , dataType : "number" } ] } ) ; return sdkResponse ; } catch ( err ) { throw err ; } } param ListUserDefinedFunctionsRequest return throws example Click  https to see how to use ListUserDefinedFunctions API.
      public async listUserDefinedFunctions ( listUserDefinedFunctionsRequest ) { if ( this . logger ) this . logger . debug ( "Calling operation DataIntegrationClient#listUserDefinedFunctions." ) ; const pathParams = { "{workspaceId}" : listUserDefinedFunctionsRequest . workspaceId } ; const queryParams = { "functionLibraryKey" : listUserDefinedFunctionsRequest . functionLibraryKey , "fields" : listUserDefinedFunctionsRequest . fields , "name" : listUserDefinedFunctionsRequest . name , "identifier" : listUserDefinedFunctionsRequest . identifier , "limit" : listUserDefinedFunctionsRequest . limit , "page" : listUserDefinedFunctionsRequest . page , "sortOrder" : listUserDefinedFunctionsRequest . sortOrder , "sortBy" : listUserDefinedFunctionsRequest . sortBy } ; let headerParams = { "Content-Type" : common . Constants . APPLICATION_JSON , "opc-request-id" : listUserDefinedFunctionsRequest . opcRequestId } ; const specRetryConfiguration = common . NoRetryConfigurationDetails ; const retrier = GenericRetrier . createPreferredRetrier ( this . _clientConfiguration ? this . _clientConfiguration . retryConfiguration : undefined , listUserDefinedFunctionsRequest . retryConfiguration , specRetryConfiguration ) ; if ( this . logger ) retrier . logger = this . logger ; const request = await composeRequest ( { baseEndpoint : this . _endpoint , defaultHeaders : this . _defaultHeaders , path : "/workspaces/{workspaceId}/userDefinedFunctions" , method : "GET" , pathParams : pathParams , headerParams : headerParams , queryParams : queryParams } ) ; try { const response = await retrier . makeServiceCall ( this . _httpClient , request ) ; const sdkResponse = composeResponse ( { responseObject : < responses . ListUserDefinedFunctionsResponse > { } , body : await response . json ( ) , bodyKey : "userDefinedFunctionSummaryCollection" , bodyModel : model . UserDefinedFunctionSummaryCollection , type : "model.UserDefinedFunctionSummaryCollection" , responseHeaders : [ { value : response . headers . get ( "opc-request-id" ) , key : "opcRequestId" , dataType : "string" } , { value : response . headers . get ( "opc-next-page" ) , key : "opcNextPage" , dataType : "string" } , { value : response . headers . get ( "opc-prev-page" ) , key : "opcPrevPage" , dataType : "string" } , { value : response . headers . get ( "opc-total-items" ) , key : "opcTotalItems" , dataType : "number" } ] } ) ; return sdkResponse ; } catch ( err ) { throw err ; } } param ListWorkRequestErrorsRequest return throws example Click  https to see how to use ListWorkRequestErrors API.
      public async listWorkRequestErrors ( listWorkRequestErrorsRequest ) { if ( this . logger ) this . logger . debug ( "Calling operation DataIntegrationClient#listWorkRequestErrors." ) ; const pathParams = { "{workRequestId}" : listWorkRequestErrorsRequest . workRequestId } ; const queryParams = { "page" : listWorkRequestErrorsRequest . page , "limit" : listWorkRequestErrorsRequest . limit , "sortOrder" : listWorkRequestErrorsRequest . sortOrder , "sortBy" : listWorkRequestErrorsRequest . sortBy } ; let headerParams = { "Content-Type" : common . Constants . APPLICATION_JSON , "opc-request-id" : listWorkRequestErrorsRequest . opcRequestId } ; const specRetryConfiguration = common . NoRetryConfigurationDetails ; const retrier = GenericRetrier . createPreferredRetrier ( this . _clientConfiguration ? this . _clientConfiguration . retryConfiguration : undefined , listWorkRequestErrorsRequest . retryConfiguration , specRetryConfiguration ) ; if ( this . logger ) retrier . logger = this . logger ; const request = await composeRequest ( { baseEndpoint : this . _endpoint , defaultHeaders : this . _defaultHeaders , path : "/workRequests/{workRequestId}/workRequestErrors" , method : "GET" , pathParams : pathParams , headerParams : headerParams , queryParams : queryParams } ) ; try { const response = await retrier . makeServiceCall ( this . _httpClient , request ) ; const sdkResponse = composeResponse ( { responseObject : < responses . ListWorkRequestErrorsResponse > { } , body : await response . json ( ) , bodyKey : "items" , bodyModel : model . WorkRequestError , type : "Array<model.WorkRequestError>" , responseHeaders : [ { value : response . headers . get ( "opc-request-id" ) , key : "opcRequestId" , dataType : "string" } , { value : response . headers . get ( "opc-next-page" ) , key : "opcNextPage" , dataType : "string" } ] } ) ; return sdkResponse ; } catch ( err ) { throw err ; } } param request public listAllWorkRequestErrors ( request ) { return paginateRecords ( request , req => this . listWorkRequestErrors ( req ) ) ; } param request public listAllWorkRequestErrorsResponses ( request ) { return paginateResponses ( request , req => this . listWorkRequestErrors ( req ) ) ; } param request public listWorkRequestErrorsRecordIterator ( request ) { return paginateRecords ( request , req => this . listWorkRequestErrors ( req ) ) ; } param request public listWorkRequestErrorsResponseIterator ( request ) { return paginateResponses ( request , req => this . listWorkRequestErrors ( req ) ) ; } param ListWorkRequestLogsRequest return throws example Click  https to see how to use ListWorkRequestLogs API.
      public async listWorkRequestLogs ( listWorkRequestLogsRequest ) { if ( this . logger ) this . logger . debug ( "Calling operation DataIntegrationClient#listWorkRequestLogs." ) ; const pathParams = { "{workRequestId}" : listWorkRequestLogsRequest . workRequestId } ; const queryParams = { "page" : listWorkRequestLogsRequest . page , "limit" : listWorkRequestLogsRequest . limit , "sortOrder" : listWorkRequestLogsRequest . sortOrder , "sortBy" : listWorkRequestLogsRequest . sortBy } ; let headerParams = { "Content-Type" : common . Constants . APPLICATION_JSON , "opc-request-id" : listWorkRequestLogsRequest . opcRequestId } ; const specRetryConfiguration = common . NoRetryConfigurationDetails ; const retrier = GenericRetrier . createPreferredRetrier ( this . _clientConfiguration ? this . _clientConfiguration . retryConfiguration : undefined , listWorkRequestLogsRequest . retryConfiguration , specRetryConfiguration ) ; if ( this . logger ) retrier . logger = this . logger ; const request = await composeRequest ( { baseEndpoint : this . _endpoint , defaultHeaders : this . _defaultHeaders , path : "/workRequests/{workRequestId}/logs" , method : "GET" , pathParams : pathParams , headerParams : headerParams , queryParams : queryParams } ) ; try { const response = await retrier . makeServiceCall ( this . _httpClient , request ) ; const sdkResponse = composeResponse ( { responseObject : < responses . ListWorkRequestLogsResponse > { } , body : await response . json ( ) , bodyKey : "items" , bodyModel : model . WorkRequestLogEntry , type : "Array<model.WorkRequestLogEntry>" , responseHeaders : [ { value : response . headers . get ( "opc-request-id" ) , key : "opcRequestId" , dataType : "string" } , { value : response . headers . get ( "opc-next-page" ) , key : "opcNextPage" , dataType : "string" } ] } ) ; return sdkResponse ; } catch ( err ) { throw err ; } } param request public listAllWorkRequestLogs ( request ) { return paginateRecords ( request , req => this . listWorkRequestLogs ( req ) ) ; } param request public listAllWorkRequestLogsResponses ( request ) { return paginateResponses ( request , req => this . listWorkRequestLogs ( req ) ) ; } param request public listWorkRequestLogsRecordIterator ( request ) { return paginateRecords ( request , req => this . listWorkRequestLogs ( req ) ) ; } param request public listWorkRequestLogsResponseIterator ( request ) { return paginateResponses ( request , req => this . listWorkRequestLogs ( req ) ) ; } param ListWorkRequestsRequest return throws example Click  https to see how to use ListWorkRequests API.
      public async listWorkRequests ( listWorkRequestsRequest ) { if ( this . logger ) this . logger . debug ( "Calling operation DataIntegrationClient#listWorkRequests." ) ; const pathParams = { } ; const queryParams = { "compartmentId" : listWorkRequestsRequest . compartmentId , "workspaceId" : listWorkRequestsRequest . workspaceId , "workRequestStatus" : listWorkRequestsRequest . workRequestStatus , "page" : listWorkRequestsRequest . page , "limit" : listWorkRequestsRequest . limit , "sortOrder" : listWorkRequestsRequest . sortOrder , "sortBy" : listWorkRequestsRequest . sortBy } ; let headerParams = { "Content-Type" : common . Constants . APPLICATION_JSON , "opc-request-id" : listWorkRequestsRequest . opcRequestId } ; const specRetryConfiguration = common . NoRetryConfigurationDetails ; const retrier = GenericRetrier . createPreferredRetrier ( this . _clientConfiguration ? this . _clientConfiguration . retryConfiguration : undefined , listWorkRequestsRequest . retryConfiguration , specRetryConfiguration ) ; if ( this . logger ) retrier . logger = this . logger ; const request = await composeRequest ( { baseEndpoint : this . _endpoint , defaultHeaders : this . _defaultHeaders , path : "/workRequests" , method : "GET" , pathParams : pathParams , headerParams : headerParams , queryParams : queryParams } ) ; try { const response = await retrier . makeServiceCall ( this . _httpClient , request ) ; const sdkResponse = composeResponse ( { responseObject : < responses . ListWorkRequestsResponse > { } , body : await response . json ( ) , bodyKey : "items" , bodyModel : model . WorkRequestSummary , type : "Array<model.WorkRequestSummary>" , responseHeaders : [ { value : response . headers . get ( "opc-request-id" ) , key : "opcRequestId" , dataType : "string" } , { value : response . headers . get ( "opc-next-page" ) , key : "opcNextPage" , dataType : "string" } ] } ) ; return sdkResponse ; } catch ( err ) { throw err ; } } param request public listAllWorkRequests ( request ) { return paginateRecords ( request , req => this . listWorkRequests ( req ) ) ; } param request public listAllWorkRequestsResponses ( request ) { return paginateResponses ( request , req => this . listWorkRequests ( req ) ) ; } param request public listWorkRequestsRecordIterator ( request ) { return paginateRecords ( request , req => this . listWorkRequests ( req ) ) ; } param request public listWorkRequestsResponseIterator ( request ) { return paginateResponses ( request , req => this . listWorkRequests ( req ) ) ; } param ListWorkspacesRequest return throws example Click  https to see how to use ListWorkspaces API.
      public async listWorkspaces ( listWorkspacesRequest ) { if ( this . logger ) this . logger . debug ( "Calling operation DataIntegrationClient#listWorkspaces." ) ; const pathParams = { } ; const queryParams = { "compartmentId" : listWorkspacesRequest . compartmentId , "name" : listWorkspacesRequest . name , "limit" : listWorkspacesRequest . limit , "page" : listWorkspacesRequest . page , "lifecycleState" : listWorkspacesRequest . lifecycleState , "sortOrder" : listWorkspacesRequest . sortOrder , "sortBy" : listWorkspacesRequest . sortBy } ; let headerParams = { "Content-Type" : common . Constants . APPLICATION_JSON , "opc-request-id" : listWorkspacesRequest . opcRequestId } ; const specRetryConfiguration = common . NoRetryConfigurationDetails ; const retrier = GenericRetrier . createPreferredRetrier ( this . _clientConfiguration ? this . _clientConfiguration . retryConfiguration : undefined , listWorkspacesRequest . retryConfiguration , specRetryConfiguration ) ; if ( this . logger ) retrier . logger = this . logger ; const request = await composeRequest ( { baseEndpoint : this . _endpoint , defaultHeaders : this . _defaultHeaders , path : "/workspaces" , method : "GET" , pathParams : pathParams , headerParams : headerParams , queryParams : queryParams } ) ; try { const response = await retrier . makeServiceCall ( this . _httpClient , request ) ; const sdkResponse = composeResponse ( { responseObject : < responses . ListWorkspacesResponse > { } , body : await response . json ( ) , bodyKey : "items" , bodyModel : model . WorkspaceSummary , type : "Array<model.WorkspaceSummary>" , responseHeaders : [ { value : response . headers . get ( "opc-request-id" ) , key : "opcRequestId" , dataType : "string" } , { value : response . headers . get ( "opc-next-page" ) , key : "opcNextPage" , dataType : "string" } ] } ) ; return sdkResponse ; } catch ( err ) { throw err ; } } param request public listAllWorkspaces ( request ) { return paginateRecords ( request , req => this . listWorkspaces ( req ) ) ; } param request public listAllWorkspacesResponses ( request ) { return paginateResponses ( request , req => this . listWorkspaces ( req ) ) ; } param request public listWorkspacesRecordIterator ( request ) { return paginateRecords ( request , req => this . listWorkspaces ( req ) ) ; } param request public listWorkspacesResponseIterator ( request ) { return paginateResponses ( request , req => this . listWorkspaces ( req ) ) ; } param StartWorkspaceRequest return throws example Click  https to see how to use StartWorkspace API.
      public async startWorkspace ( startWorkspaceRequest ) { if ( this . logger ) this . logger . debug ( "Calling operation DataIntegrationClient#startWorkspace." ) ; const pathParams = { "{workspaceId}" : startWorkspaceRequest . workspaceId } ; const queryParams = { } ; let headerParams = { "Content-Type" : common . Constants . APPLICATION_JSON , "if-match" : startWorkspaceRequest . ifMatch , "opc-request-id" : startWorkspaceRequest . opcRequestId , "opc-retry-token" : startWorkspaceRequest . opcRetryToken } ; const specRetryConfiguration = common . NoRetryConfigurationDetails ; const retrier = GenericRetrier . createPreferredRetrier ( this . _clientConfiguration ? this . _clientConfiguration . retryConfiguration : undefined , startWorkspaceRequest . retryConfiguration , specRetryConfiguration ) ; if ( this . logger ) retrier . logger = this . logger ; const request = await composeRequest ( { baseEndpoint : this . _endpoint , defaultHeaders : this . _defaultHeaders , path : "/workspaces/{workspaceId}/actions/start" , method : "POST" , pathParams : pathParams , headerParams : headerParams , queryParams : queryParams } ) ; try { const response = await retrier . makeServiceCall ( this . _httpClient , request ) ; const sdkResponse = composeResponse ( { responseObject : < responses . StartWorkspaceResponse > { } , responseHeaders : [ { value : response . headers . get ( "opc-request-id" ) , key : "opcRequestId" , dataType : "string" } , { value : response . headers . get ( "opc-work-request-id" ) , key : "opcWorkRequestId" , dataType : "string" } ] } ) ; return sdkResponse ; } catch ( err ) { throw err ; } } param StopWorkspaceRequest return throws example Click  https to see how to use StopWorkspace API.
      public async stopWorkspace ( stopWorkspaceRequest ) { if ( this . logger ) this . logger . debug ( "Calling operation DataIntegrationClient#stopWorkspace." ) ; const pathParams = { "{workspaceId}" : stopWorkspaceRequest . workspaceId } ; const queryParams = { "quiesceTimeout" : stopWorkspaceRequest . quiesceTimeout , "isForceOperation" : stopWorkspaceRequest . isForceOperation } ; let headerParams = { "Content-Type" : common . Constants . APPLICATION_JSON , "if-match" : stopWorkspaceRequest . ifMatch , "opc-request-id" : stopWorkspaceRequest . opcRequestId , "opc-retry-token" : stopWorkspaceRequest . opcRetryToken } ; const specRetryConfiguration = common . NoRetryConfigurationDetails ; const retrier = GenericRetrier . createPreferredRetrier ( this . _clientConfiguration ? this . _clientConfiguration . retryConfiguration : undefined , stopWorkspaceRequest . retryConfiguration , specRetryConfiguration ) ; if ( this . logger ) retrier . logger = this . logger ; const request = await composeRequest ( { baseEndpoint : this . _endpoint , defaultHeaders : this . _defaultHeaders , path : "/workspaces/{workspaceId}/actions/stop" , method : "POST" , pathParams : pathParams , headerParams : headerParams , queryParams : queryParams } ) ; try { const response = await retrier . makeServiceCall ( this . _httpClient , request ) ; const sdkResponse = composeResponse ( { responseObject : < responses . StopWorkspaceResponse > { } , responseHeaders : [ { value : response . headers . get ( "opc-request-id" ) , key : "opcRequestId" , dataType : "string" } , { value : response . headers . get ( "opc-work-request-id" ) , key : "opcWorkRequestId" , dataType : "string" } ] } ) ; return sdkResponse ; } catch ( err ) { throw err ; } } param UpdateApplicationRequest return throws example Click  https to see how to use UpdateApplication API.
      public async updateApplication ( updateApplicationRequest ) { if ( this . logger ) this . logger . debug ( "Calling operation DataIntegrationClient#updateApplication." ) ; const pathParams = { "{workspaceId}" : updateApplicationRequest . workspaceId , "{applicationKey}" : updateApplicationRequest . applicationKey } ; const queryParams = { } ; let headerParams = { "Content-Type" : common . Constants . APPLICATION_JSON , "if-match" : updateApplicationRequest . ifMatch , "opc-request-id" : updateApplicationRequest . opcRequestId } ; const specRetryConfiguration = common . NoRetryConfigurationDetails ; const retrier = GenericRetrier . createPreferredRetrier ( this . _clientConfiguration ? this . _clientConfiguration . retryConfiguration : undefined , updateApplicationRequest . retryConfiguration , specRetryConfiguration ) ; if ( this . logger ) retrier . logger = this . logger ; const request = await composeRequest ( { baseEndpoint : this . _endpoint , defaultHeaders : this . _defaultHeaders , path : "/workspaces/{workspaceId}/applications/{applicationKey}" , method : "PUT" , bodyContent : common . ObjectSerializer . serialize ( updateApplicationRequest . updateApplicationDetails , "UpdateApplicationDetails" , model . UpdateApplicationDetails . getJsonObj ) , pathParams : pathParams , headerParams : headerParams , queryParams : queryParams } ) ; try { const response = await retrier . makeServiceCall ( this . _httpClient , request ) ; const sdkResponse = composeResponse ( { responseObject : < responses . UpdateApplicationResponse > { } , body : await response . json ( ) , bodyKey : "application" , bodyModel : model . Application , type : "model.Application" , responseHeaders : [ { value : response . headers . get ( "etag" ) , key : "etag" , dataType : "string" } , { value : response . headers . get ( "opc-request-id" ) , key : "opcRequestId" , dataType : "string" } ] } ) ; return sdkResponse ; } catch ( err ) { throw err ; } } param UpdateConnectionRequest return throws example Click  https to see how to use UpdateConnection API.
      public async updateConnection ( updateConnectionRequest ) { if ( this . logger ) this . logger . debug ( "Calling operation DataIntegrationClient#updateConnection." ) ; const pathParams = { "{workspaceId}" : updateConnectionRequest . workspaceId , "{connectionKey}" : updateConnectionRequest . connectionKey } ; const queryParams = { } ; let headerParams = { "Content-Type" : common . Constants . APPLICATION_JSON , "opc-request-id" : updateConnectionRequest . opcRequestId , "if-match" : updateConnectionRequest . ifMatch } ; const specRetryConfiguration = common . NoRetryConfigurationDetails ; const retrier = GenericRetrier . createPreferredRetrier ( this . _clientConfiguration ? this . _clientConfiguration . retryConfiguration : undefined , updateConnectionRequest . retryConfiguration , specRetryConfiguration ) ; if ( this . logger ) retrier . logger = this . logger ; const request = await composeRequest ( { baseEndpoint : this . _endpoint , defaultHeaders : this . _defaultHeaders , path : "/workspaces/{workspaceId}/connections/{connectionKey}" , method : "PUT" , bodyContent : common . ObjectSerializer . serialize ( updateConnectionRequest . updateConnectionDetails , "UpdateConnectionDetails" , model . UpdateConnectionDetails . getJsonObj ) , pathParams : pathParams , headerParams : headerParams , queryParams : queryParams } ) ; try { const response = await retrier . makeServiceCall ( this . _httpClient , request ) ; const sdkResponse = composeResponse ( { responseObject : < responses . UpdateConnectionResponse > { } , body : await response . json ( ) , bodyKey : "connection" , bodyModel : model . Connection , type : "model.Connection" , responseHeaders : [ { value : response . headers . get ( "etag" ) , key : "etag" , dataType : "string" } , { value : response . headers . get ( "opc-request-id" ) , key : "opcRequestId" , dataType : "string" } ] } ) ; return sdkResponse ; } catch ( err ) { throw err ; } } param UpdateDataAssetRequest return throws example Click  https to see how to use UpdateDataAsset API.
      public async updateDataAsset ( updateDataAssetRequest ) { if ( this . logger ) this . logger . debug ( "Calling operation DataIntegrationClient#updateDataAsset." ) ; const pathParams = { "{workspaceId}" : updateDataAssetRequest . workspaceId , "{dataAssetKey}" : updateDataAssetRequest . dataAssetKey } ; const queryParams = { } ; let headerParams = { "Content-Type" : common . Constants . APPLICATION_JSON , "opc-request-id" : updateDataAssetRequest . opcRequestId , "if-match" : updateDataAssetRequest . ifMatch } ; const specRetryConfiguration = common . NoRetryConfigurationDetails ; const retrier = GenericRetrier . createPreferredRetrier ( this . _clientConfiguration ? this . _clientConfiguration . retryConfiguration : undefined , updateDataAssetRequest . retryConfiguration , specRetryConfiguration ) ; if ( this . logger ) retrier . logger = this . logger ; const request = await composeRequest ( { baseEndpoint : this . _endpoint , defaultHeaders : this . _defaultHeaders , path : "/workspaces/{workspaceId}/dataAssets/{dataAssetKey}" , method : "PUT" , bodyContent : common . ObjectSerializer . serialize ( updateDataAssetRequest . updateDataAssetDetails , "UpdateDataAssetDetails" , model . UpdateDataAssetDetails . getJsonObj ) , pathParams : pathParams , headerParams : headerParams , queryParams : queryParams } ) ; try { const response = await retrier . makeServiceCall ( this . _httpClient , request ) ; const sdkResponse = composeResponse ( { responseObject : < responses . UpdateDataAssetResponse > { } , body : await response . json ( ) , bodyKey : "dataAsset" , bodyModel : model . DataAsset , type : "model.DataAsset" , responseHeaders : [ { value : response . headers . get ( "etag" ) , key : "etag" , dataType : "string" } , { value : response . headers . get ( "opc-request-id" ) , key : "opcRequestId" , dataType : "string" } ] } ) ; return sdkResponse ; } catch ( err ) { throw err ; } } param UpdateDataFlowRequest return throws example Click  https to see how to use UpdateDataFlow API.
      public async updateDataFlow ( updateDataFlowRequest ) { if ( this . logger ) this . logger . debug ( "Calling operation DataIntegrationClient#updateDataFlow." ) ; const pathParams = { "{workspaceId}" : updateDataFlowRequest . workspaceId , "{dataFlowKey}" : updateDataFlowRequest . dataFlowKey } ; const queryParams = { } ; let headerParams = { "Content-Type" : common . Constants . APPLICATION_JSON , "opc-request-id" : updateDataFlowRequest . opcRequestId , "if-match" : updateDataFlowRequest . ifMatch } ; const specRetryConfiguration = common . NoRetryConfigurationDetails ; const retrier = GenericRetrier . createPreferredRetrier ( this . _clientConfiguration ? this . _clientConfiguration . retryConfiguration : undefined , updateDataFlowRequest . retryConfiguration , specRetryConfiguration ) ; if ( this . logger ) retrier . logger = this . logger ; const request = await composeRequest ( { baseEndpoint : this . _endpoint , defaultHeaders : this . _defaultHeaders , path : "/workspaces/{workspaceId}/dataFlows/{dataFlowKey}" , method : "PUT" , bodyContent : common . ObjectSerializer . serialize ( updateDataFlowRequest . updateDataFlowDetails , "UpdateDataFlowDetails" , model . UpdateDataFlowDetails . getJsonObj ) , pathParams : pathParams , headerParams : headerParams , queryParams : queryParams } ) ; try { const response = await retrier . makeServiceCall ( this . _httpClient , request ) ; const sdkResponse = composeResponse ( { responseObject : < responses . UpdateDataFlowResponse > { } , body : await response . json ( ) , bodyKey : "dataFlow" , bodyModel : model . DataFlow , type : "model.DataFlow" , responseHeaders : [ { value : response . headers . get ( "etag" ) , key : "etag" , dataType : "string" } , { value : response . headers . get ( "opc-request-id" ) , key : "opcRequestId" , dataType : "string" } ] } ) ; return sdkResponse ; } catch ( err ) { throw err ; } } param UpdateExternalPublicationRequest return throws example Click  https to see how to use UpdateExternalPublication API.
      public async updateExternalPublication ( updateExternalPublicationRequest ) { if ( this . logger ) this . logger . debug ( "Calling operation DataIntegrationClient#updateExternalPublication." ) ; const pathParams = { "{workspaceId}" : updateExternalPublicationRequest . workspaceId , "{taskKey}" : updateExternalPublicationRequest . taskKey , "{externalPublicationsKey}" : updateExternalPublicationRequest . externalPublicationsKey } ; const queryParams = { } ; let headerParams = { "Content-Type" : common . Constants . APPLICATION_JSON , "opc-request-id" : updateExternalPublicationRequest . opcRequestId , "if-match" : updateExternalPublicationRequest . ifMatch } ; const specRetryConfiguration = common . NoRetryConfigurationDetails ; const retrier = GenericRetrier . createPreferredRetrier ( this . _clientConfiguration ? this . _clientConfiguration . retryConfiguration : undefined , updateExternalPublicationRequest . retryConfiguration , specRetryConfiguration ) ; if ( this . logger ) retrier . logger = this . logger ; const request = await composeRequest ( { baseEndpoint : this . _endpoint , defaultHeaders : this . _defaultHeaders , path : "/workspaces/{workspaceId}/tasks/{taskKey}/externalPublications/{externalPublicationsKey}" , method : "PUT" , bodyContent : common . ObjectSerializer . serialize ( updateExternalPublicationRequest . updateExternalPublicationDetails , "UpdateExternalPublicationDetails" , model . UpdateExternalPublicationDetails . getJsonObj ) , pathParams : pathParams , headerParams : headerParams , queryParams : queryParams } ) ; try { const response = await retrier . makeServiceCall ( this . _httpClient , request ) ; const sdkResponse = composeResponse ( { responseObject : < responses . UpdateExternalPublicationResponse > { } , body : await response . json ( ) , bodyKey : "externalPublication" , bodyModel : model . ExternalPublication , type : "model.ExternalPublication" , responseHeaders : [ { value : response . headers . get ( "etag" ) , key : "etag" , dataType : "string" } , { value : response . headers . get ( "opc-request-id" ) , key : "opcRequestId" , dataType : "string" } ] } ) ; return sdkResponse ; } catch ( err ) { throw err ; } } param UpdateFolderRequest return throws example Click  https to see how to use UpdateFolder API.
      public async updateFolder ( updateFolderRequest ) { if ( this . logger ) this . logger . debug ( "Calling operation DataIntegrationClient#updateFolder." ) ; const pathParams = { "{workspaceId}" : updateFolderRequest . workspaceId , "{folderKey}" : updateFolderRequest . folderKey } ; const queryParams = { } ; let headerParams = { "Content-Type" : common . Constants . APPLICATION_JSON , "opc-request-id" : updateFolderRequest . opcRequestId , "if-match" : updateFolderRequest . ifMatch } ; const specRetryConfiguration = common . NoRetryConfigurationDetails ; const retrier = GenericRetrier . createPreferredRetrier ( this . _clientConfiguration ? this . _clientConfiguration . retryConfiguration : undefined , updateFolderRequest . retryConfiguration , specRetryConfiguration ) ; if ( this . logger ) retrier . logger = this . logger ; const request = await composeRequest ( { baseEndpoint : this . _endpoint , defaultHeaders : this . _defaultHeaders , path : "/workspaces/{workspaceId}/folders/{folderKey}" , method : "PUT" , bodyContent : common . ObjectSerializer . serialize ( updateFolderRequest . updateFolderDetails , "UpdateFolderDetails" , model . UpdateFolderDetails . getJsonObj ) , pathParams : pathParams , headerParams : headerParams , queryParams : queryParams } ) ; try { const response = await retrier . makeServiceCall ( this . _httpClient , request ) ; const sdkResponse = composeResponse ( { responseObject : < responses . UpdateFolderResponse > { } , body : await response . json ( ) , bodyKey : "folder" , bodyModel : model . Folder , type : "model.Folder" , responseHeaders : [ { value : response . headers . get ( "etag" ) , key : "etag" , dataType : "string" } , { value : response . headers . get ( "opc-request-id" ) , key : "opcRequestId" , dataType : "string" } ] } ) ; return sdkResponse ; } catch ( err ) { throw err ; } } param UpdateFunctionLibraryRequest return throws example Click  https to see how to use UpdateFunctionLibrary API.
      public async updateFunctionLibrary ( updateFunctionLibraryRequest ) { if ( this . logger ) this . logger . debug ( "Calling operation DataIntegrationClient#updateFunctionLibrary." ) ; const pathParams = { "{workspaceId}" : updateFunctionLibraryRequest . workspaceId , "{functionLibraryKey}" : updateFunctionLibraryRequest . functionLibraryKey } ; const queryParams = { } ; let headerParams = { "Content-Type" : common . Constants . APPLICATION_JSON , "opc-request-id" : updateFunctionLibraryRequest . opcRequestId , "if-match" : updateFunctionLibraryRequest . ifMatch } ; const specRetryConfiguration = common . NoRetryConfigurationDetails ; const retrier = GenericRetrier . createPreferredRetrier ( this . _clientConfiguration ? this . _clientConfiguration . retryConfiguration : undefined , updateFunctionLibraryRequest . retryConfiguration , specRetryConfiguration ) ; if ( this . logger ) retrier . logger = this . logger ; const request = await composeRequest ( { baseEndpoint : this . _endpoint , defaultHeaders : this . _defaultHeaders , path : "/workspaces/{workspaceId}/functionLibraries/{functionLibraryKey}" , method : "PUT" , bodyContent : common . ObjectSerializer . serialize ( updateFunctionLibraryRequest . updateFunctionLibraryDetails , "UpdateFunctionLibraryDetails" , model . UpdateFunctionLibraryDetails . getJsonObj ) , pathParams : pathParams , headerParams : headerParams , queryParams : queryParams } ) ; try { const response = await retrier . makeServiceCall ( this . _httpClient , request ) ; const sdkResponse = composeResponse ( { responseObject : < responses . UpdateFunctionLibraryResponse > { } , body : await response . json ( ) , bodyKey : "functionLibrary" , bodyModel : model . FunctionLibrary , type : "model.FunctionLibrary" , responseHeaders : [ { value : response . headers . get ( "etag" ) , key : "etag" , dataType : "string" } , { value : response . headers . get ( "opc-request-id" ) , key : "opcRequestId" , dataType : "string" } ] } ) ; return sdkResponse ; } catch ( err ) { throw err ; } } param UpdatePipelineRequest return throws example Click  https to see how to use UpdatePipeline API.
      public async updatePipeline ( updatePipelineRequest ) { if ( this . logger ) this . logger . debug ( "Calling operation DataIntegrationClient#updatePipeline." ) ; const pathParams = { "{workspaceId}" : updatePipelineRequest . workspaceId , "{pipelineKey}" : updatePipelineRequest . pipelineKey } ; const queryParams = { } ; let headerParams = { "Content-Type" : common . Constants . APPLICATION_JSON , "opc-request-id" : updatePipelineRequest . opcRequestId , "if-match" : updatePipelineRequest . ifMatch } ; const specRetryConfiguration = common . NoRetryConfigurationDetails ; const retrier = GenericRetrier . createPreferredRetrier ( this . _clientConfiguration ? this . _clientConfiguration . retryConfiguration : undefined , updatePipelineRequest . retryConfiguration , specRetryConfiguration ) ; if ( this . logger ) retrier . logger = this . logger ; const request = await composeRequest ( { baseEndpoint : this . _endpoint , defaultHeaders : this . _defaultHeaders , path : "/workspaces/{workspaceId}/pipelines/{pipelineKey}" , method : "PUT" , bodyContent : common . ObjectSerializer . serialize ( updatePipelineRequest . updatePipelineDetails , "UpdatePipelineDetails" , model . UpdatePipelineDetails . getJsonObj ) , pathParams : pathParams , headerParams : headerParams , queryParams : queryParams } ) ; try { const response = await retrier . makeServiceCall ( this . _httpClient , request ) ; const sdkResponse = composeResponse ( { responseObject : < responses . UpdatePipelineResponse > { } , body : await response . json ( ) , bodyKey : "pipeline" , bodyModel : model . Pipeline , type : "model.Pipeline" , responseHeaders : [ { value : response . headers . get ( "etag" ) , key : "etag" , dataType : "string" } , { value : response . headers . get ( "opc-request-id" ) , key : "opcRequestId" , dataType : "string" } ] } ) ; return sdkResponse ; } catch ( err ) { throw err ; } } param UpdateProjectRequest return throws example Click  https to see how to use UpdateProject API.
      public async updateProject ( updateProjectRequest ) { if ( this . logger ) this . logger . debug ( "Calling operation DataIntegrationClient#updateProject." ) ; const pathParams = { "{workspaceId}" : updateProjectRequest . workspaceId , "{projectKey}" : updateProjectRequest . projectKey } ; const queryParams = { } ; let headerParams = { "Content-Type" : common . Constants . APPLICATION_JSON , "opc-request-id" : updateProjectRequest . opcRequestId , "if-match" : updateProjectRequest . ifMatch } ; const specRetryConfiguration = common . NoRetryConfigurationDetails ; const retrier = GenericRetrier . createPreferredRetrier ( this . _clientConfiguration ? this . _clientConfiguration . retryConfiguration : undefined , updateProjectRequest . retryConfiguration , specRetryConfiguration ) ; if ( this . logger ) retrier . logger = this . logger ; const request = await composeRequest ( { baseEndpoint : this . _endpoint , defaultHeaders : this . _defaultHeaders , path : "/workspaces/{workspaceId}/projects/{projectKey}" , method : "PUT" , bodyContent : common . ObjectSerializer . serialize ( updateProjectRequest . updateProjectDetails , "UpdateProjectDetails" , model . UpdateProjectDetails . getJsonObj ) , pathParams : pathParams , headerParams : headerParams , queryParams : queryParams } ) ; try { const response = await retrier . makeServiceCall ( this . _httpClient , request ) ; const sdkResponse = composeResponse ( { responseObject : < responses . UpdateProjectResponse > { } , body : await response . json ( ) , bodyKey : "project" , bodyModel : model . Project , type : "model.Project" , responseHeaders : [ { value : response . headers . get ( "etag" ) , key : "etag" , dataType : "string" } , { value : response . headers . get ( "opc-request-id" ) , key : "opcRequestId" , dataType : "string" } ] } ) ; return sdkResponse ; } catch ( err ) { throw err ; } } param UpdateReferenceRequest return throws example Click  https to see how to use UpdateReference API.
      public async updateReference ( updateReferenceRequest ) { if ( this . logger ) this . logger . debug ( "Calling operation DataIntegrationClient#updateReference." ) ; const pathParams = { "{workspaceId}" : updateReferenceRequest . workspaceId , "{applicationKey}" : updateReferenceRequest . applicationKey , "{referenceKey}" : updateReferenceRequest . referenceKey } ; const queryParams = { } ; let headerParams = { "Content-Type" : common . Constants . APPLICATION_JSON , "opc-request-id" : updateReferenceRequest . opcRequestId , "if-match" : updateReferenceRequest . ifMatch , "opc-retry-token" : updateReferenceRequest . opcRetryToken } ; const specRetryConfiguration = common . NoRetryConfigurationDetails ; const retrier = GenericRetrier . createPreferredRetrier ( this . _clientConfiguration ? this . _clientConfiguration . retryConfiguration : undefined , updateReferenceRequest . retryConfiguration , specRetryConfiguration ) ; if ( this . logger ) retrier . logger = this . logger ; const request = await composeRequest ( { baseEndpoint : this . _endpoint , defaultHeaders : this . _defaultHeaders , path : "/workspaces/{workspaceId}/applications/{applicationKey}/references/{referenceKey}" , method : "PUT" , bodyContent : common . ObjectSerializer . serialize ( updateReferenceRequest . updateReferenceDetails , "UpdateReferenceDetails" , model . UpdateReferenceDetails . getJsonObj ) , pathParams : pathParams , headerParams : headerParams , queryParams : queryParams } ) ; try { const response = await retrier . makeServiceCall ( this . _httpClient , request ) ; const sdkResponse = composeResponse ( { responseObject : < responses . UpdateReferenceResponse > { } , body : await response . json ( ) , bodyKey : "reference" , bodyModel : model . Reference , type : "model.Reference" , responseHeaders : [ { value : response . headers . get ( "etag" ) , key : "etag" , dataType : "string" } , { value : response . headers . get ( "opc-request-id" ) , key : "opcRequestId" , dataType : "string" } ] } ) ; return sdkResponse ; } catch ( err ) { throw err ; } } param UpdateScheduleRequest return throws example Click  https to see how to use UpdateSchedule API.
      public async updateSchedule ( updateScheduleRequest ) { if ( this . logger ) this . logger . debug ( "Calling operation DataIntegrationClient#updateSchedule." ) ; const pathParams = { "{workspaceId}" : updateScheduleRequest . workspaceId , "{applicationKey}" : updateScheduleRequest . applicationKey , "{scheduleKey}" : updateScheduleRequest . scheduleKey } ; const queryParams = { } ; let headerParams = { "Content-Type" : common . Constants . APPLICATION_JSON , "if-match" : updateScheduleRequest . ifMatch , "opc-request-id" : updateScheduleRequest . opcRequestId } ; const specRetryConfiguration = common . NoRetryConfigurationDetails ; const retrier = GenericRetrier . createPreferredRetrier ( this . _clientConfiguration ? this . _clientConfiguration . retryConfiguration : undefined , updateScheduleRequest . retryConfiguration , specRetryConfiguration ) ; if ( this . logger ) retrier . logger = this . logger ; const request = await composeRequest ( { baseEndpoint : this . _endpoint , defaultHeaders : this . _defaultHeaders , path : "/workspaces/{workspaceId}/applications/{applicationKey}/schedules/{scheduleKey}" , method : "PUT" , bodyContent : common . ObjectSerializer . serialize ( updateScheduleRequest . updateScheduleDetails , "UpdateScheduleDetails" , model . UpdateScheduleDetails . getJsonObj ) , pathParams : pathParams , headerParams : headerParams , queryParams : queryParams } ) ; try { const response = await retrier . makeServiceCall ( this . _httpClient , request ) ; const sdkResponse = composeResponse ( { responseObject : < responses . UpdateScheduleResponse > { } , body : await response . json ( ) , bodyKey : "schedule" , bodyModel : model . Schedule , type : "model.Schedule" , responseHeaders : [ { value : response . headers . get ( "opc-request-id" ) , key : "opcRequestId" , dataType : "string" } , { value : response . headers . get ( "etag" ) , key : "etag" , dataType : "string" } ] } ) ; return sdkResponse ; } catch ( err ) { throw err ; } } param UpdateTaskRequest return throws example Click  https to see how to use UpdateTask API.
      public async updateTask ( updateTaskRequest ) { if ( this . logger ) this . logger . debug ( "Calling operation DataIntegrationClient#updateTask." ) ; const pathParams = { "{workspaceId}" : updateTaskRequest . workspaceId , "{taskKey}" : updateTaskRequest . taskKey } ; const queryParams = { } ; let headerParams = { "Content-Type" : common . Constants . APPLICATION_JSON , "opc-request-id" : updateTaskRequest . opcRequestId , "if-match" : updateTaskRequest . ifMatch } ; const specRetryConfiguration = common . NoRetryConfigurationDetails ; const retrier = GenericRetrier . createPreferredRetrier ( this . _clientConfiguration ? this . _clientConfiguration . retryConfiguration : undefined , updateTaskRequest . retryConfiguration , specRetryConfiguration ) ; if ( this . logger ) retrier . logger = this . logger ; const request = await composeRequest ( { baseEndpoint : this . _endpoint , defaultHeaders : this . _defaultHeaders , path : "/workspaces/{workspaceId}/tasks/{taskKey}" , method : "PUT" , bodyContent : common . ObjectSerializer . serialize ( updateTaskRequest . updateTaskDetails , "UpdateTaskDetails" , model . UpdateTaskDetails . getJsonObj ) , pathParams : pathParams , headerParams : headerParams , queryParams : queryParams } ) ; try { const response = await retrier . makeServiceCall ( this . _httpClient , request ) ; const sdkResponse = composeResponse ( { responseObject : < responses . UpdateTaskResponse > { } , body : await response . json ( ) , bodyKey : "task" , bodyModel : model . Task , type : "model.Task" , responseHeaders : [ { value : response . headers . get ( "etag" ) , key : "etag" , dataType : "string" } , { value : response . headers . get ( "opc-request-id" ) , key : "opcRequestId" , dataType : "string" } ] } ) ; return sdkResponse ; } catch ( err ) { throw err ; } } param UpdateTaskRunRequest return throws example Click  https to see how to use UpdateTaskRun API.
      public async updateTaskRun ( updateTaskRunRequest ) { if ( this . logger ) this . logger . debug ( "Calling operation DataIntegrationClient#updateTaskRun." ) ; const pathParams = { "{workspaceId}" : updateTaskRunRequest . workspaceId , "{applicationKey}" : updateTaskRunRequest . applicationKey , "{taskRunKey}" : updateTaskRunRequest . taskRunKey } ; const queryParams = { } ; let headerParams = { "Content-Type" : common . Constants . APPLICATION_JSON , "opc-request-id" : updateTaskRunRequest . opcRequestId , "if-match" : updateTaskRunRequest . ifMatch } ; const specRetryConfiguration = common . NoRetryConfigurationDetails ; const retrier = GenericRetrier . createPreferredRetrier ( this . _clientConfiguration ? this . _clientConfiguration . retryConfiguration : undefined , updateTaskRunRequest . retryConfiguration , specRetryConfiguration ) ; if ( this . logger ) retrier . logger = this . logger ; const request = await composeRequest ( { baseEndpoint : this . _endpoint , defaultHeaders : this . _defaultHeaders , path : "/workspaces/{workspaceId}/applications/{applicationKey}/taskRuns/{taskRunKey}" , method : "PUT" , bodyContent : common . ObjectSerializer . serialize ( updateTaskRunRequest . updateTaskRunDetails , "UpdateTaskRunDetails" , model . UpdateTaskRunDetails . getJsonObj ) , pathParams : pathParams , headerParams : headerParams , queryParams : queryParams } ) ; try { const response = await retrier . makeServiceCall ( this . _httpClient , request ) ; const sdkResponse = composeResponse ( { responseObject : < responses . UpdateTaskRunResponse > { } , body : await response . json ( ) , bodyKey : "taskRunDetails" , bodyModel : model . TaskRunDetails , type : "model.TaskRunDetails" , responseHeaders : [ { value : response . headers . get ( "etag" ) , key : "etag" , dataType : "string" } , { value : response . headers . get ( "opc-request-id" ) , key : "opcRequestId" , dataType : "string" } ] } ) ; return sdkResponse ; } catch ( err ) { throw err ; } } param UpdateTaskScheduleRequest return throws example Click  https to see how to use UpdateTaskSchedule API.
      public async updateTaskSchedule ( updateTaskScheduleRequest ) { if ( this . logger ) this . logger . debug ( "Calling operation DataIntegrationClient#updateTaskSchedule." ) ; const pathParams = { "{workspaceId}" : updateTaskScheduleRequest . workspaceId , "{applicationKey}" : updateTaskScheduleRequest . applicationKey , "{taskScheduleKey}" : updateTaskScheduleRequest . taskScheduleKey } ; const queryParams = { } ; let headerParams = { "Content-Type" : common . Constants . APPLICATION_JSON , "if-match" : updateTaskScheduleRequest . ifMatch , "opc-request-id" : updateTaskScheduleRequest . opcRequestId } ; const specRetryConfiguration = common . NoRetryConfigurationDetails ; const retrier = GenericRetrier . createPreferredRetrier ( this . _clientConfiguration ? this . _clientConfiguration . retryConfiguration : undefined , updateTaskScheduleRequest . retryConfiguration , specRetryConfiguration ) ; if ( this . logger ) retrier . logger = this . logger ; const request = await composeRequest ( { baseEndpoint : this . _endpoint , defaultHeaders : this . _defaultHeaders , path : "/workspaces/{workspaceId}/applications/{applicationKey}/taskSchedules/{taskScheduleKey}" , method : "PUT" , bodyContent : common . ObjectSerializer . serialize ( updateTaskScheduleRequest . updateTaskScheduleDetails , "UpdateTaskScheduleDetails" , model . UpdateTaskScheduleDetails . getJsonObj ) , pathParams : pathParams , headerParams : headerParams , queryParams : queryParams } ) ; try { const response = await retrier . makeServiceCall ( this . _httpClient , request ) ; const sdkResponse = composeResponse ( { responseObject : < responses . UpdateTaskScheduleResponse > { } , body : await response . json ( ) , bodyKey : "taskSchedule" , bodyModel : model . TaskSchedule , type : "model.TaskSchedule" , responseHeaders : [ { value : response . headers . get ( "opc-request-id" ) , key : "opcRequestId" , dataType : "string" } , { value : response . headers . get ( "etag" ) , key : "etag" , dataType : "string" } ] } ) ; return sdkResponse ; } catch ( err ) { throw err ; } } param UpdateUserDefinedFunctionRequest return throws example Click  https to see how to use UpdateUserDefinedFunction API.
      public async updateUserDefinedFunction ( updateUserDefinedFunctionRequest ) { if ( this . logger ) this . logger . debug ( "Calling operation DataIntegrationClient#updateUserDefinedFunction." ) ; const pathParams = { "{workspaceId}" : updateUserDefinedFunctionRequest . workspaceId , "{userDefinedFunctionKey}" : updateUserDefinedFunctionRequest . userDefinedFunctionKey } ; const queryParams = { } ; let headerParams = { "Content-Type" : common . Constants . APPLICATION_JSON , "opc-request-id" : updateUserDefinedFunctionRequest . opcRequestId , "if-match" : updateUserDefinedFunctionRequest . ifMatch } ; const specRetryConfiguration = common . NoRetryConfigurationDetails ; const retrier = GenericRetrier . createPreferredRetrier ( this . _clientConfiguration ? this . _clientConfiguration . retryConfiguration : undefined , updateUserDefinedFunctionRequest . retryConfiguration , specRetryConfiguration ) ; if ( this . logger ) retrier . logger = this . logger ; const request = await composeRequest ( { baseEndpoint : this . _endpoint , defaultHeaders : this . _defaultHeaders , path : "/workspaces/{workspaceId}/userDefinedFunctions/{userDefinedFunctionKey}" , method : "PUT" , bodyContent : common . ObjectSerializer . serialize ( updateUserDefinedFunctionRequest . updateUserDefinedFunctionDetails , "UpdateUserDefinedFunctionDetails" , model . UpdateUserDefinedFunctionDetails . getJsonObj ) , pathParams : pathParams , headerParams : headerParams , queryParams : queryParams } ) ; try { const response = await retrier . makeServiceCall ( this . _httpClient , request ) ; const sdkResponse = composeResponse ( { responseObject : < responses . UpdateUserDefinedFunctionResponse > { } , body : await response . json ( ) , bodyKey : "userDefinedFunction" , bodyModel : model . UserDefinedFunction , type : "model.UserDefinedFunction" , responseHeaders : [ { value : response . headers . get ( "etag" ) , key : "etag" , dataType : "string" } , { value : response . headers . get ( "opc-request-id" ) , key : "opcRequestId" , dataType : "string" } ] } ) ; return sdkResponse ; } catch ( err ) { throw err ; } } param UpdateWorkspaceRequest return throws example Click  https to see how to use UpdateWorkspace API.
      public async updateWorkspace ( updateWorkspaceRequest ) { if ( this . logger ) this . logger . debug ( "Calling operation DataIntegrationClient#updateWorkspace." ) ; const pathParams = { "{workspaceId}" : updateWorkspaceRequest . workspaceId } ; const queryParams = { } ; let headerParams = { "Content-Type" : common . Constants . APPLICATION_JSON , "if-match" : updateWorkspaceRequest . ifMatch , "opc-request-id" : updateWorkspaceRequest . opcRequestId } ; const specRetryConfiguration = common . NoRetryConfigurationDetails ; const retrier = GenericRetrier . createPreferredRetrier ( this . _clientConfiguration ? this . _clientConfiguration . retryConfiguration : undefined , updateWorkspaceRequest . retryConfiguration , specRetryConfiguration ) ; if ( this . logger ) retrier . logger = this . logger ; const request = await composeRequest ( { baseEndpoint : this . _endpoint , defaultHeaders : this . _defaultHeaders , path : "/workspaces/{workspaceId}" , method : "PUT" , bodyContent : common . ObjectSerializer . serialize ( updateWorkspaceRequest . updateWorkspaceDetails , "UpdateWorkspaceDetails" , model . UpdateWorkspaceDetails . getJsonObj ) , pathParams : pathParams , headerParams : headerParams , queryParams : queryParams } ) ; try { const response = await retrier . makeServiceCall ( this . _httpClient , request ) ; const sdkResponse = composeResponse ( { responseObject : < responses . UpdateWorkspaceResponse > { } , body : await response . json ( ) , bodyKey : "workspace" , bodyModel : model . Workspace , type : "model.Workspace" , responseHeaders : [ { value : response . headers . get ( "etag" ) , key : "etag" , dataType : "string" } , { value : response . headers . get ( "opc-request-id" ) , key : "opcRequestId" , dataType : "string" } , { value : response . headers . get ( "opc-work-request-id" ) , key : "opcWorkRequestId" , dataType : "string" } ] } ) ; return sdkResponse ; } catch ( err ) { throw err ; } } }