import { Observable } from 'rxjs'; import { GatewayConnection } from '../data/gateway-connection'; import { NodeConnection } from '../data/node-connection'; import { Rpc } from '../rpc/rpc'; import { RpcWorkItem } from '../rpc/work-item/rpc-work-item-model'; import { NotificationConnection } from './notification-connection'; import { WorkItemResult } from './work-item-request'; /** * Work item manager class. */ export declare class WorkItemManager { private rpc; private gatewayConnection; private nodeConnection; notificationConnection: NotificationConnection; private static apiWorkItems24hours; private static apiNotificationMessageStored; private static apiNotificationMessageSubscriptionId; active: boolean; private startSubscription; private powerShellNotification; private notificationSubscription; private rpcWorkItemSubscription; private notificationManager; private sequenceCounter; private sequencePackets; private rpcWorkItemSubjectServer; private rootSubscriptionId; /** * Initializes a new instance of the WorkItemManager class. * * @param rpc the RPC object. * @param gatewayConnection the gateway connection service. * @param nodeConnection the node connection service. * @param notificationManager the notification manager. */ constructor(rpc: Rpc, gatewayConnection: GatewayConnection, nodeConnection: NodeConnection, notificationConnection: NotificationConnection); /** * Start the work item management. */ start(): void; /** * Stop the work item management. */ stop(): void; /** * Create and submit a workItem. * * @param request the work item request. * @return Observable the WorkItemResult observable. */ submitWorkItem(request: RpcWorkItem): Observable; /** * Query a workItem. * * @param request the work item request. * @return Observable the WorkItemResult observable. */ queryWorkItem(request: RpcWorkItem): Observable; private getErrorLevel; }