ORIONIS API REFERENCE

THE ORIONIS API

Build with clarity.

Explore the building blocks of an async-first Python framework. Every module, class, and method — connected, searchable, and ready to build with.

class documentation

class RealtimeConnectionLike(Protocol): (source)

View In Hierarchy

Describe the connection surface required by the worker-local registry.

Async Method invoke Invoke one client method and await its correlated completion.
Async Method sendEncoded Send an encoded frame while preserving transport backpressure.
Class Variable __slots__ Undocumented
Property closing Report whether this connection is being released.
Property context Return the immutable connection identity and handshake context.
Property hub Return the Hub namespace owning this connection.
Property protocol Return the immutable codec selected for this connection.
Property ready Report whether acceptance has admitted ordered realtime delivery.
async def invoke(self, target: str, *args: object, timeout: float | None = None) -> object: (source)

Invoke one client method and await its correlated completion.

Parameters
target:strExplicit client method name.
*args:objectSerializable positional arguments supplied to the client method.
timeout:float | None, optionalTotal send/result deadline in seconds. None uses the configured client-result timeout.
Returns
objectClient completion result, including None.
Raises
ConnectionErrorIf the connection is not ready or disconnects.
RuntimeErrorIf the pending client-result budget is exhausted.
ValueErrorIf the target, argument count or deadline is invalid.
TimeoutErrorIf sending or receiving the completion exceeds the deadline.
ClientInvocationErrorIf the client returns a completion error.
async def sendEncoded(self, data: str | bytes): (source)

Send an encoded frame while preserving transport backpressure.

Parameters
data:str | bytesImmutable, already encoded protocol envelope.
Returns
NoneComplete the ordered transport write.
Raises
ConnectionErrorIf connection cleanup has started.
__slots__: tuple = (source)

Undocumented

Report whether this connection is being released.

Returns
boolWhether connection cleanup has started.
context: HubContext = (source)

Return the immutable connection identity and handshake context.

Returns
HubContextConnection identity, public socket and authenticated user.

Return the Hub namespace owning this connection.

Returns
type[Hub]Application-owned Hub type associated with the connection.
protocol: HubProtocol = (source)

Return the immutable codec selected for this connection.

Returns
HubProtocolRoute-selected codec for protocol envelopes.

Report whether acceptance has admitted ordered realtime delivery.

Returns
boolWhether the ready message has admitted connection targeting.