From 9544d8ab5065657cb035cbf39a89f06d39e2e391 Mon Sep 17 00:00:00 2001 From: Andrew Ayer Date: Wed, 21 May 2025 14:59:51 -0400 Subject: [PATCH] Imprve comment --- monitor/monitor.go | 8 +++++++- 1 file changed, 7 insertions(+), 1 deletion(-) diff --git a/monitor/monitor.go b/monitor/monitor.go index 14cad2e..ab62715 100644 --- a/monitor/monitor.go +++ b/monitor/monitor.go @@ -269,7 +269,13 @@ func monitorLogContinously(ctx context.Context, config *Config, ctlog *loglist.L retry: position := state.DownloadPosition.Size() - // generateBatchesWorker ==> downloadWorker ==> processWorker ==> saveStateWorker + // logs are monitored using the following pipeline of workers, with each worker sending results to the next worker: + // 1 getSTHWorker ==> 1 generateBatchesWorker ==> multiple downloadWorkers ==> multiple processWorkers ==> 1 saveStateWorker + // getSTHWorker - periodically download STHs from the log + // generateBatchesWorker - generate batches of work + // downloadWorkers - download the entries in each batch + // processWorkers - process the certificates (store/notify if matches watch list) in each batch + // saveStateWorker - builds the Merkle Tree and compares against STHs sths := make(chan *cttypes.SignedTreeHead, 1) batches := make(chan *batch, downloadWorkers(ctlog))