concurrent

type BatchConfig struct {
	WindowMs       int
	MaxBatchSize   int
	MaxWaitTime    time.Duration
	EnableBatching bool
}

type BatchProcessor interface {
	ProcessBatch(ctx context.Context, serverName string, requests []Request) []Response
}

type BatchRequest struct {
	Request  Request
	ResultCh chan *Response
	ErrorCh  chan error
	Arrived  time.Time
}

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

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

type CircuitBreakerConfig struct {
	Threshold          int
	Cooldown           time.Duration
	HalfOpenMaxSuccess int
}

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

type CircuitBreakerMetrics struct {
	State          string
	Failures       int32
	Threshold      int
	TotalSuccesses int32
	TotalFailures  int32
	LastFailure    time.Time
}

type CircuitState int

type Clock interface {
	Now() time.Time
	Since(time.Time) time.Duration
}

type ConcurrentError struct {
	Code    int             `json:"code"`
	Message string          `json:"message"`
	Data    json.RawMessage `json:"data,omitempty"`
}

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

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

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

type PoolConfig struct {
	MaxConcurrent   int
	MaxQueueSize    int
	QueueTimeout    time.Duration
	WorkerCount     int
	BatchWindowMs   int
	RateLimitMax    int
	RateLimitWindow time.Duration
}

type PoolStats struct {
	TotalRequests   int64
	ActiveRequests  int64
	QueuedRequests  int64
	FailedRequests  int64
	SuccessRequests int64
	AverageLatency  time.Duration
}

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

type QueuedRequest struct {
	Request    Request
	ResultCh   chan *Response
	ErrorCh    chan error
	EnqueuedAt time.Time
}

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

type RateLimiterConfig struct {
	MaxRequests int
	Window      time.Duration
}

type RateLimiterStats struct {
	ServerName      string
	CurrentRequests int
	MaxRequests     int
	BlockedCount    int64
}

type RealClock struct{}

type Request struct {
	Method     string          `json:"method"`
	Params     json.RawMessage `json:"params,omitempty"`
	ID         interface{}     `json:"id"`
	ServerName string          `json:"server_name"`
	Timeout    time.Duration
	ResultCh   chan *Response
	ErrorCh    chan error
}

type RequestHandler interface {
	Handle(ctx context.Context, req *Request) (*Response, error)
}

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

type Response struct {
	Result json.RawMessage  `json:"result,omitempty"`
	Error  *ConcurrentError `json:"error,omitempty"`
	ID     interface{}      `json:"id"`
}

type ServerHandle struct {
	Name           string
	State          ServerState
	CurrentLoad    int32
	MaxConcurrent  int
	RequestCount   int64
	ErrorCount     int64
	AvgLatencyMs   float64
	LastRequestAt  time.Time
	RestartCount   int
	CurrentBackoff time.Duration
}

type ServerState string

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

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

type WorkerPoolMetrics struct {
	SubmittedTasks  int64
	CompletedTasks  int64
	FailedTasks     int64
	QueuedTasks     int64
	RejectedTasks   int64
	AverageWaitTime time.Duration
}