stores

package
v0.31.1 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Feb 15, 2026 License: MIT Imports: 21 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func IsBusyError 

func IsBusyError(err error) bool

IsBusyError returns true if the error is a SQLITE_BUSY error.

func IsCorruptionError 

func IsCorruptionError(err error) bool

IsCorruptionError returns true if the error indicates database corruption.

func IsNotFoundError 

func IsNotFoundError(err error) bool

IsNotFoundError returns true if the error is a "not found" error.

func MigrateFromJSON 

func MigrateFromJSON(ctx context.Context, database *db.DB, dataDir string) error

MigrateFromJSON migrates data from JSON files to SQLite if conditions are met: - sessions.json exists - Database has no sessions Skips migration if DB already populated to avoid duplicates.

func RecoverFromCorruption 

func RecoverFromCorruption(dataDir string) error

RecoverFromCorruption attempts to recover from database corruption by backing up the corrupted file and creating a new database.

Types

type KVStore 

type KVStore struct {
	// contains filtered or unexported fields
}

KVStore implements kv.KV using SQLite.

func NewKVStore 

func NewKVStore(db *db.DB) *KVStore

NewKVStore creates a new SQLite-backed KV store.

func (*KVStore) Delete 

func (s *KVStore) Delete(ctx context.Context, key string) error

Delete removes a key.

func (*KVStore) Get 

func (s *KVStore) Get(ctx context.Context, key string, dest any) error

Get retrieves and deserializes a value by key. Returns an error wrapping sql.ErrNoRows if the key does not exist. Expired entries are lazily deleted and treated as missing.

func (*KVStore) GetRaw 

func (s *KVStore) GetRaw(ctx context.Context, key string) (kv.Entry, error)

GetRaw retrieves a raw KV entry with metadata. Returns an error wrapping sql.ErrNoRows if the key does not exist.

func (*KVStore) Has 

func (s *KVStore) Has(ctx context.Context, key string) (bool, error)

Has returns whether a key exists (and is not expired).

func (*KVStore) ListKeys 

func (s *KVStore) ListKeys(ctx context.Context) ([]string, error)

ListKeys returns all non-expired keys in sorted order.

func (*KVStore) Set 

func (s *KVStore) Set(ctx context.Context, key string, value any) error

Set stores a value with no expiry.

func (*KVStore) SetTTL 

func (s *KVStore) SetTTL(ctx context.Context, key string, value any, ttl time.Duration) error

SetTTL stores a value that expires after the given duration.

func (*KVStore) SweepExpired 

func (s *KVStore) SweepExpired(ctx context.Context) error

SweepExpired deletes all entries whose TTL has passed.

type MessageStore 

type MessageStore struct {
	// contains filtered or unexported fields
}

MessageStore implements messaging.Store using SQLite.

func NewMessageStore 

func NewMessageStore(db *db.DB, maxMessages int) *MessageStore

NewMessageStore creates a new SQLite-backed message store. maxMessages controls retention per topic (0 = unlimited).

func (*MessageStore) Acknowledge 

func (m *MessageStore) Acknowledge(ctx context.Context, consumerID string, messageIDs []string) error

Acknowledge marks messages as read by a consumer.

func (*MessageStore) GetUnread 

func (m *MessageStore) GetUnread(ctx context.Context, consumerID string, topic string) ([]messaging.Message, error)

GetUnread returns messages not yet acknowledged by consumer. Supports wildcard topic patterns.

func (*MessageStore) List 

func (m *MessageStore) List(ctx context.Context) ([]string, error)

List returns all topic names.

func (*MessageStore) Prune 

func (m *MessageStore) Prune(ctx context.Context, olderThan time.Duration) (int, error)

Prune removes messages older than the given duration across all topics. Returns the number of messages removed.

func (*MessageStore) Publish 

func (m *MessageStore) Publish(ctx context.Context, msg messaging.Message, topics []string) error

Publish adds a message to multiple topics. Wildcards are expanded before publishing. Enforces retention limit by deleting oldest messages if needed. All topics are published atomically within a single transaction.

func (*MessageStore) Subscribe 

func (m *MessageStore) Subscribe(ctx context.Context, topic string, since time.Time) ([]messaging.Message, error)

Subscribe returns all messages for a topic pattern, optionally filtered by since timestamp. The topic parameter supports wildcards:

  • "*" or "" returns messages from all topics
  • "prefix.*" matches topics starting with "prefix."

Returns ErrTopicNotFound if no matching topics exist.

type NotifyStore 

type NotifyStore struct {
	// contains filtered or unexported fields
}

NotifyStore implements notify.Store using SQLite.

func NewNotifyStore 

func NewNotifyStore(db *db.DB) *NotifyStore

NewNotifyStore creates a new SQLite-backed notification store.

func (*NotifyStore) Clear 

func (s *NotifyStore) Clear(ctx context.Context) error

Clear deletes all notifications.

func (*NotifyStore) Count 

func (s *NotifyStore) Count(ctx context.Context) (int64, error)

Count returns the total number of notifications.

func (*NotifyStore) List 

func (s *NotifyStore) List(ctx context.Context) ([]notify.Notification, error)

List returns all notifications ordered by newest first.

func (*NotifyStore) Save 

func (s *NotifyStore) Save(ctx context.Context, n notify.Notification) (int64, error)

Save persists a notification and returns its auto-generated ID.

type ReviewStore 

type ReviewStore struct {
	// contains filtered or unexported fields
}

ReviewStore implements review.Store using SQLite.

func NewReviewStore 

func NewReviewStore(db *db.DB) *ReviewStore

NewReviewStore creates a new SQLite-backed review store.

func (*ReviewStore) CleanupStaleSessions 

func (s *ReviewStore) CleanupStaleSessions(ctx context.Context, documentPath string, currentHash string) error

CleanupStaleSessions removes review sessions for a document with different content hash.

func (*ReviewStore) CreateSession 

func (s *ReviewStore) CreateSession(ctx context.Context, documentPath string, contentHash string) (review.Session, error)

CreateSession creates a new review session for a document with content hash.

func (*ReviewStore) DeleteComment 

func (s *ReviewStore) DeleteComment(ctx context.Context, commentID string) error

DeleteComment removes a specific comment.

func (*ReviewStore) DeleteSession 

func (s *ReviewStore) DeleteSession(ctx context.Context, sessionID string) error

DeleteSession removes a review session and all associated comments.

func (*ReviewStore) FinalizeSession 

func (s *ReviewStore) FinalizeSession(ctx context.Context, sessionID string) error

FinalizeSession marks a review session as finalized.

func (*ReviewStore) GetAllActiveSessionsWithCounts 

func (s *ReviewStore) GetAllActiveSessionsWithCounts(ctx context.Context) (map[string]SessionInfo, error)

GetAllActiveSessionsWithCounts returns all active (non-finalized) sessions with comment counts. This is optimized for batch operations like the document picker.

func (*ReviewStore) GetSession 

func (s *ReviewStore) GetSession(ctx context.Context, documentPath string) (review.Session, error)

GetSession returns the most recent review session for the given document.

func (*ReviewStore) GetSessionByHash 

func (s *ReviewStore) GetSessionByHash(ctx context.Context, documentPath string, contentHash string) (review.Session, error)

GetSessionByHash returns a review session for the given document and content hash.

func (*ReviewStore) ListComments 

func (s *ReviewStore) ListComments(ctx context.Context, sessionID string) ([]review.Comment, error)

ListComments returns all comments for a review session, sorted by start line.

func (*ReviewStore) SaveComment 

func (s *ReviewStore) SaveComment(ctx context.Context, comment review.Comment) error

SaveComment adds a comment to a review session.

func (*ReviewStore) UpdateComment 

func (s *ReviewStore) UpdateComment(ctx context.Context, comment review.Comment) error

UpdateComment updates the comment text for an existing comment.

type SessionFile 

type SessionFile struct {
	Sessions []session.Session `json:"sessions"`
}

SessionFile is the root JSON structure for sessions.json

type SessionInfo 

type SessionInfo struct {
	Session      review.Session
	CommentCount int
}

SessionInfo contains session data with comment count for efficient batch queries.

type SessionStore 

type SessionStore struct {
	// contains filtered or unexported fields
}

SessionStore implements session.Store using SQLite.

func NewSessionStore 

func NewSessionStore(db *db.DB) *SessionStore

NewSessionStore creates a new SQLite-backed session store.

func (*SessionStore) Delete 

func (s *SessionStore) Delete(ctx context.Context, id string) error

Delete removes a session by ID. Returns ErrNotFound if not found.

func (*SessionStore) FindRecyclable 

func (s *SessionStore) FindRecyclable(ctx context.Context, remote string) (session.Session, error)

FindRecyclable returns a recyclable session for the given remote. Returns ErrNoRecyclable if none available.

func (*SessionStore) Get 

func (s *SessionStore) Get(ctx context.Context, id string) (session.Session, error)

Get returns a session by ID. Returns ErrNotFound if not found.

func (*SessionStore) List 

func (s *SessionStore) List(ctx context.Context) ([]session.Session, error)

List returns all sessions.

func (*SessionStore) Save 

func (s *SessionStore) Save(ctx context.Context, sess session.Session) error

Save creates or updates a session.

type TopicFile 

type TopicFile struct {
	Topic    string              `json:"topic"`
	Messages []messaging.Message `json:"messages"`
}

TopicFile is the root JSON structure for per-topic message files.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.