Versions in this module Expand all Collapse all v0 v0.0.1 Jun 22, 2026 Changes in this version + var ForceImport = 0 + func SharedDB(ctx context.Context) (*gorm.DB, *sql.DB, error) + type Capabilities struct + FTS5Enabled bool + VecEnabled bool + func SharedCapabilities(ctx context.Context) (Capabilities, error) + type ConflictError = registrystore.ConflictError + type ForbiddenError = registrystore.ForbiddenError + type NotFoundError = registrystore.NotFoundError + type SQLiteStore struct + func (s *SQLiteStore) AcceptTransfer(ctx context.Context, userID string, transferID uuid.UUID) error + func (s *SQLiteStore) AdminDeleteAttachment(ctx context.Context, attachmentID uuid.UUID) error + func (s *SQLiteStore) AdminGetAttachment(ctx context.Context, attachmentID uuid.UUID) (*registrystore.AdminAttachment, error) + func (s *SQLiteStore) AdminGetAttachmentByStorageKey(ctx context.Context, storageKey string) (*registrystore.AdminAttachment, error) + func (s *SQLiteStore) AdminGetCheckpoint(ctx context.Context, clientID string) (*registrystore.ClientCheckpoint, error) + func (s *SQLiteStore) AdminGetConversation(ctx context.Context, conversationID uuid.UUID) (*registrystore.ConversationDetail, error) + func (s *SQLiteStore) AdminGetEntries(ctx context.Context, conversationID uuid.UUID, ...) (*registrystore.PagedEntries, error) + func (s *SQLiteStore) AdminGetEntryByID(ctx context.Context, entryID uuid.UUID) (*model.Entry, error) + func (s *SQLiteStore) AdminListAttachments(ctx context.Context, query registrystore.AdminAttachmentQuery) ([]registrystore.AdminAttachment, *string, error) + func (s *SQLiteStore) AdminListChildConversations(ctx context.Context, conversationID uuid.UUID, afterCursor *string, limit int) ([]registrystore.ConversationSummary, *string, error) + func (s *SQLiteStore) AdminListConversations(ctx context.Context, query registrystore.AdminConversationQuery) ([]registrystore.ConversationSummary, *string, error) + func (s *SQLiteStore) AdminListForks(ctx context.Context, conversationID uuid.UUID, afterCursor *string, limit int) ([]registrystore.ConversationForkSummary, *string, error) + func (s *SQLiteStore) AdminListMemberships(ctx context.Context, conversationID uuid.UUID, afterCursor *string, limit int) ([]model.ConversationMembership, *string, error) + func (s *SQLiteStore) AdminPutCheckpoint(ctx context.Context, checkpoint registrystore.ClientCheckpoint) (*registrystore.ClientCheckpoint, error) + func (s *SQLiteStore) AdminSearchEntries(ctx context.Context, query registrystore.AdminSearchQuery) (*registrystore.SearchResults, error) + func (s *SQLiteStore) AdminSetConversationArchived(ctx context.Context, conversationID uuid.UUID, archived bool) error + func (s *SQLiteStore) AdminStatsSummary(ctx context.Context) (*registrystore.AdminStatsSummary, error) + func (s *SQLiteStore) AppendEntries(ctx context.Context, userID string, conversationID uuid.UUID, ...) ([]model.Entry, error) + func (s *SQLiteStore) AppendOutboxEvents(ctx context.Context, events []registrystore.OutboxWrite) ([]registrystore.OutboxEvent, error) + func (s *SQLiteStore) ArchiveConversation(ctx context.Context, userID string, conversationID uuid.UUID) error + func (s *SQLiteStore) ClaimReadyTasks(ctx context.Context, limit int) ([]model.Task, error) + func (s *SQLiteStore) CountEvictableGroups(ctx context.Context, cutoff time.Time) (int64, error) + func (s *SQLiteStore) CreateAttachment(ctx context.Context, userID string, conversationID uuid.UUID, ...) (*model.Attachment, error) + func (s *SQLiteStore) CreateConversation(ctx context.Context, userID string, clientID string, title string, ...) (*registrystore.ConversationDetail, error) + func (s *SQLiteStore) CreateConversationWithID(ctx context.Context, userID string, clientID string, convID uuid.UUID, ...) (*registrystore.ConversationDetail, error) + func (s *SQLiteStore) CreateOwnershipTransfer(ctx context.Context, userID string, conversationID uuid.UUID, toUserID string) (*registrystore.OwnershipTransferDto, error) + func (s *SQLiteStore) CreateTask(ctx context.Context, taskType string, taskBody map[string]interface{}) error + func (s *SQLiteStore) DeleteAttachment(ctx context.Context, userID string, conversationID uuid.UUID, ...) error + func (s *SQLiteStore) DeleteMembership(ctx context.Context, userID string, conversationID uuid.UUID, ...) error + func (s *SQLiteStore) DeleteTask(ctx context.Context, taskID uuid.UUID) error + func (s *SQLiteStore) DeleteTransfer(ctx context.Context, userID string, transferID uuid.UUID) error + func (s *SQLiteStore) EvictOutboxEventsBefore(ctx context.Context, before time.Time, limit int) (int64, error) + func (s *SQLiteStore) FailTask(ctx context.Context, taskID uuid.UUID, errMsg string, retryDelay time.Duration) error + func (s *SQLiteStore) FetchSearchResultDetails(ctx context.Context, userID string, entryIDs []uuid.UUID, includeEntry bool) ([]registrystore.SearchResult, error) + func (s *SQLiteStore) FindEntriesPendingVectorIndexing(ctx context.Context, limit int) ([]model.Entry, error) + func (s *SQLiteStore) FindEvictableGroupIDs(ctx context.Context, cutoff time.Time, limit int) ([]uuid.UUID, error) + func (s *SQLiteStore) GetAttachment(ctx context.Context, userID string, conversationID uuid.UUID, ...) (*model.Attachment, error) + func (s *SQLiteStore) GetConversation(ctx context.Context, userID string, conversationID uuid.UUID) (*registrystore.ConversationDetail, error) + func (s *SQLiteStore) GetEntries(ctx context.Context, userID string, conversationID uuid.UUID, ...) (*registrystore.PagedEntries, error) + func (s *SQLiteStore) GetEntryGroupID(ctx context.Context, entryID uuid.UUID) (uuid.UUID, error) + func (s *SQLiteStore) GetGroupMemberUserIDs(ctx context.Context, conversationGroupID uuid.UUID) ([]string, error) + func (s *SQLiteStore) GetTransfer(ctx context.Context, userID string, transferID uuid.UUID) (*registrystore.OwnershipTransferDto, error) + func (s *SQLiteStore) HardDeleteConversationGroups(ctx context.Context, groupIDs []uuid.UUID) error + func (s *SQLiteStore) InReadTx(ctx context.Context, fn func(context.Context) error) error + func (s *SQLiteStore) InWriteTx(ctx context.Context, fn func(context.Context) error) error + func (s *SQLiteStore) IndexEntries(ctx context.Context, entries []registrystore.IndexEntryRequest) (*registrystore.IndexConversationsResponse, error) + func (s *SQLiteStore) ListAttachments(ctx context.Context, userID string, conversationID uuid.UUID, ...) ([]model.Attachment, *string, error) + func (s *SQLiteStore) ListChildConversations(ctx context.Context, userID string, conversationID uuid.UUID, ...) ([]registrystore.ConversationSummary, *string, error) + func (s *SQLiteStore) ListConversationGroupIDs(ctx context.Context, userID string) ([]uuid.UUID, error) + func (s *SQLiteStore) ListConversations(ctx context.Context, userID string, query *string, afterCursor *string, ...) ([]registrystore.ConversationSummary, *string, error) + func (s *SQLiteStore) ListForks(ctx context.Context, userID string, conversationID uuid.UUID, ...) ([]registrystore.ConversationForkSummary, *string, error) + func (s *SQLiteStore) ListMemberships(ctx context.Context, userID string, conversationID uuid.UUID, ...) ([]model.ConversationMembership, *string, error) + func (s *SQLiteStore) ListOutboxEvents(ctx context.Context, query registrystore.OutboxQuery) (*registrystore.OutboxPage, error) + func (s *SQLiteStore) ListPendingTransfers(ctx context.Context, userID string, role string, afterCursor *string, ...) ([]registrystore.OwnershipTransferDto, *string, error) + func (s *SQLiteStore) ListUnindexedEntries(ctx context.Context, limit int, afterCursor *string) ([]model.Entry, *string, error) + func (s *SQLiteStore) LoadDeletedConversationGroups(ctx context.Context, groupIDs []uuid.UUID) ([]registrystore.DeletedConversationGroup, error) + func (s *SQLiteStore) OutboxEnabled() bool + func (s *SQLiteStore) SearchEntries(ctx context.Context, userID string, query string, afterCursor *string, ...) (*registrystore.SearchResults, error) + func (s *SQLiteStore) SetIndexedAt(ctx context.Context, entryID uuid.UUID, conversationGroupID uuid.UUID, ...) error + func (s *SQLiteStore) ShareConversation(ctx context.Context, userID string, conversationID uuid.UUID, ...) (*model.ConversationMembership, error) + func (s *SQLiteStore) SyncAgentEntry(ctx context.Context, userID string, conversationID uuid.UUID, ...) (*registrystore.SyncResult, error) + func (s *SQLiteStore) UnarchiveConversation(ctx context.Context, userID string, conversationID uuid.UUID) error + func (s *SQLiteStore) UpdateAttachment(ctx context.Context, userID string, attachmentID uuid.UUID, ...) (*model.Attachment, error) + func (s *SQLiteStore) UpdateConversation(ctx context.Context, userID string, conversationID uuid.UUID, title *string, ...) (*registrystore.ConversationDetail, error) + func (s *SQLiteStore) UpdateMembership(ctx context.Context, userID string, conversationID uuid.UUID, ...) (*model.ConversationMembership, error) + type ValidationError = registrystore.ValidationError
Go to main page