This is an automated email from the ASF dual-hosted git repository.
sjwiesman pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink-statefun.git.
from 33abb7b [FLINK-22752] More robust state configurations in base
flink-conf.yaml
new 1dfe226 [FLINK-18810][sdk] Golang remote functions SDK
new a7dfca8 [FLINK-18810][sdk] Golang remote functions smoke test
new 60c8b71 [FLINK-18810][sdk] Document Golang SDK
The 3 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
docs/content/docs/io-module/flink-connectors.md | 33 +
docs/content/docs/sdk/golang.md | 362 +++++
pom.xml | 15 +-
statefun-e2e-tests/pom.xml | 1 +
.../statefun-smoke-e2e-golang}/pom.xml | 20 +-
.../src/main/go/CommandInterpreterFn.go | 133 ++
.../src/main/go/SmokeE2EMain.go | 50 +
.../src/main/go/commands.pb.go | 915 +++++++++++
.../src/main/protobuf/commands.proto | 2 +-
.../smoke/golang/SmokeVerificationGolangE2E.java} | 18 +-
.../src/test/resources/Dockerfile | 0
.../src/test/resources/Dockerfile.remote-function | 12 +-
.../src/test/resources/log4j.properties | 0
.../src/test/resources/remote-module}/module.yaml | 2 +-
.../generate-dev-protos.sh | 4 +-
statefun-sdk-go/go.mod | 23 +
statefun-sdk-go/go.sum | 19 +
{statefun-sdk-python => statefun-sdk-go}/pom.xml | 6 +-
.../run-unit-tests.sh | 15 +-
statefun-sdk-go/v3/pkg/statefun/cancellation.go | 58 +
.../v3/pkg/statefun/cancellation_test.go | 31 +
statefun-sdk-go/v3/pkg/statefun/context.go | 162 ++
statefun-sdk-go/v3/pkg/statefun/context_test.go | 168 ++
statefun-sdk-go/v3/pkg/statefun/egress.go | 230 +++
statefun-sdk-go/v3/pkg/statefun/handler.go | 251 +++
statefun-sdk-go/v3/pkg/statefun/internal/cell.go | 146 ++
.../v3/pkg/statefun/internal/cell_test.go | 121 ++
.../statefun/internal/protocol/kafka-egress.pb.go | 183 +++
.../internal/protocol/kinesis-egress.pb.go | 195 +++
.../statefun/internal/protocol/request-reply.pb.go | 1602 ++++++++++++++++++++
.../v3/pkg/statefun/internal/protocol/types.pb.go | 486 ++++++
statefun-sdk-go/v3/pkg/statefun/message.go | 174 +++
statefun-sdk-go/v3/pkg/statefun/message_test.go | 61 +
.../v3/pkg/statefun/stateful_function.go | 79 +
statefun-sdk-go/v3/pkg/statefun/storage.go | 180 +++
statefun-sdk-go/v3/pkg/statefun/typename.go | 132 ++
statefun-sdk-go/v3/pkg/statefun/typename_test.go | 50 +
statefun-sdk-go/v3/pkg/statefun/types.go | 332 ++++
statefun-sdk-go/v3/pkg/statefun/types_test.go | 154 ++
statefun-sdk-go/v3/pkg/statefun/value_spec.go | 124 ++
.../src/main/protobuf/io/kafka-egress.proto | 1 +
.../src/main/protobuf/io/kinesis-egress.proto | 1 +
.../src/main/protobuf/sdk/request-reply.proto | 1 +
.../src/main/protobuf/types/types.proto | 2 +-
44 files changed, 6508 insertions(+), 46 deletions(-)
create mode 100644 docs/content/docs/sdk/golang.md
copy {statefun-sdk-python =>
statefun-e2e-tests/statefun-smoke-e2e-golang}/pom.xml (70%)
create mode 100644
statefun-e2e-tests/statefun-smoke-e2e-golang/src/main/go/CommandInterpreterFn.go
create mode 100644
statefun-e2e-tests/statefun-smoke-e2e-golang/src/main/go/SmokeE2EMain.go
create mode 100644
statefun-e2e-tests/statefun-smoke-e2e-golang/src/main/go/commands.pb.go
copy statefun-e2e-tests/{statefun-smoke-e2e-common =>
statefun-smoke-e2e-golang}/src/main/protobuf/commands.proto (98%)
copy
statefun-e2e-tests/{statefun-smoke-e2e-java/src/test/java/org/apache/flink/statefun/e2e/smoke/java/SmokeVerificationJavaE2E.java
=>
statefun-smoke-e2e-golang/src/test/java/org/apache/flink/statefun/e2e/smoke/golang/SmokeVerificationGolangE2E.java}
(83%)
copy statefun-e2e-tests/{statefun-smoke-e2e-java =>
statefun-smoke-e2e-golang}/src/test/resources/Dockerfile (100%)
copy statefun-e2e-tests/{statefun-smoke-e2e-java =>
statefun-smoke-e2e-golang}/src/test/resources/Dockerfile.remote-function (79%)
copy statefun-e2e-tests/{statefun-smoke-e2e-java =>
statefun-smoke-e2e-golang}/src/test/resources/log4j.properties (100%)
copy
statefun-e2e-tests/{statefun-smoke-e2e-multilang-harness/src/test/resources =>
statefun-smoke-e2e-golang/src/test/resources/remote-module}/module.yaml (94%)
copy statefun-sdk-python/generte-dev-protos.sh =>
statefun-sdk-go/generate-dev-protos.sh (94%)
mode change 100755 => 100644
create mode 100644 statefun-sdk-go/go.mod
create mode 100644 statefun-sdk-go/go.sum
copy {statefun-sdk-python => statefun-sdk-go}/pom.xml (92%)
copy statefun-sdk-python/generte-dev-protos.sh =>
statefun-sdk-go/run-unit-tests.sh (80%)
create mode 100644 statefun-sdk-go/v3/pkg/statefun/cancellation.go
create mode 100644 statefun-sdk-go/v3/pkg/statefun/cancellation_test.go
create mode 100644 statefun-sdk-go/v3/pkg/statefun/context.go
create mode 100644 statefun-sdk-go/v3/pkg/statefun/context_test.go
create mode 100644 statefun-sdk-go/v3/pkg/statefun/egress.go
create mode 100644 statefun-sdk-go/v3/pkg/statefun/handler.go
create mode 100644 statefun-sdk-go/v3/pkg/statefun/internal/cell.go
create mode 100644 statefun-sdk-go/v3/pkg/statefun/internal/cell_test.go
create mode 100644
statefun-sdk-go/v3/pkg/statefun/internal/protocol/kafka-egress.pb.go
create mode 100644
statefun-sdk-go/v3/pkg/statefun/internal/protocol/kinesis-egress.pb.go
create mode 100644
statefun-sdk-go/v3/pkg/statefun/internal/protocol/request-reply.pb.go
create mode 100644
statefun-sdk-go/v3/pkg/statefun/internal/protocol/types.pb.go
create mode 100644 statefun-sdk-go/v3/pkg/statefun/message.go
create mode 100644 statefun-sdk-go/v3/pkg/statefun/message_test.go
create mode 100644 statefun-sdk-go/v3/pkg/statefun/stateful_function.go
create mode 100644 statefun-sdk-go/v3/pkg/statefun/storage.go
create mode 100644 statefun-sdk-go/v3/pkg/statefun/typename.go
create mode 100644 statefun-sdk-go/v3/pkg/statefun/typename_test.go
create mode 100644 statefun-sdk-go/v3/pkg/statefun/types.go
create mode 100644 statefun-sdk-go/v3/pkg/statefun/types_test.go
create mode 100644 statefun-sdk-go/v3/pkg/statefun/value_spec.go
