Skip to content

NexusLabs.Needlr.AgentFramework.Progress

NexusLabs.Needlr.AgentFramework

NexusLabs.Needlr.AgentFramework.Progress Namespace

Classes
AgentCompletedEvent An agent has completed its turn.
AgentFailedEvent An agent run failed.
AgentHandoffEvent An agent handed off to another agent.
AgentInvokedEvent An agent has been invoked (turn started).
BudgetExceededEvent A token budget limit has been exceeded.
BudgetUpdatedEvent Token budget usage has been updated.
ChannelProgressReporter Non-blocking IProgressReporter that pushes events to a System.Threading.Channels.Channel<> and drains them to sinks on a background task. Use this when sinks do I/O (database, network) and you don't want to block the agent pipeline.
CompositeDisposable Composite System.IDisposable that owns a fixed set of child disposables and releases them in reverse order on NexusLabs.Needlr.AgentFramework.Progress.CompositeDisposable.Dispose.
LlmCallCompletedEvent An LLM response has been received.
LlmCallFailedEvent An LLM call failed.
LlmCallStartedEvent An LLM request has been sent.
SuperStepCompletedProgressEvent A workflow control-flow step (SuperStep) has completed.
SuperStepStartedProgressEvent A workflow control-flow step (SuperStep) has started. Represents one cycle of the orchestration loop: send work to agents → collect results → decide next.
ToolCallCompletedEvent A tool invocation has completed.
ToolCallFailedEvent A tool invocation failed.
ToolCallStartedEvent A tool invocation has started.
WorkflowCompletedEvent Workflow execution has completed.
WorkflowStartedEvent Workflow execution has started.
Interfaces
IProgressEvent Base interface for all progress events emitted during agent/workflow execution. Every event carries correlation context enabling hierarchical trace reconstruction.
IProgressReporter Emits progress events to registered sinks. Carries hierarchical context (workflow ID, agent ID, depth) so events are automatically correlated.
IProgressReporterAccessor Provides ambient access to the IProgressReporter for the current async flow. Follows the IHttpContextAccessor pattern — backed by System.Threading.AsyncLocal<> so concurrent orchestrations see their own reporters.
IProgressReporterErrorHandler Receives callbacks when an IProgressSink throws while handling an event. Without a handler, sink exceptions would be silently swallowed.
IProgressReporterFactory Creates IProgressReporter instances scoped to a specific orchestration run.
IProgressSequence Provides globally-ordered sequence numbers for progress events across all concurrent orchestrations. Registered as a singleton in DI so all IProgressReporter instances share a single monotonic counter.
IProgressSink Receives progress events as they occur during agent/workflow execution. Implement this interface to build SSE streams, console displays, trace diagrams, etc.