#![allow(unused_mut)]
#![allow(unused_imports)]
type BoxFut<'a, T> = ::futures::future::BoxFuture<'a, T>;
type BoxStr<'a, T> = ::futures::stream::BoxStream<'a, T>;
use super::super::stream_paginated;
use super::client::*;
use crate::Result;
use futures::{StreamExt, TryStreamExt};
use std::future::IntoFuture;
use unitycatalog_common::models::schemas::v1::*;
pub struct ListSchemasBuilder {
client: SchemaServiceClient,
request: ListSchemasRequest,
}
impl ListSchemasBuilder {
pub(crate) fn new(client: SchemaServiceClient, catalog_name: impl Into<String>) -> Self {
let request = ListSchemasRequest {
catalog_name: catalog_name.into(),
..Default::default()
};
Self { client, request }
}
pub fn with_max_results(mut self, max_results: impl Into<Option<i32>>) -> Self {
self.request.max_results = max_results.into();
self
}
pub fn with_page_token(mut self, page_token: impl Into<Option<String>>) -> Self {
self.request.page_token = page_token.into();
self
}
pub fn with_include_browse(mut self, include_browse: impl Into<Option<bool>>) -> Self {
self.request.include_browse = include_browse.into();
self
}
pub fn into_stream(self) -> BoxStr<'static, Result<Schema>> {
let remaining = self.request.max_results;
let stream = stream_paginated(
(self, remaining),
move |(mut builder, mut remaining), page_token| async move {
builder.request.page_token = page_token;
let res = builder.client.list_schemas(&builder.request).await?;
if let Some(ref mut rem) = remaining {
*rem -= res.schemas.len() as i32;
}
let next_page_token = if remaining.is_some_and(|r| r <= 0) {
None
} else {
res.next_page_token.clone()
};
Ok((res, (builder, remaining), next_page_token))
},
)
.map_ok(|resp| futures::stream::iter(resp.schemas.into_iter().map(Ok)))
.try_flatten();
stream.boxed()
}
}
impl IntoFuture for ListSchemasBuilder {
type Output = Result<ListSchemasResponse>;
type IntoFuture = BoxFut<'static, Self::Output>;
fn into_future(self) -> Self::IntoFuture {
let client = self.client;
let request = self.request;
Box::pin(async move { client.list_schemas(&request).await })
}
}
pub struct CreateSchemaBuilder {
client: SchemaServiceClient,
request: CreateSchemaRequest,
}
impl CreateSchemaBuilder {
pub(crate) fn new(
client: SchemaServiceClient,
name: impl Into<String>,
catalog_name: impl Into<String>,
) -> Self {
let request = CreateSchemaRequest {
name: name.into(),
catalog_name: catalog_name.into(),
..Default::default()
};
Self { client, request }
}
pub fn with_comment(mut self, comment: impl Into<Option<String>>) -> Self {
self.request.comment = comment.into();
self
}
pub fn with_properties<I, K, V>(mut self, properties: I) -> Self
where
I: IntoIterator<Item = (K, V)>,
K: Into<String>,
V: Into<String>,
{
self.request.properties = properties
.into_iter()
.map(|(k, v)| (k.into(), v.into()))
.collect();
self
}
pub fn with_storage_root(mut self, storage_root: impl Into<Option<String>>) -> Self {
self.request.storage_root = storage_root.into();
self
}
}
impl IntoFuture for CreateSchemaBuilder {
type Output = Result<Schema>;
type IntoFuture = BoxFut<'static, Self::Output>;
fn into_future(self) -> Self::IntoFuture {
let client = self.client;
let request = self.request;
Box::pin(async move { client.create_schema(&request).await })
}
}
pub struct GetSchemaBuilder {
client: SchemaServiceClient,
request: GetSchemaRequest,
}
impl GetSchemaBuilder {
pub(crate) fn new(client: SchemaServiceClient, full_name: impl Into<String>) -> Self {
let request = GetSchemaRequest {
full_name: full_name.into(),
..Default::default()
};
Self { client, request }
}
}
impl IntoFuture for GetSchemaBuilder {
type Output = Result<Schema>;
type IntoFuture = BoxFut<'static, Self::Output>;
fn into_future(self) -> Self::IntoFuture {
let client = self.client;
let request = self.request;
Box::pin(async move { client.get_schema(&request).await })
}
}
pub struct UpdateSchemaBuilder {
client: SchemaServiceClient,
request: UpdateSchemaRequest,
}
impl UpdateSchemaBuilder {
pub(crate) fn new(client: SchemaServiceClient, full_name: impl Into<String>) -> Self {
let request = UpdateSchemaRequest {
full_name: full_name.into(),
..Default::default()
};
Self { client, request }
}
pub fn with_comment(mut self, comment: impl Into<Option<String>>) -> Self {
self.request.comment = comment.into();
self
}
pub fn with_properties<I, K, V>(mut self, properties: I) -> Self
where
I: IntoIterator<Item = (K, V)>,
K: Into<String>,
V: Into<String>,
{
self.request.properties = properties
.into_iter()
.map(|(k, v)| (k.into(), v.into()))
.collect();
self
}
pub fn with_new_name(mut self, new_name: impl Into<Option<String>>) -> Self {
self.request.new_name = new_name.into();
self
}
}
impl IntoFuture for UpdateSchemaBuilder {
type Output = Result<Schema>;
type IntoFuture = BoxFut<'static, Self::Output>;
fn into_future(self) -> Self::IntoFuture {
let client = self.client;
let request = self.request;
Box::pin(async move { client.update_schema(&request).await })
}
}
pub struct DeleteSchemaBuilder {
client: SchemaServiceClient,
request: DeleteSchemaRequest,
}
impl DeleteSchemaBuilder {
pub(crate) fn new(client: SchemaServiceClient, full_name: impl Into<String>) -> Self {
let request = DeleteSchemaRequest {
full_name: full_name.into(),
..Default::default()
};
Self { client, request }
}
pub fn with_force(mut self, force: impl Into<Option<bool>>) -> Self {
self.request.force = force.into();
self
}
}
impl IntoFuture for DeleteSchemaBuilder {
type Output = Result<()>;
type IntoFuture = BoxFut<'static, Self::Output>;
fn into_future(self) -> Self::IntoFuture {
let client = self.client;
let request = self.request;
Box::pin(async move { client.delete_schema(&request).await })
}
}