///
import * as EventEmitter from "events";
import MongoWrapper from "./MongoWrapper";
import { TopicConfig, Hook } from "../interfaces";
import { Metrics } from "../Metrics";
export default class MongoPoller extends EventEmitter {
collected: {
topicConfigs: TopicConfig[];
hooks: Hook[];
};
private readonly metrics;
private readonly topicConfigModel;
private readonly hookModel;
private intv;
private topicConfigHash;
constructor(mongoWrapper: MongoWrapper, metrics: Metrics);
start(intervalMs?: number): Promise;
close(): void;
getCollected(): {
topicConfigs: TopicConfig[];
hooks: Hook[];
};
private onInterval;
}
//# sourceMappingURL=MongoPoller.d.ts.map