micromegas_analytics/lib.rs
1//! Micromegas analytics: makes the telemetry data lake accessible and useful.
2
3// crate-specific lint exceptions:
4#![allow(missing_docs, clippy::missing_errors_doc)]
5
6/// Convert arrow array into Property instances
7pub mod arrow_properties;
8/// Misc arrow utilities
9pub mod arrow_utils;
10/// Processing of async events from thread event blocks
11pub mod async_block_processing;
12/// In-memory async events in arrow format
13pub mod async_events_table;
14/// The precedence rule for a row's own `audience` column, and the `coalesced_audience_column`/
15/// `audience_column_mismatch` SQL fragments shared by the writer and both enforcement prongs.
16pub mod audience;
17/// Transforms thread events into call trees
18pub mod call_tree;
19/// Removal of old data
20pub mod delete;
21/// Datafusion extensions
22pub mod dfext;
23/// In-memory images in arrow format
24pub mod images_table;
25/// Module dedicated to the maintenance and query of materialized views
26///
27/// Unlike the telemetry data lake where it's fast & cheap to write but costly to read,
28/// the lakehouse partitions are costly to write but allow for cheap & fast queries using datafusion.
29///
30/// Views based on a low frequency of events (< 1k events per second per process) are kept updated regularly.
31/// Views based on a high frequency of events (up to 100k events per second per process) are metrialized on demand.
32pub mod lakehouse;
33/// In-memory log entries in arrow format
34pub mod log_entries_table;
35/// Parsing of log entries from telemetry payload
36pub mod log_entry;
37/// Parsing of metrics from telemetry payload
38pub mod measure;
39/// Access to the metadata stored in the relational database
40pub mod metadata;
41/// In-memory metrics in arrow format
42pub mod metrics_table;
43/// Parsing of network tracing event streams
44pub mod net_block_processing;
45/// Transforms net events into pre-paired bandwidth spans
46pub mod net_span_tree;
47/// In-memory net spans in arrow format
48pub mod net_spans_table;
49/// Access to the raw binary telemetry payload
50pub mod payload;
51/// UDF to convert properties to dictionary-encoded arrays
52pub mod properties;
53pub mod record_batch_transformer;
54/// bulk metadata & payload ingestion using Arrow
55pub mod replication;
56/// Streams response for long requests
57pub mod response_writer;
58/// Location in instrumented source code
59pub mod scope;
60/// In-memory call tree in arrow format
61pub mod span_table;
62/// Convert sqlx rows into arrow format
63pub mod sql_arrow_bridge;
64/// Parses thread event streams
65pub mod thread_block_processor;
66/// Conversion between ticks and more convenient date/time representations
67pub mod time;