Type Alias OpaqueStreamingAgg 

pub type OpaqueStreamingAgg = LazySerde<SpecialEq<Arc<dyn AnonymousStreamingAgg>>>;

Aliased Type

pub enum OpaqueStreamingAgg {
    Deserialized(SpecialEq<Arc<dyn AnonymousStreamingAgg>>),
    Bytes(Bytes),
    Named {
        name: String,
        payload: Option<Bytes>,
        value: Option<SpecialEq<Arc<dyn AnonymousStreamingAgg>>>,
    },
}

Variants

Deserialized(SpecialEq<Arc<dyn AnonymousStreamingAgg>>)

Bytes(Bytes)

Named

Named functions allow for serializing arbitrary Rust functions as long as both sides know ahead of time which function it is. There is a registry of functions that both sides know and every time we need serialize we serialize the function by name in the registry.

Used by cloud.

Fields

name: String

payload: Option<Bytes>

value: Option<SpecialEq<Arc<dyn AnonymousStreamingAgg>>>