Skip to content
Open
Changes from 1 commit
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
3 changes: 3 additions & 0 deletions consumer/store_json_file.go
Original file line number Diff line number Diff line change
Expand Up @@ -33,6 +33,9 @@ var _ Store = &JSONFileStore{} // JSONFileStore is-a Store.
// of the Store's state, which is decoded into, encoded from, and retained
// as JSONFileState.State.
func NewJSONFileStore(rec *recoverylog.Recorder, state interface{}) (*JSONFileStore, error) {
if state == nil {
return nil, errors.New("state must not be nil")
}
var store = &JSONFileStore{
State: state,
fs: recoverylog.RecordedAferoFS{Recorder: rec, Fs: afero.NewOsFs()},
Expand Down