Huge News!Announcing our $40M Series B led by Abstract Ventures.Learn More
Socket
Sign inDemoInstall
Socket

@rhoas/kafka-instance-sdk

Package Overview
Dependencies
Maintainers
5
Versions
88
Alerts
File Explorer

Advanced tools

Socket logo

Install Socket

Detect and block malicious and high-risk dependencies

Install

@rhoas/kafka-instance-sdk - npm Package Compare versions

Comparing version 0.31.0 to 0.31.1

2

dist/generated/api.d.ts

@@ -5,3 +5,3 @@ /**

*
* The version of the OpenAPI document: 0.8.1-SNAPSHOT
* The version of the OpenAPI document: 0.10.0
*

@@ -8,0 +8,0 @@ *

@@ -8,3 +8,3 @@ "use strict";

*
* The version of the OpenAPI document: 0.8.1-SNAPSHOT
* The version of the OpenAPI document: 0.10.0
*

@@ -11,0 +11,0 @@ *

@@ -5,3 +5,3 @@ /**

*
* The version of the OpenAPI document: 0.8.1-SNAPSHOT
* The version of the OpenAPI document: 0.10.0
*

@@ -8,0 +8,0 @@ *

@@ -8,3 +8,3 @@ "use strict";

*
* The version of the OpenAPI document: 0.8.1-SNAPSHOT
* The version of the OpenAPI document: 0.10.0
*

@@ -11,0 +11,0 @@ *

@@ -5,3 +5,3 @@ /**

*
* The version of the OpenAPI document: 0.8.1-SNAPSHOT
* The version of the OpenAPI document: 0.10.0
*

@@ -8,0 +8,0 @@ *

@@ -8,3 +8,3 @@ "use strict";

*
* The version of the OpenAPI document: 0.8.1-SNAPSHOT
* The version of the OpenAPI document: 0.10.0
*

@@ -11,0 +11,0 @@ *

@@ -5,3 +5,3 @@ /**

*
* The version of the OpenAPI document: 0.8.1-SNAPSHOT
* The version of the OpenAPI document: 0.10.0
*

@@ -30,2 +30,3 @@ *

* @param {number} [limit] Limit the number of records fetched and returned
* @param {number} [maxValueLength] Maximum length of string values returned in the response. Values with a length that exceeds this parameter will be truncated. When this parameter is not included in the request, the full string values will be returned.
* @param {number} [offset] Retrieve messages with an offset equal to or greater than this offset. If both `timestamp` and `offset` are requested, `timestamp` is given preference.

@@ -37,3 +38,3 @@ * @param {number} [partition] Retrieve messages only from this partition

*/
consumeRecords: (topicName: string, include?: Array<RecordIncludedProperty>, limit?: number, offset?: number, partition?: number, timestamp?: any, options?: AxiosRequestConfig) => Promise<RequestArgs>;
consumeRecords: (topicName: string, include?: Array<RecordIncludedProperty>, limit?: number, maxValueLength?: number, offset?: number, partition?: number, timestamp?: any, options?: AxiosRequestConfig) => Promise<RequestArgs>;
/**

@@ -60,2 +61,3 @@ * Produce (write) a single record to a topic.

* @param {number} [limit] Limit the number of records fetched and returned
* @param {number} [maxValueLength] Maximum length of string values returned in the response. Values with a length that exceeds this parameter will be truncated. When this parameter is not included in the request, the full string values will be returned.
* @param {number} [offset] Retrieve messages with an offset equal to or greater than this offset. If both &#x60;timestamp&#x60; and &#x60;offset&#x60; are requested, &#x60;timestamp&#x60; is given preference.

@@ -67,3 +69,3 @@ * @param {number} [partition] Retrieve messages only from this partition

*/
consumeRecords(topicName: string, include?: Array<RecordIncludedProperty>, limit?: number, offset?: number, partition?: number, timestamp?: any, options?: AxiosRequestConfig): Promise<(axios?: AxiosInstance, basePath?: string) => AxiosPromise<RecordList>>;
consumeRecords(topicName: string, include?: Array<RecordIncludedProperty>, limit?: number, maxValueLength?: number, offset?: number, partition?: number, timestamp?: any, options?: AxiosRequestConfig): Promise<(axios?: AxiosInstance, basePath?: string) => AxiosPromise<RecordList>>;
/**

@@ -90,2 +92,3 @@ * Produce (write) a single record to a topic.

* @param {number} [limit] Limit the number of records fetched and returned
* @param {number} [maxValueLength] Maximum length of string values returned in the response. Values with a length that exceeds this parameter will be truncated. When this parameter is not included in the request, the full string values will be returned.
* @param {number} [offset] Retrieve messages with an offset equal to or greater than this offset. If both &#x60;timestamp&#x60; and &#x60;offset&#x60; are requested, &#x60;timestamp&#x60; is given preference.

@@ -97,3 +100,3 @@ * @param {number} [partition] Retrieve messages only from this partition

*/
consumeRecords(topicName: string, include?: Array<RecordIncludedProperty>, limit?: number, offset?: number, partition?: number, timestamp?: any, options?: any): AxiosPromise<RecordList>;
consumeRecords(topicName: string, include?: Array<RecordIncludedProperty>, limit?: number, maxValueLength?: number, offset?: number, partition?: number, timestamp?: any, options?: any): AxiosPromise<RecordList>;
/**

@@ -121,2 +124,3 @@ * Produce (write) a single record to a topic.

* @param {number} [limit] Limit the number of records fetched and returned
* @param {number} [maxValueLength] Maximum length of string values returned in the response. Values with a length that exceeds this parameter will be truncated. When this parameter is not included in the request, the full string values will be returned.
* @param {number} [offset] Retrieve messages with an offset equal to or greater than this offset. If both &#x60;timestamp&#x60; and &#x60;offset&#x60; are requested, &#x60;timestamp&#x60; is given preference.

@@ -129,3 +133,3 @@ * @param {number} [partition] Retrieve messages only from this partition

*/
consumeRecords(topicName: string, include?: Array<RecordIncludedProperty>, limit?: number, offset?: number, partition?: number, timestamp?: any, options?: AxiosRequestConfig): AxiosPromise<RecordList>;
consumeRecords(topicName: string, include?: Array<RecordIncludedProperty>, limit?: number, maxValueLength?: number, offset?: number, partition?: number, timestamp?: any, options?: AxiosRequestConfig): AxiosPromise<RecordList>;
/**

@@ -155,2 +159,3 @@ * Produce (write) a single record to a topic.

* @param {number} [limit] Limit the number of records fetched and returned
* @param {number} [maxValueLength] Maximum length of string values returned in the response. Values with a length that exceeds this parameter will be truncated. When this parameter is not included in the request, the full string values will be returned.
* @param {number} [offset] Retrieve messages with an offset equal to or greater than this offset. If both &#x60;timestamp&#x60; and &#x60;offset&#x60; are requested, &#x60;timestamp&#x60; is given preference.

@@ -163,3 +168,3 @@ * @param {number} [partition] Retrieve messages only from this partition

*/
consumeRecords(topicName: string, include?: Array<RecordIncludedProperty>, limit?: number, offset?: number, partition?: number, timestamp?: any, options?: AxiosRequestConfig): Promise<import("axios").AxiosResponse<RecordList, any>>;
consumeRecords(topicName: string, include?: Array<RecordIncludedProperty>, limit?: number, maxValueLength?: number, offset?: number, partition?: number, timestamp?: any, options?: AxiosRequestConfig): Promise<import("axios").AxiosResponse<RecordList, any>>;
/**

@@ -166,0 +171,0 @@ * Produce (write) a single record to a topic.

@@ -8,3 +8,3 @@ "use strict";

*
* The version of the OpenAPI document: 0.8.1-SNAPSHOT
* The version of the OpenAPI document: 0.10.0
*

@@ -45,2 +45,3 @@ *

* @param {number} [limit] Limit the number of records fetched and returned
* @param {number} [maxValueLength] Maximum length of string values returned in the response. Values with a length that exceeds this parameter will be truncated. When this parameter is not included in the request, the full string values will be returned.
* @param {number} [offset] Retrieve messages with an offset equal to or greater than this offset. If both &#x60;timestamp&#x60; and &#x60;offset&#x60; are requested, &#x60;timestamp&#x60; is given preference.

@@ -52,3 +53,3 @@ * @param {number} [partition] Retrieve messages only from this partition

*/
consumeRecords: (topicName, include, limit, offset, partition, timestamp, options = {}) => __awaiter(this, void 0, void 0, function* () {
consumeRecords: (topicName, include, limit, maxValueLength, offset, partition, timestamp, options = {}) => __awaiter(this, void 0, void 0, function* () {
// verify required parameter 'topicName' is not null or undefined

@@ -76,2 +77,5 @@ (0, common_1.assertParamExists)('consumeRecords', 'topicName', topicName);

}
if (maxValueLength !== undefined) {
localVarQueryParameter['maxValueLength'] = maxValueLength;
}
if (offset !== undefined) {

@@ -147,2 +151,3 @@ localVarQueryParameter['offset'] = offset;

* @param {number} [limit] Limit the number of records fetched and returned
* @param {number} [maxValueLength] Maximum length of string values returned in the response. Values with a length that exceeds this parameter will be truncated. When this parameter is not included in the request, the full string values will be returned.
* @param {number} [offset] Retrieve messages with an offset equal to or greater than this offset. If both &#x60;timestamp&#x60; and &#x60;offset&#x60; are requested, &#x60;timestamp&#x60; is given preference.

@@ -154,5 +159,5 @@ * @param {number} [partition] Retrieve messages only from this partition

*/
consumeRecords(topicName, include, limit, offset, partition, timestamp, options) {
consumeRecords(topicName, include, limit, maxValueLength, offset, partition, timestamp, options) {
return __awaiter(this, void 0, void 0, function* () {
const localVarAxiosArgs = yield localVarAxiosParamCreator.consumeRecords(topicName, include, limit, offset, partition, timestamp, options);
const localVarAxiosArgs = yield localVarAxiosParamCreator.consumeRecords(topicName, include, limit, maxValueLength, offset, partition, timestamp, options);
return (0, common_1.createRequestFunction)(localVarAxiosArgs, axios_1.default, base_1.BASE_PATH, configuration);

@@ -191,2 +196,3 @@ });

* @param {number} [limit] Limit the number of records fetched and returned
* @param {number} [maxValueLength] Maximum length of string values returned in the response. Values with a length that exceeds this parameter will be truncated. When this parameter is not included in the request, the full string values will be returned.
* @param {number} [offset] Retrieve messages with an offset equal to or greater than this offset. If both &#x60;timestamp&#x60; and &#x60;offset&#x60; are requested, &#x60;timestamp&#x60; is given preference.

@@ -198,4 +204,4 @@ * @param {number} [partition] Retrieve messages only from this partition

*/
consumeRecords(topicName, include, limit, offset, partition, timestamp, options) {
return localVarFp.consumeRecords(topicName, include, limit, offset, partition, timestamp, options).then((request) => request(axios, basePath));
consumeRecords(topicName, include, limit, maxValueLength, offset, partition, timestamp, options) {
return localVarFp.consumeRecords(topicName, include, limit, maxValueLength, offset, partition, timestamp, options).then((request) => request(axios, basePath));
},

@@ -229,2 +235,3 @@ /**

* @param {number} [limit] Limit the number of records fetched and returned
* @param {number} [maxValueLength] Maximum length of string values returned in the response. Values with a length that exceeds this parameter will be truncated. When this parameter is not included in the request, the full string values will be returned.
* @param {number} [offset] Retrieve messages with an offset equal to or greater than this offset. If both &#x60;timestamp&#x60; and &#x60;offset&#x60; are requested, &#x60;timestamp&#x60; is given preference.

@@ -237,4 +244,4 @@ * @param {number} [partition] Retrieve messages only from this partition

*/
consumeRecords(topicName, include, limit, offset, partition, timestamp, options) {
return (0, exports.RecordsApiFp)(this.configuration).consumeRecords(topicName, include, limit, offset, partition, timestamp, options).then((request) => request(this.axios, this.basePath));
consumeRecords(topicName, include, limit, maxValueLength, offset, partition, timestamp, options) {
return (0, exports.RecordsApiFp)(this.configuration).consumeRecords(topicName, include, limit, maxValueLength, offset, partition, timestamp, options).then((request) => request(this.axios, this.basePath));
}

@@ -241,0 +248,0 @@ /**

@@ -5,3 +5,3 @@ /**

*
* The version of the OpenAPI document: 0.8.1-SNAPSHOT
* The version of the OpenAPI document: 0.10.0
*

@@ -8,0 +8,0 @@ *

@@ -8,3 +8,3 @@ "use strict";

*
* The version of the OpenAPI document: 0.8.1-SNAPSHOT
* The version of the OpenAPI document: 0.10.0
*

@@ -11,0 +11,0 @@ *

@@ -5,3 +5,3 @@ /**

*
* The version of the OpenAPI document: 0.8.1-SNAPSHOT
* The version of the OpenAPI document: 0.10.0
*

@@ -8,0 +8,0 @@ *

@@ -8,3 +8,3 @@ "use strict";

*
* The version of the OpenAPI document: 0.8.1-SNAPSHOT
* The version of the OpenAPI document: 0.10.0
*

@@ -11,0 +11,0 @@ *

@@ -5,3 +5,3 @@ /**

*
* The version of the OpenAPI document: 0.8.1-SNAPSHOT
* The version of the OpenAPI document: 0.10.0
*

@@ -8,0 +8,0 @@ *

@@ -8,3 +8,3 @@ "use strict";

*
* The version of the OpenAPI document: 0.8.1-SNAPSHOT
* The version of the OpenAPI document: 0.10.0
*

@@ -11,0 +11,0 @@ *

@@ -5,3 +5,3 @@ /**

*
* The version of the OpenAPI document: 0.8.1-SNAPSHOT
* The version of the OpenAPI document: 0.10.0
*

@@ -8,0 +8,0 @@ *

@@ -8,3 +8,3 @@ "use strict";

*
* The version of the OpenAPI document: 0.8.1-SNAPSHOT
* The version of the OpenAPI document: 0.10.0
*

@@ -11,0 +11,0 @@ *

@@ -5,3 +5,3 @@ /**

*
* The version of the OpenAPI document: 0.8.1-SNAPSHOT
* The version of the OpenAPI document: 0.10.0
*

@@ -8,0 +8,0 @@ *

@@ -8,3 +8,3 @@ "use strict";

*
* The version of the OpenAPI document: 0.8.1-SNAPSHOT
* The version of the OpenAPI document: 0.10.0
*

@@ -11,0 +11,0 @@ *

@@ -5,3 +5,3 @@ /**

*
* The version of the OpenAPI document: 0.8.1-SNAPSHOT
* The version of the OpenAPI document: 0.10.0
*

@@ -8,0 +8,0 @@ *

@@ -8,3 +8,3 @@ "use strict";

*
* The version of the OpenAPI document: 0.8.1-SNAPSHOT
* The version of the OpenAPI document: 0.10.0
*

@@ -11,0 +11,0 @@ *

@@ -5,3 +5,3 @@ /**

*
* The version of the OpenAPI document: 0.8.1-SNAPSHOT
* The version of the OpenAPI document: 0.10.0
*

@@ -8,0 +8,0 @@ *

@@ -8,3 +8,3 @@ "use strict";

*
* The version of the OpenAPI document: 0.8.1-SNAPSHOT
* The version of the OpenAPI document: 0.10.0
*

@@ -11,0 +11,0 @@ *

@@ -5,3 +5,3 @@ /**

*
* The version of the OpenAPI document: 0.8.1-SNAPSHOT
* The version of the OpenAPI document: 0.10.0
*

@@ -8,0 +8,0 @@ *

@@ -8,3 +8,3 @@ "use strict";

*
* The version of the OpenAPI document: 0.8.1-SNAPSHOT
* The version of the OpenAPI document: 0.10.0
*

@@ -11,0 +11,0 @@ *

@@ -5,3 +5,3 @@ /**

*
* The version of the OpenAPI document: 0.8.1-SNAPSHOT
* The version of the OpenAPI document: 0.10.0
*

@@ -8,0 +8,0 @@ *

@@ -8,3 +8,3 @@ "use strict";

*
* The version of the OpenAPI document: 0.8.1-SNAPSHOT
* The version of the OpenAPI document: 0.10.0
*

@@ -11,0 +11,0 @@ *

@@ -5,3 +5,3 @@ /**

*
* The version of the OpenAPI document: 0.8.1-SNAPSHOT
* The version of the OpenAPI document: 0.10.0
*

@@ -8,0 +8,0 @@ *

@@ -8,3 +8,3 @@ "use strict";

*
* The version of the OpenAPI document: 0.8.1-SNAPSHOT
* The version of the OpenAPI document: 0.10.0
*

@@ -11,0 +11,0 @@ *

@@ -5,3 +5,3 @@ /**

*
* The version of the OpenAPI document: 0.8.1-SNAPSHOT
* The version of the OpenAPI document: 0.10.0
*

@@ -8,0 +8,0 @@ *

@@ -8,3 +8,3 @@ "use strict";

*
* The version of the OpenAPI document: 0.8.1-SNAPSHOT
* The version of the OpenAPI document: 0.10.0
*

@@ -11,0 +11,0 @@ *

@@ -5,3 +5,3 @@ /**

*
* The version of the OpenAPI document: 0.8.1-SNAPSHOT
* The version of the OpenAPI document: 0.10.0
*

@@ -8,0 +8,0 @@ *

@@ -8,3 +8,3 @@ "use strict";

*
* The version of the OpenAPI document: 0.8.1-SNAPSHOT
* The version of the OpenAPI document: 0.10.0
*

@@ -11,0 +11,0 @@ *

@@ -5,3 +5,3 @@ /**

*
* The version of the OpenAPI document: 0.8.1-SNAPSHOT
* The version of the OpenAPI document: 0.10.0
*

@@ -8,0 +8,0 @@ *

@@ -8,3 +8,3 @@ "use strict";

*
* The version of the OpenAPI document: 0.8.1-SNAPSHOT
* The version of the OpenAPI document: 0.10.0
*

@@ -11,0 +11,0 @@ *

@@ -5,3 +5,3 @@ /**

*
* The version of the OpenAPI document: 0.8.1-SNAPSHOT
* The version of the OpenAPI document: 0.10.0
*

@@ -8,0 +8,0 @@ *

@@ -8,3 +8,3 @@ "use strict";

*
* The version of the OpenAPI document: 0.8.1-SNAPSHOT
* The version of the OpenAPI document: 0.10.0
*

@@ -11,0 +11,0 @@ *

@@ -5,3 +5,3 @@ /**

*
* The version of the OpenAPI document: 0.8.1-SNAPSHOT
* The version of the OpenAPI document: 0.10.0
*

@@ -8,0 +8,0 @@ *

@@ -8,3 +8,3 @@ "use strict";

*
* The version of the OpenAPI document: 0.8.1-SNAPSHOT
* The version of the OpenAPI document: 0.10.0
*

@@ -11,0 +11,0 @@ *

@@ -5,3 +5,3 @@ /**

*
* The version of the OpenAPI document: 0.8.1-SNAPSHOT
* The version of the OpenAPI document: 0.10.0
*

@@ -8,0 +8,0 @@ *

@@ -8,3 +8,3 @@ "use strict";

*
* The version of the OpenAPI document: 0.8.1-SNAPSHOT
* The version of the OpenAPI document: 0.10.0
*

@@ -11,0 +11,0 @@ *

@@ -5,3 +5,3 @@ /**

*
* The version of the OpenAPI document: 0.8.1-SNAPSHOT
* The version of the OpenAPI document: 0.10.0
*

@@ -8,0 +8,0 @@ *

@@ -8,3 +8,3 @@ "use strict";

*
* The version of the OpenAPI document: 0.8.1-SNAPSHOT
* The version of the OpenAPI document: 0.10.0
*

@@ -11,0 +11,0 @@ *

@@ -5,3 +5,3 @@ /**

*
* The version of the OpenAPI document: 0.8.1-SNAPSHOT
* The version of the OpenAPI document: 0.10.0
*

@@ -8,0 +8,0 @@ *

@@ -8,3 +8,3 @@ "use strict";

*
* The version of the OpenAPI document: 0.8.1-SNAPSHOT
* The version of the OpenAPI document: 0.10.0
*

@@ -11,0 +11,0 @@ *

@@ -5,3 +5,3 @@ /**

*
* The version of the OpenAPI document: 0.8.1-SNAPSHOT
* The version of the OpenAPI document: 0.10.0
*

@@ -8,0 +8,0 @@ *

@@ -8,3 +8,3 @@ "use strict";

*
* The version of the OpenAPI document: 0.8.1-SNAPSHOT
* The version of the OpenAPI document: 0.10.0
*

@@ -11,0 +11,0 @@ *

@@ -5,3 +5,3 @@ /**

*
* The version of the OpenAPI document: 0.8.1-SNAPSHOT
* The version of the OpenAPI document: 0.10.0
*

@@ -8,0 +8,0 @@ *

@@ -8,3 +8,3 @@ "use strict";

*
* The version of the OpenAPI document: 0.8.1-SNAPSHOT
* The version of the OpenAPI document: 0.10.0
*

@@ -11,0 +11,0 @@ *

@@ -5,3 +5,3 @@ /**

*
* The version of the OpenAPI document: 0.8.1-SNAPSHOT
* The version of the OpenAPI document: 0.10.0
*

@@ -8,0 +8,0 @@ *

@@ -8,3 +8,3 @@ "use strict";

*
* The version of the OpenAPI document: 0.8.1-SNAPSHOT
* The version of the OpenAPI document: 0.10.0
*

@@ -11,0 +11,0 @@ *

@@ -5,3 +5,3 @@ /**

*
* The version of the OpenAPI document: 0.8.1-SNAPSHOT
* The version of the OpenAPI document: 0.10.0
*

@@ -8,0 +8,0 @@ *

@@ -8,3 +8,3 @@ "use strict";

*
* The version of the OpenAPI document: 0.8.1-SNAPSHOT
* The version of the OpenAPI document: 0.10.0
*

@@ -11,0 +11,0 @@ *

@@ -5,3 +5,3 @@ /**

*
* The version of the OpenAPI document: 0.8.1-SNAPSHOT
* The version of the OpenAPI document: 0.10.0
*

@@ -8,0 +8,0 @@ *

@@ -8,3 +8,3 @@ "use strict";

*
* The version of the OpenAPI document: 0.8.1-SNAPSHOT
* The version of the OpenAPI document: 0.10.0
*

@@ -11,0 +11,0 @@ *

@@ -5,3 +5,3 @@ /**

*
* The version of the OpenAPI document: 0.8.1-SNAPSHOT
* The version of the OpenAPI document: 0.10.0
*

@@ -8,0 +8,0 @@ *

@@ -8,3 +8,3 @@ "use strict";

*
* The version of the OpenAPI document: 0.8.1-SNAPSHOT
* The version of the OpenAPI document: 0.10.0
*

@@ -11,0 +11,0 @@ *

@@ -5,3 +5,3 @@ /**

*
* The version of the OpenAPI document: 0.8.1-SNAPSHOT
* The version of the OpenAPI document: 0.10.0
*

@@ -8,0 +8,0 @@ *

@@ -8,3 +8,3 @@ "use strict";

*
* The version of the OpenAPI document: 0.8.1-SNAPSHOT
* The version of the OpenAPI document: 0.10.0
*

@@ -11,0 +11,0 @@ *

@@ -5,3 +5,3 @@ /**

*
* The version of the OpenAPI document: 0.8.1-SNAPSHOT
* The version of the OpenAPI document: 0.10.0
*

@@ -8,0 +8,0 @@ *

@@ -8,3 +8,3 @@ "use strict";

*
* The version of the OpenAPI document: 0.8.1-SNAPSHOT
* The version of the OpenAPI document: 0.10.0
*

@@ -11,0 +11,0 @@ *

@@ -5,3 +5,3 @@ /**

*
* The version of the OpenAPI document: 0.8.1-SNAPSHOT
* The version of the OpenAPI document: 0.10.0
*

@@ -8,0 +8,0 @@ *

@@ -8,3 +8,3 @@ "use strict";

*
* The version of the OpenAPI document: 0.8.1-SNAPSHOT
* The version of the OpenAPI document: 0.10.0
*

@@ -11,0 +11,0 @@ *

@@ -5,3 +5,3 @@ /**

*
* The version of the OpenAPI document: 0.8.1-SNAPSHOT
* The version of the OpenAPI document: 0.10.0
*

@@ -8,0 +8,0 @@ *

@@ -8,3 +8,3 @@ "use strict";

*
* The version of the OpenAPI document: 0.8.1-SNAPSHOT
* The version of the OpenAPI document: 0.10.0
*

@@ -11,0 +11,0 @@ *

@@ -5,3 +5,3 @@ /**

*
* The version of the OpenAPI document: 0.8.1-SNAPSHOT
* The version of the OpenAPI document: 0.10.0
*

@@ -8,0 +8,0 @@ *

@@ -8,3 +8,3 @@ "use strict";

*
* The version of the OpenAPI document: 0.8.1-SNAPSHOT
* The version of the OpenAPI document: 0.10.0
*

@@ -11,0 +11,0 @@ *

@@ -5,3 +5,3 @@ /**

*
* The version of the OpenAPI document: 0.8.1-SNAPSHOT
* The version of the OpenAPI document: 0.10.0
*

@@ -8,0 +8,0 @@ *

@@ -8,3 +8,3 @@ "use strict";

*
* The version of the OpenAPI document: 0.8.1-SNAPSHOT
* The version of the OpenAPI document: 0.10.0
*

@@ -11,0 +11,0 @@ *

@@ -5,3 +5,3 @@ /**

*
* The version of the OpenAPI document: 0.8.1-SNAPSHOT
* The version of the OpenAPI document: 0.10.0
*

@@ -8,0 +8,0 @@ *

@@ -8,3 +8,3 @@ "use strict";

*
* The version of the OpenAPI document: 0.8.1-SNAPSHOT
* The version of the OpenAPI document: 0.10.0
*

@@ -11,0 +11,0 @@ *

@@ -5,3 +5,3 @@ /**

*
* The version of the OpenAPI document: 0.8.1-SNAPSHOT
* The version of the OpenAPI document: 0.10.0
*

@@ -8,0 +8,0 @@ *

@@ -8,3 +8,3 @@ "use strict";

*
* The version of the OpenAPI document: 0.8.1-SNAPSHOT
* The version of the OpenAPI document: 0.10.0
*

@@ -11,0 +11,0 @@ *

@@ -5,3 +5,3 @@ /**

*
* The version of the OpenAPI document: 0.8.1-SNAPSHOT
* The version of the OpenAPI document: 0.10.0
*

@@ -8,0 +8,0 @@ *

@@ -8,3 +8,3 @@ "use strict";

*
* The version of the OpenAPI document: 0.8.1-SNAPSHOT
* The version of the OpenAPI document: 0.10.0
*

@@ -11,0 +11,0 @@ *

@@ -5,3 +5,3 @@ /**

*
* The version of the OpenAPI document: 0.8.1-SNAPSHOT
* The version of the OpenAPI document: 0.10.0
*

@@ -8,0 +8,0 @@ *

@@ -8,3 +8,3 @@ "use strict";

*
* The version of the OpenAPI document: 0.8.1-SNAPSHOT
* The version of the OpenAPI document: 0.10.0
*

@@ -11,0 +11,0 @@ *

@@ -5,3 +5,3 @@ /**

*
* The version of the OpenAPI document: 0.8.1-SNAPSHOT
* The version of the OpenAPI document: 0.10.0
*

@@ -8,0 +8,0 @@ *

@@ -8,3 +8,3 @@ "use strict";

*
* The version of the OpenAPI document: 0.8.1-SNAPSHOT
* The version of the OpenAPI document: 0.10.0
*

@@ -11,0 +11,0 @@ *

@@ -5,3 +5,3 @@ /**

*
* The version of the OpenAPI document: 0.8.1-SNAPSHOT
* The version of the OpenAPI document: 0.10.0
*

@@ -8,0 +8,0 @@ *

@@ -8,3 +8,3 @@ "use strict";

*
* The version of the OpenAPI document: 0.8.1-SNAPSHOT
* The version of the OpenAPI document: 0.10.0
*

@@ -11,0 +11,0 @@ *

@@ -5,3 +5,3 @@ /**

*
* The version of the OpenAPI document: 0.8.1-SNAPSHOT
* The version of the OpenAPI document: 0.10.0
*

@@ -8,0 +8,0 @@ *

@@ -8,3 +8,3 @@ "use strict";

*
* The version of the OpenAPI document: 0.8.1-SNAPSHOT
* The version of the OpenAPI document: 0.10.0
*

@@ -11,0 +11,0 @@ *

@@ -5,3 +5,3 @@ /**

*
* The version of the OpenAPI document: 0.8.1-SNAPSHOT
* The version of the OpenAPI document: 0.10.0
*

@@ -8,0 +8,0 @@ *

@@ -8,3 +8,3 @@ "use strict";

*
* The version of the OpenAPI document: 0.8.1-SNAPSHOT
* The version of the OpenAPI document: 0.10.0
*

@@ -11,0 +11,0 @@ *

@@ -5,3 +5,3 @@ /**

*
* The version of the OpenAPI document: 0.8.1-SNAPSHOT
* The version of the OpenAPI document: 0.10.0
*

@@ -8,0 +8,0 @@ *

@@ -8,3 +8,3 @@ "use strict";

*
* The version of the OpenAPI document: 0.8.1-SNAPSHOT
* The version of the OpenAPI document: 0.10.0
*

@@ -11,0 +11,0 @@ *

@@ -5,3 +5,3 @@ /**

*
* The version of the OpenAPI document: 0.8.1-SNAPSHOT
* The version of the OpenAPI document: 0.10.0
*

@@ -8,0 +8,0 @@ *

@@ -8,3 +8,3 @@ "use strict";

*
* The version of the OpenAPI document: 0.8.1-SNAPSHOT
* The version of the OpenAPI document: 0.10.0
*

@@ -11,0 +11,0 @@ *

@@ -5,3 +5,3 @@ /**

*
* The version of the OpenAPI document: 0.8.1-SNAPSHOT
* The version of the OpenAPI document: 0.10.0
*

@@ -8,0 +8,0 @@ *

@@ -8,3 +8,3 @@ "use strict";

*
* The version of the OpenAPI document: 0.8.1-SNAPSHOT
* The version of the OpenAPI document: 0.10.0
*

@@ -11,0 +11,0 @@ *

{
"name": "@rhoas/kafka-instance-sdk",
"version": "0.31.0",
"version": "0.31.1",
"description": "RHOAS Kafka Instance Adminstration SDK",

@@ -27,8 +27,8 @@ "author": "Red Hat Developers",

"dependencies": {
"axios": "0.26.1"
"axios": "0.27.1"
},
"devDependencies": {
"@types/node": "16.11.27",
"@types/node": "16.11.31",
"typescript": "4.6.3"
}
}

@@ -7,3 +7,3 @@ /* tslint:disable */

*
* The version of the OpenAPI document: 0.8.1-SNAPSHOT
* The version of the OpenAPI document: 0.10.0
*

@@ -10,0 +10,0 @@ *

@@ -7,3 +7,3 @@ /* tslint:disable */

*
* The version of the OpenAPI document: 0.8.1-SNAPSHOT
* The version of the OpenAPI document: 0.10.0
*

@@ -10,0 +10,0 @@ *

@@ -7,3 +7,3 @@ /* tslint:disable */

*
* The version of the OpenAPI document: 0.8.1-SNAPSHOT
* The version of the OpenAPI document: 0.10.0
*

@@ -10,0 +10,0 @@ *

@@ -7,3 +7,3 @@ /* tslint:disable */

*
* The version of the OpenAPI document: 0.8.1-SNAPSHOT
* The version of the OpenAPI document: 0.10.0
*

@@ -42,2 +42,3 @@ *

* @param {number} [limit] Limit the number of records fetched and returned
* @param {number} [maxValueLength] Maximum length of string values returned in the response. Values with a length that exceeds this parameter will be truncated. When this parameter is not included in the request, the full string values will be returned.
* @param {number} [offset] Retrieve messages with an offset equal to or greater than this offset. If both &#x60;timestamp&#x60; and &#x60;offset&#x60; are requested, &#x60;timestamp&#x60; is given preference.

@@ -49,3 +50,3 @@ * @param {number} [partition] Retrieve messages only from this partition

*/
consumeRecords: async (topicName: string, include?: Array<RecordIncludedProperty>, limit?: number, offset?: number, partition?: number, timestamp?: any, options: AxiosRequestConfig = {}): Promise<RequestArgs> => {
consumeRecords: async (topicName: string, include?: Array<RecordIncludedProperty>, limit?: number, maxValueLength?: number, offset?: number, partition?: number, timestamp?: any, options: AxiosRequestConfig = {}): Promise<RequestArgs> => {
// verify required parameter 'topicName' is not null or undefined

@@ -78,2 +79,6 @@ assertParamExists('consumeRecords', 'topicName', topicName)

if (maxValueLength !== undefined) {
localVarQueryParameter['maxValueLength'] = maxValueLength;
}
if (offset !== undefined) {

@@ -162,2 +167,3 @@ localVarQueryParameter['offset'] = offset;

* @param {number} [limit] Limit the number of records fetched and returned
* @param {number} [maxValueLength] Maximum length of string values returned in the response. Values with a length that exceeds this parameter will be truncated. When this parameter is not included in the request, the full string values will be returned.
* @param {number} [offset] Retrieve messages with an offset equal to or greater than this offset. If both &#x60;timestamp&#x60; and &#x60;offset&#x60; are requested, &#x60;timestamp&#x60; is given preference.

@@ -169,4 +175,4 @@ * @param {number} [partition] Retrieve messages only from this partition

*/
async consumeRecords(topicName: string, include?: Array<RecordIncludedProperty>, limit?: number, offset?: number, partition?: number, timestamp?: any, options?: AxiosRequestConfig): Promise<(axios?: AxiosInstance, basePath?: string) => AxiosPromise<RecordList>> {
const localVarAxiosArgs = await localVarAxiosParamCreator.consumeRecords(topicName, include, limit, offset, partition, timestamp, options);
async consumeRecords(topicName: string, include?: Array<RecordIncludedProperty>, limit?: number, maxValueLength?: number, offset?: number, partition?: number, timestamp?: any, options?: AxiosRequestConfig): Promise<(axios?: AxiosInstance, basePath?: string) => AxiosPromise<RecordList>> {
const localVarAxiosArgs = await localVarAxiosParamCreator.consumeRecords(topicName, include, limit, maxValueLength, offset, partition, timestamp, options);
return createRequestFunction(localVarAxiosArgs, globalAxios, BASE_PATH, configuration);

@@ -202,2 +208,3 @@ },

* @param {number} [limit] Limit the number of records fetched and returned
* @param {number} [maxValueLength] Maximum length of string values returned in the response. Values with a length that exceeds this parameter will be truncated. When this parameter is not included in the request, the full string values will be returned.
* @param {number} [offset] Retrieve messages with an offset equal to or greater than this offset. If both &#x60;timestamp&#x60; and &#x60;offset&#x60; are requested, &#x60;timestamp&#x60; is given preference.

@@ -209,4 +216,4 @@ * @param {number} [partition] Retrieve messages only from this partition

*/
consumeRecords(topicName: string, include?: Array<RecordIncludedProperty>, limit?: number, offset?: number, partition?: number, timestamp?: any, options?: any): AxiosPromise<RecordList> {
return localVarFp.consumeRecords(topicName, include, limit, offset, partition, timestamp, options).then((request) => request(axios, basePath));
consumeRecords(topicName: string, include?: Array<RecordIncludedProperty>, limit?: number, maxValueLength?: number, offset?: number, partition?: number, timestamp?: any, options?: any): AxiosPromise<RecordList> {
return localVarFp.consumeRecords(topicName, include, limit, maxValueLength, offset, partition, timestamp, options).then((request) => request(axios, basePath));
},

@@ -239,2 +246,3 @@ /**

* @param {number} [limit] Limit the number of records fetched and returned
* @param {number} [maxValueLength] Maximum length of string values returned in the response. Values with a length that exceeds this parameter will be truncated. When this parameter is not included in the request, the full string values will be returned.
* @param {number} [offset] Retrieve messages with an offset equal to or greater than this offset. If both &#x60;timestamp&#x60; and &#x60;offset&#x60; are requested, &#x60;timestamp&#x60; is given preference.

@@ -247,3 +255,3 @@ * @param {number} [partition] Retrieve messages only from this partition

*/
consumeRecords(topicName: string, include?: Array<RecordIncludedProperty>, limit?: number, offset?: number, partition?: number, timestamp?: any, options?: AxiosRequestConfig): AxiosPromise<RecordList>;
consumeRecords(topicName: string, include?: Array<RecordIncludedProperty>, limit?: number, maxValueLength?: number, offset?: number, partition?: number, timestamp?: any, options?: AxiosRequestConfig): AxiosPromise<RecordList>;

@@ -276,2 +284,3 @@ /**

* @param {number} [limit] Limit the number of records fetched and returned
* @param {number} [maxValueLength] Maximum length of string values returned in the response. Values with a length that exceeds this parameter will be truncated. When this parameter is not included in the request, the full string values will be returned.
* @param {number} [offset] Retrieve messages with an offset equal to or greater than this offset. If both &#x60;timestamp&#x60; and &#x60;offset&#x60; are requested, &#x60;timestamp&#x60; is given preference.

@@ -284,4 +293,4 @@ * @param {number} [partition] Retrieve messages only from this partition

*/
public consumeRecords(topicName: string, include?: Array<RecordIncludedProperty>, limit?: number, offset?: number, partition?: number, timestamp?: any, options?: AxiosRequestConfig) {
return RecordsApiFp(this.configuration).consumeRecords(topicName, include, limit, offset, partition, timestamp, options).then((request) => request(this.axios, this.basePath));
public consumeRecords(topicName: string, include?: Array<RecordIncludedProperty>, limit?: number, maxValueLength?: number, offset?: number, partition?: number, timestamp?: any, options?: AxiosRequestConfig) {
return RecordsApiFp(this.configuration).consumeRecords(topicName, include, limit, maxValueLength, offset, partition, timestamp, options).then((request) => request(this.axios, this.basePath));
}

@@ -288,0 +297,0 @@

@@ -7,3 +7,3 @@ /* tslint:disable */

*
* The version of the OpenAPI document: 0.8.1-SNAPSHOT
* The version of the OpenAPI document: 0.10.0
*

@@ -10,0 +10,0 @@ *

@@ -7,3 +7,3 @@ /* tslint:disable */

*
* The version of the OpenAPI document: 0.8.1-SNAPSHOT
* The version of the OpenAPI document: 0.10.0
*

@@ -10,0 +10,0 @@ *

@@ -7,3 +7,3 @@ /* tslint:disable */

*
* The version of the OpenAPI document: 0.8.1-SNAPSHOT
* The version of the OpenAPI document: 0.10.0
*

@@ -10,0 +10,0 @@ *

@@ -7,3 +7,3 @@ /* tslint:disable */

*
* The version of the OpenAPI document: 0.8.1-SNAPSHOT
* The version of the OpenAPI document: 0.10.0
*

@@ -10,0 +10,0 @@ *

@@ -7,3 +7,3 @@ /* tslint:disable */

*
* The version of the OpenAPI document: 0.8.1-SNAPSHOT
* The version of the OpenAPI document: 0.10.0
*

@@ -10,0 +10,0 @@ *

@@ -7,3 +7,3 @@ /* tslint:disable */

*
* The version of the OpenAPI document: 0.8.1-SNAPSHOT
* The version of the OpenAPI document: 0.10.0
*

@@ -10,0 +10,0 @@ *

@@ -7,3 +7,3 @@ /* tslint:disable */

*
* The version of the OpenAPI document: 0.8.1-SNAPSHOT
* The version of the OpenAPI document: 0.10.0
*

@@ -10,0 +10,0 @@ *

@@ -7,3 +7,3 @@ /* tslint:disable */

*
* The version of the OpenAPI document: 0.8.1-SNAPSHOT
* The version of the OpenAPI document: 0.10.0
*

@@ -10,0 +10,0 @@ *

@@ -7,3 +7,3 @@ /* tslint:disable */

*
* The version of the OpenAPI document: 0.8.1-SNAPSHOT
* The version of the OpenAPI document: 0.10.0
*

@@ -10,0 +10,0 @@ *

@@ -7,3 +7,3 @@ /* tslint:disable */

*
* The version of the OpenAPI document: 0.8.1-SNAPSHOT
* The version of the OpenAPI document: 0.10.0
*

@@ -10,0 +10,0 @@ *

@@ -7,3 +7,3 @@ /* tslint:disable */

*
* The version of the OpenAPI document: 0.8.1-SNAPSHOT
* The version of the OpenAPI document: 0.10.0
*

@@ -10,0 +10,0 @@ *

@@ -7,3 +7,3 @@ /* tslint:disable */

*
* The version of the OpenAPI document: 0.8.1-SNAPSHOT
* The version of the OpenAPI document: 0.10.0
*

@@ -10,0 +10,0 @@ *

@@ -7,3 +7,3 @@ /* tslint:disable */

*
* The version of the OpenAPI document: 0.8.1-SNAPSHOT
* The version of the OpenAPI document: 0.10.0
*

@@ -10,0 +10,0 @@ *

@@ -7,3 +7,3 @@ /* tslint:disable */

*
* The version of the OpenAPI document: 0.8.1-SNAPSHOT
* The version of the OpenAPI document: 0.10.0
*

@@ -10,0 +10,0 @@ *

@@ -7,3 +7,3 @@ /* tslint:disable */

*
* The version of the OpenAPI document: 0.8.1-SNAPSHOT
* The version of the OpenAPI document: 0.10.0
*

@@ -10,0 +10,0 @@ *

@@ -7,3 +7,3 @@ /* tslint:disable */

*
* The version of the OpenAPI document: 0.8.1-SNAPSHOT
* The version of the OpenAPI document: 0.10.0
*

@@ -10,0 +10,0 @@ *

@@ -7,3 +7,3 @@ /* tslint:disable */

*
* The version of the OpenAPI document: 0.8.1-SNAPSHOT
* The version of the OpenAPI document: 0.10.0
*

@@ -10,0 +10,0 @@ *

@@ -7,3 +7,3 @@ /* tslint:disable */

*
* The version of the OpenAPI document: 0.8.1-SNAPSHOT
* The version of the OpenAPI document: 0.10.0
*

@@ -10,0 +10,0 @@ *

@@ -7,3 +7,3 @@ /* tslint:disable */

*
* The version of the OpenAPI document: 0.8.1-SNAPSHOT
* The version of the OpenAPI document: 0.10.0
*

@@ -10,0 +10,0 @@ *

@@ -7,3 +7,3 @@ /* tslint:disable */

*
* The version of the OpenAPI document: 0.8.1-SNAPSHOT
* The version of the OpenAPI document: 0.10.0
*

@@ -10,0 +10,0 @@ *

@@ -7,3 +7,3 @@ /* tslint:disable */

*
* The version of the OpenAPI document: 0.8.1-SNAPSHOT
* The version of the OpenAPI document: 0.10.0
*

@@ -10,0 +10,0 @@ *

@@ -7,3 +7,3 @@ /* tslint:disable */

*
* The version of the OpenAPI document: 0.8.1-SNAPSHOT
* The version of the OpenAPI document: 0.10.0
*

@@ -10,0 +10,0 @@ *

@@ -7,3 +7,3 @@ /* tslint:disable */

*
* The version of the OpenAPI document: 0.8.1-SNAPSHOT
* The version of the OpenAPI document: 0.10.0
*

@@ -10,0 +10,0 @@ *

@@ -7,3 +7,3 @@ /* tslint:disable */

*
* The version of the OpenAPI document: 0.8.1-SNAPSHOT
* The version of the OpenAPI document: 0.10.0
*

@@ -10,0 +10,0 @@ *

@@ -7,3 +7,3 @@ /* tslint:disable */

*
* The version of the OpenAPI document: 0.8.1-SNAPSHOT
* The version of the OpenAPI document: 0.10.0
*

@@ -10,0 +10,0 @@ *

@@ -7,3 +7,3 @@ /* tslint:disable */

*
* The version of the OpenAPI document: 0.8.1-SNAPSHOT
* The version of the OpenAPI document: 0.10.0
*

@@ -10,0 +10,0 @@ *

@@ -7,3 +7,3 @@ /* tslint:disable */

*
* The version of the OpenAPI document: 0.8.1-SNAPSHOT
* The version of the OpenAPI document: 0.10.0
*

@@ -10,0 +10,0 @@ *

@@ -7,3 +7,3 @@ /* tslint:disable */

*
* The version of the OpenAPI document: 0.8.1-SNAPSHOT
* The version of the OpenAPI document: 0.10.0
*

@@ -10,0 +10,0 @@ *

@@ -7,3 +7,3 @@ /* tslint:disable */

*
* The version of the OpenAPI document: 0.8.1-SNAPSHOT
* The version of the OpenAPI document: 0.10.0
*

@@ -10,0 +10,0 @@ *

@@ -7,3 +7,3 @@ /* tslint:disable */

*
* The version of the OpenAPI document: 0.8.1-SNAPSHOT
* The version of the OpenAPI document: 0.10.0
*

@@ -10,0 +10,0 @@ *

@@ -7,3 +7,3 @@ /* tslint:disable */

*
* The version of the OpenAPI document: 0.8.1-SNAPSHOT
* The version of the OpenAPI document: 0.10.0
*

@@ -10,0 +10,0 @@ *

@@ -7,3 +7,3 @@ /* tslint:disable */

*
* The version of the OpenAPI document: 0.8.1-SNAPSHOT
* The version of the OpenAPI document: 0.10.0
*

@@ -10,0 +10,0 @@ *

@@ -7,3 +7,3 @@ /* tslint:disable */

*
* The version of the OpenAPI document: 0.8.1-SNAPSHOT
* The version of the OpenAPI document: 0.10.0
*

@@ -10,0 +10,0 @@ *

@@ -7,3 +7,3 @@ /* tslint:disable */

*
* The version of the OpenAPI document: 0.8.1-SNAPSHOT
* The version of the OpenAPI document: 0.10.0
*

@@ -10,0 +10,0 @@ *

@@ -7,3 +7,3 @@ /* tslint:disable */

*
* The version of the OpenAPI document: 0.8.1-SNAPSHOT
* The version of the OpenAPI document: 0.10.0
*

@@ -10,0 +10,0 @@ *

@@ -7,3 +7,3 @@ /* tslint:disable */

*
* The version of the OpenAPI document: 0.8.1-SNAPSHOT
* The version of the OpenAPI document: 0.10.0
*

@@ -10,0 +10,0 @@ *

@@ -7,3 +7,3 @@ /* tslint:disable */

*
* The version of the OpenAPI document: 0.8.1-SNAPSHOT
* The version of the OpenAPI document: 0.10.0
*

@@ -10,0 +10,0 @@ *

@@ -7,3 +7,3 @@ /* tslint:disable */

*
* The version of the OpenAPI document: 0.8.1-SNAPSHOT
* The version of the OpenAPI document: 0.10.0
*

@@ -10,0 +10,0 @@ *

@@ -7,3 +7,3 @@ /* tslint:disable */

*
* The version of the OpenAPI document: 0.8.1-SNAPSHOT
* The version of the OpenAPI document: 0.10.0
*

@@ -10,0 +10,0 @@ *

@@ -7,3 +7,3 @@ /* tslint:disable */

*
* The version of the OpenAPI document: 0.8.1-SNAPSHOT
* The version of the OpenAPI document: 0.10.0
*

@@ -10,0 +10,0 @@ *

@@ -7,3 +7,3 @@ /* tslint:disable */

*
* The version of the OpenAPI document: 0.8.1-SNAPSHOT
* The version of the OpenAPI document: 0.10.0
*

@@ -10,0 +10,0 @@ *

SocketSocket SOC 2 Logo

Product

  • Package Alerts
  • Integrations
  • Docs
  • Pricing
  • FAQ
  • Roadmap
  • Changelog

Packages

npm

Stay in touch

Get open source security insights delivered straight into your inbox.


  • Terms
  • Privacy
  • Security

Made with ⚡️ by Socket Inc