remotivelabs.topology.namespaces.namespace

class Namespace(abc.ABC, typing.Generic[~F, ~C]):
Namespace(name: str, broker_client: remotivelabs.broker.BrokerClient)
name: str
async def open(self) -> typing_extensions.Self:

Open the namespace and prepare it for use. This is an idempotent operation - calling it multiple times has no additional effect.

Raises:
  • ValueError: If the namespace is not configured on RemotiveBroker
Returns:

The namespace

async def close(self) -> None:

Close the namespace and clean up resources. This is an idempotent operation - calling it multiple times has no additional effect.