Make certain functions private to crate

lib/src/dbs/channel.rs

@@ -14,7 +14,7 @@ use async_recursion::async_recursion;
 use tokio::sync::mpsc::Sender;
 
 impl Value {
-	pub async fn channel(
+	pub(crate) async fn channel(
 		self,
 		ctx: Runtime,
 		opt: Options,
@@ -37,7 +37,7 @@ impl Value {
 
 impl Array {
 	#[async_recursion]
-	pub async fn process(
+	pub(crate) async fn process(
 		self,
 		ctx: &Runtime,
 		opt: &Options,
@@ -61,7 +61,7 @@ impl Array {
 }
 
 impl Model {
-	pub async fn process(
+	pub(crate) async fn process(
 		self,
 		ctx: &Runtime,
 		opt: &Options,
@@ -96,7 +96,7 @@ impl Model {
 }
 
 impl Thing {
-	pub async fn process(
+	pub(crate) async fn process(
 		self,
 		ctx: &Runtime,
 		opt: &Options,
@@ -118,7 +118,7 @@ impl Thing {
 }
 
 impl Table {
-	pub async fn process(
+	pub(crate) async fn process(
 		self,
 		ctx: &Runtime,
 		opt: &Options,

lib/src/dbs/iterate.rs

@@ -15,7 +15,7 @@ use async_recursion::async_recursion;
 impl Value {
 	#[cfg_attr(feature = "parallel", async_recursion)]
 	#[cfg_attr(not(feature = "parallel"), async_recursion(?Send))]
-	pub async fn iterate(
+	pub(crate) async fn iterate(
 		self,
 		ctx: &Runtime,
 		opt: &Options,
@@ -38,7 +38,7 @@ impl Value {
 impl Array {
 	#[cfg_attr(feature = "parallel", async_recursion)]
 	#[cfg_attr(not(feature = "parallel"), async_recursion(?Send))]
-	pub async fn iterate(
+	pub(crate) async fn iterate(
 		self,
 		ctx: &Runtime,
 		opt: &Options,
@@ -61,7 +61,7 @@ impl Array {
 }
 
 impl Model {
-	pub async fn iterate(
+	pub(crate) async fn iterate(
 		self,
 		ctx: &Runtime,
 		opt: &Options,
@@ -95,7 +95,7 @@ impl Model {
 }
 
 impl Thing {
-	pub async fn iterate(
+	pub(crate) async fn iterate(
 		self,
 		ctx: &Runtime,
 		opt: &Options,
@@ -116,7 +116,7 @@ impl Thing {
 }
 
 impl Table {
-	pub async fn iterate(
+	pub(crate) async fn iterate(
 		self,
 		ctx: &Runtime,
 		opt: &Options,

lib/src/doc/compute.rs

@@ -9,7 +9,7 @@ use crate::sql::value::Value;
 use tokio::sync::mpsc::Sender;
 
 impl<'a> Document<'a> {
-	pub async fn compute(
+	pub(crate) async fn compute(
 		ctx: Runtime,
 		opt: Options,
 		txn: Transaction,

lib/src/sql/array.rs

@@ -137,7 +137,7 @@ impl Array {
 }
 
 impl Array {
-	pub async fn compute(
+	pub(crate) async fn compute(
 		&self,
 		ctx: &Runtime,
 		opt: &Options,

lib/src/sql/expression.rs

@@ -29,7 +29,7 @@ impl Default for Expression {
 
 impl Expression {
 	// Create a new expression
-	pub fn new(l: Value, o: Operator, r: Value) -> Expression {
+	fn new(l: Value, o: Operator, r: Value) -> Expression {
 		Expression {
 			l,
 			o,
@@ -37,7 +37,7 @@ impl Expression {
 		}
 	}
 	// Augment an existing expression
-	pub fn augment(mut self, l: Value, o: Operator) -> Expression {
+	fn augment(mut self, l: Value, o: Operator) -> Expression {
 		if o.precedence() >= self.o.precedence() {
 			match self.l {
 				Value::Expression(x) => {
@@ -57,7 +57,7 @@ impl Expression {
 }
 
 impl Expression {
-	pub async fn compute(
+	pub(crate) async fn compute(
 		&self,
 		ctx: &Runtime,
 		opt: &Options,

lib/src/sql/function.rs

@@ -102,7 +102,7 @@ impl Function {
 }
 
 impl Function {
-	pub async fn compute(
+	pub(crate) async fn compute(
 		&self,
 		ctx: &Runtime,
 		opt: &Options,

lib/src/sql/idiom.rs

@@ -84,7 +84,7 @@ impl Idiom {
 }
 
 impl Idiom {
-	pub async fn compute(
+	pub(crate) async fn compute(
 		&self,
 		ctx: &Runtime,
 		opt: &Options,

lib/src/sql/object.rs

@@ -90,7 +90,7 @@ impl Object {
 }
 
 impl Object {
-	pub async fn compute(
+	pub(crate) async fn compute(
 		&self,
 		ctx: &Runtime,
 		opt: &Options,

lib/src/sql/param.rs

@@ -27,7 +27,7 @@ impl From<Idiom> for Param {
 }
 
 impl Param {
-	pub async fn compute(
+	pub(crate) async fn compute(
 		&self,
 		ctx: &Runtime,
 		opt: &Options,

lib/src/sql/statement.rs

@@ -88,7 +88,7 @@ impl Statement {
 }
 
 impl Statement {
-	pub async fn compute(
+	pub(crate) async fn compute(
 		&self,
 		ctx: &Runtime,
 		opt: &Options,

lib/src/sql/statements/create.rs

@@ -28,7 +28,7 @@ pub struct CreateStatement {
 }
 
 impl CreateStatement {
-	pub async fn compute(
+	pub(crate) async fn compute(
 		self: &Arc<Self>,
 		ctx: &Runtime,
 		opt: &Options,

lib/src/sql/statements/define.rs

@@ -46,7 +46,7 @@ pub enum DefineStatement {
 }
 
 impl DefineStatement {
-	pub async fn compute(
+	pub(crate) async fn compute(
 		&self,
 		ctx: &Runtime,
 		opt: &Options,
@@ -107,7 +107,7 @@ pub struct DefineNamespaceStatement {
 }
 
 impl DefineNamespaceStatement {
-	pub async fn compute(
+	pub(crate) async fn compute(
 		&self,
 		_ctx: &Runtime,
 		opt: &Options,
@@ -154,7 +154,7 @@ pub struct DefineDatabaseStatement {
 }
 
 impl DefineDatabaseStatement {
-	pub async fn compute(
+	pub(crate) async fn compute(
 		&self,
 		_ctx: &Runtime,
 		opt: &Options,
@@ -209,7 +209,7 @@ pub struct DefineLoginStatement {
 }
 
 impl DefineLoginStatement {
-	pub async fn compute(
+	pub(crate) async fn compute(
 		&self,
 		_ctx: &Runtime,
 		opt: &Options,
@@ -328,7 +328,7 @@ pub struct DefineTokenStatement {
 }
 
 impl DefineTokenStatement {
-	pub async fn compute(
+	pub(crate) async fn compute(
 		&self,
 		_ctx: &Runtime,
 		opt: &Options,
@@ -424,7 +424,7 @@ pub struct DefineScopeStatement {
 }
 
 impl DefineScopeStatement {
-	pub async fn compute(
+	pub(crate) async fn compute(
 		&self,
 		_ctx: &Runtime,
 		opt: &Options,
@@ -560,7 +560,7 @@ pub struct DefineTableStatement {
 }
 
 impl DefineTableStatement {
-	pub async fn compute(
+	pub(crate) async fn compute(
 		&self,
 		ctx: &Runtime,
 		opt: &Options,
@@ -725,7 +725,7 @@ pub struct DefineEventStatement {
 }
 
 impl DefineEventStatement {
-	pub async fn compute(
+	pub(crate) async fn compute(
 		&self,
 		_ctx: &Runtime,
 		opt: &Options,
@@ -804,7 +804,7 @@ pub struct DefineFieldStatement {
 }
 
 impl DefineFieldStatement {
-	pub async fn compute(
+	pub(crate) async fn compute(
 		&self,
 		_ctx: &Runtime,
 		opt: &Options,
@@ -942,7 +942,7 @@ pub struct DefineIndexStatement {
 }
 
 impl DefineIndexStatement {
-	pub async fn compute(
+	pub(crate) async fn compute(
 		&self,
 		ctx: &Runtime,
 		opt: &Options,

lib/src/sql/statements/delete.rs

@@ -29,7 +29,7 @@ pub struct DeleteStatement {
 }
 
 impl DeleteStatement {
-	pub async fn compute(
+	pub(crate) async fn compute(
 		self: &Arc<Self>,
 		ctx: &Runtime,
 		opt: &Options,

lib/src/sql/statements/ifelse.rs

@@ -19,7 +19,7 @@ pub struct IfelseStatement {
 }
 
 impl IfelseStatement {
-	pub async fn compute(
+	pub(crate) async fn compute(
 		&self,
 		ctx: &Runtime,
 		opt: &Options,

lib/src/sql/statements/info.rs

@@ -24,7 +24,7 @@ pub enum InfoStatement {
 }
 
 impl InfoStatement {
-	pub async fn compute(
+	pub(crate) async fn compute(
 		&self,
 		_ctx: &Runtime,
 		opt: &Options,

lib/src/sql/statements/insert.rs

@@ -32,7 +32,7 @@ pub struct InsertStatement {
 }
 
 impl InsertStatement {
-	pub async fn compute(
+	pub(crate) async fn compute(
 		self: &Arc<Self>,
 		ctx: &Runtime,
 		opt: &Options,

lib/src/sql/statements/kill.rs

@@ -17,7 +17,7 @@ pub struct KillStatement {
 }
 
 impl KillStatement {
-	pub async fn compute(
+	pub(crate) async fn compute(
 		&self,
 		_ctx: &Runtime,
 		_opt: &Options,

lib/src/sql/statements/live.rs

@@ -25,7 +25,7 @@ pub struct LiveStatement {
 }
 
 impl LiveStatement {
-	pub async fn compute(
+	pub(crate) async fn compute(
 		&self,
 		_ctx: &Runtime,
 		_opt: &Options,

lib/src/sql/statements/output.rs

@@ -16,7 +16,7 @@ pub struct OutputStatement {
 }
 
 impl OutputStatement {
-	pub async fn compute(
+	pub(crate) async fn compute(
 		&self,
 		ctx: &Runtime,
 		opt: &Options,

lib/src/sql/statements/relate.rs

@@ -35,7 +35,7 @@ pub struct RelateStatement {
 }
 
 impl RelateStatement {
-	pub async fn compute(
+	pub(crate) async fn compute(
 		self: &Arc<Self>,
 		ctx: &Runtime,
 		opt: &Options,

lib/src/sql/statements/remove.rs

@@ -30,7 +30,7 @@ pub enum RemoveStatement {
 }
 
 impl RemoveStatement {
-	pub async fn compute(
+	pub(crate) async fn compute(
 		&self,
 		ctx: &Runtime,
 		opt: &Options,
@@ -91,7 +91,7 @@ pub struct RemoveNamespaceStatement {
 }
 
 impl RemoveNamespaceStatement {
-	pub async fn compute(
+	pub(crate) async fn compute(
 		&self,
 		_ctx: &Runtime,
 		opt: &Options,
@@ -145,7 +145,7 @@ pub struct RemoveDatabaseStatement {
 }
 
 impl RemoveDatabaseStatement {
-	pub async fn compute(
+	pub(crate) async fn compute(
 		&self,
 		_ctx: &Runtime,
 		opt: &Options,
@@ -200,7 +200,7 @@ pub struct RemoveLoginStatement {
 }
 
 impl RemoveLoginStatement {
-	pub async fn compute(
+	pub(crate) async fn compute(
 		&self,
 		_ctx: &Runtime,
 		opt: &Options,
@@ -275,7 +275,7 @@ pub struct RemoveTokenStatement {
 }
 
 impl RemoveTokenStatement {
-	pub async fn compute(
+	pub(crate) async fn compute(
 		&self,
 		_ctx: &Runtime,
 		opt: &Options,
@@ -349,7 +349,7 @@ pub struct RemoveScopeStatement {
 }
 
 impl RemoveScopeStatement {
-	pub async fn compute(
+	pub(crate) async fn compute(
 		&self,
 		_ctx: &Runtime,
 		opt: &Options,
@@ -400,7 +400,7 @@ pub struct RemoveTableStatement {
 }
 
 impl RemoveTableStatement {
-	pub async fn compute(
+	pub(crate) async fn compute(
 		&self,
 		_ctx: &Runtime,
 		opt: &Options,
@@ -455,7 +455,7 @@ pub struct RemoveEventStatement {
 }
 
 impl RemoveEventStatement {
-	pub async fn compute(
+	pub(crate) async fn compute(
 		&self,
 		_ctx: &Runtime,
 		opt: &Options,
@@ -513,7 +513,7 @@ pub struct RemoveFieldStatement {
 }
 
 impl RemoveFieldStatement {
-	pub async fn compute(
+	pub(crate) async fn compute(
 		&self,
 		_ctx: &Runtime,
 		opt: &Options,
@@ -571,7 +571,7 @@ pub struct RemoveIndexStatement {
 }
 
 impl RemoveIndexStatement {
-	pub async fn compute(
+	pub(crate) async fn compute(
 		&self,
 		_ctx: &Runtime,
 		opt: &Options,

lib/src/sql/statements/select.rs

@@ -57,7 +57,7 @@ impl SelectStatement {
 }
 
 impl SelectStatement {
-	pub async fn compute(
+	pub(crate) async fn compute(
 		self: &Arc<Self>,
 		ctx: &Runtime,
 		opt: &Options,

lib/src/sql/statements/set.rs

@@ -21,7 +21,7 @@ pub struct SetStatement {
 }
 
 impl SetStatement {
-	pub async fn compute(
+	pub(crate) async fn compute(
 		&self,
 		ctx: &Runtime,
 		opt: &Options,

lib/src/sql/statements/update.rs

@@ -30,7 +30,7 @@ pub struct UpdateStatement {
 }
 
 impl UpdateStatement {
-	pub async fn compute(
+	pub(crate) async fn compute(
 		self: &Arc<Self>,
 		ctx: &Runtime,
 		opt: &Options,

lib/src/sql/subquery.rs

@@ -40,7 +40,7 @@ impl PartialOrd for Subquery {
 }
 
 impl Subquery {
-	pub async fn compute(
+	pub(crate) async fn compute(
 		&self,
 		ctx: &Runtime,
 		opt: &Options,

lib/src/sql/value/value.rs

@@ -977,7 +977,7 @@ impl fmt::Display for Value {
 impl Value {
 	#[cfg_attr(feature = "parallel", async_recursion)]
 	#[cfg_attr(not(feature = "parallel"), async_recursion(?Send))]
-	pub async fn compute(
+	pub(crate) async fn compute(
 		&self,
 		ctx: &Runtime,
 		opt: &Options,