Skip to content
Open
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
3 changes: 2 additions & 1 deletion generated-sources/api/.openapi-generator/FILES
Original file line number Diff line number Diff line change
Expand Up @@ -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
Expand All @@ -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
Expand Down
18 changes: 9 additions & 9 deletions generated-sources/api/src/models/BaseSubscribeConfigObject.ts
Original file line number Diff line number Diff line change
Expand Up @@ -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';

/**
*
Expand Down Expand Up @@ -88,10 +88,10 @@ export interface BaseSubscribeConfigObject {
otherEvents?: Array<string>;
/**
*
* @type {SalesforceQuotaOptimizationConfig}
* @type {SubscribeProviderOptions}
* @memberof BaseSubscribeConfigObject
*/
salesforceQuotaOptimization?: SalesforceQuotaOptimizationConfig;
providerOptions?: SubscribeProviderOptions;
}

/**
Expand Down Expand Up @@ -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']),
};
}

Expand All @@ -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),
};
}

14 changes: 12 additions & 2 deletions generated-sources/api/src/models/CreateDestinationRequest.ts
Original file line number Diff line number Diff line change
Expand Up @@ -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`, `sns`, `eventbridge`, `pubsub`, `rabbitmq`) are configured via the `metadata` and `secrets` fields documented below.
* @type {string}
* @memberof CreateDestinationRequest
*/
Expand All @@ -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',
Sns: 'sns',
Eventbridge: 'eventbridge',
Pubsub: 'pubsub',
Rabbitmq: 'rabbitmq'
} as const;
export type CreateDestinationRequestTypeEnum = typeof CreateDestinationRequestTypeEnum[keyof typeof CreateDestinationRequestTypeEnum];

Expand Down
186 changes: 185 additions & 1 deletion generated-sources/api/src/models/CreateDestinationRequestMetadata.ts
Original file line number Diff line number Diff line change
Expand Up @@ -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
*/
Expand Down Expand Up @@ -73,6 +73,144 @@ 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`).
* @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.
* @type {string}
* @memberof CreateDestinationRequestMetadata
*/
queueUrl?: string;
/**
* The SNS topic ARN for the `sns` destination.
* @type {string}
* @memberof CreateDestinationRequestMetadata
*/
topicArn?: string;
/**
* The EventBridge event bus name for the `eventbridge` destination.
* @type {string}
* @memberof CreateDestinationRequestMetadata
*/
eventBusName?: string;
/**
* The EventBridge detail-type for published events (`eventbridge`).
* @type {string}
* @memberof CreateDestinationRequestMetadata
*/
detailType?: string;
/**
* The Pub/Sub topic ID for the `pubsub` destination.
* @type {string}
* @memberof CreateDestinationRequestMetadata
*/
topicId?: string;
/**
* The routing key for the `rabbitmq` destination.
* @type {string}
* @memberof CreateDestinationRequestMetadata
*/
routingKey?: string;
/**
* 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;
}

/**
Expand Down Expand Up @@ -103,6 +241,29 @@ 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'],
'topicArn': !exists(json, 'topicArn') ? undefined : json['topicArn'],
'eventBusName': !exists(json, 'eventBusName') ? undefined : json['eventBusName'],
'detailType': !exists(json, 'detailType') ? undefined : json['detailType'],
'topicId': !exists(json, 'topicId') ? undefined : json['topicId'],
'routingKey': !exists(json, 'routingKey') ? undefined : json['routingKey'],
'batchSize': !exists(json, 'batchSize') ? undefined : json['batchSize'],
'maxWaitSecs': !exists(json, 'maxWaitSecs') ? undefined : json['maxWaitSecs'],
};
}

Expand All @@ -124,6 +285,29 @@ 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,
'topicArn': value.topicArn,
'eventBusName': value.eventBusName,
'detailType': value.detailType,
'topicId': value.topicId,
'routingKey': value.routingKey,
'batchSize': value.batchSize,
'maxWaitSecs': value.maxWaitSecs,
};
}

Original file line number Diff line number Diff line change
Expand Up @@ -37,6 +37,48 @@ export interface CreateDestinationRequestSecrets {
* @memberof CreateDestinationRequestSecrets
*/
awsSessionToken?: string;
/**
* The password for the `clickhouse` destination.
* @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.
* @type {string}
* @memberof CreateDestinationRequestSecrets
*/
credentials?: string;
/**
* The AWS access key ID for the `redshift`, `sqs`, `sns`, and `eventbridge` destinations.
* @type {string}
* @memberof CreateDestinationRequestSecrets
*/
accessKeyId?: string;
/**
* The AWS secret access key for the `redshift`, `sqs`, `sns`, and `eventbridge` destinations.
* @type {string}
* @memberof CreateDestinationRequestSecrets
*/
secretAccessKey?: string;
/**
* The account access key for the `azureblob` destination.
* @type {string}
* @memberof CreateDestinationRequestSecrets
*/
accessKey?: string;
/**
* The connection URI (embeds credentials) for the `rabbitmq` destination.
* @type {string}
* @memberof CreateDestinationRequestSecrets
*/
uri?: string;
}

/**
Expand All @@ -61,6 +103,13 @@ 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'],
'uri': !exists(json, 'uri') ? undefined : json['uri'],
};
}

Expand All @@ -76,6 +125,13 @@ 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,
'uri': value.uri,
};
}

Loading
Loading