daemon

package
v0.11.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Nov 22, 2025 License: MIT Imports: 28 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func CalculatePriority 

func CalculatePriority(info os.FileInfo) int

CalculatePriority calculates job priority based on file modification time More recently modified files get higher priority

func DetectServiceManager 

func DetectServiceManager() string

DetectServiceManager returns the appropriate service manager for the platform

func GetAlreadyRunningHelp 

func GetAlreadyRunningHelp() string

GetAlreadyRunningHelp returns platform-specific help for "already running" errors

func GetNotRunningHelp 

func GetNotRunningHelp() string

GetNotRunningHelp returns platform-specific help for "not running" errors

func GetServiceManagerHint 

func GetServiceManagerHint(sm string) string

GetServiceManagerHint returns helpful hint for managing daemon as service

func GetSignalErrorHelp 

func GetSignalErrorHelp(pid int) string

GetSignalErrorHelp returns platform-specific help for signal errors

func IsServiceManaged 

func IsServiceManaged() bool

IsServiceManaged attempts to detect if daemon is running under service manager

func StartHealthCheckServer 

func StartHealthCheckServer(port int, metrics *HealthMetrics) error

StartHealthCheckServer starts an HTTP server for health checks

Types

type Daemon 

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

Daemon manages background index computation

func New 

func New(cfg *config.Config, logger *slog.Logger, logWriter *lumberjack.Logger) (*Daemon, error)

New creates a new daemon instance

func (*Daemon) GetConfig 

func (d *Daemon) GetConfig() *config.Config

GetConfig returns the current configuration (thread-safe)

func (*Daemon) GetLogger 

func (d *Daemon) GetLogger() *slog.Logger

GetLogger returns the current logger (thread-safe)

func (*Daemon) GetSemanticAnalyzer 

func (d *Daemon) GetSemanticAnalyzer() *semantic.Analyzer

GetSemanticAnalyzer returns the current semantic analyzer (lock-free)

func (*Daemon) Rebuild 

func (d *Daemon) Rebuild() error

Rebuild forces an immediate index rebuild

func (*Daemon) ReloadConfig 

func (d *Daemon) ReloadConfig() error

ReloadConfig reloads configuration and applies changes

func (*Daemon) SetConfig 

func (d *Daemon) SetConfig(cfg *config.Config)

SetConfig sets the configuration atomically (thread-safe)

func (*Daemon) SetLogger 

func (d *Daemon) SetLogger(l *slog.Logger)

SetLogger sets the logger atomically (thread-safe)

func (*Daemon) SetSemanticAnalyzer 

func (d *Daemon) SetSemanticAnalyzer(a *semantic.Analyzer)

SetSemanticAnalyzer sets the semantic analyzer atomically (lock-free)

func (*Daemon) Start 

func (d *Daemon) Start() error

Start starts the daemon

func (*Daemon) Stop 

func (d *Daemon) Stop()

Stop stops the daemon

type HealthCheckHandler 

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

HealthCheckHandler provides an HTTP health check endpoint

func NewHealthCheckHandler 

func NewHealthCheckHandler(metrics *HealthMetrics) *HealthCheckHandler

NewHealthCheckHandler creates a new health check HTTP handler

func (*HealthCheckHandler) ServeHTTP 

func (h *HealthCheckHandler) ServeHTTP(w http.ResponseWriter, r *http.Request)

ServeHTTP handles health check requests

type HealthMetrics 

type HealthMetrics struct {
	StartTime        time.Time `json:"start_time"`
	Uptime           string    `json:"uptime"`
	UptimeSeconds    int64     `json:"uptime_seconds"`
	FilesProcessed   int       `json:"files_processed"`
	APICalls         int       `json:"api_calls"`
	CacheHits        int       `json:"cache_hits"`
	Errors           int       `json:"errors"`
	LastBuildTime    time.Time `json:"last_build_time"`
	LastBuildSuccess bool      `json:"last_build_success"`
	IndexFileCount   int       `json:"index_file_count"`
	WatcherActive    bool      `json:"watcher_active"`
	// contains filtered or unexported fields
}

HealthMetrics tracks daemon health statistics

func NewHealthMetrics 

func NewHealthMetrics() *HealthMetrics

NewHealthMetrics creates a new health metrics tracker

func (*HealthMetrics) GetSnapshot 

func (h *HealthMetrics) GetSnapshot() HealthSnapshot

GetSnapshot returns a snapshot of current metrics

func (*HealthMetrics) RecordBuild 

func (h *HealthMetrics) RecordBuild(filesProcessed, apiCalls, cacheHits, errors int, success bool)

RecordBuild records a build attempt

func (*HealthMetrics) RecordError 

func (h *HealthMetrics) RecordError()

RecordError increments the error counter

func (*HealthMetrics) SetIndexFileCount 

func (h *HealthMetrics) SetIndexFileCount(count int)

SetIndexFileCount updates the current index file count

func (*HealthMetrics) SetWatcherActive 

func (h *HealthMetrics) SetWatcherActive(active bool)

SetWatcherActive sets the watcher active status

type HealthSnapshot 

type HealthSnapshot struct {
	StartTime        time.Time `json:"start_time"`
	Uptime           string    `json:"uptime"`
	UptimeSeconds    int64     `json:"uptime_seconds"`
	FilesProcessed   int       `json:"files_processed"`
	APICalls         int       `json:"api_calls"`
	CacheHits        int       `json:"cache_hits"`
	Errors           int       `json:"errors"`
	LastBuildTime    time.Time `json:"last_build_time"`
	LastBuildSuccess bool      `json:"last_build_success"`
	IndexFileCount   int       `json:"index_file_count"`
	WatcherActive    bool      `json:"watcher_active"`
}

HealthSnapshot represents a point-in-time snapshot of health metrics without the mutex, safe for copying and serialization

type Job 

type Job struct {
	Path     string
	Info     os.FileInfo
	Priority int // Higher priority = process first
}

Job represents a file processing job

type JobResult 

type JobResult struct {
	Entry types.IndexEntry
	Error error
}

JobResult represents the result of processing a job

type PoolStats 

type PoolStats struct {
	JobsProcessed int
	JobsQueued    int
	CacheHits     int
	APICalls      int
	Errors        int
}

PoolStats tracks worker pool statistics

type WorkerPool 

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

WorkerPool manages parallel file processing with rate limiting

func NewWorkerPool 

func NewWorkerPool(
	workers int,
	rateLimitPerMin int,
	metadataExtractor *metadata.Extractor,
	semanticAnalyzer *semantic.Analyzer,
	cacheManager *cache.Manager,
	logger *slog.Logger,
	ctx context.Context,
) *WorkerPool

NewWorkerPool creates a new worker pool

func (*WorkerPool) GetStats 

func (wp *WorkerPool) GetStats() PoolStats

GetStats returns current pool statistics

func (*WorkerPool) Results 

func (wp *WorkerPool) Results() <-chan JobResult

Results returns the result channel

func (*WorkerPool) Start 

func (wp *WorkerPool) Start()

Start starts the worker pool

func (*WorkerPool) Stop 

func (wp *WorkerPool) Stop()

Stop stops the worker pool gracefully

func (*WorkerPool) Submit 

func (wp *WorkerPool) Submit(job Job)

Submit submits a job to the pool

func (*WorkerPool) SubmitBatch 

func (wp *WorkerPool) SubmitBatch(jobs []Job)

SubmitBatch submits multiple jobs, sorted by priority

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.