Versions in this module Expand all Collapse all v0 v0.2.0 Jun 1, 2026 Changes in this version + func MaskArgs(args []string) string + func MaskEnv() string + type AgentInfo struct + AgentID string + AgentName string + AgentNetwork string + Arch string + Hostname string + NetworkInfo NetInfo + NumCPU int + OS string + PID int + StartedAt time.Time + StartupArgs string + StartupEnv string + UpdatedAt time.Time + Version string + type InterfaceInfo struct + Addrs []string + Name string + type LogEntry struct + ID int64 + Line string + Timestamp time.Time + type LogFilter struct + Limit int + Offset int + Since time.Time + Until time.Time + type LogWriter struct + func NewLogWriter(store *SQLiteStore) *LogWriter + func (w *LogWriter) Run() + func (w *LogWriter) Stop() + func (w *LogWriter) Write(entry LogEntry) + type MetricSample struct + ActiveWorkers int32 + CPUPercent float64 + ChunkParallelism int + FDLimit int + FDUsed int + Goroutines int + HeapAllocMB uint64 + HeapSysMB uint64 + ID int64 + MemAvailMB uint64 + MemTotalMB uint64 + RSSMB uint64 + Timestamp time.Time + type NetInfo struct + DNSResolvers []string + Gateway string + Interfaces []InterfaceInfo + NetworkType string + PrivateIPs []string + PublicIPs []string + func DetectNetInfo() NetInfo + type SQLiteStore struct + func Open(dbPath string) (*SQLiteStore, error) + func (s *SQLiteStore) ActiveTasks(ctx context.Context) ([]Task, error) + func (s *SQLiteStore) CheckpointWAL() error + func (s *SQLiteStore) Close() error + func (s *SQLiteStore) DBPath() string + func (s *SQLiteStore) DBSizeBytes() (int64, error) + func (s *SQLiteStore) FinishTask(ctx context.Context, taskID, status string) error + func (s *SQLiteStore) GetAgentInfo(ctx context.Context) (*AgentInfo, error) + func (s *SQLiteStore) InsertLog(ctx context.Context, entry *LogEntry) error + func (s *SQLiteStore) InsertMetric(ctx context.Context, sample *MetricSample) error + func (s *SQLiteStore) InsertTask(ctx context.Context, task *Task) error + func (s *SQLiteStore) QueryLogs(ctx context.Context, filter LogFilter) ([]LogEntry, error) + func (s *SQLiteStore) QueryMetrics(ctx context.Context, since, until time.Time, limit int) ([]MetricSample, error) + func (s *SQLiteStore) RecentTasks(ctx context.Context, limit int) ([]Task, error) + func (s *SQLiteStore) UpsertAgentInfo(ctx context.Context, info *AgentInfo) error + type SizeCaps struct + LogCapBytes int64 + MetricCapBytes int64 + func LoadSizeCaps() (SizeCaps, error) + type Store interface + ActiveTasks func(ctx context.Context) ([]Task, error) + Close func() error + DBSizeBytes func() (int64, error) + FinishTask func(ctx context.Context, taskID, status string) error + GetAgentInfo func(ctx context.Context) (*AgentInfo, error) + InsertLog func(ctx context.Context, entry *LogEntry) error + InsertMetric func(ctx context.Context, sample *MetricSample) error + InsertTask func(ctx context.Context, task *Task) error + QueryLogs func(ctx context.Context, filter LogFilter) ([]LogEntry, error) + QueryMetrics func(ctx context.Context, since, until time.Time, limit int) ([]MetricSample, error) + RecentTasks func(ctx context.Context, limit int) ([]Task, error) + UpsertAgentInfo func(ctx context.Context, info *AgentInfo) error + type Task struct + FinishedAt time.Time + ID int64 + StartedAt time.Time + Status string + TaskID string + Type string + type Truncator struct + func NewTruncator(store *SQLiteStore, logCapBytes, metCapBytes int64) *Truncator + func (t *Truncator) Run(ctx context.Context)
Go to main page