@@ -48,6 +48,10 @@ type Network struct {
48
48
ID string `json:"id"`
49
49
}
50
50
51
+ type NetworkReport struct {
52
+ Events []NetworkEvent `json:"events"`
53
+ }
54
+
51
55
type NetworkEvent struct {
52
56
Timestamp time.Time `json:"timestamp"`
53
57
PID int `json:"pid"`
@@ -608,33 +612,15 @@ func (c *Cluster) waitUntilRunning(node Node, nodeNum int, timeoutDuration time.
608
612
}
609
613
610
614
func (c * Cluster ) CollectNetworkReport () ([]NetworkEvent , error ) {
611
- output , err := exec .Command ("replicated" , "network" , "report" , fmt .Sprintf ("--id=%v" , c .network .ID ), "-ojson" ).Output ()
615
+ output , err := exec .Command ("replicated" , "network" , "report" , fmt .Sprintf ("--id=%v" , c .network .ID )).Output ()
612
616
if err != nil {
613
617
return nil , fmt .Errorf ("collect network report: %v" , err )
614
618
}
615
619
616
- type eventWrapper struct {
617
- EventData string `json:"event_data"`
618
- }
619
-
620
- type networkReport struct {
621
- Events []eventWrapper `json:"events"`
622
- }
623
-
624
- report := networkReport {}
620
+ report := NetworkReport {}
625
621
if err := json .Unmarshal (output , & report ); err != nil {
626
622
return nil , fmt .Errorf ("unmarshal network events: %v" , err )
627
623
}
628
624
629
- networkEvents := make ([]NetworkEvent , 0 , len (report .Events ))
630
- for _ , e := range report .Events {
631
- ne := NetworkEvent {}
632
- if err := json .Unmarshal ([]byte (e .EventData ), & ne ); err != nil {
633
- return nil , fmt .Errorf ("unmarshal network event data: %v" , err )
634
- }
635
-
636
- networkEvents = append (networkEvents , ne )
637
- }
638
-
639
- return networkEvents , nil
625
+ return report .Events , nil
640
626
}
0 commit comments