This commit is contained in:
Zach Musgrave
2023-12-05 11:37:48 -08:00
parent 07be50d655
commit 2e963ee8f9

View File

@@ -52,7 +52,7 @@ func NewTestClient() *TestClient {
type flushTester struct {
Client *TestClient
Fbp *FileBackedProc
Flusher *GrpcEventFlusher
Flusher *FileFlusher
}
func createFlushTester(fs filesys.Filesys, hdir string, ddir string) *flushTester {
@@ -62,7 +62,7 @@ func createFlushTester(fs filesys.Filesys, hdir string, ddir string) *flushTeste
fbp := NewFileBackedProc(fs, hdir, ddir, sn.Name, sn.Check)
gef := &GrpcEventFlusher{em: &GrpcEmitter{client}, fbp: fbp}
gef := &FileFlusher{emitter: &GrpcEmitter{client}, fbp: fbp}
return &flushTester{Client: client, Fbp: fbp, Flusher: gef}
}