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`, `pubsub`, `rabbitmq`, `azureservicebus`, `kafka`) 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',
Pubsub: 'pubsub',
Rabbitmq: 'rabbitmq',
Azureservicebus: 'azureservicebus',
Kafka: 'kafka'
} as const;
export type CreateDestinationRequestTypeEnum = typeof CreateDestinationRequestTypeEnum[keyof typeof CreateDestinationRequestTypeEnum];

Expand Down
226 changes: 223 additions & 3 deletions 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 All @@ -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
*/
Expand All @@ -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.
*/
Expand Down Expand Up @@ -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'],
};
}

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

Loading
Loading