Class ModuleTestInvoker

java.lang.Object

ai.pipestream.module.pipelineprobe.moduletest.ModuleTestInvoker

@ApplicationScoped
public class ModuleTestInvoker
extends Object

Forwards a serialized PipeStream to a module's dev test door (POST /module-runtime/v1/process-once) and returns the door's raw JSON outcome. A dumb byte-forwarder: it shapes nothing — the caller supplies a correctly-shaped payload — and it resolves the target from ModuleTestConfig (static config), never runtime discovery.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static final record	ModuleTestInvoker.DoorResponse	The door's HTTP status plus its raw response body (JSON on success).

Constructor Summary

Constructors

Constructor	Description
ModuleTestInvoker()	Creates the module test invoker.

Method Summary

Modifier and Type	Method	Description
ModuleTestInvoker.DoorResponse	invoke(String moduleName, byte[] payload)	POST payload to <configured baseUrl>/module-runtime/v1/process-once.
ModuleTestInvoker.DoorResponse	ramp(String moduleName, String jsonBody)	Proxy to the module's ops ramp surface (/module-runtime/v1/ramp): body == null → GET (current pool state), otherwise POST it (JSON {"ceiling": N}).

Methods inherited from class Object

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

Constructor Details

ModuleTestInvoker

public ModuleTestInvoker()

Creates the module test invoker. Instances are managed by CDI.

Method Details

invoke

public ModuleTestInvoker.DoorResponse invoke(String moduleName,
 byte[] payload)

POST payload to <configured baseUrl>/module-runtime/v1/process-once.

Parameters:

moduleName - configured module key (see ModuleTestConfig.targets())

payload - a serialized PipeStream (the module's payload type)

Returns:

the door's status + body

Throws:

IllegalArgumentException - if the module has no configured target

IllegalStateException - if the door is unreachable

ramp

public ModuleTestInvoker.DoorResponse ramp(String moduleName,
 String jsonBody)

Proxy to the module's ops ramp surface (/module-runtime/v1/ramp): body == null → GET (current pool state), otherwise POST it (JSON {"ceiling": N}). Same target resolution as the door.

Parameters:

moduleName - configured module key (see ModuleTestConfig.targets())

jsonBody - the JSON body to POST, or null to issue a GET for current state

Returns:

the ramp endpoint's status + body

Throws:

IllegalArgumentException - if the module has no configured target

IllegalStateException - if the ramp endpoint is unreachable