Compare commits
1 Commits
fix-stream
...
v0.3.6-alp
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
3e14f8ee14 |
14
replica.go
14
replica.go
@@ -159,6 +159,9 @@ func (r *Replica) Sync(ctx context.Context) (err error) {
|
||||
|
||||
Tracef("%s(%s): replica sync: db.pos=%s", r.db.Path(), r.Name(), dpos)
|
||||
|
||||
// Create a new snapshot and update the current replica position if
|
||||
// the generation on the database has changed.
|
||||
if r.Pos().Generation != generation {
|
||||
// Create snapshot if no snapshots exist for generation.
|
||||
snapshotN, err := r.snapshotN(generation)
|
||||
if err != nil {
|
||||
@@ -169,12 +172,8 @@ func (r *Replica) Sync(ctx context.Context) (err error) {
|
||||
} else if info.Generation != generation {
|
||||
return fmt.Errorf("generation changed during snapshot, exiting sync")
|
||||
}
|
||||
snapshotN = 1
|
||||
}
|
||||
replicaSnapshotTotalGaugeVec.WithLabelValues(r.db.Path(), r.Name()).Set(float64(snapshotN))
|
||||
|
||||
// Determine position, if necessary.
|
||||
if r.Pos().Generation != generation {
|
||||
pos, err := r.calcPos(ctx, generation)
|
||||
if err != nil {
|
||||
return fmt.Errorf("cannot determine replica position: %s", err)
|
||||
@@ -1307,13 +1306,6 @@ func (r *Replica) downloadWAL(ctx context.Context, generation string, index int,
|
||||
|
||||
// Replica metrics.
|
||||
var (
|
||||
replicaSnapshotTotalGaugeVec = promauto.NewGaugeVec(prometheus.GaugeOpts{
|
||||
Namespace: "litestream",
|
||||
Subsystem: "replica",
|
||||
Name: "snapshot_total",
|
||||
Help: "The current number of snapshots",
|
||||
}, []string{"db", "name"})
|
||||
|
||||
replicaWALBytesCounterVec = promauto.NewCounterVec(prometheus.CounterOpts{
|
||||
Namespace: "litestream",
|
||||
Subsystem: "replica",
|
||||
|
||||
Reference in New Issue
Block a user