middleware

type BlockingRateLimiter interface {
	Wait(ctx context.Context) error
}

type Cache interface {
	Key(req *llmpkg.ChatRequest) string
	Get(key string) (*llmpkg.ChatResponse, bool)
	Set(key string, resp *llmpkg.ChatResponse)
}

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

type EmptyToolsCleaner struct{}

type Handler func(ctx context.Context, req *llmpkg.ChatRequest) (*llmpkg.ChatResponse, error)

type MetricsCollector interface {
	RecordRequest(model string, duration time.Duration, success bool)
	RecordTokens(model string, tokens int)
}

type Middleware func(next Handler) Handler

type PanicError struct {
	Value any
}

type RequestRewriter interface {
	// Rewrite 改写请求
	// 返回改写后的请求和错误（如果改写失败）
	Rewrite(ctx context.Context, req *llmpkg.ChatRequest) (*llmpkg.ChatRequest, error)

	// Name 返回改写器名称（用于日志和调试）
	Name() string
}

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

type Validator interface {
	Validate(req *llmpkg.ChatRequest) error
}