1dfe226d85fea05a46c8ffa688175b4c0f2d4900 - flink-statefun

commit: 1dfe226d85fea05a46c8ffa688175b4c0f2d4900
[log]
author: sjwiesman <sjwiesman@gmail.com>
Wed Aug 11 09:14:31 2021 -0500
committer: sjwiesman <sjwiesman@gmail.com>
Mon Aug 16 08:57:27 2021 -0500
tree: cc4e74b07828e2c73e42479ecd3ed1dbf362f8e2
parent: 33abb7bbddf7dda2471bd8935731e00716e6b077 [diff]

[FLINK-18810][sdk] Golang remote functions SDK

pom.xml[diff]
statefun-sdk-go/generate-dev-protos.sh[Added - diff]
statefun-sdk-go/go.mod[Added - diff]
statefun-sdk-go/go.sum[Added - diff]
statefun-sdk-go/pom.xml[Added - diff]
statefun-sdk-go/run-unit-tests.sh[Added - diff]
statefun-sdk-go/v3/pkg/statefun/cancellation.go[Added - diff]
statefun-sdk-go/v3/pkg/statefun/cancellation_test.go[Added - diff]
statefun-sdk-go/v3/pkg/statefun/context.go[Added - diff]
statefun-sdk-go/v3/pkg/statefun/context_test.go[Added - diff]
statefun-sdk-go/v3/pkg/statefun/egress.go[Added - diff]
statefun-sdk-go/v3/pkg/statefun/handler.go[Added - diff]
statefun-sdk-go/v3/pkg/statefun/internal/cell.go[Added - diff]
statefun-sdk-go/v3/pkg/statefun/internal/cell_test.go[Added - diff]
statefun-sdk-go/v3/pkg/statefun/internal/protocol/kafka-egress.pb.go[Added - diff]
statefun-sdk-go/v3/pkg/statefun/internal/protocol/kinesis-egress.pb.go[Added - diff]
statefun-sdk-go/v3/pkg/statefun/internal/protocol/request-reply.pb.go[Added - diff]
statefun-sdk-go/v3/pkg/statefun/internal/protocol/types.pb.go[Added - diff]
statefun-sdk-go/v3/pkg/statefun/message.go[Added - diff]
statefun-sdk-go/v3/pkg/statefun/message_test.go[Added - diff]
statefun-sdk-go/v3/pkg/statefun/stateful_function.go[Added - diff]
statefun-sdk-go/v3/pkg/statefun/storage.go[Added - diff]
statefun-sdk-go/v3/pkg/statefun/typename.go[Added - diff]
statefun-sdk-go/v3/pkg/statefun/typename_test.go[Added - diff]
statefun-sdk-go/v3/pkg/statefun/types.go[Added - diff]
statefun-sdk-go/v3/pkg/statefun/types_test.go[Added - diff]
statefun-sdk-go/v3/pkg/statefun/value_spec.go[Added - diff]
statefun-sdk-protos/src/main/protobuf/io/kafka-egress.proto[diff]
statefun-sdk-protos/src/main/protobuf/io/kinesis-egress.proto[diff]
statefun-sdk-protos/src/main/protobuf/sdk/request-reply.proto[diff]
statefun-sdk-protos/src/main/protobuf/types/types.proto[diff]

31 files changed