Log events in the FakeRecorder in e2e tests

Signed-off-by: James Munnelly <james@munnelly.eu>
This commit is contained in:
James Munnelly 2018-11-28 11:26:17 +00:00
parent 34c3590052
commit 939c90c356

View File

@ -19,6 +19,7 @@ package test
import ( import (
"flag" "flag"
"fmt" "fmt"
"log"
"reflect" "reflect"
"time" "time"
@ -85,6 +86,19 @@ func (b *Builder) Start() {
// this may need to be increased in future to acomodate tests that // this may need to be increased in future to acomodate tests that
// produce more than 5 events // produce more than 5 events
b.Recorder = record.NewFakeRecorder(5) b.Recorder = record.NewFakeRecorder(5)
// read all events out of the recorder and just log for now
// TODO: validate logged events
go func() {
r, ok := b.Recorder.(*record.FakeRecorder)
if !ok {
return
}
// exits when r.Events is closed in Finish
for e := range r.Events {
log.Printf("Event logged: %v", e)
}
}()
b.FakeKubeClient().PrependReactor("create", "*", b.generateNameReactor) b.FakeKubeClient().PrependReactor("create", "*", b.generateNameReactor)
b.FakeCMClient().PrependReactor("create", "*", b.generateNameReactor) b.FakeCMClient().PrependReactor("create", "*", b.generateNameReactor)
@ -178,6 +192,10 @@ func (b *Builder) Stop() {
} }
close(b.stopCh) close(b.stopCh)
if r, ok := b.Recorder.(*record.FakeRecorder); ok {
close(r.Events)
}
} }
// WaitForResync will wait for the informer factory informer duration by // WaitForResync will wait for the informer factory informer duration by