cortexdb-client 0.2.0

Typed gRPC client for CortexDB (AI memory + knowledge graph sidecar)
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

syntax = "proto3";
package cortexdb.v1;
option go_package = "github.com/liliang-cn/cortexdb/v2/pkg/rpc/v1;rpcv1";

import "google/protobuf/timestamp.proto";
import "google/protobuf/struct.proto";
import "cortexdb/v1/common.proto";

message MemoryRecord {
  string id = 1;
  string user_id = 2;
  string session_id = 3;
  string scope = 4;
  string namespace = 5;
  string role = 6;
  string content = 7;
  google.protobuf.Struct metadata = 8;
  double importance = 9;
  int32 ttl_seconds = 10;
  google.protobuf.Timestamp expires_at = 11;
  google.protobuf.Timestamp created_at = 12;
}

message SaveMemoryRequest {
  string memory_id = 1;
  string user_id = 2;
  string session_id = 3;
  string scope = 4;
  string namespace = 5;
  string role = 6;
  string content = 7;
  google.protobuf.Struct metadata = 8;
  double importance = 9;
  int32 ttl_seconds = 10;
}

message SaveMemoryResponse { MemoryRecord memory = 1; }

message UpdateMemoryRequest {
  string memory_id = 1;
  optional string content = 2;
  google.protobuf.Struct metadata = 3;
  optional double importance = 4;
  optional int32 ttl_seconds = 5;
}

message GetMemoryRequest { string memory_id = 1; }
message GetMemoryResponse { MemoryRecord memory = 1; }

message DeleteMemoryRequest { string memory_id = 1; }
message DeleteMemoryResponse {
  string memory_id = 1;
  bool deleted = 2;
}

message SearchMemoryRequest {
  string query = 1;
  string user_id = 2;
  string session_id = 3;
  string scope = 4;
  string namespace = 5;
  int32 top_k = 6;
  repeated string keywords = 7;
  repeated string alternate_queries = 8;
  string retrieval_mode = 9;
  optional RetrievalPlan plan = 10;
}

message MemorySearchHit {
  MemoryRecord memory = 1;
  double score = 2;
}

message SearchMemoryResponse {
  string query = 1;
  RetrievalPlan plan = 2;
  RetrievalDecision decision = 3;
  repeated MemorySearchHit results = 4;
}

service MemoryService {
  rpc SaveMemory(SaveMemoryRequest) returns (SaveMemoryResponse);
  rpc UpdateMemory(UpdateMemoryRequest) returns (SaveMemoryResponse);
  rpc GetMemory(GetMemoryRequest) returns (GetMemoryResponse);
  rpc SearchMemory(SearchMemoryRequest) returns (SearchMemoryResponse);
  rpc DeleteMemory(DeleteMemoryRequest) returns (DeleteMemoryResponse);
}