Struct ClientJwtInterceptor 

pub struct ClientJwtInterceptor<P: TokenProvider> { /* private fields */ }

Generic interceptor that calls any TokenProvider and attaches the result as a Bearer token on every outbound gRPC request.

Used internally by the from_endpoint_with_provider constructor that #[derive(GrpcClient)] generates on every client struct; consumers do not typically construct this directly.

To forward the caller’s token from an incoming request to a downstream service, use crate::auth::extract_token to obtain a rust_auth_lib::ForwardedToken and pass it as the provider:

#[rust_grpc_lib::keycloak_authenticated_service]
impl Daq for MyDaqService {
    async fn get_data(&self, req: Request<GetDataRequest>) -> Result<Response<GetDataResponse>, Status> {
        let provider = rust_grpc_lib::auth::extract_token(&req)?;
        let client = AlarmCommandsClient::from_endpoint_with_provider(
            "http://alarm-host:50051",
            provider,
        )?;
        // ...
    }
}

Implementations

impl<P: TokenProvider> ClientJwtInterceptor<P>

pub fn new(provider: P) -> Self

Trait Implementations

impl<P: TokenProvider> Interceptor for ClientJwtInterceptor<P>

fn call(&mut self, req: Request<()>) -> Result<Request<()>, Status>

Intercept a request before it is sent, optionally cancelling it.