aether-protocol 0.9.3

The official network protocol crate for AetherDB. Defines all request/response data structures for communicating with the high-performance CORD engine.
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

// File: src/request.rs
// =============================================================================
// This file defines the top-level `Request` enum. This is the single, unified
// type that represents every possible command a client can send to the server.

use crate::types::{BatchRequest, Filter, QueryOptions, Record};
use serde::{Deserialize, Serialize};

/// The primary enum representing all possible client requests.
#[derive(Serialize, Deserialize, Debug, PartialEq)]
pub enum Request {
    // --- Database Management ---
    CreateDatabase { db_name: String },
    DropDatabase { db_name: String },
    ListDatabases,

    // --- Collection Management ---
    ListCollections,
    CreateCollection { db_name: String, collection_name: String },
    DropCollection { db_name: String, collection_name: String },
    GetStats,
    Flush,

    // --- Index Management ---
    CreateIndex { db_name: String, collection: String, field_name: String },
    DropIndex { db_name: String, collection: String, field_name: String },
    ListIndexes { db_name: String, collection: String },

    // --- Record Operations (CRUD) ---
    CreateRecord { db_name: String, collection: String, record_id: String, data: Record },
    UpdateRecord { db_name: String, collection: String, record_id: String, data: Record },
    UpsertRecord { db_name: String, collection: String, record_id: String, data: Record },
    GetRecord { db_name: String, collection: String, record_id: String },
    DeleteRecord { db_name: String, collection: String, record_id: String, cascade: bool },
    GetLastInsertId,

    // --- Querying & Relational ---
    FindRecords {
        db_name: String,
        collection: String,
        filter: Filter,
        options: Option<QueryOptions>,
    },
    CountRecords {
        db_name: String,
        collection: String,
        filter: Filter,
    },
    GetRecordWithRelated {
        db_name: String,
        primary_collection: String,
        primary_record_id: String,
        relation_key_field: String,
        related_collection: String, 
    },
    ExecuteBatchGet(BatchRequest),
    Search {
        db_name: String,
        collection: String,
        query: String,
        field: Option<String>, // An optional field to search within. If None, search all fields.

    },
}