pub struct TaskSupervisorConfig {
pub enrichment_limit: usize,
pub telemetry_limit: usize,
pub abort_enrichment_on_turn: bool,
pub background_shell_limit: usize,
}Expand description
Background task supervisor configuration, nested under [agent.supervisor] in TOML.
Controls per-class concurrency limits and turn-boundary behaviour for the
BackgroundSupervisor in zeph-core.
All fields have sensible defaults that match the Phase 1 hardcoded values; only change
these if you observe excessive background task drops under load.
§Example (TOML)
[agent.supervisor]
enrichment_limit = 4
telemetry_limit = 8
abort_enrichment_on_turn = falseFields§
§enrichment_limit: usizeMaximum concurrent enrichment tasks (summarization, graph/persona/trajectory extraction).
Default: 4.
telemetry_limit: usizeMaximum concurrent telemetry tasks (audit log writes, graph count sync).
Default: 8.
abort_enrichment_on_turn: boolAbort all inflight enrichment tasks at turn boundary to prevent backlog buildup.
Default: false.
background_shell_limit: usizeMaximum concurrent background shell runs tracked by the supervisor.
Should match tools.shell.max_background_runs so both layers agree on capacity.
Default: 8.
Trait Implementations§
Source§impl Clone for TaskSupervisorConfig
impl Clone for TaskSupervisorConfig
Source§fn clone(&self) -> TaskSupervisorConfig
fn clone(&self) -> TaskSupervisorConfig
1.0.0 · Source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
source. Read moreSource§impl Debug for TaskSupervisorConfig
impl Debug for TaskSupervisorConfig
Source§impl Default for TaskSupervisorConfig
impl Default for TaskSupervisorConfig
Source§fn default() -> TaskSupervisorConfig
fn default() -> TaskSupervisorConfig
Source§impl<'de> Deserialize<'de> for TaskSupervisorConfigwhere
TaskSupervisorConfig: Default,
impl<'de> Deserialize<'de> for TaskSupervisorConfigwhere
TaskSupervisorConfig: Default,
Source§fn deserialize<__D>(
__deserializer: __D,
) -> Result<TaskSupervisorConfig, <__D as Deserializer<'de>>::Error>where
__D: Deserializer<'de>,
fn deserialize<__D>(
__deserializer: __D,
) -> Result<TaskSupervisorConfig, <__D as Deserializer<'de>>::Error>where
__D: Deserializer<'de>,
Source§impl Serialize for TaskSupervisorConfig
impl Serialize for TaskSupervisorConfig
Source§fn serialize<__S>(
&self,
__serializer: __S,
) -> Result<<__S as Serializer>::Ok, <__S as Serializer>::Error>where
__S: Serializer,
fn serialize<__S>(
&self,
__serializer: __S,
) -> Result<<__S as Serializer>::Ok, <__S as Serializer>::Error>where
__S: Serializer,
Auto Trait Implementations§
impl Freeze for TaskSupervisorConfig
impl RefUnwindSafe for TaskSupervisorConfig
impl Send for TaskSupervisorConfig
impl Sync for TaskSupervisorConfig
impl Unpin for TaskSupervisorConfig
impl UnsafeUnpin for TaskSupervisorConfig
impl UnwindSafe for TaskSupervisorConfig
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Source§impl<T> CloneToUninit for Twhere
T: Clone,
impl<T> CloneToUninit for Twhere
T: Clone,
Source§impl<T> Instrument for T
impl<T> Instrument for T
Source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
Source§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
Source§impl<T> IntoEither for T
impl<T> IntoEither for T
Source§fn into_either(self, into_left: bool) -> Either<Self, Self>
fn into_either(self, into_left: bool) -> Either<Self, Self>
self into a Left variant of Either<Self, Self>
if into_left is true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moreSource§fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
self into a Left variant of Either<Self, Self>
if into_left(&self) returns true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moreSource§impl<T> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
Source§fn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
T in a tonic::Request