fix: Remove namespace argument from write test helper fn
Carol (Nichols || Goulding)
parent
c27d3a22d2
commit
5854ff28e9
|
|
@ -392,7 +392,6 @@ pub mod test_utils {
|
|||
|
||||
/// Writes line protocol and returns the [`DmlWrite`] that was written.
|
||||
pub async fn write(
|
||||
_namespace: &str,
|
||||
writer: &impl WriteBufferWriting,
|
||||
lp: &str,
|
||||
shard_index: ShardIndex,
|
||||
|
|
@ -453,7 +452,6 @@ pub mod test_utils {
|
|||
|
||||
// adding content allows us to get results
|
||||
let w1 = write(
|
||||
"namespace",
|
||||
&writer,
|
||||
entry_1,
|
||||
shard_index,
|
||||
|
|
@ -469,7 +467,6 @@ pub mod test_utils {
|
|||
|
||||
// adding more data unblocks the stream
|
||||
let w2 = write(
|
||||
"namespace",
|
||||
&writer,
|
||||
entry_2,
|
||||
shard_index,
|
||||
|
|
@ -478,7 +475,6 @@ pub mod test_utils {
|
|||
)
|
||||
.await;
|
||||
let w3 = write(
|
||||
"namespace",
|
||||
&writer,
|
||||
entry_3,
|
||||
shard_index,
|
||||
|
|
@ -516,7 +512,6 @@ pub mod test_utils {
|
|||
let shard_index = ShardIndex::new(0);
|
||||
|
||||
let w1 = write(
|
||||
"namespace",
|
||||
&writer,
|
||||
entry_1,
|
||||
shard_index,
|
||||
|
|
@ -525,7 +520,6 @@ pub mod test_utils {
|
|||
)
|
||||
.await;
|
||||
let w2 = write(
|
||||
"namespace",
|
||||
&writer,
|
||||
entry_2,
|
||||
shard_index,
|
||||
|
|
@ -534,7 +528,6 @@ pub mod test_utils {
|
|||
)
|
||||
.await;
|
||||
let w3 = write(
|
||||
"namespace",
|
||||
&writer,
|
||||
entry_3,
|
||||
shard_index,
|
||||
|
|
@ -609,7 +602,6 @@ pub mod test_utils {
|
|||
|
||||
// entries arrive at the right target stream
|
||||
let w1 = write(
|
||||
"namespace",
|
||||
&writer,
|
||||
entry_1,
|
||||
shard_index_1,
|
||||
|
|
@ -621,7 +613,6 @@ pub mod test_utils {
|
|||
assert_stream_pending(&mut stream_2).await;
|
||||
|
||||
let w2 = write(
|
||||
"namespace",
|
||||
&writer,
|
||||
entry_2,
|
||||
shard_index_2,
|
||||
|
|
@ -633,7 +624,6 @@ pub mod test_utils {
|
|||
assert_write_op_eq(&stream_2.next().await.unwrap().unwrap(), &w2);
|
||||
|
||||
let w3 = write(
|
||||
"namespace",
|
||||
&writer,
|
||||
entry_3,
|
||||
shard_index_1,
|
||||
|
|
@ -680,7 +670,6 @@ pub mod test_utils {
|
|||
let shard_index_2 = set_pop_first(&mut shard_indexes_1).unwrap();
|
||||
|
||||
let w_east_1 = write(
|
||||
"namespace",
|
||||
&writer_1,
|
||||
entry_east_1,
|
||||
shard_index_1,
|
||||
|
|
@ -689,7 +678,6 @@ pub mod test_utils {
|
|||
)
|
||||
.await;
|
||||
let w_west_1 = write(
|
||||
"namespace",
|
||||
&writer_1,
|
||||
entry_west_1,
|
||||
shard_index_2,
|
||||
|
|
@ -698,7 +686,6 @@ pub mod test_utils {
|
|||
)
|
||||
.await;
|
||||
let w_east_2 = write(
|
||||
"namespace",
|
||||
&writer_2,
|
||||
entry_east_2,
|
||||
shard_index_1,
|
||||
|
|
@ -744,7 +731,6 @@ pub mod test_utils {
|
|||
let shard_index_2 = set_pop_first(&mut shard_indexes).unwrap();
|
||||
|
||||
let w_east_1 = write(
|
||||
"namespace",
|
||||
&writer,
|
||||
entry_east_1,
|
||||
shard_index_1,
|
||||
|
|
@ -753,7 +739,6 @@ pub mod test_utils {
|
|||
)
|
||||
.await;
|
||||
let w_east_2 = write(
|
||||
"namespace",
|
||||
&writer,
|
||||
entry_east_2,
|
||||
shard_index_1,
|
||||
|
|
@ -762,7 +747,6 @@ pub mod test_utils {
|
|||
)
|
||||
.await;
|
||||
let w_west_1 = write(
|
||||
"namespace",
|
||||
&writer,
|
||||
entry_west_1,
|
||||
shard_index_2,
|
||||
|
|
@ -811,7 +795,6 @@ pub mod test_utils {
|
|||
);
|
||||
|
||||
let w_east_3 = write(
|
||||
"namespace",
|
||||
&writer,
|
||||
entry_east_3,
|
||||
ShardIndex::new(0),
|
||||
|
|
@ -854,7 +837,6 @@ pub mod test_utils {
|
|||
let shard_index_1 = set_pop_first(&mut shard_indexes).unwrap();
|
||||
|
||||
let w_east_1 = write(
|
||||
"namespace",
|
||||
&writer,
|
||||
entry_east_1,
|
||||
shard_index_1,
|
||||
|
|
@ -863,7 +845,6 @@ pub mod test_utils {
|
|||
)
|
||||
.await;
|
||||
let w_east_2 = write(
|
||||
"namespace",
|
||||
&writer,
|
||||
entry_east_2,
|
||||
shard_index_1,
|
||||
|
|
@ -927,7 +908,6 @@ pub mod test_utils {
|
|||
|
||||
// high water mark moves
|
||||
write(
|
||||
"namespace",
|
||||
&writer,
|
||||
entry_east_1,
|
||||
shard_index_1,
|
||||
|
|
@ -936,7 +916,6 @@ pub mod test_utils {
|
|||
)
|
||||
.await;
|
||||
let w1 = write(
|
||||
"namespace",
|
||||
&writer,
|
||||
entry_east_2,
|
||||
shard_index_1,
|
||||
|
|
@ -945,7 +924,6 @@ pub mod test_utils {
|
|||
)
|
||||
.await;
|
||||
let w2 = write(
|
||||
"namespace",
|
||||
&writer,
|
||||
entry_west_1,
|
||||
shard_index_2,
|
||||
|
|
@ -989,7 +967,6 @@ pub mod test_utils {
|
|||
let shard_index = set_pop_first(&mut shard_indexes).unwrap();
|
||||
|
||||
let write = write(
|
||||
"namespace",
|
||||
&writer,
|
||||
entry,
|
||||
shard_index,
|
||||
|
|
@ -1039,7 +1016,6 @@ pub mod test_utils {
|
|||
// Two ops with the same partition keys, first write at time 100
|
||||
time_provider.set(time_provider.inc(Duration::from_millis(100)));
|
||||
write(
|
||||
"ns1",
|
||||
&writer,
|
||||
"table foo=1",
|
||||
shard_index,
|
||||
|
|
@ -1051,7 +1027,6 @@ pub mod test_utils {
|
|||
// second write @ time 200
|
||||
time_provider.set(time_provider.inc(Duration::from_millis(100)));
|
||||
write(
|
||||
"ns1",
|
||||
&writer,
|
||||
"table foo=1",
|
||||
shard_index,
|
||||
|
|
@ -1063,7 +1038,6 @@ pub mod test_utils {
|
|||
// third write @ time 300
|
||||
time_provider.set(time_provider.inc(Duration::from_millis(100)));
|
||||
write(
|
||||
"ns1",
|
||||
&writer,
|
||||
"table foo=1",
|
||||
shard_index,
|
||||
|
|
@ -1185,7 +1159,6 @@ pub mod test_utils {
|
|||
|
||||
// 1: no context
|
||||
write(
|
||||
"namespace",
|
||||
&writer,
|
||||
entry,
|
||||
shard_index,
|
||||
|
|
@ -1205,7 +1178,6 @@ pub mod test_utils {
|
|||
// 2: some context
|
||||
let span_context_1 = SpanContext::new(Arc::clone(&collector) as Arc<_>);
|
||||
write(
|
||||
"namespace",
|
||||
&writer,
|
||||
entry,
|
||||
shard_index,
|
||||
|
|
@ -1218,7 +1190,6 @@ pub mod test_utils {
|
|||
let span_context_parent = SpanContext::new(Arc::clone(&collector) as Arc<_>);
|
||||
let span_context_2 = span_context_parent.child("foo").ctx;
|
||||
write(
|
||||
"namespace",
|
||||
&writer,
|
||||
entry,
|
||||
shard_index,
|
||||
|
|
@ -1292,7 +1263,6 @@ pub mod test_utils {
|
|||
let shard_index = set_pop_first(&mut shard_indexes).unwrap();
|
||||
|
||||
let w1 = write(
|
||||
"namespace_1",
|
||||
&writer,
|
||||
entry_2,
|
||||
shard_index,
|
||||
|
|
@ -1301,7 +1271,6 @@ pub mod test_utils {
|
|||
)
|
||||
.await;
|
||||
let w2 = write(
|
||||
"namespace_2",
|
||||
&writer,
|
||||
entry_1,
|
||||
shard_index,
|
||||
|
|
@ -1335,7 +1304,6 @@ pub mod test_utils {
|
|||
let entry = format!("upc,region=east user={} {}", i, i);
|
||||
|
||||
write(
|
||||
"ns",
|
||||
writer.as_ref(),
|
||||
&entry,
|
||||
shard_index,
|
||||
|
|
|
|||
|
|
@ -848,7 +848,6 @@ mod tests {
|
|||
let entry_4 = "upc,region=east user=4 400";
|
||||
|
||||
let w1 = write(
|
||||
&ctx.database_name,
|
||||
&writer,
|
||||
entry_1,
|
||||
shard_index,
|
||||
|
|
@ -857,7 +856,6 @@ mod tests {
|
|||
)
|
||||
.await;
|
||||
let w2 = write(
|
||||
&ctx.database_name,
|
||||
&writer,
|
||||
entry_2,
|
||||
shard_index,
|
||||
|
|
@ -866,7 +864,6 @@ mod tests {
|
|||
)
|
||||
.await;
|
||||
let w3 = write(
|
||||
&ctx.database_name,
|
||||
&writer,
|
||||
entry_3,
|
||||
shard_index,
|
||||
|
|
@ -875,7 +872,6 @@ mod tests {
|
|||
)
|
||||
.await;
|
||||
let w4 = write(
|
||||
&ctx.database_name,
|
||||
&writer,
|
||||
entry_4,
|
||||
shard_index,
|
||||
|
|
@ -918,7 +914,6 @@ mod tests {
|
|||
let entry_2 = "upc,region=east user=2 200";
|
||||
|
||||
let w1 = write(
|
||||
&ctx.database_name,
|
||||
&writer,
|
||||
entry_1,
|
||||
shard_index,
|
||||
|
|
@ -927,7 +922,6 @@ mod tests {
|
|||
)
|
||||
.await;
|
||||
let w2 = write(
|
||||
&ctx.database_name,
|
||||
&writer,
|
||||
entry_2,
|
||||
shard_index,
|
||||
|
|
|
|||
|
|
@ -698,7 +698,6 @@ mod tests {
|
|||
.await
|
||||
.unwrap();
|
||||
let w = crate::core::test_utils::write(
|
||||
"namespace",
|
||||
&producer,
|
||||
"table foo=1 1",
|
||||
shard_index,
|
||||
|
|
|
|||
Loading…
Reference in New Issue