| 1234567891011121314151617181920212223242526272829303132333435 |
- export interface MqttMessage {
- id?: number;
- clientid: string;
- topic: string;
- payload?: string;
- qos: number;
- retain: number;
- message_id?: string;
- message_type: 'publish' | 'subscribe' | 'unsubscribe';
- timestamp: number;
- node: string;
- username?: string;
- proto_ver: number;
- payload_format?: string;
- created_at?: Date;
- message_time: Date;
- }
- export declare class MqttMessageModel {
- static getAll(limit?: number, offset?: number): Promise<MqttMessage[]>;
- static getByClientId(clientid: string, limit?: number): Promise<MqttMessage[]>;
- static getByTopic(topic: string, limit?: number): Promise<MqttMessage[]>;
- static getByType(messageType: string, limit?: number): Promise<MqttMessage[]>;
- static getByTimeRange(startTime: Date, endTime: Date): Promise<MqttMessage[]>;
- static getCount(): Promise<number>;
- static getTypeStats(): Promise<any[]>;
- static getQosStats(): Promise<any[]>;
- static getSizeStats(): Promise<any[]>;
- static getHourlyStats(hours?: number): Promise<any[]>;
- static getPopularTopics(limit?: number): Promise<any[]>;
- static getActiveClients(limit?: number): Promise<any[]>;
- static create(messageData: Omit<MqttMessage, 'id' | 'created_at'>): Promise<MqttMessage>;
- static getById(id: number): Promise<MqttMessage | null>;
- static getHeatmapData(days?: number): Promise<any[]>;
- }
- //# sourceMappingURL=mqttMessage.d.ts.map
|