probex 0.1.19

The missing Linux profiler — low-friction, easy to use, works out of the box
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79

use arrow::datatypes::{DataType, Field, Schema};
use std::sync::Arc;

/// Creates the Arrow schema for the temporary event table before stack finalization.
pub fn create_intermediate_schema() -> Schema {
    Schema::new(vec![
        Field::new("event_type", DataType::Utf8, false),
        Field::new("ts_ns", DataType::UInt64, false),
        Field::new("pid", DataType::UInt32, false),
        Field::new("tgid", DataType::UInt32, false),
        Field::new("process_name", DataType::Utf8, true),
        Field::new("stack_id", DataType::Int32, true),
        Field::new("kernel_stack_id", DataType::Int32, true),
        Field::new("stack_kind", DataType::Utf8, true),
        Field::new("stack_frames", DataType::Utf8, true),
        Field::new("stack_trace", DataType::Utf8, true),
        Field::new("cpu", DataType::UInt8, false),
        // SchedSwitch fields (nullable)
        Field::new("prev_pid", DataType::UInt32, true),
        Field::new("next_pid", DataType::UInt32, true),
        Field::new("prev_state", DataType::Int64, true),
        // ProcessFork fields (nullable)
        Field::new("parent_pid", DataType::UInt32, true),
        Field::new("child_pid", DataType::UInt32, true),
        // ProcessExit fields (nullable)
        Field::new("exit_code", DataType::Int32, true),
        // PageFault fields (nullable)
        Field::new("address", DataType::UInt64, true),
        Field::new("error_code", DataType::UInt64, true),
        // Syscall fields (nullable)
        Field::new("fd", DataType::Int64, true),
        Field::new("count", DataType::UInt64, true),
        Field::new("ret", DataType::Int64, true),
        // io_uring completion fields (nullable)
        Field::new("submit_ts_ns", DataType::UInt64, true),
        Field::new("io_uring_opcode", DataType::UInt8, true),
        Field::new("io_uring_res", DataType::Int32, true),
    ])
}

/// Creates the final Arrow schema for persisted traces.
pub fn create_final_schema() -> Schema {
    Schema::new(vec![
        Field::new("event_type", DataType::Utf8, false),
        Field::new("ts_ns", DataType::UInt64, false),
        Field::new("pid", DataType::UInt32, false),
        Field::new("tgid", DataType::UInt32, false),
        Field::new("process_name", DataType::Utf8, true),
        Field::new("stack_id", DataType::Int32, true),
        Field::new("kernel_stack_id", DataType::Int32, true),
        Field::new("stack_kind", DataType::Utf8, true),
        Field::new(
            "stack_trace",
            DataType::List(Arc::new(Field::new("item", DataType::Utf8View, true))),
            true,
        ),
        Field::new("cpu", DataType::UInt8, false),
        // SchedSwitch fields (nullable)
        Field::new("prev_pid", DataType::UInt32, true),
        Field::new("next_pid", DataType::UInt32, true),
        Field::new("prev_state", DataType::Int64, true),
        // ProcessFork fields (nullable)
        Field::new("parent_pid", DataType::UInt32, true),
        Field::new("child_pid", DataType::UInt32, true),
        // ProcessExit fields (nullable)
        Field::new("exit_code", DataType::Int32, true),
        // PageFault fields (nullable)
        Field::new("address", DataType::UInt64, true),
        Field::new("error_code", DataType::UInt64, true),
        // Syscall fields (nullable)
        Field::new("fd", DataType::Int64, true),
        Field::new("count", DataType::UInt64, true),
        Field::new("ret", DataType::Int64, true),
        // io_uring completion fields (nullable)
        Field::new("submit_ts_ns", DataType::UInt64, true),
        Field::new("io_uring_opcode", DataType::UInt8, true),
        Field::new("io_uring_res", DataType::Int32, true),
    ])
}