#[repr(C)]pub struct PluginVTable {
pub api_version: u32,
pub create: extern "C" fn() -> RResult<*mut c_void, RBoxError>,
pub destroy: extern "C" fn(state: *mut c_void),
pub init: extern "C" fn(state: *mut c_void, ctx: &PluginContext) -> RResult<(), RBoxError>,
pub process: extern "C" fn(state: *const c_void, msg: &SpoeMessage) -> RResult<ProcessingResult, RBoxError>,
pub name: extern "C" fn(state: *const c_void) -> RStr<'static>,
pub plugin_version: extern "C" fn(state: *const c_void) -> RStr<'static>,
pub shutdown: extern "C" fn(state: *const c_void),
pub config_schema: extern "C" fn(state: *const c_void) -> ROption<RString>,
pub validate: extern "C" fn(state: *const c_void, ctx: &PluginContext) -> RVec<Diagnostic>,
pub set_metric_recorder: extern "C" fn(state: *mut c_void, record_fn: RecordMetricFn, ctx: *const c_void),
}Expand description
The function table a plugin shared library exports.
#[repr(C)] is mandatory: it pins field offsets and padding rules
so plugins built against an older version of this crate keep
working when the hub is built against a newer one (and vice versa).
§Safety contract for hosts
Fields below the v1 baseline marker are version-gated. Hosts MUST
NOT access them via &PluginVTable directly — the borrow would
implicitly cover the whole struct, which on an older plugin is
past the end of its allocation. Use the read_*_field accessors
or read individual fields through the raw pointer (e.g.
unsafe { (*ptr).api_version }) which read only the bytes for that
field.
Fields§
§api_version: u32Plugin’s reported API version. The hub uses this to gate access to fields beyond the v1 baseline.
create: extern "C" fn() -> RResult<*mut c_void, RBoxError>Factory: allocate and return a new plugin state pointer.
RErr aborts plugin loading.
destroy: extern "C" fn(state: *mut c_void)Destructor: free the plugin state pointer. Called once at hub
shutdown or when a plugin fails post-create. MUST tolerate
being called with a state pointer that init() has not yet
observed.
init: extern "C" fn(state: *mut c_void, ctx: &PluginContext) -> RResult<(), RBoxError>Initialize the plugin. Called once after create and any
schema/validate pre-checks. RErr aborts plugin loading.
process: extern "C" fn(state: *const c_void, msg: &SpoeMessage) -> RResult<ProcessingResult, RBoxError>Handle one SPOE message. Called per request. The implementation
is wrapped in catch_unwind by the define_plugin! macro so a
panic does not abort the hub process.
name: extern "C" fn(state: *const c_void) -> RStr<'static>Plugin’s display name. Borrowed for the lifetime of the plugin
instance (until destroy is called). Plugins typically return
a &'static str literal.
plugin_version: extern "C" fn(state: *const c_void) -> RStr<'static>Plugin’s SemVer string. Same lifetime contract as name.
shutdown: extern "C" fn(state: *const c_void)Shutdown hook. Called once before destroy.
config_schema: extern "C" fn(state: *const c_void) -> ROption<RString>Optional JSON Schema string for config validation. RNone
skips schema validation. The default define_plugin! macro
emits a thunk that returns RNone when the plugin author has
not declared one.
validate: extern "C" fn(state: *const c_void, ctx: &PluginContext) -> RVec<Diagnostic>Deep config validation. Returns an empty RVec when the
plugin’s config is valid. Errors block loading; warnings are
surfaced but do not block.
set_metric_recorder: extern "C" fn(state: *mut c_void, record_fn: RecordMetricFn, ctx: *const c_void)Install the hub’s metric recorder on the plugin. Called by the
hub once between create and init, so the plugin can emit
metrics from init onward. The plugin stores the record_fn
and ctx (typically inside a MetricRecorder field of its
state) and invokes record_fn(ctx, ...) for every metric
event. The recorder remains valid until destroy returns; the
hub guarantees lifetime, the plugin guarantees not to call it
after destroy.
Plugins that don’t want metrics still need to provide a thunk
(the define_plugin! macro emits a no-op default) — the field
is unconditionally read on v2 hubs.
Host access: gated on api_version >= PLUGIN_API_VERSION_V2.
Reading this field on a v1 plugin’s vtable is UB — the v1
allocation does not include these bytes.
Implementations§
Source§impl PluginVTable
impl PluginVTable
Sourcepub unsafe fn read_api_version(vtable_ptr: *const PluginVTable) -> u32
pub unsafe fn read_api_version(vtable_ptr: *const PluginVTable) -> u32
Read just the api_version field of a plugin’s vtable.
§Safety
vtable_ptr must be a non-null pointer to a PluginVTable
allocation that is at least 4 bytes long (every plugin has at
least the api_version field).
Sourcepub unsafe fn read_set_metric_recorder(
vtable_ptr: *const PluginVTable,
) -> Option<extern "C" fn(state: *mut c_void, record_fn: RecordMetricFn, ctx: *const c_void)>
pub unsafe fn read_set_metric_recorder( vtable_ptr: *const PluginVTable, ) -> Option<extern "C" fn(state: *mut c_void, record_fn: RecordMetricFn, ctx: *const c_void)>
Read the v2 set_metric_recorder field, returning None for
plugins built against v1 (whose allocation doesn’t include it).
§Safety
vtable_ptr must be a non-null pointer to a PluginVTable
allocation produced by a published plugin (i.e. consistent with
the api_version field’s claim about which fields are present).
On v1 plugins this function reads only api_version and returns
None without touching past the v1 baseline.
Auto Trait Implementations§
impl Freeze for PluginVTable
impl RefUnwindSafe for PluginVTable
impl Send for PluginVTable
impl Sync for PluginVTable
impl Unpin for PluginVTable
impl UnsafeUnpin for PluginVTable
impl UnwindSafe for PluginVTable
Blanket Implementations§
Source§impl<T> AlignerFor<1> for T
impl<T> AlignerFor<1> for T
Source§impl<T> AlignerFor<1024> for T
impl<T> AlignerFor<1024> for T
Source§type Aligner = AlignTo1024<T>
type Aligner = AlignTo1024<T>
AlignTo* type which aligns Self to ALIGNMENT.Source§impl<T> AlignerFor<128> for T
impl<T> AlignerFor<128> for T
Source§type Aligner = AlignTo128<T>
type Aligner = AlignTo128<T>
AlignTo* type which aligns Self to ALIGNMENT.Source§impl<T> AlignerFor<16> for T
impl<T> AlignerFor<16> for T
Source§impl<T> AlignerFor<16384> for T
impl<T> AlignerFor<16384> for T
Source§type Aligner = AlignTo16384<T>
type Aligner = AlignTo16384<T>
AlignTo* type which aligns Self to ALIGNMENT.Source§impl<T> AlignerFor<2> for T
impl<T> AlignerFor<2> for T
Source§impl<T> AlignerFor<2048> for T
impl<T> AlignerFor<2048> for T
Source§type Aligner = AlignTo2048<T>
type Aligner = AlignTo2048<T>
AlignTo* type which aligns Self to ALIGNMENT.Source§impl<T> AlignerFor<256> for T
impl<T> AlignerFor<256> for T
Source§type Aligner = AlignTo256<T>
type Aligner = AlignTo256<T>
AlignTo* type which aligns Self to ALIGNMENT.Source§impl<T> AlignerFor<32> for T
impl<T> AlignerFor<32> for T
Source§impl<T> AlignerFor<32768> for T
impl<T> AlignerFor<32768> for T
Source§type Aligner = AlignTo32768<T>
type Aligner = AlignTo32768<T>
AlignTo* type which aligns Self to ALIGNMENT.Source§impl<T> AlignerFor<4> for T
impl<T> AlignerFor<4> for T
Source§impl<T> AlignerFor<4096> for T
impl<T> AlignerFor<4096> for T
Source§type Aligner = AlignTo4096<T>
type Aligner = AlignTo4096<T>
AlignTo* type which aligns Self to ALIGNMENT.Source§impl<T> AlignerFor<512> for T
impl<T> AlignerFor<512> for T
Source§type Aligner = AlignTo512<T>
type Aligner = AlignTo512<T>
AlignTo* type which aligns Self to ALIGNMENT.Source§impl<T> AlignerFor<64> for T
impl<T> AlignerFor<64> for T
Source§impl<T> AlignerFor<8> for T
impl<T> AlignerFor<8> for T
Source§impl<T> AlignerFor<8192> for T
impl<T> AlignerFor<8192> for T
Source§type Aligner = AlignTo8192<T>
type Aligner = AlignTo8192<T>
AlignTo* type which aligns Self to ALIGNMENT.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
Source§impl<T, W> HasTypeWitness<W> for Twhere
W: MakeTypeWitness<Arg = T>,
T: ?Sized,
impl<T, W> HasTypeWitness<W> for Twhere
W: MakeTypeWitness<Arg = T>,
T: ?Sized,
Source§impl<T> Identity for Twhere
T: ?Sized,
impl<T> Identity for Twhere
T: ?Sized,
Source§impl<S> ROExtAcc for S
impl<S> ROExtAcc for S
Source§fn f_get<F>(&self, offset: FieldOffset<S, F, Aligned>) -> &F
fn f_get<F>(&self, offset: FieldOffset<S, F, Aligned>) -> &F
offset. Read moreSource§fn f_get_mut<F>(&mut self, offset: FieldOffset<S, F, Aligned>) -> &mut F
fn f_get_mut<F>(&mut self, offset: FieldOffset<S, F, Aligned>) -> &mut F
offset. Read moreSource§fn f_get_ptr<F, A>(&self, offset: FieldOffset<S, F, A>) -> *const F
fn f_get_ptr<F, A>(&self, offset: FieldOffset<S, F, A>) -> *const F
offset. Read moreSource§fn f_get_mut_ptr<F, A>(&mut self, offset: FieldOffset<S, F, A>) -> *mut F
fn f_get_mut_ptr<F, A>(&mut self, offset: FieldOffset<S, F, A>) -> *mut F
offset. Read moreSource§impl<S> ROExtOps<Aligned> for S
impl<S> ROExtOps<Aligned> for S
Source§fn f_replace<F>(&mut self, offset: FieldOffset<S, F, Aligned>, value: F) -> F
fn f_replace<F>(&mut self, offset: FieldOffset<S, F, Aligned>, value: F) -> F
offset) with value,
returning the previous value of the field. Read moreSource§fn f_get_copy<F>(&self, offset: FieldOffset<S, F, Aligned>) -> Fwhere
F: Copy,
fn f_get_copy<F>(&self, offset: FieldOffset<S, F, Aligned>) -> Fwhere
F: Copy,
Source§impl<S> ROExtOps<Unaligned> for S
impl<S> ROExtOps<Unaligned> for S
Source§fn f_replace<F>(&mut self, offset: FieldOffset<S, F, Unaligned>, value: F) -> F
fn f_replace<F>(&mut self, offset: FieldOffset<S, F, Unaligned>, value: F) -> F
offset) with value,
returning the previous value of the field. Read moreSource§fn f_get_copy<F>(&self, offset: FieldOffset<S, F, Unaligned>) -> Fwhere
F: Copy,
fn f_get_copy<F>(&self, offset: FieldOffset<S, F, Unaligned>) -> Fwhere
F: Copy,
Source§impl<T> SelfOps for Twhere
T: ?Sized,
impl<T> SelfOps for Twhere
T: ?Sized,
Source§fn piped<F, U>(self, f: F) -> U
fn piped<F, U>(self, f: F) -> U
Source§fn piped_ref<'a, F, U>(&'a self, f: F) -> Uwhere
F: FnOnce(&'a Self) -> U,
fn piped_ref<'a, F, U>(&'a self, f: F) -> Uwhere
F: FnOnce(&'a Self) -> U,
piped except that the function takes &Self
Useful for functions that take &Self instead of Self. Read moreSource§fn piped_mut<'a, F, U>(&'a mut self, f: F) -> Uwhere
F: FnOnce(&'a mut Self) -> U,
fn piped_mut<'a, F, U>(&'a mut self, f: F) -> Uwhere
F: FnOnce(&'a mut Self) -> U,
piped, except that the function takes &mut Self.
Useful for functions that take &mut Self instead of Self.Source§fn mutated<F>(self, f: F) -> Self
fn mutated<F>(self, f: F) -> Self
Source§fn observe<F>(self, f: F) -> Self
fn observe<F>(self, f: F) -> Self
Source§fn as_ref_<T>(&self) -> &T
fn as_ref_<T>(&self) -> &T
AsRef,
using the turbofish .as_ref_::<_>() syntax. Read more