You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@beam.apache.org by lc...@apache.org on 2018/04/06 18:38:58 UTC

[beam] 01/01: [BEAM-3355] Diagnostic interfaces

This is an automated email from the ASF dual-hosted git repository.

lcwik pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git

commit 16232c2a8964e294662bbfa30a12aff1a17cf8fa
Merge: c75a1d9 dea8f6e
Author: Lukasz Cwik <lc...@google.com>
AuthorDate: Fri Apr 6 14:38:53 2018 -0400

    [BEAM-3355] Diagnostic interfaces

 sdks/go/pkg/beam/core/runtime/harness/harness.go |  25 +--
 sdks/go/pkg/beam/core/runtime/harness/session.go |  97 +++++++-----
 sdks/go/pkg/beam/core/util/hooks/hooks.go        | 186 +++++++++++++++++++++++
 sdks/go/pkg/beam/runners/dataflow/dataflow.go    |  40 ++++-
 sdks/go/pkg/beam/runners/dataflow/messages.go    |   6 +-
 sdks/go/pkg/beam/runners/session/session.go      |   6 +-
 sdks/go/pkg/beam/util/grpcx/hook.go              |  86 +++++++++++
 sdks/go/pkg/beam/x/hooks/perf/perf.go            | 170 +++++++++++++++++++++
 8 files changed, 550 insertions(+), 66 deletions(-)

-- 
To stop receiving notification emails like this one, please contact
lcwik@apache.org.