Crate xaeroflux_ffi 

Structs

FfiSubject

Opaque pointer to a Subject pipeline.

Functions

xf_event_create^⚠

Create a new XaeroEvent from C data

xf_event_free^⚠

Free a XaeroEvent created by xf_event_create

xf_event_get_data^⚠

Helper function to safely access XaeroEvent data from C Returns a pointer to the event data and sets the length.

xf_event_get_timestamp^⚠

Helper function to get event timestamp from C

xf_event_get_type^⚠

Helper function to get event type from C

xf_subject_blackhole

Terminal operator: consume all events without processing (blackhole).

xf_subject_filter

xf_subject_filter_merkle_proofs

Drop events lacking a Merkle proof (no callback needed).

xf_subject_map

xf_subject_new^⚠

Create a new Subject pipeline for the given name. Returns a pointer you must later pass to the other calls.

xf_subject_unsafe_run

Run the pipeline to completion (or until it blocks). After calling this, the Subject is consumed/dropped.

Type Aliases

FilterCallback

Filter operator: drop or keep events based on your predicate. Return “true” to keep the event.

MapCallback

Map operator: apply your own callback to every event. cb is a C function pointer that takes an Arc and returns an Arc.