ref: have run take a channel instead of a Ticker

chaoskube/chaoskube.go

@@ -83,17 +83,17 @@ func New(client kubernetes.Interface, labels, annotations, namespaces labels.Sel
 	}
 }
 
-// Run continuously picks and terminates a victim pod at a given interval described by ticker.
-// It returns when the given context is cancelled.
-func (c *Chaoskube) Run(ctx context.Context, ticker *time.Ticker) {
+// Run continuously picks and terminates a victim pod at a given interval
+// described by channel next. It returns when the given context is canceled.
+func (c *Chaoskube) Run(ctx context.Context, next <-chan time.Time) {
 	for {
 		if err := c.TerminateVictim(); err != nil {
 			c.Logger.WithField("err", err).Error("failed to terminate victim")
 		}
 
 		c.Logger.Debug("sleeping...")
 		select {
-		case <-ticker.C:
+		case <-next:
 		case <-ctx.Done():
 			return
 		}

chaoskube/chaoskube_test.go

@@ -74,7 +74,7 @@ func (suite *Suite) TestNew() {
 }
 
 // TestRun todo
-func (suite *Suite) TestRunContextCancelled() {
+func (suite *Suite) TestRunContextCanceled() {
 	chaoskube := suite.setup(
 		labels.Everything(),
 		labels.Everything(),
@@ -89,10 +89,7 @@ func (suite *Suite) TestRunContextCancelled() {
 	ctx, cancel := context.WithCancel(context.Background())
 	cancel()
 
-	ticker := time.NewTicker(1)
-	defer ticker.Stop()
-
-	chaoskube.Run(ctx, ticker)
+	chaoskube.Run(ctx, nil)
 }
 
 func (suite *Suite) TestCandidates() {

main.go

@@ -170,7 +170,7 @@ func main() {
 	ticker := time.NewTicker(interval)
 	defer ticker.Stop()
 
-	chaoskube.Run(ctx, ticker)
+	chaoskube.Run(ctx, ticker.C)
 }
 
 func newClient() (*kubernetes.Clientset, error) {