Skip to content

Commit

Permalink
Update README.md
Browse files Browse the repository at this point in the history
  • Loading branch information
lmangani authored Jan 26, 2025
1 parent 49bdcd3 commit 7f30259
Showing 1 changed file with 42 additions and 3 deletions.
45 changes: 42 additions & 3 deletions README.md
Original file line number Diff line number Diff line change
Expand Up @@ -6,11 +6,28 @@
##### Features

- Bun Server
- InfluxDB3/FlightSQL API
- Object Storage, Parquet
- [x] Bun Server
- [x] hep-js sockets
- [ ] parsip extractor
- [x] InfluxDB3/FlightSQL API
- [x] Object Storage, Parquet
- [ ] HOMER Search API

```mermaid
%%{
init: {
'theme': 'base',
'themeVariables': {
'primaryColor': '#BB2528',
'primaryTextColor': '#fff',
'primaryBorderColor': '#7C0000',
'lineColor': '#F8B229',
'secondaryColor': '#006100',
'tertiaryColor': '#fff'
}
}
}%%
graph TD;
HEP-Client-- hep -->HEPop:9069;
HEPop:9069-- gRPC -->IOx:8181;
Expand Down Expand Up @@ -49,3 +66,25 @@ The repository includes a stand-alone example using hepop and influxdb3 with fil
```
docker compose up
```

### Ingestion
Just send hep to the server using UDP/TCP. Each HEP type will generate a table _(hep_1, hep_100, etc)_

### Query
Query the HEP data using the HTTP API or Flight SQL
#### API
```bash
# curl http://127.0.0.1:8181/api/v3/query_sql --data '{"db": "hep", "q": "select * from hep_1 limit 1"}'
```
```json
[{"capture_id":2001,"capture_pass":"myHep","correlation_id":"067d3@127.0.0.1","dst_ip":"192.168.1.2","dst_port":5060,"ip_family":2,"payload":"OPTIONS sip:127.0.0.1 SIP/2.0Call-ID: 067d3@127.0.0.1CSeq: 9999 OPTIONSFrom: <sip:nodejs@127.0.0.1>;tag=2628881569To: <sip:nodejs@127.0.0.1>Via: SIP/2.0/UDP 127.0.0.1:48495;branch=z9hG4bK9b82aa8fb4c7705466a3456dfff7f384333332Max-Forwards: 70User-Agent: HEPGEN-UACContent-Length: 0","proto_type":0,"protocol":17,"src_ip":"192.168.1.1","src_port":5060,"time":"2025-01-26T18:44:07.120","time_sec":1737917047,"time_usec":120000,"type":"1"}]
```
#### Flight
```sql
influxdb3 query --database hep "SELECT * FROM hep_1 limit 1"
+------------+--------------+-----------------+-------------+----------+-----------+------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------+------------+----------+-------------+----------+-------------------------+------------+-----------+------+
| capture_id | capture_pass | correlation_id | dst_ip | dst_port | ip_family | payload | proto_type | protocol | src_ip | src_port | time | time_sec | time_usec | type |
+------------+--------------+-----------------+-------------+----------+-----------+------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------+------------+----------+-------------+----------+-------------------------+------------+-----------+------+
| 2001 | myHep | 067d3@127.0.0.1 | 192.168.1.2 | 5060 | 2 | OPTIONS sip:127.0.0.1 SIP/2.0Call-ID: 067d3@127.0.0.1CSeq: 9999 OPTIONSFrom: <sip:nodejs@127.0.0.1>;tag=2628881569To: <sip:nodejs@127.0.0.1>Via: SIP/2.0/UDP 127.0.0.1:48495;branch=z9hG4bK9b82aa8fb4c7705466a3456dfff7f384333332Max-Forwards: 70User-Agent: HEPGEN-UACContent-Length: 0 | 0 | 17 | 192.168.1.1 | 5060 | 2025-01-26T18:44:07.120 | 1737917047 | 120000 | 1 |
+------------+--------------+-----------------+-------------+----------+-----------+------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------+------------+----------+-------------+----------+-------------------------+------------+-----------+------+
```

0 comments on commit 7f30259

Please sign in to comment.