timecraft: add log resource type to get and describe commands

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).

format/timecraft.go

@@ -197,8 +197,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 +215,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.