add test dat

influxdata · Jul 18, 2017 · 3d8b29b · 3d8b29b
1 parent 9c3cb1c
commit 3d8b29b
Show file tree

Hide file tree

Showing 2 changed files with 54 additions and 0 deletions.
diff --git a/integrations/data/TestStream_Sample.srpl b/integrations/data/TestStream_Sample.srpl
@@ -0,0 +1,33 @@
+dbname
+rpname
+packets value=1000 0000000000
+dbname
+rpname
+packets value=1001 0000000001
+dbname
+rpname
+packets value=1002 0000000002
+dbname
+rpname
+packets value=1003 0000000003
+dbname
+rpname
+packets value=1004 0000000004
+dbname
+rpname
+packets value=1005 0000000005
+dbname
+rpname
+packets value=1006 0000000006
+dbname
+rpname
+packets value=1007 0000000007
+dbname
+rpname
+packets value=1008 0000000008
+dbname
+rpname
+packets value=1009 0000000009
+dbname
+rpname
+packets value=1010 0000000010
diff --git a/k8s_autoscale.go b/k8s_autoscale.go
@@ -69,7 +69,28 @@ func newK8sAutoscaleNode(et *ExecutingTask, n *pipeline.K8sAutoscaleNode, l *log
 }
 
 func (k *K8sAutoscaleNode) runAutoscale([]byte) error {
+	consumer := edge.NewGroupedConsumer(
+		k.ins[0],
+		k,
+	)
+	return consumer.Consume()
+}
+
+
+func (k *K8sAutoscaleNode) NewGroup(group edge.GroupInfo, first edge.PointMeta) (edge.Receiver, error) {
+	return edge.NewReceiverFromForwardReceiverWithStats(
+		k.outs,
+		edge.NewTimedForwardReceiver(k.timer, 
+
+	)
+	panic("not implemented")
+}
+
+func (k *K8sAutoscaleNode) DeleteGroup(group models.GroupID) {
+	panic("not implemented")
+}
 
+func (k *K8sAutoscaleNode) asdf([]byte) error {
 	ins := NewLegacyEdges(k.ins)
 	outs := NewLegacyEdges(k.outs)