database

Documentation

Index

• func CreateContextSnapshotsCollection() *models.Collection
• func CreateMemoryEntriesCollection() *models.Collection
• func CreateRelationshipsCollection() *models.Collection
• func CreateSessionsCollection() *models.Collection
• func CreateTaskProgressCollection() *models.Collection
• type Database
  • func NewDatabase(dbPath string, logger *log.Logger) (*Database, error)
  • func (d *Database) BeginTransaction() (*sql.Tx, error)
  • func (d *Database) Close() error
  • func (d *Database) ExecuteInTransaction(fn func(*sql.Tx) error) error
  • func (d *Database) GetDB() *sql.DB
  • func (d *Database) GetStats() (map[string]interface{}, error)
  • func (d *Database) HealthCheck() error
• type SimplePocketBaseClient
  • func NewSimplePocketBaseClient(dataDir string) (*SimplePocketBaseClient, error)
  • func (c *SimplePocketBaseClient) Bootstrap(ctx context.Context) error
  • func (c *SimplePocketBaseClient) Close() error
  • func (c *SimplePocketBaseClient) GetApp() *pocketbase.PocketBase

Functions

func CreateContextSnapshotsCollection

func CreateContextSnapshotsCollection() *models.Collection

CreateContextSnapshotsCollection creates the context_snapshots collection

func CreateMemoryEntriesCollection

func CreateMemoryEntriesCollection() *models.Collection

CreateMemoryEntriesCollection creates the memory_entries collection

func CreateRelationshipsCollection

func CreateRelationshipsCollection() *models.Collection

CreateRelationshipsCollection creates the relationships collection

func CreateSessionsCollection

func CreateSessionsCollection() *models.Collection

CreateSessionsCollection creates the sessions collection with proper schema

func CreateTaskProgressCollection

func CreateTaskProgressCollection() *models.Collection

CreateTaskProgressCollection creates the task_progress collection

Types

type Database

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

Database represents the SQLite database connection and operations

func NewDatabase

func NewDatabase(dbPath string, logger *log.Logger) (*Database, error)

NewDatabase creates a new database connection and initializes the schema

func (*Database) BeginTransaction

func (d *Database) BeginTransaction() (*sql.Tx, error)

BeginTransaction starts a new transaction

func (*Database) Close

func (d *Database) Close() error

Close closes the database connection

func (*Database) ExecuteInTransaction

func (d *Database) ExecuteInTransaction(fn func(*sql.Tx) error) error

ExecuteInTransaction executes a function within a transaction

func (*Database) GetDB

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

GetDB returns the underlying sql.DB for direct operations

func (*Database) GetStats

func (d *Database) GetStats() (map[string]interface{}, error)

GetStats returns database statistics

func (*Database) HealthCheck

func (d *Database) HealthCheck() error

HealthCheck performs a basic health check on the database

type SimplePocketBaseClient

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

SimplePocketBaseClient wraps PocketBase with minimal configuration

func NewSimplePocketBaseClient

func NewSimplePocketBaseClient(dataDir string) (*SimplePocketBaseClient, error)

NewSimplePocketBaseClient creates a new simple PocketBase client

func (*SimplePocketBaseClient) Bootstrap

func (c *SimplePocketBaseClient) Bootstrap(ctx context.Context) error

Bootstrap initializes the database with required collections

func (*SimplePocketBaseClient) Close

func (c *SimplePocketBaseClient) Close() error

Close gracefully shuts down the PocketBase client

func (*SimplePocketBaseClient) GetApp

func (c *SimplePocketBaseClient) GetApp() *pocketbase.PocketBase

GetApp returns the underlying PocketBase app instance