monitors

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 ErrorsMonitorConfig struct {
	// 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 LoggerWrapper struct {
	// contains filtered or unexported fields
}

type LoggerWriterMonitorConfig struct {
	// Logger is the echo.Logger to wrap with monitoring.
	Logger echo.Logger
	// UsePolling enables polling mode instead of SSE for real-time updates.
	UsePolling bool
}

type LogsMonitorConfig struct {
	// Logger is the original echo.Logger to wrap with monitoring.
	Logger echo.Logger
	// UsePolling enables polling mode instead of SSE for real-time updates.
	UsePolling bool
}

type QueriesMonitorConfig 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 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 RequestsMonitorConfig 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 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"`
}