postgres

package

Go to main page

Versions in this module

v0

v0.22.2

Apr 13, 2026

v0.22.1

Apr 13, 2026

v0.22.0

Apr 13, 2026

v0.21.0

Apr 13, 2026

Changes in this version

type Store

+ func (s *Store) GetDailyUsage(_ context.Context, _ db.UsageFilter) (db.DailyUsageResult, error)

+ func (s *Store) GetTopSessionsByCost(_ context.Context, _ db.UsageFilter, _ int) ([]db.TopSessionEntry, error)

+ func (s *Store) GetUsageSessionCounts(_ context.Context, _ db.UsageFilter) (db.UsageSessionCounts, error)

v0.20.0

Apr 12, 2026

v0.19.0

Apr 9, 2026

Changes in this version

+ type SyncOptions struct

+ ExcludeProjects []string

+ Projects []string

v0.18.0

Apr 2, 2026

v0.17.1

Mar 29, 2026

v0.17.0

Mar 28, 2026

Changes in this version

type Store

+ func (s *Store) GetSessionActivity(ctx context.Context, sessionID string) (*db.SessionActivityResponse, error)

v0.16.2

Mar 25, 2026

v0.16.1

Mar 25, 2026

v0.16.0

Mar 25, 2026

Changes in this version

+ const LocalSyncTimestampLayout

+ const MaxHeatmapDays

+ func CheckSSL(dsn string) error

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

+ func EnsureSchema(ctx context.Context, db *sql.DB, schema string) error

+ func FormatISO8601(t time.Time) string

+ func FormatSyncTimestamp(t time.Time) string

+ func IsReadOnlyError(err error) bool

+ func NormalizeLocalSyncStateTimestamps(local SyncStateStore) error

+ func NormalizeLocalSyncTimestamp(value string) (string, error)

+ func NormalizeSyncTimestamp(value string) (string, error)

+ func Open(dsn, schema string, allowInsecure bool) (*sql.DB, error)

+ func ParseSQLiteTimestamp(s string) (time.Time, bool)

+ func PreviousLocalSyncTimestamp(value string) (string, error)

+ func RedactDSN(dsn string) string

+ func WarnInsecureSSL(dsn string)

+ type PushResult struct

+ Duration time.Duration

+ Errors int

+ MessagesPushed int

+ SessionsPushed int

+ type Store struct

+ func NewStore(pgURL, schema string, allowInsecure bool) (*Store, error)

+ func (s *Store) BulkStarSessions(_ []string) error

+ func (s *Store) Close() error

+ func (s *Store) DB() *sql.DB

+ func (s *Store) DecodeCursor(raw string) (db.SessionCursor, error)

+ func (s *Store) DeleteInsight(_ int64) error

+ func (s *Store) DeleteSessionIfTrashed(_ string) (int64, error)

+ func (s *Store) EmptyTrash() (int, error)

+ func (s *Store) EncodeCursor(endedAt, id string, total ...int) string

+ func (s *Store) GetAgents(ctx context.Context, excludeOneShot bool) ([]db.AgentInfo, error)

+ func (s *Store) GetAllMessages(ctx context.Context, sessionID string) ([]db.Message, error)

+ func (s *Store) GetAnalyticsActivity(ctx context.Context, f db.AnalyticsFilter, granularity string) (db.ActivityResponse, error)

+ func (s *Store) GetAnalyticsHeatmap(ctx context.Context, f db.AnalyticsFilter, metric string) (db.HeatmapResponse, error)

+ func (s *Store) GetAnalyticsHourOfWeek(ctx context.Context, f db.AnalyticsFilter) (db.HourOfWeekResponse, error)

+ func (s *Store) GetAnalyticsProjects(ctx context.Context, f db.AnalyticsFilter) (db.ProjectsAnalyticsResponse, error)

+ func (s *Store) GetAnalyticsSessionShape(ctx context.Context, f db.AnalyticsFilter) (db.SessionShapeResponse, error)

+ func (s *Store) GetAnalyticsSummary(ctx context.Context, f db.AnalyticsFilter) (db.AnalyticsSummary, error)

+ func (s *Store) GetAnalyticsTools(ctx context.Context, f db.AnalyticsFilter) (db.ToolsAnalyticsResponse, error)

+ func (s *Store) GetAnalyticsTopSessions(ctx context.Context, f db.AnalyticsFilter, metric string) (db.TopSessionsResponse, error)

+ func (s *Store) GetAnalyticsVelocity(ctx context.Context, f db.AnalyticsFilter) (db.VelocityResponse, error)

+ func (s *Store) GetChildSessions(ctx context.Context, parentID string) ([]db.Session, error)

+ func (s *Store) GetInsight(_ context.Context, _ int64) (*db.Insight, error)

+ func (s *Store) GetMachines(ctx context.Context, excludeOneShot bool) ([]string, error)

+ func (s *Store) GetMessages(ctx context.Context, sessionID string, from, limit int, asc bool) ([]db.Message, error)

+ func (s *Store) GetMinimap(ctx context.Context, sessionID string) ([]db.MinimapEntry, error)

+ func (s *Store) GetMinimapFrom(ctx context.Context, sessionID string, from int) ([]db.MinimapEntry, error)

+ func (s *Store) GetProjects(ctx context.Context, excludeOneShot bool) ([]db.ProjectInfo, error)

+ func (s *Store) GetSession(ctx context.Context, id string) (*db.Session, error)

+ func (s *Store) GetSessionFull(ctx context.Context, id string) (*db.Session, error)

+ func (s *Store) GetSessionVersion(id string) (int, int64, bool)

+ func (s *Store) GetStats(ctx context.Context, excludeOneShot bool) (db.Stats, error)

+ func (s *Store) HasFTS() bool

+ func (s *Store) InsertInsight(_ db.Insight) (int64, error)

+ func (s *Store) ListInsights(_ context.Context, _ db.InsightFilter) ([]db.Insight, error)

+ func (s *Store) ListPinnedMessages(_ context.Context, _ string) ([]db.PinnedMessage, error)

+ func (s *Store) ListSessions(ctx context.Context, f db.SessionFilter) (db.SessionPage, error)

+ func (s *Store) ListStarredSessionIDs(_ context.Context) ([]string, error)

+ func (s *Store) ListTrashedSessions(_ context.Context) ([]db.Session, error)

+ func (s *Store) PinMessage(_ string, _ int64, _ *string) (int64, error)

+ func (s *Store) ReadOnly() bool

+ func (s *Store) RenameSession(_ string, _ *string) error

+ func (s *Store) ReplaceSessionMessages(_ string, _ []db.Message) error

+ func (s *Store) RestoreSession(_ string) (int64, error)

+ func (s *Store) Search(ctx context.Context, f db.SearchFilter) (db.SearchPage, error)

+ func (s *Store) SearchSession(ctx context.Context, sessionID, query string) ([]int, error)

+ func (s *Store) SetCursorSecret(secret []byte)

+ func (s *Store) SoftDeleteSession(_ string) error

+ func (s *Store) StarSession(_ string) (bool, error)

+ func (s *Store) UnpinMessage(_ string, _ int64) error

+ func (s *Store) UnstarSession(_ string) error

+ func (s *Store) UpsertSession(_ db.Session) error

+ type Sync struct

+ func New(pgURL, schema string, local *db.DB, machine string, allowInsecure bool) (*Sync, error)

+ func (s *Sync) Close() error

+ func (s *Sync) DB() *sql.DB

+ func (s *Sync) EnsureSchema(ctx context.Context) error

+ func (s *Sync) Push(ctx context.Context, full bool) (PushResult, error)

+ func (s *Sync) Status(ctx context.Context) (SyncStatus, error)

+ type SyncStateStore interface

+ GetSyncState func(key string) (string, error)

+ SetSyncState func(key, value string) error

+ type SyncStatus struct

+ LastPushAt string

+ Machine string

+ PGMessages int

+ PGSessions int

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