Function resetLocalCheckpoint

db/active_replicator_checkpointer.go:549–555

resetLocalCheckpoint removes the local checkpoint to roll back the replication.

(dataStore base.DataStore, checkpointID string)

// resetLocalCheckpoint removes the local checkpoint to roll back the replication.
func resetLocalCheckpoint(dataStore base.DataStore, checkpointID string) error {
	key := RealSpecialDocID(DocTypeLocal, CheckpointDocIDPrefix+checkpointID)
	if err := dataStore.Delete(key); err != nil && !base.IsDocNotFoundError(err) {
		return err
	}
	return nil
}

// getRemoteCheckpoint returns the sequence and rev for the remote checkpoint.
// if the checkpoint does not exist, returns empty sequence and rev.