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