feat: First version of rest catalog.

crates/iceberg/Cargo.toml

@@ -41,20 +41,24 @@ either = "1"
 futures = "0.3"
 itertools = "0.11"
 lazy_static = "1"
+log = "^0.4"
 murmur3 = "0.5.2"
 once_cell = "1"
 opendal = "0.40"
 ordered-float = "4.0.0"
+reqwest = { version = "^0.11", features = ["json"] }
 rust_decimal = "1.31.0"
 serde = { version = "^1.0", features = ["rc"] }
 serde_bytes = "0.11.8"
 serde_derive = "^1.0"
 serde_json = "^1.0"
 serde_repr = "0.1.16"
 url = "2"
+urlencoding = "2"
 uuid = "1.4.1"
 
 [dev-dependencies]
+mockito = "^1"
 pretty_assertions = "1.4.0"
 tempdir = "0.3"
 tokio = { version = "1", features = ["macros"] }

crates/iceberg/src/catalog/mod.rs

@@ -17,9 +17,14 @@
 
 //! Catalog API for Apache Iceberg
 
+#[allow(dead_code)]
+mod rest;
+pub use rest::*;
+use serde_derive::{Deserialize, Serialize};
+
 use crate::spec::{PartitionSpec, Schema, SortOrder};
 use crate::table::Table;
-use crate::Result;
+use crate::{Error, ErrorKind, Result};
 use async_trait::async_trait;
 use std::collections::HashMap;
 
@@ -88,6 +93,8 @@ pub trait Catalog {
 /// The namespace identifier is a list of strings, where each string is a
 /// component of the namespace. It's catalog implementer's responsibility to
 /// handle the namespace identifier correctly.
+
+#[derive(Serialize, Deserialize, Debug, Clone, PartialEq, Eq, Hash)]
 pub struct NamespaceIdent(Vec<String>);
 
 impl NamespaceIdent {
@@ -97,8 +104,14 @@ impl NamespaceIdent {
     }
 
     /// Create a multi-level namespace identifier from vector.
-    pub fn from_vec(names: Vec<String>) -> Self {
-        Self(names)
+    pub fn from_vec(names: Vec<String>) -> Result<Self> {
+        if names.is_empty() {
+            return Err(Error::new(
+                ErrorKind::DataInvalid,
+                "Namespace identifier can't be empty!",
+            ));
+        }
+        Ok(Self(names))
     }
 }
 
@@ -109,6 +122,7 @@ impl AsRef<Vec<String>> for NamespaceIdent {
 }
 
 /// Namespace represents a namespace in the catalog.
+#[derive(Debug, Clone, PartialEq, Eq)]
 pub struct Namespace {
     name: NamespaceIdent,
     properties: HashMap<String, String>,
@@ -137,6 +151,7 @@ impl Namespace {
 }
 
 /// TableIdent represents the identifier of a table in the catalog.
+#[derive(Serialize, Deserialize, Debug, Clone, PartialEq, Eq, Hash)]
 pub struct TableIdent {
     namespace: NamespaceIdent,
     name: String,