hive/mcp-server/dist/whoosh-client.d.ts

/**
 * WHOOSH Client
 *
 * Handles communication with the WHOOSH backend API
 */
import WebSocket from 'ws';
export interface WHOOSHConfig {
    baseUrl: string;
    wsUrl: string;
    timeout: number;
}
export interface Agent {
    id: string;
    endpoint: string;
    model: string;
    specialty: string;
    status: 'available' | 'busy' | 'offline';
    current_tasks: number;
    max_concurrent: number;
    agent_type?: 'ollama' | 'cli';
    cli_config?: {
        host?: string;
        node_version?: string;
        model?: string;
        specialization?: string;
        max_concurrent?: number;
        command_timeout?: number;
        ssh_timeout?: number;
        agent_type?: string;
    };
}
export interface Task {
    id: string;
    type: string;
    priority: number;
    context: Record<string, any>;
    status: 'pending' | 'in_progress' | 'completed' | 'failed';
    assigned_agent?: string;
    result?: Record<string, any>;
    created_at: string;
    completed_at?: string;
}
export interface ClusterStatus {
    system: {
        status: string;
        uptime: number;
        version: string;
    };
    agents: {
        total: number;
        available: number;
        busy: number;
    };
    tasks: {
        total: number;
        pending: number;
        running: number;
        completed: number;
        failed: number;
    };
}
export declare class WHOOSHClient {
    private api;
    private config;
    private wsConnection?;
    constructor(config?: Partial<WHOOSHConfig>);
    testConnection(): Promise<boolean>;
    getAgents(): Promise<Agent[]>;
    registerAgent(agentData: Partial<Agent>): Promise<{
        agent_id: string;
    }>;
    getCliAgents(): Promise<Agent[]>;
    registerCliAgent(agentData: {
        id: string;
        host: string;
        node_version: string;
        model?: string;
        specialization?: string;
        max_concurrent?: number;
        agent_type?: string;
        command_timeout?: number;
        ssh_timeout?: number;
    }): Promise<{
        agent_id: string;
        endpoint: string;
        health_check?: any;
    }>;
    registerPredefinedCliAgents(): Promise<{
        results: any[];
    }>;
    healthCheckCliAgent(agentId: string): Promise<any>;
    getCliAgentStatistics(): Promise<any>;
    unregisterCliAgent(agentId: string): Promise<{
        success: boolean;
    }>;
    createTask(taskData: {
        type: string;
        priority: number;
        context: Record<string, any>;
    }): Promise<Task>;
    getTask(taskId: string): Promise<Task>;
    getTasks(filters?: {
        status?: string;
        agent?: string;
        limit?: number;
    }): Promise<Task[]>;
    getWorkflows(): Promise<any[]>;
    createWorkflow(workflowData: Record<string, any>): Promise<{
        workflow_id: string;
    }>;
    executeWorkflow(workflowId: string, inputs?: Record<string, any>): Promise<{
        execution_id: string;
    }>;
    getClusterStatus(): Promise<ClusterStatus>;
    getMetrics(): Promise<string>;
    getExecutions(workflowId?: string): Promise<any[]>;
    connectWebSocket(topic?: string): Promise<WebSocket>;
    disconnect(): Promise<void>;
}
//# sourceMappingURL=whoosh-client.d.ts.map