Versions in this module Expand all Collapse all v1 v1.3.0 Dec 10, 2020 Changes in this version + type JournalPersister struct + func (lp *JournalPersister) Finalize() + func (lp *JournalPersister) Persist(enc gob.GobEncoder) error + func (lp *JournalPersister) PersistStream(encC chan gob.GobEncoder) chan error + func (lp *JournalPersister) Recover() (chan []byte, error) + func (lp *JournalPersister) ResetDataDir() error + type Persister interface + Finalize func() + Persist func(gob.GobEncoder) error + PersistStream func(chan gob.GobEncoder) chan error + Recover func() (chan []byte, error) + ResetDataDir func() error + func NewJournalPersister(s Storage) Persister + type Storage interface + Reader func() (io.ReadCloser, error) + Reset func() error + Writer func() (io.WriteCloser, error) + func InMemStorage() (Storage, error) + func NewBlobStore(cfg StoreConfig) (Storage, error) + type StoreConfig struct + Bucket *url.URL + func (cfg StoreConfig) Storage() (Storage, error)