tiny.tracy.FlightReport

1pub const Report = struct {2    policy: OverflowPolicy,3    state: State,4    capacity_bytes: usize,5    retained_bytes: usize,6    event_capacity_bytes: usize,7    writer_capacity_bytes: usize,8    observed_events: u64,9    stored_events: u64,10    retained_events: usize,11    overwritten_events: u64,12    dropped_events: u64,13    oversized_events: u64,14    partial_event_bytes: usize,15    discarding_oversized_event: bool,1617    pub fn valid(self: Report) bool {18        if (self.capacity_bytes == 0) return false;19        if (self.event_capacity_bytes == 0) return false;20        if (self.writer_capacity_bytes == 0) return false;21        if (self.retained_bytes > self.capacity_bytes) return false;22        if (self.partial_event_bytes > self.event_capacity_bytes) return false;23        if (self.discarding_oversized_event and self.partial_event_bytes != 0) return false;24        const retained_events = std.math.cast(u64, self.retained_events) orelse return false;25        const retained_and_overwritten = retained_events +| self.overwritten_events;26        if (retained_and_overwritten != self.stored_events) return false;27        const rejected_events = self.dropped_events +| self.oversized_events;28        const accounted_events = self.stored_events +| rejected_events;29        if (accounted_events != self.observed_events) return false;30        if (self.policy == .overwrite_oldest and self.dropped_events != 0) return false;31        if (self.policy == .stop_when_full and self.overwritten_events != 0) return false;32        if (self.state == .full and self.policy != .stop_when_full) return false;33        return true;34    }3536    pub fn writeJson(self: Report, writer: *std.Io.Writer) !void {37        assert(self.valid());38        var stream = pretty_json.Writer.init(writer, .minified);39        const object = try stream.object();40        try self.writeFields(object);41        try object.end();42    }4344    pub fn writeFields(self: Report, object: pretty_json.Object) !void {45        assert(self.valid());46        try object.field("schema", schema);47        try object.field("policy", self.policy.tag());48        try object.field("state", self.state.tag());49        try object.field("capacity_bytes", self.capacity_bytes);50        try object.field("retained_bytes", self.retained_bytes);51        try object.field("event_capacity_bytes", self.event_capacity_bytes);52        try object.field("writer_capacity_bytes", self.writer_capacity_bytes);53        try object.field("observed_events", self.observed_events);54        try object.field("stored_events", self.stored_events);55        try object.field("retained_events", self.retained_events);56        try object.field("overwritten_events", self.overwritten_events);57        try object.field("dropped_events", self.dropped_events);58        try object.field("oversized_events", self.oversized_events);59        try object.field("partial_event_bytes", self.partial_event_bytes);60        try object.field("discarding_oversized_event", self.discarding_oversized_event);61    }6263    pub fn writeJsonl(self: Report, writer: *std.Io.Writer) !void {64        try self.writeJson(writer);65        try writer.writeByte('\n');66    }67};

1pub const FlightReport = transport_mod.Report;