tzulitai opened a new pull request #243: URL: https://github.com/apache/flink-statefun/pull/243
The goal of this PR is to allow pluggable / extendable transport clients for invoking remote functions. There are a few major changes included: - (1st commit) Add new SPI interfaces for binding extension objects by `TypeName`. Specifically, these new interfaces are `ExtensionModule` and `ExtensionResolver`, the former used for binding extensions to the application universe, and former used for getting access to bound extensions within the main modules, etc. `StatefulFunctionModules` or `FlinkIOModules`. 2cdddf9 - Introduces a new interface, `RequestReplyClientFactory`, that is responsible for creating the client for each individual remote function endpoint. This interface is public to users as an extension, by binding client factory instances using `ExtensionModule`s. Later on, the factory to use can be referenced using the `TypeName` that was used when binding the factory. a808653 84bce57 45aa1b4 c4f37da - Furthermore, the original OkHttp client's instantiation logic has been refactored as a `RequestReplyClientFactory`. This factory is used by default if users do not specify any transport extensions. 387f7e2 84be2ba - Last of all, we bump the module YAML format version, and rework how transport properties are specified. b6f847b af7f337 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
