From d22314fb03bf8718d293727602192eedbbb28ef7 Mon Sep 17 00:00:00 2001 From: Ampersand Ops Date: Wed, 19 Aug 2026 22:04:54 +0000 Subject: [PATCH] [auto] Update openapi to 31921c2518ee9d506abcc8480dc79f192f9f3d0d --- .../api/.openapi-generator/FILES | 3 +- .../src/models/BaseSubscribeConfigObject.ts | 18 +- .../src/models/CreateDestinationRequest.ts | 14 +- .../CreateDestinationRequestMetadata.ts | 226 +++++++++++++++++- .../models/CreateDestinationRequestSecrets.ts | 70 +++++- .../api/src/models/DestinationMetadata.ts | 220 +++++++++++++++++ .../api/src/models/IntegrationObject.ts | 2 +- .../api/src/models/QuotaOptimizationConfig.ts | 66 +++++ .../SalesforceQuotaOptimizationConfig.ts | 66 ----- .../api/src/models/SubscribeConfigObject.ts | 18 +- .../src/models/SubscribeProviderOptions.ts | 72 ++++++ .../src/models/UpdateDestinationRequest.ts | 34 +++ ...teDestinationRequestDestinationMetadata.ts | 224 ++++++++++++++++- ...ateDestinationRequestDestinationSecrets.ts | 70 +++++- generated-sources/api/src/models/index.ts | 3 +- 15 files changed, 1006 insertions(+), 100 deletions(-) create mode 100644 generated-sources/api/src/models/QuotaOptimizationConfig.ts delete mode 100644 generated-sources/api/src/models/SalesforceQuotaOptimizationConfig.ts create mode 100644 generated-sources/api/src/models/SubscribeProviderOptions.ts diff --git a/generated-sources/api/.openapi-generator/FILES b/generated-sources/api/.openapi-generator/FILES index 9e6501734..11fc493fc 100644 --- a/generated-sources/api/.openapi-generator/FILES +++ b/generated-sources/api/.openapi-generator/FILES @@ -199,13 +199,13 @@ src/models/ProviderAppMetadata1.ts src/models/ProviderInfo.ts src/models/ProviderMetadata1.ts src/models/ProviderMetadataInfo.ts +src/models/QuotaOptimizationConfig.ts src/models/ReadConfig.ts src/models/ReadConfigAllOf.ts src/models/ReadConfigObject.ts src/models/ReadFilter.ts src/models/RedirectResponse.ts src/models/Revision.ts -src/models/SalesforceQuotaOptimizationConfig.ts src/models/SearchOperators.ts src/models/SearchSupport.ts src/models/SelectedFieldsAutoConfig.ts @@ -214,6 +214,7 @@ src/models/StringFieldOptions.ts src/models/SubscribeConfig.ts src/models/SubscribeConfigAllOf.ts src/models/SubscribeConfigObject.ts +src/models/SubscribeProviderOptions.ts src/models/SubscribeRequirements.ts src/models/SubscribeSupport.ts src/models/Support.ts diff --git a/generated-sources/api/src/models/BaseSubscribeConfigObject.ts b/generated-sources/api/src/models/BaseSubscribeConfigObject.ts index e0216413f..f4e05af90 100644 --- a/generated-sources/api/src/models/BaseSubscribeConfigObject.ts +++ b/generated-sources/api/src/models/BaseSubscribeConfigObject.ts @@ -31,12 +31,12 @@ import { ConfigUpdateEventFromJSONTyped, ConfigUpdateEventToJSON, } from './ConfigUpdateEvent'; -import type { SalesforceQuotaOptimizationConfig } from './SalesforceQuotaOptimizationConfig'; +import type { SubscribeProviderOptions } from './SubscribeProviderOptions'; import { - SalesforceQuotaOptimizationConfigFromJSON, - SalesforceQuotaOptimizationConfigFromJSONTyped, - SalesforceQuotaOptimizationConfigToJSON, -} from './SalesforceQuotaOptimizationConfig'; + SubscribeProviderOptionsFromJSON, + SubscribeProviderOptionsFromJSONTyped, + SubscribeProviderOptionsToJSON, +} from './SubscribeProviderOptions'; /** * @@ -88,10 +88,10 @@ export interface BaseSubscribeConfigObject { otherEvents?: Array; /** * - * @type {SalesforceQuotaOptimizationConfig} + * @type {SubscribeProviderOptions} * @memberof BaseSubscribeConfigObject */ - salesforceQuotaOptimization?: SalesforceQuotaOptimizationConfig; + providerOptions?: SubscribeProviderOptions; } /** @@ -123,7 +123,7 @@ export function BaseSubscribeConfigObjectFromJSONTyped(json: any, ignoreDiscrimi 'updateEvent': !exists(json, 'updateEvent') ? undefined : ConfigUpdateEventFromJSON(json['updateEvent']), 'deleteEvent': !exists(json, 'deleteEvent') ? undefined : ConfigDeleteEventFromJSON(json['deleteEvent']), 'otherEvents': !exists(json, 'otherEvents') ? undefined : json['otherEvents'], - 'salesforceQuotaOptimization': !exists(json, 'salesforceQuotaOptimization') ? undefined : SalesforceQuotaOptimizationConfigFromJSON(json['salesforceQuotaOptimization']), + 'providerOptions': !exists(json, 'providerOptions') ? undefined : SubscribeProviderOptionsFromJSON(json['providerOptions']), }; } @@ -143,7 +143,7 @@ export function BaseSubscribeConfigObjectToJSON(value?: BaseSubscribeConfigObjec 'updateEvent': ConfigUpdateEventToJSON(value.updateEvent), 'deleteEvent': ConfigDeleteEventToJSON(value.deleteEvent), 'otherEvents': value.otherEvents, - 'salesforceQuotaOptimization': SalesforceQuotaOptimizationConfigToJSON(value.salesforceQuotaOptimization), + 'providerOptions': SubscribeProviderOptionsToJSON(value.providerOptions), }; } diff --git a/generated-sources/api/src/models/CreateDestinationRequest.ts b/generated-sources/api/src/models/CreateDestinationRequest.ts index 5f24235ca..dfdac2649 100644 --- a/generated-sources/api/src/models/CreateDestinationRequest.ts +++ b/generated-sources/api/src/models/CreateDestinationRequest.ts @@ -39,7 +39,7 @@ export interface CreateDestinationRequest { */ name: string; /** - * The type of the destination. + * The type of the destination. For `slack`, set `metadata.url` to a Slack incoming webhook URL. The warehouse and message-queue types (`clickhouse`, `snowflake`, `bigquery`, `redshift`, `sqs`, `pubsub`, `rabbitmq`, `azureservicebus`, `kafka`) are configured via the `metadata` and `secrets` fields documented below. * @type {string} * @memberof CreateDestinationRequest */ @@ -65,7 +65,17 @@ export interface CreateDestinationRequest { export const CreateDestinationRequestTypeEnum = { Webhook: 'webhook', Kinesis: 'kinesis', - S3: 's3' + S3: 's3', + Slack: 'slack', + Clickhouse: 'clickhouse', + Snowflake: 'snowflake', + Bigquery: 'bigquery', + Redshift: 'redshift', + Sqs: 'sqs', + Pubsub: 'pubsub', + Rabbitmq: 'rabbitmq', + Azureservicebus: 'azureservicebus', + Kafka: 'kafka' } as const; export type CreateDestinationRequestTypeEnum = typeof CreateDestinationRequestTypeEnum[keyof typeof CreateDestinationRequestTypeEnum]; diff --git a/generated-sources/api/src/models/CreateDestinationRequestMetadata.ts b/generated-sources/api/src/models/CreateDestinationRequestMetadata.ts index 34b0717ad..923bdcf2e 100644 --- a/generated-sources/api/src/models/CreateDestinationRequestMetadata.ts +++ b/generated-sources/api/src/models/CreateDestinationRequestMetadata.ts @@ -20,7 +20,7 @@ import { exists, mapValues } from '../runtime'; */ export interface CreateDestinationRequestMetadata { /** - * Webhook URL, must start with "https://". + * Webhook URL, must start with "https://". For `slack` destinations, this is the Slack incoming webhook URL. * @type {string} * @memberof CreateDestinationRequestMetadata */ @@ -44,13 +44,13 @@ export interface CreateDestinationRequestMetadata { */ streamName?: string; /** - * The endpoint URL for the Kinesis stream. + * The endpoint URL for the `kinesis` stream, or the optional custom endpoint URL for the `sqs` destination. * @type {string} * @memberof CreateDestinationRequestMetadata */ endpointUrl?: string; /** - * The template for the partition key to use when sending events to Kinesis (a JMESPath template) + * The template for the partition key (a JMESPath template). Used by `kinesis`, and optionally by `kafka`. * @type {string} * @memberof CreateDestinationRequestMetadata */ @@ -73,8 +73,176 @@ export interface CreateDestinationRequestMetadata { * @memberof CreateDestinationRequestMetadata */ storageClass?: string; + /** + * The username for the `clickhouse` destination. + * @type {string} + * @memberof CreateDestinationRequestMetadata + */ + username?: string; + /** + * The destination table name (`clickhouse`, `snowflake`, `redshift`). + * @type {string} + * @memberof CreateDestinationRequestMetadata + */ + tableName?: string; + /** + * The database name for the `clickhouse` destination. + * @type {string} + * @memberof CreateDestinationRequestMetadata + */ + database?: string; + /** + * The Snowflake account identifier for the `snowflake` destination. + * @type {string} + * @memberof CreateDestinationRequestMetadata + */ + accountIdentifier?: string; + /** + * The user ID for the `snowflake` destination. + * @type {string} + * @memberof CreateDestinationRequestMetadata + */ + userId?: string; + /** + * The database name (`snowflake`, `redshift`). + * @type {string} + * @memberof CreateDestinationRequestMetadata + */ + dbName?: string; + /** + * The schema name (`snowflake`, `redshift`). + * @type {string} + * @memberof CreateDestinationRequestMetadata + */ + schemaName?: string; + /** + * The Google Cloud project ID (`bigquery`, `pubsub`). Required for `pubsub`. + * @type {string} + * @memberof CreateDestinationRequestMetadata + */ + projectId?: string; + /** + * The BigQuery dataset ID for the `bigquery` destination. + * @type {string} + * @memberof CreateDestinationRequestMetadata + */ + datasetId?: string; + /** + * The BigQuery table ID for the `bigquery` destination. + * @type {string} + * @memberof CreateDestinationRequestMetadata + */ + tableId?: string; + /** + * The Redshift Serverless workgroup name for the `redshift` destination. + * @type {string} + * @memberof CreateDestinationRequestMetadata + */ + workgroupName?: string; + /** + * The Redshift provisioned cluster identifier for the `redshift` destination. + * @type {string} + * @memberof CreateDestinationRequestMetadata + */ + clusterIdentifier?: string; + /** + * The database user for the `redshift` destination. + * @type {string} + * @memberof CreateDestinationRequestMetadata + */ + dbUser?: string; + /** + * The storage account name for the `azureblob` destination. + * @type {string} + * @memberof CreateDestinationRequestMetadata + */ + account?: string; + /** + * The blob container name for the `azureblob` destination. + * @type {string} + * @memberof CreateDestinationRequestMetadata + */ + container?: string; + /** + * The SQS queue URL for the `sqs` destination. Required for `sqs`. + * @type {string} + * @memberof CreateDestinationRequestMetadata + */ + queueUrl?: string; + /** + * The Pub/Sub topic ID for the `pubsub` destination. Required for `pubsub`. + * @type {string} + * @memberof CreateDestinationRequestMetadata + */ + topicId?: string; + /** + * The AMQP server URL for the `rabbitmq` destination. Required for `rabbitmq`. + * @type {string} + * @memberof CreateDestinationRequestMetadata + */ + serverUrl?: string; + /** + * The exchange to publish to for the `rabbitmq` destination. Required for `rabbitmq`. + * @type {string} + * @memberof CreateDestinationRequestMetadata + */ + exchange?: string; + /** + * Whether to connect over TLS. Optional for the `rabbitmq` and `kafka` destinations. + * @type {boolean} + * @memberof CreateDestinationRequestMetadata + */ + tls?: boolean; + /** + * The queue or topic name for the `azureservicebus` destination. Required for `azureservicebus`. + * @type {string} + * @memberof CreateDestinationRequestMetadata + */ + name?: string; + /** + * The comma-separated list of Kafka broker addresses for the `kafka` destination. Required for `kafka`. + * @type {string} + * @memberof CreateDestinationRequestMetadata + */ + brokers?: string; + /** + * The Kafka topic to publish to for the `kafka` destination. Required for `kafka`. + * @type {string} + * @memberof CreateDestinationRequestMetadata + */ + topic?: string; + /** + * The SASL mechanism used to authenticate to Kafka for the `kafka` destination. Required for `kafka`. + * @type {string} + * @memberof CreateDestinationRequestMetadata + */ + saslMechanism?: CreateDestinationRequestMetadataSaslMechanismEnum; + /** + * For warehouse destinations (`clickhouse`, `snowflake`, `bigquery`, `redshift`), the number of rows to buffer before flushing a batch. Defaults to 1000. + * @type {number} + * @memberof CreateDestinationRequestMetadata + */ + batchSize?: number; + /** + * For warehouse destinations, the maximum number of seconds to wait before flushing a batch (whichever comes first with `batchSize`). Defaults to 30. + * @type {number} + * @memberof CreateDestinationRequestMetadata + */ + maxWaitSecs?: number; } + +/** + * @export + */ +export const CreateDestinationRequestMetadataSaslMechanismEnum = { + Plain: 'plain', + ScramSha256: 'scram-sha-256', + ScramSha512: 'scram-sha-512' +} as const; +export type CreateDestinationRequestMetadataSaslMechanismEnum = typeof CreateDestinationRequestMetadataSaslMechanismEnum[keyof typeof CreateDestinationRequestMetadataSaslMechanismEnum]; + + /** * Check if a given object implements the CreateDestinationRequestMetadata interface. */ @@ -103,6 +271,32 @@ export function CreateDestinationRequestMetadataFromJSONTyped(json: any, ignoreD 'bucket': !exists(json, 'bucket') ? undefined : json['bucket'], 'keyTemplate': !exists(json, 'keyTemplate') ? undefined : json['keyTemplate'], 'storageClass': !exists(json, 'storageClass') ? undefined : json['storageClass'], + 'username': !exists(json, 'username') ? undefined : json['username'], + 'tableName': !exists(json, 'tableName') ? undefined : json['tableName'], + 'database': !exists(json, 'database') ? undefined : json['database'], + 'accountIdentifier': !exists(json, 'accountIdentifier') ? undefined : json['accountIdentifier'], + 'userId': !exists(json, 'userId') ? undefined : json['userId'], + 'dbName': !exists(json, 'dbName') ? undefined : json['dbName'], + 'schemaName': !exists(json, 'schemaName') ? undefined : json['schemaName'], + 'projectId': !exists(json, 'projectId') ? undefined : json['projectId'], + 'datasetId': !exists(json, 'datasetId') ? undefined : json['datasetId'], + 'tableId': !exists(json, 'tableId') ? undefined : json['tableId'], + 'workgroupName': !exists(json, 'workgroupName') ? undefined : json['workgroupName'], + 'clusterIdentifier': !exists(json, 'clusterIdentifier') ? undefined : json['clusterIdentifier'], + 'dbUser': !exists(json, 'dbUser') ? undefined : json['dbUser'], + 'account': !exists(json, 'account') ? undefined : json['account'], + 'container': !exists(json, 'container') ? undefined : json['container'], + 'queueUrl': !exists(json, 'queueUrl') ? undefined : json['queueUrl'], + 'topicId': !exists(json, 'topicId') ? undefined : json['topicId'], + 'serverUrl': !exists(json, 'serverUrl') ? undefined : json['serverUrl'], + 'exchange': !exists(json, 'exchange') ? undefined : json['exchange'], + 'tls': !exists(json, 'tls') ? undefined : json['tls'], + 'name': !exists(json, 'name') ? undefined : json['name'], + 'brokers': !exists(json, 'brokers') ? undefined : json['brokers'], + 'topic': !exists(json, 'topic') ? undefined : json['topic'], + 'saslMechanism': !exists(json, 'saslMechanism') ? undefined : json['saslMechanism'], + 'batchSize': !exists(json, 'batchSize') ? undefined : json['batchSize'], + 'maxWaitSecs': !exists(json, 'maxWaitSecs') ? undefined : json['maxWaitSecs'], }; } @@ -124,6 +318,32 @@ export function CreateDestinationRequestMetadataToJSON(value?: CreateDestination 'bucket': value.bucket, 'keyTemplate': value.keyTemplate, 'storageClass': value.storageClass, + 'username': value.username, + 'tableName': value.tableName, + 'database': value.database, + 'accountIdentifier': value.accountIdentifier, + 'userId': value.userId, + 'dbName': value.dbName, + 'schemaName': value.schemaName, + 'projectId': value.projectId, + 'datasetId': value.datasetId, + 'tableId': value.tableId, + 'workgroupName': value.workgroupName, + 'clusterIdentifier': value.clusterIdentifier, + 'dbUser': value.dbUser, + 'account': value.account, + 'container': value.container, + 'queueUrl': value.queueUrl, + 'topicId': value.topicId, + 'serverUrl': value.serverUrl, + 'exchange': value.exchange, + 'tls': value.tls, + 'name': value.name, + 'brokers': value.brokers, + 'topic': value.topic, + 'saslMechanism': value.saslMechanism, + 'batchSize': value.batchSize, + 'maxWaitSecs': value.maxWaitSecs, }; } diff --git a/generated-sources/api/src/models/CreateDestinationRequestSecrets.ts b/generated-sources/api/src/models/CreateDestinationRequestSecrets.ts index 6a4c2c881..ede5b00b4 100644 --- a/generated-sources/api/src/models/CreateDestinationRequestSecrets.ts +++ b/generated-sources/api/src/models/CreateDestinationRequestSecrets.ts @@ -20,23 +20,71 @@ import { exists, mapValues } from '../runtime'; */ export interface CreateDestinationRequestSecrets { /** - * The AWS access key ID for the Kinesis or S3 destination. + * The AWS access key ID for the `kinesis`, `s3`, and `sqs` destinations. Required for `sqs`. * @type {string} * @memberof CreateDestinationRequestSecrets */ awsKeyId?: string; /** - * The AWS secret access key for the Kinesis or S3 destination. + * The AWS secret access key for the `kinesis`, `s3`, and `sqs` destinations. Required for `sqs`. * @type {string} * @memberof CreateDestinationRequestSecrets */ awsSecretKey?: string; /** - * The AWS session token for the Kinesis or S3 destination. + * The optional AWS session token for the `kinesis`, `s3`, and `sqs` destinations. * @type {string} * @memberof CreateDestinationRequestSecrets */ awsSessionToken?: string; + /** + * The password for the `clickhouse`, `rabbitmq`, and `kafka` destinations. Required for `rabbitmq` and `kafka`. + * @type {string} + * @memberof CreateDestinationRequestSecrets + */ + password?: string; + /** + * The PEM-encoded RSA private key for the `snowflake` destination. + * @type {string} + * @memberof CreateDestinationRequestSecrets + */ + privateKey?: string; + /** + * The service-account credentials JSON for the `bigquery`, `gcs`, and `pubsub` destinations. Required for `pubsub`. + * @type {string} + * @memberof CreateDestinationRequestSecrets + */ + credentials?: string; + /** + * The AWS access key ID for the `redshift` destination. + * @type {string} + * @memberof CreateDestinationRequestSecrets + */ + accessKeyId?: string; + /** + * The AWS secret access key for the `redshift` destination. + * @type {string} + * @memberof CreateDestinationRequestSecrets + */ + secretAccessKey?: string; + /** + * The account access key for the `azureblob` destination. + * @type {string} + * @memberof CreateDestinationRequestSecrets + */ + accessKey?: string; + /** + * The username for the `rabbitmq` and `kafka` destinations. Required for both. + * @type {string} + * @memberof CreateDestinationRequestSecrets + */ + username?: string; + /** + * The connection string for the `azureservicebus` destination. Required for `azureservicebus`. + * @type {string} + * @memberof CreateDestinationRequestSecrets + */ + connectionString?: string; } /** @@ -61,6 +109,14 @@ export function CreateDestinationRequestSecretsFromJSONTyped(json: any, ignoreDi 'awsKeyId': !exists(json, 'awsKeyId') ? undefined : json['awsKeyId'], 'awsSecretKey': !exists(json, 'awsSecretKey') ? undefined : json['awsSecretKey'], 'awsSessionToken': !exists(json, 'awsSessionToken') ? undefined : json['awsSessionToken'], + 'password': !exists(json, 'password') ? undefined : json['password'], + 'privateKey': !exists(json, 'privateKey') ? undefined : json['privateKey'], + 'credentials': !exists(json, 'credentials') ? undefined : json['credentials'], + 'accessKeyId': !exists(json, 'accessKeyId') ? undefined : json['accessKeyId'], + 'secretAccessKey': !exists(json, 'secretAccessKey') ? undefined : json['secretAccessKey'], + 'accessKey': !exists(json, 'accessKey') ? undefined : json['accessKey'], + 'username': !exists(json, 'username') ? undefined : json['username'], + 'connectionString': !exists(json, 'connectionString') ? undefined : json['connectionString'], }; } @@ -76,6 +132,14 @@ export function CreateDestinationRequestSecretsToJSON(value?: CreateDestinationR 'awsKeyId': value.awsKeyId, 'awsSecretKey': value.awsSecretKey, 'awsSessionToken': value.awsSessionToken, + 'password': value.password, + 'privateKey': value.privateKey, + 'credentials': value.credentials, + 'accessKeyId': value.accessKeyId, + 'secretAccessKey': value.secretAccessKey, + 'accessKey': value.accessKey, + 'username': value.username, + 'connectionString': value.connectionString, }; } diff --git a/generated-sources/api/src/models/DestinationMetadata.ts b/generated-sources/api/src/models/DestinationMetadata.ts index c4bbd8130..9825d5281 100644 --- a/generated-sources/api/src/models/DestinationMetadata.ts +++ b/generated-sources/api/src/models/DestinationMetadata.ts @@ -67,8 +67,176 @@ export interface DestinationMetadata { * @memberof DestinationMetadata */ storageClass?: string; + /** + * The username for the clickhouse destination + * @type {string} + * @memberof DestinationMetadata + */ + username?: string; + /** + * The destination table name (clickhouse, snowflake, redshift) + * @type {string} + * @memberof DestinationMetadata + */ + tableName?: string; + /** + * The database name for the clickhouse destination + * @type {string} + * @memberof DestinationMetadata + */ + database?: string; + /** + * The Snowflake account identifier for the snowflake destination + * @type {string} + * @memberof DestinationMetadata + */ + accountIdentifier?: string; + /** + * The user ID for the snowflake destination + * @type {string} + * @memberof DestinationMetadata + */ + userId?: string; + /** + * The database name (snowflake, redshift) + * @type {string} + * @memberof DestinationMetadata + */ + dbName?: string; + /** + * The schema name (snowflake, redshift) + * @type {string} + * @memberof DestinationMetadata + */ + schemaName?: string; + /** + * The Google Cloud project ID (bigquery, pubsub) + * @type {string} + * @memberof DestinationMetadata + */ + projectId?: string; + /** + * The BigQuery dataset ID for the bigquery destination + * @type {string} + * @memberof DestinationMetadata + */ + datasetId?: string; + /** + * The BigQuery table ID for the bigquery destination + * @type {string} + * @memberof DestinationMetadata + */ + tableId?: string; + /** + * The Redshift Serverless workgroup name for the redshift destination + * @type {string} + * @memberof DestinationMetadata + */ + workgroupName?: string; + /** + * The Redshift provisioned cluster identifier for the redshift destination + * @type {string} + * @memberof DestinationMetadata + */ + clusterIdentifier?: string; + /** + * The database user for the redshift destination + * @type {string} + * @memberof DestinationMetadata + */ + dbUser?: string; + /** + * The storage account name for the azureblob destination + * @type {string} + * @memberof DestinationMetadata + */ + account?: string; + /** + * The blob container name for the azureblob destination + * @type {string} + * @memberof DestinationMetadata + */ + container?: string; + /** + * The SQS queue URL for the sqs destination + * @type {string} + * @memberof DestinationMetadata + */ + queueUrl?: string; + /** + * The Pub/Sub topic ID for the pubsub destination + * @type {string} + * @memberof DestinationMetadata + */ + topicId?: string; + /** + * The AMQP server URL for the rabbitmq destination + * @type {string} + * @memberof DestinationMetadata + */ + serverUrl?: string; + /** + * The exchange to publish to for the rabbitmq destination + * @type {string} + * @memberof DestinationMetadata + */ + exchange?: string; + /** + * Whether to connect over TLS (rabbitmq, kafka) + * @type {boolean} + * @memberof DestinationMetadata + */ + tls?: boolean; + /** + * The queue or topic name for the azureservicebus destination + * @type {string} + * @memberof DestinationMetadata + */ + name?: string; + /** + * The comma-separated list of Kafka broker addresses for the kafka destination + * @type {string} + * @memberof DestinationMetadata + */ + brokers?: string; + /** + * The Kafka topic to publish to for the kafka destination + * @type {string} + * @memberof DestinationMetadata + */ + topic?: string; + /** + * The SASL mechanism used to authenticate to Kafka for the kafka destination + * @type {string} + * @memberof DestinationMetadata + */ + saslMechanism?: DestinationMetadataSaslMechanismEnum; + /** + * For warehouse destinations, rows to buffer before flushing a batch (default 1000) + * @type {number} + * @memberof DestinationMetadata + */ + batchSize?: number; + /** + * For warehouse destinations, max seconds before flushing a batch (default 30) + * @type {number} + * @memberof DestinationMetadata + */ + maxWaitSecs?: number; } + +/** + * @export + */ +export const DestinationMetadataSaslMechanismEnum = { + Plain: 'plain', + ScramSha256: 'scram-sha-256', + ScramSha512: 'scram-sha-512' +} as const; +export type DestinationMetadataSaslMechanismEnum = typeof DestinationMetadataSaslMechanismEnum[keyof typeof DestinationMetadataSaslMechanismEnum]; + + /** * Check if a given object implements the DestinationMetadata interface. */ @@ -96,6 +264,32 @@ export function DestinationMetadataFromJSONTyped(json: any, ignoreDiscriminator: 'bucket': !exists(json, 'bucket') ? undefined : json['bucket'], 'keyTemplate': !exists(json, 'keyTemplate') ? undefined : json['keyTemplate'], 'storageClass': !exists(json, 'storageClass') ? undefined : json['storageClass'], + 'username': !exists(json, 'username') ? undefined : json['username'], + 'tableName': !exists(json, 'tableName') ? undefined : json['tableName'], + 'database': !exists(json, 'database') ? undefined : json['database'], + 'accountIdentifier': !exists(json, 'accountIdentifier') ? undefined : json['accountIdentifier'], + 'userId': !exists(json, 'userId') ? undefined : json['userId'], + 'dbName': !exists(json, 'dbName') ? undefined : json['dbName'], + 'schemaName': !exists(json, 'schemaName') ? undefined : json['schemaName'], + 'projectId': !exists(json, 'projectId') ? undefined : json['projectId'], + 'datasetId': !exists(json, 'datasetId') ? undefined : json['datasetId'], + 'tableId': !exists(json, 'tableId') ? undefined : json['tableId'], + 'workgroupName': !exists(json, 'workgroupName') ? undefined : json['workgroupName'], + 'clusterIdentifier': !exists(json, 'clusterIdentifier') ? undefined : json['clusterIdentifier'], + 'dbUser': !exists(json, 'dbUser') ? undefined : json['dbUser'], + 'account': !exists(json, 'account') ? undefined : json['account'], + 'container': !exists(json, 'container') ? undefined : json['container'], + 'queueUrl': !exists(json, 'queueUrl') ? undefined : json['queueUrl'], + 'topicId': !exists(json, 'topicId') ? undefined : json['topicId'], + 'serverUrl': !exists(json, 'serverUrl') ? undefined : json['serverUrl'], + 'exchange': !exists(json, 'exchange') ? undefined : json['exchange'], + 'tls': !exists(json, 'tls') ? undefined : json['tls'], + 'name': !exists(json, 'name') ? undefined : json['name'], + 'brokers': !exists(json, 'brokers') ? undefined : json['brokers'], + 'topic': !exists(json, 'topic') ? undefined : json['topic'], + 'saslMechanism': !exists(json, 'saslMechanism') ? undefined : json['saslMechanism'], + 'batchSize': !exists(json, 'batchSize') ? undefined : json['batchSize'], + 'maxWaitSecs': !exists(json, 'maxWaitSecs') ? undefined : json['maxWaitSecs'], }; } @@ -116,6 +310,32 @@ export function DestinationMetadataToJSON(value?: DestinationMetadata | null): a 'bucket': value.bucket, 'keyTemplate': value.keyTemplate, 'storageClass': value.storageClass, + 'username': value.username, + 'tableName': value.tableName, + 'database': value.database, + 'accountIdentifier': value.accountIdentifier, + 'userId': value.userId, + 'dbName': value.dbName, + 'schemaName': value.schemaName, + 'projectId': value.projectId, + 'datasetId': value.datasetId, + 'tableId': value.tableId, + 'workgroupName': value.workgroupName, + 'clusterIdentifier': value.clusterIdentifier, + 'dbUser': value.dbUser, + 'account': value.account, + 'container': value.container, + 'queueUrl': value.queueUrl, + 'topicId': value.topicId, + 'serverUrl': value.serverUrl, + 'exchange': value.exchange, + 'tls': value.tls, + 'name': value.name, + 'brokers': value.brokers, + 'topic': value.topic, + 'saslMechanism': value.saslMechanism, + 'batchSize': value.batchSize, + 'maxWaitSecs': value.maxWaitSecs, }; } diff --git a/generated-sources/api/src/models/IntegrationObject.ts b/generated-sources/api/src/models/IntegrationObject.ts index cd7b30d46..86fa95f1a 100644 --- a/generated-sources/api/src/models/IntegrationObject.ts +++ b/generated-sources/api/src/models/IntegrationObject.ts @@ -105,7 +105,7 @@ export interface IntegrationObject { */ delivery?: Delivery; /** - * If set to `always`, the integration will automatically install upon user connection and skip the user field selection step. + * If set to `always`, Ampersand reads this object for every installation even if the customer never selects it (or it isn't present) in the installation config. * @type {string} * @memberof IntegrationObject */ diff --git a/generated-sources/api/src/models/QuotaOptimizationConfig.ts b/generated-sources/api/src/models/QuotaOptimizationConfig.ts new file mode 100644 index 000000000..2a129e096 --- /dev/null +++ b/generated-sources/api/src/models/QuotaOptimizationConfig.ts @@ -0,0 +1,66 @@ +/* tslint:disable */ +/* eslint-disable */ +/** + * Ampersand public API + * No description provided (generated by Openapi Generator https://github.com/openapitools/openapi-generator) + * + * The version of the OpenAPI document: 1.0.0 + * + * + * NOTE: This class is auto generated by OpenAPI Generator (https://openapi-generator.tech). + * https://openapi-generator.tech + * Do not edit the class manually. + */ + +import { exists, mapValues } from '../runtime'; +/** + * Reduces API quota consumption for update events by filtering irrelevant change events at the source, so only updates that affect watched fields are delivered. Requires `updateEvent.requiredWatchFields` to be non-empty; it cannot be used with `updateEvent.watchFieldsAuto: all`. Currently supported for Salesforce. + * @export + * @interface QuotaOptimizationConfig + */ +export interface QuotaOptimizationConfig { + /** + * Whether quota optimization is enabled for this object. + * @type {boolean} + * @memberof QuotaOptimizationConfig + */ + enabled: boolean; +} + +/** + * Check if a given object implements the QuotaOptimizationConfig interface. + */ +export function instanceOfQuotaOptimizationConfig(value: object): boolean { + let isInstance = true; + isInstance = isInstance && "enabled" in value; + + return isInstance; +} + +export function QuotaOptimizationConfigFromJSON(json: any): QuotaOptimizationConfig { + return QuotaOptimizationConfigFromJSONTyped(json, false); +} + +export function QuotaOptimizationConfigFromJSONTyped(json: any, ignoreDiscriminator: boolean): QuotaOptimizationConfig { + if ((json === undefined) || (json === null)) { + return json; + } + return { + + 'enabled': json['enabled'], + }; +} + +export function QuotaOptimizationConfigToJSON(value?: QuotaOptimizationConfig | null): any { + if (value === undefined) { + return undefined; + } + if (value === null) { + return null; + } + return { + + 'enabled': value.enabled, + }; +} + diff --git a/generated-sources/api/src/models/SalesforceQuotaOptimizationConfig.ts b/generated-sources/api/src/models/SalesforceQuotaOptimizationConfig.ts deleted file mode 100644 index 99ec19370..000000000 --- a/generated-sources/api/src/models/SalesforceQuotaOptimizationConfig.ts +++ /dev/null @@ -1,66 +0,0 @@ -/* tslint:disable */ -/* eslint-disable */ -/** - * Ampersand public API - * No description provided (generated by Openapi Generator https://github.com/openapitools/openapi-generator) - * - * The version of the OpenAPI document: 1.0.0 - * - * - * NOTE: This class is auto generated by OpenAPI Generator (https://openapi-generator.tech). - * https://openapi-generator.tech - * Do not edit the class manually. - */ - -import { exists, mapValues } from '../runtime'; -/** - * Salesforce only. Reduces Salesforce API quota consumption for update events by filtering irrelevant change events at the source: Ampersand creates a checkbox field on the object and an Apex trigger that sets it when a watched field changes, then only delivers update events where the checkbox is set. Requires `updateEvent.requiredWatchFields` to be non-empty; it cannot be used with `updateEvent.watchFieldsAuto: all`. - * @export - * @interface SalesforceQuotaOptimizationConfig - */ -export interface SalesforceQuotaOptimizationConfig { - /** - * Whether quota optimization is enabled for this object. - * @type {boolean} - * @memberof SalesforceQuotaOptimizationConfig - */ - enabled: boolean; -} - -/** - * Check if a given object implements the SalesforceQuotaOptimizationConfig interface. - */ -export function instanceOfSalesforceQuotaOptimizationConfig(value: object): boolean { - let isInstance = true; - isInstance = isInstance && "enabled" in value; - - return isInstance; -} - -export function SalesforceQuotaOptimizationConfigFromJSON(json: any): SalesforceQuotaOptimizationConfig { - return SalesforceQuotaOptimizationConfigFromJSONTyped(json, false); -} - -export function SalesforceQuotaOptimizationConfigFromJSONTyped(json: any, ignoreDiscriminator: boolean): SalesforceQuotaOptimizationConfig { - if ((json === undefined) || (json === null)) { - return json; - } - return { - - 'enabled': json['enabled'], - }; -} - -export function SalesforceQuotaOptimizationConfigToJSON(value?: SalesforceQuotaOptimizationConfig | null): any { - if (value === undefined) { - return undefined; - } - if (value === null) { - return null; - } - return { - - 'enabled': value.enabled, - }; -} - diff --git a/generated-sources/api/src/models/SubscribeConfigObject.ts b/generated-sources/api/src/models/SubscribeConfigObject.ts index 4609b0af0..aec910388 100644 --- a/generated-sources/api/src/models/SubscribeConfigObject.ts +++ b/generated-sources/api/src/models/SubscribeConfigObject.ts @@ -31,12 +31,12 @@ import { ConfigUpdateEventFromJSONTyped, ConfigUpdateEventToJSON, } from './ConfigUpdateEvent'; -import type { SalesforceQuotaOptimizationConfig } from './SalesforceQuotaOptimizationConfig'; +import type { SubscribeProviderOptions } from './SubscribeProviderOptions'; import { - SalesforceQuotaOptimizationConfigFromJSON, - SalesforceQuotaOptimizationConfigFromJSONTyped, - SalesforceQuotaOptimizationConfigToJSON, -} from './SalesforceQuotaOptimizationConfig'; + SubscribeProviderOptionsFromJSON, + SubscribeProviderOptionsFromJSONTyped, + SubscribeProviderOptionsToJSON, +} from './SubscribeProviderOptions'; /** * @@ -88,10 +88,10 @@ export interface SubscribeConfigObject { otherEvents?: Array; /** * - * @type {SalesforceQuotaOptimizationConfig} + * @type {SubscribeProviderOptions} * @memberof SubscribeConfigObject */ - salesforceQuotaOptimization?: SalesforceQuotaOptimizationConfig; + providerOptions?: SubscribeProviderOptions; } /** @@ -123,7 +123,7 @@ export function SubscribeConfigObjectFromJSONTyped(json: any, ignoreDiscriminato 'updateEvent': !exists(json, 'updateEvent') ? undefined : ConfigUpdateEventFromJSON(json['updateEvent']), 'deleteEvent': !exists(json, 'deleteEvent') ? undefined : ConfigDeleteEventFromJSON(json['deleteEvent']), 'otherEvents': !exists(json, 'otherEvents') ? undefined : json['otherEvents'], - 'salesforceQuotaOptimization': !exists(json, 'salesforceQuotaOptimization') ? undefined : SalesforceQuotaOptimizationConfigFromJSON(json['salesforceQuotaOptimization']), + 'providerOptions': !exists(json, 'providerOptions') ? undefined : SubscribeProviderOptionsFromJSON(json['providerOptions']), }; } @@ -143,7 +143,7 @@ export function SubscribeConfigObjectToJSON(value?: SubscribeConfigObject | null 'updateEvent': ConfigUpdateEventToJSON(value.updateEvent), 'deleteEvent': ConfigDeleteEventToJSON(value.deleteEvent), 'otherEvents': value.otherEvents, - 'salesforceQuotaOptimization': SalesforceQuotaOptimizationConfigToJSON(value.salesforceQuotaOptimization), + 'providerOptions': SubscribeProviderOptionsToJSON(value.providerOptions), }; } diff --git a/generated-sources/api/src/models/SubscribeProviderOptions.ts b/generated-sources/api/src/models/SubscribeProviderOptions.ts new file mode 100644 index 000000000..d9c39eead --- /dev/null +++ b/generated-sources/api/src/models/SubscribeProviderOptions.ts @@ -0,0 +1,72 @@ +/* tslint:disable */ +/* eslint-disable */ +/** + * Ampersand public API + * No description provided (generated by Openapi Generator https://github.com/openapitools/openapi-generator) + * + * The version of the OpenAPI document: 1.0.0 + * + * + * NOTE: This class is auto generated by OpenAPI Generator (https://openapi-generator.tech). + * https://openapi-generator.tech + * Do not edit the class manually. + */ + +import { exists, mapValues } from '../runtime'; +import type { QuotaOptimizationConfig } from './QuotaOptimizationConfig'; +import { + QuotaOptimizationConfigFromJSON, + QuotaOptimizationConfigFromJSONTyped, + QuotaOptimizationConfigToJSON, +} from './QuotaOptimizationConfig'; + +/** + * Subscribe options that only apply to certain providers. Each option documents which providers support it; setting one for a provider that does not support it is rejected. + * @export + * @interface SubscribeProviderOptions + */ +export interface SubscribeProviderOptions { + /** + * + * @type {QuotaOptimizationConfig} + * @memberof SubscribeProviderOptions + */ + quotaOptimization?: QuotaOptimizationConfig; +} + +/** + * Check if a given object implements the SubscribeProviderOptions interface. + */ +export function instanceOfSubscribeProviderOptions(value: object): boolean { + let isInstance = true; + + return isInstance; +} + +export function SubscribeProviderOptionsFromJSON(json: any): SubscribeProviderOptions { + return SubscribeProviderOptionsFromJSONTyped(json, false); +} + +export function SubscribeProviderOptionsFromJSONTyped(json: any, ignoreDiscriminator: boolean): SubscribeProviderOptions { + if ((json === undefined) || (json === null)) { + return json; + } + return { + + 'quotaOptimization': !exists(json, 'quotaOptimization') ? undefined : QuotaOptimizationConfigFromJSON(json['quotaOptimization']), + }; +} + +export function SubscribeProviderOptionsToJSON(value?: SubscribeProviderOptions | null): any { + if (value === undefined) { + return undefined; + } + if (value === null) { + return null; + } + return { + + 'quotaOptimization': QuotaOptimizationConfigToJSON(value.quotaOptimization), + }; +} + diff --git a/generated-sources/api/src/models/UpdateDestinationRequest.ts b/generated-sources/api/src/models/UpdateDestinationRequest.ts index 9a501d079..fd6516f9e 100644 --- a/generated-sources/api/src/models/UpdateDestinationRequest.ts +++ b/generated-sources/api/src/models/UpdateDestinationRequest.ts @@ -38,9 +38,43 @@ export interface UpdateDestinationRequest { * - metadata.bucket * - metadata.keyTemplate * - metadata.storageClass + * - metadata.username + * - metadata.tableName + * - metadata.database + * - metadata.accountIdentifier + * - metadata.userId + * - metadata.dbName + * - metadata.schemaName + * - metadata.projectId + * - metadata.datasetId + * - metadata.tableId + * - metadata.workgroupName + * - metadata.clusterIdentifier + * - metadata.dbUser + * - metadata.account + * - metadata.container + * - metadata.queueUrl + * - metadata.topicId + * - metadata.serverUrl + * - metadata.exchange + * - metadata.tls + * - metadata.name + * - metadata.brokers + * - metadata.topic + * - metadata.saslMechanism + * - metadata.batchSize + * - metadata.maxWaitSecs * - secrets.awsKeyId * - secrets.awsSecretKey * - secrets.awsSessionToken + * - secrets.password + * - secrets.privateKey + * - secrets.credentials + * - secrets.accessKeyId + * - secrets.secretAccessKey + * - secrets.accessKey + * - secrets.username + * - secrets.connectionString * @type {Array} * @memberof UpdateDestinationRequest */ diff --git a/generated-sources/api/src/models/UpdateDestinationRequestDestinationMetadata.ts b/generated-sources/api/src/models/UpdateDestinationRequestDestinationMetadata.ts index 69d7512a4..71a19c904 100644 --- a/generated-sources/api/src/models/UpdateDestinationRequestDestinationMetadata.ts +++ b/generated-sources/api/src/models/UpdateDestinationRequestDestinationMetadata.ts @@ -44,13 +44,13 @@ export interface UpdateDestinationRequestDestinationMetadata { */ streamName?: string; /** - * The endpoint URL for the Kinesis stream. + * The endpoint URL for the `kinesis` stream, or the optional custom endpoint URL for the `sqs` destination. * @type {string} * @memberof UpdateDestinationRequestDestinationMetadata */ endpointUrl?: string; /** - * The template for the partition key to use when sending events to Kinesis (a JMESPath template) + * The template for the partition key (a JMESPath template). Used by `kinesis`, and optionally by `kafka`. * @type {string} * @memberof UpdateDestinationRequestDestinationMetadata */ @@ -73,8 +73,176 @@ export interface UpdateDestinationRequestDestinationMetadata { * @memberof UpdateDestinationRequestDestinationMetadata */ storageClass?: string; + /** + * The username for the `clickhouse` destination. + * @type {string} + * @memberof UpdateDestinationRequestDestinationMetadata + */ + username?: string; + /** + * The destination table name (`clickhouse`, `snowflake`, `redshift`). + * @type {string} + * @memberof UpdateDestinationRequestDestinationMetadata + */ + tableName?: string; + /** + * The database name for the `clickhouse` destination. + * @type {string} + * @memberof UpdateDestinationRequestDestinationMetadata + */ + database?: string; + /** + * The Snowflake account identifier for the `snowflake` destination. + * @type {string} + * @memberof UpdateDestinationRequestDestinationMetadata + */ + accountIdentifier?: string; + /** + * The user ID for the `snowflake` destination. + * @type {string} + * @memberof UpdateDestinationRequestDestinationMetadata + */ + userId?: string; + /** + * The database name (`snowflake`, `redshift`). + * @type {string} + * @memberof UpdateDestinationRequestDestinationMetadata + */ + dbName?: string; + /** + * The schema name (`snowflake`, `redshift`). + * @type {string} + * @memberof UpdateDestinationRequestDestinationMetadata + */ + schemaName?: string; + /** + * The Google Cloud project ID (`bigquery`, `pubsub`). Required for `pubsub`. + * @type {string} + * @memberof UpdateDestinationRequestDestinationMetadata + */ + projectId?: string; + /** + * The BigQuery dataset ID for the `bigquery` destination. + * @type {string} + * @memberof UpdateDestinationRequestDestinationMetadata + */ + datasetId?: string; + /** + * The BigQuery table ID for the `bigquery` destination. + * @type {string} + * @memberof UpdateDestinationRequestDestinationMetadata + */ + tableId?: string; + /** + * The Redshift Serverless workgroup name for the `redshift` destination. + * @type {string} + * @memberof UpdateDestinationRequestDestinationMetadata + */ + workgroupName?: string; + /** + * The Redshift provisioned cluster identifier for the `redshift` destination. + * @type {string} + * @memberof UpdateDestinationRequestDestinationMetadata + */ + clusterIdentifier?: string; + /** + * The database user for the `redshift` destination. + * @type {string} + * @memberof UpdateDestinationRequestDestinationMetadata + */ + dbUser?: string; + /** + * The storage account name for the `azureblob` destination. + * @type {string} + * @memberof UpdateDestinationRequestDestinationMetadata + */ + account?: string; + /** + * The blob container name for the `azureblob` destination. + * @type {string} + * @memberof UpdateDestinationRequestDestinationMetadata + */ + container?: string; + /** + * The SQS queue URL for the `sqs` destination. Required for `sqs`. + * @type {string} + * @memberof UpdateDestinationRequestDestinationMetadata + */ + queueUrl?: string; + /** + * The Pub/Sub topic ID for the `pubsub` destination. Required for `pubsub`. + * @type {string} + * @memberof UpdateDestinationRequestDestinationMetadata + */ + topicId?: string; + /** + * The AMQP server URL for the `rabbitmq` destination. Required for `rabbitmq`. + * @type {string} + * @memberof UpdateDestinationRequestDestinationMetadata + */ + serverUrl?: string; + /** + * The exchange to publish to for the `rabbitmq` destination. Required for `rabbitmq`. + * @type {string} + * @memberof UpdateDestinationRequestDestinationMetadata + */ + exchange?: string; + /** + * Whether to connect over TLS. Optional for the `rabbitmq` and `kafka` destinations. + * @type {boolean} + * @memberof UpdateDestinationRequestDestinationMetadata + */ + tls?: boolean; + /** + * The queue or topic name for the `azureservicebus` destination. Required for `azureservicebus`. + * @type {string} + * @memberof UpdateDestinationRequestDestinationMetadata + */ + name?: string; + /** + * The comma-separated list of Kafka broker addresses for the `kafka` destination. Required for `kafka`. + * @type {string} + * @memberof UpdateDestinationRequestDestinationMetadata + */ + brokers?: string; + /** + * The Kafka topic to publish to for the `kafka` destination. Required for `kafka`. + * @type {string} + * @memberof UpdateDestinationRequestDestinationMetadata + */ + topic?: string; + /** + * The SASL mechanism used to authenticate to Kafka for the `kafka` destination. Required for `kafka`. + * @type {string} + * @memberof UpdateDestinationRequestDestinationMetadata + */ + saslMechanism?: UpdateDestinationRequestDestinationMetadataSaslMechanismEnum; + /** + * For warehouse destinations, rows to buffer before flushing a batch (default 1000). + * @type {number} + * @memberof UpdateDestinationRequestDestinationMetadata + */ + batchSize?: number; + /** + * For warehouse destinations, max seconds before flushing a batch (default 30). + * @type {number} + * @memberof UpdateDestinationRequestDestinationMetadata + */ + maxWaitSecs?: number; } + +/** + * @export + */ +export const UpdateDestinationRequestDestinationMetadataSaslMechanismEnum = { + Plain: 'plain', + ScramSha256: 'scram-sha-256', + ScramSha512: 'scram-sha-512' +} as const; +export type UpdateDestinationRequestDestinationMetadataSaslMechanismEnum = typeof UpdateDestinationRequestDestinationMetadataSaslMechanismEnum[keyof typeof UpdateDestinationRequestDestinationMetadataSaslMechanismEnum]; + + /** * Check if a given object implements the UpdateDestinationRequestDestinationMetadata interface. */ @@ -103,6 +271,32 @@ export function UpdateDestinationRequestDestinationMetadataFromJSONTyped(json: a 'bucket': !exists(json, 'bucket') ? undefined : json['bucket'], 'keyTemplate': !exists(json, 'keyTemplate') ? undefined : json['keyTemplate'], 'storageClass': !exists(json, 'storageClass') ? undefined : json['storageClass'], + 'username': !exists(json, 'username') ? undefined : json['username'], + 'tableName': !exists(json, 'tableName') ? undefined : json['tableName'], + 'database': !exists(json, 'database') ? undefined : json['database'], + 'accountIdentifier': !exists(json, 'accountIdentifier') ? undefined : json['accountIdentifier'], + 'userId': !exists(json, 'userId') ? undefined : json['userId'], + 'dbName': !exists(json, 'dbName') ? undefined : json['dbName'], + 'schemaName': !exists(json, 'schemaName') ? undefined : json['schemaName'], + 'projectId': !exists(json, 'projectId') ? undefined : json['projectId'], + 'datasetId': !exists(json, 'datasetId') ? undefined : json['datasetId'], + 'tableId': !exists(json, 'tableId') ? undefined : json['tableId'], + 'workgroupName': !exists(json, 'workgroupName') ? undefined : json['workgroupName'], + 'clusterIdentifier': !exists(json, 'clusterIdentifier') ? undefined : json['clusterIdentifier'], + 'dbUser': !exists(json, 'dbUser') ? undefined : json['dbUser'], + 'account': !exists(json, 'account') ? undefined : json['account'], + 'container': !exists(json, 'container') ? undefined : json['container'], + 'queueUrl': !exists(json, 'queueUrl') ? undefined : json['queueUrl'], + 'topicId': !exists(json, 'topicId') ? undefined : json['topicId'], + 'serverUrl': !exists(json, 'serverUrl') ? undefined : json['serverUrl'], + 'exchange': !exists(json, 'exchange') ? undefined : json['exchange'], + 'tls': !exists(json, 'tls') ? undefined : json['tls'], + 'name': !exists(json, 'name') ? undefined : json['name'], + 'brokers': !exists(json, 'brokers') ? undefined : json['brokers'], + 'topic': !exists(json, 'topic') ? undefined : json['topic'], + 'saslMechanism': !exists(json, 'saslMechanism') ? undefined : json['saslMechanism'], + 'batchSize': !exists(json, 'batchSize') ? undefined : json['batchSize'], + 'maxWaitSecs': !exists(json, 'maxWaitSecs') ? undefined : json['maxWaitSecs'], }; } @@ -124,6 +318,32 @@ export function UpdateDestinationRequestDestinationMetadataToJSON(value?: Update 'bucket': value.bucket, 'keyTemplate': value.keyTemplate, 'storageClass': value.storageClass, + 'username': value.username, + 'tableName': value.tableName, + 'database': value.database, + 'accountIdentifier': value.accountIdentifier, + 'userId': value.userId, + 'dbName': value.dbName, + 'schemaName': value.schemaName, + 'projectId': value.projectId, + 'datasetId': value.datasetId, + 'tableId': value.tableId, + 'workgroupName': value.workgroupName, + 'clusterIdentifier': value.clusterIdentifier, + 'dbUser': value.dbUser, + 'account': value.account, + 'container': value.container, + 'queueUrl': value.queueUrl, + 'topicId': value.topicId, + 'serverUrl': value.serverUrl, + 'exchange': value.exchange, + 'tls': value.tls, + 'name': value.name, + 'brokers': value.brokers, + 'topic': value.topic, + 'saslMechanism': value.saslMechanism, + 'batchSize': value.batchSize, + 'maxWaitSecs': value.maxWaitSecs, }; } diff --git a/generated-sources/api/src/models/UpdateDestinationRequestDestinationSecrets.ts b/generated-sources/api/src/models/UpdateDestinationRequestDestinationSecrets.ts index 5e1de2b57..4b1a7ae50 100644 --- a/generated-sources/api/src/models/UpdateDestinationRequestDestinationSecrets.ts +++ b/generated-sources/api/src/models/UpdateDestinationRequestDestinationSecrets.ts @@ -20,23 +20,71 @@ import { exists, mapValues } from '../runtime'; */ export interface UpdateDestinationRequestDestinationSecrets { /** - * The AWS access key ID for the Kinesis or S3 destination. + * The AWS access key ID for the `kinesis`, `s3`, and `sqs` destinations. Required for `sqs`. * @type {string} * @memberof UpdateDestinationRequestDestinationSecrets */ awsKeyId?: string; /** - * The AWS secret access key for the Kinesis or S3 destination. + * The AWS secret access key for the `kinesis`, `s3`, and `sqs` destinations. Required for `sqs`. * @type {string} * @memberof UpdateDestinationRequestDestinationSecrets */ awsSecretKey?: string; /** - * The AWS session token for the Kinesis or S3 destination. + * The optional AWS session token for the `kinesis`, `s3`, and `sqs` destinations. * @type {string} * @memberof UpdateDestinationRequestDestinationSecrets */ awsSessionToken?: string; + /** + * The password for the `clickhouse`, `rabbitmq`, and `kafka` destinations. Required for `rabbitmq` and `kafka`. + * @type {string} + * @memberof UpdateDestinationRequestDestinationSecrets + */ + password?: string; + /** + * The PEM-encoded RSA private key for the `snowflake` destination. + * @type {string} + * @memberof UpdateDestinationRequestDestinationSecrets + */ + privateKey?: string; + /** + * The service-account credentials JSON for the `bigquery`, `gcs`, and `pubsub` destinations. Required for `pubsub`. + * @type {string} + * @memberof UpdateDestinationRequestDestinationSecrets + */ + credentials?: string; + /** + * The AWS access key ID for the `redshift` destination. + * @type {string} + * @memberof UpdateDestinationRequestDestinationSecrets + */ + accessKeyId?: string; + /** + * The AWS secret access key for the `redshift` destination. + * @type {string} + * @memberof UpdateDestinationRequestDestinationSecrets + */ + secretAccessKey?: string; + /** + * The account access key for the `azureblob` destination. + * @type {string} + * @memberof UpdateDestinationRequestDestinationSecrets + */ + accessKey?: string; + /** + * The username for the `rabbitmq` and `kafka` destinations. Required for both. + * @type {string} + * @memberof UpdateDestinationRequestDestinationSecrets + */ + username?: string; + /** + * The connection string for the `azureservicebus` destination. Required for `azureservicebus`. + * @type {string} + * @memberof UpdateDestinationRequestDestinationSecrets + */ + connectionString?: string; } /** @@ -61,6 +109,14 @@ export function UpdateDestinationRequestDestinationSecretsFromJSONTyped(json: an 'awsKeyId': !exists(json, 'awsKeyId') ? undefined : json['awsKeyId'], 'awsSecretKey': !exists(json, 'awsSecretKey') ? undefined : json['awsSecretKey'], 'awsSessionToken': !exists(json, 'awsSessionToken') ? undefined : json['awsSessionToken'], + 'password': !exists(json, 'password') ? undefined : json['password'], + 'privateKey': !exists(json, 'privateKey') ? undefined : json['privateKey'], + 'credentials': !exists(json, 'credentials') ? undefined : json['credentials'], + 'accessKeyId': !exists(json, 'accessKeyId') ? undefined : json['accessKeyId'], + 'secretAccessKey': !exists(json, 'secretAccessKey') ? undefined : json['secretAccessKey'], + 'accessKey': !exists(json, 'accessKey') ? undefined : json['accessKey'], + 'username': !exists(json, 'username') ? undefined : json['username'], + 'connectionString': !exists(json, 'connectionString') ? undefined : json['connectionString'], }; } @@ -76,6 +132,14 @@ export function UpdateDestinationRequestDestinationSecretsToJSON(value?: UpdateD 'awsKeyId': value.awsKeyId, 'awsSecretKey': value.awsSecretKey, 'awsSessionToken': value.awsSessionToken, + 'password': value.password, + 'privateKey': value.privateKey, + 'credentials': value.credentials, + 'accessKeyId': value.accessKeyId, + 'secretAccessKey': value.secretAccessKey, + 'accessKey': value.accessKey, + 'username': value.username, + 'connectionString': value.connectionString, }; } diff --git a/generated-sources/api/src/models/index.ts b/generated-sources/api/src/models/index.ts index 8c61c1619..c59f168a2 100644 --- a/generated-sources/api/src/models/index.ts +++ b/generated-sources/api/src/models/index.ts @@ -176,13 +176,13 @@ export * from './ProviderAppMetadata1'; export * from './ProviderInfo'; export * from './ProviderMetadata1'; export * from './ProviderMetadataInfo'; +export * from './QuotaOptimizationConfig'; export * from './ReadConfig'; export * from './ReadConfigAllOf'; export * from './ReadConfigObject'; export * from './ReadFilter'; export * from './RedirectResponse'; export * from './Revision'; -export * from './SalesforceQuotaOptimizationConfig'; export * from './SearchOperators'; export * from './SearchSupport'; export * from './SelectedFieldsAutoConfig'; @@ -191,6 +191,7 @@ export * from './StringFieldOptions'; export * from './SubscribeConfig'; export * from './SubscribeConfigAllOf'; export * from './SubscribeConfigObject'; +export * from './SubscribeProviderOptions'; export * from './SubscribeRequirements'; export * from './SubscribeSupport'; export * from './Support';