class documentation

Resolve and retain one operation-service address on the SDK loop.

Method __init__ Initialize a source-service channel.
Method unary_unary Return a unary callable routed through the source service.
Method _resolve_address Resolve the source address once and reuse it for this adapter.
Instance Variable _channel Undocumented
Instance Variable _resolved_address Undocumented
Instance Variable _service_name Undocumented
def __init__(self, channel: Channel, service_name: str): (source)

Initialize a source-service channel.

Parameters
channel:ChannelSDK channel that owns the transport pool.
service_name:strSource service used for deferred address resolution.
def unary_unary(self, method: str, request_serializer: SerializingFunction | None = None, response_deserializer: DeserializingFunction | None = None) -> UnaryUnaryMultiCallable[Any, Any]: (source)

Return a unary callable routed through the source service.

Parameters
method:strFully qualified gRPC method name.
request_serializer:SerializingFunction | NoneOptional request serializer.
response_deserializer:DeserializingFunction | NoneOptional response deserializer.
Returns
UnaryUnaryMultiCallable[Any, Any]Callable that creates a cross-loop unary call.
def _resolve_address(self) -> str: (source)

Resolve the source address once and reuse it for this adapter.

Calls reach this method only from the parent channel's SDK event loop, so no additional lock is needed. Failed resolution is not cached and a later operation call may retry it.

Returns
strStable transport address for this operation-service adapter.
_channel = (source)

Undocumented

_resolved_address: str | None = (source)

Undocumented

_service_name = (source)

Undocumented