observability

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

type EMFMetricSinkOption func(*EMFMetricSink)

type ErrorNotifier interface {
	Notify(ctx context.Context, entry LogEntry) error
}

type LogEntry struct {
	Timestamp time.Time      `json:"timestamp"`
	Level     string         `json:"level"`
	Message   string         `json:"message"`
	Fields    map[string]any `json:"fields,omitempty"`

	RequestID string `json:"request_id,omitempty"`
	TenantID  string `json:"tenant_id,omitempty"`
	UserID    string `json:"user_id,omitempty"`
	TraceID   string `json:"trace_id,omitempty"`
	SpanID    string `json:"span_id,omitempty"`
}

type LoggerConfig struct {
	Format     string        `json:"format"`
	Level      string        `json:"level"`
	RetryDelay time.Duration `json:"retry_delay"`
	BatchSize  int           `json:"batch_size"`
	// BufferSize is accepted for compatibility and has no effect on the zap
	// logger: error notifications are delivered synchronously inside the call
	// that logs, so there is no notification queue to size.
	BufferSize         int                  `json:"buffer_size"`
	MaxRetries         int                  `json:"max_retries"`
	EnableStack        bool                 `json:"enable_stack"`
	EnableCaller       bool                 `json:"enable_caller"`
	SanitizationPolicy *sanitization.Policy `json:"sanitization,omitempty"`
}

type LoggerFactory interface {
	CreateConsoleLogger(config LoggerConfig) (StructuredLogger, error)
	CreateTestLogger() StructuredLogger
	CreateNoOpLogger() StructuredLogger
}

type LoggerStats struct {
	LastFlush      time.Time     `json:"last_flush"`
	LastError      string        `json:"last_error,omitempty"`
	EntriesLogged  int64         `json:"entries_logged"`
	EntriesDropped int64         `json:"entries_dropped"`
	FlushCount     int64         `json:"flush_count"`
	ErrorCount     int64         `json:"error_count"`
	AverageFlush   time.Duration `json:"average_flush_time"`
}

type LoggingProfileAlertingHints struct {
	FingerprintFields  []string `json:"fingerprint_fields,omitempty" yaml:"fingerprint_fields,omitempty"`
	KeeperLookupFields []string `json:"keeper_lookup_fields,omitempty" yaml:"keeper_lookup_fields,omitempty"`
}

type LoggingProfileConfig struct {
	SchemaVersion     string                      `json:"schema_version" yaml:"schema_version"`
	Profile           string                      `json:"profile" yaml:"profile"`
	Encoding          LoggingProfileEncoding      `json:"encoding" yaml:"encoding"`
	Levels            map[string]string           `json:"levels,omitempty" yaml:"levels,omitempty"`
	RequiredFields    []string                    `json:"required_fields,omitempty" yaml:"required_fields,omitempty"`
	RecommendedFields []string                    `json:"recommended_fields,omitempty" yaml:"recommended_fields,omitempty"`
	FieldMap          map[string]string           `json:"field_map,omitempty" yaml:"field_map,omitempty"`
	Enrichment        LoggingProfileEnrichment    `json:"enrichment,omitempty" yaml:"enrichment,omitempty"`
	ErrorCapture      LoggingProfileErrorCapture  `json:"error_capture,omitempty" yaml:"error_capture,omitempty"`
	Sanitization      LoggingProfileSanitization  `json:"sanitization,omitempty" yaml:"sanitization,omitempty"`
	AlertingHints     LoggingProfileAlertingHints `json:"alerting_hints,omitempty" yaml:"alerting_hints,omitempty"`
}

type LoggingProfileEncoding struct {
	Format          string `json:"format" yaml:"format"`
	TimestampField  string `json:"timestamp_field,omitempty" yaml:"timestamp_field,omitempty"`
	TimestampFormat string `json:"timestamp_format,omitempty" yaml:"timestamp_format,omitempty"`
	LevelField      string `json:"level_field,omitempty" yaml:"level_field,omitempty"`
	MessageField    string `json:"message_field,omitempty" yaml:"message_field,omitempty"`
}

type LoggingProfileEnrichment struct {
	Static  map[string]string `json:"static,omitempty" yaml:"static,omitempty"`
	Context map[string]string `json:"context,omitempty" yaml:"context,omitempty"`
}

type LoggingProfileError struct {
	Type       string `json:"type,omitempty"`
	Code       string `json:"code,omitempty"`
	Message    string `json:"message,omitempty"`
	StackTrace string `json:"stack_trace,omitempty"`
}

type LoggingProfileErrorCapture struct {
	IncludeErrorType   bool   `json:"include_error_type" yaml:"include_error_type"`
	IncludeErrorCode   bool   `json:"include_error_code" yaml:"include_error_code"`
	IncludeStackTrace  bool   `json:"include_stack_trace" yaml:"include_stack_trace"`
	StackTraceField    string `json:"stack_trace_field,omitempty" yaml:"stack_trace_field,omitempty"`
	StackHashField     string `json:"stack_hash_field,omitempty" yaml:"stack_hash_field,omitempty"`
	StackHashAlgorithm string `json:"stack_hash_algorithm,omitempty" yaml:"stack_hash_algorithm,omitempty"`
}

type LoggingProfileEvent struct {
	Timestamp         time.Time                    `json:"timestamp"`
	Level             string                       `json:"level"`
	Event             string                       `json:"event,omitempty"`
	Message           string                       `json:"message"`
	NormalizedMessage string                       `json:"normalized_message,omitempty"`
	Request           LoggingProfileRequestContext `json:"request,omitempty"`
	Job               LoggingProfileJobContext     `json:"job,omitempty"`
	Error             LoggingProfileError          `json:"error,omitempty"`
	Fields            map[string]any               `json:"fields,omitempty"`
}

type LoggingProfileJobContext struct {
	Name string `json:"name,omitempty"`
}

type LoggingProfileRequestContext struct {
	RequestID     string `json:"request_id,omitempty"`
	TenantID      string `json:"tenant_id,omitempty"`
	UserID        string `json:"user_id,omitempty"`
	TraceID       string `json:"trace_id,omitempty"`
	SpanID        string `json:"span_id,omitempty"`
	CorrelationID string `json:"correlation_id,omitempty"`
	Route         string `json:"route,omitempty"`
	Method        string `json:"method,omitempty"`
	Path          string `json:"path,omitempty"`
	Status        int    `json:"status,omitempty"`
}

type LoggingProfileSanitization struct {
	ExistingSanitizedLogging bool   `json:"existing_sanitized_logging" yaml:"existing_sanitized_logging"`
	Notes                    string `json:"notes,omitempty" yaml:"notes,omitempty"`
}

type LoggingProfileValidationError struct {
	Errors []string
}

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

type ProfileLoggerOption func(*profileLoggerOptions)

type SanitizerFunc func(key string, value any) any

type StructuredLogger interface {
	Debug(message string, fields ...map[string]any)
	Info(message string, fields ...map[string]any)
	Warn(message string, fields ...map[string]any)
	Error(message string, fields ...map[string]any)

	WithField(key string, value any) StructuredLogger
	WithFields(fields map[string]any) StructuredLogger

	WithRequestID(requestID string) StructuredLogger
	WithTenantID(tenantID string) StructuredLogger
	WithUserID(userID string) StructuredLogger
	WithTraceID(traceID string) StructuredLogger
	WithSpanID(spanID string) StructuredLogger

	Flush(ctx context.Context) error
	Close() error
	IsHealthy() bool
	GetStats() LoggerStats
}

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