postgres

package

Go to main page

Versions in this module

v0

v0.4.0

May 9, 2026

Changes in this version

type CapabilityStore

+ func (s *CapabilityStore) SetToggles(ctx context.Context, teamID string, toggles map[domain.CapabilityType]bool) error

type ConnectionStore

+ func (s *ConnectionStore) GetByTenantID(ctx context.Context, platform domain.PlatformType, tenantID string) (*domain.Connection, error)

type OAuthTokenStore

+ func (s *OAuthTokenStore) ListClientsForUser(ctx context.Context, userID string) ([]string, error)

+ func (s *OAuthTokenStore) ListUsersForClient(ctx context.Context, clientID string) ([]string, error)

+ type SyncFailedDocStore struct

+ func NewSyncFailedDocStore(db *DB) *SyncFailedDocStore

+ func (s *SyncFailedDocStore) CountBySource(ctx context.Context, sourceID string) (int, error)

+ func (s *SyncFailedDocStore) ListBySource(ctx context.Context, sourceID string, limit int) ([]domain.SyncFailedDoc, error)

+ func (s *SyncFailedDocStore) ListReadyForRetry(ctx context.Context, sourceID string, now time.Time, limit int) ([]domain.SyncFailedDoc, error)

+ func (s *SyncFailedDocStore) MarkSucceeded(ctx context.Context, sourceID, externalID string) error

+ func (s *SyncFailedDocStore) Record(ctx context.Context, failure driven.SyncFailedDocRecord) error

v0.3.0

May 1, 2026

Changes in this version

+ func Down(ctx context.Context, db *sql.DB) error

+ func EnsureClean(ctx context.Context, db *sql.DB) error

+ func MaxEmbeddedVersion() (int64, error)

+ func Status(ctx context.Context, db *sql.DB) error

+ func Up(ctx context.Context, db *sql.DB) error

+ func Version(ctx context.Context, db *sql.DB) (int64, error)

type DocumentStore

+ func (s *DocumentStore) GetByIDs(ctx context.Context, ids []string) (map[string]*domain.Document, error)

+ type EnvDBCredential struct

+ EnvVar string

+ func NewEnvDBCredential() *EnvDBCredential

+ func (e *EnvDBCredential) Resolve(_ context.Context) (string, error)

+ type SyncEventRepository struct

+ func NewSyncEventRepository(db *DB) *SyncEventRepository

+ func (r *SyncEventRepository) List(ctx context.Context, teamID string, limit int) ([]*domain.SyncEvent, error)

+ func (r *SyncEventRepository) ListBySource(ctx context.Context, sourceID string, limit int) ([]*domain.SyncEvent, error)

+ func (r *SyncEventRepository) Save(ctx context.Context, event *domain.SyncEvent) error

v0.2.2

Apr 19, 2026

v0.2.1

Apr 16, 2026

Changes in this version

+ type AuthorizationCodeStore struct

+ func NewAuthorizationCodeStore(db *sql.DB) *AuthorizationCodeStore

+ func (s *AuthorizationCodeStore) Cleanup(ctx context.Context) error

+ func (s *AuthorizationCodeStore) GetAndMarkUsed(ctx context.Context, code string) (*domain.AuthorizationCode, error)

+ func (s *AuthorizationCodeStore) Save(ctx context.Context, code *domain.AuthorizationCode) error

type ConnectionStore

+ func (s *ConnectionStore) GetByPlatform(ctx context.Context, platform domain.PlatformType) ([]*domain.ConnectionSummary, error)

type DocumentStore

+ func (s *DocumentStore) DeleteBySourceAndContainer(ctx context.Context, sourceID, containerID string) error

+ type OAuthClientStore struct

+ func NewOAuthClientStore(db *sql.DB) *OAuthClientStore

+ func (s *OAuthClientStore) Delete(ctx context.Context, clientID string) error

+ func (s *OAuthClientStore) Get(ctx context.Context, clientID string) (*domain.OAuthClient, error)

+ func (s *OAuthClientStore) List(ctx context.Context) ([]*domain.OAuthClient, error)

+ func (s *OAuthClientStore) Save(ctx context.Context, client *domain.OAuthClient) error

+ type OAuthTokenStore struct

+ func NewOAuthTokenStore(db *sql.DB) *OAuthTokenStore

+ func (s *OAuthTokenStore) Cleanup(ctx context.Context) error

+ func (s *OAuthTokenStore) GetAccessToken(ctx context.Context, tokenID string) (*domain.OAuthAccessToken, error)

+ func (s *OAuthTokenStore) GetRefreshToken(ctx context.Context, tokenID string) (*domain.OAuthRefreshToken, error)

+ func (s *OAuthTokenStore) RevokeAccessToken(ctx context.Context, tokenID string) error

+ func (s *OAuthTokenStore) RevokeAllForClient(ctx context.Context, clientID string) error

+ func (s *OAuthTokenStore) RevokeRefreshToken(ctx context.Context, tokenID string) error

+ func (s *OAuthTokenStore) RotateRefreshToken(ctx context.Context, oldTokenID string, newTokenID string) error

+ func (s *OAuthTokenStore) SaveAccessToken(ctx context.Context, token *domain.OAuthAccessToken) error

+ func (s *OAuthTokenStore) SaveRefreshToken(ctx context.Context, token *domain.OAuthRefreshToken) error

v0.2.0

Apr 8, 2026

Changes in this version

+ const DefaultOAuthStateTTL

+ var ErrDecryptionFailed = errors.New("failed to decrypt secret blob")

+ var ErrInvalidBlobSize = errors.New("encrypted blob is too small")

+ var ErrInvalidKeySize = errors.New("encryption key must be 32 bytes")

+ var ErrUnsupportedVersion = errors.New("unsupported secret blob version")

+ func NullString(s *string) sql.NullString

+ func NullTime(t *time.Time) sql.NullTime

+ func StringPtr(ns sql.NullString) *string

+ func TimePtr(nt sql.NullTime) *time.Time

+ type AdvisoryLock struct

+ func NewAdvisoryLock(db *DB) *AdvisoryLock

+ func (l *AdvisoryLock) Acquire(ctx context.Context, name string, ttl time.Duration) (bool, error)

+ func (l *AdvisoryLock) Extend(ctx context.Context, name string, ttl time.Duration) error

+ func (l *AdvisoryLock) Ping(ctx context.Context) error

+ func (l *AdvisoryLock) Release(ctx context.Context, name string) error

+ type CapabilityStore struct

+ func NewCapabilityStore(db *DB) *CapabilityStore

+ func (s *CapabilityStore) GetPreferences(ctx context.Context, teamID string) (*domain.CapabilityPreferences, error)

+ func (s *CapabilityStore) SavePreferences(ctx context.Context, prefs *domain.CapabilityPreferences) error

+ type ChunkStore struct

+ func NewChunkStore(db *DB) *ChunkStore

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

+ func (s *ChunkStore) DeleteBatch(ctx context.Context, ids []string) error

+ func (s *ChunkStore) DeleteByDocument(ctx context.Context, documentID string) error

+ func (s *ChunkStore) DeleteBySource(ctx context.Context, sourceID string) error

+ func (s *ChunkStore) GetByDocument(ctx context.Context, documentID string) ([]*domain.Chunk, error)

+ func (s *ChunkStore) GetChunkIDs(ctx context.Context, documentID string) ([]string, error)

+ func (s *ChunkStore) GetChunkIDsBySource(ctx context.Context, sourceID string) ([]string, error)

+ func (s *ChunkStore) Save(ctx context.Context, chunk *domain.Chunk) error

+ func (s *ChunkStore) SaveBatch(ctx context.Context, chunks []*domain.Chunk) error

+ type Config struct

+ ConnMaxIdleTime time.Duration

+ ConnMaxLifetime time.Duration

+ MaxIdleConns int

+ MaxOpenConns int

+ URL string

+ func DefaultConfig(url string) Config

+ type ConnectionStore struct

+ func NewConnectionStore(db *sql.DB, encryptor *SecretEncryptor) *ConnectionStore

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

+ func (s *ConnectionStore) Get(ctx context.Context, id string) (*domain.Connection, error)

+ func (s *ConnectionStore) GetByAccountID(ctx context.Context, providerType domain.ProviderType, accountID string) (*domain.Connection, error)

+ func (s *ConnectionStore) GetByProvider(ctx context.Context, providerType domain.ProviderType) ([]*domain.ConnectionSummary, error)

+ func (s *ConnectionStore) List(ctx context.Context) ([]*domain.ConnectionSummary, error)

+ func (s *ConnectionStore) Save(ctx context.Context, conn *domain.Connection) error

+ func (s *ConnectionStore) UpdateLastUsed(ctx context.Context, id string) error

+ func (s *ConnectionStore) UpdateSecrets(ctx context.Context, id string, secrets *domain.ConnectionSecrets, ...) error

+ type DB struct

+ func Connect(ctx context.Context, cfg Config) (*DB, error)

+ func (db *DB) Close() error

+ func (db *DB) InitSchema(ctx context.Context) error

+ func (db *DB) Ping(ctx context.Context) error

+ func (db *DB) Transaction(ctx context.Context, fn func(*sql.Tx) error) error

+ type DocumentStore struct

+ func NewDocumentStore(db *DB) *DocumentStore

+ func (s *DocumentStore) Count(ctx context.Context) (int, error)

+ func (s *DocumentStore) CountBySource(ctx context.Context, sourceID string) (int, error)

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

+ func (s *DocumentStore) DeleteBatch(ctx context.Context, ids []string) error

+ func (s *DocumentStore) DeleteBySource(ctx context.Context, sourceID string) error

+ func (s *DocumentStore) Get(ctx context.Context, id string) (*domain.Document, error)

+ func (s *DocumentStore) GetByExternalID(ctx context.Context, sourceID, externalID string) (*domain.Document, error)

+ func (s *DocumentStore) GetBySource(ctx context.Context, sourceID string, limit, offset int) ([]*domain.Document, error)

+ func (s *DocumentStore) ListExternalIDs(ctx context.Context, sourceID string) ([]string, error)

+ func (s *DocumentStore) Save(ctx context.Context, doc *domain.Document) error

+ func (s *DocumentStore) SaveBatch(ctx context.Context, docs []*domain.Document) error

+ type OAuthStateStore struct

+ func NewOAuthStateStore(db *sql.DB) *OAuthStateStore

+ func NewOAuthStateStoreWithTTL(db *sql.DB, ttl time.Duration) *OAuthStateStore

+ func (s *OAuthStateStore) Cleanup(ctx context.Context) error

+ func (s *OAuthStateStore) GetAndDelete(ctx context.Context, state string) (*driven.OAuthState, error)

+ func (s *OAuthStateStore) Save(ctx context.Context, state *driven.OAuthState) error

+ type SchedulerStore struct

+ func NewSchedulerStore(db *DB) *SchedulerStore

+ func (s *SchedulerStore) DeleteScheduledTask(ctx context.Context, id string) error

+ func (s *SchedulerStore) GetDueScheduledTasks(ctx context.Context) ([]*domain.ScheduledTask, error)

+ func (s *SchedulerStore) GetScheduledTask(ctx context.Context, id string) (*domain.ScheduledTask, error)

+ func (s *SchedulerStore) ListScheduledTasks(ctx context.Context, teamID string) ([]*domain.ScheduledTask, error)

+ func (s *SchedulerStore) SaveScheduledTask(ctx context.Context, task *domain.ScheduledTask) error

+ func (s *SchedulerStore) UpdateLastRun(ctx context.Context, id string, lastError string) error

+ type SearchQueryRepository struct

+ func NewSearchQueryRepository(db *DB) *SearchQueryRepository

+ func (r *SearchQueryRepository) GetSearchAnalytics(ctx context.Context, teamID string, period domain.AnalyticsPeriod) (*domain.SearchAnalytics, error)

+ func (r *SearchQueryRepository) GetSearchHistory(ctx context.Context, teamID string, limit int) ([]*domain.SearchQuery, error)

+ func (r *SearchQueryRepository) GetSearchMetrics(ctx context.Context, teamID string, period domain.AnalyticsPeriod) (*domain.SearchMetrics, error)

+ func (r *SearchQueryRepository) Save(ctx context.Context, query *domain.SearchQuery) error

+ type SecretEncryptor struct

+ func NewSecretEncryptor(key []byte) (*SecretEncryptor, error)

+ func (e *SecretEncryptor) Decrypt(blob []byte, value any) error

+ func (e *SecretEncryptor) DecryptString(blob []byte) (string, error)

+ func (e *SecretEncryptor) Encrypt(value any) ([]byte, error)

+ func (e *SecretEncryptor) EncryptString(s string) ([]byte, error)

+ type SessionStore struct

+ func NewSessionStore(db *DB) *SessionStore

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

+ func (s *SessionStore) DeleteByToken(ctx context.Context, token string) error

+ func (s *SessionStore) DeleteByUser(ctx context.Context, userID string) error

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

+ func (s *SessionStore) GetByRefreshToken(ctx context.Context, refreshToken string) (*domain.Session, error)

+ func (s *SessionStore) GetByToken(ctx context.Context, token string) (*domain.Session, error)

+ func (s *SessionStore) ListByUser(ctx context.Context, userID string) ([]*domain.Session, error)

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

+ type SettingsStore struct

+ func NewSettingsStore(db *DB) *SettingsStore

+ func (s *SettingsStore) GetAISettings(ctx context.Context, teamID string) (*domain.AISettings, error)

+ func (s *SettingsStore) GetSettings(ctx context.Context, teamID string) (*domain.Settings, error)

+ func (s *SettingsStore) SaveAISettings(ctx context.Context, teamID string, settings *domain.AISettings) error

+ func (s *SettingsStore) SaveSettings(ctx context.Context, settings *domain.Settings) error

+ type SourceStore struct

+ func NewSourceStore(db *DB) *SourceStore

+ func (s *SourceStore) CountByConnection(ctx context.Context, connectionID string) (int, error)

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

+ func (s *SourceStore) Get(ctx context.Context, id string) (*domain.Source, error)

+ func (s *SourceStore) GetByName(ctx context.Context, name string) (*domain.Source, error)

+ func (s *SourceStore) List(ctx context.Context) ([]*domain.Source, error)

+ func (s *SourceStore) ListByConnection(ctx context.Context, connectionID string) ([]*domain.Source, error)

+ func (s *SourceStore) ListEnabled(ctx context.Context) ([]*domain.Source, error)

+ func (s *SourceStore) Save(ctx context.Context, source *domain.Source) error

+ func (s *SourceStore) SetEnabled(ctx context.Context, id string, enabled bool) error

+ func (s *SourceStore) UpdateContainers(ctx context.Context, id string, containers []domain.Container) error

+ type SyncStateStore struct

+ func NewSyncStateStore(db *DB) *SyncStateStore

+ func (s *SyncStateStore) Delete(ctx context.Context, sourceID string) error

+ func (s *SyncStateStore) Get(ctx context.Context, sourceID string) (*domain.SyncState, error)

+ func (s *SyncStateStore) List(ctx context.Context) ([]*domain.SyncState, error)

+ func (s *SyncStateStore) Save(ctx context.Context, state *domain.SyncState) error

+ func (s *SyncStateStore) UpdateCursor(ctx context.Context, sourceID string, cursor string) error

+ func (s *SyncStateStore) UpdateStatus(ctx context.Context, sourceID string, status domain.SyncStatus) error

+ type UserStore struct

+ func NewUserStore(db *DB) *UserStore

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

+ func (s *UserStore) Get(ctx context.Context, id string) (*domain.User, error)

+ func (s *UserStore) GetByEmail(ctx context.Context, email string) (*domain.User, error)

+ func (s *UserStore) List(ctx context.Context, teamID string) ([]*domain.User, error)

+ func (s *UserStore) Save(ctx context.Context, user *domain.User) error

+ func (s *UserStore) UpdateLastLogin(ctx context.Context, id string) error

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL