()
| 1220 | // Event (NOTE: not a Django model, stored in ClickHouse table `events`) |
| 1221 | |
| 1222 | public async fetchEvents(): Promise<ClickHouseEvent[]> { |
| 1223 | const queryResult = await this.clickhouseQuery<RawClickHouseEvent>( |
| 1224 | `SELECT * FROM events ORDER BY timestamp ASC` |
| 1225 | ) |
| 1226 | return queryResult.data.map(parseRawClickHouseEvent) |
| 1227 | } |
| 1228 | |
| 1229 | public async fetchDeadLetterQueueEvents(): Promise<DeadLetterQueueEvent[]> { |
| 1230 | const result = await this.clickhouseQuery(`SELECT * FROM events_dead_letter_queue ORDER BY _timestamp ASC`) |
no outgoing calls