Versions in this module Expand all Collapse all v1 v1.24.3 Apr 25, 2026 Changes in this version + const LogicalSessionTimeoutMinutes + type Registry struct + func NewRegistry(timeout time.Duration, l *slog.Logger) *Registry + func (r *Registry) AddCursor(ctx context.Context, userID UserID, sessionID uuid.UUID, cursorID int64) + func (r *Registry) Collect(ch chan<- prometheus.Metric) + func (r *Registry) CreateOrUpdateByLSID(ctx context.Context, spec wirebson.AnyDocument) (UserID, uuid.UUID, error) + func (r *Registry) CreateOrUpdateSessions(ctx context.Context, sessionIDs []uuid.UUID) + func (r *Registry) DeleteAllSessions() []int64 + func (r *Registry) DeleteCursor(userID UserID, cursorID int64, db string) error + func (r *Registry) DeleteExpired() []int64 + func (r *Registry) DeleteSessionsByIDs(userID UserID, sessionIDs []uuid.UUID) []int64 + func (r *Registry) DeleteSessionsByUserIDs(userIDs []UserID) []int64 + func (r *Registry) Describe(ch chan<- *prometheus.Desc) + func (r *Registry) EndSessions(ctx context.Context, sessionIDs []uuid.UUID) + func (r *Registry) NewSession(ctx context.Context) uuid.UUID + func (r *Registry) Stop() + func (r *Registry) ValidateCursor(userID UserID, sessionID uuid.UUID, cursorID int64) error + type UserID [sha256.Size]byte + func GetUIDFromUsername(db, username string) UserID + func (s UserID) String() string
Go to main page