feat: re-export 'retry' in common connector crate (#2922)

infinyon · Jan 11, 2023 · ae47fe0 · ae47fe0 · github-actions · Jan 11, 2023
1 parent 0b4486a
commit ae47fe0
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 2 deletions.
diff --git a/crates/fluvio-connector-common/src/lib.rs b/crates/fluvio-connector-common/src/lib.rs
@@ -17,6 +17,7 @@ pub type Result<T> = std::result::Result<T, Error>;
 pub mod future {
     pub use fluvio_future::task::run_block_on;
     pub use fluvio_future::subscriber::init_logger;
+    pub use fluvio_future::retry;
 }
 
 pub mod tracing {

diff --git a/crates/fluvio-connector-derive/src/generator.rs b/crates/fluvio-connector-derive/src/generator.rs
@@ -113,7 +113,7 @@ pub(crate) fn generate_connector_config(item: &ConnectorConfigStruct) -> TokenSt
         #config_struct
 
         impl #ident {
-            fn __config_name() -> &'static str {
+            pub fn __config_name() -> &'static str {
                 #config_name
             }
         }

diff --git a/crates/fluvio/src/producer/config.rs b/crates/fluvio/src/producer/config.rs
@@ -228,7 +228,7 @@ impl Iterator for RetryPolicyIter {
 }
 
 impl RetryPolicy {
-    pub(crate) fn iter(&self) -> impl Iterator<Item = Duration> + Debug + Send {
+    pub fn iter(&self) -> impl Iterator<Item = Duration> + Debug + Send {
         match self.strategy {
             RetryStrategy::FixedDelay => {
                 RetryPolicyIter::FixedDelay(FixedDelay::new(self.initial_delay))
Benchmark suite	Current: `ae47fe0`	Previous: `0b4486a`	Ratio
`vecu8 encoding`	`326470` ns/iter (`± 738881`)	`336571` ns/iter (`± 765963`)	`0.97`
`vecu8 decoding`	`446838` ns/iter (`± 270`)	`622099` ns/iter (`± 3998`)	`0.72`
`bytebuf encoding`	`7161` ns/iter (`± 60`)	`7669` ns/iter (`± 3`)	`0.93`
`bytebuf decoding`	`7041` ns/iter (`± 85`)	`7602` ns/iter (`± 31`)	`0.93`