Further abstract batch storage driver
Sayan Nandan
7 months ago
parent
a188ccb60d
commit
102a4b4b40
@ -0,0 +1,83 @@
|
||||
/*
|
||||
* Created on Sun Feb 18 2024
|
||||
*
|
||||
* This file is a part of Skytable
|
||||
* Skytable (formerly known as TerrabaseDB or Skybase) is a free and open-source
|
||||
* NoSQL database written by Sayan Nandan ("the Author") with the
|
||||
* vision to provide flexibility in data modelling without compromising
|
||||
* on performance, queryability or scalability.
|
||||
*
|
||||
* Copyright (c) 2024, Sayan Nandan <nandansayan@outlook.com>
|
||||
*
|
||||
* This program is free software: you can redistribute it and/or modify
|
||||
* it under the terms of the GNU Affero General Public License as published by
|
||||
* the Free Software Foundation, either version 3 of the License, or
|
||||
* (at your option) any later version.
|
||||
*
|
||||
* This program is distributed in the hope that it will be useful,
|
||||
* but WITHOUT ANY WARRANTY; without even the implied warranty of
|
||||
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
|
||||
* GNU Affero General Public License for more details.
|
||||
*
|
||||
* You should have received a copy of the GNU Affero General Public License
|
||||
* along with this program. If not, see <https://www.gnu.org/licenses/>.
|
||||
*
|
||||
*/
|
||||
|
||||
use {
|
||||
super::super::raw::{
|
||||
journal::{EventLogAdapter, EventLogSpec},
|
||||
spec::SystemDatabaseV1,
|
||||
},
|
||||
crate::{
|
||||
engine::{
|
||||
core::GlobalNS,
|
||||
storage::{
|
||||
common_encoding::r1::impls::gns::GNSEvent, v2::raw::journal::JournalAdapterEvent,
|
||||
},
|
||||
txn::gns::{
|
||||
model::{
|
||||
AlterModelAddTxn, AlterModelRemoveTxn, AlterModelUpdateTxn, CreateModelTxn,
|
||||
DropModelTxn,
|
||||
},
|
||||
space::{AlterSpaceTxn, CreateSpaceTxn, DropSpaceTxn},
|
||||
GNSTransaction, GNSTransactionCode,
|
||||
},
|
||||
RuntimeResult,
|
||||
},
|
||||
util::compiler::TaggedEnum,
|
||||
},
|
||||
};
|
||||
|
||||
/*
|
||||
GNS event log impl
|
||||
*/
|
||||
|
||||
pub struct GNSEventLog;
|
||||
|
||||
impl EventLogSpec for GNSEventLog {
|
||||
type Spec = SystemDatabaseV1;
|
||||
type GlobalState = GlobalNS;
|
||||
type EventMeta = GNSTransactionCode;
|
||||
type DecodeDispatch =
|
||||
[fn(&GlobalNS, Vec<u8>) -> RuntimeResult<()>; GNSTransactionCode::VARIANT_COUNT];
|
||||
const DECODE_DISPATCH: Self::DecodeDispatch = [
|
||||
<CreateSpaceTxn as GNSEvent>::decode_apply,
|
||||
<AlterSpaceTxn as GNSEvent>::decode_apply,
|
||||
<DropSpaceTxn as GNSEvent>::decode_apply,
|
||||
<CreateModelTxn as GNSEvent>::decode_apply,
|
||||
<AlterModelAddTxn as GNSEvent>::decode_apply,
|
||||
<AlterModelRemoveTxn as GNSEvent>::decode_apply,
|
||||
<AlterModelUpdateTxn as GNSEvent>::decode_apply,
|
||||
<DropModelTxn as GNSEvent>::decode_apply,
|
||||
];
|
||||
}
|
||||
|
||||
impl<T: GNSEvent> JournalAdapterEvent<EventLogAdapter<GNSEventLog>> for T {
|
||||
fn md(&self) -> u64 {
|
||||
<T as GNSTransaction>::CODE.dscr_u64()
|
||||
}
|
||||
fn write_buffered(self, b: &mut Vec<u8>) {
|
||||
T::encode_event(self, b)
|
||||
}
|
||||
}
|
||||
@ -0,0 +1,25 @@
|
||||
/*
|
||||
* Created on Sun Feb 18 2024
|
||||
*
|
||||
* This file is a part of Skytable
|
||||
* Skytable (formerly known as TerrabaseDB or Skybase) is a free and open-source
|
||||
* NoSQL database written by Sayan Nandan ("the Author") with the
|
||||
* vision to provide flexibility in data modelling without compromising
|
||||
* on performance, queryability or scalability.
|
||||
*
|
||||
* Copyright (c) 2024, Sayan Nandan <nandansayan@outlook.com>
|
||||
*
|
||||
* This program is free software: you can redistribute it and/or modify
|
||||
* it under the terms of the GNU Affero General Public License as published by
|
||||
* the Free Software Foundation, either version 3 of the License, or
|
||||
* (at your option) any later version.
|
||||
*
|
||||
* This program is distributed in the hope that it will be useful,
|
||||
* but WITHOUT ANY WARRANTY; without even the implied warranty of
|
||||
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
|
||||
* GNU Affero General Public License for more details.
|
||||
*
|
||||
* You should have received a copy of the GNU Affero General Public License
|
||||
* along with this program. If not, see <https://www.gnu.org/licenses/>.
|
||||
*
|
||||
*/
|
||||
@ -0,0 +1,28 @@
|
||||
/*
|
||||
* Created on Sun Feb 18 2024
|
||||
*
|
||||
* This file is a part of Skytable
|
||||
* Skytable (formerly known as TerrabaseDB or Skybase) is a free and open-source
|
||||
* NoSQL database written by Sayan Nandan ("the Author") with the
|
||||
* vision to provide flexibility in data modelling without compromising
|
||||
* on performance, queryability or scalability.
|
||||
*
|
||||
* Copyright (c) 2024, Sayan Nandan <nandansayan@outlook.com>
|
||||
*
|
||||
* This program is free software: you can redistribute it and/or modify
|
||||
* it under the terms of the GNU Affero General Public License as published by
|
||||
* the Free Software Foundation, either version 3 of the License, or
|
||||
* (at your option) any later version.
|
||||
*
|
||||
* This program is distributed in the hope that it will be useful,
|
||||
* but WITHOUT ANY WARRANTY; without even the implied warranty of
|
||||
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
|
||||
* GNU Affero General Public License for more details.
|
||||
*
|
||||
* You should have received a copy of the GNU Affero General Public License
|
||||
* along with this program. If not, see <https://www.gnu.org/licenses/>.
|
||||
*
|
||||
*/
|
||||
|
||||
mod gns_log;
|
||||
mod mdl_journal;
|
||||
Loading…
Reference in New Issue