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.23.2 to 0.24.0

34

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

@@ -12,3 +12,3 @@ /**

*/
import { AxiosPromise, AxiosInstance } from 'axios';
import { AxiosPromise, AxiosInstance, AxiosRequestConfig } from 'axios';
import { Configuration } from '../configuration';

@@ -34,3 +34,3 @@ import { RequestArgs, BaseAPI } from '../base';

*/
createAcl: (aclBinding: AclBinding, options?: any) => Promise<RequestArgs>;
createAcl: (aclBinding: AclBinding, options?: AxiosRequestConfig) => Promise<RequestArgs>;
/**

@@ -48,3 +48,3 @@ * Deletes ACL bindings that match the query parameters.

*/
deleteAcls: (resourceType?: AclResourceTypeFilter, resourceName?: string, patternType?: AclPatternTypeFilter, principal?: string, operation?: AclOperationFilter, permission?: AclPermissionTypeFilter, options?: any) => Promise<RequestArgs>;
deleteAcls: (resourceType?: AclResourceTypeFilter, resourceName?: string, patternType?: AclPatternTypeFilter, principal?: string, operation?: AclOperationFilter, permission?: AclPermissionTypeFilter, options?: AxiosRequestConfig) => Promise<RequestArgs>;
/**

@@ -56,3 +56,3 @@ * Retrieve the resources and associated operations that may have ACLs configured.

*/
getAclResourceOperations: (options?: any) => Promise<RequestArgs>;
getAclResourceOperations: (options?: AxiosRequestConfig) => Promise<RequestArgs>;
/**

@@ -74,3 +74,3 @@ * Returns a list of all of the available ACL bindings, or the list of bindings that meet the users URL Query Parameters. If no parameters are specified, all ACL bindings known to the system will be returned (with paging).

*/
getAcls: (resourceType?: AclResourceTypeFilter, resourceName?: string, patternType?: AclPatternTypeFilter, principal?: string, operation?: AclOperationFilter, permission?: AclPermissionTypeFilter, page?: number, size?: number, order?: 'asc' | 'desc', orderKey?: 'resourceType' | 'resourceName' | 'patternType' | 'principal' | 'operation' | 'permission', options?: any) => Promise<RequestArgs>;
getAcls: (resourceType?: AclResourceTypeFilter, resourceName?: string, patternType?: AclPatternTypeFilter, principal?: string, operation?: AclOperationFilter, permission?: AclPermissionTypeFilter, page?: number, size?: number, order?: 'asc' | 'desc', orderKey?: 'resourceType' | 'resourceName' | 'patternType' | 'principal' | 'operation' | 'permission', options?: AxiosRequestConfig) => Promise<RequestArgs>;
};

@@ -89,3 +89,3 @@ /**

*/
createAcl(aclBinding: AclBinding, options?: any): Promise<(axios?: AxiosInstance, basePath?: string) => AxiosPromise<void>>;
createAcl(aclBinding: AclBinding, options?: AxiosRequestConfig): Promise<(axios?: AxiosInstance, basePath?: string) => AxiosPromise<void>>;
/**

@@ -103,3 +103,3 @@ * Deletes ACL bindings that match the query parameters.

*/
deleteAcls(resourceType?: AclResourceTypeFilter, resourceName?: string, patternType?: AclPatternTypeFilter, principal?: string, operation?: AclOperationFilter, permission?: AclPermissionTypeFilter, options?: any): Promise<(axios?: AxiosInstance, basePath?: string) => AxiosPromise<AclBindingListPage>>;
deleteAcls(resourceType?: AclResourceTypeFilter, resourceName?: string, patternType?: AclPatternTypeFilter, principal?: string, operation?: AclOperationFilter, permission?: AclPermissionTypeFilter, options?: AxiosRequestConfig): Promise<(axios?: AxiosInstance, basePath?: string) => AxiosPromise<AclBindingListPage>>;
/**

@@ -111,3 +111,3 @@ * Retrieve the resources and associated operations that may have ACLs configured.

*/
getAclResourceOperations(options?: any): Promise<(axios?: AxiosInstance, basePath?: string) => AxiosPromise<{
getAclResourceOperations(options?: AxiosRequestConfig): Promise<(axios?: AxiosInstance, basePath?: string) => AxiosPromise<{
[key: string]: string[];

@@ -131,3 +131,3 @@ }>>;

*/
getAcls(resourceType?: AclResourceTypeFilter, resourceName?: string, patternType?: AclPatternTypeFilter, principal?: string, operation?: AclOperationFilter, permission?: AclPermissionTypeFilter, page?: number, size?: number, order?: 'asc' | 'desc', orderKey?: 'resourceType' | 'resourceName' | 'patternType' | 'principal' | 'operation' | 'permission', options?: any): Promise<(axios?: AxiosInstance, basePath?: string) => AxiosPromise<AclBindingListPage>>;
getAcls(resourceType?: AclResourceTypeFilter, resourceName?: string, patternType?: AclPatternTypeFilter, principal?: string, operation?: AclOperationFilter, permission?: AclPermissionTypeFilter, page?: number, size?: number, order?: 'asc' | 'desc', orderKey?: 'resourceType' | 'resourceName' | 'patternType' | 'principal' | 'operation' | 'permission', options?: AxiosRequestConfig): Promise<(axios?: AxiosInstance, basePath?: string) => AxiosPromise<AclBindingListPage>>;
};

@@ -201,3 +201,3 @@ /**

*/
createAcl(aclBinding: AclBinding, options?: any): AxiosPromise<void>;
createAcl(aclBinding: AclBinding, options?: AxiosRequestConfig): AxiosPromise<void>;
/**

@@ -216,3 +216,3 @@ * Deletes ACL bindings that match the query parameters.

*/
deleteAcls(resourceType?: AclResourceTypeFilter, resourceName?: string, patternType?: AclPatternTypeFilter, principal?: string, operation?: AclOperationFilter, permission?: AclPermissionTypeFilter, options?: any): AxiosPromise<AclBindingListPage>;
deleteAcls(resourceType?: AclResourceTypeFilter, resourceName?: string, patternType?: AclPatternTypeFilter, principal?: string, operation?: AclOperationFilter, permission?: AclPermissionTypeFilter, options?: AxiosRequestConfig): AxiosPromise<AclBindingListPage>;
/**

@@ -225,3 +225,3 @@ * Retrieve the resources and associated operations that may have ACLs configured.

*/
getAclResourceOperations(options?: any): AxiosPromise<{
getAclResourceOperations(options?: AxiosRequestConfig): AxiosPromise<{
[key: string]: Array<string>;

@@ -246,3 +246,3 @@ }>;

*/
getAcls(resourceType?: AclResourceTypeFilter, resourceName?: string, patternType?: AclPatternTypeFilter, principal?: string, operation?: AclOperationFilter, permission?: AclPermissionTypeFilter, page?: number, size?: number, order?: 'asc' | 'desc', orderKey?: 'resourceType' | 'resourceName' | 'patternType' | 'principal' | 'operation' | 'permission', options?: any): AxiosPromise<AclBindingListPage>;
getAcls(resourceType?: AclResourceTypeFilter, resourceName?: string, patternType?: AclPatternTypeFilter, principal?: string, operation?: AclOperationFilter, permission?: AclPermissionTypeFilter, page?: number, size?: number, order?: 'asc' | 'desc', orderKey?: 'resourceType' | 'resourceName' | 'patternType' | 'principal' | 'operation' | 'permission', options?: AxiosRequestConfig): AxiosPromise<AclBindingListPage>;
}

@@ -264,3 +264,3 @@ /**

*/
createAcl(aclBinding: AclBinding, options?: any): Promise<import("axios").AxiosResponse<void, any>>;
createAcl(aclBinding: AclBinding, options?: AxiosRequestConfig): Promise<import("axios").AxiosResponse<void, any>>;
/**

@@ -279,3 +279,3 @@ * Deletes ACL bindings that match the query parameters.

*/
deleteAcls(resourceType?: AclResourceTypeFilter, resourceName?: string, patternType?: AclPatternTypeFilter, principal?: string, operation?: AclOperationFilter, permission?: AclPermissionTypeFilter, options?: any): Promise<import("axios").AxiosResponse<AclBindingListPage, any>>;
deleteAcls(resourceType?: AclResourceTypeFilter, resourceName?: string, patternType?: AclPatternTypeFilter, principal?: string, operation?: AclOperationFilter, permission?: AclPermissionTypeFilter, options?: AxiosRequestConfig): Promise<import("axios").AxiosResponse<AclBindingListPage, any>>;
/**

@@ -288,3 +288,3 @@ * Retrieve the resources and associated operations that may have ACLs configured.

*/
getAclResourceOperations(options?: any): Promise<import("axios").AxiosResponse<{
getAclResourceOperations(options?: AxiosRequestConfig): Promise<import("axios").AxiosResponse<{
[key: string]: string[];

@@ -309,3 +309,3 @@ }, any>>;

*/
getAcls(resourceType?: AclResourceTypeFilter, resourceName?: string, patternType?: AclPatternTypeFilter, principal?: string, operation?: AclOperationFilter, permission?: AclPermissionTypeFilter, page?: number, size?: number, order?: 'asc' | 'desc', orderKey?: 'resourceType' | 'resourceName' | 'patternType' | 'principal' | 'operation' | 'permission', options?: any): Promise<import("axios").AxiosResponse<AclBindingListPage, any>>;
getAcls(resourceType?: AclResourceTypeFilter, resourceName?: string, patternType?: AclPatternTypeFilter, principal?: string, operation?: AclOperationFilter, permission?: AclPermissionTypeFilter, page?: number, size?: number, order?: 'asc' | 'desc', orderKey?: 'resourceType' | 'resourceName' | 'patternType' | 'principal' | 'operation' | 'permission', options?: AxiosRequestConfig): Promise<import("axios").AxiosResponse<AclBindingListPage, any>>;
}

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

localVarHeaderParameter['Content-Type'] = 'application/json';
(0, common_1.setSearchParams)(localVarUrlObj, localVarQueryParameter, options.query);
(0, common_1.setSearchParams)(localVarUrlObj, localVarQueryParameter);
let headersFromBaseOptions = baseOptions && baseOptions.headers ? baseOptions.headers : {};

@@ -116,3 +116,3 @@ localVarRequestOptions.headers = Object.assign(Object.assign(Object.assign({}, localVarHeaderParameter), headersFromBaseOptions), options.headers);

}
(0, common_1.setSearchParams)(localVarUrlObj, localVarQueryParameter, options.query);
(0, common_1.setSearchParams)(localVarUrlObj, localVarQueryParameter);
let headersFromBaseOptions = baseOptions && baseOptions.headers ? baseOptions.headers : {};

@@ -145,3 +145,3 @@ localVarRequestOptions.headers = Object.assign(Object.assign(Object.assign({}, localVarHeaderParameter), headersFromBaseOptions), options.headers);

yield (0, common_1.setOAuthToObject)(localVarHeaderParameter, "Bearer", [], configuration);
(0, common_1.setSearchParams)(localVarUrlObj, localVarQueryParameter, options.query);
(0, common_1.setSearchParams)(localVarUrlObj, localVarQueryParameter);
let headersFromBaseOptions = baseOptions && baseOptions.headers ? baseOptions.headers : {};

@@ -214,3 +214,3 @@ localVarRequestOptions.headers = Object.assign(Object.assign(Object.assign({}, localVarHeaderParameter), headersFromBaseOptions), options.headers);

}
(0, common_1.setSearchParams)(localVarUrlObj, localVarQueryParameter, options.query);
(0, common_1.setSearchParams)(localVarUrlObj, localVarQueryParameter);
let headersFromBaseOptions = baseOptions && baseOptions.headers ? baseOptions.headers : {};

@@ -217,0 +217,0 @@ localVarRequestOptions.headers = Object.assign(Object.assign(Object.assign({}, localVarHeaderParameter), headersFromBaseOptions), options.headers);

@@ -12,3 +12,3 @@ /**

*/
import { AxiosPromise, AxiosInstance } from 'axios';
import { AxiosPromise, AxiosInstance, AxiosRequestConfig } from 'axios';
import { Configuration } from '../configuration';

@@ -32,3 +32,3 @@ import { RequestArgs, BaseAPI } from '../base';

*/
deleteConsumerGroupById: (consumerGroupId: string, options?: any) => Promise<RequestArgs>;
deleteConsumerGroupById: (consumerGroupId: string, options?: AxiosRequestConfig) => Promise<RequestArgs>;
/**

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

*/
getConsumerGroupById: (consumerGroupId: string, order?: 'asc' | 'desc', orderKey?: 'offset' | 'endOffset' | 'lag' | 'partition', partitionFilter?: number, topic?: string, options?: any) => Promise<RequestArgs>;
getConsumerGroupById: (consumerGroupId: string, order?: 'asc' | 'desc', orderKey?: 'offset' | 'endOffset' | 'lag' | 'partition', partitionFilter?: number, topic?: string, options?: AxiosRequestConfig) => Promise<RequestArgs>;
/**

@@ -61,3 +61,3 @@ * 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.

*/
getConsumerGroups: (offset?: number, limit?: number, size?: number, page?: number, topic?: string, groupIdFilter?: string, order?: 'asc' | 'desc', orderKey?: 'name', options?: any) => Promise<RequestArgs>;
getConsumerGroups: (offset?: number, limit?: number, size?: number, page?: number, topic?: string, groupIdFilter?: string, order?: 'asc' | 'desc', orderKey?: 'name', options?: AxiosRequestConfig) => Promise<RequestArgs>;
/**

@@ -71,3 +71,3 @@ * Reset the offset for a particular consumer group.

*/
resetConsumerGroupOffset: (consumerGroupId: string, consumerGroupResetOffsetParameters: ConsumerGroupResetOffsetParameters, options?: any) => Promise<RequestArgs>;
resetConsumerGroupOffset: (consumerGroupId: string, consumerGroupResetOffsetParameters: ConsumerGroupResetOffsetParameters, options?: AxiosRequestConfig) => Promise<RequestArgs>;
};

@@ -86,3 +86,3 @@ /**

*/
deleteConsumerGroupById(consumerGroupId: string, options?: any): Promise<(axios?: AxiosInstance, basePath?: string) => AxiosPromise<void>>;
deleteConsumerGroupById(consumerGroupId: string, options?: AxiosRequestConfig): Promise<(axios?: AxiosInstance, basePath?: string) => AxiosPromise<void>>;
/**

@@ -99,3 +99,3 @@ *

*/
getConsumerGroupById(consumerGroupId: string, order?: 'asc' | 'desc', orderKey?: 'offset' | 'endOffset' | 'lag' | 'partition', partitionFilter?: number, topic?: string, options?: any): Promise<(axios?: AxiosInstance, basePath?: string) => AxiosPromise<ConsumerGroup>>;
getConsumerGroupById(consumerGroupId: string, order?: 'asc' | 'desc', orderKey?: 'offset' | 'endOffset' | 'lag' | 'partition', partitionFilter?: number, topic?: string, options?: AxiosRequestConfig): Promise<(axios?: AxiosInstance, basePath?: string) => AxiosPromise<ConsumerGroup>>;
/**

@@ -115,3 +115,3 @@ * 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.

*/
getConsumerGroups(offset?: number, limit?: number, size?: number, page?: number, topic?: string, groupIdFilter?: string, order?: 'asc' | 'desc', orderKey?: 'name', options?: any): Promise<(axios?: AxiosInstance, basePath?: string) => AxiosPromise<ConsumerGroupList>>;
getConsumerGroups(offset?: number, limit?: number, size?: number, page?: number, topic?: string, groupIdFilter?: string, order?: 'asc' | 'desc', orderKey?: 'name', options?: AxiosRequestConfig): Promise<(axios?: AxiosInstance, basePath?: string) => AxiosPromise<ConsumerGroupList>>;
/**

@@ -125,3 +125,3 @@ * Reset the offset for a particular consumer group.

*/
resetConsumerGroupOffset(consumerGroupId: string, consumerGroupResetOffsetParameters: ConsumerGroupResetOffsetParameters, options?: any): Promise<(axios?: AxiosInstance, basePath?: string) => AxiosPromise<ConsumerGroupResetOffsetResult>>;
resetConsumerGroupOffset(consumerGroupId: string, consumerGroupResetOffsetParameters: ConsumerGroupResetOffsetParameters, options?: AxiosRequestConfig): Promise<(axios?: AxiosInstance, basePath?: string) => AxiosPromise<ConsumerGroupResetOffsetResult>>;
};

@@ -192,3 +192,3 @@ /**

*/
deleteConsumerGroupById(consumerGroupId: string, options?: any): AxiosPromise<void>;
deleteConsumerGroupById(consumerGroupId: string, options?: AxiosRequestConfig): AxiosPromise<void>;
/**

@@ -206,3 +206,3 @@ *

*/
getConsumerGroupById(consumerGroupId: string, order?: 'asc' | 'desc', orderKey?: 'offset' | 'endOffset' | 'lag' | 'partition', partitionFilter?: number, topic?: string, options?: any): AxiosPromise<ConsumerGroup>;
getConsumerGroupById(consumerGroupId: string, order?: 'asc' | 'desc', orderKey?: 'offset' | 'endOffset' | 'lag' | 'partition', partitionFilter?: number, topic?: string, options?: AxiosRequestConfig): AxiosPromise<ConsumerGroup>;
/**

@@ -223,3 +223,3 @@ * 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.

*/
getConsumerGroups(offset?: number, limit?: number, size?: number, page?: number, topic?: string, groupIdFilter?: string, order?: 'asc' | 'desc', orderKey?: 'name', options?: any): AxiosPromise<ConsumerGroupList>;
getConsumerGroups(offset?: number, limit?: number, size?: number, page?: number, topic?: string, groupIdFilter?: string, order?: 'asc' | 'desc', orderKey?: 'name', options?: AxiosRequestConfig): AxiosPromise<ConsumerGroupList>;
/**

@@ -234,3 +234,3 @@ * Reset the offset for a particular consumer group.

*/
resetConsumerGroupOffset(consumerGroupId: string, consumerGroupResetOffsetParameters: ConsumerGroupResetOffsetParameters, options?: any): AxiosPromise<ConsumerGroupResetOffsetResult>;
resetConsumerGroupOffset(consumerGroupId: string, consumerGroupResetOffsetParameters: ConsumerGroupResetOffsetParameters, options?: AxiosRequestConfig): AxiosPromise<ConsumerGroupResetOffsetResult>;
}

@@ -252,3 +252,3 @@ /**

*/
deleteConsumerGroupById(consumerGroupId: string, options?: any): Promise<import("axios").AxiosResponse<void, any>>;
deleteConsumerGroupById(consumerGroupId: string, options?: AxiosRequestConfig): Promise<import("axios").AxiosResponse<void, any>>;
/**

@@ -266,3 +266,3 @@ *

*/
getConsumerGroupById(consumerGroupId: string, order?: 'asc' | 'desc', orderKey?: 'offset' | 'endOffset' | 'lag' | 'partition', partitionFilter?: number, topic?: string, options?: any): Promise<import("axios").AxiosResponse<ConsumerGroup, any>>;
getConsumerGroupById(consumerGroupId: string, order?: 'asc' | 'desc', orderKey?: 'offset' | 'endOffset' | 'lag' | 'partition', partitionFilter?: number, topic?: string, options?: AxiosRequestConfig): Promise<import("axios").AxiosResponse<ConsumerGroup, any>>;
/**

@@ -283,3 +283,3 @@ * 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.

*/
getConsumerGroups(offset?: number, limit?: number, size?: number, page?: number, topic?: string, groupIdFilter?: string, order?: 'asc' | 'desc', orderKey?: 'name', options?: any): Promise<import("axios").AxiosResponse<ConsumerGroupList, any>>;
getConsumerGroups(offset?: number, limit?: number, size?: number, page?: number, topic?: string, groupIdFilter?: string, order?: 'asc' | 'desc', orderKey?: 'name', options?: AxiosRequestConfig): Promise<import("axios").AxiosResponse<ConsumerGroupList, any>>;
/**

@@ -294,3 +294,3 @@ * Reset the offset for a particular consumer group.

*/
resetConsumerGroupOffset(consumerGroupId: string, consumerGroupResetOffsetParameters: ConsumerGroupResetOffsetParameters, options?: any): Promise<import("axios").AxiosResponse<ConsumerGroupResetOffsetResult, any>>;
resetConsumerGroupOffset(consumerGroupId: string, consumerGroupResetOffsetParameters: ConsumerGroupResetOffsetParameters, options?: AxiosRequestConfig): Promise<import("axios").AxiosResponse<ConsumerGroupResetOffsetResult, any>>;
}

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

yield (0, common_1.setOAuthToObject)(localVarHeaderParameter, "Bearer", [], configuration);
(0, common_1.setSearchParams)(localVarUrlObj, localVarQueryParameter, options.query);
(0, common_1.setSearchParams)(localVarUrlObj, localVarQueryParameter);
let headersFromBaseOptions = baseOptions && baseOptions.headers ? baseOptions.headers : {};

@@ -111,3 +111,3 @@ localVarRequestOptions.headers = Object.assign(Object.assign(Object.assign({}, localVarHeaderParameter), headersFromBaseOptions), options.headers);

}
(0, common_1.setSearchParams)(localVarUrlObj, localVarQueryParameter, options.query);
(0, common_1.setSearchParams)(localVarUrlObj, localVarQueryParameter);
let headersFromBaseOptions = baseOptions && baseOptions.headers ? baseOptions.headers : {};

@@ -172,3 +172,3 @@ localVarRequestOptions.headers = Object.assign(Object.assign(Object.assign({}, localVarHeaderParameter), headersFromBaseOptions), options.headers);

}
(0, common_1.setSearchParams)(localVarUrlObj, localVarQueryParameter, options.query);
(0, common_1.setSearchParams)(localVarUrlObj, localVarQueryParameter);
let headersFromBaseOptions = baseOptions && baseOptions.headers ? baseOptions.headers : {};

@@ -209,3 +209,3 @@ localVarRequestOptions.headers = Object.assign(Object.assign(Object.assign({}, localVarHeaderParameter), headersFromBaseOptions), options.headers);

localVarHeaderParameter['Content-Type'] = 'application/json';
(0, common_1.setSearchParams)(localVarUrlObj, localVarQueryParameter, options.query);
(0, common_1.setSearchParams)(localVarUrlObj, localVarQueryParameter);
let headersFromBaseOptions = baseOptions && baseOptions.headers ? baseOptions.headers : {};

@@ -212,0 +212,0 @@ localVarRequestOptions.headers = Object.assign(Object.assign(Object.assign({}, localVarHeaderParameter), headersFromBaseOptions), options.headers);

@@ -12,3 +12,3 @@ /**

*/
import { AxiosPromise, AxiosInstance } from 'axios';
import { AxiosPromise, AxiosInstance, AxiosRequestConfig } from 'axios';
import { Configuration } from '../configuration';

@@ -32,3 +32,3 @@ import { RequestArgs, BaseAPI } from '../base';

*/
createTopic: (newTopicInput: NewTopicInput, options?: any) => Promise<RequestArgs>;
createTopic: (newTopicInput: NewTopicInput, options?: AxiosRequestConfig) => Promise<RequestArgs>;
/**

@@ -41,3 +41,3 @@ * Deletes the topic with the specified name.

*/
deleteTopic: (topicName: string, options?: any) => Promise<RequestArgs>;
deleteTopic: (topicName: string, options?: AxiosRequestConfig) => Promise<RequestArgs>;
/**

@@ -50,3 +50,3 @@ * Topic

*/
getTopic: (topicName: string, options?: any) => Promise<RequestArgs>;
getTopic: (topicName: string, options?: AxiosRequestConfig) => Promise<RequestArgs>;
/**

@@ -65,3 +65,3 @@ * 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.

*/
getTopics: (offset?: number, limit?: number, size?: number, filter?: string, page?: number, order?: 'asc' | 'desc', orderKey?: 'name' | 'partitions' | 'retention.ms' | 'retention.bytes', options?: any) => Promise<RequestArgs>;
getTopics: (offset?: number, limit?: number, size?: number, filter?: string, page?: number, order?: 'asc' | 'desc', orderKey?: 'name' | 'partitions' | 'retention.ms' | 'retention.bytes', options?: AxiosRequestConfig) => Promise<RequestArgs>;
/**

@@ -75,3 +75,3 @@ * updates the topic with the new data.

*/
updateTopic: (topicName: string, updateTopicInput: UpdateTopicInput, options?: any) => Promise<RequestArgs>;
updateTopic: (topicName: string, updateTopicInput: UpdateTopicInput, options?: AxiosRequestConfig) => Promise<RequestArgs>;
};

@@ -90,3 +90,3 @@ /**

*/
createTopic(newTopicInput: NewTopicInput, options?: any): Promise<(axios?: AxiosInstance, basePath?: string) => AxiosPromise<Topic>>;
createTopic(newTopicInput: NewTopicInput, options?: AxiosRequestConfig): Promise<(axios?: AxiosInstance, basePath?: string) => AxiosPromise<Topic>>;
/**

@@ -99,3 +99,3 @@ * Deletes the topic with the specified name.

*/
deleteTopic(topicName: string, options?: any): Promise<(axios?: AxiosInstance, basePath?: string) => AxiosPromise<void>>;
deleteTopic(topicName: string, options?: AxiosRequestConfig): Promise<(axios?: AxiosInstance, basePath?: string) => AxiosPromise<void>>;
/**

@@ -108,3 +108,3 @@ * Topic

*/
getTopic(topicName: string, options?: any): Promise<(axios?: AxiosInstance, basePath?: string) => AxiosPromise<Topic>>;
getTopic(topicName: string, options?: AxiosRequestConfig): Promise<(axios?: AxiosInstance, basePath?: string) => AxiosPromise<Topic>>;
/**

@@ -123,3 +123,3 @@ * 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.

*/
getTopics(offset?: number, limit?: number, size?: number, filter?: string, page?: number, order?: 'asc' | 'desc', orderKey?: 'name' | 'partitions' | 'retention.ms' | 'retention.bytes', options?: any): Promise<(axios?: AxiosInstance, basePath?: string) => AxiosPromise<TopicsList>>;
getTopics(offset?: number, limit?: number, size?: number, filter?: string, page?: number, order?: 'asc' | 'desc', orderKey?: 'name' | 'partitions' | 'retention.ms' | 'retention.bytes', options?: AxiosRequestConfig): Promise<(axios?: AxiosInstance, basePath?: string) => AxiosPromise<TopicsList>>;
/**

@@ -133,3 +133,3 @@ * updates the topic with the new data.

*/
updateTopic(topicName: string, updateTopicInput: UpdateTopicInput, options?: any): Promise<(axios?: AxiosInstance, basePath?: string) => AxiosPromise<Topic>>;
updateTopic(topicName: string, updateTopicInput: UpdateTopicInput, options?: AxiosRequestConfig): Promise<(axios?: AxiosInstance, basePath?: string) => AxiosPromise<Topic>>;
};

@@ -203,3 +203,3 @@ /**

*/
createTopic(newTopicInput: NewTopicInput, options?: any): AxiosPromise<Topic>;
createTopic(newTopicInput: NewTopicInput, options?: AxiosRequestConfig): AxiosPromise<Topic>;
/**

@@ -213,3 +213,3 @@ * Deletes the topic with the specified name.

*/
deleteTopic(topicName: string, options?: any): AxiosPromise<void>;
deleteTopic(topicName: string, options?: AxiosRequestConfig): AxiosPromise<void>;
/**

@@ -223,3 +223,3 @@ * Topic

*/
getTopic(topicName: string, options?: any): AxiosPromise<Topic>;
getTopic(topicName: string, options?: AxiosRequestConfig): AxiosPromise<Topic>;
/**

@@ -239,3 +239,3 @@ * 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.

*/
getTopics(offset?: number, limit?: number, size?: number, filter?: string, page?: number, order?: 'asc' | 'desc', orderKey?: 'name' | 'partitions' | 'retention.ms' | 'retention.bytes', options?: any): AxiosPromise<TopicsList>;
getTopics(offset?: number, limit?: number, size?: number, filter?: string, page?: number, order?: 'asc' | 'desc', orderKey?: 'name' | 'partitions' | 'retention.ms' | 'retention.bytes', options?: AxiosRequestConfig): AxiosPromise<TopicsList>;
/**

@@ -250,3 +250,3 @@ * updates the topic with the new data.

*/
updateTopic(topicName: string, updateTopicInput: UpdateTopicInput, options?: any): AxiosPromise<Topic>;
updateTopic(topicName: string, updateTopicInput: UpdateTopicInput, options?: AxiosRequestConfig): AxiosPromise<Topic>;
}

@@ -268,3 +268,3 @@ /**

*/
createTopic(newTopicInput: NewTopicInput, options?: any): Promise<import("axios").AxiosResponse<Topic, any>>;
createTopic(newTopicInput: NewTopicInput, options?: AxiosRequestConfig): Promise<import("axios").AxiosResponse<Topic, any>>;
/**

@@ -278,3 +278,3 @@ * Deletes the topic with the specified name.

*/
deleteTopic(topicName: string, options?: any): Promise<import("axios").AxiosResponse<void, any>>;
deleteTopic(topicName: string, options?: AxiosRequestConfig): Promise<import("axios").AxiosResponse<void, any>>;
/**

@@ -288,3 +288,3 @@ * Topic

*/
getTopic(topicName: string, options?: any): Promise<import("axios").AxiosResponse<Topic, any>>;
getTopic(topicName: string, options?: AxiosRequestConfig): Promise<import("axios").AxiosResponse<Topic, any>>;
/**

@@ -304,3 +304,3 @@ * 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.

*/
getTopics(offset?: number, limit?: number, size?: number, filter?: string, page?: number, order?: 'asc' | 'desc', orderKey?: 'name' | 'partitions' | 'retention.ms' | 'retention.bytes', options?: any): Promise<import("axios").AxiosResponse<TopicsList, any>>;
getTopics(offset?: number, limit?: number, size?: number, filter?: string, page?: number, order?: 'asc' | 'desc', orderKey?: 'name' | 'partitions' | 'retention.ms' | 'retention.bytes', options?: AxiosRequestConfig): Promise<import("axios").AxiosResponse<TopicsList, any>>;
/**

@@ -315,3 +315,3 @@ * updates the topic with the new data.

*/
updateTopic(topicName: string, updateTopicInput: UpdateTopicInput, options?: any): Promise<import("axios").AxiosResponse<Topic, any>>;
updateTopic(topicName: string, updateTopicInput: UpdateTopicInput, options?: AxiosRequestConfig): Promise<import("axios").AxiosResponse<Topic, any>>;
}

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

localVarHeaderParameter['Content-Type'] = 'application/json';
(0, common_1.setSearchParams)(localVarUrlObj, localVarQueryParameter, options.query);
(0, common_1.setSearchParams)(localVarUrlObj, localVarQueryParameter);
let headersFromBaseOptions = baseOptions && baseOptions.headers ? baseOptions.headers : {};

@@ -96,3 +96,3 @@ localVarRequestOptions.headers = Object.assign(Object.assign(Object.assign({}, localVarHeaderParameter), headersFromBaseOptions), options.headers);

yield (0, common_1.setOAuthToObject)(localVarHeaderParameter, "Bearer", [], configuration);
(0, common_1.setSearchParams)(localVarUrlObj, localVarQueryParameter, options.query);
(0, common_1.setSearchParams)(localVarUrlObj, localVarQueryParameter);
let headersFromBaseOptions = baseOptions && baseOptions.headers ? baseOptions.headers : {};

@@ -129,3 +129,3 @@ localVarRequestOptions.headers = Object.assign(Object.assign(Object.assign({}, localVarHeaderParameter), headersFromBaseOptions), options.headers);

yield (0, common_1.setOAuthToObject)(localVarHeaderParameter, "Bearer", [], configuration);
(0, common_1.setSearchParams)(localVarUrlObj, localVarQueryParameter, options.query);
(0, common_1.setSearchParams)(localVarUrlObj, localVarQueryParameter);
let headersFromBaseOptions = baseOptions && baseOptions.headers ? baseOptions.headers : {};

@@ -186,3 +186,3 @@ localVarRequestOptions.headers = Object.assign(Object.assign(Object.assign({}, localVarHeaderParameter), headersFromBaseOptions), options.headers);

}
(0, common_1.setSearchParams)(localVarUrlObj, localVarQueryParameter, options.query);
(0, common_1.setSearchParams)(localVarUrlObj, localVarQueryParameter);
let headersFromBaseOptions = baseOptions && baseOptions.headers ? baseOptions.headers : {};

@@ -223,3 +223,3 @@ localVarRequestOptions.headers = Object.assign(Object.assign(Object.assign({}, localVarHeaderParameter), headersFromBaseOptions), options.headers);

localVarHeaderParameter['Content-Type'] = 'application/json';
(0, common_1.setSearchParams)(localVarUrlObj, localVarQueryParameter, options.query);
(0, common_1.setSearchParams)(localVarUrlObj, localVarQueryParameter);
let headersFromBaseOptions = baseOptions && baseOptions.headers ? baseOptions.headers : {};

@@ -226,0 +226,0 @@ localVarRequestOptions.headers = Object.assign(Object.assign(Object.assign({}, localVarHeaderParameter), headersFromBaseOptions), options.headers);

@@ -13,3 +13,3 @@ /**

import { Configuration } from "./configuration";
import { AxiosInstance } from 'axios';
import { AxiosInstance, AxiosRequestConfig } from 'axios';
export declare const BASE_PATH: string;

@@ -33,3 +33,3 @@ /**

url: string;
options: any;
options: AxiosRequestConfig;
}

@@ -36,0 +36,0 @@ /**

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

const axios_1 = require("axios");
exports.BASE_PATH = "http://localhost/rest".replace(/\/+$/, "");
exports.BASE_PATH = "/rest".replace(/\/+$/, "");
/**

@@ -23,0 +23,0 @@ *

@@ -14,3 +14,3 @@ /**

import { RequestArgs } from "./base";
import { AxiosInstance } from 'axios';
import { AxiosInstance, AxiosResponse } from 'axios';
/**

@@ -66,2 +66,2 @@ *

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

@@ -24,3 +24,3 @@ /**

*/
items?: Array<AclBinding>;
'items'?: Array<AclBinding>;
}

@@ -27,3 +27,3 @@ /**

*/
resourceType: AclResourceType;
'resourceType': AclResourceType;
/**

@@ -34,3 +34,3 @@ *

*/
resourceName: string;
'resourceName': string;
/**

@@ -41,3 +41,3 @@ *

*/
patternType: AclPatternType;
'patternType': AclPatternType;
/**

@@ -48,3 +48,3 @@ * Identifies the user or service account to which an ACL entry is bound. The literal prefix value of `User:` is required. May be used to specify all users with value `User:*`.

*/
principal: string;
'principal': string;
/**

@@ -55,3 +55,3 @@ *

*/
operation: AclOperation;
'operation': AclOperation;
/**

@@ -62,3 +62,3 @@ *

*/
permission: AclPermissionType;
'permission': AclPermissionType;
}

@@ -17,13 +17,14 @@ /**

*/
export declare enum AclOperationFilter {
All = "ALL",
Read = "READ",
Write = "WRITE",
Create = "CREATE",
Delete = "DELETE",
Alter = "ALTER",
Describe = "DESCRIBE",
DescribeConfigs = "DESCRIBE_CONFIGS",
AlterConfigs = "ALTER_CONFIGS",
Any = "ANY"
}
export declare const AclOperationFilter: {
readonly All: "ALL";
readonly Read: "READ";
readonly Write: "WRITE";
readonly Create: "CREATE";
readonly Delete: "DELETE";
readonly Alter: "ALTER";
readonly Describe: "DESCRIBE";
readonly DescribeConfigs: "DESCRIBE_CONFIGS";
readonly AlterConfigs: "ALTER_CONFIGS";
readonly Any: "ANY";
};
export declare type AclOperationFilter = typeof AclOperationFilter[keyof typeof AclOperationFilter];

@@ -22,14 +22,13 @@ "use strict";

*/
var AclOperationFilter;
(function (AclOperationFilter) {
AclOperationFilter["All"] = "ALL";
AclOperationFilter["Read"] = "READ";
AclOperationFilter["Write"] = "WRITE";
AclOperationFilter["Create"] = "CREATE";
AclOperationFilter["Delete"] = "DELETE";
AclOperationFilter["Alter"] = "ALTER";
AclOperationFilter["Describe"] = "DESCRIBE";
AclOperationFilter["DescribeConfigs"] = "DESCRIBE_CONFIGS";
AclOperationFilter["AlterConfigs"] = "ALTER_CONFIGS";
AclOperationFilter["Any"] = "ANY";
})(AclOperationFilter = exports.AclOperationFilter || (exports.AclOperationFilter = {}));
exports.AclOperationFilter = {
All: 'ALL',
Read: 'READ',
Write: 'WRITE',
Create: 'CREATE',
Delete: 'DELETE',
Alter: 'ALTER',
Describe: 'DESCRIBE',
DescribeConfigs: 'DESCRIBE_CONFIGS',
AlterConfigs: 'ALTER_CONFIGS',
Any: 'ANY'
};

@@ -17,12 +17,13 @@ /**

*/
export declare enum AclOperation {
All = "ALL",
Read = "READ",
Write = "WRITE",
Create = "CREATE",
Delete = "DELETE",
Alter = "ALTER",
Describe = "DESCRIBE",
DescribeConfigs = "DESCRIBE_CONFIGS",
AlterConfigs = "ALTER_CONFIGS"
}
export declare const AclOperation: {
readonly All: "ALL";
readonly Read: "READ";
readonly Write: "WRITE";
readonly Create: "CREATE";
readonly Delete: "DELETE";
readonly Alter: "ALTER";
readonly Describe: "DESCRIBE";
readonly DescribeConfigs: "DESCRIBE_CONFIGS";
readonly AlterConfigs: "ALTER_CONFIGS";
};
export declare type AclOperation = typeof AclOperation[keyof typeof AclOperation];

@@ -22,13 +22,12 @@ "use strict";

*/
var AclOperation;
(function (AclOperation) {
AclOperation["All"] = "ALL";
AclOperation["Read"] = "READ";
AclOperation["Write"] = "WRITE";
AclOperation["Create"] = "CREATE";
AclOperation["Delete"] = "DELETE";
AclOperation["Alter"] = "ALTER";
AclOperation["Describe"] = "DESCRIBE";
AclOperation["DescribeConfigs"] = "DESCRIBE_CONFIGS";
AclOperation["AlterConfigs"] = "ALTER_CONFIGS";
})(AclOperation = exports.AclOperation || (exports.AclOperation = {}));
exports.AclOperation = {
All: 'ALL',
Read: 'READ',
Write: 'WRITE',
Create: 'CREATE',
Delete: 'DELETE',
Alter: 'ALTER',
Describe: 'DESCRIBE',
DescribeConfigs: 'DESCRIBE_CONFIGS',
AlterConfigs: 'ALTER_CONFIGS'
};

@@ -17,7 +17,8 @@ /**

*/
export declare enum AclPatternTypeFilter {
Literal = "LITERAL",
Prefixed = "PREFIXED",
Any = "ANY",
Match = "MATCH"
}
export declare const AclPatternTypeFilter: {
readonly Literal: "LITERAL";
readonly Prefixed: "PREFIXED";
readonly Any: "ANY";
readonly Match: "MATCH";
};
export declare type AclPatternTypeFilter = typeof AclPatternTypeFilter[keyof typeof AclPatternTypeFilter];

@@ -22,8 +22,7 @@ "use strict";

*/
var AclPatternTypeFilter;
(function (AclPatternTypeFilter) {
AclPatternTypeFilter["Literal"] = "LITERAL";
AclPatternTypeFilter["Prefixed"] = "PREFIXED";
AclPatternTypeFilter["Any"] = "ANY";
AclPatternTypeFilter["Match"] = "MATCH";
})(AclPatternTypeFilter = exports.AclPatternTypeFilter || (exports.AclPatternTypeFilter = {}));
exports.AclPatternTypeFilter = {
Literal: 'LITERAL',
Prefixed: 'PREFIXED',
Any: 'ANY',
Match: 'MATCH'
};

@@ -17,5 +17,6 @@ /**

*/
export declare enum AclPatternType {
Literal = "LITERAL",
Prefixed = "PREFIXED"
}
export declare const AclPatternType: {
readonly Literal: "LITERAL";
readonly Prefixed: "PREFIXED";
};
export declare type AclPatternType = typeof AclPatternType[keyof typeof AclPatternType];

@@ -22,6 +22,5 @@ "use strict";

*/
var AclPatternType;
(function (AclPatternType) {
AclPatternType["Literal"] = "LITERAL";
AclPatternType["Prefixed"] = "PREFIXED";
})(AclPatternType = exports.AclPatternType || (exports.AclPatternType = {}));
exports.AclPatternType = {
Literal: 'LITERAL',
Prefixed: 'PREFIXED'
};

@@ -17,6 +17,7 @@ /**

*/
export declare enum AclPermissionTypeFilter {
Allow = "ALLOW",
Deny = "DENY",
Any = "ANY"
}
export declare const AclPermissionTypeFilter: {
readonly Allow: "ALLOW";
readonly Deny: "DENY";
readonly Any: "ANY";
};
export declare type AclPermissionTypeFilter = typeof AclPermissionTypeFilter[keyof typeof AclPermissionTypeFilter];

@@ -22,7 +22,6 @@ "use strict";

*/
var AclPermissionTypeFilter;
(function (AclPermissionTypeFilter) {
AclPermissionTypeFilter["Allow"] = "ALLOW";
AclPermissionTypeFilter["Deny"] = "DENY";
AclPermissionTypeFilter["Any"] = "ANY";
})(AclPermissionTypeFilter = exports.AclPermissionTypeFilter || (exports.AclPermissionTypeFilter = {}));
exports.AclPermissionTypeFilter = {
Allow: 'ALLOW',
Deny: 'DENY',
Any: 'ANY'
};

@@ -17,5 +17,6 @@ /**

*/
export declare enum AclPermissionType {
Allow = "ALLOW",
Deny = "DENY"
}
export declare const AclPermissionType: {
readonly Allow: "ALLOW";
readonly Deny: "DENY";
};
export declare type AclPermissionType = typeof AclPermissionType[keyof typeof AclPermissionType];

@@ -22,6 +22,5 @@ "use strict";

*/
var AclPermissionType;
(function (AclPermissionType) {
AclPermissionType["Allow"] = "ALLOW";
AclPermissionType["Deny"] = "DENY";
})(AclPermissionType = exports.AclPermissionType || (exports.AclPermissionType = {}));
exports.AclPermissionType = {
Allow: 'ALLOW',
Deny: 'DENY'
};

@@ -17,8 +17,9 @@ /**

*/
export declare enum AclResourceTypeFilter {
Any = "ANY",
Group = "GROUP",
Topic = "TOPIC",
Cluster = "CLUSTER",
TransactionalId = "TRANSACTIONAL_ID"
}
export declare const AclResourceTypeFilter: {
readonly Any: "ANY";
readonly Group: "GROUP";
readonly Topic: "TOPIC";
readonly Cluster: "CLUSTER";
readonly TransactionalId: "TRANSACTIONAL_ID";
};
export declare type AclResourceTypeFilter = typeof AclResourceTypeFilter[keyof typeof AclResourceTypeFilter];

@@ -22,9 +22,8 @@ "use strict";

*/
var AclResourceTypeFilter;
(function (AclResourceTypeFilter) {
AclResourceTypeFilter["Any"] = "ANY";
AclResourceTypeFilter["Group"] = "GROUP";
AclResourceTypeFilter["Topic"] = "TOPIC";
AclResourceTypeFilter["Cluster"] = "CLUSTER";
AclResourceTypeFilter["TransactionalId"] = "TRANSACTIONAL_ID";
})(AclResourceTypeFilter = exports.AclResourceTypeFilter || (exports.AclResourceTypeFilter = {}));
exports.AclResourceTypeFilter = {
Any: 'ANY',
Group: 'GROUP',
Topic: 'TOPIC',
Cluster: 'CLUSTER',
TransactionalId: 'TRANSACTIONAL_ID'
};

@@ -17,7 +17,8 @@ /**

*/
export declare enum AclResourceType {
Group = "GROUP",
Topic = "TOPIC",
Cluster = "CLUSTER",
TransactionalId = "TRANSACTIONAL_ID"
}
export declare const AclResourceType: {
readonly Group: "GROUP";
readonly Topic: "TOPIC";
readonly Cluster: "CLUSTER";
readonly TransactionalId: "TRANSACTIONAL_ID";
};
export declare type AclResourceType = typeof AclResourceType[keyof typeof AclResourceType];

@@ -22,8 +22,7 @@ "use strict";

*/
var AclResourceType;
(function (AclResourceType) {
AclResourceType["Group"] = "GROUP";
AclResourceType["Topic"] = "TOPIC";
AclResourceType["Cluster"] = "CLUSTER";
AclResourceType["TransactionalId"] = "TRANSACTIONAL_ID";
})(AclResourceType = exports.AclResourceType || (exports.AclResourceType = {}));
exports.AclResourceType = {
Group: 'GROUP',
Topic: 'TOPIC',
Cluster: 'CLUSTER',
TransactionalId: 'TRANSACTIONAL_ID'
};

@@ -23,3 +23,3 @@ /**

*/
key?: string;
'key'?: string;
/**

@@ -30,3 +30,3 @@ * Value to indicate the setting on the topic configuration entry.

*/
value?: string;
'value'?: string;
}

@@ -24,3 +24,3 @@ /**

*/
items?: Array<ConsumerGroup>;
'items'?: Array<ConsumerGroup>;
/**

@@ -31,3 +31,3 @@ * The total number of consumer groups.

*/
total?: number;
'total'?: number;
/**

@@ -38,3 +38,3 @@ * The number of consumer groups per page.

*/
size?: number;
'size'?: number;
/**

@@ -45,3 +45,3 @@ * The page

*/
page?: number;
'page'?: number;
/**

@@ -53,3 +53,3 @@ * Offset of the topic list

*/
offset?: number;
'offset'?: number;
/**

@@ -61,3 +61,3 @@ * Maximum of returned topics

*/
limit?: number;
'limit'?: number;
/**

@@ -69,3 +69,3 @@ * The total number of consumer groups.

*/
count?: number;
'count'?: number;
}

@@ -24,3 +24,3 @@ /**

*/
value?: string;
'value'?: string;
/**

@@ -31,3 +31,3 @@ *

*/
offset: ConsumerGroupResetOffsetParametersOffsetEnum;
'offset': ConsumerGroupResetOffsetParametersOffsetEnum;
/**

@@ -38,13 +38,10 @@ *

*/
topics?: Array<TopicsToResetOffset>;
'topics'?: Array<TopicsToResetOffset>;
}
/**
* @export
* @enum {string}
*/
export declare enum ConsumerGroupResetOffsetParametersOffsetEnum {
Timestamp = "timestamp",
Absolute = "absolute",
Latest = "latest",
Earliest = "earliest"
}
export declare const ConsumerGroupResetOffsetParametersOffsetEnum: {
readonly Timestamp: "timestamp";
readonly Absolute: "absolute";
readonly Latest: "latest";
readonly Earliest: "earliest";
};
export declare type ConsumerGroupResetOffsetParametersOffsetEnum = typeof ConsumerGroupResetOffsetParametersOffsetEnum[keyof typeof ConsumerGroupResetOffsetParametersOffsetEnum];

@@ -17,12 +17,7 @@ "use strict";

exports.ConsumerGroupResetOffsetParametersOffsetEnum = void 0;
/**
* @export
* @enum {string}
*/
var ConsumerGroupResetOffsetParametersOffsetEnum;
(function (ConsumerGroupResetOffsetParametersOffsetEnum) {
ConsumerGroupResetOffsetParametersOffsetEnum["Timestamp"] = "timestamp";
ConsumerGroupResetOffsetParametersOffsetEnum["Absolute"] = "absolute";
ConsumerGroupResetOffsetParametersOffsetEnum["Latest"] = "latest";
ConsumerGroupResetOffsetParametersOffsetEnum["Earliest"] = "earliest";
})(ConsumerGroupResetOffsetParametersOffsetEnum = exports.ConsumerGroupResetOffsetParametersOffsetEnum || (exports.ConsumerGroupResetOffsetParametersOffsetEnum = {}));
exports.ConsumerGroupResetOffsetParametersOffsetEnum = {
Timestamp: 'timestamp',
Absolute: 'absolute',
Latest: 'latest',
Earliest: 'earliest'
};

@@ -24,3 +24,3 @@ /**

*/
items?: Array<ConsumerGroupResetOffsetResultItem>;
'items'?: Array<ConsumerGroupResetOffsetResultItem>;
}

@@ -23,3 +23,3 @@ /**

*/
topic?: string;
'topic'?: string;
/**

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

*/
partition?: number;
'partition'?: number;
/**

@@ -37,3 +37,3 @@ *

*/
offset?: number;
'offset'?: number;
}

@@ -24,3 +24,3 @@ /**

*/
groupId: string;
'groupId': string;
/**

@@ -31,3 +31,3 @@ *

*/
state?: ConsumerGroupStateEnum;
'state'?: ConsumerGroupStateEnum;
/**

@@ -38,15 +38,12 @@ * The list of consumers associated with this consumer group

*/
consumers: Array<Consumer>;
'consumers': Array<Consumer>;
}
/**
* @export
* @enum {string}
*/
export declare enum ConsumerGroupStateEnum {
Stable = "STABLE",
Dead = "DEAD",
Empty = "EMPTY",
CompletingRebalance = "COMPLETING_REBALANCE",
PreparingRebalance = "PREPARING_REBALANCE",
Unknown = "UNKNOWN"
}
export declare const ConsumerGroupStateEnum: {
readonly Stable: "STABLE";
readonly Dead: "DEAD";
readonly Empty: "EMPTY";
readonly CompletingRebalance: "COMPLETING_REBALANCE";
readonly PreparingRebalance: "PREPARING_REBALANCE";
readonly Unknown: "UNKNOWN";
};
export declare type ConsumerGroupStateEnum = typeof ConsumerGroupStateEnum[keyof typeof ConsumerGroupStateEnum];

@@ -17,14 +17,9 @@ "use strict";

exports.ConsumerGroupStateEnum = void 0;
/**
* @export
* @enum {string}
*/
var ConsumerGroupStateEnum;
(function (ConsumerGroupStateEnum) {
ConsumerGroupStateEnum["Stable"] = "STABLE";
ConsumerGroupStateEnum["Dead"] = "DEAD";
ConsumerGroupStateEnum["Empty"] = "EMPTY";
ConsumerGroupStateEnum["CompletingRebalance"] = "COMPLETING_REBALANCE";
ConsumerGroupStateEnum["PreparingRebalance"] = "PREPARING_REBALANCE";
ConsumerGroupStateEnum["Unknown"] = "UNKNOWN";
})(ConsumerGroupStateEnum = exports.ConsumerGroupStateEnum || (exports.ConsumerGroupStateEnum = {}));
exports.ConsumerGroupStateEnum = {
Stable: 'STABLE',
Dead: 'DEAD',
Empty: 'EMPTY',
CompletingRebalance: 'COMPLETING_REBALANCE',
PreparingRebalance: 'PREPARING_REBALANCE',
Unknown: 'UNKNOWN'
};

@@ -23,3 +23,3 @@ /**

*/
groupId: string;
'groupId': string;
/**

@@ -30,3 +30,3 @@ * The unique topic name to which this consumer belongs

*/
topic: string;
'topic': string;
/**

@@ -37,3 +37,3 @@ * The partition number to which this consumer group is assigned to.

*/
partition: number;
'partition': number;
/**

@@ -44,3 +44,3 @@ * Offset denotes the position of the consumer in a partition.

*/
offset: number;
'offset': number;
/**

@@ -51,3 +51,3 @@ * The log end offset is the offset of the last message written to a log.

*/
logEndOffset?: number;
'logEndOffset'?: number;
/**

@@ -58,3 +58,3 @@ * Offset Lag is the delta between the last produced message and the last consumer\'s committed offset.

*/
lag: number;
'lag': number;
/**

@@ -65,3 +65,3 @@ * The member ID is a unique identifier given to a consumer by the coordinator upon initially joining the group.

*/
memberId?: string;
'memberId'?: string;
}

@@ -23,3 +23,3 @@ /**

*/
code?: number;
'code'?: number;
/**

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

*/
error_message?: string;
'error_message'?: string;
/**

@@ -37,3 +37,3 @@ *

*/
_class?: string;
'class'?: string;
}

@@ -24,3 +24,3 @@ /**

*/
name: string;
'name': string;
/**

@@ -31,3 +31,3 @@ *

*/
settings: TopicSettings;
'settings': TopicSettings;
}

@@ -23,3 +23,3 @@ /**

*/
partition: number;
'partition': number;
/**

@@ -31,3 +31,3 @@ * Unique id for the partition (deprecated, use `partition` instead)

*/
id?: number;
'id'?: number;
/**

@@ -38,3 +38,3 @@ * List of replicas for the partition

*/
replicas?: Array<object>;
'replicas'?: Array<object>;
/**

@@ -45,3 +45,3 @@ * List in-sync replicas for this partition.

*/
isr?: Array<object>;
'isr'?: Array<object>;
/**

@@ -52,3 +52,3 @@ * Kafka server / broker.

*/
leader?: object;
'leader'?: object;
}

@@ -23,3 +23,3 @@ /**

*/
total: number;
'total': number;
/**

@@ -30,3 +30,3 @@ * Current page number (returned for fetch requests)

*/
page?: number;
'page'?: number;
/**

@@ -37,3 +37,3 @@ * Number of entries per page (returned for fetch requests)

*/
size?: number;
'size'?: number;
}

@@ -24,3 +24,3 @@ /**

*/
numPartitions: number;
'numPartitions': number;
/**

@@ -31,3 +31,3 @@ * Topic configuration entry.

*/
config?: Array<ConfigEntry>;
'config'?: Array<ConfigEntry>;
}

@@ -25,3 +25,3 @@ /**

*/
name?: string;
'name'?: string;
/**

@@ -32,3 +32,3 @@ * Topic configuration entry.

*/
config?: Array<ConfigEntry>;
'config'?: Array<ConfigEntry>;
/**

@@ -39,3 +39,3 @@ * Partitions for this topic.

*/
partitions?: Array<Partition>;
'partitions'?: Array<Partition>;
}

@@ -24,3 +24,3 @@ /**

*/
page?: number;
'page'?: number;
/**

@@ -31,3 +31,3 @@ * number of entries per page

*/
size?: number;
'size'?: number;
/**

@@ -39,3 +39,3 @@ * Offset of the topic list

*/
offset?: number;
'offset'?: number;
/**

@@ -47,3 +47,3 @@ * Maximum of returned topics

*/
limit?: number;
'limit'?: number;
/**

@@ -54,3 +54,3 @@ * Total number of topics

*/
total?: number;
'total'?: number;
/**

@@ -61,3 +61,3 @@ * List of topics

*/
items?: Array<Topic>;
'items'?: Array<Topic>;
}

@@ -23,3 +23,3 @@ /**

*/
topic: string;
'topic': string;
/**

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

*/
partitions?: Array<number>;
'partitions'?: Array<number>;
}

@@ -24,3 +24,3 @@ /**

*/
config?: Array<ConfigEntry>;
'config'?: Array<ConfigEntry>;
/**

@@ -31,3 +31,3 @@ * Number of partitions (only increasing supported)

*/
numPartitions?: number;
'numPartitions'?: number;
}
{
"name": "@rhoas/kafka-instance-sdk",
"version": "0.23.2",
"version": "0.24.0",
"description": "RHOAS Kafka Instance Adminstration SDK",

@@ -5,0 +5,0 @@ "author": "Red Hat Developers",

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

import globalAxios, { AxiosPromise, AxiosInstance } from 'axios';
import globalAxios, { AxiosPromise, AxiosInstance, AxiosRequestConfig } from 'axios';
import { Configuration } from '../configuration';

@@ -49,3 +49,3 @@ // Some imports not used depending on template conditions

*/
createAcl: async (aclBinding: AclBinding, options: any = {}): Promise<RequestArgs> => {
createAcl: async (aclBinding: AclBinding, options: AxiosRequestConfig = {}): Promise<RequestArgs> => {
// verify required parameter 'aclBinding' is not null or undefined

@@ -73,3 +73,3 @@ assertParamExists('createAcl', 'aclBinding', aclBinding)

setSearchParams(localVarUrlObj, localVarQueryParameter, options.query);
setSearchParams(localVarUrlObj, localVarQueryParameter);
let headersFromBaseOptions = baseOptions && baseOptions.headers ? baseOptions.headers : {};

@@ -96,3 +96,3 @@ localVarRequestOptions.headers = {...localVarHeaderParameter, ...headersFromBaseOptions, ...options.headers};

*/
deleteAcls: async (resourceType?: AclResourceTypeFilter, resourceName?: string, patternType?: AclPatternTypeFilter, principal?: string, operation?: AclOperationFilter, permission?: AclPermissionTypeFilter, options: any = {}): Promise<RequestArgs> => {
deleteAcls: async (resourceType?: AclResourceTypeFilter, resourceName?: string, patternType?: AclPatternTypeFilter, principal?: string, operation?: AclOperationFilter, permission?: AclPermissionTypeFilter, options: AxiosRequestConfig = {}): Promise<RequestArgs> => {
const localVarPath = `/acls`;

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

setSearchParams(localVarUrlObj, localVarQueryParameter, options.query);
setSearchParams(localVarUrlObj, localVarQueryParameter);
let headersFromBaseOptions = baseOptions && baseOptions.headers ? baseOptions.headers : {};

@@ -156,3 +156,3 @@ localVarRequestOptions.headers = {...localVarHeaderParameter, ...headersFromBaseOptions, ...options.headers};

*/
getAclResourceOperations: async (options: any = {}): Promise<RequestArgs> => {
getAclResourceOperations: async (options: AxiosRequestConfig = {}): Promise<RequestArgs> => {
const localVarPath = `/acls/resource-operations`;

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

setSearchParams(localVarUrlObj, localVarQueryParameter, options.query);
setSearchParams(localVarUrlObj, localVarQueryParameter);
let headersFromBaseOptions = baseOptions && baseOptions.headers ? baseOptions.headers : {};

@@ -202,3 +202,3 @@ localVarRequestOptions.headers = {...localVarHeaderParameter, ...headersFromBaseOptions, ...options.headers};

*/
getAcls: async (resourceType?: AclResourceTypeFilter, resourceName?: string, patternType?: AclPatternTypeFilter, principal?: string, operation?: AclOperationFilter, permission?: AclPermissionTypeFilter, page?: number, size?: number, order?: 'asc' | 'desc', orderKey?: 'resourceType' | 'resourceName' | 'patternType' | 'principal' | 'operation' | 'permission', options: any = {}): Promise<RequestArgs> => {
getAcls: async (resourceType?: AclResourceTypeFilter, resourceName?: string, patternType?: AclPatternTypeFilter, principal?: string, operation?: AclOperationFilter, permission?: AclPermissionTypeFilter, page?: number, size?: number, order?: 'asc' | 'desc', orderKey?: 'resourceType' | 'resourceName' | 'patternType' | 'principal' | 'operation' | 'permission', options: AxiosRequestConfig = {}): Promise<RequestArgs> => {
const localVarPath = `/acls`;

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

setSearchParams(localVarUrlObj, localVarQueryParameter, options.query);
setSearchParams(localVarUrlObj, localVarQueryParameter);
let headersFromBaseOptions = baseOptions && baseOptions.headers ? baseOptions.headers : {};

@@ -289,3 +289,3 @@ localVarRequestOptions.headers = {...localVarHeaderParameter, ...headersFromBaseOptions, ...options.headers};

*/
async createAcl(aclBinding: AclBinding, options?: any): Promise<(axios?: AxiosInstance, basePath?: string) => AxiosPromise<void>> {
async createAcl(aclBinding: AclBinding, options?: AxiosRequestConfig): Promise<(axios?: AxiosInstance, basePath?: string) => AxiosPromise<void>> {
const localVarAxiosArgs = await localVarAxiosParamCreator.createAcl(aclBinding, options);

@@ -306,3 +306,3 @@ return createRequestFunction(localVarAxiosArgs, globalAxios, BASE_PATH, configuration);

*/
async deleteAcls(resourceType?: AclResourceTypeFilter, resourceName?: string, patternType?: AclPatternTypeFilter, principal?: string, operation?: AclOperationFilter, permission?: AclPermissionTypeFilter, options?: any): Promise<(axios?: AxiosInstance, basePath?: string) => AxiosPromise<AclBindingListPage>> {
async deleteAcls(resourceType?: AclResourceTypeFilter, resourceName?: string, patternType?: AclPatternTypeFilter, principal?: string, operation?: AclOperationFilter, permission?: AclPermissionTypeFilter, options?: AxiosRequestConfig): Promise<(axios?: AxiosInstance, basePath?: string) => AxiosPromise<AclBindingListPage>> {
const localVarAxiosArgs = await localVarAxiosParamCreator.deleteAcls(resourceType, resourceName, patternType, principal, operation, permission, options);

@@ -317,3 +317,3 @@ return createRequestFunction(localVarAxiosArgs, globalAxios, BASE_PATH, configuration);

*/
async getAclResourceOperations(options?: any): Promise<(axios?: AxiosInstance, basePath?: string) => AxiosPromise<{ [key: string]: Array<string>; }>> {
async getAclResourceOperations(options?: AxiosRequestConfig): Promise<(axios?: AxiosInstance, basePath?: string) => AxiosPromise<{ [key: string]: Array<string>; }>> {
const localVarAxiosArgs = await localVarAxiosParamCreator.getAclResourceOperations(options);

@@ -338,3 +338,3 @@ return createRequestFunction(localVarAxiosArgs, globalAxios, BASE_PATH, configuration);

*/
async getAcls(resourceType?: AclResourceTypeFilter, resourceName?: string, patternType?: AclPatternTypeFilter, principal?: string, operation?: AclOperationFilter, permission?: AclPermissionTypeFilter, page?: number, size?: number, order?: 'asc' | 'desc', orderKey?: 'resourceType' | 'resourceName' | 'patternType' | 'principal' | 'operation' | 'permission', options?: any): Promise<(axios?: AxiosInstance, basePath?: string) => AxiosPromise<AclBindingListPage>> {
async getAcls(resourceType?: AclResourceTypeFilter, resourceName?: string, patternType?: AclPatternTypeFilter, principal?: string, operation?: AclOperationFilter, permission?: AclPermissionTypeFilter, page?: number, size?: number, order?: 'asc' | 'desc', orderKey?: 'resourceType' | 'resourceName' | 'patternType' | 'principal' | 'operation' | 'permission', options?: AxiosRequestConfig): Promise<(axios?: AxiosInstance, basePath?: string) => AxiosPromise<AclBindingListPage>> {
const localVarAxiosArgs = await localVarAxiosParamCreator.getAcls(resourceType, resourceName, patternType, principal, operation, permission, page, size, order, orderKey, options);

@@ -423,3 +423,3 @@ return createRequestFunction(localVarAxiosArgs, globalAxios, BASE_PATH, configuration);

*/
createAcl(aclBinding: AclBinding, options?: any): AxiosPromise<void>;
createAcl(aclBinding: AclBinding, options?: AxiosRequestConfig): AxiosPromise<void>;

@@ -439,3 +439,3 @@ /**

*/
deleteAcls(resourceType?: AclResourceTypeFilter, resourceName?: string, patternType?: AclPatternTypeFilter, principal?: string, operation?: AclOperationFilter, permission?: AclPermissionTypeFilter, options?: any): AxiosPromise<AclBindingListPage>;
deleteAcls(resourceType?: AclResourceTypeFilter, resourceName?: string, patternType?: AclPatternTypeFilter, principal?: string, operation?: AclOperationFilter, permission?: AclPermissionTypeFilter, options?: AxiosRequestConfig): AxiosPromise<AclBindingListPage>;

@@ -449,3 +449,3 @@ /**

*/
getAclResourceOperations(options?: any): AxiosPromise<{ [key: string]: Array<string>; }>;
getAclResourceOperations(options?: AxiosRequestConfig): AxiosPromise<{ [key: string]: Array<string>; }>;

@@ -469,3 +469,3 @@ /**

*/
getAcls(resourceType?: AclResourceTypeFilter, resourceName?: string, patternType?: AclPatternTypeFilter, principal?: string, operation?: AclOperationFilter, permission?: AclPermissionTypeFilter, page?: number, size?: number, order?: 'asc' | 'desc', orderKey?: 'resourceType' | 'resourceName' | 'patternType' | 'principal' | 'operation' | 'permission', options?: any): AxiosPromise<AclBindingListPage>;
getAcls(resourceType?: AclResourceTypeFilter, resourceName?: string, patternType?: AclPatternTypeFilter, principal?: string, operation?: AclOperationFilter, permission?: AclPermissionTypeFilter, page?: number, size?: number, order?: 'asc' | 'desc', orderKey?: 'resourceType' | 'resourceName' | 'patternType' | 'principal' | 'operation' | 'permission', options?: AxiosRequestConfig): AxiosPromise<AclBindingListPage>;

@@ -489,3 +489,3 @@ }

*/
public createAcl(aclBinding: AclBinding, options?: any) {
public createAcl(aclBinding: AclBinding, options?: AxiosRequestConfig) {
return AclsApiFp(this.configuration).createAcl(aclBinding, options).then((request) => request(this.axios, this.basePath));

@@ -507,3 +507,3 @@ }

*/
public deleteAcls(resourceType?: AclResourceTypeFilter, resourceName?: string, patternType?: AclPatternTypeFilter, principal?: string, operation?: AclOperationFilter, permission?: AclPermissionTypeFilter, options?: any) {
public deleteAcls(resourceType?: AclResourceTypeFilter, resourceName?: string, patternType?: AclPatternTypeFilter, principal?: string, operation?: AclOperationFilter, permission?: AclPermissionTypeFilter, options?: AxiosRequestConfig) {
return AclsApiFp(this.configuration).deleteAcls(resourceType, resourceName, patternType, principal, operation, permission, options).then((request) => request(this.axios, this.basePath));

@@ -519,3 +519,3 @@ }

*/
public getAclResourceOperations(options?: any) {
public getAclResourceOperations(options?: AxiosRequestConfig) {
return AclsApiFp(this.configuration).getAclResourceOperations(options).then((request) => request(this.axios, this.basePath));

@@ -541,5 +541,5 @@ }

*/
public getAcls(resourceType?: AclResourceTypeFilter, resourceName?: string, patternType?: AclPatternTypeFilter, principal?: string, operation?: AclOperationFilter, permission?: AclPermissionTypeFilter, page?: number, size?: number, order?: 'asc' | 'desc', orderKey?: 'resourceType' | 'resourceName' | 'patternType' | 'principal' | 'operation' | 'permission', options?: any) {
public getAcls(resourceType?: AclResourceTypeFilter, resourceName?: string, patternType?: AclPatternTypeFilter, principal?: string, operation?: AclOperationFilter, permission?: AclPermissionTypeFilter, page?: number, size?: number, order?: 'asc' | 'desc', orderKey?: 'resourceType' | 'resourceName' | 'patternType' | 'principal' | 'operation' | 'permission', options?: AxiosRequestConfig) {
return AclsApiFp(this.configuration).getAcls(resourceType, resourceName, patternType, principal, operation, permission, page, size, order, orderKey, options).then((request) => request(this.axios, this.basePath));
}
}

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

import globalAxios, { AxiosPromise, AxiosInstance } from 'axios';
import globalAxios, { AxiosPromise, AxiosInstance, AxiosRequestConfig } from 'axios';
import { Configuration } from '../configuration';

@@ -45,3 +45,3 @@ // Some imports not used depending on template conditions

*/
deleteConsumerGroupById: async (consumerGroupId: string, options: any = {}): Promise<RequestArgs> => {
deleteConsumerGroupById: async (consumerGroupId: string, options: AxiosRequestConfig = {}): Promise<RequestArgs> => {
// verify required parameter 'consumerGroupId' is not null or undefined

@@ -68,3 +68,3 @@ assertParamExists('deleteConsumerGroupById', 'consumerGroupId', consumerGroupId)

setSearchParams(localVarUrlObj, localVarQueryParameter, options.query);
setSearchParams(localVarUrlObj, localVarQueryParameter);
let headersFromBaseOptions = baseOptions && baseOptions.headers ? baseOptions.headers : {};

@@ -89,3 +89,3 @@ localVarRequestOptions.headers = {...localVarHeaderParameter, ...headersFromBaseOptions, ...options.headers};

*/
getConsumerGroupById: async (consumerGroupId: string, order?: 'asc' | 'desc', orderKey?: 'offset' | 'endOffset' | 'lag' | 'partition', partitionFilter?: number, topic?: string, options: any = {}): Promise<RequestArgs> => {
getConsumerGroupById: async (consumerGroupId: string, order?: 'asc' | 'desc', orderKey?: 'offset' | 'endOffset' | 'lag' | 'partition', partitionFilter?: number, topic?: string, options: AxiosRequestConfig = {}): Promise<RequestArgs> => {
// verify required parameter 'consumerGroupId' is not null or undefined

@@ -128,3 +128,3 @@ assertParamExists('getConsumerGroupById', 'consumerGroupId', consumerGroupId)

setSearchParams(localVarUrlObj, localVarQueryParameter, options.query);
setSearchParams(localVarUrlObj, localVarQueryParameter);
let headersFromBaseOptions = baseOptions && baseOptions.headers ? baseOptions.headers : {};

@@ -152,3 +152,3 @@ localVarRequestOptions.headers = {...localVarHeaderParameter, ...headersFromBaseOptions, ...options.headers};

*/
getConsumerGroups: async (offset?: number, limit?: number, size?: number, page?: number, topic?: string, groupIdFilter?: string, order?: 'asc' | 'desc', orderKey?: 'name', options: any = {}): Promise<RequestArgs> => {
getConsumerGroups: async (offset?: number, limit?: number, size?: number, page?: number, topic?: string, groupIdFilter?: string, order?: 'asc' | 'desc', orderKey?: 'name', options: AxiosRequestConfig = {}): Promise<RequestArgs> => {
const localVarPath = `/consumer-groups`;

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

setSearchParams(localVarUrlObj, localVarQueryParameter, options.query);
setSearchParams(localVarUrlObj, localVarQueryParameter);
let headersFromBaseOptions = baseOptions && baseOptions.headers ? baseOptions.headers : {};

@@ -222,3 +222,3 @@ localVarRequestOptions.headers = {...localVarHeaderParameter, ...headersFromBaseOptions, ...options.headers};

*/
resetConsumerGroupOffset: async (consumerGroupId: string, consumerGroupResetOffsetParameters: ConsumerGroupResetOffsetParameters, options: any = {}): Promise<RequestArgs> => {
resetConsumerGroupOffset: async (consumerGroupId: string, consumerGroupResetOffsetParameters: ConsumerGroupResetOffsetParameters, options: AxiosRequestConfig = {}): Promise<RequestArgs> => {
// verify required parameter 'consumerGroupId' is not null or undefined

@@ -249,3 +249,3 @@ assertParamExists('resetConsumerGroupOffset', 'consumerGroupId', consumerGroupId)

setSearchParams(localVarUrlObj, localVarQueryParameter, options.query);
setSearchParams(localVarUrlObj, localVarQueryParameter);
let headersFromBaseOptions = baseOptions && baseOptions.headers ? baseOptions.headers : {};

@@ -277,3 +277,3 @@ localVarRequestOptions.headers = {...localVarHeaderParameter, ...headersFromBaseOptions, ...options.headers};

*/
async deleteConsumerGroupById(consumerGroupId: string, options?: any): Promise<(axios?: AxiosInstance, basePath?: string) => AxiosPromise<void>> {
async deleteConsumerGroupById(consumerGroupId: string, options?: AxiosRequestConfig): Promise<(axios?: AxiosInstance, basePath?: string) => AxiosPromise<void>> {
const localVarAxiosArgs = await localVarAxiosParamCreator.deleteConsumerGroupById(consumerGroupId, options);

@@ -293,3 +293,3 @@ return createRequestFunction(localVarAxiosArgs, globalAxios, BASE_PATH, configuration);

*/
async getConsumerGroupById(consumerGroupId: string, order?: 'asc' | 'desc', orderKey?: 'offset' | 'endOffset' | 'lag' | 'partition', partitionFilter?: number, topic?: string, options?: any): Promise<(axios?: AxiosInstance, basePath?: string) => AxiosPromise<ConsumerGroup>> {
async getConsumerGroupById(consumerGroupId: string, order?: 'asc' | 'desc', orderKey?: 'offset' | 'endOffset' | 'lag' | 'partition', partitionFilter?: number, topic?: string, options?: AxiosRequestConfig): Promise<(axios?: AxiosInstance, basePath?: string) => AxiosPromise<ConsumerGroup>> {
const localVarAxiosArgs = await localVarAxiosParamCreator.getConsumerGroupById(consumerGroupId, order, orderKey, partitionFilter, topic, options);

@@ -312,3 +312,3 @@ return createRequestFunction(localVarAxiosArgs, globalAxios, BASE_PATH, configuration);

*/
async getConsumerGroups(offset?: number, limit?: number, size?: number, page?: number, topic?: string, groupIdFilter?: string, order?: 'asc' | 'desc', orderKey?: 'name', options?: any): Promise<(axios?: AxiosInstance, basePath?: string) => AxiosPromise<ConsumerGroupList>> {
async getConsumerGroups(offset?: number, limit?: number, size?: number, page?: number, topic?: string, groupIdFilter?: string, order?: 'asc' | 'desc', orderKey?: 'name', options?: AxiosRequestConfig): Promise<(axios?: AxiosInstance, basePath?: string) => AxiosPromise<ConsumerGroupList>> {
const localVarAxiosArgs = await localVarAxiosParamCreator.getConsumerGroups(offset, limit, size, page, topic, groupIdFilter, order, orderKey, options);

@@ -325,3 +325,3 @@ return createRequestFunction(localVarAxiosArgs, globalAxios, BASE_PATH, configuration);

*/
async resetConsumerGroupOffset(consumerGroupId: string, consumerGroupResetOffsetParameters: ConsumerGroupResetOffsetParameters, options?: any): Promise<(axios?: AxiosInstance, basePath?: string) => AxiosPromise<ConsumerGroupResetOffsetResult>> {
async resetConsumerGroupOffset(consumerGroupId: string, consumerGroupResetOffsetParameters: ConsumerGroupResetOffsetParameters, options?: AxiosRequestConfig): Promise<(axios?: AxiosInstance, basePath?: string) => AxiosPromise<ConsumerGroupResetOffsetResult>> {
const localVarAxiosArgs = await localVarAxiosParamCreator.resetConsumerGroupOffset(consumerGroupId, consumerGroupResetOffsetParameters, options);

@@ -409,3 +409,3 @@ return createRequestFunction(localVarAxiosArgs, globalAxios, BASE_PATH, configuration);

*/
deleteConsumerGroupById(consumerGroupId: string, options?: any): AxiosPromise<void>;
deleteConsumerGroupById(consumerGroupId: string, options?: AxiosRequestConfig): AxiosPromise<void>;

@@ -424,3 +424,3 @@ /**

*/
getConsumerGroupById(consumerGroupId: string, order?: 'asc' | 'desc', orderKey?: 'offset' | 'endOffset' | 'lag' | 'partition', partitionFilter?: number, topic?: string, options?: any): AxiosPromise<ConsumerGroup>;
getConsumerGroupById(consumerGroupId: string, order?: 'asc' | 'desc', orderKey?: 'offset' | 'endOffset' | 'lag' | 'partition', partitionFilter?: number, topic?: string, options?: AxiosRequestConfig): AxiosPromise<ConsumerGroup>;

@@ -442,3 +442,3 @@ /**

*/
getConsumerGroups(offset?: number, limit?: number, size?: number, page?: number, topic?: string, groupIdFilter?: string, order?: 'asc' | 'desc', orderKey?: 'name', options?: any): AxiosPromise<ConsumerGroupList>;
getConsumerGroups(offset?: number, limit?: number, size?: number, page?: number, topic?: string, groupIdFilter?: string, order?: 'asc' | 'desc', orderKey?: 'name', options?: AxiosRequestConfig): AxiosPromise<ConsumerGroupList>;

@@ -454,3 +454,3 @@ /**

*/
resetConsumerGroupOffset(consumerGroupId: string, consumerGroupResetOffsetParameters: ConsumerGroupResetOffsetParameters, options?: any): AxiosPromise<ConsumerGroupResetOffsetResult>;
resetConsumerGroupOffset(consumerGroupId: string, consumerGroupResetOffsetParameters: ConsumerGroupResetOffsetParameters, options?: AxiosRequestConfig): AxiosPromise<ConsumerGroupResetOffsetResult>;

@@ -474,3 +474,3 @@ }

*/
public deleteConsumerGroupById(consumerGroupId: string, options?: any) {
public deleteConsumerGroupById(consumerGroupId: string, options?: AxiosRequestConfig) {
return GroupsApiFp(this.configuration).deleteConsumerGroupById(consumerGroupId, options).then((request) => request(this.axios, this.basePath));

@@ -491,3 +491,3 @@ }

*/
public getConsumerGroupById(consumerGroupId: string, order?: 'asc' | 'desc', orderKey?: 'offset' | 'endOffset' | 'lag' | 'partition', partitionFilter?: number, topic?: string, options?: any) {
public getConsumerGroupById(consumerGroupId: string, order?: 'asc' | 'desc', orderKey?: 'offset' | 'endOffset' | 'lag' | 'partition', partitionFilter?: number, topic?: string, options?: AxiosRequestConfig) {
return GroupsApiFp(this.configuration).getConsumerGroupById(consumerGroupId, order, orderKey, partitionFilter, topic, options).then((request) => request(this.axios, this.basePath));

@@ -511,3 +511,3 @@ }

*/
public getConsumerGroups(offset?: number, limit?: number, size?: number, page?: number, topic?: string, groupIdFilter?: string, order?: 'asc' | 'desc', orderKey?: 'name', options?: any) {
public getConsumerGroups(offset?: number, limit?: number, size?: number, page?: number, topic?: string, groupIdFilter?: string, order?: 'asc' | 'desc', orderKey?: 'name', options?: AxiosRequestConfig) {
return GroupsApiFp(this.configuration).getConsumerGroups(offset, limit, size, page, topic, groupIdFilter, order, orderKey, options).then((request) => request(this.axios, this.basePath));

@@ -525,5 +525,5 @@ }

*/
public resetConsumerGroupOffset(consumerGroupId: string, consumerGroupResetOffsetParameters: ConsumerGroupResetOffsetParameters, options?: any) {
public resetConsumerGroupOffset(consumerGroupId: string, consumerGroupResetOffsetParameters: ConsumerGroupResetOffsetParameters, options?: AxiosRequestConfig) {
return GroupsApiFp(this.configuration).resetConsumerGroupOffset(consumerGroupId, consumerGroupResetOffsetParameters, options).then((request) => request(this.axios, this.basePath));
}
}

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

import globalAxios, { AxiosPromise, AxiosInstance } from 'axios';
import globalAxios, { AxiosPromise, AxiosInstance, AxiosRequestConfig } from 'axios';
import { Configuration } from '../configuration';

@@ -45,3 +45,3 @@ // Some imports not used depending on template conditions

*/
createTopic: async (newTopicInput: NewTopicInput, options: any = {}): Promise<RequestArgs> => {
createTopic: async (newTopicInput: NewTopicInput, options: AxiosRequestConfig = {}): Promise<RequestArgs> => {
// verify required parameter 'newTopicInput' is not null or undefined

@@ -69,3 +69,3 @@ assertParamExists('createTopic', 'newTopicInput', newTopicInput)

setSearchParams(localVarUrlObj, localVarQueryParameter, options.query);
setSearchParams(localVarUrlObj, localVarQueryParameter);
let headersFromBaseOptions = baseOptions && baseOptions.headers ? baseOptions.headers : {};

@@ -87,3 +87,3 @@ localVarRequestOptions.headers = {...localVarHeaderParameter, ...headersFromBaseOptions, ...options.headers};

*/
deleteTopic: async (topicName: string, options: any = {}): Promise<RequestArgs> => {
deleteTopic: async (topicName: string, options: AxiosRequestConfig = {}): Promise<RequestArgs> => {
// verify required parameter 'topicName' is not null or undefined

@@ -110,3 +110,3 @@ assertParamExists('deleteTopic', 'topicName', topicName)

setSearchParams(localVarUrlObj, localVarQueryParameter, options.query);
setSearchParams(localVarUrlObj, localVarQueryParameter);
let headersFromBaseOptions = baseOptions && baseOptions.headers ? baseOptions.headers : {};

@@ -127,3 +127,3 @@ localVarRequestOptions.headers = {...localVarHeaderParameter, ...headersFromBaseOptions, ...options.headers};

*/
getTopic: async (topicName: string, options: any = {}): Promise<RequestArgs> => {
getTopic: async (topicName: string, options: AxiosRequestConfig = {}): Promise<RequestArgs> => {
// verify required parameter 'topicName' is not null or undefined

@@ -150,3 +150,3 @@ assertParamExists('getTopic', 'topicName', topicName)

setSearchParams(localVarUrlObj, localVarQueryParameter, options.query);
setSearchParams(localVarUrlObj, localVarQueryParameter);
let headersFromBaseOptions = baseOptions && baseOptions.headers ? baseOptions.headers : {};

@@ -173,3 +173,3 @@ localVarRequestOptions.headers = {...localVarHeaderParameter, ...headersFromBaseOptions, ...options.headers};

*/
getTopics: async (offset?: number, limit?: number, size?: number, filter?: string, page?: number, order?: 'asc' | 'desc', orderKey?: 'name' | 'partitions' | 'retention.ms' | 'retention.bytes', options: any = {}): Promise<RequestArgs> => {
getTopics: async (offset?: number, limit?: number, size?: number, filter?: string, page?: number, order?: 'asc' | 'desc', orderKey?: 'name' | 'partitions' | 'retention.ms' | 'retention.bytes', options: AxiosRequestConfig = {}): Promise<RequestArgs> => {
const localVarPath = `/topics`;

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

setSearchParams(localVarUrlObj, localVarQueryParameter, options.query);
setSearchParams(localVarUrlObj, localVarQueryParameter);
let headersFromBaseOptions = baseOptions && baseOptions.headers ? baseOptions.headers : {};

@@ -239,3 +239,3 @@ localVarRequestOptions.headers = {...localVarHeaderParameter, ...headersFromBaseOptions, ...options.headers};

*/
updateTopic: async (topicName: string, updateTopicInput: UpdateTopicInput, options: any = {}): Promise<RequestArgs> => {
updateTopic: async (topicName: string, updateTopicInput: UpdateTopicInput, options: AxiosRequestConfig = {}): Promise<RequestArgs> => {
// verify required parameter 'topicName' is not null or undefined

@@ -266,3 +266,3 @@ assertParamExists('updateTopic', 'topicName', topicName)

setSearchParams(localVarUrlObj, localVarQueryParameter, options.query);
setSearchParams(localVarUrlObj, localVarQueryParameter);
let headersFromBaseOptions = baseOptions && baseOptions.headers ? baseOptions.headers : {};

@@ -294,3 +294,3 @@ localVarRequestOptions.headers = {...localVarHeaderParameter, ...headersFromBaseOptions, ...options.headers};

*/
async createTopic(newTopicInput: NewTopicInput, options?: any): Promise<(axios?: AxiosInstance, basePath?: string) => AxiosPromise<Topic>> {
async createTopic(newTopicInput: NewTopicInput, options?: AxiosRequestConfig): Promise<(axios?: AxiosInstance, basePath?: string) => AxiosPromise<Topic>> {
const localVarAxiosArgs = await localVarAxiosParamCreator.createTopic(newTopicInput, options);

@@ -306,3 +306,3 @@ return createRequestFunction(localVarAxiosArgs, globalAxios, BASE_PATH, configuration);

*/
async deleteTopic(topicName: string, options?: any): Promise<(axios?: AxiosInstance, basePath?: string) => AxiosPromise<void>> {
async deleteTopic(topicName: string, options?: AxiosRequestConfig): Promise<(axios?: AxiosInstance, basePath?: string) => AxiosPromise<void>> {
const localVarAxiosArgs = await localVarAxiosParamCreator.deleteTopic(topicName, options);

@@ -318,3 +318,3 @@ return createRequestFunction(localVarAxiosArgs, globalAxios, BASE_PATH, configuration);

*/
async getTopic(topicName: string, options?: any): Promise<(axios?: AxiosInstance, basePath?: string) => AxiosPromise<Topic>> {
async getTopic(topicName: string, options?: AxiosRequestConfig): Promise<(axios?: AxiosInstance, basePath?: string) => AxiosPromise<Topic>> {
const localVarAxiosArgs = await localVarAxiosParamCreator.getTopic(topicName, options);

@@ -336,3 +336,3 @@ return createRequestFunction(localVarAxiosArgs, globalAxios, BASE_PATH, configuration);

*/
async getTopics(offset?: number, limit?: number, size?: number, filter?: string, page?: number, order?: 'asc' | 'desc', orderKey?: 'name' | 'partitions' | 'retention.ms' | 'retention.bytes', options?: any): Promise<(axios?: AxiosInstance, basePath?: string) => AxiosPromise<TopicsList>> {
async getTopics(offset?: number, limit?: number, size?: number, filter?: string, page?: number, order?: 'asc' | 'desc', orderKey?: 'name' | 'partitions' | 'retention.ms' | 'retention.bytes', options?: AxiosRequestConfig): Promise<(axios?: AxiosInstance, basePath?: string) => AxiosPromise<TopicsList>> {
const localVarAxiosArgs = await localVarAxiosParamCreator.getTopics(offset, limit, size, filter, page, order, orderKey, options);

@@ -349,3 +349,3 @@ return createRequestFunction(localVarAxiosArgs, globalAxios, BASE_PATH, configuration);

*/
async updateTopic(topicName: string, updateTopicInput: UpdateTopicInput, options?: any): Promise<(axios?: AxiosInstance, basePath?: string) => AxiosPromise<Topic>> {
async updateTopic(topicName: string, updateTopicInput: UpdateTopicInput, options?: AxiosRequestConfig): Promise<(axios?: AxiosInstance, basePath?: string) => AxiosPromise<Topic>> {
const localVarAxiosArgs = await localVarAxiosParamCreator.updateTopic(topicName, updateTopicInput, options);

@@ -438,3 +438,3 @@ return createRequestFunction(localVarAxiosArgs, globalAxios, BASE_PATH, configuration);

*/
createTopic(newTopicInput: NewTopicInput, options?: any): AxiosPromise<Topic>;
createTopic(newTopicInput: NewTopicInput, options?: AxiosRequestConfig): AxiosPromise<Topic>;

@@ -449,3 +449,3 @@ /**

*/
deleteTopic(topicName: string, options?: any): AxiosPromise<void>;
deleteTopic(topicName: string, options?: AxiosRequestConfig): AxiosPromise<void>;

@@ -460,3 +460,3 @@ /**

*/
getTopic(topicName: string, options?: any): AxiosPromise<Topic>;
getTopic(topicName: string, options?: AxiosRequestConfig): AxiosPromise<Topic>;

@@ -477,3 +477,3 @@ /**

*/
getTopics(offset?: number, limit?: number, size?: number, filter?: string, page?: number, order?: 'asc' | 'desc', orderKey?: 'name' | 'partitions' | 'retention.ms' | 'retention.bytes', options?: any): AxiosPromise<TopicsList>;
getTopics(offset?: number, limit?: number, size?: number, filter?: string, page?: number, order?: 'asc' | 'desc', orderKey?: 'name' | 'partitions' | 'retention.ms' | 'retention.bytes', options?: AxiosRequestConfig): AxiosPromise<TopicsList>;

@@ -489,3 +489,3 @@ /**

*/
updateTopic(topicName: string, updateTopicInput: UpdateTopicInput, options?: any): AxiosPromise<Topic>;
updateTopic(topicName: string, updateTopicInput: UpdateTopicInput, options?: AxiosRequestConfig): AxiosPromise<Topic>;

@@ -509,3 +509,3 @@ }

*/
public createTopic(newTopicInput: NewTopicInput, options?: any) {
public createTopic(newTopicInput: NewTopicInput, options?: AxiosRequestConfig) {
return TopicsApiFp(this.configuration).createTopic(newTopicInput, options).then((request) => request(this.axios, this.basePath));

@@ -522,3 +522,3 @@ }

*/
public deleteTopic(topicName: string, options?: any) {
public deleteTopic(topicName: string, options?: AxiosRequestConfig) {
return TopicsApiFp(this.configuration).deleteTopic(topicName, options).then((request) => request(this.axios, this.basePath));

@@ -535,3 +535,3 @@ }

*/
public getTopic(topicName: string, options?: any) {
public getTopic(topicName: string, options?: AxiosRequestConfig) {
return TopicsApiFp(this.configuration).getTopic(topicName, options).then((request) => request(this.axios, this.basePath));

@@ -554,3 +554,3 @@ }

*/
public getTopics(offset?: number, limit?: number, size?: number, filter?: string, page?: number, order?: 'asc' | 'desc', orderKey?: 'name' | 'partitions' | 'retention.ms' | 'retention.bytes', options?: any) {
public getTopics(offset?: number, limit?: number, size?: number, filter?: string, page?: number, order?: 'asc' | 'desc', orderKey?: 'name' | 'partitions' | 'retention.ms' | 'retention.bytes', options?: AxiosRequestConfig) {
return TopicsApiFp(this.configuration).getTopics(offset, limit, size, filter, page, order, orderKey, options).then((request) => request(this.axios, this.basePath));

@@ -568,5 +568,5 @@ }

*/
public updateTopic(topicName: string, updateTopicInput: UpdateTopicInput, options?: any) {
public updateTopic(topicName: string, updateTopicInput: UpdateTopicInput, options?: AxiosRequestConfig) {
return TopicsApiFp(this.configuration).updateTopic(topicName, updateTopicInput, options).then((request) => request(this.axios, this.basePath));
}
}

@@ -19,5 +19,5 @@ /* tslint:disable */

// @ts-ignore
import globalAxios, { AxiosPromise, AxiosInstance } from 'axios';
import globalAxios, { AxiosPromise, AxiosInstance, AxiosRequestConfig } from 'axios';
export const BASE_PATH = "http://localhost/rest".replace(/\/+$/, "");
export const BASE_PATH = "/rest".replace(/\/+$/, "");

@@ -42,3 +42,3 @@ /**

url: string;
options: any;
options: AxiosRequestConfig;
}

@@ -45,0 +45,0 @@

@@ -17,4 +17,4 @@ /* tslint:disable */

import { Configuration } from "./configuration";
import { RequiredError, RequestArgs } from "./base";
import { AxiosInstance } from 'axios';
import { RequiredError, RequestArgs } from "./base";
import { AxiosInstance, AxiosResponse } from 'axios';

@@ -135,6 +135,6 @@ /**

export const createRequestFunction = function (axiosArgs: RequestArgs, globalAxios: AxiosInstance, BASE_PATH: string, configuration?: Configuration) {
return (axios: AxiosInstance = globalAxios, basePath: string = BASE_PATH) => {
return <T = unknown, R = AxiosResponse<T>>(axios: AxiosInstance = globalAxios, basePath: string = BASE_PATH) => {
const axiosRequestArgs = {...axiosArgs.options, url: (configuration?.basePath || basePath) + axiosArgs.url};
return axios.request(axiosRequestArgs);
return axios.request<T, R>(axiosRequestArgs);
};
}

@@ -28,2 +28,1 @@ /* tslint:disable */

@@ -29,5 +29,4 @@ /* tslint:disable */

*/
items?: Array<AclBinding>;
'items'?: Array<AclBinding>;
}

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

*/
resourceType: AclResourceType;
'resourceType': AclResourceType;
/**

@@ -39,3 +39,3 @@ *

*/
resourceName: string;
'resourceName': string;
/**

@@ -46,3 +46,3 @@ *

*/
patternType: AclPatternType;
'patternType': AclPatternType;
/**

@@ -53,3 +53,3 @@ * Identifies the user or service account to which an ACL entry is bound. The literal prefix value of `User:` is required. May be used to specify all users with value `User:*`.

*/
principal: string;
'principal': string;
/**

@@ -60,3 +60,3 @@ *

*/
operation: AclOperation;
'operation': AclOperation;
/**

@@ -67,5 +67,4 @@ *

*/
permission: AclPermissionType;
'permission': AclPermissionType;
}

@@ -23,16 +23,18 @@ /* tslint:disable */

export enum AclOperationFilter {
All = 'ALL',
Read = 'READ',
Write = 'WRITE',
Create = 'CREATE',
Delete = 'DELETE',
Alter = 'ALTER',
Describe = 'DESCRIBE',
DescribeConfigs = 'DESCRIBE_CONFIGS',
AlterConfigs = 'ALTER_CONFIGS',
Any = 'ANY'
}
export const AclOperationFilter = {
All: 'ALL',
Read: 'READ',
Write: 'WRITE',
Create: 'CREATE',
Delete: 'DELETE',
Alter: 'ALTER',
Describe: 'DESCRIBE',
DescribeConfigs: 'DESCRIBE_CONFIGS',
AlterConfigs: 'ALTER_CONFIGS',
Any: 'ANY'
} as const;
export type AclOperationFilter = typeof AclOperationFilter[keyof typeof AclOperationFilter];

@@ -23,15 +23,17 @@ /* tslint:disable */

export enum AclOperation {
All = 'ALL',
Read = 'READ',
Write = 'WRITE',
Create = 'CREATE',
Delete = 'DELETE',
Alter = 'ALTER',
Describe = 'DESCRIBE',
DescribeConfigs = 'DESCRIBE_CONFIGS',
AlterConfigs = 'ALTER_CONFIGS'
}
export const AclOperation = {
All: 'ALL',
Read: 'READ',
Write: 'WRITE',
Create: 'CREATE',
Delete: 'DELETE',
Alter: 'ALTER',
Describe: 'DESCRIBE',
DescribeConfigs: 'DESCRIBE_CONFIGS',
AlterConfigs: 'ALTER_CONFIGS'
} as const;
export type AclOperation = typeof AclOperation[keyof typeof AclOperation];

@@ -23,10 +23,12 @@ /* tslint:disable */

export enum AclPatternTypeFilter {
Literal = 'LITERAL',
Prefixed = 'PREFIXED',
Any = 'ANY',
Match = 'MATCH'
}
export const AclPatternTypeFilter = {
Literal: 'LITERAL',
Prefixed: 'PREFIXED',
Any: 'ANY',
Match: 'MATCH'
} as const;
export type AclPatternTypeFilter = typeof AclPatternTypeFilter[keyof typeof AclPatternTypeFilter];

@@ -23,8 +23,10 @@ /* tslint:disable */

export enum AclPatternType {
Literal = 'LITERAL',
Prefixed = 'PREFIXED'
}
export const AclPatternType = {
Literal: 'LITERAL',
Prefixed: 'PREFIXED'
} as const;
export type AclPatternType = typeof AclPatternType[keyof typeof AclPatternType];

@@ -23,9 +23,11 @@ /* tslint:disable */

export enum AclPermissionTypeFilter {
Allow = 'ALLOW',
Deny = 'DENY',
Any = 'ANY'
}
export const AclPermissionTypeFilter = {
Allow: 'ALLOW',
Deny: 'DENY',
Any: 'ANY'
} as const;
export type AclPermissionTypeFilter = typeof AclPermissionTypeFilter[keyof typeof AclPermissionTypeFilter];

@@ -23,8 +23,10 @@ /* tslint:disable */

export enum AclPermissionType {
Allow = 'ALLOW',
Deny = 'DENY'
}
export const AclPermissionType = {
Allow: 'ALLOW',
Deny: 'DENY'
} as const;
export type AclPermissionType = typeof AclPermissionType[keyof typeof AclPermissionType];

@@ -23,11 +23,13 @@ /* tslint:disable */

export enum AclResourceTypeFilter {
Any = 'ANY',
Group = 'GROUP',
Topic = 'TOPIC',
Cluster = 'CLUSTER',
TransactionalId = 'TRANSACTIONAL_ID'
}
export const AclResourceTypeFilter = {
Any: 'ANY',
Group: 'GROUP',
Topic: 'TOPIC',
Cluster: 'CLUSTER',
TransactionalId: 'TRANSACTIONAL_ID'
} as const;
export type AclResourceTypeFilter = typeof AclResourceTypeFilter[keyof typeof AclResourceTypeFilter];

@@ -23,10 +23,12 @@ /* tslint:disable */

export enum AclResourceType {
Group = 'GROUP',
Topic = 'TOPIC',
Cluster = 'CLUSTER',
TransactionalId = 'TRANSACTIONAL_ID'
}
export const AclResourceType = {
Group: 'GROUP',
Topic: 'TOPIC',
Cluster: 'CLUSTER',
TransactionalId: 'TRANSACTIONAL_ID'
} as const;
export type AclResourceType = typeof AclResourceType[keyof typeof AclResourceType];

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

*/
key?: string;
'key'?: string;
/**

@@ -35,5 +35,4 @@ * Value to indicate the setting on the topic configuration entry.

*/
value?: string;
'value'?: string;
}

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

*/
items?: Array<ConsumerGroup>;
'items'?: Array<ConsumerGroup>;
/**

@@ -36,3 +36,3 @@ * The total number of consumer groups.

*/
total?: number;
'total'?: number;
/**

@@ -43,3 +43,3 @@ * The number of consumer groups per page.

*/
size?: number;
'size'?: number;
/**

@@ -50,3 +50,3 @@ * The page

*/
page?: number;
'page'?: number;
/**

@@ -58,3 +58,3 @@ * Offset of the topic list

*/
offset?: number;
'offset'?: number;
/**

@@ -66,3 +66,3 @@ * Maximum of returned topics

*/
limit?: number;
'limit'?: number;
/**

@@ -74,5 +74,4 @@ * The total number of consumer groups.

*/
count?: number;
'count'?: number;
}

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

*/
value?: string;
'value'?: string;
/**

@@ -36,3 +36,3 @@ *

*/
offset: ConsumerGroupResetOffsetParametersOffsetEnum;
'offset': ConsumerGroupResetOffsetParametersOffsetEnum;
/**

@@ -43,17 +43,14 @@ *

*/
topics?: Array<TopicsToResetOffset>;
'topics'?: Array<TopicsToResetOffset>;
}
/**
* @export
* @enum {string}
*/
export enum ConsumerGroupResetOffsetParametersOffsetEnum {
Timestamp = 'timestamp',
Absolute = 'absolute',
Latest = 'latest',
Earliest = 'earliest'
}
export const ConsumerGroupResetOffsetParametersOffsetEnum = {
Timestamp: 'timestamp',
Absolute: 'absolute',
Latest: 'latest',
Earliest: 'earliest'
} as const;
export type ConsumerGroupResetOffsetParametersOffsetEnum = typeof ConsumerGroupResetOffsetParametersOffsetEnum[keyof typeof ConsumerGroupResetOffsetParametersOffsetEnum];

@@ -29,5 +29,4 @@ /* tslint:disable */

*/
items?: Array<ConsumerGroupResetOffsetResultItem>;
'items'?: Array<ConsumerGroupResetOffsetResultItem>;
}

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

*/
topic?: string;
'topic'?: string;
/**

@@ -35,3 +35,3 @@ *

*/
partition?: number;
'partition'?: number;
/**

@@ -42,5 +42,4 @@ *

*/
offset?: number;
'offset'?: number;
}

@@ -27,2 +27,1 @@ /* tslint:disable */

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

*/
groupId: string;
'groupId': string;
/**

@@ -36,3 +36,3 @@ *

*/
state?: ConsumerGroupStateEnum;
'state'?: ConsumerGroupStateEnum;
/**

@@ -43,19 +43,16 @@ * The list of consumers associated with this consumer group

*/
consumers: Array<Consumer>;
'consumers': Array<Consumer>;
}
/**
* @export
* @enum {string}
*/
export enum ConsumerGroupStateEnum {
Stable = 'STABLE',
Dead = 'DEAD',
Empty = 'EMPTY',
CompletingRebalance = 'COMPLETING_REBALANCE',
PreparingRebalance = 'PREPARING_REBALANCE',
Unknown = 'UNKNOWN'
}
export const ConsumerGroupStateEnum = {
Stable: 'STABLE',
Dead: 'DEAD',
Empty: 'EMPTY',
CompletingRebalance: 'COMPLETING_REBALANCE',
PreparingRebalance: 'PREPARING_REBALANCE',
Unknown: 'UNKNOWN'
} as const;
export type ConsumerGroupStateEnum = typeof ConsumerGroupStateEnum[keyof typeof ConsumerGroupStateEnum];

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

*/
groupId: string;
'groupId': string;
/**

@@ -35,3 +35,3 @@ * The unique topic name to which this consumer belongs

*/
topic: string;
'topic': string;
/**

@@ -42,3 +42,3 @@ * The partition number to which this consumer group is assigned to.

*/
partition: number;
'partition': number;
/**

@@ -49,3 +49,3 @@ * Offset denotes the position of the consumer in a partition.

*/
offset: number;
'offset': number;
/**

@@ -56,3 +56,3 @@ * The log end offset is the offset of the last message written to a log.

*/
logEndOffset?: number;
'logEndOffset'?: number;
/**

@@ -63,3 +63,3 @@ * Offset Lag is the delta between the last produced message and the last consumer\'s committed offset.

*/
lag: number;
'lag': number;
/**

@@ -70,5 +70,4 @@ * The member ID is a unique identifier given to a consumer by the coordinator upon initially joining the group.

*/
memberId?: string;
'memberId'?: string;
}

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

*/
code?: number;
'code'?: number;
/**

@@ -35,3 +35,3 @@ *

*/
error_message?: string;
'error_message'?: string;
/**

@@ -42,5 +42,4 @@ *

*/
_class?: string;
'class'?: string;
}

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

*/
name: string;
'name': string;
/**

@@ -36,5 +36,4 @@ *

*/
settings: TopicSettings;
'settings': TopicSettings;
}

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

*/
partition: number;
'partition': number;
/**

@@ -36,3 +36,3 @@ * Unique id for the partition (deprecated, use `partition` instead)

*/
id?: number;
'id'?: number;
/**

@@ -43,3 +43,3 @@ * List of replicas for the partition

*/
replicas?: Array<object>;
'replicas'?: Array<object>;
/**

@@ -50,3 +50,3 @@ * List in-sync replicas for this partition.

*/
isr?: Array<object>;
'isr'?: Array<object>;
/**

@@ -57,5 +57,4 @@ * Kafka server / broker.

*/
leader?: object;
'leader'?: object;
}

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

*/
total: number;
'total': number;
/**

@@ -35,3 +35,3 @@ * Current page number (returned for fetch requests)

*/
page?: number;
'page'?: number;
/**

@@ -42,5 +42,4 @@ * Number of entries per page (returned for fetch requests)

*/
size?: number;
'size'?: number;
}

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

*/
numPartitions: number;
'numPartitions': number;
/**

@@ -36,5 +36,4 @@ * Topic configuration entry.

*/
config?: Array<ConfigEntry>;
'config'?: Array<ConfigEntry>;
}

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

*/
name?: string;
'name'?: string;
/**

@@ -37,3 +37,3 @@ * Topic configuration entry.

*/
config?: Array<ConfigEntry>;
'config'?: Array<ConfigEntry>;
/**

@@ -44,5 +44,4 @@ * Partitions for this topic.

*/
partitions?: Array<Partition>;
'partitions'?: Array<Partition>;
}

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

*/
page?: number;
'page'?: number;
/**

@@ -36,3 +36,3 @@ * number of entries per page

*/
size?: number;
'size'?: number;
/**

@@ -44,3 +44,3 @@ * Offset of the topic list

*/
offset?: number;
'offset'?: number;
/**

@@ -52,3 +52,3 @@ * Maximum of returned topics

*/
limit?: number;
'limit'?: number;
/**

@@ -59,3 +59,3 @@ * Total number of topics

*/
total?: number;
'total'?: number;
/**

@@ -66,5 +66,4 @@ * List of topics

*/
items?: Array<Topic>;
'items'?: Array<Topic>;
}

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

*/
topic: string;
'topic': string;
/**

@@ -35,5 +35,4 @@ *

*/
partitions?: Array<number>;
'partitions'?: Array<number>;
}

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

*/
config?: Array<ConfigEntry>;
'config'?: Array<ConfigEntry>;
/**

@@ -36,5 +36,4 @@ * Number of partitions (only increasing supported)

*/
numPartitions?: number;
'numPartitions'?: number;
}
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