Struct ProcessFunctionDescriptor 

pub struct ProcessFunctionDescriptor {

    pub version: u32,
    pub runtime: ProcessRuntime,
    pub function_id: String,
    pub pipeline_state_id: String,
    pub implementation_digest: String,
    pub determinism: ProcessDeterminism,
    pub python_environment: Option<PythonEnvironmentBinding>,
    pub input_schema: SchemaRef,
    pub output_schema: SchemaRef,
    pub key_columns: Vec<String>,
    pub event_time_column: String,
    pub output_event_time_column: String,
    pub value_state_name: String,
    pub timer_names: Vec<String>,
    pub limits: ProcessFunctionLimits,
}

Immutable, versioned binding for one process function. The initial state codec is an optional signed 64-bit value; a present null is distinct from absent state.

Fields

version: u32

Descriptor format version. Currently only 1 is admitted.

runtime: ProcessRuntime

Runtime that executes the immutable implementation.

function_id: String

Stable function identity, independent of the output stream name.

pipeline_state_id: String

Stable pipeline state identity. Two pipelines must use different identities.

implementation_digest: String

Hex SHA-256 of the trusted native build or other immutable implementation identity.

determinism: ProcessDeterminism

Effects contract bound into the canonical manifest and checkpoint identity.

python_environment: Option<PythonEnvironmentBinding>

Optional Python runtime and import-tree identity checked by the local supervisor. File hashes detect deployment drift; they do not enforce lifetime immutability.

input_schema: SchemaRef

Exact input schema admitted from one direct source. V1 retains accepted per-key arrival order; timestamps do not sort input. Replayable source positions alone do not define the merge order of independent input partitions.

output_schema: SchemaRef

Exact append-only output schema.

key_columns: Vec<String>

Ordered, nonnullable canonical partition-key columns.

event_time_column: String

Nonnullable UTC microsecond input timestamp column.

output_event_time_column: String

UTC microsecond output timestamp column; output may not precede its activation.

value_state_name: String

Stable name of the one managed ValueState<Int64?> slot.

timer_names: Vec<String>

Names of supported event-time timers.

limits: ProcessFunctionLimits

Hard execution and retained-state limits.

Implementations

impl ProcessFunctionDescriptor

pub fn to_manifest_json(&self) -> Result<Vec<u8>, DbError>

Encode the validated v1 function contract as canonical UTF-8 JSON. This is a portable package and negotiation manifest; it does not package native code or certify replay.

Errors

Rejects unsupported schemas or invalid descriptor fields.

pub fn from_manifest_json(bytes: &[u8]) -> Result<Self, DbError>

Decode and validate a v1 function manifest. Unknown fields and unsupported semantics fail closed; the caller must separately bind the implementation digest to trusted code.

Errors

Rejects malformed, oversized or incompatible manifests.

Trait Implementations

impl Clone for ProcessFunctionDescriptor

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 ProcessFunctionDescriptor

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

Formats the value using the given formatter.