This is an automated email from the ASF dual-hosted git repository.
trohrmann pushed a change to branch dev
in repository https://gitbox.apache.org/repos/asf/flink-statefun-playground.git.
from d6f6da3 [FLINK-25934] Reduce Statefun's memory consumption to 300mb
add cf7251c [FLINK-26155] Add Playground ingress/egress that allows to
ingest and consume messages via curl
No new revisions were added by this update.
Summary of changes:
...pache.flink.statefun.extensions.ExtensionModule | 10 ++
.../statefun-playground-entrypoint/pom.xml | 45 ++++++++
.../entrypoint/LocalEnvironmentEntrypoint.java | 3 +-
.../statefun/playground/internal/io/Constants.java | 29 +++++
.../playground/internal/io/binders/Utils.java | 34 ++++++
.../internal/io/binders/egress/v1/Module.java | 13 +++
.../binders/egress/v1/PlaygroundEgressBinder.java | 24 ++++
.../internal/io/binders/ingress/v1/Module.java | 13 +++
.../ingress/v1/PlaygroundIngressBinder.java | 27 +++++
.../playground/internal/io/flink/EgressRecord.java | 21 ++++
.../internal/io/flink/EgressWebServer.java | 85 ++++++++++++++
.../internal/io/flink/IngressWebServer.java | 122 +++++++++++++++++++++
.../internal/io/flink/ParseException.java | 7 ++
.../internal/io/flink/PlaygroundEgress.java | 66 +++++++++++
.../internal/io/flink/PlaygroundFlinkIoModule.java | 15 +++
.../internal/io/flink/PlaygroundIngress.java | 50 +++++++++
.../internal/io/flink/PlaygroundSinkProvider.java | 22 ++++
.../io/flink/PlaygroundSourceProvider.java | 23 ++++
.../internal/io/flink/RefCountedContainer.java | 68 ++++++++++++
.../internal/io/spec/PlaygroundEgressSpec.java | 59 ++++++++++
.../internal/io/spec/PlaygroundIngressSpec.java | 49 +++++++++
.../LocalEnvironmentEntrypointITCase.java | 13 +++
.../src/test/resources/module.yaml | 28 +++--
23 files changed, 813 insertions(+), 13 deletions(-)
create mode 100644
playground-internal/statefun-playground-entrypoint/META-INF/services/org.apache.flink.statefun.extensions.ExtensionModule
create mode 100644
playground-internal/statefun-playground-entrypoint/src/main/java/org/apache/flink/statefun/playground/internal/io/Constants.java
create mode 100644
playground-internal/statefun-playground-entrypoint/src/main/java/org/apache/flink/statefun/playground/internal/io/binders/Utils.java
create mode 100644
playground-internal/statefun-playground-entrypoint/src/main/java/org/apache/flink/statefun/playground/internal/io/binders/egress/v1/Module.java
create mode 100644
playground-internal/statefun-playground-entrypoint/src/main/java/org/apache/flink/statefun/playground/internal/io/binders/egress/v1/PlaygroundEgressBinder.java
create mode 100644
playground-internal/statefun-playground-entrypoint/src/main/java/org/apache/flink/statefun/playground/internal/io/binders/ingress/v1/Module.java
create mode 100644
playground-internal/statefun-playground-entrypoint/src/main/java/org/apache/flink/statefun/playground/internal/io/binders/ingress/v1/PlaygroundIngressBinder.java
create mode 100644
playground-internal/statefun-playground-entrypoint/src/main/java/org/apache/flink/statefun/playground/internal/io/flink/EgressRecord.java
create mode 100644
playground-internal/statefun-playground-entrypoint/src/main/java/org/apache/flink/statefun/playground/internal/io/flink/EgressWebServer.java
create mode 100644
playground-internal/statefun-playground-entrypoint/src/main/java/org/apache/flink/statefun/playground/internal/io/flink/IngressWebServer.java
create mode 100644
playground-internal/statefun-playground-entrypoint/src/main/java/org/apache/flink/statefun/playground/internal/io/flink/ParseException.java
create mode 100644
playground-internal/statefun-playground-entrypoint/src/main/java/org/apache/flink/statefun/playground/internal/io/flink/PlaygroundEgress.java
create mode 100644
playground-internal/statefun-playground-entrypoint/src/main/java/org/apache/flink/statefun/playground/internal/io/flink/PlaygroundFlinkIoModule.java
create mode 100644
playground-internal/statefun-playground-entrypoint/src/main/java/org/apache/flink/statefun/playground/internal/io/flink/PlaygroundIngress.java
create mode 100644
playground-internal/statefun-playground-entrypoint/src/main/java/org/apache/flink/statefun/playground/internal/io/flink/PlaygroundSinkProvider.java
create mode 100644
playground-internal/statefun-playground-entrypoint/src/main/java/org/apache/flink/statefun/playground/internal/io/flink/PlaygroundSourceProvider.java
create mode 100644
playground-internal/statefun-playground-entrypoint/src/main/java/org/apache/flink/statefun/playground/internal/io/flink/RefCountedContainer.java
create mode 100644
playground-internal/statefun-playground-entrypoint/src/main/java/org/apache/flink/statefun/playground/internal/io/spec/PlaygroundEgressSpec.java
create mode 100644
playground-internal/statefun-playground-entrypoint/src/main/java/org/apache/flink/statefun/playground/internal/io/spec/PlaygroundIngressSpec.java
create mode 100644
playground-internal/statefun-playground-entrypoint/src/test/java/org/apache/flink/statefun/playground/internal/entrypoint/LocalEnvironmentEntrypointITCase.java
copy javascript/greeter/Dockerfile =>
playground-internal/statefun-playground-entrypoint/src/test/resources/module.yaml
(71%)
