Versions in this module Expand all Collapse all v1 v1.9.1 Mar 9, 2026 v1.9.0 Mar 8, 2026 v1.8.1 Mar 8, 2026 v1.8.0 Mar 7, 2026 Changes in this version + var ErrProjectSyncPaused = errors.New("cloudstore: project sync paused") + type AddCloudObservationParams struct + Content string + Project string + Scope string + SessionID string + Title string + ToolName string + TopicKey string + Type string + type AddCloudPromptParams struct + Content string + Project string + SessionID string + type CloudChunkEntry struct + ChunkID string + CreatedBy string + ImportedAt string + Memories int + Prompts int + Sessions int + UserID string + type CloudMutation struct + Entity string + EntityKey string + OccurredAt string + Op string + Payload json.RawMessage + Seq int64 + UserID string + type CloudObservation struct + Content string + CreatedAt string + DeletedAt *string + DuplicateCount int + ID int64 + LastSeenAt *string + Project *string + RevisionCount int + Scope string + SessionID string + Title string + ToolName *string + TopicKey *string + Type string + UpdatedAt string + UserID string + type CloudPrompt struct + Content string + CreatedAt string + ID int64 + Project string + SessionID string + UserID string + type CloudSearchOptions struct + Limit int + Project string + Scope string + Type string + type CloudSearchResult struct + Rank float64 + type CloudSession struct + Directory string + EndedAt *string + ID string + Project string + StartedAt string + Summary *string + UserID string + type CloudSessionSummary struct + EndedAt *string + ID string + ObservationCount int + Project string + StartedAt string + Summary *string + type CloudStats struct + Projects []string + TotalObservations int + TotalPrompts int + TotalSessions int + type CloudStore struct + func New(cfg cloud.Config) (*CloudStore, error) + func (cs *CloudStore) AddObservation(userID string, p AddCloudObservationParams) (int64, error) + func (cs *CloudStore) AddPrompt(userID string, p AddCloudPromptParams) (int64, error) + func (cs *CloudStore) AppendMutation(userID, entity, entityKey, op string, payload json.RawMessage) (int64, error) + func (cs *CloudStore) AppendMutationBatch(userID string, entries []PushMutationEntry) (*PushMutationsResult, error) + func (cs *CloudStore) ApplyMutationPayload(userID, entity, op string, payload json.RawMessage) error + func (cs *CloudStore) Close() error + func (cs *CloudStore) ContributorStats() ([]ContributorStat, error) + func (cs *CloudStore) CreateSession(userID, sessionID, project, directory string) error + func (cs *CloudStore) CreateUser(username, email, password string) (*CloudUser, error) + func (cs *CloudStore) DB() *sql.DB + func (cs *CloudStore) DeleteObservation(userID string, id int64, hard bool) error + func (cs *CloudStore) DeleteObservationByPayload(userID string, payload json.RawMessage) error + func (cs *CloudStore) EndSession(userID, sessionID, summary string) error + func (cs *CloudStore) FilterObservations(userID, project, scope, obsType string, limit int) ([]CloudObservation, error) + func (cs *CloudStore) FormatContext(userID, project, scope string) (string, error) + func (cs *CloudStore) GetChunk(userID, chunkID string) ([]byte, error) + func (cs *CloudStore) GetObservation(userID string, id int64) (*CloudObservation, error) + func (cs *CloudStore) GetProjectSyncControl(project string) (*ProjectSyncControl, error) + func (cs *CloudStore) GetPrompt(userID string, id int64) (*CloudPrompt, error) + func (cs *CloudStore) GetSession(userID, sessionID string) (*CloudSession, error) + func (cs *CloudStore) GetSyncedChunks(userID string) (map[string]bool, error) + func (cs *CloudStore) GetUserByAPIKeyHash(hash string) (*CloudUser, error) + func (cs *CloudStore) GetUserByEmail(email string) (*CloudUser, error) + func (cs *CloudStore) GetUserByID(userID string) (*CloudUser, error) + func (cs *CloudStore) GetUserByUsername(username string) (*CloudUser, error) + func (cs *CloudStore) IsProjectSyncEnabled(project string) (bool, error) + func (cs *CloudStore) ListAllUsers() ([]CloudUser, error) + func (cs *CloudStore) ListChunks(userID string) ([]CloudChunkEntry, error) + func (cs *CloudStore) ListProjectSyncControls() ([]ProjectSyncControl, error) + func (cs *CloudStore) ObservationTypes(userID, project string) ([]string, error) + func (cs *CloudStore) Ping() error + func (cs *CloudStore) ProjectStats(userID string) ([]ProjectStat, error) + func (cs *CloudStore) PullMutations(userID string, sinceSeq int64, limit int) (*PullMutationsResult, error) + func (cs *CloudStore) RecentObservations(userID, project, scope string, limit int) ([]CloudObservation, error) + func (cs *CloudStore) RecentPrompts(userID, project string, limit int) ([]CloudPrompt, error) + func (cs *CloudStore) RecentSessions(userID, project string, limit int) ([]CloudSessionSummary, error) + func (cs *CloudStore) RecordSyncedChunk(userID, chunkID string) error + func (cs *CloudStore) Search(userID, query string, opts CloudSearchOptions) ([]CloudSearchResult, error) + func (cs *CloudStore) SearchPrompts(userID, query, project string, limit int) ([]CloudPrompt, error) + func (cs *CloudStore) SessionObservations(userID, sessionID string, limit int) ([]CloudObservation, error) + func (cs *CloudStore) SessionPrompts(userID, sessionID string, limit int) ([]CloudPrompt, error) + func (cs *CloudStore) SetAPIKeyHash(userID, hash string) error + func (cs *CloudStore) SetProjectSyncEnabled(project string, enabled bool, updatedBy, reason string) error + func (cs *CloudStore) Stats(userID string) (*CloudStats, error) + func (cs *CloudStore) StoreChunk(userID, chunkID, createdBy string, data []byte, ...) error + func (cs *CloudStore) SystemHealth() (*SystemHealthInfo, error) + func (cs *CloudStore) UpsertObservationByPayload(userID string, payload json.RawMessage) error + func (cs *CloudStore) UpsertPromptByPayload(userID string, payload json.RawMessage) error + func (cs *CloudStore) UpsertSessionByPayload(userID string, payload json.RawMessage) error + func (cs *CloudStore) UserProjects(userID string) ([]string, error) + type CloudUser struct + APIKeyHash *string + CreatedAt string + Email string + ID string + PasswordHash string + UpdatedAt string + Username string + type ContributorStat struct + Email string + LastSync *string + ObservationCount int + SessionCount int + UserID string + Username string + type ProjectStat struct + LastActivity *string + ObservationCount int + Project string + PromptCount int + SessionCount int + type ProjectSyncControl struct + PausedReason *string + Project string + SyncEnabled bool + UpdatedAt string + UpdatedBy *string + type PullMutationsResult struct + HasMore bool + Mutations []CloudMutation + type PushMutationEntry struct + Entity string + EntityKey string + Op string + Payload json.RawMessage + type PushMutationsRequest struct + Mutations []PushMutationEntry + type PushMutationsResult struct + Accepted int + LastSeq int64 + type SystemHealthInfo struct + DBConnected bool + DBVersion string + TotalMemories int + TotalMutations int + TotalPrompts int + TotalSessions int + TotalUsers int
Go to main page