pub struct RoutineService { /* private fields */ }Expand description
Implements a client for the BigQuery API.
§Example
async fn sample(
) -> anyhow::Result<()> {
let client = RoutineService::builder().build().await?;
let response = client.get_routine()
/* set fields */
.send().await?;
println!("response {:?}", response);
Ok(())
}§Service Description
RoutineService provides management access to BigQuery routines.
§Configuration
To configure RoutineService use the with_* methods in the type returned
by builder(). The default configuration should
work for most applications. Common configuration changes include
- with_endpoint(): by default this client uses the global default endpoint
(
https://bigquery.googleapis.com). Applications using regional endpoints or running in restricted networks (e.g. a network configured with Private Google Access with VPC Service Controls) may want to override this default. - with_credentials(): by default this client uses Application Default Credentials. Applications using custom authentication may need to override this default.
§Pooling and Cloning
RoutineService holds a connection pool internally, it is advised to
create one and reuse it. You do not need to wrap RoutineService in
an Rc or Arc to reuse it, because it
already uses an Arc internally.
Implementations§
Source§impl RoutineService
impl RoutineService
Sourcepub fn builder() -> ClientBuilder
pub fn builder() -> ClientBuilder
Returns a builder for RoutineService.
let client = RoutineService::builder().build().await?;Sourcepub fn from_stub<T>(stub: impl Into<Arc<T>>) -> Selfwhere
T: RoutineService + 'static,
pub fn from_stub<T>(stub: impl Into<Arc<T>>) -> Selfwhere
T: RoutineService + 'static,
Creates a new client from the provided stub.
The most common case for calling this function is in tests mocking the client’s behavior.
Sourcepub fn get_routine(&self) -> GetRoutine
pub fn get_routine(&self) -> GetRoutine
Gets the specified routine resource by routine ID.
§IAM Permissions
Requires the bigquery.routines.get permission on the routine.
§Example
use google_cloud_bigquery_v2::Result;
async fn sample(
client: &RoutineService
) -> Result<()> {
let response = client.get_routine()
/* set fields */
.send().await?;
println!("response {:?}", response);
Ok(())
}Sourcepub fn insert_routine(&self) -> InsertRoutine
pub fn insert_routine(&self) -> InsertRoutine
Creates a new routine in the dataset.
§IAM Permissions
Requires the bigquery.routines.create permission on the dataset.
§Example
use google_cloud_bigquery_v2::Result;
async fn sample(
client: &RoutineService
) -> Result<()> {
let response = client.insert_routine()
/* set fields */
.send().await?;
println!("response {:?}", response);
Ok(())
}Sourcepub fn update_routine(&self) -> UpdateRoutine
pub fn update_routine(&self) -> UpdateRoutine
Updates information in an existing routine. The update method replaces the entire Routine resource.
§IAM Permissions
Requires the bigquery.routines.update permission on the routine.
§Example
use google_cloud_bigquery_v2::Result;
async fn sample(
client: &RoutineService
) -> Result<()> {
let response = client.update_routine()
/* set fields */
.send().await?;
println!("response {:?}", response);
Ok(())
}Sourcepub fn delete_routine(&self) -> DeleteRoutine
pub fn delete_routine(&self) -> DeleteRoutine
Deletes the routine specified by routineId from the dataset.
§IAM Permissions
Requires the bigquery.routines.delete permission on the routine.
§Example
use google_cloud_bigquery_v2::Result;
async fn sample(
client: &RoutineService
) -> Result<()> {
client.delete_routine()
/* set fields */
.send().await?;
Ok(())
}Sourcepub fn list_routines(&self) -> ListRoutines
pub fn list_routines(&self) -> ListRoutines
Lists all routines in the specified dataset. Requires the READER dataset role.
§IAM Permissions
Requires the bigquery.routines.list permission on the dataset.
§Example
use google_cloud_gax::paginator::ItemPaginator as _;
use google_cloud_bigquery_v2::Result;
async fn sample(
client: &RoutineService
) -> Result<()> {
let mut list = client.list_routines()
/* set fields */
.by_item();
while let Some(item) = list.next().await.transpose()? {
println!("{:?}", item);
}
Ok(())
}Trait Implementations§
Source§impl Clone for RoutineService
impl Clone for RoutineService
Source§fn clone(&self) -> RoutineService
fn clone(&self) -> RoutineService
1.0.0 (const: unstable) · Source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
source. Read moreAuto Trait Implementations§
impl !RefUnwindSafe for RoutineService
impl !UnwindSafe for RoutineService
impl Freeze for RoutineService
impl Send for RoutineService
impl Sync for RoutineService
impl Unpin for RoutineService
impl UnsafeUnpin for RoutineService
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
impl<ST, DT> CastableFrom<ST, Initialized, Initialized> for DT
impl<ST, DT> CastableFrom<ST, Uninit, Uninit> for DT
Source§impl<T> CloneToUninit for Twhere
T: Clone,
impl<T> CloneToUninit for Twhere
T: Clone,
Source§impl<T> FutureExt for T
impl<T> FutureExt for T
Source§fn with_context(self, otel_cx: Context) -> WithContext<Self> ⓘ
fn with_context(self, otel_cx: Context) -> WithContext<Self> ⓘ
Source§fn with_current_context(self) -> WithContext<Self> ⓘ
fn with_current_context(self) -> WithContext<Self> ⓘ
Source§impl<T> Instrument for T
impl<T> Instrument for T
Source§fn instrument(self, span: Span) -> Instrumented<Self> ⓘ
fn instrument(self, span: Span) -> Instrumented<Self> ⓘ
Source§fn in_current_span(self) -> Instrumented<Self> ⓘ
fn in_current_span(self) -> Instrumented<Self> ⓘ
Source§impl<T> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
Source§fn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
T in a tonic::Request