/// import DaprClient from "../../implementation/Client/DaprClient"; import Class from "../../types/Class"; import ActorId from "../ActorId"; import AbstractActor from "./AbstractActor"; import BufferSerializer from "./BufferSerializer"; export default class ActorManager { readonly actorCls: Class; readonly daprClient: DaprClient; readonly serializer: BufferSerializer; actors: Map; constructor(actorCls: Class, daprClient: DaprClient); createActor(actorId: ActorId): Promise; activateActor(actorId: ActorId): Promise; deactivateActor(actorId: ActorId): Promise; getActiveActor(actorId: ActorId): Promise; /** * Execute the given method with requestBody on the given Actor * * @param actorId * @param actorMethodName * @param requestBody * @param actorMethodContext * @returns */ invoke(actorId: ActorId, actorMethodName: string, requestBody?: Buffer): Promise; fireReminder(actorId: ActorId, reminderName: string, requestBody?: Buffer): Promise; fireTimer(actorId: ActorId, timerName: string, requestBody?: Buffer): Promise; callActorMethod(actorId: ActorId, actorMethodName: string, args: any): Promise; }