Crate fluvio

Re-exports

• pub use config::FluvioConfig;
• pub use consumer::PartitionConsumer;
• pub use consumer::ConsumerConfig;
• pub use consumer::MultiplePartitionConsumer;
• pub use consumer::PartitionSelectionStrategy;

Modules

• config
• consumer
• dataplane
• metadata
  re-export metadata from sc-api
• metrics
• spu

Structs

• Fluvio
  An interface for interacting with Fluvio streaming
• FluvioAdmin
  An interface for managing a Fluvio cluster
• FutureRecordMetadata
  Output of TopicProducer::send Used to wait the RecordMetadata of the record being sent. See FutureRecordMetadata::wait
• Offset
  Describes the location of an event stored in a Fluvio partition
• PartitionerConfig
• ProduceOutput
  Struct returned by of TopicProduce::send call, it is used to gather the record metadata associated to each send call.
• RecordKey
  A key for determining which partition a record should be sent to.
• RecordMetadata
  Metadata of a record send to a topic
• RetryPolicy
  Defines parameters of retries in DeliverySemantic::AtLeastOnce delivery semantic.
• SmartModuleExtraParams
• SmartModuleInvocation
  The request payload when using a Consumer SmartModule.
• TopicProducer
  An interface for producing events to a particular topic
• TopicProducerConfig
  Options used to adjust the behavior of the Producer. Create this struct with TopicProducerConfigBuilder.
• TopicProducerConfigBuilder
  Builder for TopicProducerConfig.

Enums

• Compression
  The compression algorithm used to compress and decompress records in fluvio batches
• DeliverySemantic
  Defines guarantees that Producer must follow delivering records to SPU.
• FluvioError
  Possible errors that may arise when using Fluvio
• Isolation
• ProducerError
• RetryStrategy
  Strategy of delays distribution.
• SmartModuleContextData
• SmartModuleInvocationWasm
• SmartModuleKind
  Indicates the type of SmartModule as well as any special data required

Traits

• Partitioner
  A trait for defining a partitioning strategy for key/value records.

Functions

• consumer
  Creates a producer that receives events from the given topic and partition
• producer
  Creates a producer that sends records to the named topic