Class MockWorkEngineService

java.lang.Object
ai.pipestream.module.work.v1.ModuleWorkServiceGrpc.ModuleWorkServiceImplBase
ai.pipestream.module.pipelineprobe.mockengine.MockWorkEngineService
All Implemented Interfaces:
ai.pipestream.module.work.v1.ModuleWorkServiceGrpc.AsyncService, io.grpc.BindableService
public class MockWorkEngineService extends ai.pipestream.module.work.v1.ModuleWorkServiceGrpc.ModuleWorkServiceImplBase
A mock ModuleWorkService engine for exercising a module's demand-pull work loop in isolation — no real engine, Kafka, Redis or S3. Point a module's quarkus.grpc.clients.engine at this sidecar and it serves synthetic PipeStream work units from MockWorkCorpus and records the WorkAcks in MockWorkStats.

Speaks the v1 short-lived-bidi protocol exactly: one work unit per stream — Hello → WorkUnit (or NoWorkAvailable) → [Heartbeats] → WorkAck → AckConfirmed, then the stream closes. Heartbeats are accepted and ignored.

OFF by default (pipestream.module.mock-engine.enabled=false): the service is registered but always answers NoWorkAvailable, so a sidecar not being used as a mock engine is unaffected. In mock-engine mode you typically also set pipestream.module.worker-loop.enabled=false so this sidecar only SERVES work rather than also pulling it.

  • Constructor Summary

    Constructors
    Constructor
    Description
    MockWorkEngineService()
    CDI.

  • Method Summary

    Modifier and Type
    Method
    Description
    io.grpc.stub.StreamObserver<ai.pipestream.module.work.v1.WorkRequest>
    work(io.grpc.stub.StreamObserver<ai.pipestream.module.work.v1.WorkResponse> responseObserver)
     

    Methods inherited from class ai.pipestream.module.work.v1.ModuleWorkServiceGrpc.ModuleWorkServiceImplBase

    bindService

    Methods inherited from class Object

    clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

  • Constructor Details

    • MockWorkEngineService

      public MockWorkEngineService()
      CDI.

  • Method Details

    • work

      public io.grpc.stub.StreamObserver<ai.pipestream.module.work.v1.WorkRequest> work(io.grpc.stub.StreamObserver<ai.pipestream.module.work.v1.WorkResponse> responseObserver)