This is an automated email from the ASF dual-hosted git repository.
altay pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git
The following commit(s) were added to refs/heads/master by this push:
new 34d9762 Add string method to unit status
new d0cb12b Merge pull request #7760 from lostluck/statusStrings
34d9762 is described below
commit 34d976224268184b7f0b9141e1483b9ce7adcb4c
Author: Robert Burke <rob...@frantil.com>
AuthorDate: Wed Feb 6 23:14:21 2019 +0000
Add string method to unit status
---
sdks/go/pkg/beam/core/runtime/exec/status.go | 19 +++++++++++++++++++
sdks/go/pkg/beam/core/runtime/harness/session.go | 8 --------
2 files changed, 19 insertions(+), 8 deletions(-)
diff --git a/sdks/go/pkg/beam/core/runtime/exec/status.go
b/sdks/go/pkg/beam/core/runtime/exec/status.go
index 46b2c32..43e6039 100644
--- a/sdks/go/pkg/beam/core/runtime/exec/status.go
+++ b/sdks/go/pkg/beam/core/runtime/exec/status.go
@@ -15,6 +15,8 @@
package exec
+import "fmt"
+
// Status is the status of a unit or plan.
type Status int
@@ -25,3 +27,20 @@ const (
Broken
Down
)
+
+func (s Status) String() string {
+ switch s {
+ case Initializing:
+ return "Initialzing"
+ case Up:
+ return "Up"
+ case Active:
+ return "Active"
+ case Broken:
+ return "Broken"
+ case Down:
+ return "Down"
+ default:
+ return fmt.Sprintf("UnknownStatus(%d)", int(s))
+ }
+}
diff --git a/sdks/go/pkg/beam/core/runtime/harness/session.go
b/sdks/go/pkg/beam/core/runtime/harness/session.go
index 88807ba..7fecf9f 100644
--- a/sdks/go/pkg/beam/core/runtime/harness/session.go
+++ b/sdks/go/pkg/beam/core/runtime/harness/session.go
@@ -28,14 +28,6 @@ import (
"github.com/golang/protobuf/proto"
)
-const (
- unknown = iota
- instructionRequest
- instructionResponse
- dataReceive
- dataSend
-)
-
// capture is set by the capture hook below.
var capture io.WriteCloser
