sqlite

package

Go to main page

Versions in this module

v1

v1.22.3

Feb 26, 2026

v1.22.2

Feb 26, 2026

v1.22.1

Feb 26, 2026

Changes in this version

+ func WithTimeout(ctx context.Context, timeout time.Duration) (context.Context, context.CancelFunc)

v1.22.0

Feb 25, 2026

Changes in this version

type LogEventPolicyCategoryStatuses

+ CountObservedByComplianceCategory func(ctx context.Context) (map[domain.PolicyCategory]int64, error)

v1.21.0

Feb 25, 2026

Changes in this version

type LogEventPolicies

+ Approve func(ctx context.Context, id, userID string) error

+ Dismiss func(ctx context.Context, id, userID string) error

v1.20.0

Feb 25, 2026

v1.19.0

Feb 24, 2026

Changes in this version

type LogEventPolicyCategoryStatuses

+ ListComplianceCategoryStatuses func(ctx context.Context) ([]domain.PolicyCategoryStatus, error)

v1.18.0

Feb 24, 2026

Changes in this version

type DB

+ LogEventPolicyCategoryStatuses func() LogEventPolicyCategoryStatuses

+ LogEventPolicyStatuses func() LogEventPolicyStatuses

+ type LogEventPolicyCategoryStatuses interface

+ ListQualityCategoryStatuses func(ctx context.Context) ([]domain.PolicyCategoryStatus, error)

+ ListWasteCategoryStatuses func(ctx context.Context) ([]domain.PolicyCategoryStatus, error)

+ type LogEventPolicyStatuses interface

+ GetPolicyCard func(ctx context.Context, policyID string) (*domain.PolicyCard, error)

+ ListTopPendingPoliciesByCategory func(ctx context.Context, category domain.PolicyCategory, limit int64) ([]domain.WastePolicy, error)

v1.17.0

Feb 20, 2026

Changes in this version

type DB

+ LogEventStatuses func() LogEventStatuses

+ type LogEventStatuses interface

+ ListByService func(ctx context.Context, serviceName string, limit int64) ([]domain.LogEventStatus, error)

v1.16.0

Feb 19, 2026

Changes in this version

+ type CompliancePolicies interface

+ CountFixed func(ctx context.Context) (int64, error)

+ CountTotal func(ctx context.Context) (int64, error)

+ ListCategorySummaries func(ctx context.Context) ([]domain.ComplianceCategorySummary, error)

+ ListPendingPoliciesByCategory func(ctx context.Context, category string, limit int64) ([]domain.CompliancePolicy, error)

type DB

+ CompliancePolicies func() CompliancePolicies

type LogEventPolicies

+ ListWasteCategoryStatuses func(ctx context.Context) ([]domain.PolicyCategoryStatus, error)

v1.15.0

Feb 13, 2026

Changes in this version

type LogEventPolicies

+ CountFixedPIIPolicies func(ctx context.Context) (int64, error)

+ ListPendingPIIPolicies func(ctx context.Context) ([]domain.PIIPolicy, error)

+ ListTopPendingPoliciesByCategory func(ctx context.Context, category string, limit int64) ([]domain.WastePolicy, error)

type ServiceStatuses

+ ListAllServiceStatuses func(ctx context.Context) ([]domain.ServiceStatus, error)

+ ListEnabledServiceStatuses func(ctx context.Context, limit int64) ([]domain.ServiceStatus, error)

type Services

+ Get func(ctx context.Context, id domain.ServiceID) (gen.Service, error)

+ SetEnabled func(ctx context.Context, id domain.ServiceID, enabled bool) error

v1.14.0

Feb 11, 2026

Changes in this version

type DatadogAccountStatuses

+ GetSummary func(ctx context.Context) (domain.AccountSummary, error)

type Messages

+ Delete func(ctx context.Context, id domain.MessageID) error

v1.13.0

Feb 11, 2026

Changes in this version

type DB

+ ReadRaw func() *sql.DB

v1.12.0

Feb 11, 2026

v1.11.1

Feb 10, 2026

v1.11.0

Feb 10, 2026

v1.10.0

Feb 9, 2026

v1.9.0

Feb 9, 2026

Changes in this version

+ func SetExtensionPath(path string)

+ func WrapSQLiteError(err error, op string) error

+ type Conversations interface

+ Count func(ctx context.Context) (int64, error)

+ Create func(ctx context.Context, accountID, workspaceID string) (string, error)

+ Get func(ctx context.Context, id string) (gen.Conversation, error)

+ List func(ctx context.Context, accountID string) ([]gen.Conversation, error)

+ UpdateTitle func(ctx context.Context, id, title string) error

+ type DB interface

+ Close func() error

+ Conversations func() Conversations

+ DatadogAccountStatuses func() DatadogAccountStatuses

+ Exec func(ctx context.Context, sql string, args ...any) (sql.Result, error)

+ LogEventPolicies func() LogEventPolicies

+ LogEvents func() LogEvents

+ Messages func() Messages

+ PendingUploadCounts func(ctx context.Context) (map[Table]int64, error)

+ Query func(ctx context.Context, sql string, args ...any) (*sql.Rows, error)

+ QueryRow func(ctx context.Context, sql string, args ...any) *sql.Row

+ Raw func() *sql.DB

+ ServiceStatuses func() ServiceStatuses

+ Services func() Services

+ Subscribe func() *Subscription

+ WithTx func(ctx context.Context, fn func(tx *Tx) error) error

+ func Open(ctx context.Context, path string) (DB, error)

+ type DatadogAccountStatuses interface

+ GetCatalogSummary func(ctx context.Context) (domain.CatalogSummary, error)

+ GetPolicySummary func(ctx context.Context) (domain.PolicySummary, error)

+ type LogEventPolicies interface

+ Count func(ctx context.Context) (int64, error)

+ ListCategoryStatuses func(ctx context.Context) ([]domain.PolicyCategoryStatus, error)

+ type LogEvents interface

+ Count func(ctx context.Context) (int64, error)

+ type Messages interface

+ Count func(ctx context.Context) (int64, error)

+ CreateAssistantMessage func(ctx context.Context, accountID domain.AccountID, ...) (domain.MessageID, error)

+ CreateToolResultMessage func(ctx context.Context, accountID domain.AccountID, ...) (domain.MessageID, error)

+ CreateUserMessage func(ctx context.Context, accountID domain.AccountID, ...) (domain.MessageID, error)

+ Get func(ctx context.Context, id domain.MessageID) (*domain.Message, error)

+ List func(ctx context.Context, conversationID domain.ConversationID) ([]domain.Message, error)

+ UpdateContent func(ctx context.Context, id domain.MessageID, content string) error

+ UpdateMeta func(ctx context.Context, id domain.MessageID, model, stopReason string) error

+ type SQLiteError struct

+ Code int

+ ExtendedCode int

+ Message string

+ Op string

+ func (e *SQLiteError) Error() string

+ func (e *SQLiteError) Unwrap() error

+ type ServiceStatuses interface

+ ListServiceStatuses func(ctx context.Context) ([]domain.ServiceStatus, error)

+ type Services interface

+ Count func(ctx context.Context) (int64, error)

+ type Storage interface

+ Clear func() error

+ ClearDatabase func(accountID string) error

+ DatabasePath func(accountID string) (string, error)

+ type StorageService struct

+ func NewStorageService(cfg *config.Config) *StorageService

+ func (s *StorageService) Clear() error

+ func (s *StorageService) ClearDatabase(accountID string) error

+ func (s *StorageService) DatabasePath(accountID string) (string, error)

+ type Subscription struct

+ func (s *Subscription) Changes() <-chan []Table

+ func (s *Subscription) Stop()

+ type Table string

+ const TableConversations

+ const TableLogEventPolicies

+ const TableLogEvents

+ const TableMessages

+ const TableServices

+ type Tx struct

+ func (t *Tx) Commit() error

+ func (t *Tx) Exec(ctx context.Context, query string, args ...any) (sql.Result, error)

+ func (t *Tx) Query(ctx context.Context, query string, args ...any) (*sql.Rows, error)

+ func (t *Tx) QueryRow(ctx context.Context, query string, args ...any) *sql.Row

+ func (t *Tx) Rollback() error

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