This closes #3928
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/63b54a5b Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/63b54a5b Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/63b54a5b Branch: refs/heads/master Commit: 63b54a5b0d64e5eb427fb249d5612d60d34e1741 Parents: ed00299 c18f15c Author: Thomas Groh <[email protected]> Authored: Fri Oct 6 08:48:19 2017 -0700 Committer: Thomas Groh <[email protected]> Committed: Fri Oct 6 08:48:19 2017 -0700 ---------------------------------------------------------------------- pom.xml | 49 ++ runners/gcp/gcemd/Dockerfile | 30 + runners/gcp/gcemd/main.go | 85 +++ runners/gcp/gcemd/pom.xml | 154 ++++ runners/gcp/gcsproxy/Dockerfile | 30 + runners/gcp/gcsproxy/main.go | 91 +++ runners/gcp/gcsproxy/pom.xml | 154 ++++ runners/gcp/pom.xml | 38 + runners/pom.xml | 1 + .../src/main/proto/beam_provision_api.proto | 8 +- .../src/main/proto/beam_artifact_api.proto | 10 + sdks/go/BUILD.md | 63 ++ sdks/go/cmd/beamctl/artifact.go | 98 +++ sdks/go/cmd/beamctl/main.go | 64 ++ sdks/go/descriptor.xml | 29 + sdks/go/pkg/beam/artifact/gcsproxy/retrieval.go | 155 ++++ sdks/go/pkg/beam/artifact/gcsproxy/staging.go | 200 +++++ sdks/go/pkg/beam/artifact/materialize.go | 240 ++++++ sdks/go/pkg/beam/artifact/materialize_test.go | 238 ++++++ sdks/go/pkg/beam/artifact/server_test.go | 212 ++++++ sdks/go/pkg/beam/artifact/stage.go | 238 ++++++ sdks/go/pkg/beam/artifact/stage_test.go | 98 +++ sdks/go/pkg/beam/model/gen.go | 21 + .../beam_provision_api.pb.go | 219 ++++++ .../beam_artifact_api.pb.go | 729 +++++++++++++++++++ sdks/go/pkg/beam/provision/provision_test.go | 54 ++ sdks/go/pkg/beam/provision/provison.go | 80 ++ sdks/go/pkg/beam/util/errorx/guarded.go | 47 ++ sdks/go/pkg/beam/util/execx/exec.go | 33 + sdks/go/pkg/beam/util/gcsx/gcs.go | 88 +++ sdks/go/pkg/beam/util/grpcx/dial.go | 37 + sdks/go/pkg/beam/util/grpcx/metadata.go | 55 ++ sdks/go/pom.xml | 163 +++++ sdks/java/container/Dockerfile | 28 + sdks/java/container/boot.go | 111 +++ sdks/java/container/pom.xml | 184 +++++ sdks/java/harness/pom.xml | 66 ++ sdks/java/pom.xml | 1 + sdks/pom.xml | 1 + 39 files changed, 4201 insertions(+), 1 deletion(-) ----------------------------------------------------------------------
