igalshilman opened a new pull request #19: [FLINK-15956] Add HTTP function protocol URL: https://github.com/apache/flink-statefun/pull/19 ### Work in progress PR This PR introduces an `HttpFunction`, an extension to stateful functions that allows invoking remote functions exposed via an HTTP endpoint. As a reminder, users can specify an http function by providing an `module.yaml` with the following section: ``` module: .. spec: functions: - function: meta: kind: http type: com.foobar/world spec: endpoint: foobar.com:5959/statefun states: - seen_count ... ``` The definition above implies the following: - that there is a function running behind an HTTP server located at `foobar.com`, port `5959` under the path `/statefun`. - Parsing this module, would create a `StatefulFunction` of type `HttpFunction` that would act as a proxy for the function located at that url. - Any messages sent to `Address(FunctionType("com.foobar", "world"), KEY)` would be directed to an instance of the `HttpFunction` responsible for `KEY` which is responsible for forwarding the message to the actual function at `foobar.com:5959/statefun`. The on the wire communication format is a set of Protocol Buffers messages defined at `http-function.proto`.
---------------------------------------------------------------- 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. For queries about this service, please contact Infrastructure at: [email protected] With regards, Apache Git Services
