Struct AttachedFunction 

pub struct AttachedFunction {

    pub id: AttachedFunctionUuid,
    pub name: String,
    pub function_id: Uuid,
    pub input_collection_id: CollectionUuid,
    pub output_collection_name: String,
    pub output_collection_id: Option<CollectionUuid>,
    pub params: Option<String>,
    pub tenant_id: String,
    pub database_id: String,
    pub last_run: Option<SystemTime>,
    pub next_run: SystemTime,
    pub completion_offset: u64,
    pub min_records_for_invocation: u64,
    pub is_deleted: bool,
    pub created_at: SystemTime,
    pub updated_at: SystemTime,
    pub next_nonce: NonceUuid,
    pub lowest_live_nonce: Option<NonceUuid>,
}

Fields

id: AttachedFunctionUuid

Unique identifier for the attached function

name: String

Human-readable name for the attached function instance

function_id: Uuid

UUID of the function/built-in definition this attached function uses

input_collection_id: CollectionUuid

Source collection that triggers the attached function

output_collection_name: String

Name of target collection where attached function output is stored

output_collection_id: Option<CollectionUuid>

ID of the output collection (lazily filled in after creation)

params: Option<String>

Optional JSON parameters for the function

tenant_id: String

Tenant name this attached function belongs to (despite field name, this is a name not a UUID)

database_id: String

Database name this attached function belongs to (despite field name, this is a name not a UUID)

last_run: Option<SystemTime>

Timestamp of the last successful function run

next_run: SystemTime

Timestamp when the attached function should next run

completion_offset: u64

Completion offset: the WAL position up to which the attached function has processed records

min_records_for_invocation: u64

Minimum number of new records required before the attached function runs again

is_deleted: bool

Whether the attached function has been soft-deleted

created_at: SystemTime

Timestamp when the attached function was created

updated_at: SystemTime

Timestamp when the attached function was last updated

next_nonce: NonceUuid

Next nonce (UUIDv7) for execution tracking

lowest_live_nonce: Option<NonceUuid>

Lowest live nonce (UUIDv7) - marks the earliest epoch that still needs verification When lowest_live_nonce is Some and < next_nonce, it indicates finish failed and we should skip execution and only run the scout_logs recheck phase None indicates the attached function has never been scheduled (brand new)

Trait Implementations

impl Clone for AttachedFunction

fn clone(&self) -> AttachedFunction

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for AttachedFunction

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for AttachedFunction

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for AttachedFunction

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

where __S: Serializer,

Serialize this value into the given Serde serializer.