Module tonic::transport

source ·
Expand description

Batteries included server and client.

This module provides a set of batteries included, fully featured and fast set of HTTP/2 server and client’s. These components each provide a rustls tls backend when the respective feature flag is enabled, and provides builders to configure transport behavior.

§Features

  • TLS support via rustls.
  • Load balancing
  • Timeouts
  • Concurrency Limits
  • Rate limiting

§Examples

§Client

let cert = std::fs::read_to_string("ca.pem")?;

let mut channel = Channel::from_static("https://example.com")
    .tls_config(ClientTlsConfig::new()
        .ca_certificate(Certificate::from_pem(&cert))
        .domain_name("example.com".to_string()))?
    .timeout(Duration::from_secs(5))
    .rate_limit(5, Duration::from_secs(1))
    .concurrency_limit(256)
    .connect()
    .await?;

channel.call(Request::new(tonic::body::empty_body())).await?;

§Server

let cert = std::fs::read_to_string("server.pem")?;
let key = std::fs::read_to_string("server.key")?;

let addr = "[::1]:50051".parse()?;

Server::builder()
    .tls_config(ServerTlsConfig::new()
        .identity(Identity::from_pem(&cert, &key)))?
    .concurrency_limit_per_connection(256)
    .add_service(my_svc)
    .serve(addr)
    .await?;

Re-exports§

Modules§

  • Client implementation and builder.
  • Server implementation and builder.

Structs§

  • Represents a X509 certificate.
  • A DER-encoded X.509 certificate; as specified in RFC 5280
  • A default batteries included transport channel.
  • Channel builder.
  • Error’s that originate from the client or server;
  • Represents a private key and X509 certificate.
  • A default batteries included transport server.
  • Deprecated. Please use crate::status::TimeoutExpired instead. Error returned if a request didn’t complete within the configured timeout.
  • The URI component of a request.

Traits§

  • Trait representing a streaming body of a Request or Response.