clients

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

type CircuitBreaker = HTTPCircuitBreaker

type CircuitBreakerConfig struct {
	FailureThreshold int           // Number of failures before opening
	SuccessThreshold int           // Number of successes before closing
	Timeout          time.Duration // Timeout before retrying
}

type CircuitBreakerState struct {
	State                string    `json:"state"`
	LastStateChange      time.Time `json:"last_state_change"`
	ConsecutiveFailures  int32     `json:"consecutive_failures"`
	ConsecutiveSuccesses int32     `json:"consecutive_successes"`
	TotalRequests        int64     `json:"total_requests"`
	FailedRequests       int64     `json:"failed_requests"`
	FailureRate          float64   `json:"failure_rate"`
	NextRetryTime        time.Time `json:"next_retry_time,omitempty"`
}

type CircuitState int32

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

type ConnectionPoolStats struct {
	ActiveConnections int64         `json:"active_connections"`
	IdleConnections   int64         `json:"idle_connections"`
	TotalConnections  int64         `json:"total_connections"`
	TotalCreated      int64         `json:"total_created"`
	TotalReused       int64         `json:"total_reused"`
	ReuseRate         float64       `json:"reuse_rate"`
	AverageUseCount   float64       `json:"average_use_count"`
	OldestConnection  time.Duration `json:"oldest_connection_age"`
}

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

type EndpointMetrics struct {
	Host           string        `json:"host"`
	Method         string        `json:"method"`
	RequestCount   int64         `json:"request_count"`
	AverageLatency time.Duration `json:"average_latency"`
	MinLatency     time.Duration `json:"min_latency"`
	MaxLatency     time.Duration `json:"max_latency"`
}

type HTTP2Stats struct {
	Connections    int64   `json:"connections"`
	TotalStreams   int64   `json:"total_streams"`
	StreamsPerConn float64 `json:"streams_per_conn"`
}

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

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

type HTTPConfig struct {
	// Connection settings
	MaxIdleConns        int           `json:"max_idle_conns"`
	MaxIdleConnsPerHost int           `json:"max_idle_conns_per_host"`
	MaxConnsPerHost     int           `json:"max_conns_per_host"`
	IdleConnTimeout     time.Duration `json:"idle_conn_timeout"`
	DisableKeepAlives   bool          `json:"disable_keep_alives"`
	DisableCompression  bool          `json:"disable_compression"`

	// HTTP/2 settings
	EnableHTTP2          bool `json:"enable_http2"`
	MaxConcurrentStreams int  `json:"max_concurrent_streams"`

	// Timeouts
	DialTimeout           time.Duration `json:"dial_timeout"`
	TLSHandshakeTimeout   time.Duration `json:"tls_handshake_timeout"`
	ResponseHeaderTimeout time.Duration `json:"response_header_timeout"`
	RequestTimeout        time.Duration `json:"request_timeout"`
	KeepAlive             time.Duration `json:"keep_alive"`

	// TLS settings
	InsecureSkipVerify bool   `json:"insecure_skip_verify"`
	TLSMinVersion      uint16 `json:"tls_min_version"`

	// Performance settings
	EnableConnectionReuse bool `json:"enable_connection_reuse"`
	EnableRequestPooling  bool `json:"enable_request_pooling"`
	RequestPoolSize       int  `json:"request_pool_size"`

	// Rate limiting
	RateLimit float64 `json:"rate_limit"`
	RateBurst int     `json:"rate_burst"`

	// Circuit breaker
	CircuitBreakerEnabled bool          `json:"circuit_breaker_enabled"`
	FailureThreshold      int           `json:"failure_threshold"`
	SuccessThreshold      int           `json:"success_threshold"`
	Timeout               time.Duration `json:"timeout"`
}

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

type HTTPStats struct {
	ActiveConnections int64         `json:"active_connections"`
	IdleConnections   int64         `json:"idle_connections"`
	TotalConnections  int64         `json:"total_connections"`
	TotalRequests     int64         `json:"total_requests"`
	FailedRequests    int64         `json:"failed_requests"`
	SuccessRate       float64       `json:"success_rate"`
	ConnectionReuse   float64       `json:"connection_reuse_rate"`
	AverageLatency    time.Duration `json:"average_latency"`
	P95Latency        time.Duration `json:"p95_latency"`
	P99Latency        time.Duration `json:"p99_latency"`
}

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

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

type OAuth2Config struct {
	// Client credentials
	ClientID     string `json:"client_id"`
	ClientSecret string `json:"client_secret"`
	RedirectURL  string `json:"redirect_url,omitempty"`

	// Token endpoints
	AuthURL    string `json:"auth_url"`
	TokenURL   string `json:"token_url"`
	RefreshURL string `json:"refresh_url,omitempty"`

	// Scopes
	Scopes []string `json:"scopes"`

	// Grant type
	GrantType string `json:"grant_type"` // authorization_code, client_credentials, refresh_token

	// Token settings
	AutoRefresh      bool          `json:"auto_refresh"`
	RefreshThreshold time.Duration `json:"refresh_threshold"`
	MaxRetries       int           `json:"max_retries"`
	RetryDelay       time.Duration `json:"retry_delay"`

	// Advanced settings
	UseBasicAuth  bool              `json:"use_basic_auth"`
	CustomHeaders map[string]string `json:"custom_headers,omitempty"`
	CustomParams  map[string]string `json:"custom_params,omitempty"`
}

type OAuth2Error struct {
	ErrorCode        string `json:"error"`
	ErrorDescription string `json:"error_description,omitempty"`
	ErrorURI         string `json:"error_uri,omitempty"`
}

type OAuth2Stats struct {
	TokenRequests     int64 `json:"token_requests"`
	TokenRefreshes    int64 `json:"token_refreshes"`
	AuthFailures      int64 `json:"auth_failures"`
	CurrentTokenValid bool  `json:"current_token_valid"`
}

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

type PooledRequest struct {
	Method  string
	URL     string
	Headers http.Header
	Body    io.Reader
}

type PooledResponse struct {
	StatusCode int
	Headers    http.Header

	Body io.ReadCloser
	// contains filtered or unexported fields
}

type RateLimiter interface {
	// Allow checks if a request is allowed
	Allow() bool

	// Wait blocks until a request is allowed
	Wait(ctx context.Context) error

	// Reserve reserves a future request
	Reserve() Reservation

	// SetRate updates the rate limit
	SetRate(rate float64)

	// SetBurst updates the burst size
	SetBurst(burst int)

	// GetStats returns rate limiter statistics
	GetStats() RateLimiterStats
}

type RateLimiterCoordinator interface {
	// RegisterNode registers a node in the cluster
	RegisterNode(nodeID string) error

	// GetNodeCount returns the current number of nodes
	GetNodeCount() (int, error)

	// ReportUsage reports usage statistics
	ReportUsage(nodeID string, used int64, timestamp time.Time) error

	// GetGlobalUsage returns global usage statistics
	GetGlobalUsage() (int64, error)
}

type RateLimiterStats struct {
	Rate            float64       `json:"rate"`
	Burst           int           `json:"burst"`
	AllowedRequests int64         `json:"allowed_requests"`
	BlockedRequests int64         `json:"blocked_requests"`
	CurrentTokens   float64       `json:"current_tokens"`
	LastRefill      time.Time     `json:"last_refill"`
	AverageWaitTime time.Duration `json:"average_wait_time"`
}

type Reservation interface {
	// OK returns whether the reservation is valid
	OK() bool

	// Delay returns the delay before the request can proceed
	Delay() time.Duration

	// Cancel cancels the reservation
	Cancel()
}

type ResponseTimeStats struct {
	Count       int           `json:"count"`
	ErrorRate   float64       `json:"error_rate"`
	P95Latency  time.Duration `json:"p95_latency"`
	P99Latency  time.Duration `json:"p99_latency"`
	MeanLatency time.Duration `json:"mean_latency"`
}

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

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

type Token struct {
	AccessToken  string    `json:"access_token"`
	TokenType    string    `json:"token_type"`
	RefreshToken string    `json:"refresh_token,omitempty"`
	ExpiresAt    time.Time `json:"expires_at"`
	Scopes       []string  `json:"scopes,omitempty"`

	// Additional fields
	IDToken string                 `json:"id_token,omitempty"`
	Extra   map[string]interface{} `json:"extra,omitempty"`
}

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

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

type WindowStats struct {
	TotalRequests  int64   `json:"total_requests"`
	FailedRequests int64   `json:"failed_requests"`
	FailureRate    float64 `json:"failure_rate"`
}