import type * as grpc from '@grpc/grpc-js'; import type { EnumTypeDefinition, MessageTypeDefinition } from '@grpc/proto-loader'; import type { WorkerServiceClient as _memoflow_v1_WorkerServiceClient, WorkerServiceDefinition as _memoflow_v1_WorkerServiceDefinition } from './memoflow/v1/WorkerService.js'; import type { WorkerSessionClient as _memoflow_v1_WorkerSessionClient, WorkerSessionDefinition as _memoflow_v1_WorkerSessionDefinition } from './memoflow/v1/WorkerSession.js'; type SubtypeConstructor any, Subtype> = { new (...args: ConstructorParameters): Subtype; }; export interface ProtoGrpcType { google: { protobuf: { Duration: MessageTypeDefinition; Timestamp: MessageTypeDefinition; }; }; memoflow: { v1: { ActivityFailed: MessageTypeDefinition; ActivityOutputChunk: MessageTypeDefinition; ActivitySuccess: MessageTypeDefinition; ActivityTask: MessageTypeDefinition; AiBudgetEstimate: MessageTypeDefinition; AiBudgetPriceIdentity: MessageTypeDefinition; AiBudgetResolutionEvidence: EnumTypeDefinition; AiFinishReason: EnumTypeDefinition; AiInvocationRecord: MessageTypeDefinition; AiInvocationStatus: EnumTypeDefinition; AiNormalizedUsage: MessageTypeDefinition; AiOperation: EnumTypeDefinition; AiPriceSnapshot: MessageTypeDefinition; AiProviderExtension: MessageTypeDefinition; AiRetryAndRateLimit: MessageTypeDefinition; AiToolEffectRecord: MessageTypeDefinition; AiToolEffectStatus: EnumTypeDefinition; AppendOutputChunkRequest: MessageTypeDefinition; AvailabilityUpdate: MessageTypeDefinition; CancelNotice: MessageTypeDefinition; CapacityState: MessageTypeDefinition; Command: MessageTypeDefinition; CompleteActivityRequest: MessageTypeDefinition; CompleteWorkflowTaskRequest: MessageTypeDefinition; DurableAck: MessageTypeDefinition; ErrorCode: EnumTypeDefinition; ErrorDetail: MessageTypeDefinition; ErrorScope: EnumTypeDefinition; Evicted: MessageTypeDefinition; FieldViolation: MessageTypeDefinition; ForkEffectMode: EnumTypeDefinition; ForkExecutionOverride: MessageTypeDefinition; ForkExecutionPolicy: MessageTypeDefinition; ForkOverrideKind: EnumTypeDefinition; FrameError: MessageTypeDefinition; GetCheckpointsRequest: MessageTypeDefinition; GetCheckpointsResponse: MessageTypeDefinition; GetSqlContractRequest: MessageTypeDefinition; GetSqlContractResponse: MessageTypeDefinition; HttpEffectMeta: MessageTypeDefinition; PayloadBlobReference: MessageTypeDefinition; PayloadEncryption: MessageTypeDefinition; PayloadEnvelope: MessageTypeDefinition; PayloadMetadata: MessageTypeDefinition; Ping: MessageTypeDefinition; ReadActivityOutputRequest: MessageTypeDefinition; ReadActivityOutputResponse: MessageTypeDefinition; RecordAiInvocationRequest: MessageTypeDefinition; RecordAiToolEffectRequest: MessageTypeDefinition; RecordEffects: MessageTypeDefinition; RecordSideEffectCommand: MessageTypeDefinition; ReleaseTask: MessageTypeDefinition; ReserveAiBudgetRequest: MessageTypeDefinition; ResolveAiBudgetRequest: MessageTypeDefinition; RetryPolicy: MessageTypeDefinition; SandboxAttestation: MessageTypeDefinition; ScheduleActivityCommand: MessageTypeDefinition; ScheduleTimerCommand: MessageTypeDefinition; ServerFrame: MessageTypeDefinition; SessionHello: MessageTypeDefinition; SessionHelloAck: MessageTypeDefinition; SettleAiBudgetRequest: MessageTypeDefinition; SettleRecoveredAiBudgetRequest: MessageTypeDefinition; Signal: MessageTypeDefinition; StartChildWorkflowCommand: MessageTypeDefinition; StepCheckpoint: MessageTypeDefinition; StepStatus: EnumTypeDefinition; StepType: EnumTypeDefinition; StreamChunkRequest: MessageTypeDefinition; TaskDeliveryIdentity: MessageTypeDefinition; TaskKind: EnumTypeDefinition; TaskReference: MessageTypeDefinition; WaitForSignalCommand: MessageTypeDefinition; WorkerDrainRequest: MessageTypeDefinition; WorkerFrame: MessageTypeDefinition; WorkerService: SubtypeConstructor & { service: _memoflow_v1_WorkerServiceDefinition; }; /** * One long-lived session per worker process (or per task-queue registration — * a worker serving multiple queues opens one session per queue). * The wire-level name is intentionally frozen before launch because SDKs expose * it as WorkerSession; renaming it solely for a style suffix would churn every * generated client without improving the contract. */ WorkerSession: SubtypeConstructor & { service: _memoflow_v1_WorkerSessionDefinition; }; WorkflowInfo: MessageTypeDefinition; WorkflowStatus: EnumTypeDefinition; WorkflowTask: MessageTypeDefinition; WorkflowTaskFailed: MessageTypeDefinition; WorkflowTaskSuccess: MessageTypeDefinition; WorkflowTaskSuspended: MessageTypeDefinition; }; }; } export {};