persistence

type JournalPersister struct {
	// contains filtered or unexported fields
}

type Persister interface {
	ResetDataDir() error

	Persist(gob.GobEncoder) error
	PersistStream(chan gob.GobEncoder) chan error
	Finalize()

	Recover() (chan []byte, error)
}

type Storage interface {
	// Reset deletes any data stored in the storage
	Reset() error
	// Writer creates a new io.WriteCloser for the storage
	Writer() (io.WriteCloser, error)
	// Reader creates a new io.ReadCloser for the storage
	Reader() (io.ReadCloser, error)

	fmt.Stringer
	// contains filtered or unexported methods
}

type StoreConfig struct {
	Bucket *url.URL
}