Add events type

Author: isbm

liblogjet/src/export.rs

@@ -38,6 +38,8 @@ pub const LJX_RECORD_TYPE_LOGS: u32 = 1;
 pub const LJX_RECORD_TYPE_METRICS: u32 = 2;
 /// Record contains traces.
 pub const LJX_RECORD_TYPE_TRACES: u32 = 3;
+/// Record contains events.
+pub const LJX_RECORD_TYPE_EVENTS: u32 = 4;
 
 /// Payload is opaque bytes.
 pub const LJX_PAYLOAD_KIND_OPAQUE: u32 = 0;

ljx/src/commands/export.rs

@@ -266,6 +266,7 @@ fn record_kind_label(record_type: RecordType) -> &'static str {
         RecordType::Logs => "logs",
         RecordType::Metrics => "metrics",
         RecordType::Traces => "traces",
+        RecordType::Events => "events",
     }
 }
 

ljx/src/commands/view/detail.rs

@@ -607,6 +607,7 @@ fn record_kind_label(record_type: RecordType) -> &'static str {
         RecordType::Logs => "logs",
         RecordType::Metrics => "metrics",
         RecordType::Traces => "traces",
+        RecordType::Events => "events",
     }
 }
 

ljx/src/dataset_index.rs

@@ -525,6 +525,7 @@ fn record_type_bit(kind: RecordType) -> u8 {
         RecordType::Logs => 1,
         RecordType::Metrics => 2,
         RecordType::Traces => 4,
+        RecordType::Events => 8,
     }
 }
 

ljx/src/exporter.rs

@@ -275,6 +275,7 @@ impl LoadedExporter {
             RecordType::Logs => LJX_EXPORT_CAP_RECORD_LOGS,
             RecordType::Metrics => LJX_EXPORT_CAP_RECORD_METRICS,
             RecordType::Traces => LJX_EXPORT_CAP_RECORD_TRACES,
+            RecordType::Events => LJX_EXPORT_CAP_RECORD_LOGS,
         };
         if self.capabilities & record_flag == 0 {
             return Err(Error::Usage(format!(
@@ -560,6 +561,7 @@ fn abi_record_type(value: RecordType) -> u32 {
         RecordType::Logs => liblogjet::export::LJX_RECORD_TYPE_LOGS,
         RecordType::Metrics => liblogjet::export::LJX_RECORD_TYPE_METRICS,
         RecordType::Traces => liblogjet::export::LJX_RECORD_TYPE_TRACES,
+        RecordType::Events => liblogjet::export::LJX_RECORD_TYPE_EVENTS,
     }
 }
 
@@ -576,6 +578,7 @@ fn record_kind_label(record_type: RecordType) -> &'static str {
         RecordType::Logs => "logs",
         RecordType::Metrics => "metrics",
         RecordType::Traces => "traces",
+        RecordType::Events => "events",
     }
 }
 

src/record.rs

@@ -6,6 +6,7 @@ pub enum RecordType {
     Logs = 1,
     Metrics = 2,
     Traces = 3,
+    Events = 4,
 }
 
 impl RecordType {
@@ -14,6 +15,7 @@ impl RecordType {
             1 => Ok(Self::Logs),
             2 => Ok(Self::Metrics),
             3 => Ok(Self::Traces),
+            4 => Ok(Self::Events),
             other => Err(Error::InvalidRecordType(other)),
         }
     }