middleware

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

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

type BackoffStrategy interface {
	// NextBackoff 获取下一次重试的等待时间
	NextBackoff(attempt int) time.Duration
}

type Builder interface {
	// WithLogging 添加日志中间件
	WithLogging() Builder

	// WithMetrics 添加指标中间件
	WithMetrics() Builder

	// WithRetry 添加重试中间件
	WithRetry(maxAttempts int) Builder

	// WithTimeout 添加超时中间件
	WithTimeout() Builder

	// WithValidation 添加验证中间件
	WithValidation() Builder

	// WithCustom 添加自定义中间件
	WithCustom(middleware Middleware) Builder

	// Build 构建中间件链
	Build() ExecutionChain
}

type ChainError struct {
	MiddlewareName string
	Err            error
}

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

type CircuitState string

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

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

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

type DefaultRetryableChecker struct{}

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

type ExecutionChain interface {
	// Use 添加中间件
	Use(middleware ...Middleware) ExecutionChain

	// Execute 执行中间件链
	// 依次执行所有中间件的 Handle 方法
	Execute(ctx context.Context, execCtx *executor.ExecutionContext) error

	// Remove 移除指定名称的中间件
	Remove(name string) ExecutionChain

	// Clear 清除所有中间件
	Clear() ExecutionChain

	// List 获取所有中间件名称列表
	List() []string

	// HasMiddleware 检查是否存在指定名称的中间件
	HasMiddleware(name string) bool
}

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

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

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

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

type Middleware interface {
	// Name 返回中间件的名称
	Name() string

	// Handle 处理请求
	// 返回下一个中间件处理的 Next 函数
	Handle(ctx context.Context, execCtx *executor.ExecutionContext, next Next) error
}

type Next func(ctx context.Context) error

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

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

type QueryMetrics struct {
	TotalQueries  int64
	TotalErrors   int64
	SuccessCount  int64
	TotalTime     time.Duration
	AverageTime   time.Duration
	MinTime       time.Duration
	MaxTime       time.Duration
	ErrorRate     float64
	QueriesPerSec float64
}

type QueryStatistics struct {
	TotalQueries int64
	SelectCount  int64
	InsertCount  int64
	UpdateCount  int64
	DeleteCount  int64
	OtherCount   int64
	SelectRatio  float64
	InsertRatio  float64
	UpdateRatio  float64
	DeleteRatio  float64
	OtherRatio   float64
}

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

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

type RetryableChecker interface {
	// IsRetryable 检查给定的错误是否应该重试
	IsRetryable(err error) bool
}

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

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

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

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

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

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

type TimeoutStatistics struct {
	TotalExecutions   int64
	TimeoutExceeds    int64
	AverageDuration   time.Duration
	MaxDuration       time.Duration
	MinDuration       time.Duration
	CurrentTimeout    time.Duration
	TimeoutExceedRate float64
}

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

type Validator interface {
	// Validate 验证执行上下文
	Validate(ctx context.Context, execCtx *executor.ExecutionContext) error
}