monitors

type ErrorMonitorConfig struct {
	// UsePolling enables polling mode instead of SSE for real-time updates.
	UsePolling bool
}

type ErrorPayload struct {
	Error      string    `json:"error"`
	Type       string    `json:"type"`
	Message    string    `json:"message"`
	StackTrace string    `json:"stackTrace"`
	Timestamp  time.Time `json:"timestamp"`
}

type ErrorRecorder func(err error)

type LogMonitorConfig struct {
	// Logger is the original slog.Logger whose handler will be wrapped.
	// If nil, slog.Default() is used.
	Logger *slog.Logger
	// Skipper defines a function to skip recording a log entry.
	// Optional. Default: never skip.
	// Useful for excluding middleware.RequestLogger entries
	// (messages "REQUEST" / "REQUEST_ERROR"), which belong in RequestMonitor.
	Skipper LogSkipper
	// UsePolling enables polling mode instead of SSE for real-time updates.
	UsePolling bool
}

type LogPayload struct {
	Level     string    `json:"level"`
	Message   string    `json:"message"`
	Timestamp time.Time `json:"timestamp"`
}

type LogSkipper func(r slog.Record) bool

type QueryMonitorConfig struct {
	// DSN is the data source name for the database connection.
	DSN string
	// Driver is the database driver to wrap with monitoring.
	Driver driver.Driver
	// UsePolling enables polling mode instead of SSE for real-time updates.
	UsePolling bool
}

type QueryPayload struct {
	Query     string        `json:"query"`
	Args      []interface{} `json:"args,omitempty"`
	Duration  int64         `json:"duration"` // in milliseconds
	Error     string        `json:"error,omitempty"`
	Timestamp time.Time     `json:"timestamp"`
	Operation string        `json:"operation"` // Query, Exec, Prepare, Begin, Commit, Rollback
}

type RequestMonitorConfig struct {
	// Skipper defines a function to skip middleware.
	// Optional. Default: DefaultSkipper
	Skipper middleware.Skipper
	// UsePolling enables polling mode instead of SSE for real-time updates.
	UsePolling bool
}

type RequestPayload struct {
	Method     string            `json:"method"`
	URI        string            `json:"uri"`
	Status     int               `json:"status"`
	Latency    int64             `json:"latency"` // in milliseconds
	RemoteAddr string            `json:"remoteAddr"`
	UserAgent  string            `json:"userAgent"`
	Error      string            `json:"error,omitempty"`
	Headers    map[string]string `json:"headers,omitempty"`
	Timestamp  time.Time         `json:"timestamp"`
}

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

type WriterMonitorConfig struct {
	// Writer is the original io.Writer to write to.
	Writer io.Writer
	// UsePolling enables polling mode instead of SSE for real-time updates.
	UsePolling bool
}

type WriterPayload struct {
	Data string `json:"data"`
}