Interface Processor

src/processor.rs:9–18 · view source on GitHub ↗

Source from the content-addressed store, hash-verified

7
8	#[async_trait]
9	pub trait Processor<Input, Output> {
10
11	async fn init(&mut self);
12
13	/// if return ProcResult::Dispatch
14	/// and Dispatcher is Partition must set batch_key
15	async fn handle_message(&mut self, msg: Input) -> ProcResult<Output>;
16
17	async fn terminate(&mut self);
18	}
19
20
21

nothing calls this directly

pulsar_processor.rssrc/builtin/pulsar_processor.rs

kafka_processor.rssrc/builtin/kafka_processor.rs

complex(2 layer).rsexamples/complex(2 layer).rs

batch_insert_mysql.rsexamples/batch_insert_mysql.rs

simple(1 layer).rsexamples/simple(1 layer).rs

kafka_processor_complex.rsexamples/kafka_processor_complex.rs

dynamic_batching.rsexamples/dynamic_batching.rs

pulsar_batcher.rsexamples/pulsar_batcher.rs

kafka_producer.rsexamples/kafka_producer.rs

pulsar_producer.rsexamples/pulsar_producer.rs

complex(3 layer).rsexamples/complex(3 layer).rs

collector.rsexamples/collector.rs

no outgoing calls

no test coverage detected