Struct ClientBuilder 

pub struct ClientBuilder { /* private fields */ }

A builder for Subscriber.

Example

let builder = Subscriber::builder();
let client = builder
    .with_endpoint("https://pubsub.googleapis.com")
    .build()
    .await?;

Implementations

impl ClientBuilder

pub async fn build(self) -> BuilderResult<Subscriber>

Creates a new client.

Example

let client = Subscriber::builder().build().await?;

pub fn with_endpoint<V: Into<String>>(self, v: V) -> Self

Sets the endpoint.

Example

let client = Subscriber::builder()
    .with_endpoint("https://private.googleapis.com")
    .build()
    .await?;

pub fn with_credentials<V: Into<Credentials>>(self, v: V) -> Self

Configures the authentication credentials.

More information about valid credentials types can be found in the google-cloud-auth crate documentation.

Example

use auth::credentials::mds;
let client = Subscriber::builder()
    .with_credentials(
        mds::Builder::default()
            .with_scopes(["https://www.googleapis.com/auth/cloud-platform.read-only"])
            .build()?)
    .build()
    .await?;

pub fn with_grpc_subchannel_count(self, v: usize) -> Self

Configure the number of subchannels used by the client.

Example

let count = std::thread::available_parallelism()?.get();
let client = Subscriber::builder()
    .with_grpc_subchannel_count(std::cmp::max(1, count))
    .build()
    .await?;

gRPC-based clients may exhibit high latency if many requests need to be demuxed over a single HTTP/2 connection (often called a subchannel in gRPC).

Consider using more subchannels if your application makes many concurrent requests. Consider using fewer subchannels if your application needs the file descriptors for other purposes.