Merge pull request paritytech#4 from availproject/marko/extend-custom…

…-telemetry Marko/extend custom telemetry
Mind-Crypt · May 14, 2024 · b8f49aa · b8f49aa
2 parents bd728ff + 1c4ef5f
commit b8f49aa
Show file tree

Hide file tree

Showing 2 changed files with 312 additions and 36 deletions.
diff --git a/substrate/bin/node-template/node/src/service.rs b/substrate/bin/node-template/node/src/service.rs
@@ -63,10 +63,16 @@ pub fn new_partial(config: &Configuration) -> Result<Service, ServiceError> {
 	});
 
 	let telemetry_handle = telemetry.as_ref().map(|t| t.handle());
-	let custom_telemetry_worker = CustomTelemetryWorker { handle: telemetry_handle, sampling_interval_ms: 6_000u128 };
+	let custom_telemetry_worker = CustomTelemetryWorker 
+	{ 
+		handle: telemetry_handle, 
+		sampling_interval_ms: 6_000u128,
+		max_interval_buffer_size: 20,
+		max_block_request_buffer_size: 15,
+	};
 	task_manager
 		.spawn_handle()
-		.spawn("custom_telemetry", None, custom_telemetry_worker.run());
+		.spawn("custom_telemetry", None, custom_telemetry_worker.run(None, None));
 
 	let select_chain = sc_consensus::LongestChain::new(backend.clone());