pub struct SchedulerTuning {
pub max_concurrent_jobs: usize,
pub job_timeout_secs: u64,
pub webhook_timeout_secs: u64,
pub siem_webhook_timeout_secs: u64,
pub otel_timeout_secs: u64,
}Expand description
Tuning knobs for the Event-Plane scheduler and outbound HTTP emitters.
Fields§
§max_concurrent_jobs: usizeHard cap on concurrent in-flight scheduled jobs. Jobs beyond the cap at a minute-boundary are rejected rather than starving request-path Tokio workers with parallel SQL.
job_timeout_secs: u64Wall-clock timeout applied to each scheduled job via
ExecutionBudget. Long-running SQL bodies that exceed this are
cancelled cooperatively at the next statement boundary.
webhook_timeout_secs: u64Timeout (seconds) for a single alert-webhook POST.
siem_webhook_timeout_secs: u64Timeout (seconds) for a SIEM-webhook POST.
otel_timeout_secs: u64Timeout (seconds) for an OTLP trace-span export.
Trait Implementations§
Source§impl Clone for SchedulerTuning
impl Clone for SchedulerTuning
Source§fn clone(&self) -> SchedulerTuning
fn clone(&self) -> SchedulerTuning
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 SchedulerTuning
impl Debug for SchedulerTuning
Source§impl Default for SchedulerTuning
impl Default for SchedulerTuning
Source§impl<'de> Deserialize<'de> for SchedulerTuning
impl<'de> Deserialize<'de> for SchedulerTuning
Source§fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>where
__D: Deserializer<'de>,
fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>where
__D: Deserializer<'de>,
Deserialize this value from the given Serde deserializer. Read more
Auto Trait Implementations§
impl Freeze for SchedulerTuning
impl RefUnwindSafe for SchedulerTuning
impl Send for SchedulerTuning
impl Sync for SchedulerTuning
impl Unpin for SchedulerTuning
impl UnsafeUnpin for SchedulerTuning
impl UnwindSafe for SchedulerTuning
Blanket Implementations§
Source§impl<T> ArchivePointee for T
impl<T> ArchivePointee for T
Source§type ArchivedMetadata = ()
type ArchivedMetadata = ()
The archived version of the pointer metadata for this type.
Source§fn pointer_metadata(
_: &<T as ArchivePointee>::ArchivedMetadata,
) -> <T as Pointee>::Metadata
fn pointer_metadata( _: &<T as ArchivePointee>::ArchivedMetadata, ) -> <T as Pointee>::Metadata
Converts some archived metadata to the pointer metadata for itself.
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> LayoutRaw for T
impl<T> LayoutRaw for T
Source§fn layout_raw(_: <T as Pointee>::Metadata) -> Result<Layout, LayoutError>
fn layout_raw(_: <T as Pointee>::Metadata) -> Result<Layout, LayoutError>
Returns the layout of the type.
Source§impl<T, N1, N2> Niching<NichedOption<T, N1>> for N2
impl<T, N1, N2> Niching<NichedOption<T, N1>> for N2
Source§unsafe fn is_niched(niched: *const NichedOption<T, N1>) -> bool
unsafe fn is_niched(niched: *const NichedOption<T, N1>) -> bool
Returns whether the given value has been niched. Read more
Source§fn resolve_niched(out: Place<NichedOption<T, N1>>)
fn resolve_niched(out: Place<NichedOption<T, N1>>)
Writes data to
out indicating that a T is niched.