nebius.aio.channel.Channel

class documentation

class Channel(ChannelBase): (source)

Known subclasses: nebius.sdk.SDK

Constructor: Channel(resolver, substitutions, domain, options, ...)

Undocumented

Async Method	`__aenter__`	Undocumented
Async Method	`__aexit__`	Undocumented
Method	`__init__`	Undocumented
Method	`bg_task`	Run a coroutine without awaiting or tracking, and log any exceptions.
Async Method	`channel_ready`	Undocumented
Async Method	`close`	Undocumented
Method	`create_address_channel`	Undocumented
Method	`discard_channel`	Undocumented
Method	`get_addr_by_method`	Undocumented
Method	`get_addr_from_service_name`	Undocumented
Method	`get_addr_from_stub`	Undocumented
Method	`get_address_interceptors`	Undocumented
Method	`get_address_options`	Undocumented
Method	`get_channel_by_addr`	Undocumented
Method	`get_channel_by_method`	Undocumented
Method	`get_corresponding_operation_service`	Undocumented
Method	`get_corresponding_operation_service_alpha`	Undocumented
Method	`get_state`	Undocumented
Method	`return_channel`	Undocumented
Method	`run_sync`	Undocumented
Method	`stream_stream`	Undocumented
Method	`stream_unary`	Undocumented
Method	`sync_close`	Undocumented
Method	`unary_stream`	Undocumented
Method	`unary_unary`	Undocumented
Async Method	`wait_for_state_change`	Undocumented
Instance Variable	`_address_interceptors`	Undocumented
Instance Variable	`_address_options`	Undocumented
Instance Variable	`_closed`	Undocumented
Instance Variable	`_event_loop`	Undocumented
Instance Variable	`_free_channels`	Undocumented
Instance Variable	`_global_interceptors`	Undocumented
Instance Variable	`_global_interceptors_inner`	Undocumented
Instance Variable	`_global_options`	Undocumented
Instance Variable	`_gracefuls`	Undocumented
Instance Variable	`_max_free_channels_per_address`	Undocumented
Instance Variable	`_methods`	Undocumented
Instance Variable	`_resolver`	Undocumented
Instance Variable	`_tasks`	Undocumented
Instance Variable	`_tls_credentials`	Undocumented

async def __aenter__(self) -> Channel: (source) ¶

Undocumented

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

Undocumented

def __init__(self, *, resolver: Resolver | None = None, substitutions: dict[str, str] | None = None, domain: str = DOMAIN, options: ChannelArgumentType | None = None, interceptors: Sequence[ClientInterceptor] | None = None, address_options: dict[str, ChannelArgumentType] | None = None, address_interceptors: dict[str, Sequence[ClientInterceptor]] | None = None, credentials: Credentials = None, service_account_id: str | None = None, service_account_public_key_id: str | None = None, service_account_private_key_file_name: str | None = None, credentials_file_name: str | None = None, tls_credentials: ChannelCredentials | None = None, event_loop: AbstractEventLoop | None = None, max_free_channels_per_address: int = 2): (source) ¶

Undocumented

def bg_task(self, coro: Awaitable[T]) -> Task[None]: (source) ¶

Run a coroutine without awaiting or tracking, and log any exceptions.

async def channel_ready(self): (source) ¶

Undocumented

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

Undocumented

def create_address_channel(self, addr: str) -> AddressChannel: (source) ¶

Undocumented

def discard_channel(self, chan: AddressChannel | None): (source) ¶

Undocumented

def get_addr_by_method(self, method_name: str) -> str: (source) ¶

Undocumented

def get_addr_from_service_name(self, service_name: str) -> str: (source) ¶

Undocumented

def get_addr_from_stub(self, service_stub_class: type[ServiceStub]) -> str: (source) ¶

Undocumented

def get_address_interceptors(self, addr: str) -> Sequence[ClientInterceptor]: (source) ¶

Undocumented

def get_address_options(self, addr: str) -> ChannelArgumentType: (source) ¶

Undocumented

def get_channel_by_addr(self, addr: str) -> AddressChannel: (source) ¶

Undocumented

def get_channel_by_method(self, method_name: str) -> AddressChannel: (source) ¶

Undocumented

def get_corresponding_operation_service(self, service_stub_class: type[ServiceStub]) -> OperationServiceStub: (source) ¶

Undocumented

def get_corresponding_operation_service_alpha(self, service_stub_class: type[ServiceStub]) -> OperationServiceStubDeprecated: (source) ¶

Undocumented

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

Undocumented

def return_channel(self, chan: AddressChannel | None): (source) ¶

Undocumented

def run_sync(self, awaitable: Awaitable[T], timeout: float | None = None) -> T: (source) ¶

Undocumented

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

Undocumented

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

Undocumented

def sync_close(self, timeout: float | None = None): (source) ¶

Undocumented

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

Undocumented

def unary_unary(self, method_name: str, request_serializer: SerializingFunction | None = None, response_deserializer: DeserializingFunction | None = None) -> UnaryUnaryMultiCallable[Req, Res]: (source) ¶

Undocumented

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

Undocumented

_address_interceptors = (source) ¶

Undocumented

_address_options = (source) ¶

Undocumented

_closed: bool = (source) ¶

Undocumented

_event_loop = (source) ¶

Undocumented

_free_channels = (source) ¶