Struct IngestBridge 

pub struct IngestBridge { /* private fields */ }

The bridge.

Implementations

impl IngestBridge

pub fn new( registry: Arc<TokenRegistry>, router: Arc<dyn StoreRouter>, budget: RateBudget, cfg: BridgeConfig, ) -> Arc<Self>

Bridge over registry and router.

pub fn has_route(&self, b: &InstanceBinding) -> bool

True if a store owner is known for b.

pub fn forget(&self, instance_id: &str)

Drop an instance’s rate counters (at unload).

pub fn stats(&self) -> &BridgeStats

Counters.

pub async fn bind( self: &Arc<Self>, addr: SocketAddr, scope: BridgeScope, ) -> Result<BridgeHandle, IngestError>

Bind addr and serve scope. A non-loopback address is refused unless the config allows it and the scope is one instance.