store

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

type LogEntry struct {
	ID            int64
	LineNumber    int
	EndLineNumber int
	Timestamp     time.Time
	Raw           string
	Labels        map[string]string
}

type Pattern struct {
	PatternUUIDString string
	PatternType       string
	RawPattern        string
	SemanticID        string
	Description       string
}

type PatternSummary struct {
	PatternUUIDString string
	Pattern           string
	Count             int
	PatternType       string
	SemanticID        string
	Description       string
}

type QueryOpts struct {
	Pattern string
	From    time.Time
	To      time.Time
	Limit   int
}

type Store interface {
	// Init creates tables if they don't exist.
	Init(ctx context.Context) error
	// InsertLog stores a parsed log entry.
	InsertLog(ctx context.Context, entry LogEntry) error
	// InsertLogBatch stores multiple log entries.
	InsertLogBatch(ctx context.Context, entries []LogEntry) error
	// QueryByPattern returns entries matching a pattern semantic ID via labels.
	QueryByPattern(ctx context.Context, pattern string) ([]LogEntry, error)
	// QueryLogs returns entries matching the given options.
	QueryLogs(ctx context.Context, opts QueryOpts) ([]LogEntry, error)
	// PatternSummaries returns all patterns with their counts.
	PatternSummaries(ctx context.Context) ([]PatternSummary, error)
	// InsertPatterns upserts patterns into the patterns table.
	InsertPatterns(ctx context.Context, patterns []Pattern) error
	// Patterns returns all patterns.
	Patterns(ctx context.Context) ([]Pattern, error)
	// PatternCounts returns the number of log entries per pattern_id.
	PatternCounts(ctx context.Context) (map[string]int, error)
	// InternalDB returns the underlying *sql.DB for direct SQL queries.
	// Only use this when no interface method covers the needed operation.
	InternalDB() *sql.DB
	// Close releases resources.
	Close() error
}