Influxdata
/
influxdb
mirror of https://github.com/influxdata/influxdb.git
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

fix: Rename another sequencer to shard to be hopefully clearer

pull/24376/head
Carol (Nichols || Goulding) 2022-08-19 15:17:02 -04:00
parent f6c93f7e67
commit fbae4282df
No known key found for this signature in database
GPG Key ID: E907EE5A736F87D4
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
ingester/src/handler.rs
View File

@ -134,7 +134,7 @@ impl IngestHandlerImpl {
pub async fn new(
lifecycle_config: LifecycleConfig,
topic: KafkaTopic,
sequencer_states: BTreeMap<KafkaPartition, Shard>, // XXXJPG
shard_states: BTreeMap<KafkaPartition, Shard>,
catalog: Arc<dyn Catalog>,
object_store: Arc<DynObjectStore>,
write_buffer: Arc<dyn WriteBufferReading>,
@ -145,7 +145,7 @@ impl IngestHandlerImpl {
) -> Result<Self> {
// build the initial ingester data state
let mut shards = BTreeMap::new();
for s in sequencer_states.values() {
for s in shard_states.values() {
shards.insert(
s.id,
ShardData::new(s.kafka_partition, Arc::clone(&metric_registry)),
@ -183,10 +183,10 @@ impl IngestHandlerImpl {
lifecycle_config
);
let mut join_handles = Vec::with_capacity(sequencer_states.len() + 1);
let mut join_handles = Vec::with_capacity(shard_states.len() + 1);
join_handles.push(("lifecycle manager".to_owned(), shared_handle(handle)));
for (kafka_partition, shard) in sequencer_states {
for (kafka_partition, shard) in shard_states {
let metric_registry = Arc::clone(&metric_registry);
// Acquire a write buffer stream and seek it to the last