middleware

type CircuitBreakerConfig struct {
	// FailureThreshold is the number of consecutive failures that will open the circuit
	FailureThreshold int
	// ResetTimeout is the time to wait before trying again after the circuit is opened
	ResetTimeout time.Duration
	// HalfOpenSuccessThreshold is the number of consecutive successes that will close the circuit
	HalfOpenSuccessThreshold int
}

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

type CircuitBreakerState int

type LogEntry struct {
	// Timestamp is the timestamp of the log entry
	Timestamp time.Time `json:"timestamp"`
	// Level is the log level
	Level LogLevel `json:"level"`
	// ProviderType is the type of provider
	ProviderType core.ProviderType `json:"provider_type"`
	// Operation is the operation being performed
	Operation string `json:"operation"`
	// RequestID is the ID of the request
	RequestID string `json:"request_id"`
	// Request is the request data
	Request interface{} `json:"request,omitempty"`
	// Response is the response data
	Response interface{} `json:"response,omitempty"`
	// Error is the error message
	Error string `json:"error,omitempty"`
	// Duration is the duration of the operation
	Duration time.Duration `json:"duration,omitempty"`
	// AdditionalInfo is additional information
	AdditionalInfo map[string]interface{} `json:"additional_info,omitempty"`
}

type LogHandler func(entry *LogEntry)

type LogLevel int

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

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

type QueuedRequest struct {
	// Priority is the priority of the request (lower is higher priority)
	Priority int
	// EnqueueTime is the time the request was enqueued
	EnqueueTime time.Time
	// Context is the context of the request
	Context context.Context
	// Function is the function to execute
	Function func(ctx context.Context) (interface{}, error)
	// ResultChan is the channel to send the result to
	ResultChan chan *QueuedResult
}

type QueuedResult struct {
	// Result is the result of the request
	Result interface{}
	// Error is the error from the request
	Error error
}

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

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

type RequestQueueConfig struct {
	// MaxQueueSize is the maximum number of requests that can be queued
	MaxQueueSize int
	// MaxWaitTime is the maximum time a request can wait in the queue
	MaxWaitTime time.Duration
	// PriorityLevels is the number of priority levels
	PriorityLevels int
}

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

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

type UsageMetrics struct {
	// Requests is the number of requests made
	Requests int64
	// Tokens is the number of tokens used
	Tokens int64
	// Errors is the number of errors encountered
	Errors int64
	// LastRequestTime is the time of the last request
	LastRequestTime time.Time
	// TotalRequestDuration is the total duration of all requests
	TotalRequestDuration time.Duration
}

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