1 |
|
2 | import { Socket } from "net";
|
3 | import { TLSSocket } from "tls";
|
4 | export declare type Callback<T = any> = (err?: Error | null, result?: T) => void;
|
5 | export declare type NetStream = Socket | TLSSocket;
|
6 | export declare type CommandParameter = string | Buffer | number | any[];
|
7 | export interface Respondable {
|
8 | name: string;
|
9 | args: CommandParameter[];
|
10 | resolve(result: any): void;
|
11 | reject(error: Error): void;
|
12 | }
|
13 | export interface PipelineWriteableStream {
|
14 | isPipeline: true;
|
15 | write(data: string | Buffer): unknown;
|
16 | destination: {
|
17 | redis: {
|
18 | stream: NetStream;
|
19 | };
|
20 | };
|
21 | }
|
22 | export declare type WriteableStream = NetStream | PipelineWriteableStream;
|
23 | export interface CommandItem {
|
24 | command: Respondable;
|
25 | stream: WriteableStream;
|
26 | select: number;
|
27 | }
|
28 | export interface ScanStreamOptions {
|
29 | match?: string;
|
30 | type?: string;
|
31 | count?: number;
|
32 | }
|