namespace JobEngineSL.Hubs { public interface IJobEngineClient { Task ReceiveJobStarted(int jobId, string jobName, string correlationId); Task ReceiveJobCompleted(int jobId, string jobName, long durationMs, string? resultSummary); Task ReceiveJobFailed(int jobId, string jobName, string error, int retryAttempt, bool isDlq); Task ReceiveQueueDepth(int pending, int processing, int dlq, string messageType); } }