Documentation
¶
Overview ¶
Package observability provides metrics and quality evaluation for the Cortex memory system.
This package implements observability features similar to Mem0, including performance metrics, memory quality evaluation, and continuous monitoring of the memory system.
Index ¶
- type ObservabilityService
- func (s *ObservabilityService) EvaluateMemoryQuality(ctx context.Context, sessionID string, evalType string) (*domain.QualityMetrics, error)
- func (s *ObservabilityService) GetHealthCheck(ctx context.Context) (*domain.HealthCheck, error)
- func (s *ObservabilityService) GetSystemMetrics(ctx context.Context, sessionID string, from, to time.Time) (*domain.SystemMetrics, error)
- func (s *ObservabilityService) RecordOperation(ctx context.Context, operation *domain.Metrics) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ObservabilityService ¶
type ObservabilityService struct {
// contains filtered or unexported fields
}
ObservabilityService manages metrics collection and quality evaluation.
func NewObservabilityService ¶
func NewObservabilityService( metricsRepo domain.MetricsRepository, qualityRepo domain.QualityMetricsRepository, temporalRepo domain.TemporalSnapshotRepository, graphRepo domain.GraphRepository, observationRepo domain.ObservationRepository, ) *ObservabilityService
NewObservabilityService creates a new observability service.
func (*ObservabilityService) EvaluateMemoryQuality ¶
func (s *ObservabilityService) EvaluateMemoryQuality(ctx context.Context, sessionID string, evalType string) (*domain.QualityMetrics, error)
EvaluateMemoryQuality evaluates the quality of the memory system.
func (*ObservabilityService) GetHealthCheck ¶
func (s *ObservabilityService) GetHealthCheck(ctx context.Context) (*domain.HealthCheck, error)
GetHealthCheck provides system health status.
func (*ObservabilityService) GetSystemMetrics ¶
func (s *ObservabilityService) GetSystemMetrics(ctx context.Context, sessionID string, from, to time.Time) (*domain.SystemMetrics, error)
GetSystemMetrics retrieves system-wide performance metrics.
func (*ObservabilityService) RecordOperation ¶
func (s *ObservabilityService) RecordOperation(ctx context.Context, operation *domain.Metrics) error
RecordOperation records an operation with performance metrics.