Skip to content
Merged
Changes from 1 commit
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Prev Previous commit
Next Next commit
Removed all unrelated format changed in types/index.d.ts
  • Loading branch information
nirga committed Jan 3, 2021
commit 5f42dbe90514169ba8eed13e3497ee671f2c01b9
86 changes: 37 additions & 49 deletions types/index.d.ts
Original file line number Diff line number Diff line change
Expand Up @@ -33,9 +33,9 @@ export interface KafkaConfig {
}

export interface ISocketFactoryArgs {
host: string
port: number
ssl: tls.ConnectionOptions
host: string,
port: number,
ssl: tls.ConnectionOptions,
onConnect: () => void
}

Expand All @@ -46,22 +46,15 @@ export interface OauthbearerProviderResponse {
}

type SASLMechanismOptionsMap = {
plain: { username: string; password: string }
'scram-sha-256': { username: string; password: string }
'scram-sha-512': { username: string; password: string }
aws: {
authorizationIdentity: string
accessKeyId: string
secretAccessKey: string
sessionToken?: string
}
oauthbearer: { oauthBearerProvider: () => Promise<OauthbearerProviderResponse> }
'plain': { username: string, password: string },
'scram-sha-256': { username: string, password: string },
'scram-sha-512': { username: string, password: string },
'aws': { authorizationIdentity: string, accessKeyId: string, secretAccessKey: string, sessionToken?: string },
'oauthbearer': { oauthBearerProvider: () => Promise<OauthbearerProviderResponse> }
}

export type SASLMechanism = keyof SASLMechanismOptionsMap
type SASLMechanismOptions<T> = T extends SASLMechanism
? { mechanism: T } & SASLMechanismOptionsMap[T]
: never
type SASLMechanismOptions<T> = T extends SASLMechanism ? { mechanism: T } & SASLMechanismOptionsMap[T] : never
export type SASLOptions = SASLMechanismOptions<SASLMechanism>

export interface ProducerConfig {
Expand Down Expand Up @@ -680,13 +673,7 @@ export type MemberDescription = {
}

// See https://github.com/apache/kafka/blob/2.4.0/clients/src/main/java/org/apache/kafka/common/ConsumerGroupState.java#L25
export type ConsumerGroupState =
| 'Unknown'
| 'PreparingRebalance'
| 'CompletingRebalance'
| 'Stable'
| 'Dead'
| 'Empty'
export type ConsumerGroupState = 'Unknown' | 'PreparingRebalance' | 'CompletingRebalance' | 'Stable' | 'Dead' | 'Empty';

export type GroupDescription = {
groupId: string
Expand Down Expand Up @@ -892,10 +879,10 @@ export var CompressionCodecs: {
}

export class KafkaJSError extends Error {
readonly message: Error['message']
readonly name: string
readonly retriable: boolean
readonly helpUrl?: string
readonly message: Error["message"];
readonly name: string;
readonly retriable: boolean;
readonly helpUrl?: string;

constructor(e: Error | string, metadata?: KafkaJSErrorMetadata)
}
Expand All @@ -905,36 +892,36 @@ export class KafkaJSNonRetriableError extends KafkaJSError {
}

export class KafkaJSProtocolError extends KafkaJSError {
readonly code: number
readonly type: string
readonly code: number;
readonly type: string;
constructor(e: Error | string)
}

export class KafkaJSOffsetOutOfRange extends KafkaJSProtocolError {
readonly topic: string
readonly partition: number
readonly topic: string;
readonly partition: number;
constructor(e: Error | string, metadata?: KafkaJSOffsetOutOfRangeMetadata)
}

export class KafkaJSNumberOfRetriesExceeded extends KafkaJSNonRetriableError {
readonly stack: string
readonly originalError: Error
readonly retryCount: number
readonly retryTime: number
readonly stack: string;
readonly originalError: Error;
readonly retryCount: number;
readonly retryTime: number;
constructor(e: Error | string, metadata?: KafkaJSNumberOfRetriesExceededMetadata)
}

export class KafkaJSConnectionError extends KafkaJSError {
readonly broker: string
readonly broker: string;
constructor(e: Error | string, metadata?: KafkaJSConnectionErrorMetadata)
}

export class KafkaJSRequestTimeoutError extends KafkaJSError {
readonly broker: string
readonly correlationId: number
readonly createdAt: number
readonly sentAt: number
readonly pendingDuration: number
readonly broker: string;
readonly correlationId: number;
readonly createdAt: number;
readonly sentAt: number;
readonly pendingDuration: number;
constructor(e: Error | string, metadata?: KafkaJSRequestTimeoutErrorMetadata)
}

Expand All @@ -943,18 +930,18 @@ export class KafkaJSMetadataNotLoaded extends KafkaJSError {
}

export class KafkaJSTopicMetadataNotLoaded extends KafkaJSMetadataNotLoaded {
readonly topic: string
readonly topic: string;
constructor(e: Error | string, metadata?: KafkaJSTopicMetadataNotLoadedMetadata)
}

export class KafkaJSStaleTopicMetadataAssignment extends KafkaJSError {
readonly topic: string
readonly unknownPartitions: number
readonly topic: string;
readonly unknownPartitions: number;
constructor(e: Error | string, metadata?: KafkaJSStaleTopicMetadataAssignmentMetadata)
}

export class KafkaJSServerDoesNotSupportApiKey extends KafkaJSNonRetriableError {
readonly apiKey: number
readonly apiKey: number;
readonly apiName: string
constructor(e: Error | string, metadata?: KafkaJSServerDoesNotSupportApiKeyMetadata)
}
Expand Down Expand Up @@ -992,7 +979,7 @@ export class KafkaJSUnsupportedMagicByteInMessageSet extends KafkaJSError {
}

export class KafkaJSDeleteGroupsError extends KafkaJSError {
readonly groups: DeleteGroupsResult[]
readonly groups: DeleteGroupsResult[];
constructor(e: Error | string, groups?: KafkaJSDeleteGroupsErrorGroups[])
}

Expand All @@ -1006,14 +993,15 @@ export interface KafkaJSDeleteGroupsErrorGroups {
error: KafkaJSError
}


export interface KafkaJSDeleteTopicRecordsErrorTopic {
topic: string
topic: string,
partitions: KafkaJSDeleteTopicRecordsErrorPartition[]
}

export interface KafkaJSDeleteTopicRecordsErrorPartition {
partition: number
offset: string
partition: number;
offset: string;
error: KafkaJSError
}

Expand Down