blob: 766efaefa31009aee7359b1f70f836fe9f81fe37 (
plain) (
blame)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
|
/// <reference types="node" />
import "./MongoBigInt";
import mongoose, { Collection } from "mongoose";
import { ChangeStream, ChangeEvent } from "mongodb";
import EventEmitter from "events";
declare const _default: mongoose.Connection;
export default _default;
export interface MongooseCache {
on(event: "delete", listener: (id: string) => void): this;
on(event: "change", listener: (data: any) => void): this;
on(event: "insert", listener: (data: any) => void): this;
on(event: "close", listener: () => void): this;
}
export declare class MongooseCache extends EventEmitter {
collection: Collection;
pipeline: Array<Record<string, unknown>>;
opts: {
onlyEvents: boolean;
};
stream: ChangeStream;
data: any;
constructor(collection: Collection, pipeline: Array<Record<string, unknown>>, opts: {
onlyEvents: boolean;
});
init: () => Promise<void>;
convertResult: (obj: any) => any;
change: (doc: ChangeEvent) => boolean | Promise<any> | undefined;
destroy: () => Promise<any> | undefined;
}
|