Struct BudgetSpec 

pub struct BudgetSpec {
    pub max_records: Option<u64>,
    pub max_bytes: Option<u64>,
    pub max_duration_secs: Option<u64>,
    pub allowed_sinks: Vec<String>,
}

A run budget.

Fields

max_records: Option<u64>

Most records the sink may accept. A page that would cross it is refused whole and the run fails with budget_exceeded.

max_bytes: Option<u64>

Most estimated serialized bytes the sink may accept (same estimate as usage accounting). Refused whole at the page that would cross it.

max_duration_secs: Option<u64>

Longest an invocation may run. Past it the run is cancelled cooperatively (stops at the next page boundary, flushes) and fails with budget_exceeded.

allowed_sinks: Vec<String>

Sink template names (pipeline.sinks.* keys) and/or connector kinds a row may write to. Empty = any. Checked before anything runs.

Implementations

impl BudgetSpec

pub const DENY_ALL_SINKS: &'static str = "!none"

The allowed_sinks entry a merge leaves when two non-empty lists have nothing in common: it matches no sink, so every row is refused.

pub fn is_empty(&self) -> bool

No ceiling set at all.

pub fn validate(&self) -> Result<(), String>

Every ceiling must be positive; an empty allowed_sinks entry is a typo.

pub fn merge(&self, other: &BudgetSpec) -> BudgetSpec

The stricter of two budgets: the lower of each ceiling, and the intersection of the allowed-sink lists (either side’s list alone when only one names any). Two lists with nothing in common allow no sink (Self::DENY_ALL_SINKS) — an empty list would mean “any”.

pub fn merge_with( &self, other: &BudgetSpec, kind_of: &dyn Fn(&str) -> Option<String>, ) -> BudgetSpec

Self::merge, where kind_of names the connector kind of a sink template: a template on one side survives when the other side allows its kind.

pub fn sink_allowed(&self, sink_ref: &str, kind: &str) -> bool

Whether a row writing to sink template sink_ref of connector kind is allowed.

Trait Implementations

impl Clone for BudgetSpec

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for BudgetSpec

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for BudgetSpec

fn default() -> Self

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for BudgetSpec

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Eq for BudgetSpec

impl JsonSchema for BudgetSpec

fn schema_name() -> Cow<'static, str>

The name of the generated JSON Schema.

fn schema_id() -> Cow<'static, str>

Returns a string that uniquely identifies the schema produced by this type.

fn json_schema(generator: &mut SchemaGenerator) -> Schema

Generates a JSON Schema for this type.

fn inline_schema() -> bool

Whether JSON Schemas generated for this type should be included directly in parent schemas, rather than being re-used where possible using the $ref keyword.

impl PartialEq for BudgetSpec

fn eq(&self, other: &Self) -> bool

Equality operator ==.

fn ne(&self, other: &Rhs) -> bool

Inequality operator !=.

impl Serialize for BudgetSpec

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl StructuralPartialEq for BudgetSpec