temporalio.bridge.services_generated.OperatorService

temporalio.bridge.services_generated.OperatorService

class documentation

class OperatorService: (source)

Known subclasses: temporalio.service.OperatorService

Constructor: OperatorService(client)

View In Hierarchy

RPC calls for the OperatorService.

def __init__(self, client: ServiceClient): (source)

Initialize service with the provided ServiceClient.

async def add_or_update_remote_cluster(self, req: temporalio.api.operatorservice.v1.AddOrUpdateRemoteClusterRequest, retry: bool = False, metadata: Mapping[str, str | bytes] = {}, timeout: timedelta | None = None) -> temporalio.api.operatorservice.v1.AddOrUpdateRemoteClusterResponse: (source)

Invokes the OperatorService.add_or_update_remote_cluster rpc method.

async def add_search_attributes(self, req: temporalio.api.operatorservice.v1.AddSearchAttributesRequest, retry: bool = False, metadata: Mapping[str, str | bytes] = {}, timeout: timedelta | None = None) -> temporalio.api.operatorservice.v1.AddSearchAttributesResponse: (source)

Invokes the OperatorService.add_search_attributes rpc method.

async def create_nexus_endpoint(self, req: temporalio.api.operatorservice.v1.CreateNexusEndpointRequest, retry: bool = False, metadata: Mapping[str, str | bytes] = {}, timeout: timedelta | None = None) -> temporalio.api.operatorservice.v1.CreateNexusEndpointResponse: (source)

Invokes the OperatorService.create_nexus_endpoint rpc method.

async def delete_namespace(self, req: temporalio.api.operatorservice.v1.DeleteNamespaceRequest, retry: bool = False, metadata: Mapping[str, str | bytes] = {}, timeout: timedelta | None = None) -> temporalio.api.operatorservice.v1.DeleteNamespaceResponse: (source)

Invokes the OperatorService.delete_namespace rpc method.

async def delete_nexus_endpoint(self, req: temporalio.api.operatorservice.v1.DeleteNexusEndpointRequest, retry: bool = False, metadata: Mapping[str, str | bytes] = {}, timeout: timedelta | None = None) -> temporalio.api.operatorservice.v1.DeleteNexusEndpointResponse: (source)

Invokes the OperatorService.delete_nexus_endpoint rpc method.

async def get_nexus_endpoint(self, req: temporalio.api.operatorservice.v1.GetNexusEndpointRequest, retry: bool = False, metadata: Mapping[str, str | bytes] = {}, timeout: timedelta | None = None) -> temporalio.api.operatorservice.v1.GetNexusEndpointResponse: (source)

Invokes the OperatorService.get_nexus_endpoint rpc method.

async def list_clusters(self, req: temporalio.api.operatorservice.v1.ListClustersRequest, retry: bool = False, metadata: Mapping[str, str | bytes] = {}, timeout: timedelta | None = None) -> temporalio.api.operatorservice.v1.ListClustersResponse: (source)

Invokes the OperatorService.list_clusters rpc method.

async def list_nexus_endpoints(self, req: temporalio.api.operatorservice.v1.ListNexusEndpointsRequest, retry: bool = False, metadata: Mapping[str, str | bytes] = {}, timeout: timedelta | None = None) -> temporalio.api.operatorservice.v1.ListNexusEndpointsResponse: (source)

Invokes the OperatorService.list_nexus_endpoints rpc method.

async def list_search_attributes(self, req: temporalio.api.operatorservice.v1.ListSearchAttributesRequest, retry: bool = False, metadata: Mapping[str, str | bytes] = {}, timeout: timedelta | None = None) -> temporalio.api.operatorservice.v1.ListSearchAttributesResponse: (source)

Invokes the OperatorService.list_search_attributes rpc method.

async def remove_remote_cluster(self, req: temporalio.api.operatorservice.v1.RemoveRemoteClusterRequest, retry: bool = False, metadata: Mapping[str, str | bytes] = {}, timeout: timedelta | None = None) -> temporalio.api.operatorservice.v1.RemoveRemoteClusterResponse: (source)

Invokes the OperatorService.remove_remote_cluster rpc method.

async def remove_search_attributes(self, req: temporalio.api.operatorservice.v1.RemoveSearchAttributesRequest, retry: bool = False, metadata: Mapping[str, str | bytes] = {}, timeout: timedelta | None = None) -> temporalio.api.operatorservice.v1.RemoveSearchAttributesResponse: (source)

Invokes the OperatorService.remove_search_attributes rpc method.

async def update_nexus_endpoint(self, req: temporalio.api.operatorservice.v1.UpdateNexusEndpointRequest, retry: bool = False, metadata: Mapping[str, str | bytes] = {}, timeout: timedelta | None = None) -> temporalio.api.operatorservice.v1.UpdateNexusEndpointResponse: (source)

Invokes the OperatorService.update_nexus_endpoint rpc method.

_client = (source)

Undocumented

_service: str = (source)

Undocumented