kylefang/DefinitelyTyped
1
0
Fork 0
mirror of https://github.com/zhigang1992/DefinitelyTyped.git synced 2026-04-22 20:39:17 +08:00
Code Issues Packages Projects Releases Wiki Activity

kafka-node: Fix 'on' return types, added FetchRequest. (#13451)

Browse Source
This commit is contained in:
Joe Herman
2016-12-27 19:38:56 -05:00
committed by Andy
parent bec25785d7
commit 2b3fb9d080
1 changed files with 18 additions and 12 deletions
Download Patch File Download Diff File Expand all files Collapse all files

30
kafka-node/index.d.ts vendored
View File

@@ -4,7 +4,6 @@
// Definitions: https://github.com/DefinitelyTyped/DefinitelyTyped
// # Classes
export declare class Client {
constructor(connectionString: string, clientId: string, options?: ZKOptions);
@@ -14,24 +13,24 @@ export declare class Client {
export declare class Producer {
constructor(client: Client);
on(eventName: string, cb: () => any): void;
on(eventName: string, cb: (error: any) => any): void;
on(eventName: string, cb: () => any): Producer;
on(eventName: string, cb: (error: any) => any): Producer;
send(payloads: Array<ProduceRequest>, cb: (error: any, data: any) => any): void;
createTopics(topics: Array<string>, async: boolean, cb?: (error: any, data: any) => any): void;
}
export declare class HighLevelProducer {
constructor(client: Client);
on(eventName: string, cb: () => any): void;
on(eventName: string, cb: (error: any) => any): void;
on(eventName: string, cb: () => any): HighLevelProducer;
on(eventName: string, cb: (error: any) => any): HighLevelProducer;
send(payloads: Array<ProduceRequest>, cb: (error: any, data: any) => any): void;
createTopics(topics: Array<string>, async: boolean, cb?: (error: any, data: any) => any): void;
}
export declare class Consumer {
constructor(client: Client, fetchRequests: Array<OffsetFetchRequest>, options: ConsumerOptions);
on(eventName: string, cb: (message: string) => any): void;
on(eventName: string, cb: (error: any) => any): void;
constructor(client: Client, fetchRequests: Array<FetchRequest>, options: ConsumerOptions);
on(eventName: string, cb: (message: string) => any): Consumer;
on(eventName: string, cb: (error: any) => any): Consumer;
addTopics(topics: Array<string>, cb: (error: any, added: boolean) => any): void;
addTopics(topics: Array<Topic>, cb: (error: any, added: boolean) => any, fromOffset: boolean): void;
removeTopics(topics: Array<string>, cb: (error: any, removed: boolean) => any): void;
@@ -46,8 +45,8 @@ export declare class Consumer {
export declare class HighLevelConsumer {
constructor(client: Client, payloads: Array<Topic>, options: ConsumerOptions);
on(eventName: string, cb: (message: string) => any): void;
on(eventName: string, cb: (error: any) => any): void;
on(eventName: string, cb: (message: string) => any): HighLevelConsumer;
on(eventName: string, cb: (error: any) => any): HighLevelConsumer;
addTopics(topics: Array<string>, cb: (error: any, added: boolean) => any): void;
addTopics(topics: Array<Topic>, cb: (error: any, added: boolean) => any, fromOffset: boolean): void;
removeTopics(topics: Array<string>, cb: (error: any, removed: boolean) => any): void;
@@ -62,12 +61,12 @@ export declare class HighLevelConsumer {
export declare class Offset {
constructor(client: Client);
on(eventName: string, cb: () => any): void;
on(eventName: string, cb: () => any): Offset;
fetch(payloads: Array<OffsetRequest>, cb: (error: any, data: any) => any): void;
commit(groupId: string, payloads: Array<OffsetCommitRequest>, cb: (error: any, data: any) => any): void;
fetchCommits(groupId: string, payloads: Array<OffsetFetchRequest>, cb: (error: any, data: any) => any): void;
fetchLatestOffsets(topics: Array<string>, cb: (error: any, data: any) => any): void;
on(eventName: string, cb: (error: any) => any): void;
on(eventName: string, cb: (error: any) => any): Offset;
}
export declare class KeyedMessage {
@@ -84,6 +83,7 @@ export interface ZKOptions {
export interface ProduceRequest {
topic: string;
messages: any; // Array<string> | Array<KeyedMessage> | string | KeyedMessage
key?: string;
partition?: number;
attributes?: number;
}
@@ -124,3 +124,9 @@ export interface OffsetFetchRequest {
topic: string;
partition?: number;
}
export interface FetchRequest {
topic: string;
offset?: number;
}