rename symbols

Author: john-z-yang

src/consumer/deserialize_activation.rs

@@ -8,13 +8,11 @@ use sentry_protos::sentry::v1::TaskActivation;
 
 use crate::inflight_activation_store::{InflightActivation, TaskActivationStatus};
 
-pub struct DeserializerConfig {
+pub struct Config {
     pub deadletter_duration: Option<Duration>,
 }
 
-pub fn new(
-    config: DeserializerConfig,
-) -> impl Fn(Arc<OwnedMessage>) -> Result<InflightActivation, Error> {
+pub fn new(config: Config) -> impl Fn(Arc<OwnedMessage>) -> Result<InflightActivation, Error> {
     move |msg: Arc<OwnedMessage>| {
         let Some(payload) = msg.payload() else {
             return Err(anyhow!("Message has no payload"));

src/consumer/inflight_activation_writer.rs

@@ -9,22 +9,22 @@ use super::kafka::{
     ReducerWhenFullBehaviour,
 };
 
-pub struct InflightTaskWriterConfig {
+pub struct Config {
     pub max_buf_len: usize,
     pub max_pending_tasks: usize,
     pub flush_interval: Option<Duration>,
     pub when_full_behaviour: ReducerWhenFullBehaviour,
     pub shutdown_behaviour: ReduceShutdownBehaviour,
 }
 
-pub struct InflightTaskWriter {
+pub struct InflightActivationWriter {
     store: Arc<InflightActivationStore>,
     buffer: Vec<InflightActivation>,
-    config: InflightTaskWriterConfig,
+    config: Config,
 }
 
-impl InflightTaskWriter {
-    pub fn new(store: Arc<InflightActivationStore>, config: InflightTaskWriterConfig) -> Self {
+impl InflightActivationWriter {
+    pub fn new(store: Arc<InflightActivationStore>, config: Config) -> Self {
         Self {
             store,
             buffer: Vec::with_capacity(config.max_buf_len),
@@ -33,7 +33,7 @@ impl InflightTaskWriter {
     }
 }
 
-impl Reducer for InflightTaskWriter {
+impl Reducer for InflightActivationWriter {
     type Input = InflightActivation;
 
     type Output = ();

src/main.rs

@@ -3,8 +3,8 @@ use std::{sync::Arc, time::Duration};
 use anyhow::Error;
 use chrono::Utc;
 use consumer::{
-    deserialize_activation::{self, DeserializerConfig},
-    inflight_activation_writer::{InflightTaskWriter, InflightTaskWriterConfig},
+    deserialize_activation::{self},
+    inflight_activation_writer::{self, InflightActivationWriter},
     kafka::{start_consumer, ReduceShutdownBehaviour, ReducerWhenFullBehaviour},
     os_stream_writer::{OsStream, OsStreamWriter},
 };
@@ -47,13 +47,13 @@ async fn main() -> Result<(), Error> {
             .set("enable.auto.offset.store", "false")
             .set_log_level(RDKafkaLogLevel::Debug),
         processing_strategy!({
-            map: deserialize_activation::new(DeserializerConfig {
+            map: deserialize_activation::new(deserialize_activation::Config {
                 deadletter_duration,
             }),
 
-            reduce: InflightTaskWriter::new(
+            reduce: InflightActivationWriter::new(
                 store.clone(),
-                InflightTaskWriterConfig {
+                inflight_activation_writer::Config {
                     max_buf_len: 128,
                     max_pending_tasks: 2048,
                     flush_interval: None,