proxy

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

type HTTPTransportConfig struct {
	Port           string
	ReadTimeout    time.Duration
	WriteTimeout   time.Duration
	MaxHeaderBytes int
}

type HTTPTransportOption func(*HTTPTransport)

type HealthConfig struct {
	CheckInterval      time.Duration
	ResponseTimeout    time.Duration
	MaxRestartAttempts int
	RestartBackoff     time.Duration
}

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

type JITConfig struct {
	Enabled   bool
	CacheSize int
	CacheTTL  string
}

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

type JSONRPCRequest struct {
	JSONRPC string          `json:"jsonrpc"`
	Method  string          `json:"method"`
	Params  json.RawMessage `json:"params,omitempty"`
	ID      interface{}     `json:"id"`
}

type JSONRPCResponse struct {
	JSONRPC string               `json:"jsonrpc"`
	Result  json.RawMessage      `json:"result,omitempty"`
	Error   *errors.JSONRPCError `json:"error,omitempty"`
	ID      interface{}          `json:"id"`
}

type MCPHandler func(ctx context.Context, req *JSONRPCRequest) (*JSONRPCResponse, error)

type ManagedServer interface {
	Name() string
	PID() int
	IsRunning() bool
	StartTime() time.Time
	LastResponseTime() time.Time
	RequestCount() int64
	ErrorCount() int64
	OnCrash(callback func())
	OnRestart(callback func())
}

type ProcessHealth struct {
	PID        int
	MemoryMB   int64
	CPUPercent float64
	Status     string
	IsAlive    bool
}

type ProcessHealthChecker struct {
}

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

type RegistryGetter interface {
	GetToolSchema(ctx context.Context, serverID, toolName string) (json.RawMessage, error)
}

type RequestForwarder interface {
	ForwardRequest(ctx context.Context, req JSONRPCRequest) (JSONRPCResponse, error)
}

type SchemaCache interface {
	Get(key string) (json.RawMessage, bool)
	Set(key string, schema json.RawMessage)
	Delete(key string)
	Clear()
}

type ServerHealthStatus string

type ServerStatus struct {
	Name             string             `json:"name"`
	Status           ServerHealthStatus `json:"status"`
	Uptime           time.Duration      `json:"uptime"`
	LastResponseTime time.Time          `json:"last_response_time"`
	LastError        string             `json:"last_error,omitempty"`
	RestartCount     int                `json:"restart_count"`
	RequestCount     int64              `json:"request_count"`
	ErrorRate        float64            `json:"error_rate"`
	MemoryMB         int64              `json:"memory_mb,omitempty"`
	CPUPercent       float64            `json:"cpu_percent,omitempty"`
}

type ServerStatusList struct {
	Timestamp time.Time      `json:"timestamp"`
	Servers   []ServerStatus `json:"servers"`
}

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

type SessionState struct {
	ServerName       string          `json:"server_name"`
	ClientID         string          `json:"client_id"`
	Capabilities     []string        `json:"capabilities,omitempty"`
	InitializeParams json.RawMessage `json:"init_params,omitempty"`
	CreatedAt        time.Time       `json:"created_at"`
	LastUsedAt       time.Time       `json:"last_used_at"`
}