Versions in this module Expand all Collapse all v0 v0.6.0 Nov 27, 2021 Changes in this version + const SimpleFormatVersionFirst + var ErrorIncompatibleSessionData = errors.New("incompatible session data") + type Factory interface + New func(batchId string) Pipe + Restore func(id SessionId) (pipe Pipe, err error) + func NewSimple(l esl.Logger, f eq_pipe_preserve.Factory) Factory + func NewTransientSimple(l esl.Logger) Factory + type Pipe interface + Close func() + Delete func(d []byte) + Dequeue func() (d []byte) + Enqueue func(d []byte) + Preserve func() (id SessionId, err error) + Size func() int + type SessionId string