Gets the current lock status of the MiddlewareManager
InternalInternalCompose a runner for a task with its local interceptors and applicable middlewares. Returns a function that accepts the task input and resolves to the task output.
Gets all "everywhere" middlewares that apply to the given resource
Gets all "everywhere" middlewares that apply to the given task
InternalSnapshot of resource owners that registered middleware interceptors.
Adds an interceptor for task or resource middleware execution Interceptors are executed in the order they are added, with the ability to modify, log, or prevent middleware execution
The type of middleware to intercept ("task" or "resource")
The interceptor function to add
Adds an interceptor for task or resource middleware execution Interceptors are executed in the order they are added, with the ability to modify, log, or prevent middleware execution
The type of middleware to intercept ("task" or "resource")
The interceptor function to add
Adds an interceptor for a specific middleware instance with better type safety This method automatically determines the type and provides type-safe access
The middleware instance to intercept
The interceptor function with proper typing
Adds an interceptor for a specific middleware instance with better type safety This method automatically determines the type and provides type-safe access
The middleware instance to intercept
The interceptor function with proper typing
InternalSame behavior as interceptMiddleware(), but records owner metadata for tooling.
OptionalownerResourceId: stringInternalSame behavior as interceptMiddleware(), but records owner metadata for tooling.
OptionalownerResourceId: stringInternalSame behavior as intercept(), but records owner metadata for tooling.
OptionalownerResourceId: stringInternalSame behavior as intercept(), but records owner metadata for tooling.
OptionalownerResourceId: stringLocks the MiddlewareManager, preventing any further modifications to interceptors
Centralizes middleware composition and execution for both tasks and resources. Keeps observability emissions and unhandled error routing consistent.
This is a facade that delegates to specialized composer classes for maintainability.