soulfire.plugin_api_connect.PluginApiServiceClient

class soulfire.plugin_api_connect.PluginApiServiceClient(address: str, *, codec: connectrpc.codec.Codec | None = _PROTO_BINARY_CODEC, protocol: connectrpc.protocol.ProtocolType = ProtocolType.CONNECT, accept_compression: collections.abc.Iterable[connectrpc.compression.Compression] | None = None, send_compression: connectrpc.compression.Compression | None = _GZIP_COMPRESSION, timeout_ms: int | None = None, read_max_bytes: int | None = None, interceptors: collections.abc.Iterable[connectrpc.interceptor.Interceptor] = (), http_client: pyqwest.Client | None = None)

Bases: connectrpc.client.ConnectClient

An asynchronous client for the Connect protocol.

async list_plugin_apis(request: soulfire.plugin_api_pb2.ListPluginApisRequest, *, headers: connectrpc.request.Headers | collections.abc.Mapping[str, str] | None = None, timeout_ms: int | None = None) → soulfire.plugin_api_pb2.ListPluginApisResponse

async get_plugin_api(request: soulfire.plugin_api_pb2.GetPluginApiRequest, *, headers: connectrpc.request.Headers | collections.abc.Mapping[str, str] | None = None, timeout_ms: int | None = None) → soulfire.plugin_api_pb2.GetPluginApiResponse

async get_plugin_descriptor_set(request: soulfire.plugin_api_pb2.GetPluginDescriptorSetRequest, *, headers: connectrpc.request.Headers | collections.abc.Mapping[str, str] | None = None, timeout_ms: int | None = None) → soulfire.plugin_api_pb2.GetPluginDescriptorSetResponse

watch_plugin_apis(request: soulfire.plugin_api_pb2.WatchPluginApisRequest, *, headers: connectrpc.request.Headers | collections.abc.Mapping[str, str] | None = None, timeout_ms: int | None = None) → collections.abc.AsyncIterator[soulfire.plugin_api_pb2.PluginApiEvent]

watch_plugin_events(request: soulfire.plugin_api_pb2.WatchPluginEventsRequest, *, headers: connectrpc.request.Headers | collections.abc.Mapping[str, str] | None = None, timeout_ms: int | None = None) → collections.abc.AsyncIterator[soulfire.plugin_api_pb2.PluginEvent]