use fluvio_protocol::{
Encoder, Decoder,
record::Record,
link::smartmodule::{
SmartModuleTransformRuntimeError, SmartModuleInitRuntimeError,
SmartModuleLookbackRuntimeError,
},
};
#[derive(Debug, Default, Encoder, Decoder)]
pub struct SmartModuleOutput {
pub successes: Vec<Record>,
pub error: Option<SmartModuleTransformRuntimeError>,
}
impl SmartModuleOutput {
pub fn new(successes: Vec<Record>) -> Self {
Self {
successes,
error: None,
}
}
pub fn with_error(
successes: Vec<Record>,
error: Option<SmartModuleTransformRuntimeError>,
) -> Self {
Self { successes, error }
}
}
#[derive(Debug, Default, Encoder, Decoder)]
pub struct SmartModuleAggregateOutput {
pub base: SmartModuleOutput,
#[fluvio(min_version = 16)]
pub accumulator: Vec<u8>,
}
impl SmartModuleAggregateOutput {
pub fn new(base: SmartModuleOutput, accumulator: Vec<u8>) -> Self {
Self { base, accumulator }
}
}
#[derive(Debug, Default, Encoder, Decoder)]
pub struct SmartModuleInitOutput {
pub error: SmartModuleInitRuntimeError,
}
#[derive(Debug, Default, Encoder, Decoder)]
pub struct SmartModuleLookbackOutput {
pub error: SmartModuleLookbackRuntimeError,
}