Fixed intelsdi-x#1675: Updated exemplary streaming collector plugin

plugin/collector/snap-plugin-stream-collector-rand1/main.go → plugin/collector/snap-plugin-streaming-collector-rand1/main.go

@@ -20,8 +20,8 @@ limitations under the License.
 package main
 
 import (
+	"github.com/intelsdi-x/snap-plugin-lib-go/examples/snap-plugin-collector-rand-streaming/rand"
 	"github.com/intelsdi-x/snap-plugin-lib-go/v1/plugin"
-	"github.com/intelsdi-x/snap/plugin/collector/snap-plugin-stream-collector-rand1/rand"
 )
 
 const (

plugin/collector/snap-plugin-stream-collector-rand1/rand/rand.go → plugin/collector/snap-plugin-streaming-collector-rand1/rand/rand.go

@@ -20,6 +20,7 @@ limitations under the License.
 package rand
 
 import (
+	"context"
 	"fmt"
 	"math/rand"
 	"time"
@@ -61,21 +62,21 @@ type RandCollector struct {
 	metrics []plugin.Metric
 }
 
-// StreamMetrics taks both an in and out channel of []plugin.Metric
+// StreamMetrics takes both an in and out channel of []plugin.Metric
 //
 // The metrics_in channel is used to set/update the metrics that Snap is
 // currently requesting to be collected by the plugin.
 //
 // The metrics_out channel is used by the plugin to send the collected metrics
 // to Snap.
 func (r *RandCollector) StreamMetrics(
+	ctx context.Context,
 	metrics_in chan []plugin.Metric,
 	metrics_out chan []plugin.Metric,
 	err chan string) error {
 
 	go r.streamIt(metrics_out, err)
-	go r.drainMetrics(metrics_in)
-
+	r.drainMetrics(metrics_in)
 	return nil
 }
 
@@ -125,7 +126,7 @@ func (r *RandCollector) streamIt(ch chan []plugin.Metric, err chan string) {
 			}
 		}
 		ch <- metrics
-		time.Sleep(time.Second * time.Duration(rand.Int63n(10)))
+		time.Sleep(time.Millisecond * time.Duration(rand.Int63n(1000)))
 	}
 }
 
@@ -145,7 +146,6 @@ func (RandCollector) GetMetricTypes(cfg plugin.Config) ([]plugin.Metric, error)
 	for _, val := range vals {
 		metric := plugin.Metric{
 			Namespace: plugin.NewNamespace("random", val),
-			Version:   1,
 		}
 		metrics = append(metrics, metric)
 	}