@@ -21,7 +21,7 @@ import (
21
21
"log"
22
22
"time"
23
23
24
- "github.com/arduino/arduino-cli/rpc/monitor"
24
+ monitor "github.com/arduino/arduino-cli/rpc/cc/arduino/cli/ monitor/v1 "
25
25
"google.golang.org/grpc"
26
26
"google.golang.org/protobuf/types/known/structpb"
27
27
)
@@ -40,7 +40,7 @@ func main() {
40
40
defer conn .Close ()
41
41
42
42
// Open a monitor instance
43
- mon := monitor .NewMonitorClient (conn )
43
+ mon := monitor .NewMonitorServiceClient (conn )
44
44
stream , err := mon .StreamingOpen (context .Background ())
45
45
if err != nil {
46
46
log .Fatal ("Error opening stream:" , err )
@@ -53,10 +53,10 @@ func main() {
53
53
log .Fatal ("Error creating config:" , err )
54
54
}
55
55
56
- if err := stream .Send (& monitor.StreamingOpenReq {
57
- Content : & monitor.StreamingOpenReq_MonitorConfig {
58
- MonitorConfig : & monitor.MonitorConfig {
59
- Type : monitor .MonitorConfig_NULL ,
56
+ if err := stream .Send (& monitor.StreamingOpenRequest {
57
+ Content : & monitor.StreamingOpenRequest_Config {
58
+ Config : & monitor.MonitorConfig {
59
+ Type : monitor .MonitorConfig_TARGET_TYPE_NULL ,
60
60
AdditionalConfig : additionalConf ,
61
61
RecvRateLimitBuffer : 1024 ,
62
62
},
@@ -65,8 +65,8 @@ func main() {
65
65
log .Fatal ("Error opening stream:" , err )
66
66
}
67
67
68
- if err := stream .Send (& monitor.StreamingOpenReq {
69
- Content : & monitor.StreamingOpenReq_RecvAcknowledge {
68
+ if err := stream .Send (& monitor.StreamingOpenRequest {
69
+ Content : & monitor.StreamingOpenRequest_RecvAcknowledge {
70
70
RecvAcknowledge : 5 ,
71
71
},
72
72
}); err != nil {
@@ -84,8 +84,8 @@ func main() {
84
84
if r .Dropped > 0 {
85
85
fmt .Printf ("DROPPED %d bytes!!!\n " , r .Dropped )
86
86
}
87
- if err := stream .Send (& monitor.StreamingOpenReq {
88
- Content : & monitor.StreamingOpenReq_RecvAcknowledge {
87
+ if err := stream .Send (& monitor.StreamingOpenRequest {
88
+ Content : & monitor.StreamingOpenRequest_RecvAcknowledge {
89
89
RecvAcknowledge : 1 ,
90
90
},
91
91
}); err != nil {
0 commit comments