nebius.aio.service_descriptor.ExtractorChannel

class documentation

class ExtractorChannel(GRPCChannel): (source)

View In Hierarchy

Undocumented

Async Method __aenter__ Undocumented
Async Method __aexit__ Undocumented
Method __init__ Undocumented
Async Method channel_ready Undocumented
Async Method close Undocumented
Method get_service_name Undocumented
Method get_state Undocumented
Method stream_stream Undocumented
Method stream_unary Undocumented
Method unary_stream Undocumented
Method unary_unary Undocumented
Async Method wait_for_state_change Undocumented
Instance Variable _last_method Undocumented
async def __aenter__(self) -> ExtractorChannel: (source)

Undocumented

async def __aexit__(self, exc_type: Any, exc_val: Any, exc_tb: Any): (source)

Undocumented

def __init__(self): (source)

Undocumented

async def channel_ready(self): (source)

Undocumented

async def close(self, grace: float | None = None): (source)

Undocumented

def get_service_name(self) -> str: (source)

Undocumented

def get_state(self, try_to_connect: bool = False) -> ChannelConnectivity: (source)

Undocumented

def stream_stream(self, method: str, request_serializer: SerializingFunction | None = None, response_deserializer: DeserializingFunction | None = None, _registered_method: bool | None = None) -> StreamStreamMultiCallable: (source)

Undocumented

def stream_unary(self, method: str, request_serializer: SerializingFunction | None = None, response_deserializer: DeserializingFunction | None = None, _registered_method: bool | None = None) -> StreamUnaryMultiCallable: (source)

Undocumented

def unary_stream(self, method: str, request_serializer: SerializingFunction | None = None, response_deserializer: DeserializingFunction | None = None, _registered_method: bool | None = None) -> UnaryStreamMultiCallable[Req, Res]: (source)

Undocumented

def unary_unary(self, method: str, request_serializer: SerializingFunction | None = None, response_deserializer: DeserializingFunction | None = None, _registered_method: bool | None = False) -> UnaryUnaryMultiCallable[Req, Res]: (source)

Undocumented

async def wait_for_state_change(self, last_observed_state: ChannelConnectivity): (source)

Undocumented

_last_method = (source)

Undocumented