ballotwriter

Oct 1, 2024

Changes in this version

+ var BallotAddTime = metrics.NewSimpleCounter(namespace, "ballot_add_time", "time spent in ballots.Add (under lock)")

+ var BatchWriteCount = metrics.NewSimpleCounter(namespace, "batch_write_count", "number of errors when writing a batch")

+ var CleanupTime = metrics.NewSimpleCounter(namespace, "cleanup_time", "time spent in final cleanup(under lock)")

+ var ErroredBatchCount = metrics.NewSimpleCounter(namespace, "errored_batch", "number of batches that errored")

+ var FlushBatchSize = metrics.NewSimpleCounter(namespace, "flush_batch_size", "size of flushed batch")

+ var LayerBallotTime = metrics.NewSimpleCounter(namespace, "layer_ballot_time", ...)

+ var WriteBatchErrorsCount = metrics.NewSimpleCounter(namespace, "write_batch_errors", "number of errors when writing a batch")

+ var WriteTime = metrics.NewSimpleCounter(namespace, "batch_write_time", "time spent writing data to db (under lock)")

+ var WriteTimeHist = metrics.NewSimpleHistogram("write_time_hist", namespace, ...)

+ type BallotWriter struct

+ func New(db db, logger *zap.Logger) *BallotWriter

+ func (w *BallotWriter) Start(ctx context.Context)

+ func (w *BallotWriter) Store(b *types.Ballot) error