Versions in this module Expand all Collapse all v0 v0.6.0 Nov 27, 2021 Changes in this version + var ErrorPreserveIsNotSupported = errors.New("this pipe does not support preserve") + var ErrorSessionIsNotAvailable = errors.New("session is not available") + type Factory interface + NewPreserver func() Preserver + NewRestorer func(sessionId string) Restorer + func NewFactory(l esl.Logger, basePath string) Factory + func NopFactory() Factory + type Preserver interface + Add func(d []byte) error + Commit func(info []byte) (sessionId string, err error) + Start func() error + func NewPreserver(l esl.Logger, basePath string) Preserver + func NopPreserver() Preserver + type Restorer interface + Restore func(infoLoader func(info []byte) error, loader func(d []byte) error) error + func NewRestorer(l esl.Logger, basePath, sessionId string) Restorer + func NopRestorer() Restorer