Skip to content

Commit 3528fc1

Browse files
authored
chore(transforms): Move TransformOutputsBuf functions out of test flag (#23116)
* chore(remap transform) Move take_primary() outside of test flag * chore(remap transform): Remove other take/drain functions from the test FF * fix: also remove called function from test FF
1 parent bb6a914 commit 3528fc1

File tree

1 file changed

+0
-5
lines changed
  • lib/vector-core/src/transform

1 file changed

+0
-5
lines changed

lib/vector-core/src/transform/mod.rs

Lines changed: 0 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -376,7 +376,6 @@ impl TransformOutputsBuf {
376376
/// # Panics
377377
///
378378
/// Panics if there is no default output.
379-
#[cfg(any(feature = "test", test))]
380379
pub fn drain(&mut self) -> impl Iterator<Item = Event> + '_ {
381380
self.primary_buffer
382381
.as_mut()
@@ -389,7 +388,6 @@ impl TransformOutputsBuf {
389388
/// # Panics
390389
///
391390
/// Panics if there is no output with the given name.
392-
#[cfg(any(feature = "test", test))]
393391
pub fn drain_named(&mut self, name: &str) -> impl Iterator<Item = Event> + '_ {
394392
self.named_buffers
395393
.get_mut(name)
@@ -402,12 +400,10 @@ impl TransformOutputsBuf {
402400
/// # Panics
403401
///
404402
/// Panics if there is no default output.
405-
#[cfg(any(feature = "test", test))]
406403
pub fn take_primary(&mut self) -> OutputBuffer {
407404
std::mem::take(self.primary_buffer.as_mut().expect("no default output"))
408405
}
409406

410-
#[cfg(any(feature = "test", test))]
411407
pub fn take_all_named(&mut self) -> HashMap<String, OutputBuffer> {
412408
std::mem::take(&mut self.named_buffers)
413409
}
@@ -482,7 +478,6 @@ impl OutputBuffer {
482478
})
483479
}
484480

485-
#[cfg(any(feature = "test", test))]
486481
pub fn drain(&mut self) -> impl Iterator<Item = Event> + '_ {
487482
self.0.drain(..).flat_map(EventArray::into_events)
488483
}

0 commit comments

Comments
 (0)