Merge branch 'main' into debug-repl

format/logsegment/logsegment.fbs

@@ -9,8 +9,11 @@ table RecordBatch {
  // Logical offset of the first record in this batch.
  first_offset:long;
  // Monotonic timestamp of the first record in this batch, relative to the process start
- // time of the function invocation time (expressed in nanoseconds).
+ // time (expressed in nanoseconds).
  first_timestamp:long;
+ // Monotonic timestamp of the last record in this batch, relative to the process start
+ // time (expressed in nanoseconds).
+ last_timestamp:long;
  // Size of the compressed records following the record batch (in bytes).
  compressed_size:uint;
  // Uncompressed size of the records (in bytes).
@@ -39,32 +42,6 @@ table Record {
  function_call:[ubyte];
 }
 
-// Details about a function call.
-table FunctionCall {
- // State of the WebAssembly stack before and after the function was called.
- // The first {param_count} values are the input parameters, and the remaining
- // values are the return values.
- stack:[ulong];
- // Captured sections of the WebAssembly module's linear memory, stored
- // contiguously and indexed by {memory_access}.
- memory:[ubyte];
- // Ordered collection of memory reads and writes made by the function.
- memory_access:[MemoryAccess];
-}
-
-// MemoryAccess represents the capture of a section of memory.
-struct MemoryAccess {
- // Byte offset in the WebAssembly module's linear memory where the memory
- // access starts.
- offset:uint;
- // Byte offset into {FunctionCall.memory}. The length of the captured memory
- // can be derived by comparing the {index_offset} with that of the next
- // {FunctionCall.memory_access}. The length of the final memory region can
- // be derived by comparing the {index_offset} with the length of
- // {FunctionCall.memory}.
- index_offset:uint;
-}
-
 root_type RecordBatch;
 
 file_identifier "TL.0";

format/timecraft.go

@@ -72,6 +72,7 @@ const (
  TypeTimecraftRuntime MediaType = "application/vnd.timecraft.runtime.v1+json"
  TypeTimecraftConfig MediaType = "application/vnd.timecraft.config.v1+json"
  TypeTimecraftProcess MediaType = "application/vnd.timecraft.process.v1+json"
+ TypeTimecraftProfile MediaType = "application/vnd.timecraft.profile.v1+pprof"
  TypeTimecraftManifest MediaType = "application/vnd.timecraft.manifest.v1+json"
  TypeTimecraftModule MediaType = "application/vnd.timecraft.module.v1+wasm"
 )
@@ -197,8 +198,10 @@ func jsonDecode(b []byte, value any) error {
 }
 
 type Manifest struct {
- Process *Descriptor `json:"process" yaml:"process"`
- StartTime time.Time `json:"startTime" yaml:"startTime"`
+ ProcessID UUID `json:"-" yaml:"-"`
+ StartTime time.Time `json:"startTime" yaml:"startTime"`
+ Process *Descriptor `json:"process" yaml:"process"`
+ Segments []LogSegment `json:"segments,omitempty" yaml:"segments,omitempty"`
 }
 
 func (m *Manifest) ContentType() MediaType {
@@ -213,6 +216,12 @@ func (m *Manifest) UnmarshalResource(b []byte) error {
  return jsonDecode(b, m)
 }
 
+type LogSegment struct {
+ Number int `json:"number" yaml:"number"`
+ Size int64 `json:"size" yaml:"size"`
+ CreatedAt time.Time `json:"createdAt" yaml:"createdAt"`
+}
+
 var (
  _ ResourceMarshaler = (*Descriptor)(nil)
  _ ResourceMarshaler = (*Module)(nil)

format/types/types.fbs

@@ -3,7 +3,7 @@ namespace types;
 // Compression is the enumeration representing the supported compression
 // algorithms for data sections of log snapshots.
 enum Compression:uint {
- Uncompressed, Snappy, Zstd
+ uncompressed, snappy, zstd
 }
 
 // Hash represents a OCI hash which pairs an algorithm name to a digest.