Struct IngestHooks 

pub struct IngestHooks { /* private fields */ }

A node’s ingest wiring, shared by its workload hosts.

Implementations

impl IngestHooks

pub fn new( own_node: impl Into<String>, registry: Arc<TokenRegistry>, bridge: Arc<IngestBridge>, shared: SocketAddr, scoped_bind: Option<IpAddr>, ) -> Self

Hooks over registry and bridge; native cogs are told shared (where the shared listener is bound).

pub fn disabled(own_node: impl Into<String>, reason: impl Into<String>) -> Self

Hooks for a node whose bridge could not start. Cogs are placed with no token and no URL, and every place result, status and advertisement says ingest: disabled.

pub fn with_project_controllers( self, c: HashMap<String, HashSet<String>>, ) -> Self

Controllers (node ids) besides this node allowed to place for each project.

pub fn with_project_directory(self, d: Arc<dyn ProjectDirectory>) -> Self

Identity records: a project’s bound key may place for it.

pub fn is_enabled(&self) -> bool

True when the bridge is running.

pub fn state(&self) -> &'static str

enabled or disabled.

pub fn disabled_reason(&self) -> Option<&str>

Why the bridge is disabled.

pub fn registry(&self) -> &Arc<TokenRegistry>

The token registry.

pub fn authorize(&self, b: &InstanceBinding) -> Result<(), IngestError>

May the controller in b.controller_node place a cog for b.project_id, and is there a store owner for the placement? The instance id is not known yet at place time and is ignored.

A project needs one of: the controller is this node; the controller is listed for the project in the config; the controller is the node of the project’s bound key. Whatever the project, a route to a store owner must exist, so a placement whose vectors could not be delivered is refused instead of placed.

pub async fn prepare( &self, route: &str, contract: HostContract, ) -> Result<(HostContract, Option<BridgeHandle>), IngestError>

Complete contract for an instance on route: native cogs get the shared bridge URL; other routes get their own token-scoped listener (when scoped_bind is set) as their ingest_upstream.

pub fn lease( &self, binding: InstanceBinding, contract: HostContract, listener: Option<BridgeHandle>, ) -> Result<IngestLease, IngestError>

Bind a loaded instance to its placement and accept its token.

pub fn activate(&self, l: &IngestLease) -> Result<(), IngestError>

Accept the token again (after a stop and a later start).

pub fn deactivate(&self, l: &IngestLease)

Stop accepting the instance’s token.

Trait Implementations

impl Clone for IngestHooks

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.