postgres

package
v0.80.1 Latest Latest
Warning

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

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

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewDB 

func NewDB(profile *profile.Profile) (store.Driver, error)

Types

type ConflictConstraintError 

type ConflictConstraintError struct {
	Err     error
	Message string
}

ConflictConstraintError represents a schedule conflict constraint violation. This error is returned when the database EXCLUDE constraint detects an overlap.

func (*ConflictConstraintError) Error 

func (e *ConflictConstraintError) Error() string

func (*ConflictConstraintError) Unwrap 

func (e *ConflictConstraintError) Unwrap() error

type DB 

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

func (*DB) BM25Search 

func (d *DB) BM25Search(ctx context.Context, opts *store.BM25SearchOptions) ([]*store.BM25Result, error)

BM25Search performs full-text search using PostgreSQL's ts_vector with BM25 ranking. Uses the 'simple' text search configuration for better multilingual support.

func (*DB) Close 

func (d *DB) Close() error

func (*DB) CreateAIConversation 

func (d *DB) CreateAIConversation(ctx context.Context, create *store.AIConversation) (*store.AIConversation, error)

func (*DB) CreateAIMessage 

func (d *DB) CreateAIMessage(ctx context.Context, create *store.AIMessage) (*store.AIMessage, error)

func (*DB) CreateActivity 

func (d *DB) CreateActivity(ctx context.Context, create *store.Activity) (*store.Activity, error)

func (*DB) CreateAttachment 

func (d *DB) CreateAttachment(ctx context.Context, create *store.Attachment) (*store.Attachment, error)

func (*DB) CreateEpisodicMemory 

func (d *DB) CreateEpisodicMemory(ctx context.Context, create *store.EpisodicMemory) (*store.EpisodicMemory, error)

func (*DB) CreateIdentityProvider 

func (d *DB) CreateIdentityProvider(ctx context.Context, create *store.IdentityProvider) (*store.IdentityProvider, error)

func (*DB) CreateInbox 

func (d *DB) CreateInbox(ctx context.Context, create *store.Inbox) (*store.Inbox, error)

func (*DB) CreateMemo 

func (d *DB) CreateMemo(ctx context.Context, create *store.Memo) (*store.Memo, error)

func (*DB) CreateSchedule 

func (d *DB) CreateSchedule(ctx context.Context, create *store.Schedule) (*store.Schedule, error)

func (*DB) CreateUser 

func (d *DB) CreateUser(ctx context.Context, create *store.User) (*store.User, error)

func (*DB) DeleteAIConversation 

func (d *DB) DeleteAIConversation(ctx context.Context, delete *store.DeleteAIConversation) error

func (*DB) DeleteAIMessage 

func (d *DB) DeleteAIMessage(ctx context.Context, delete *store.DeleteAIMessage) error

func (*DB) DeleteAgentMetrics 

func (d *DB) DeleteAgentMetrics(ctx context.Context, delete *store.DeleteAgentMetrics) error

func (*DB) DeleteAttachment 

func (d *DB) DeleteAttachment(ctx context.Context, delete *store.DeleteAttachment) error

func (*DB) DeleteEpisodicMemory 

func (d *DB) DeleteEpisodicMemory(ctx context.Context, delete *store.DeleteEpisodicMemory) error

func (*DB) DeleteIdentityProvider 

func (d *DB) DeleteIdentityProvider(ctx context.Context, delete *store.DeleteIdentityProvider) error

func (*DB) DeleteInbox 

func (d *DB) DeleteInbox(ctx context.Context, delete *store.DeleteInbox) error

func (*DB) DeleteInstanceSetting 

func (d *DB) DeleteInstanceSetting(ctx context.Context, delete *store.DeleteInstanceSetting) error

func (*DB) DeleteMemo 

func (d *DB) DeleteMemo(ctx context.Context, delete *store.DeleteMemo) error

func (*DB) DeleteMemoEmbedding 

func (d *DB) DeleteMemoEmbedding(ctx context.Context, memoID int32) error

DeleteMemoEmbedding deletes a memo embedding.

func (*DB) DeleteMemoRelation 

func (d *DB) DeleteMemoRelation(ctx context.Context, delete *store.DeleteMemoRelation) error

func (*DB) DeleteReaction 

func (d *DB) DeleteReaction(ctx context.Context, delete *store.DeleteReaction) error

func (*DB) DeleteSchedule 

func (d *DB) DeleteSchedule(ctx context.Context, delete *store.DeleteSchedule) error

func (*DB) DeleteToolMetrics 

func (d *DB) DeleteToolMetrics(ctx context.Context, delete *store.DeleteToolMetrics) error

func (*DB) DeleteUser 

func (d *DB) DeleteUser(ctx context.Context, delete *store.DeleteUser) error

func (*DB) FindMemosWithoutEmbedding 

func (d *DB) FindMemosWithoutEmbedding(ctx context.Context, find *store.FindMemosWithoutEmbedding) ([]*store.Memo, error)

FindMemosWithoutEmbedding finds memos that don't have embeddings for the specified model.

func (*DB) GetDB 

func (d *DB) GetDB() *sql.DB

func (*DB) GetInbox 

func (d *DB) GetInbox(ctx context.Context, find *store.FindInbox) (*store.Inbox, error)

func (*DB) GetMemo 

func (d *DB) GetMemo(ctx context.Context, find *store.FindMemo) (*store.Memo, error)

func (*DB) GetReaction 

func (d *DB) GetReaction(ctx context.Context, find *store.FindReaction) (*store.Reaction, error)

func (*DB) GetUserByPATHash 

func (d *DB) GetUserByPATHash(ctx context.Context, tokenHash string) (*store.PATQueryResult, error)

func (*DB) GetUserPreferences 

func (d *DB) GetUserPreferences(ctx context.Context, find *store.FindUserPreferences) (*store.UserPreferences, error)

func (*DB) IsInitialized 

func (d *DB) IsInitialized(ctx context.Context) (bool, error)

func (*DB) ListAIConversations 

func (d *DB) ListAIConversations(ctx context.Context, find *store.FindAIConversation) ([]*store.AIConversation, error)

func (*DB) ListAIMessages 

func (d *DB) ListAIMessages(ctx context.Context, find *store.FindAIMessage) ([]*store.AIMessage, error)

func (*DB) ListActiveUserIDs 

func (d *DB) ListActiveUserIDs(ctx context.Context, cutoff time.Time) ([]int32, error)

func (*DB) ListActivities 

func (d *DB) ListActivities(ctx context.Context, find *store.FindActivity) ([]*store.Activity, error)

func (*DB) ListAgentMetrics 

func (d *DB) ListAgentMetrics(ctx context.Context, find *store.FindAgentMetrics) ([]*store.AgentMetrics, error)

func (*DB) ListAttachments 

func (d *DB) ListAttachments(ctx context.Context, find *store.FindAttachment) ([]*store.Attachment, error)

func (*DB) ListEpisodicMemories 

func (d *DB) ListEpisodicMemories(ctx context.Context, find *store.FindEpisodicMemory) ([]*store.EpisodicMemory, error)

func (*DB) ListIdentityProviders 

func (d *DB) ListIdentityProviders(ctx context.Context, find *store.FindIdentityProvider) ([]*store.IdentityProvider, error)

func (*DB) ListInboxes 

func (d *DB) ListInboxes(ctx context.Context, find *store.FindInbox) ([]*store.Inbox, error)

func (*DB) ListInstanceSettings 

func (d *DB) ListInstanceSettings(ctx context.Context, find *store.FindInstanceSetting) ([]*store.InstanceSetting, error)

func (*DB) ListMemoEmbeddings 

func (d *DB) ListMemoEmbeddings(ctx context.Context, find *store.FindMemoEmbedding) ([]*store.MemoEmbedding, error)

ListMemoEmbeddings lists memo embeddings.

func (*DB) ListMemoRelations 

func (d *DB) ListMemoRelations(ctx context.Context, find *store.FindMemoRelation) ([]*store.MemoRelation, error)

func (*DB) ListMemos 

func (d *DB) ListMemos(ctx context.Context, find *store.FindMemo) ([]*store.Memo, error)

func (*DB) ListReactions 

func (d *DB) ListReactions(ctx context.Context, find *store.FindReaction) ([]*store.Reaction, error)

func (*DB) ListSchedules 

func (d *DB) ListSchedules(ctx context.Context, find *store.FindSchedule) ([]*store.Schedule, error)

func (*DB) ListToolMetrics 

func (d *DB) ListToolMetrics(ctx context.Context, find *store.FindToolMetrics) ([]*store.ToolMetrics, error)

func (*DB) ListUserSettings 

func (d *DB) ListUserSettings(ctx context.Context, find *store.FindUserSetting) ([]*store.UserSetting, error)

func (*DB) ListUsers 

func (d *DB) ListUsers(ctx context.Context, find *store.FindUser) ([]*store.User, error)

func (*DB) SearchMemosByVector 

func (d *DB) SearchMemosByVector(ctx context.Context, embedding []float32, limit int) ([]*store.Memo, []float32, error)

SearchMemosByVector performs semantic search using vector similarity. Returns memos and their similarity scores (0-1, higher is more similar).

func (*DB) UpdateAIConversation 

func (d *DB) UpdateAIConversation(ctx context.Context, update *store.UpdateAIConversation) (*store.AIConversation, error)

func (*DB) UpdateAttachment 

func (d *DB) UpdateAttachment(ctx context.Context, update *store.UpdateAttachment) error

func (*DB) UpdateIdentityProvider 

func (d *DB) UpdateIdentityProvider(ctx context.Context, update *store.UpdateIdentityProvider) (*store.IdentityProvider, error)

func (*DB) UpdateInbox 

func (d *DB) UpdateInbox(ctx context.Context, update *store.UpdateInbox) (*store.Inbox, error)

func (*DB) UpdateMemo 

func (d *DB) UpdateMemo(ctx context.Context, update *store.UpdateMemo) error

func (*DB) UpdateMemoEmbedding 

func (d *DB) UpdateMemoEmbedding(ctx context.Context, id int32, embedding []float32) error

UpdateMemoEmbedding updates the embedding vector for a memo.

func (*DB) UpdateSchedule 

func (d *DB) UpdateSchedule(ctx context.Context, update *store.UpdateSchedule) error

func (*DB) UpdateUser 

func (d *DB) UpdateUser(ctx context.Context, update *store.UpdateUser) (*store.User, error)

func (*DB) UpsertAgentMetrics 

func (d *DB) UpsertAgentMetrics(ctx context.Context, upsert *store.UpsertAgentMetrics) (*store.AgentMetrics, error)

func (*DB) UpsertInstanceSetting 

func (d *DB) UpsertInstanceSetting(ctx context.Context, upsert *store.InstanceSetting) (*store.InstanceSetting, error)

func (*DB) UpsertMemoEmbedding 

func (d *DB) UpsertMemoEmbedding(ctx context.Context, embedding *store.MemoEmbedding) (*store.MemoEmbedding, error)

UpsertMemoEmbedding inserts or updates a memo embedding.

func (*DB) UpsertMemoRelation 

func (d *DB) UpsertMemoRelation(ctx context.Context, create *store.MemoRelation) (*store.MemoRelation, error)

func (*DB) UpsertReaction 

func (d *DB) UpsertReaction(ctx context.Context, upsert *store.Reaction) (*store.Reaction, error)

func (*DB) UpsertToolMetrics 

func (d *DB) UpsertToolMetrics(ctx context.Context, upsert *store.UpsertToolMetrics) (*store.ToolMetrics, error)

func (*DB) UpsertUserPreferences 

func (d *DB) UpsertUserPreferences(ctx context.Context, upsert *store.UpsertUserPreferences) (*store.UserPreferences, error)

func (*DB) UpsertUserSetting 

func (d *DB) UpsertUserSetting(ctx context.Context, upsert *store.UserSetting) (*store.UserSetting, error)

func (*DB) VectorSearch 

func (d *DB) VectorSearch(ctx context.Context, opts *store.VectorSearchOptions) ([]*store.MemoWithScore, error)

VectorSearch performs vector similarity search using pgvector.

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.