Versions in this module Expand all Collapse all v0 v0.1.0 Jun 14, 2026 Changes in this version + type Option func(*Store) + func WithSynchronous(mode string) Option + type Store struct + func Open(path string, opts ...Option) (*Store, error) + func (s *Store) Append(ctx context.Context, id event.LoopID, expectedLastSeq uint64, ...) error + func (s *Store) Close() error + func (s *Store) Get(ctx context.Context, key string) ([]byte, error) + func (s *Store) LatestSnapshot(ctx context.Context, id event.LoopID) (event.Snapshot, bool, error) + func (s *Store) List(ctx context.Context, f runtime.ListFilter) ([]runtime.LoopMeta, error) + func (s *Store) Load(ctx context.Context, id event.LoopID, fromSeq uint64) iter.Seq2[event.Envelope, error] + func (s *Store) Put(ctx context.Context, loopID event.LoopID, seq uint64, data []byte) (string, error) + func (s *Store) SaveSnapshot(ctx context.Context, snap event.Snapshot) error
Go to main page