@@ -22,42 +22,42 @@ import (
22
22
"go.etcd.io/raft/v3/raftpb"
23
23
)
24
24
25
- type storageRecorder struct {
25
+ type StorageRecorder struct {
26
26
testutil.Recorder
27
27
dbPath string // must have '/' suffix if set
28
28
}
29
29
30
- func NewStorageRecorder (db string ) * storageRecorder {
31
- return & storageRecorder {& testutil.RecorderBuffered {}, db }
30
+ func NewStorageRecorder (db string ) * StorageRecorder {
31
+ return & StorageRecorder {& testutil.RecorderBuffered {}, db }
32
32
}
33
33
34
- func NewStorageRecorderStream (db string ) * storageRecorder {
35
- return & storageRecorder {testutil .NewRecorderStream (), db }
34
+ func NewStorageRecorderStream (db string ) * StorageRecorder {
35
+ return & StorageRecorder {testutil .NewRecorderStream (), db }
36
36
}
37
37
38
- func (p * storageRecorder ) Save (st raftpb.HardState , ents []raftpb.Entry ) error {
38
+ func (p * StorageRecorder ) Save (st raftpb.HardState , ents []raftpb.Entry ) error {
39
39
p .Record (testutil.Action {Name : "Save" })
40
40
return nil
41
41
}
42
42
43
- func (p * storageRecorder ) SaveSnap (st raftpb.Snapshot ) error {
43
+ func (p * StorageRecorder ) SaveSnap (st raftpb.Snapshot ) error {
44
44
if ! raft .IsEmptySnap (st ) {
45
45
p .Record (testutil.Action {Name : "SaveSnap" })
46
46
}
47
47
return nil
48
48
}
49
49
50
- func (p * storageRecorder ) Release (st raftpb.Snapshot ) error {
50
+ func (p * StorageRecorder ) Release (st raftpb.Snapshot ) error {
51
51
if ! raft .IsEmptySnap (st ) {
52
52
p .Record (testutil.Action {Name : "Release" })
53
53
}
54
54
return nil
55
55
}
56
56
57
- func (p * storageRecorder ) Sync () error {
57
+ func (p * StorageRecorder ) Sync () error {
58
58
p .Record (testutil.Action {Name : "Sync" })
59
59
return nil
60
60
}
61
61
62
- func (p * storageRecorder ) Close () error { return nil }
63
- func (p * storageRecorder ) MinimalEtcdVersion () * semver.Version { return nil }
62
+ func (p * StorageRecorder ) Close () error { return nil }
63
+ func (p * StorageRecorder ) MinimalEtcdVersion () * semver.Version { return nil }
0 commit comments