pub struct TaskSupervisorConfig {
pub enrichment_limit: usize,
pub telemetry_limit: usize,
pub abort_enrichment_on_turn: bool,
}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.
Trait Implementations§
Source§impl Clone for TaskSupervisorConfig
impl Clone for TaskSupervisorConfig
Source§fn clone(&self) -> TaskSupervisorConfig
fn clone(&self) -> TaskSupervisorConfig
Returns a duplicate of the value. Read more
1.0.0 · Source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
Performs copy-assignment from
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
Returns the “default value” for a type. Read more
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>,
Deserialize this value from the given Serde deserializer. Read more
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,
Serialize this value into the given Serde serializer. Read more
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
Mutably borrows from an owned value. Read more
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>
Converts
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>
Converts
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>
Wrap the input message
T in a tonic::Request