storage

Documentation

Index

• Constants
• type DB
  • func NewDB(cfg *config.Config) (*DB, error)
  • func (db *DB) ApplyRetentionPolicy(policy RetentionPolicy) (int, error)
  • func (db *DB) Close() error
  • func (db *DB) GetConnection() *sql.DB
  • func (db *DB) GetDatabaseStats(dbPath string) (*DatabaseStats, error)
  • func (db *DB) RunMaintenance() error
• type DatabaseStats
• type RetentionPolicy

Constants

const (
	SchemaVersion = 9
)

Types

type DB

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

DB represents the database connection

func NewDB

func NewDB(cfg *config.Config) (*DB, error)

NewDB creates a new database connection

func (*DB) ApplyRetentionPolicy

func (db *DB) ApplyRetentionPolicy(policy RetentionPolicy) (int, error)

ApplyRetentionPolicy deletes old memories according to the retention policy

func (*DB) Close

func (db *DB) Close() error

Close closes the database connection

func (*DB) GetConnection

func (db *DB) GetConnection() *sql.DB

GetConnection returns the underlying database connection

func (*DB) GetDatabaseStats

func (db *DB) GetDatabaseStats(dbPath string) (*DatabaseStats, error)

GetDatabaseStats returns statistics about the database

func (*DB) RunMaintenance

func (db *DB) RunMaintenance() error

RunMaintenance performs database optimization and cleanup

type DatabaseStats

type DatabaseStats struct {
	FileSizeBytes    int64
	TotalMemories    int
	MemoriesByType   map[string]int
	OldestMemoryTime string
	NewestMemoryTime string
	FragmentationPct float64
}

DatabaseStats holds statistics about the database

type RetentionPolicy

type RetentionPolicy struct {
	MaxAgeDays   int
	MaxCount     int
	ExcludeTypes []string
	DryRun       bool
}

RetentionPolicy defines rules for automatic memory cleanup