authority_client
Module: authority_client
Section titled “Module: authority_client”Contents
Section titled “Contents”Modules
backoff- Exponential reconnect backoff with bounded jitter.channel- Authority gRPC channel builder.policy_bundle-WatchPolicyBundlestream task.readiness- Readiness state shared between Authority stream tasks and the pipeline.revocation-WatchRevocationsstream task.swappable_policy- Hot-swappable policy evaluator.
Structs
AuthorityClientHandle- Join handles for the spawned stream tasks.AuthorityDeps- Dependencies required to spawn Authority stream clients.
Functions
spawn_authority_client- Spawn both Authority stream clients.
firma_sidecar::authority_client::AuthorityClientHandle
Section titled “firma_sidecar::authority_client::AuthorityClientHandle”Struct
Join handles for the spawned stream tasks.
Fields:
policy_task: tokio::task::JoinHandle<()>-WatchPolicyBundletask.revocation_task: tokio::task::JoinHandle<()>-WatchRevocationstask.
firma_sidecar::authority_client::AuthorityDeps
Section titled “firma_sidecar::authority_client::AuthorityDeps”Struct
Dependencies required to spawn Authority stream clients.
Fields:
channel: tonic::transport::Channel- Shared tonic channel to the Authority.swappable_policy: std::sync::Arc<self::swappable_policy::SwappablePolicyEvaluation>- Hot-swappable policy evaluator used by Stage 2.revocation_store: std::sync::Arc<dyn RevocationStore>- Revocation store shared with Stage 1.readiness: std::sync::Arc<self::readiness::ReadinessFlag>- Readiness writer shared by stream tasks.cancel: tokio_util::sync::CancellationToken- Cancellation token used for graceful shutdown.config: crate::config::AuthorityConfig- Authority client tuning.bundle_parser: std::sync::Arc<dyn BundleParser>- Policy bundle parser implementation.
Module: backoff
Section titled “Module: backoff”Exponential reconnect backoff with bounded jitter.
Module: channel
Section titled “Module: channel”Authority gRPC channel builder.
Module: policy_bundle
Section titled “Module: policy_bundle”WatchPolicyBundle stream task.
Module: readiness
Section titled “Module: readiness”Readiness state shared between Authority stream tasks and the pipeline.
Module: revocation
Section titled “Module: revocation”WatchRevocations stream task.
firma_sidecar::authority_client::spawn_authority_client
Section titled “firma_sidecar::authority_client::spawn_authority_client”Function
Spawn both Authority stream clients.
fn spawn_authority_client(deps: AuthorityDeps) -> AuthorityClientHandleModule: swappable_policy
Section titled “Module: swappable_policy”Hot-swappable policy evaluator.