storage

Documentation

Index

• type ActionLog
• type DB
  • func Open(path string) (*DB, error)
  • func (db *DB) Close() error
  • func (db *DB) Conn() *sql.DB
  • func (db *DB) Insert(log ActionLog) error
  • func (db *DB) Purge(retentionDays int) (int64, error)
  • func (db *DB) QueryLogs(opts QueryOptions) ([]ActionLog, error)
  • func (db *DB) SchemaVersion() (int, error)
• type QueryOptions

Types

type ActionLog

type ActionLog struct {
	Timestamp   time.Time
	AgentIDHash string
	Method      string
	Direction   string
	Success     bool
	LatencyMs   float64
	PayloadSize int
	AuthStatus  string
	ErrorCode   string
	IPAddress   string
}

ActionLog represents a single intercepted message log entry.

type DB

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

DB wraps a SQLite connection.

func Open

func Open(path string) (*DB, error)

Open opens (or creates) a SQLite database at path, enables WAL mode, and runs migrations.

func (*DB) Close

func (db *DB) Close() error

Close closes the underlying database connection.

func (*DB) Conn

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

Conn returns the underlying *sql.DB connection.

func (*DB) Insert

func (db *DB) Insert(log ActionLog) error

Insert stores a single ActionLog entry.

func (*DB) Purge

func (db *DB) Purge(retentionDays int) (int64, error)

Purge deletes log entries older than retentionDays days. Returns the number of rows deleted.

func (*DB) QueryLogs

func (db *DB) QueryLogs(opts QueryOptions) ([]ActionLog, error)

QueryLogs returns log entries matching opts, ordered newest-first.

func (*DB) SchemaVersion

func (db *DB) SchemaVersion() (int, error)

SchemaVersion returns the current schema version (for diagnostics).

type QueryOptions

type QueryOptions struct {
	Last      int
	AgentHash string
	Since     time.Duration
	Method    string
}

QueryOptions controls which log entries are returned by QueryLogs.