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

@rhoas/kafka-instance-sdk

Package Overview
Dependencies
Maintainers
5
Versions
88
Alerts
File Explorer

Advanced tools

License
Socket logo

Install Socket

Detect and block malicious and high-risk dependencies

Install

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

Comparing version 0.12.3 to 0.14.0

48

dist/generated/api/acls-api.js

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

// verify required parameter 'aclBinding' is not null or undefined
common_1.assertParamExists('createAcl', 'aclBinding', aclBinding);
(0, common_1.assertParamExists)('createAcl', 'aclBinding', aclBinding);
const localVarPath = `/acls`;

@@ -61,10 +61,10 @@ // use dummy base URL string because the URL constructor only accepts absolute URLs.

// oauth required
yield common_1.setOAuthToObject(localVarHeaderParameter, "Bearer", [], configuration);
yield (0, common_1.setOAuthToObject)(localVarHeaderParameter, "Bearer", [], configuration);
localVarHeaderParameter['Content-Type'] = 'application/json';
common_1.setSearchParams(localVarUrlObj, localVarQueryParameter, options.query);
(0, common_1.setSearchParams)(localVarUrlObj, localVarQueryParameter, options.query);
let headersFromBaseOptions = baseOptions && baseOptions.headers ? baseOptions.headers : {};
localVarRequestOptions.headers = Object.assign(Object.assign(Object.assign({}, localVarHeaderParameter), headersFromBaseOptions), options.headers);
localVarRequestOptions.data = common_1.serializeDataIfNeeded(aclBinding, localVarRequestOptions, configuration);
localVarRequestOptions.data = (0, common_1.serializeDataIfNeeded)(aclBinding, localVarRequestOptions, configuration);
return {
url: common_1.toPathString(localVarUrlObj),
url: (0, common_1.toPathString)(localVarUrlObj),
options: localVarRequestOptions,

@@ -98,3 +98,3 @@ };

// oauth required
yield common_1.setOAuthToObject(localVarHeaderParameter, "Bearer", [], configuration);
yield (0, common_1.setOAuthToObject)(localVarHeaderParameter, "Bearer", [], configuration);
if (resourceType !== undefined) {

@@ -118,7 +118,7 @@ localVarQueryParameter['resourceType'] = resourceType;

}
common_1.setSearchParams(localVarUrlObj, localVarQueryParameter, options.query);
(0, common_1.setSearchParams)(localVarUrlObj, localVarQueryParameter, options.query);
let headersFromBaseOptions = baseOptions && baseOptions.headers ? baseOptions.headers : {};
localVarRequestOptions.headers = Object.assign(Object.assign(Object.assign({}, localVarHeaderParameter), headersFromBaseOptions), options.headers);
return {
url: common_1.toPathString(localVarUrlObj),
url: (0, common_1.toPathString)(localVarUrlObj),
options: localVarRequestOptions,

@@ -146,8 +146,8 @@ };

// oauth required
yield common_1.setOAuthToObject(localVarHeaderParameter, "Bearer", [], configuration);
common_1.setSearchParams(localVarUrlObj, localVarQueryParameter, options.query);
yield (0, common_1.setOAuthToObject)(localVarHeaderParameter, "Bearer", [], configuration);
(0, common_1.setSearchParams)(localVarUrlObj, localVarQueryParameter, options.query);
let headersFromBaseOptions = baseOptions && baseOptions.headers ? baseOptions.headers : {};
localVarRequestOptions.headers = Object.assign(Object.assign(Object.assign({}, localVarHeaderParameter), headersFromBaseOptions), options.headers);
return {
url: common_1.toPathString(localVarUrlObj),
url: (0, common_1.toPathString)(localVarUrlObj),
options: localVarRequestOptions,

@@ -185,3 +185,3 @@ };

// oauth required
yield common_1.setOAuthToObject(localVarHeaderParameter, "Bearer", [], configuration);
yield (0, common_1.setOAuthToObject)(localVarHeaderParameter, "Bearer", [], configuration);
if (resourceType !== undefined) {

@@ -217,7 +217,7 @@ localVarQueryParameter['resourceType'] = resourceType;

}
common_1.setSearchParams(localVarUrlObj, localVarQueryParameter, options.query);
(0, common_1.setSearchParams)(localVarUrlObj, localVarQueryParameter, options.query);
let headersFromBaseOptions = baseOptions && baseOptions.headers ? baseOptions.headers : {};
localVarRequestOptions.headers = Object.assign(Object.assign(Object.assign({}, localVarHeaderParameter), headersFromBaseOptions), options.headers);
return {
url: common_1.toPathString(localVarUrlObj),
url: (0, common_1.toPathString)(localVarUrlObj),
options: localVarRequestOptions,

@@ -234,3 +234,3 @@ };

const AclsApiFp = function (configuration) {
const localVarAxiosParamCreator = exports.AclsApiAxiosParamCreator(configuration);
const localVarAxiosParamCreator = (0, exports.AclsApiAxiosParamCreator)(configuration);
return {

@@ -247,3 +247,3 @@ /**

const localVarAxiosArgs = yield localVarAxiosParamCreator.createAcl(aclBinding, options);
return common_1.createRequestFunction(localVarAxiosArgs, axios_1.default, base_1.BASE_PATH, configuration);
return (0, common_1.createRequestFunction)(localVarAxiosArgs, axios_1.default, base_1.BASE_PATH, configuration);
});

@@ -266,3 +266,3 @@ },

const localVarAxiosArgs = yield localVarAxiosParamCreator.deleteAcls(resourceType, resourceName, patternType, principal, operation, permission, options);
return common_1.createRequestFunction(localVarAxiosArgs, axios_1.default, base_1.BASE_PATH, configuration);
return (0, common_1.createRequestFunction)(localVarAxiosArgs, axios_1.default, base_1.BASE_PATH, configuration);
});

@@ -279,3 +279,3 @@ },

const localVarAxiosArgs = yield localVarAxiosParamCreator.getAclResourceOperations(options);
return common_1.createRequestFunction(localVarAxiosArgs, axios_1.default, base_1.BASE_PATH, configuration);
return (0, common_1.createRequestFunction)(localVarAxiosArgs, axios_1.default, base_1.BASE_PATH, configuration);
});

@@ -302,3 +302,3 @@ },

const localVarAxiosArgs = yield localVarAxiosParamCreator.getAcls(resourceType, resourceName, patternType, principal, operation, permission, page, size, order, orderKey, options);
return common_1.createRequestFunction(localVarAxiosArgs, axios_1.default, base_1.BASE_PATH, configuration);
return (0, common_1.createRequestFunction)(localVarAxiosArgs, axios_1.default, base_1.BASE_PATH, configuration);
});

@@ -314,3 +314,3 @@ },

const AclsApiFactory = function (configuration, basePath, axios) {
const localVarFp = exports.AclsApiFp(configuration);
const localVarFp = (0, exports.AclsApiFp)(configuration);
return {

@@ -389,3 +389,3 @@ /**

createAcl(aclBinding, options) {
return exports.AclsApiFp(this.configuration).createAcl(aclBinding, options).then((request) => request(this.axios, this.basePath));
return (0, exports.AclsApiFp)(this.configuration).createAcl(aclBinding, options).then((request) => request(this.axios, this.basePath));
}

@@ -406,3 +406,3 @@ /**

deleteAcls(resourceType, resourceName, patternType, principal, operation, permission, options) {
return exports.AclsApiFp(this.configuration).deleteAcls(resourceType, resourceName, patternType, principal, operation, permission, options).then((request) => request(this.axios, this.basePath));
return (0, exports.AclsApiFp)(this.configuration).deleteAcls(resourceType, resourceName, patternType, principal, operation, permission, options).then((request) => request(this.axios, this.basePath));
}

@@ -417,3 +417,3 @@ /**

getAclResourceOperations(options) {
return exports.AclsApiFp(this.configuration).getAclResourceOperations(options).then((request) => request(this.axios, this.basePath));
return (0, exports.AclsApiFp)(this.configuration).getAclResourceOperations(options).then((request) => request(this.axios, this.basePath));
}

@@ -438,5 +438,5 @@ /**

getAcls(resourceType, resourceName, patternType, principal, operation, permission, page, size, order, orderKey, options) {
return exports.AclsApiFp(this.configuration).getAcls(resourceType, resourceName, patternType, principal, operation, permission, page, size, order, orderKey, options).then((request) => request(this.axios, this.basePath));
return (0, exports.AclsApiFp)(this.configuration).getAcls(resourceType, resourceName, patternType, principal, operation, permission, page, size, order, orderKey, options).then((request) => request(this.axios, this.basePath));
}
}
exports.AclsApi = AclsApi;

30

dist/generated/api/groups-api.d.ts

@@ -45,3 +45,3 @@ /**

/**
* Returns a list of all consumer groups for a particular Kafka instance.
* Returns a list of all consumer groups for a particular Kafka instance. The consumer groups returned are limited to those records the requestor is authorized to view.
* @summary List of consumer groups in the Kafka instance.

@@ -52,4 +52,4 @@ * @param {number} [offset] The page offset

* @param {number} [page] The page when returning the list of consumer groups
* @param {string} [topic] Return consumer groups for this topic
* @param {string} [groupIdFilter] Return the consumer groups where the ID begins with this value
* @param {string} [topic] Return consumer groups where the topic name contains with this value
* @param {string} [groupIdFilter] Return the consumer groups where the ID contains with this value
* @param {'asc' | 'desc'} [order] Order of the consumer groups sorting. Ascending order is used as default.

@@ -97,3 +97,3 @@ * @param {'name'} [orderKey] Order key to sort the items by. Only the value \'name\' is currently applicable.

/**
* Returns a list of all consumer groups for a particular Kafka instance.
* Returns a list of all consumer groups for a particular Kafka instance. The consumer groups returned are limited to those records the requestor is authorized to view.
* @summary List of consumer groups in the Kafka instance.

@@ -104,4 +104,4 @@ * @param {number} [offset] The page offset

* @param {number} [page] The page when returning the list of consumer groups
* @param {string} [topic] Return consumer groups for this topic
* @param {string} [groupIdFilter] Return the consumer groups where the ID begins with this value
* @param {string} [topic] Return consumer groups where the topic name contains with this value
* @param {string} [groupIdFilter] Return the consumer groups where the ID contains with this value
* @param {'asc' | 'desc'} [order] Order of the consumer groups sorting. Ascending order is used as default.

@@ -149,3 +149,3 @@ * @param {'name'} [orderKey] Order key to sort the items by. Only the value \'name\' is currently applicable.

/**
* Returns a list of all consumer groups for a particular Kafka instance.
* Returns a list of all consumer groups for a particular Kafka instance. The consumer groups returned are limited to those records the requestor is authorized to view.
* @summary List of consumer groups in the Kafka instance.

@@ -156,4 +156,4 @@ * @param {number} [offset] The page offset

* @param {number} [page] The page when returning the list of consumer groups
* @param {string} [topic] Return consumer groups for this topic
* @param {string} [groupIdFilter] Return the consumer groups where the ID begins with this value
* @param {string} [topic] Return consumer groups where the topic name contains with this value
* @param {string} [groupIdFilter] Return the consumer groups where the ID contains with this value
* @param {'asc' | 'desc'} [order] Order of the consumer groups sorting. Ascending order is used as default.

@@ -204,3 +204,3 @@ * @param {'name'} [orderKey] Order key to sort the items by. Only the value \'name\' is currently applicable.

/**
* Returns a list of all consumer groups for a particular Kafka instance.
* Returns a list of all consumer groups for a particular Kafka instance. The consumer groups returned are limited to those records the requestor is authorized to view.
* @summary List of consumer groups in the Kafka instance.

@@ -211,4 +211,4 @@ * @param {number} [offset] The page offset

* @param {number} [page] The page when returning the list of consumer groups
* @param {string} [topic] Return consumer groups for this topic
* @param {string} [groupIdFilter] Return the consumer groups where the ID begins with this value
* @param {string} [topic] Return consumer groups where the topic name contains with this value
* @param {string} [groupIdFilter] Return the consumer groups where the ID contains with this value
* @param {'asc' | 'desc'} [order] Order of the consumer groups sorting. Ascending order is used as default.

@@ -262,3 +262,3 @@ * @param {'name'} [orderKey] Order key to sort the items by. Only the value \'name\' is currently applicable.

/**
* Returns a list of all consumer groups for a particular Kafka instance.
* Returns a list of all consumer groups for a particular Kafka instance. The consumer groups returned are limited to those records the requestor is authorized to view.
* @summary List of consumer groups in the Kafka instance.

@@ -269,4 +269,4 @@ * @param {number} [offset] The page offset

* @param {number} [page] The page when returning the list of consumer groups
* @param {string} [topic] Return consumer groups for this topic
* @param {string} [groupIdFilter] Return the consumer groups where the ID begins with this value
* @param {string} [topic] Return consumer groups where the topic name contains with this value
* @param {string} [groupIdFilter] Return the consumer groups where the ID contains with this value
* @param {'asc' | 'desc'} [order] Order of the consumer groups sorting. Ascending order is used as default.

@@ -273,0 +273,0 @@ * @param {'name'} [orderKey] Order key to sort the items by. Only the value \'name\' is currently applicable.

78

dist/generated/api/groups-api.js

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

// verify required parameter 'consumerGroupId' is not null or undefined
common_1.assertParamExists('deleteConsumerGroupById', 'consumerGroupId', consumerGroupId);
(0, common_1.assertParamExists)('deleteConsumerGroupById', 'consumerGroupId', consumerGroupId);
const localVarPath = `/consumer-groups/{consumerGroupId}`

@@ -62,8 +62,8 @@ .replace(`{${"consumerGroupId"}}`, encodeURIComponent(String(consumerGroupId)));

// oauth required
yield common_1.setOAuthToObject(localVarHeaderParameter, "Bearer", [], configuration);
common_1.setSearchParams(localVarUrlObj, localVarQueryParameter, options.query);
yield (0, common_1.setOAuthToObject)(localVarHeaderParameter, "Bearer", [], configuration);
(0, common_1.setSearchParams)(localVarUrlObj, localVarQueryParameter, options.query);
let headersFromBaseOptions = baseOptions && baseOptions.headers ? baseOptions.headers : {};
localVarRequestOptions.headers = Object.assign(Object.assign(Object.assign({}, localVarHeaderParameter), headersFromBaseOptions), options.headers);
return {
url: common_1.toPathString(localVarUrlObj),
url: (0, common_1.toPathString)(localVarUrlObj),
options: localVarRequestOptions,

@@ -85,3 +85,3 @@ };

// verify required parameter 'consumerGroupId' is not null or undefined
common_1.assertParamExists('getConsumerGroupById', 'consumerGroupId', consumerGroupId);
(0, common_1.assertParamExists)('getConsumerGroupById', 'consumerGroupId', consumerGroupId);
const localVarPath = `/consumer-groups/{consumerGroupId}`

@@ -100,3 +100,3 @@ .replace(`{${"consumerGroupId"}}`, encodeURIComponent(String(consumerGroupId)));

// oauth required
yield common_1.setOAuthToObject(localVarHeaderParameter, "Bearer", [], configuration);
yield (0, common_1.setOAuthToObject)(localVarHeaderParameter, "Bearer", [], configuration);
if (order !== undefined) {

@@ -114,7 +114,7 @@ localVarQueryParameter['order'] = order;

}
common_1.setSearchParams(localVarUrlObj, localVarQueryParameter, options.query);
(0, common_1.setSearchParams)(localVarUrlObj, localVarQueryParameter, options.query);
let headersFromBaseOptions = baseOptions && baseOptions.headers ? baseOptions.headers : {};
localVarRequestOptions.headers = Object.assign(Object.assign(Object.assign({}, localVarHeaderParameter), headersFromBaseOptions), options.headers);
return {
url: common_1.toPathString(localVarUrlObj),
url: (0, common_1.toPathString)(localVarUrlObj),
options: localVarRequestOptions,

@@ -124,3 +124,3 @@ };

/**
* Returns a list of all consumer groups for a particular Kafka instance.
* Returns a list of all consumer groups for a particular Kafka instance. The consumer groups returned are limited to those records the requestor is authorized to view.
* @summary List of consumer groups in the Kafka instance.

@@ -131,4 +131,4 @@ * @param {number} [offset] The page offset

* @param {number} [page] The page when returning the list of consumer groups
* @param {string} [topic] Return consumer groups for this topic
* @param {string} [groupIdFilter] Return the consumer groups where the ID begins with this value
* @param {string} [topic] Return consumer groups where the topic name contains with this value
* @param {string} [groupIdFilter] Return the consumer groups where the ID contains with this value
* @param {'asc' | 'desc'} [order] Order of the consumer groups sorting. Ascending order is used as default.

@@ -152,3 +152,3 @@ * @param {'name'} [orderKey] Order key to sort the items by. Only the value \'name\' is currently applicable.

// oauth required
yield common_1.setOAuthToObject(localVarHeaderParameter, "Bearer", [], configuration);
yield (0, common_1.setOAuthToObject)(localVarHeaderParameter, "Bearer", [], configuration);
if (offset !== undefined) {

@@ -178,7 +178,7 @@ localVarQueryParameter['offset'] = offset;

}
common_1.setSearchParams(localVarUrlObj, localVarQueryParameter, options.query);
(0, common_1.setSearchParams)(localVarUrlObj, localVarQueryParameter, options.query);
let headersFromBaseOptions = baseOptions && baseOptions.headers ? baseOptions.headers : {};
localVarRequestOptions.headers = Object.assign(Object.assign(Object.assign({}, localVarHeaderParameter), headersFromBaseOptions), options.headers);
return {
url: common_1.toPathString(localVarUrlObj),
url: (0, common_1.toPathString)(localVarUrlObj),
options: localVarRequestOptions,

@@ -197,5 +197,5 @@ };

// verify required parameter 'consumerGroupId' is not null or undefined
common_1.assertParamExists('resetConsumerGroupOffset', 'consumerGroupId', consumerGroupId);
(0, common_1.assertParamExists)('resetConsumerGroupOffset', 'consumerGroupId', consumerGroupId);
// verify required parameter 'consumerGroupResetOffsetParameters' is not null or undefined
common_1.assertParamExists('resetConsumerGroupOffset', 'consumerGroupResetOffsetParameters', consumerGroupResetOffsetParameters);
(0, common_1.assertParamExists)('resetConsumerGroupOffset', 'consumerGroupResetOffsetParameters', consumerGroupResetOffsetParameters);
const localVarPath = `/consumer-groups/{consumerGroupId}/reset-offset`

@@ -214,10 +214,10 @@ .replace(`{${"consumerGroupId"}}`, encodeURIComponent(String(consumerGroupId)));

// oauth required
yield common_1.setOAuthToObject(localVarHeaderParameter, "Bearer", [], configuration);
yield (0, common_1.setOAuthToObject)(localVarHeaderParameter, "Bearer", [], configuration);
localVarHeaderParameter['Content-Type'] = 'application/json';
common_1.setSearchParams(localVarUrlObj, localVarQueryParameter, options.query);
(0, common_1.setSearchParams)(localVarUrlObj, localVarQueryParameter, options.query);
let headersFromBaseOptions = baseOptions && baseOptions.headers ? baseOptions.headers : {};
localVarRequestOptions.headers = Object.assign(Object.assign(Object.assign({}, localVarHeaderParameter), headersFromBaseOptions), options.headers);
localVarRequestOptions.data = common_1.serializeDataIfNeeded(consumerGroupResetOffsetParameters, localVarRequestOptions, configuration);
localVarRequestOptions.data = (0, common_1.serializeDataIfNeeded)(consumerGroupResetOffsetParameters, localVarRequestOptions, configuration);
return {
url: common_1.toPathString(localVarUrlObj),
url: (0, common_1.toPathString)(localVarUrlObj),
options: localVarRequestOptions,

@@ -234,3 +234,3 @@ };

const GroupsApiFp = function (configuration) {
const localVarAxiosParamCreator = exports.GroupsApiAxiosParamCreator(configuration);
const localVarAxiosParamCreator = (0, exports.GroupsApiAxiosParamCreator)(configuration);
return {

@@ -247,3 +247,3 @@ /**

const localVarAxiosArgs = yield localVarAxiosParamCreator.deleteConsumerGroupById(consumerGroupId, options);
return common_1.createRequestFunction(localVarAxiosArgs, axios_1.default, base_1.BASE_PATH, configuration);
return (0, common_1.createRequestFunction)(localVarAxiosArgs, axios_1.default, base_1.BASE_PATH, configuration);
});

@@ -265,7 +265,7 @@ },

const localVarAxiosArgs = yield localVarAxiosParamCreator.getConsumerGroupById(consumerGroupId, order, orderKey, partitionFilter, topic, options);
return common_1.createRequestFunction(localVarAxiosArgs, axios_1.default, base_1.BASE_PATH, configuration);
return (0, common_1.createRequestFunction)(localVarAxiosArgs, axios_1.default, base_1.BASE_PATH, configuration);
});
},
/**
* Returns a list of all consumer groups for a particular Kafka instance.
* Returns a list of all consumer groups for a particular Kafka instance. The consumer groups returned are limited to those records the requestor is authorized to view.
* @summary List of consumer groups in the Kafka instance.

@@ -276,4 +276,4 @@ * @param {number} [offset] The page offset

* @param {number} [page] The page when returning the list of consumer groups
* @param {string} [topic] Return consumer groups for this topic
* @param {string} [groupIdFilter] Return the consumer groups where the ID begins with this value
* @param {string} [topic] Return consumer groups where the topic name contains with this value
* @param {string} [groupIdFilter] Return the consumer groups where the ID contains with this value
* @param {'asc' | 'desc'} [order] Order of the consumer groups sorting. Ascending order is used as default.

@@ -287,3 +287,3 @@ * @param {'name'} [orderKey] Order key to sort the items by. Only the value \'name\' is currently applicable.

const localVarAxiosArgs = yield localVarAxiosParamCreator.getConsumerGroups(offset, limit, size, page, topic, groupIdFilter, order, orderKey, options);
return common_1.createRequestFunction(localVarAxiosArgs, axios_1.default, base_1.BASE_PATH, configuration);
return (0, common_1.createRequestFunction)(localVarAxiosArgs, axios_1.default, base_1.BASE_PATH, configuration);
});

@@ -302,3 +302,3 @@ },

const localVarAxiosArgs = yield localVarAxiosParamCreator.resetConsumerGroupOffset(consumerGroupId, consumerGroupResetOffsetParameters, options);
return common_1.createRequestFunction(localVarAxiosArgs, axios_1.default, base_1.BASE_PATH, configuration);
return (0, common_1.createRequestFunction)(localVarAxiosArgs, axios_1.default, base_1.BASE_PATH, configuration);
});

@@ -314,3 +314,3 @@ },

const GroupsApiFactory = function (configuration, basePath, axios) {
const localVarFp = exports.GroupsApiFp(configuration);
const localVarFp = (0, exports.GroupsApiFp)(configuration);
return {

@@ -342,3 +342,3 @@ /**

/**
* Returns a list of all consumer groups for a particular Kafka instance.
* Returns a list of all consumer groups for a particular Kafka instance. The consumer groups returned are limited to those records the requestor is authorized to view.
* @summary List of consumer groups in the Kafka instance.

@@ -349,4 +349,4 @@ * @param {number} [offset] The page offset

* @param {number} [page] The page when returning the list of consumer groups
* @param {string} [topic] Return consumer groups for this topic
* @param {string} [groupIdFilter] Return the consumer groups where the ID begins with this value
* @param {string} [topic] Return consumer groups where the topic name contains with this value
* @param {string} [groupIdFilter] Return the consumer groups where the ID contains with this value
* @param {'asc' | 'desc'} [order] Order of the consumer groups sorting. Ascending order is used as default.

@@ -390,3 +390,3 @@ * @param {'name'} [orderKey] Order key to sort the items by. Only the value \'name\' is currently applicable.

deleteConsumerGroupById(consumerGroupId, options) {
return exports.GroupsApiFp(this.configuration).deleteConsumerGroupById(consumerGroupId, options).then((request) => request(this.axios, this.basePath));
return (0, exports.GroupsApiFp)(this.configuration).deleteConsumerGroupById(consumerGroupId, options).then((request) => request(this.axios, this.basePath));
}

@@ -406,6 +406,6 @@ /**

getConsumerGroupById(consumerGroupId, order, orderKey, partitionFilter, topic, options) {
return exports.GroupsApiFp(this.configuration).getConsumerGroupById(consumerGroupId, order, orderKey, partitionFilter, topic, options).then((request) => request(this.axios, this.basePath));
return (0, exports.GroupsApiFp)(this.configuration).getConsumerGroupById(consumerGroupId, order, orderKey, partitionFilter, topic, options).then((request) => request(this.axios, this.basePath));
}
/**
* Returns a list of all consumer groups for a particular Kafka instance.
* Returns a list of all consumer groups for a particular Kafka instance. The consumer groups returned are limited to those records the requestor is authorized to view.
* @summary List of consumer groups in the Kafka instance.

@@ -416,4 +416,4 @@ * @param {number} [offset] The page offset

* @param {number} [page] The page when returning the list of consumer groups
* @param {string} [topic] Return consumer groups for this topic
* @param {string} [groupIdFilter] Return the consumer groups where the ID begins with this value
* @param {string} [topic] Return consumer groups where the topic name contains with this value
* @param {string} [groupIdFilter] Return the consumer groups where the ID contains with this value
* @param {'asc' | 'desc'} [order] Order of the consumer groups sorting. Ascending order is used as default.

@@ -426,3 +426,3 @@ * @param {'name'} [orderKey] Order key to sort the items by. Only the value \'name\' is currently applicable.

getConsumerGroups(offset, limit, size, page, topic, groupIdFilter, order, orderKey, options) {
return exports.GroupsApiFp(this.configuration).getConsumerGroups(offset, limit, size, page, topic, groupIdFilter, order, orderKey, options).then((request) => request(this.axios, this.basePath));
return (0, exports.GroupsApiFp)(this.configuration).getConsumerGroups(offset, limit, size, page, topic, groupIdFilter, order, orderKey, options).then((request) => request(this.axios, this.basePath));
}

@@ -439,5 +439,5 @@ /**

resetConsumerGroupOffset(consumerGroupId, consumerGroupResetOffsetParameters, options) {
return exports.GroupsApiFp(this.configuration).resetConsumerGroupOffset(consumerGroupId, consumerGroupResetOffsetParameters, options).then((request) => request(this.axios, this.basePath));
return (0, exports.GroupsApiFp)(this.configuration).resetConsumerGroupOffset(consumerGroupId, consumerGroupResetOffsetParameters, options).then((request) => request(this.axios, this.basePath));
}
}
exports.GroupsApi = GroupsApi;

10

dist/generated/api/topics-api.d.ts

@@ -49,3 +49,3 @@ /**

/**
* Returns a list of all of the available topics, or the list of topics that meet the users URL Query Parameters.
* Returns a list of all of the available topics, or the list of topics that meet the request query parameters. The topics returned are limited to those records the requestor is authorized to view.
* @summary List of topics

@@ -103,3 +103,3 @@ * @param {number} [offset] The page offset

/**
* Returns a list of all of the available topics, or the list of topics that meet the users URL Query Parameters.
* Returns a list of all of the available topics, or the list of topics that meet the request query parameters. The topics returned are limited to those records the requestor is authorized to view.
* @summary List of topics

@@ -157,3 +157,3 @@ * @param {number} [offset] The page offset

/**
* Returns a list of all of the available topics, or the list of topics that meet the users URL Query Parameters.
* Returns a list of all of the available topics, or the list of topics that meet the request query parameters. The topics returned are limited to those records the requestor is authorized to view.
* @summary List of topics

@@ -215,3 +215,3 @@ * @param {number} [offset] The page offset

/**
* Returns a list of all of the available topics, or the list of topics that meet the users URL Query Parameters.
* Returns a list of all of the available topics, or the list of topics that meet the request query parameters. The topics returned are limited to those records the requestor is authorized to view.
* @summary List of topics

@@ -276,3 +276,3 @@ * @param {number} [offset] The page offset

/**
* Returns a list of all of the available topics, or the list of topics that meet the users URL Query Parameters.
* Returns a list of all of the available topics, or the list of topics that meet the request query parameters. The topics returned are limited to those records the requestor is authorized to view.
* @summary List of topics

@@ -279,0 +279,0 @@ * @param {number} [offset] The page offset

76

dist/generated/api/topics-api.js

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

// verify required parameter 'newTopicInput' is not null or undefined
common_1.assertParamExists('createTopic', 'newTopicInput', newTopicInput);
(0, common_1.assertParamExists)('createTopic', 'newTopicInput', newTopicInput);
const localVarPath = `/topics`;

@@ -61,10 +61,10 @@ // use dummy base URL string because the URL constructor only accepts absolute URLs.

// oauth required
yield common_1.setOAuthToObject(localVarHeaderParameter, "Bearer", [], configuration);
yield (0, common_1.setOAuthToObject)(localVarHeaderParameter, "Bearer", [], configuration);
localVarHeaderParameter['Content-Type'] = 'application/json';
common_1.setSearchParams(localVarUrlObj, localVarQueryParameter, options.query);
(0, common_1.setSearchParams)(localVarUrlObj, localVarQueryParameter, options.query);
let headersFromBaseOptions = baseOptions && baseOptions.headers ? baseOptions.headers : {};
localVarRequestOptions.headers = Object.assign(Object.assign(Object.assign({}, localVarHeaderParameter), headersFromBaseOptions), options.headers);
localVarRequestOptions.data = common_1.serializeDataIfNeeded(newTopicInput, localVarRequestOptions, configuration);
localVarRequestOptions.data = (0, common_1.serializeDataIfNeeded)(newTopicInput, localVarRequestOptions, configuration);
return {
url: common_1.toPathString(localVarUrlObj),
url: (0, common_1.toPathString)(localVarUrlObj),
options: localVarRequestOptions,

@@ -82,3 +82,3 @@ };

// verify required parameter 'topicName' is not null or undefined
common_1.assertParamExists('deleteTopic', 'topicName', topicName);
(0, common_1.assertParamExists)('deleteTopic', 'topicName', topicName);
const localVarPath = `/topics/{topicName}`

@@ -97,8 +97,8 @@ .replace(`{${"topicName"}}`, encodeURIComponent(String(topicName)));

// oauth required
yield common_1.setOAuthToObject(localVarHeaderParameter, "Bearer", [], configuration);
common_1.setSearchParams(localVarUrlObj, localVarQueryParameter, options.query);
yield (0, common_1.setOAuthToObject)(localVarHeaderParameter, "Bearer", [], configuration);
(0, common_1.setSearchParams)(localVarUrlObj, localVarQueryParameter, options.query);
let headersFromBaseOptions = baseOptions && baseOptions.headers ? baseOptions.headers : {};
localVarRequestOptions.headers = Object.assign(Object.assign(Object.assign({}, localVarHeaderParameter), headersFromBaseOptions), options.headers);
return {
url: common_1.toPathString(localVarUrlObj),
url: (0, common_1.toPathString)(localVarUrlObj),
options: localVarRequestOptions,

@@ -116,3 +116,3 @@ };

// verify required parameter 'topicName' is not null or undefined
common_1.assertParamExists('getTopic', 'topicName', topicName);
(0, common_1.assertParamExists)('getTopic', 'topicName', topicName);
const localVarPath = `/topics/{topicName}`

@@ -131,8 +131,8 @@ .replace(`{${"topicName"}}`, encodeURIComponent(String(topicName)));

// oauth required
yield common_1.setOAuthToObject(localVarHeaderParameter, "Bearer", [], configuration);
common_1.setSearchParams(localVarUrlObj, localVarQueryParameter, options.query);
yield (0, common_1.setOAuthToObject)(localVarHeaderParameter, "Bearer", [], configuration);
(0, common_1.setSearchParams)(localVarUrlObj, localVarQueryParameter, options.query);
let headersFromBaseOptions = baseOptions && baseOptions.headers ? baseOptions.headers : {};
localVarRequestOptions.headers = Object.assign(Object.assign(Object.assign({}, localVarHeaderParameter), headersFromBaseOptions), options.headers);
return {
url: common_1.toPathString(localVarUrlObj),
url: (0, common_1.toPathString)(localVarUrlObj),
options: localVarRequestOptions,

@@ -142,3 +142,3 @@ };

/**
* Returns a list of all of the available topics, or the list of topics that meet the users URL Query Parameters.
* Returns a list of all of the available topics, or the list of topics that meet the request query parameters. The topics returned are limited to those records the requestor is authorized to view.
* @summary List of topics

@@ -168,3 +168,3 @@ * @param {number} [offset] The page offset

// oauth required
yield common_1.setOAuthToObject(localVarHeaderParameter, "Bearer", [], configuration);
yield (0, common_1.setOAuthToObject)(localVarHeaderParameter, "Bearer", [], configuration);
if (offset !== undefined) {

@@ -191,7 +191,7 @@ localVarQueryParameter['offset'] = offset;

}
common_1.setSearchParams(localVarUrlObj, localVarQueryParameter, options.query);
(0, common_1.setSearchParams)(localVarUrlObj, localVarQueryParameter, options.query);
let headersFromBaseOptions = baseOptions && baseOptions.headers ? baseOptions.headers : {};
localVarRequestOptions.headers = Object.assign(Object.assign(Object.assign({}, localVarHeaderParameter), headersFromBaseOptions), options.headers);
return {
url: common_1.toPathString(localVarUrlObj),
url: (0, common_1.toPathString)(localVarUrlObj),
options: localVarRequestOptions,

@@ -210,5 +210,5 @@ };

// verify required parameter 'topicName' is not null or undefined
common_1.assertParamExists('updateTopic', 'topicName', topicName);
(0, common_1.assertParamExists)('updateTopic', 'topicName', topicName);
// verify required parameter 'updateTopicInput' is not null or undefined
common_1.assertParamExists('updateTopic', 'updateTopicInput', updateTopicInput);
(0, common_1.assertParamExists)('updateTopic', 'updateTopicInput', updateTopicInput);
const localVarPath = `/topics/{topicName}`

@@ -227,10 +227,10 @@ .replace(`{${"topicName"}}`, encodeURIComponent(String(topicName)));

// oauth required
yield common_1.setOAuthToObject(localVarHeaderParameter, "Bearer", [], configuration);
yield (0, common_1.setOAuthToObject)(localVarHeaderParameter, "Bearer", [], configuration);
localVarHeaderParameter['Content-Type'] = 'application/json';
common_1.setSearchParams(localVarUrlObj, localVarQueryParameter, options.query);
(0, common_1.setSearchParams)(localVarUrlObj, localVarQueryParameter, options.query);
let headersFromBaseOptions = baseOptions && baseOptions.headers ? baseOptions.headers : {};
localVarRequestOptions.headers = Object.assign(Object.assign(Object.assign({}, localVarHeaderParameter), headersFromBaseOptions), options.headers);
localVarRequestOptions.data = common_1.serializeDataIfNeeded(updateTopicInput, localVarRequestOptions, configuration);
localVarRequestOptions.data = (0, common_1.serializeDataIfNeeded)(updateTopicInput, localVarRequestOptions, configuration);
return {
url: common_1.toPathString(localVarUrlObj),
url: (0, common_1.toPathString)(localVarUrlObj),
options: localVarRequestOptions,

@@ -247,3 +247,3 @@ };

const TopicsApiFp = function (configuration) {
const localVarAxiosParamCreator = exports.TopicsApiAxiosParamCreator(configuration);
const localVarAxiosParamCreator = (0, exports.TopicsApiAxiosParamCreator)(configuration);
return {

@@ -260,3 +260,3 @@ /**

const localVarAxiosArgs = yield localVarAxiosParamCreator.createTopic(newTopicInput, options);
return common_1.createRequestFunction(localVarAxiosArgs, axios_1.default, base_1.BASE_PATH, configuration);
return (0, common_1.createRequestFunction)(localVarAxiosArgs, axios_1.default, base_1.BASE_PATH, configuration);
});

@@ -274,3 +274,3 @@ },

const localVarAxiosArgs = yield localVarAxiosParamCreator.deleteTopic(topicName, options);
return common_1.createRequestFunction(localVarAxiosArgs, axios_1.default, base_1.BASE_PATH, configuration);
return (0, common_1.createRequestFunction)(localVarAxiosArgs, axios_1.default, base_1.BASE_PATH, configuration);
});

@@ -288,7 +288,7 @@ },

const localVarAxiosArgs = yield localVarAxiosParamCreator.getTopic(topicName, options);
return common_1.createRequestFunction(localVarAxiosArgs, axios_1.default, base_1.BASE_PATH, configuration);
return (0, common_1.createRequestFunction)(localVarAxiosArgs, axios_1.default, base_1.BASE_PATH, configuration);
});
},
/**
* Returns a list of all of the available topics, or the list of topics that meet the users URL Query Parameters.
* Returns a list of all of the available topics, or the list of topics that meet the request query parameters. The topics returned are limited to those records the requestor is authorized to view.
* @summary List of topics

@@ -308,3 +308,3 @@ * @param {number} [offset] The page offset

const localVarAxiosArgs = yield localVarAxiosParamCreator.getTopics(offset, limit, size, filter, page, order, orderKey, options);
return common_1.createRequestFunction(localVarAxiosArgs, axios_1.default, base_1.BASE_PATH, configuration);
return (0, common_1.createRequestFunction)(localVarAxiosArgs, axios_1.default, base_1.BASE_PATH, configuration);
});

@@ -323,3 +323,3 @@ },

const localVarAxiosArgs = yield localVarAxiosParamCreator.updateTopic(topicName, updateTopicInput, options);
return common_1.createRequestFunction(localVarAxiosArgs, axios_1.default, base_1.BASE_PATH, configuration);
return (0, common_1.createRequestFunction)(localVarAxiosArgs, axios_1.default, base_1.BASE_PATH, configuration);
});

@@ -335,3 +335,3 @@ },

const TopicsApiFactory = function (configuration, basePath, axios) {
const localVarFp = exports.TopicsApiFp(configuration);
const localVarFp = (0, exports.TopicsApiFp)(configuration);
return {

@@ -369,3 +369,3 @@ /**

/**
* Returns a list of all of the available topics, or the list of topics that meet the users URL Query Parameters.
* Returns a list of all of the available topics, or the list of topics that meet the request query parameters. The topics returned are limited to those records the requestor is authorized to view.
* @summary List of topics

@@ -415,3 +415,3 @@ * @param {number} [offset] The page offset

createTopic(newTopicInput, options) {
return exports.TopicsApiFp(this.configuration).createTopic(newTopicInput, options).then((request) => request(this.axios, this.basePath));
return (0, exports.TopicsApiFp)(this.configuration).createTopic(newTopicInput, options).then((request) => request(this.axios, this.basePath));
}

@@ -427,3 +427,3 @@ /**

deleteTopic(topicName, options) {
return exports.TopicsApiFp(this.configuration).deleteTopic(topicName, options).then((request) => request(this.axios, this.basePath));
return (0, exports.TopicsApiFp)(this.configuration).deleteTopic(topicName, options).then((request) => request(this.axios, this.basePath));
}

@@ -439,6 +439,6 @@ /**

getTopic(topicName, options) {
return exports.TopicsApiFp(this.configuration).getTopic(topicName, options).then((request) => request(this.axios, this.basePath));
return (0, exports.TopicsApiFp)(this.configuration).getTopic(topicName, options).then((request) => request(this.axios, this.basePath));
}
/**
* Returns a list of all of the available topics, or the list of topics that meet the users URL Query Parameters.
* Returns a list of all of the available topics, or the list of topics that meet the request query parameters. The topics returned are limited to those records the requestor is authorized to view.
* @summary List of topics

@@ -457,3 +457,3 @@ * @param {number} [offset] The page offset

getTopics(offset, limit, size, filter, page, order, orderKey, options) {
return exports.TopicsApiFp(this.configuration).getTopics(offset, limit, size, filter, page, order, orderKey, options).then((request) => request(this.axios, this.basePath));
return (0, exports.TopicsApiFp)(this.configuration).getTopics(offset, limit, size, filter, page, order, orderKey, options).then((request) => request(this.axios, this.basePath));
}

@@ -470,5 +470,5 @@ /**

updateTopic(topicName, updateTopicInput, options) {
return exports.TopicsApiFp(this.configuration).updateTopic(topicName, updateTopicInput, options).then((request) => request(this.axios, this.basePath));
return (0, exports.TopicsApiFp)(this.configuration).updateTopic(topicName, updateTopicInput, options).then((request) => request(this.axios, this.basePath));
}
}
exports.TopicsApi = TopicsApi;

2

dist/generated/common.d.ts

@@ -65,2 +65,2 @@ /**

*/
export declare const createRequestFunction: (axiosArgs: RequestArgs, globalAxios: AxiosInstance, BASE_PATH: string, configuration?: Configuration) => (axios?: AxiosInstance, basePath?: string) => Promise<import("axios").AxiosResponse<any>>;
export declare const createRequestFunction: (axiosArgs: RequestArgs, globalAxios: AxiosInstance, BASE_PATH: string, configuration?: Configuration) => (axios?: AxiosInstance, basePath?: string) => Promise<import("axios").AxiosResponse<never>>;

8

package.json
{
"name": "@rhoas/kafka-instance-sdk",
"version": "0.12.3",
"version": "0.14.0",
"description": "RHOAS Kafka Instance Adminstration SDK",

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

"dependencies": {
"axios": "0.21.1"
"axios": "0.22.0"
},
"devDependencies": {
"@types/node": "14.17.11",
"typescript": "4.3.5"
"@types/node": "14.17.21",
"typescript": "4.4.3"
}
}

30

src/generated/api/groups-api.ts

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

/**
* Returns a list of all consumer groups for a particular Kafka instance.
* Returns a list of all consumer groups for a particular Kafka instance. The consumer groups returned are limited to those records the requestor is authorized to view.
* @summary List of consumer groups in the Kafka instance.

@@ -141,4 +141,4 @@ * @param {number} [offset] The page offset

* @param {number} [page] The page when returning the list of consumer groups
* @param {string} [topic] Return consumer groups for this topic
* @param {string} [groupIdFilter] Return the consumer groups where the ID begins with this value
* @param {string} [topic] Return consumer groups where the topic name contains with this value
* @param {string} [groupIdFilter] Return the consumer groups where the ID contains with this value
* @param {'asc' | 'desc'} [order] Order of the consumer groups sorting. Ascending order is used as default.

@@ -290,3 +290,3 @@ * @param {'name'} [orderKey] Order key to sort the items by. Only the value \&#39;name\&#39; is currently applicable.

/**
* Returns a list of all consumer groups for a particular Kafka instance.
* Returns a list of all consumer groups for a particular Kafka instance. The consumer groups returned are limited to those records the requestor is authorized to view.
* @summary List of consumer groups in the Kafka instance.

@@ -297,4 +297,4 @@ * @param {number} [offset] The page offset

* @param {number} [page] The page when returning the list of consumer groups
* @param {string} [topic] Return consumer groups for this topic
* @param {string} [groupIdFilter] Return the consumer groups where the ID begins with this value
* @param {string} [topic] Return consumer groups where the topic name contains with this value
* @param {string} [groupIdFilter] Return the consumer groups where the ID contains with this value
* @param {'asc' | 'desc'} [order] Order of the consumer groups sorting. Ascending order is used as default.

@@ -356,3 +356,3 @@ * @param {'name'} [orderKey] Order key to sort the items by. Only the value \&#39;name\&#39; is currently applicable.

/**
* Returns a list of all consumer groups for a particular Kafka instance.
* Returns a list of all consumer groups for a particular Kafka instance. The consumer groups returned are limited to those records the requestor is authorized to view.
* @summary List of consumer groups in the Kafka instance.

@@ -363,4 +363,4 @@ * @param {number} [offset] The page offset

* @param {number} [page] The page when returning the list of consumer groups
* @param {string} [topic] Return consumer groups for this topic
* @param {string} [groupIdFilter] Return the consumer groups where the ID begins with this value
* @param {string} [topic] Return consumer groups where the topic name contains with this value
* @param {string} [groupIdFilter] Return the consumer groups where the ID contains with this value
* @param {'asc' | 'desc'} [order] Order of the consumer groups sorting. Ascending order is used as default.

@@ -419,3 +419,3 @@ * @param {'name'} [orderKey] Order key to sort the items by. Only the value \&#39;name\&#39; is currently applicable.

/**
* Returns a list of all consumer groups for a particular Kafka instance.
* Returns a list of all consumer groups for a particular Kafka instance. The consumer groups returned are limited to those records the requestor is authorized to view.
* @summary List of consumer groups in the Kafka instance.

@@ -426,4 +426,4 @@ * @param {number} [offset] The page offset

* @param {number} [page] The page when returning the list of consumer groups
* @param {string} [topic] Return consumer groups for this topic
* @param {string} [groupIdFilter] Return the consumer groups where the ID begins with this value
* @param {string} [topic] Return consumer groups where the topic name contains with this value
* @param {string} [groupIdFilter] Return the consumer groups where the ID contains with this value
* @param {'asc' | 'desc'} [order] Order of the consumer groups sorting. Ascending order is used as default.

@@ -486,3 +486,3 @@ * @param {'name'} [orderKey] Order key to sort the items by. Only the value \&#39;name\&#39; is currently applicable.

/**
* Returns a list of all consumer groups for a particular Kafka instance.
* Returns a list of all consumer groups for a particular Kafka instance. The consumer groups returned are limited to those records the requestor is authorized to view.
* @summary List of consumer groups in the Kafka instance.

@@ -493,4 +493,4 @@ * @param {number} [offset] The page offset

* @param {number} [page] The page when returning the list of consumer groups
* @param {string} [topic] Return consumer groups for this topic
* @param {string} [groupIdFilter] Return the consumer groups where the ID begins with this value
* @param {string} [topic] Return consumer groups where the topic name contains with this value
* @param {string} [groupIdFilter] Return the consumer groups where the ID contains with this value
* @param {'asc' | 'desc'} [order] Order of the consumer groups sorting. Ascending order is used as default.

@@ -497,0 +497,0 @@ * @param {'name'} [orderKey] Order key to sort the items by. Only the value \&#39;name\&#39; is currently applicable.

10

src/generated/api/topics-api.ts

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

/**
* Returns a list of all of the available topics, or the list of topics that meet the users URL Query Parameters.
* Returns a list of all of the available topics, or the list of topics that meet the request query parameters. The topics returned are limited to those records the requestor is authorized to view.
* @summary List of topics

@@ -311,3 +311,3 @@ * @param {number} [offset] The page offset

/**
* Returns a list of all of the available topics, or the list of topics that meet the users URL Query Parameters.
* Returns a list of all of the available topics, or the list of topics that meet the request query parameters. The topics returned are limited to those records the requestor is authorized to view.
* @summary List of topics

@@ -381,3 +381,3 @@ * @param {number} [offset] The page offset

/**
* Returns a list of all of the available topics, or the list of topics that meet the users URL Query Parameters.
* Returns a list of all of the available topics, or the list of topics that meet the request query parameters. The topics returned are limited to those records the requestor is authorized to view.
* @summary List of topics

@@ -448,3 +448,3 @@ * @param {number} [offset] The page offset

/**
* Returns a list of all of the available topics, or the list of topics that meet the users URL Query Parameters.
* Returns a list of all of the available topics, or the list of topics that meet the request query parameters. The topics returned are limited to those records the requestor is authorized to view.
* @summary List of topics

@@ -521,3 +521,3 @@ * @param {number} [offset] The page offset

/**
* Returns a list of all of the available topics, or the list of topics that meet the users URL Query Parameters.
* Returns a list of all of the available topics, or the list of topics that meet the request query parameters. The topics returned are limited to those records the requestor is authorized to view.
* @summary List of topics

@@ -524,0 +524,0 @@ * @param {number} [offset] The page offset

SocketSocket SOC 2 Logo

Product

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

About

Packages

npm

Go

Maven

PyPI

Rubygems

Stay in touch

Get open source security insights delivered straight into your inbox.

  • Terms
  • Privacy
  • Security

Made with ⚡️ by Socket Inc