ConnectorService

No overview available.

Methods

---

run()

@classmethod
def run(
    port: int,
    prometheus_port: int,
    worker: int,
    timeout: int | None,
    modules: List[str]| None
) - > None

Starts the gRPC server, making the connector service available to handle requests. This method initializes the server with specified network configurations and loads necessary modules.

Parameters

Name	Type	Description
port	int	The network port on which the gRPC server will listen for incoming connections.
prometheus_port	int	The network port on which Prometheus metrics will be exposed for monitoring.
worker	int	The number of worker threads or processes to use for handling gRPC requests, influencing concurrency and performance.
timeout	`int	None`
modules	`List[str]	None`

Returns

Type	Description
None	This method does not return any value; it runs indefinitely until the server is stopped.

---