Documentation
¶
Overview ¶
Package inmem provides an in-memory implementation of session.Store.
It is intended for tests and local development. Production deployments should use a durable implementation (for example features/session/mongo).
Index ¶
- type Store
- func (s *Store) CreateSession(ctx context.Context, sessionID string, createdAt time.Time) (session.Session, error)
- func (s *Store) EndSession(ctx context.Context, sessionID string, endedAt time.Time) (session.Session, error)
- func (s *Store) LinkChildRun(ctx context.Context, parentRunID string, child session.RunMeta) error
- func (s *Store) ListRunsBySession(ctx context.Context, sessionID string, statuses []session.RunStatus) ([]session.RunMeta, error)
- func (s *Store) LoadRun(ctx context.Context, runID string) (session.RunMeta, error)
- func (s *Store) LoadSession(ctx context.Context, sessionID string) (session.Session, error)
- func (s *Store) UpsertRun(ctx context.Context, run session.RunMeta) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Store ¶
type Store struct {
// contains filtered or unexported fields
}
Store is an in-memory implementation of session.Store. It is safe for concurrent use.
func (*Store) CreateSession ¶
func (s *Store) CreateSession(ctx context.Context, sessionID string, createdAt time.Time) (session.Session, error)
CreateSession implements session.Store.
func (*Store) EndSession ¶
func (s *Store) EndSession(ctx context.Context, sessionID string, endedAt time.Time) (session.Session, error)
EndSession implements session.Store.
func (*Store) LinkChildRun ¶
LinkChildRun implements session.Store.
Linking is idempotent: the child run ID is appended to the parent's ChildRunIDs only if it is not already present, so repeated links never duplicate entries.
func (*Store) ListRunsBySession ¶
func (s *Store) ListRunsBySession(ctx context.Context, sessionID string, statuses []session.RunStatus) ([]session.RunMeta, error)
ListRunsBySession implements session.Store.
func (*Store) LoadSession ¶
LoadSession implements session.Store.
func (*Store) UpsertRun ¶
UpsertRun implements session.Store.
ChildRunIDs is intentionally excluded from the update: parent-child links are exclusively managed by LinkChildRun, so callers doing load-modify-write (for example runtime hook handlers) can never erase links committed concurrently by LinkChildRun. Any RunMeta.ChildRunIDs value passed here is ignored and the stored links are preserved.
Source Files