zksync_protobuf_config 0.1.0

Protobuf deserialization for ZKsync configs
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88

use anyhow::Context as _;
use zksync_config::configs;
use zksync_protobuf::{repr::ProtoRepr, required};

use crate::proto::house_keeper as proto;

impl ProtoRepr for proto::HouseKeeper {
    type Type = configs::house_keeper::HouseKeeperConfig;
    fn read(&self) -> anyhow::Result<Self::Type> {
        Ok(Self::Type {
            l1_batch_metrics_reporting_interval_ms: *required(
                &self.l1_batch_metrics_reporting_interval_ms,
            )
            .context("l1_batch_metrics_reporting_interval_ms")?,
            gpu_prover_queue_reporting_interval_ms: *required(
                &self.gpu_prover_queue_reporting_interval_ms,
            )
            .context("gpu_prover_queue_reporting_interval_ms")?,
            prover_job_retrying_interval_ms: *required(&self.prover_job_retrying_interval_ms)
                .context("prover_job_retrying_interval_ms")?,
            prover_stats_reporting_interval_ms: *required(&self.prover_stats_reporting_interval_ms)
                .context("prover_stats_reporting_interval_ms")?,
            witness_job_moving_interval_ms: *required(&self.witness_job_moving_interval_ms)
                .context("witness_job_moving_interval_ms")?,
            witness_generator_stats_reporting_interval_ms: *required(
                &self.witness_generator_stats_reporting_interval_ms,
            )
            .context("witness_generator_stats_reporting_interval_ms")?,
            prover_db_pool_size: *required(&self.prover_db_pool_size)
                .context("prover_db_pool_size")?,
            proof_compressor_job_retrying_interval_ms: *required(
                &self.proof_compressor_job_retrying_interval_ms,
            )
            .context("proof_compressor_job_retrying_interval_ms")?,
            witness_generator_job_retrying_interval_ms: *required(
                &self.witness_generator_job_retrying_interval_ms,
            )
            .context("witness_generator_job_retrying_interval_ms")?,
            proof_compressor_stats_reporting_interval_ms: *required(
                &self.proof_compressor_stats_reporting_interval_ms,
            )
            .context("proof_compressor_stats_reporting_interval_ms")?,

            // TODO(PLA-862): Make these 2 variables required
            prover_job_archiver_archiving_interval_ms: self
                .prover_job_archiver_archiving_interval_ms,
            prover_job_archiver_archive_after_secs: self.prover_job_archiver_archive_after_secs,
            fri_gpu_prover_archiver_archiving_interval_ms: self
                .fri_gpu_prover_archiver_archiving_interval_ms,
            fri_gpu_prover_archiver_archive_after_secs: self
                .fri_gpu_prover_archiver_archive_after_secs,
        })
    }

    fn build(this: &Self::Type) -> Self {
        Self {
            l1_batch_metrics_reporting_interval_ms: Some(
                this.l1_batch_metrics_reporting_interval_ms,
            ),
            gpu_prover_queue_reporting_interval_ms: Some(
                this.gpu_prover_queue_reporting_interval_ms,
            ),
            prover_job_retrying_interval_ms: Some(this.prover_job_retrying_interval_ms),
            prover_stats_reporting_interval_ms: Some(this.prover_stats_reporting_interval_ms),
            witness_job_moving_interval_ms: Some(this.witness_job_moving_interval_ms),
            witness_generator_stats_reporting_interval_ms: Some(
                this.witness_generator_stats_reporting_interval_ms,
            ),
            witness_generator_job_retrying_interval_ms: Some(
                this.witness_generator_job_retrying_interval_ms,
            ),
            prover_db_pool_size: Some(this.prover_db_pool_size),
            proof_compressor_job_retrying_interval_ms: Some(
                this.proof_compressor_job_retrying_interval_ms,
            ),
            proof_compressor_stats_reporting_interval_ms: Some(
                this.proof_compressor_stats_reporting_interval_ms,
            ),
            prover_job_archiver_archiving_interval_ms: this
                .prover_job_archiver_archiving_interval_ms,
            prover_job_archiver_archive_after_secs: this.prover_job_archiver_archive_after_secs,
            fri_gpu_prover_archiver_archiving_interval_ms: this
                .fri_gpu_prover_archiver_archiving_interval_ms,
            fri_gpu_prover_archiver_archive_after_secs: this
                .fri_gpu_prover_archiver_archive_after_secs,
        }
    }
}