Type Alias fluvio_spu_schema::produce::DefaultProduceRequest

source · 
pub type DefaultProduceRequest = ProduceRequest<RecordSet<RawRecords>>;

Aliased Type§

struct DefaultProduceRequest {
    pub transactional_id: Option<String>,
    pub isolation: Isolation,
    pub timeout: Duration,
    pub topics: Vec<TopicProduceData<RecordSet<RawRecords>>>,
    pub smartmodules: Vec<SmartModuleInvocation>,
    pub data: PhantomData<RecordSet<RawRecords>>,
}

Fields§

§transactional_id: Option<String>

The transactional ID, or null if the producer is not transactional.

§isolation: Isolation

ReadUncommitted - Just wait for leader to write message (only wait for LEO update). ReadCommitted - Wait for messages to be committed (wait for HW).

§timeout: Duration

The timeout to await a response.

§topics: Vec<TopicProduceData<RecordSet<RawRecords>>>

Each topic to produce to.

§smartmodules: Vec<SmartModuleInvocation>§data: PhantomData<RecordSet<RawRecords>>