locus-core-rs 0.3.0

Core STTP parsing, validation, storage contracts, and application services for Rust
Documentation 
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
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128

use crate::domain::models::ConnectorMetadata;
use serde::Deserialize;
use serde_json::Value;

#[derive(Debug, Clone, Deserialize)]
pub struct SurrealNodeRecord {
    #[serde(rename = "SessionId")]
    pub session_id: String,
    #[serde(rename = "Raw")]
    pub raw: String,
    #[serde(rename = "Tier")]
    pub tier: String,
    #[serde(rename = "Timestamp")]
    pub timestamp: String,
    #[serde(rename = "CompressionDepth")]
    pub compression_depth: i32,
    #[serde(rename = "ParentNodeId", default)]
    pub parent_node_id: Option<String>,
    #[serde(rename = "SyncKey", default)]
    pub sync_key: Option<String>,
    #[serde(rename = "UpdatedAt", default)]
    pub updated_at: Option<String>,
    #[serde(rename = "SourceMetadata", default)]
    pub source_metadata: Option<ConnectorMetadata>,
    #[serde(rename = "ContextSummary", default)]
    pub context_summary: Option<String>,
    #[serde(rename = "Embedding", default)]
    pub embedding: Option<Vec<f32>>,
    #[serde(rename = "EmbeddingModel", default)]
    pub embedding_model: Option<String>,
    #[serde(rename = "EmbeddingDimensions", default)]
    pub embedding_dimensions: Option<usize>,
    #[serde(rename = "EmbeddedAt", default)]
    pub embedded_at: Option<String>,
    #[serde(rename = "Psi", default)]
    pub psi: f64,
    #[serde(rename = "Rho", default)]
    pub rho: f64,
    #[serde(rename = "Kappa", default)]
    pub kappa: f64,
    #[serde(rename = "UserStability", default)]
    pub user_stability: f64,
    #[serde(rename = "UserFriction", default)]
    pub user_friction: f64,
    #[serde(rename = "UserLogic", default)]
    pub user_logic: f64,
    #[serde(rename = "UserAutonomy", default)]
    pub user_autonomy: f64,
    #[serde(rename = "UserPsi", default)]
    pub user_psi: f64,
    #[serde(rename = "ModelStability", default)]
    pub model_stability: f64,
    #[serde(rename = "ModelFriction", default)]
    pub model_friction: f64,
    #[serde(rename = "ModelLogic", default)]
    pub model_logic: f64,
    #[serde(rename = "ModelAutonomy", default)]
    pub model_autonomy: f64,
    #[serde(rename = "ModelPsi", default)]
    pub model_psi: f64,
    #[serde(rename = "CompStability", default)]
    pub comp_stability: f64,
    #[serde(rename = "CompFriction", default)]
    pub comp_friction: f64,
    #[serde(rename = "CompLogic", default)]
    pub comp_logic: f64,
    #[serde(rename = "CompAutonomy", default)]
    pub comp_autonomy: f64,
    #[serde(rename = "CompPsi", default)]
    pub comp_psi: f64,
    #[serde(rename = "ResonanceDelta", default)]
    pub resonance_delta: f64,
}

#[derive(Debug, Clone, Deserialize)]
pub struct SurrealAvecRecord {
    #[serde(default)]
    pub stability: f32,
    #[serde(default)]
    pub friction: f32,
    #[serde(default)]
    pub logic: f32,
    #[serde(default)]
    pub autonomy: f32,
    #[serde(default)]
    pub psi: f32,
    #[serde(default)]
    pub created_at: Option<String>,
}

#[derive(Debug, Clone, Deserialize)]
pub struct SurrealTriggerRecord {
    pub trigger: String,
}

#[derive(Debug, Clone, Deserialize)]
pub struct SurrealExistingNodeRecord {
    #[serde(rename = "Id", default)]
    pub id: Value,
    #[serde(rename = "SourceMetadata", default)]
    pub source_metadata: Option<ConnectorMetadata>,
    #[serde(rename = "ContextSummary", default)]
    pub context_summary: Option<String>,
    #[serde(rename = "Embedding", default)]
    pub embedding: Option<Vec<f32>>,
    #[serde(rename = "EmbeddingModel", default)]
    pub embedding_model: Option<String>,
    #[serde(rename = "EmbeddingDimensions", default)]
    pub embedding_dimensions: Option<usize>,
    #[serde(rename = "EmbeddedAt", default)]
    pub embedded_at: Option<String>,
}

#[derive(Debug, Clone, Deserialize)]
pub struct SurrealCheckpointRecord {
    #[serde(rename = "SessionId")]
    pub session_id: String,
    #[serde(rename = "ConnectorId")]
    pub connector_id: String,
    #[serde(rename = "CursorUpdatedAt", default)]
    pub cursor_updated_at: Option<String>,
    #[serde(rename = "CursorSyncKey", default)]
    pub cursor_sync_key: Option<String>,
    #[serde(rename = "UpdatedAt")]
    pub updated_at: String,
    #[serde(rename = "Metadata", default)]
    pub metadata: Option<ConnectorMetadata>,
}