Code Review
/
ealt-edge.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
review
|
tree
raw
|
inline
| side by side
mepm applcm initial code
[ealt-edge.git]
/
mecm
/
mepm
/
applcm
/
broker
/
pkg
/
plugin
/
grpcclient.go
diff --git
a/mecm/mepm/applcm/broker/pkg/plugin/grpcclient.go
b/mecm/mepm/applcm/broker/pkg/plugin/grpcclient.go
index
27402ed
..
613af74
100644
(file)
--- a/
mecm/mepm/applcm/broker/pkg/plugin/grpcclient.go
+++ b/
mecm/mepm/applcm/broker/pkg/plugin/grpcclient.go
@@
-68,7
+68,7
@@
func NewClientGRPC(cfg ClientGRPCConfig) (c ClientGRPC, err error) {
return
}
return
}
-func (c *ClientGRPC) Instantiate(ctx context.Context, f string, hostIP string) (workloadId string, status string) {
+func (c *ClientGRPC) Instantiate(ctx context.Context, f string, hostIP string) (workloadId string, status string
, error error
) {
var (
writing = true
buf []byte
var (
writing = true
buf []byte
@@
-142,9
+142,10
@@
func (c *ClientGRPC) Instantiate(ctx context.Context, f string, hostIP string) (
res, err := stream.CloseAndRecv()
if err != nil {
logger.Fatalf("failed to receive upstream status response: ", err)
res, err := stream.CloseAndRecv()
if err != nil {
logger.Fatalf("failed to receive upstream status response: ", err)
+ return "", "", err
}
log.Printf("response", res)
}
log.Printf("response", res)
- return res.WorkloadId, res.Status
+ return res.WorkloadId, res.Status
, err
}
func (c *ClientGRPC) Query(ctx context.Context, hostIP string, workloadId string) (status string) {
}
func (c *ClientGRPC) Query(ctx context.Context, hostIP string, workloadId string) (status string) {