This is an automated email from the ASF dual-hosted git repository.
lostluck pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.
from 752bdfd Merge pull request #12082 from Standardizing BigQuery job
names in Beam Python and Java SDKs
add ad927a1 [BEAM-10610] Add ExternalWorker server
add f59237d [BEAM-10610] Support loopback in universal
add 06dedb6 [BEAM-10610] Set GRPC recv limit to max.
add 670cf24 [BEAM-10610] Support external env cfg.
add df9dc80 [BEAM-10610] Make missed logs more readable.
add 8798913 [BEAM-10610] Fix control response race condition.
new 63705b0 [BEAM-10610][BEAM-9982] Support Loopback mode with universal
runners in the Go SDK.
The 1 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:
sdks/go/pkg/beam/core/runtime/graphx/translate.go | 47 +++----
sdks/go/pkg/beam/core/runtime/harness/harness.go | 7 +-
sdks/go/pkg/beam/core/runtime/harness/logging.go | 2 +-
sdks/go/pkg/beam/options/jobopts/options.go | 9 +-
.../beam/runners/universal/extworker/extworker.go | 120 ++++++++++++++++++
.../runners/universal/extworker/extworker_test.go | 141 +++++++++++++++++++++
sdks/go/pkg/beam/runners/universal/universal.go | 17 ++-
sdks/go/pkg/beam/util/grpcx/dial.go | 3 +-
8 files changed, 314 insertions(+), 32 deletions(-)
create mode 100644 sdks/go/pkg/beam/runners/universal/extworker/extworker.go
create mode 100644
sdks/go/pkg/beam/runners/universal/extworker/extworker_test.go
