Struct GlobalRegistryClient 

pub struct GlobalRegistryClient {
    pub last_assigned_ttl_ns: u64,
    pub last_heartbeat_interval_ns: u64,
    pub last_announce_ts_ns: u64,
}

Client half of GlobalRegistry. Holds TTL / heartbeat state echoed from the server’s most recent Handshake; the server peer is wired through the graph at every Announce and is not a struct field.

Fields

last_assigned_ttl_ns: u64

TTL the server assigned in its last Handshake response. Stamped into outgoing Announce envelopes as remaining_deadline_ns so receivers can age out stale entries without per-peer state.

last_heartbeat_interval_ns: u64

Heartbeat interval the server computed in its last Handshake (assigned_ttl_ns / 3). The client respects this interval when throttling subsequent Announces.

last_announce_ts_ns: u64

Monotonic-ns timestamp of the most recent Announce dispatch. Skipped on snapshot/restore so bootstrap re-seeds the cadence on resume.

Implementations

impl GlobalRegistryClient

pub fn new() -> Self

Construct with default TTL state. The server peer is wired through the graph at every Announce op and is not a field.

Trait Implementations

impl AnyComponent for GlobalRegistryClient

fn as_any(&self) -> &dyn Any

Downcast view - immutable.

fn as_any_mut(&mut self) -> &mut dyn Any

Downcast view - mutable.

impl Bootstrap for GlobalRegistryClient

type Error = Infallible

Library-maker-defined error type. Must satisfy the standard engine error bounds so the framework can box it into the dispatch error channel.

fn bootstrap(&mut self, _ctx: &mut BootstrapCtx) -> Result<(), Self::Error>

Run one-shot setup. Default no-op so Components without an initialization phase need no boilerplate. Authors override to mmap state, allocate backend tensors, prime calibration buffers, etc.

impl Clone for GlobalRegistryClient

fn clone(&self) -> GlobalRegistryClient

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl ConcreteComponent for GlobalRegistryClient

const TYPE_NAME: &'static str = "GlobalRegistryClient"

Stable identifier. Convention: <crate>::<TypeName>.

const PACKAGE: ComponentPackage = ::bytesandbrains::concrete::ComponentPackage::Application

Origin tag; defaults to Application.

const DEPENDENCIES: &'static [DependencyDecl]

Sibling components this depends on. Populated by the bb::Concrete derive from #[bb::depends(...)].

type Config = ()

Per-deployment config. Use () for stateless concretes.

type Error = Infallible

Error from Self::new; use Infallible if construction can’t fail.

fn new(_config: &Self::Config) -> Result<Self, Self::Error>

Construct from &Self::Config. Install calls this once per slot.

fn serialize(&self) -> Vec<u8>

Serialize state to bytes, including config-derived fields.

fn restore(bytes: &[u8]) -> Result<Self, RestoreError>

Reconstruct from serialize output.

impl Debug for GlobalRegistryClient

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for GlobalRegistryClient

fn default() -> GlobalRegistryClient

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for GlobalRegistryClient

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl ProtocolRuntime for GlobalRegistryClient

type Error = OpError

Protocol-impl-specific error type.

fn atomic_opset(&self) -> AtomicOpsetDecl

Atomic-op opset this protocol declares. Both inbound envelope routing AND user-graph DSL ops register here.

fn dispatch_atomic( &mut self, op_type: &str, inputs: &[(&str, &dyn SlotValue)], ctx: &mut RuntimeResourceRef<'_>, ) -> Result<DispatchResult, OpError>

Single dispatch entry. For inbound envelopes the framework synthesizes inputs from the wire envelope:

impl Serialize for GlobalRegistryClient

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.