Module fluvio 

Available on crate feature fluvio only.

Fluvio is a real-time streaming data transformation platform.

This module provides a Fluvio loader for Swiftide and allows you to ingest messages from Fluvio topics and use them for RAG.

Can be configured with ConsumerConfigExt.

Example

let loader = Fluvio::builder()
    .consumer_config_ext(
        ConsumerConfigExt::builder()
            .topic("Hello Fluvio")
            .partition(0)
            .offset_start(fluvio::Offset::from_end(1))
            .build().unwrap()
    ).build().unwrap();

Structs

ConsumerConfigExt

Re-export the fluvio config builder

ConsumerConfigExtBuilder

Re-export the fluvio config builder Builder for ConsumerConfigExt.

Fluvio

FluvioBuilder

Builder for Fluvio.

Enums

FluvioBuilderError

Error type for FluvioBuilder