temporalio.service._BridgeServiceClient

class documentation

class _BridgeServiceClient(ServiceClient): (source)

Constructors: _BridgeServiceClient.connect(config), _BridgeServiceClient(config)

View In Hierarchy

Undocumented

Async Static Method connect Connect directly to Temporal services.
Method __init__ Initialize the base service client.
Method update_api_key Update Core client API key.
Method update_rpc_metadata Update Core client metadata.
Property worker_service_client Underlying service client.
Async Method _connected_client Undocumented
Async Method _rpc_call Undocumented
Instance Variable _bridge_client Undocumented
Instance Variable _bridge_client_connect_lock Undocumented
Instance Variable _bridge_config Undocumented

Inherited from ServiceClient:

Async Method check_health Check whether the WorkflowService is up.
Instance Variable cloud_service Undocumented
Instance Variable config Undocumented
Instance Variable health_service Undocumented
Instance Variable operator_service Undocumented
Instance Variable test_service Undocumented
Instance Variable workflow_service Undocumented
@staticmethod
async def connect(config: ConnectConfig) -> _BridgeServiceClient: (source)
overrides temporalio.service.ServiceClient.connect

Connect directly to Temporal services.

def __init__(self, config: ConnectConfig): (source)
overrides temporalio.service.ServiceClient.__init__

Initialize the base service client.

def update_api_key(self, api_key: str | None): (source)
overrides temporalio.service.ServiceClient.update_api_key

Update Core client API key.

def update_rpc_metadata(self, metadata: Mapping[str, str | bytes]): (source)
overrides temporalio.service.ServiceClient.update_rpc_metadata

Update Core client metadata.

@property
worker_service_client: _BridgeServiceClient = (source)
overrides temporalio.service.ServiceClient.worker_service_client

Underlying service client.

async def _connected_client(self) -> temporalio.bridge.client.Client: (source)

Undocumented

async def _rpc_call(self, rpc: str, req: google.protobuf.message.Message, resp_type: type[ServiceResponse], *, service: str, retry: bool, metadata: Mapping[str, str | bytes], timeout: timedelta | None) -> ServiceResponse: (source)
overrides temporalio.service.ServiceClient._rpc_call

Undocumented

_bridge_client: temporalio.bridge.client.Client | None = (source)

Undocumented

_bridge_client_connect_lock = (source)

Undocumented

_bridge_config = (source)

Undocumented