You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by lo...@apache.org on 2020/04/08 05:37:32 UTC
[beam] branch lostluck-protosuffix updated: Update session.go
This is an automated email from the ASF dual-hosted git repository.
lostluck pushed a commit to branch lostluck-protosuffix
in repository https://gitbox.apache.org/repos/asf/beam.git
The following commit(s) were added to refs/heads/lostluck-protosuffix by this push:
new d9772ee Update session.go
d9772ee is described below
commit d9772eedcb990125e816eccb8f54e54649f459c5
Author: Robert Burke <lo...@users.noreply.github.com>
AuthorDate: Tue Apr 7 22:37:20 2020 -0700
Update session.go
---
sdks/go/pkg/beam/core/runtime/harness/session.go | 14 +++++++-------
1 file changed, 7 insertions(+), 7 deletions(-)
diff --git a/sdks/go/pkg/beam/core/runtime/harness/session.go b/sdks/go/pkg/beam/core/runtime/harness/session.go
index d783533..f19cf24 100644
--- a/sdks/go/pkg/beam/core/runtime/harness/session.go
+++ b/sdks/go/pkg/beam/core/runtime/harness/session.go
@@ -25,7 +25,7 @@ import (
"github.com/apache/beam/sdks/go/pkg/beam/core/runtime/harness/session"
"github.com/apache/beam/sdks/go/pkg/beam/core/util/hooks"
"github.com/apache/beam/sdks/go/pkg/beam/internal/errors"
- pb "github.com/apache/beam/sdks/go/pkg/beam/model/fnexecution_v1"
+ fnpb "github.com/apache/beam/sdks/go/pkg/beam/model/fnexecution_v1"
"github.com/golang/protobuf/proto"
)
@@ -73,7 +73,7 @@ func recordMessage(opcode session.Kind, pb *session.Entry) error {
}
eh := &session.EntryHeader{
- Kind: pb.Kind,
+ Kind: fnpb.Kind,
Len: int64(len(body.Bytes())),
}
@@ -105,7 +105,7 @@ func recordMessage(opcode session.Kind, pb *session.Entry) error {
return nil
}
-func recordInstructionRequest(req *pb.InstructionRequest) error {
+func recordInstructionRequest(req *fnpb.InstructionRequest) error {
return recordMessage(session.Kind_INSTRUCTION_REQUEST,
&session.Entry{
Kind: session.Kind_INSTRUCTION_REQUEST,
@@ -115,7 +115,7 @@ func recordInstructionRequest(req *pb.InstructionRequest) error {
})
}
-func recordInstructionResponse(resp *pb.InstructionResponse) error {
+func recordInstructionResponse(resp *fnpb.InstructionResponse) error {
return recordMessage(session.Kind_INSTRUCTION_RESPONSE,
&session.Entry{
Kind: session.Kind_INSTRUCTION_RESPONSE,
@@ -125,7 +125,7 @@ func recordInstructionResponse(resp *pb.InstructionResponse) error {
})
}
-func recordStreamReceive(data *pb.Elements) error {
+func recordStreamReceive(data *fnpb.Elements) error {
return recordMessage(session.Kind_DATA_RECEIVED,
&session.Entry{
Kind: session.Kind_DATA_RECEIVED,
@@ -135,7 +135,7 @@ func recordStreamReceive(data *pb.Elements) error {
})
}
-func recordStreamSend(data *pb.Elements) error {
+func recordStreamSend(data *fnpb.Elements) error {
return recordMessage(session.Kind_DATA_SENT,
&session.Entry{
Kind: session.Kind_DATA_SENT,
@@ -145,7 +145,7 @@ func recordStreamSend(data *pb.Elements) error {
})
}
-func recordLogEntries(entries *pb.LogEntry_List) error {
+func recordLogEntries(entries *fnpb.LogEntry_List) error {
return recordMessage(session.Kind_LOG_ENTRIES,
&session.Entry{
Kind: session.Kind_LOG_ENTRIES,