mqttMessage.d.ts 1.4 KB

1234567891011121314151617181920212223242526272829303132333435
  1. export interface MqttMessage {
  2. id?: number;
  3. clientid: string;
  4. topic: string;
  5. payload?: string;
  6. qos: number;
  7. retain: number;
  8. message_id?: string;
  9. message_type: 'publish' | 'subscribe' | 'unsubscribe';
  10. timestamp: number;
  11. node: string;
  12. username?: string;
  13. proto_ver: number;
  14. payload_format?: string;
  15. created_at?: Date;
  16. message_time: Date;
  17. }
  18. export declare class MqttMessageModel {
  19. static getAll(limit?: number, offset?: number): Promise<MqttMessage[]>;
  20. static getByClientId(clientid: string, limit?: number): Promise<MqttMessage[]>;
  21. static getByTopic(topic: string, limit?: number): Promise<MqttMessage[]>;
  22. static getByType(messageType: string, limit?: number): Promise<MqttMessage[]>;
  23. static getByTimeRange(startTime: Date, endTime: Date): Promise<MqttMessage[]>;
  24. static getCount(): Promise<number>;
  25. static getTypeStats(): Promise<any[]>;
  26. static getQosStats(): Promise<any[]>;
  27. static getSizeStats(): Promise<any[]>;
  28. static getHourlyStats(hours?: number): Promise<any[]>;
  29. static getPopularTopics(limit?: number): Promise<any[]>;
  30. static getActiveClients(limit?: number): Promise<any[]>;
  31. static create(messageData: Omit<MqttMessage, 'id' | 'created_at'>): Promise<MqttMessage>;
  32. static getById(id: number): Promise<MqttMessage | null>;
  33. static getHeatmapData(days?: number): Promise<any[]>;
  34. }
  35. //# sourceMappingURL=mqttMessage.d.ts.map