observability

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

type Logger interface {
	// Info logs an info message
	Info(ctx context.Context, message string, fields map[string]interface{})
	// Error logs an error message
	Error(ctx context.Context, message string, err error, fields map[string]interface{})
	// Debug logs a debug message
	Debug(ctx context.Context, message string, fields map[string]interface{})
	// Warn logs a warning message
	Warn(ctx context.Context, message string, fields map[string]interface{})
}

type Metrics interface {
	// RecordQueryLatency records the latency of a query
	//
	// Parameters:
	// - ctx: Context for cancellation
	// - duration: Duration of the query
	RecordQueryLatency(ctx context.Context, duration time.Duration)

	// RecordIndexLatency records the latency of an index operation
	//
	// Parameters:
	// - ctx: Context for cancellation
	// - duration: Duration of the index operation
	RecordIndexLatency(ctx context.Context, duration time.Duration)

	// RecordQueryCount records the number of queries
	//
	// Parameters:
	// - ctx: Context for cancellation
	// - status: Status of the query (e.g., "success", "error")
	RecordQueryCount(ctx context.Context, status string)

	// RecordIndexCount records the number of index operations
	//
	// Parameters:
	// - ctx: Context for cancellation
	// - status: Status of the index operation (e.g., "success", "error")
	RecordIndexCount(ctx context.Context, status string)

	// RecordErrorCount records the number of errors
	//
	// Parameters:
	// - ctx: Context for cancellation
	// - errorType: Type of error
	RecordErrorCount(ctx context.Context, errorType string)

	// RecordIndexedDocuments records the number of indexed documents
	//
	// Parameters:
	// - ctx: Context for cancellation
	// - count: Number of indexed documents
	RecordIndexedDocuments(ctx context.Context, count int)

	// RecordIndexingDocuments records the number of documents being indexed
	//
	// Parameters:
	// - ctx: Context for cancellation
	// - count: Number of documents being indexed
	RecordIndexingDocuments(ctx context.Context, count int)

	// RecordMonitoredDocuments records the number of monitored documents
	//
	// Parameters:
	// - ctx: Context for cancellation
	// - count: Number of monitored documents
	RecordMonitoredDocuments(ctx context.Context, count int)

	// RecordSystemMetrics records system metrics (CPU, memory)
	//
	// Parameters:
	// - ctx: Context for cancellation
	// - cpuUsage: CPU usage percentage
	// - memoryUsage: Memory usage in MB
	RecordSystemMetrics(ctx context.Context, cpuUsage float64, memoryUsage float64)

	// Register registers the metrics with the underlying system
	//
	// Returns:
	// - error: Error if registration fails
	Register() error
}

type NoopSpan struct{}

type NoopTracer struct{}

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

type Span interface {
	// End ends the span
	End()

	// SetAttribute sets an attribute on the span
	//
	// Parameters:
	// - key: Attribute key
	// - value: Attribute value
	SetAttribute(key string, value interface{})

	// SetError sets an error on the span
	//
	// Parameters:
	// - err: Error to set
	SetError(err error)
}

type SpanContext struct {
	TraceID string // Trace ID
	SpanID  string // Span ID
}

type Tracer interface {
	// StartSpan starts a new span
	//
	// Parameters:
	// - ctx: Context for cancellation
	// - name: Name of the span
	//
	// Returns:
	// - context.Context: New context with the span
	// - Span: New span instance
	StartSpan(ctx context.Context, name string) (context.Context, Span)

	// Extract extracts a span from a context
	//
	// Parameters:
	// - ctx: Context containing the span
	//
	// Returns:
	// - Span: Extracted span
	// - bool: True if a span was found
	Extract(ctx context.Context) (Span, bool)
}