Rename `corelib` to `libtdb`

next
Sayan Nandan 4 years ago
parent 96c9bf47b0
commit 67dc83764a
No known key found for this signature in database
GPG Key ID: C31EFD7DDA12AEE0

@ -1,5 +1,5 @@
server: server/**/*
corelib: corelib/**/*
libtdb: libtdb/**/*
cli: cli/**/*
docs: ./*.md
build:

@ -29,7 +29,7 @@ You can see a list of contributors **[here](./CONTRIBUTORS.md)**
The project root has three main directories:
* `cli` : This contains code for `tsh` which is the command-line client for TDB
* `libcore` : This contains function, structs, ... used by both the `cli` and the `server`
* `libtdb` : This contains function, structs, ... used by both the `cli` and the `server`
* `server` : This contains code for the main database server
### Branches

22
Cargo.lock generated

@ -49,15 +49,6 @@ dependencies = [
"bitflags",
]
[[package]]
name = "corelib"
version = "0.4.0"
dependencies = [
"bytes",
"lazy_static",
"termcolor",
]
[[package]]
name = "devtimer"
version = "4.0.0"
@ -149,6 +140,15 @@ version = "0.2.72"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "a9f8082297d534141b30c8d39e9b1773713ab50fdbe4ff30f750d063b3bfd701"
[[package]]
name = "libtdb"
version = "0.4.0"
dependencies = [
"bytes",
"lazy_static",
"termcolor",
]
[[package]]
name = "lock_api"
version = "0.4.1"
@ -424,7 +424,7 @@ version = "0.3.2"
dependencies = [
"bincode",
"bytes",
"corelib",
"libtdb",
"parking_lot",
"tokio",
]
@ -478,8 +478,8 @@ name = "tsh"
version = "0.3.2"
dependencies = [
"bytes",
"corelib",
"devtimer",
"libtdb",
"rand",
"tokio",
]

@ -2,7 +2,7 @@
members = [
"cli",
"server",
"corelib"
"libtdb"
]
[profile.release]

@ -7,7 +7,7 @@ edition = "2018"
# See more keys and their definitions at https://doc.rust-lang.org/cargo/reference/manifest.html
[dependencies]
corelib = {path = "../corelib"}
libtdb = {path = "../libtdb"}
tokio = {version = "0.2.22", features = ["full"]}
rand = "0.7.3"
devtimer = "4.0.0"

@ -20,7 +20,7 @@
*/
use crate::protocol;
use corelib::terrapipe::ADDR;
use libtdb::terrapipe::ADDR;
use std::env;
use std::io::{self, prelude::*};
use std::process;

@ -24,7 +24,7 @@
//! the response times may be shown to be slower than they actually are
mod benchtool {
use corelib::builders::query::*;
use libtdb::builders::query::*;
use devtimer::DevTime;
use rand::distributions::Alphanumeric;
use rand::{thread_rng, Rng};

@ -21,9 +21,9 @@
//! This module provides methods to deserialize an incoming response packet
use corelib::builders::MLINE_BUF;
use corelib::de::*;
use corelib::terrapipe::*;
use libtdb::builders::MLINE_BUF;
use libtdb::de::*;
use libtdb::terrapipe::*;
use std::fmt;
/// Errors that may occur while parsing responses from the server

@ -21,9 +21,9 @@
mod deserializer;
use bytes::{Buf, BytesMut};
use corelib::builders::query::*;
use corelib::de::*;
use corelib::TResult;
use libtdb::builders::query::*;
use libtdb::de::*;
use libtdb::TResult;
use deserializer::{ClientResult, Response};
use tokio::io::{AsyncReadExt, AsyncWriteExt};
use tokio::net::TcpStream;

@ -1,5 +1,5 @@
[package]
name = "corelib"
name = "libtdb"
version = "0.4.0"
authors = ["Sayan Nandan <ohsayan@outlook.com>"]
edition = "2018"

@ -428,7 +428,7 @@ mod parser_v2 {
/// Terrapipe protocol. An `ActionGroup` contains all the elements required to
/// execute an `Action`. The `ActionGroup` contains the "action" itself.
/// It may look like:
/// ```
/// ```text
/// ["GET", "x", "y"]
/// ```
#[derive(Debug, PartialEq)]

@ -9,6 +9,6 @@ edition = "2018"
[dependencies]
tokio = { version = "0.2.22", features = ["full"] }
bytes = "0.5.6"
corelib = {path ="../corelib"}
libtdb = {path ="../libtdb"}
bincode = "1.3.1"
parking_lot = "0.11.0"

@ -25,9 +25,9 @@ use crate::diskstore;
use crate::protocol::Query;
use crate::queryengine;
use bytes::Bytes;
use corelib::builders::response::Response;
use corelib::terrapipe::{ActionType, RespCodes};
use corelib::TResult;
use libtdb::builders::response::Response;
use libtdb::terrapipe::{ActionType, RespCodes};
use libtdb::TResult;
use parking_lot::{RwLock, RwLockReadGuard, RwLockWriteGuard};
use std::collections::{hash_map::Entry, HashMap};
use std::sync::Arc;

@ -21,8 +21,8 @@
use crate::protocol::{Connection, QueryResult::*};
use crate::CoreDB;
use corelib::util::terminal;
use corelib::TResult;
use libtdb::util::terminal;
use libtdb::TResult;
use std::future::Future;
use std::process;
use std::sync::Arc;

@ -24,7 +24,7 @@
use crate::coredb::Data;
use bincode;
use bytes::Bytes;
use corelib::TResult;
use libtdb::TResult;
use std::collections::HashMap;
use std::fs;
use std::io::{ErrorKind, Write};

@ -24,9 +24,9 @@
use crate::coredb::CoreDB;
use crate::resputil::*;
use corelib::builders::response::*;
use corelib::de::DataGroup;
use corelib::terrapipe::responses;
use libtdb::builders::response::*;
use libtdb::de::DataGroup;
use libtdb::terrapipe::responses;
/// Run a `DEL` query
pub fn del(handle: &CoreDB, act: DataGroup) -> Response {
@ -59,8 +59,8 @@ pub fn del(handle: &CoreDB, act: DataGroup) -> Response {
mod tests {
use super::*;
use crate::coredb::{self, CoreDB};
use corelib::de::DataGroup;
use corelib::terrapipe::responses;
use libtdb::de::DataGroup;
use libtdb::terrapipe::responses;
#[cfg(test)]
#[test]
fn test_kvengine_del_allfailed() {

@ -24,9 +24,9 @@
use crate::coredb::CoreDB;
use crate::resputil::*;
use corelib::builders::response::*;
use corelib::de::DataGroup;
use corelib::terrapipe::responses;
use libtdb::builders::response::*;
use libtdb::de::DataGroup;
use libtdb::terrapipe::responses;
/// Run an `EXISTS` query
pub fn exists(handle: &CoreDB, act: DataGroup) -> Response {
let howmany = act.len() - 1;
@ -56,8 +56,8 @@ pub fn exists(handle: &CoreDB, act: DataGroup) -> Response {
mod tests {
use super::*;
use crate::coredb::{self, CoreDB};
use corelib::de::DataGroup;
use corelib::terrapipe::responses;
use libtdb::de::DataGroup;
use libtdb::terrapipe::responses;
#[cfg(test)]
#[test]
fn test_kvengine_exists_allfailed() {

@ -23,9 +23,9 @@
//! This module provides functions to work with `GET` queries
use crate::coredb::CoreDB;
use corelib::builders::response::*;
use corelib::de::DataGroup;
use corelib::terrapipe::RespCodes;
use libtdb::builders::response::*;
use libtdb::de::DataGroup;
use libtdb::terrapipe::RespCodes;
/// Run a `GET` query
pub fn get(handle: &CoreDB, act: DataGroup) -> Response {

@ -30,8 +30,8 @@ pub mod set;
pub mod update;
pub mod heya {
//! Respond to `HEYA` queries
use corelib::builders::response::Response;
use corelib::terrapipe::responses::HEYA;
use libtdb::builders::response::Response;
use libtdb::terrapipe::responses::HEYA;
/// Returns a `HEY!` `Response`
pub fn heya() -> Response {
HEYA.to_owned()

@ -23,9 +23,9 @@
//! This module provides functions to work with `SET` queries
use crate::coredb::CoreDB;
use corelib::builders::response::*;
use corelib::de::DataGroup;
use corelib::terrapipe::RespCodes;
use libtdb::builders::response::*;
use libtdb::de::DataGroup;
use libtdb::terrapipe::RespCodes;
/// Run a `SET` query
pub fn set(handle: &CoreDB, act: DataGroup) -> Response {

@ -23,9 +23,9 @@
//! This module provides functions to work with `UPDATE` queries
use crate::coredb::CoreDB;
use corelib::builders::response::*;
use corelib::de::DataGroup;
use corelib::terrapipe::RespCodes;
use libtdb::builders::response::*;
use libtdb::de::DataGroup;
use libtdb::terrapipe::RespCodes;
/// Run an `UPDATE` query
pub fn update(handle: &CoreDB, act: DataGroup) -> Response {

@ -21,8 +21,8 @@
//! This module provides deserialization primitives for query packets
use corelib::de::*;
use corelib::terrapipe::{ActionType, RespCodes, DEF_QMETALINE_BUFSIZE};
use libtdb::de::*;
use libtdb::terrapipe::{ActionType, RespCodes, DEF_QMETALINE_BUFSIZE};
/// Result of parsing a query
/// This is **not** the same as `std`'s `Result<T, E>` but instead is an `enum`

@ -22,10 +22,10 @@
mod deserializer;
use crate::resputil::Writable;
use bytes::{Buf, BytesMut};
use corelib::builders::response::IntoResponse;
use corelib::builders::response::Response;
use corelib::de::*;
use corelib::TResult;
use libtdb::builders::response::IntoResponse;
use libtdb::builders::response::Response;
use libtdb::de::*;
use libtdb::TResult;
pub use deserializer::{
Query,
QueryParseResult::{self, *},

@ -23,9 +23,9 @@
use crate::coredb::CoreDB;
use crate::kvengine;
use corelib::builders::response::*;
use corelib::de::DataGroup;
use corelib::terrapipe::responses;
use libtdb::builders::response::*;
use libtdb::de::DataGroup;
use libtdb::terrapipe::responses;
mod tags {
//! This module is a collection of tags/strings used for evaluating queries
//! and responses

@ -22,7 +22,7 @@
//! Utilities for generating responses, which are only used by the `server`
//!
use corelib::builders::{self, response::*};
use libtdb::builders::{self, response::*};
use std::error::Error;
use std::future::Future;
use std::mem;

Loading…
Cancel
Save