Skip to content

NexusLabs.Needlr.AgentFramework.Collectors

NexusLabs.Needlr.AgentFramework

NexusLabs.Needlr.AgentFramework.Collectors Namespace

Classes
AgentOutputCollector<T> Default thread-safe implementation of IAgentOutputCollector<T> backed by a System.Collections.Concurrent.ConcurrentQueue<>.
CollectorServiceCollectionExtensions Extension methods for registering IAgentOutputCollectorAccessor<T> in DI.
Interfaces
IAgentOutputCollector<T> Accumulates typed records produced by agent tool calls during a pipeline run. Provides a structured alternative to parsing free-form agent text output.
IAgentOutputCollectorAccessor<T> System.Threading.AsyncLocal<>-scoped accessor for IAgentOutputCollector<T>. Each pipeline run gets its own collector scope, isolated from concurrent runs.