Struct PluginResult 

#[repr(C)]
pub struct PluginResult {
    pub execution_future: FfiFuture<RResult<(), RString>>,
    pub output_schema: ROption<SafeArrowSchema>,
    pub labels: RVec<PluginLabel>,
}

Fields

execution_future: FfiFuture<RResult<(), RString>>

Future that resolves when the plugin has finished execution.

ROk(()) => graceful termination RErr(message) => error termination

output_schema: ROption<SafeArrowSchema>

Expected to be defined for sources and transforms, but not for sinks.

labels: RVec<PluginLabel>

Identity labels the plugin declares for this instance. The plugin decides the set from its options; consumers (starting with the metrics subsystem) read the same field. Empty for plugins that don’t opt in. See PluginLabel.

Implementations

impl PluginResult

pub fn new( execution_future: FfiFuture<RResult<(), RString>>, output_schema: ROption<SafeArrowSchema>, ) -> Self

pub fn with_labels(self, labels: Vec<PluginLabel>) -> Self

Attach plugin-declared identity labels to this result. Typically chained onto PluginResult::new; the host merges these labels into metric metadata so every metric the plugin instance emits carries them as Prometheus labels.

PluginResult::new(execution_future, output_schema).with_labels(vec![
    PluginLabel::new("chain_slug", options.chain.clone()),
    PluginLabel::new("topic", options.topic.clone()),
])

Trait Implementations

impl GetStaticEquivalent_ for PluginResult

type StaticEquivalent = _static_PluginResult

The 'static equivalent of Self

impl StableAbi for PluginResult

const LAYOUT: &'static TypeLayout

The layout of the type provided by implementors.

type IsNonZeroType = False

Whether this type has a single invalid bit-pattern.

const ABI_CONSTS: AbiConsts = _

const-equivalents of the associated types.