Package io.agentscope.harness.agent.gateway

Class StoreBackedSubagentRegistry

java.lang.Object

io.agentscope.harness.agent.gateway.StoreBackedSubagentRegistry

All Implemented Interfaces:

SubagentRegistry

public final class StoreBackedSubagentRegistry
extends Object
implements SubagentRegistry

Distributed SubagentRegistry backed by a BaseStore. Because the store is supplied by a DistributedStore (Redis / OSS / MySQL), exposure records become visible to every node, so any replica can resolve a subagentId and re-materialize the subagent.

Records are stored under the namespace ["subagents", "exposed"] keyed by subagentId. TTL is enforced lazily on find(java.lang.String): an elapsed record is deleted and reported as absent.

This registry deliberately stores only routing/identity metadata. Concurrency safety for the subagent's mutable conversation state is the responsibility of the distributed AgentStateStore (and BaseStore.putIfVersion(java.util.List<java.lang.String>, java.lang.String, java.util.Map<java.lang.String, java.lang.Object>, long) where explicit optimistic guarding is desired), not of this registry.

Constructor Summary

Constructors

Constructor	Description
StoreBackedSubagentRegistry(BaseStore store)

Method Summary

Modifier and Type	Method	Description
Optional<SubagentRecord>	find(String subagentId)	Resolves a subagent handle.
void	register(SubagentRecord record)	Persists an exposure record.
void	revoke(String subagentId)	Removes a single exposure record.
void	revokeByParentSession(String parentSessionId)	Removes all exposure records associated with the given parent session.

Methods inherited from class java.lang.Object

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

Constructor Details

StoreBackedSubagentRegistry

public StoreBackedSubagentRegistry(BaseStore store)

Method Details

register

public void register(SubagentRecord record)

Description copied from interface: SubagentRegistry

Persists an exposure record. Idempotent on SubagentRecord.subagentId() — re-registering the same id overwrites the previous record.

Specified by:

register in interface SubagentRegistry

Parameters:

record - the record to persist (must carry a non-null subagentId)

find

public Optional<SubagentRecord> find(String subagentId)

Description copied from interface: SubagentRegistry

Resolves a subagent handle. Implementations should treat an expired record (see SubagentRecord.isExpired(java.time.Instant)) as absent and may evict it lazily.

Specified by:

find in interface SubagentRegistry

Parameters:

subagentId - the handle to resolve

Returns:

the record, or Optional.empty() if unknown or expired

revoke

public void revoke(String subagentId)

Description copied from interface: SubagentRegistry

Removes a single exposure record. No-op when the id is unknown.

Specified by:

revoke in interface SubagentRegistry

revokeByParentSession

public void revokeByParentSession(String parentSessionId)

Description copied from interface: SubagentRegistry

Removes all exposure records associated with the given parent session. Used to clean up when a parent conversation ends. Implementations that cannot enumerate by parent may no-op.

Specified by:

revokeByParentSession in interface SubagentRegistry

Parameters:

parentSessionId - the parent session whose exposed subagents should be revoked