Commit 3c34e90f authored by Michael Kozono's avatar Michael Kozono

Rename affected “local” registry finder methods

parent e6a64aac
...@@ -8,12 +8,12 @@ module Geo ...@@ -8,12 +8,12 @@ module Geo
end end
end end
def local_attachments def syncable_attachments
attachments.geo_syncable attachments.geo_syncable
end end
def count_local_attachments def count_syncable_attachments
local_attachments.count syncable_attachments.count
end end
def count_synced_attachments def count_synced_attachments
...@@ -152,14 +152,14 @@ module Geo ...@@ -152,14 +152,14 @@ module Geo
# #
def fdw_find_synced_attachments def fdw_find_synced_attachments
fdw_find_local_attachments.merge(Geo::FileRegistry.synced) fdw_find_syncable_attachments.merge(Geo::FileRegistry.synced)
end end
def fdw_find_failed_attachments def fdw_find_failed_attachments
fdw_find_local_attachments.merge(Geo::FileRegistry.failed) fdw_find_syncable_attachments.merge(Geo::FileRegistry.failed)
end end
def fdw_find_local_attachments def fdw_find_syncable_attachments
fdw_attachments.joins("INNER JOIN file_registry ON file_registry.file_id = #{fdw_attachments_table}.id") fdw_attachments.joins("INNER JOIN file_registry ON file_registry.file_id = #{fdw_attachments_table}.id")
.geo_syncable .geo_syncable
.merge(Geo::FileRegistry.attachments) .merge(Geo::FileRegistry.attachments)
...@@ -205,7 +205,7 @@ module Geo ...@@ -205,7 +205,7 @@ module Geo
def legacy_find_synced_attachments def legacy_find_synced_attachments
legacy_inner_join_registry_ids( legacy_inner_join_registry_ids(
local_attachments, syncable_attachments,
Geo::FileRegistry.attachments.synced.pluck(:file_id), Geo::FileRegistry.attachments.synced.pluck(:file_id),
Upload Upload
) )
...@@ -213,7 +213,7 @@ module Geo ...@@ -213,7 +213,7 @@ module Geo
def legacy_find_failed_attachments def legacy_find_failed_attachments
legacy_inner_join_registry_ids( legacy_inner_join_registry_ids(
local_attachments, syncable_attachments,
find_failed_attachments_registries.pluck(:file_id), find_failed_attachments_registries.pluck(:file_id),
Upload Upload
) )
...@@ -223,7 +223,7 @@ module Geo ...@@ -223,7 +223,7 @@ module Geo
registry_file_ids = legacy_pluck_registry_file_ids(file_types: Geo::FileService::DEFAULT_OBJECT_TYPES) | except_file_ids registry_file_ids = legacy_pluck_registry_file_ids(file_types: Geo::FileService::DEFAULT_OBJECT_TYPES) | except_file_ids
legacy_left_outer_join_registry_ids( legacy_left_outer_join_registry_ids(
local_attachments, syncable_attachments,
registry_file_ids, registry_file_ids,
Upload Upload
) )
...@@ -241,7 +241,7 @@ module Geo ...@@ -241,7 +241,7 @@ module Geo
def legacy_find_synced_missing_on_primary_attachments def legacy_find_synced_missing_on_primary_attachments
legacy_inner_join_registry_ids( legacy_inner_join_registry_ids(
local_attachments, syncable_attachments,
Geo::FileRegistry.attachments.synced.missing_on_primary.pluck(:file_id), Geo::FileRegistry.attachments.synced.missing_on_primary.pluck(:file_id),
Upload Upload
) )
......
module Geo module Geo
class JobArtifactRegistryFinder < RegistryFinder class JobArtifactRegistryFinder < RegistryFinder
def count_local_job_artifacts def count_syncable_job_artifacts
local_job_artifacts.count syncable_job_artifacts.count
end end
def count_synced_job_artifacts def count_synced_job_artifacts
...@@ -72,7 +72,7 @@ module Geo ...@@ -72,7 +72,7 @@ module Geo
end end
end end
def local_job_artifacts def syncable_job_artifacts
job_artifacts.geo_syncable job_artifacts.geo_syncable
end end
...@@ -170,7 +170,7 @@ module Geo ...@@ -170,7 +170,7 @@ module Geo
def legacy_find_synced_job_artifacts def legacy_find_synced_job_artifacts
legacy_inner_join_registry_ids( legacy_inner_join_registry_ids(
local_job_artifacts, syncable_job_artifacts,
find_synced_job_artifacts_registries.pluck(:artifact_id), find_synced_job_artifacts_registries.pluck(:artifact_id),
Ci::JobArtifact Ci::JobArtifact
) )
...@@ -178,7 +178,7 @@ module Geo ...@@ -178,7 +178,7 @@ module Geo
def legacy_find_failed_job_artifacts def legacy_find_failed_job_artifacts
legacy_inner_join_registry_ids( legacy_inner_join_registry_ids(
local_job_artifacts, syncable_job_artifacts,
find_failed_job_artifacts_registries.pluck(:artifact_id), find_failed_job_artifacts_registries.pluck(:artifact_id),
Ci::JobArtifact Ci::JobArtifact
) )
...@@ -188,7 +188,7 @@ module Geo ...@@ -188,7 +188,7 @@ module Geo
registry_artifact_ids = legacy_pluck_artifact_ids(include_registry_ids: except_artifact_ids) registry_artifact_ids = legacy_pluck_artifact_ids(include_registry_ids: except_artifact_ids)
legacy_left_outer_join_registry_ids( legacy_left_outer_join_registry_ids(
local_job_artifacts, syncable_job_artifacts,
registry_artifact_ids, registry_artifact_ids,
Ci::JobArtifact Ci::JobArtifact
) )
...@@ -211,7 +211,7 @@ module Geo ...@@ -211,7 +211,7 @@ module Geo
def legacy_find_synced_missing_on_primary_job_artifacts def legacy_find_synced_missing_on_primary_job_artifacts
legacy_inner_join_registry_ids( legacy_inner_join_registry_ids(
local_job_artifacts, syncable_job_artifacts,
find_synced_missing_on_primary_job_artifacts_registries.pluck(:artifact_id), find_synced_missing_on_primary_job_artifacts_registries.pluck(:artifact_id),
Ci::JobArtifact Ci::JobArtifact
) )
......
module Geo module Geo
class LfsObjectRegistryFinder < FileRegistryFinder class LfsObjectRegistryFinder < FileRegistryFinder
def count_local_lfs_objects def count_syncable_lfs_objects
local_lfs_objects.count syncable_lfs_objects.count
end end
def count_synced_lfs_objects def count_synced_lfs_objects
...@@ -72,7 +72,7 @@ module Geo ...@@ -72,7 +72,7 @@ module Geo
end end
end end
def local_lfs_objects def syncable_lfs_objects
lfs_objects.geo_syncable lfs_objects.geo_syncable
end end
...@@ -172,7 +172,7 @@ module Geo ...@@ -172,7 +172,7 @@ module Geo
def legacy_find_synced_lfs_objects def legacy_find_synced_lfs_objects
legacy_inner_join_registry_ids( legacy_inner_join_registry_ids(
local_lfs_objects, syncable_lfs_objects,
Geo::FileRegistry.lfs_objects.synced.pluck(:file_id), Geo::FileRegistry.lfs_objects.synced.pluck(:file_id),
LfsObject LfsObject
) )
...@@ -180,7 +180,7 @@ module Geo ...@@ -180,7 +180,7 @@ module Geo
def legacy_find_failed_lfs_objects def legacy_find_failed_lfs_objects
legacy_inner_join_registry_ids( legacy_inner_join_registry_ids(
local_lfs_objects, syncable_lfs_objects,
find_failed_lfs_objects_registries.pluck(:file_id), find_failed_lfs_objects_registries.pluck(:file_id),
LfsObject LfsObject
) )
...@@ -190,7 +190,7 @@ module Geo ...@@ -190,7 +190,7 @@ module Geo
registry_file_ids = legacy_pluck_registry_file_ids(file_types: :lfs) | except_file_ids registry_file_ids = legacy_pluck_registry_file_ids(file_types: :lfs) | except_file_ids
legacy_left_outer_join_registry_ids( legacy_left_outer_join_registry_ids(
local_lfs_objects, syncable_lfs_objects,
registry_file_ids, registry_file_ids,
LfsObject LfsObject
) )
...@@ -208,7 +208,7 @@ module Geo ...@@ -208,7 +208,7 @@ module Geo
def legacy_find_synced_missing_on_primary_lfs_objects def legacy_find_synced_missing_on_primary_lfs_objects
legacy_inner_join_registry_ids( legacy_inner_join_registry_ids(
local_lfs_objects, syncable_lfs_objects,
Geo::FileRegistry.lfs_objects.synced.missing_on_primary.pluck(:file_id), Geo::FileRegistry.lfs_objects.synced.missing_on_primary.pluck(:file_id),
LfsObject LfsObject
) )
......
...@@ -39,19 +39,19 @@ class GeoNodeStatus < ActiveRecord::Base ...@@ -39,19 +39,19 @@ class GeoNodeStatus < ActiveRecord::Base
wikis_verified_count: 'Number of wikis verified on secondary', wikis_verified_count: 'Number of wikis verified on secondary',
wikis_verification_failed_count: 'Number of wikis failed to verify on secondary', wikis_verification_failed_count: 'Number of wikis failed to verify on secondary',
wikis_checksum_mismatch_count: 'Number of wikis that checksum mismatch on secondary', wikis_checksum_mismatch_count: 'Number of wikis that checksum mismatch on secondary',
lfs_objects_count: 'Total number of local LFS objects available on primary', lfs_objects_count: 'Total number of syncable LFS objects available on primary',
lfs_objects_synced_count: 'Number of local LFS objects synced on secondary', lfs_objects_synced_count: 'Number of syncable LFS objects synced on secondary',
lfs_objects_failed_count: 'Number of local LFS objects failed to sync on secondary', lfs_objects_failed_count: 'Number of syncable LFS objects failed to sync on secondary',
lfs_objects_registry_count: 'Number of LFS objects in the registry', lfs_objects_registry_count: 'Number of LFS objects in the registry',
lfs_objects_synced_missing_on_primary_count: 'Number of LFS objects marked as synced due to the file missing on the primary', lfs_objects_synced_missing_on_primary_count: 'Number of LFS objects marked as synced due to the file missing on the primary',
job_artifacts_count: 'Total number of local job artifacts available on primary', job_artifacts_count: 'Total number of syncable job artifacts available on primary',
job_artifacts_synced_count: 'Number of local job artifacts synced on secondary', job_artifacts_synced_count: 'Number of syncable job artifacts synced on secondary',
job_artifacts_failed_count: 'Number of local job artifacts failed to sync on secondary', job_artifacts_failed_count: 'Number of syncable job artifacts failed to sync on secondary',
job_artifacts_registry_count: 'Number of job artifacts in the registry', job_artifacts_registry_count: 'Number of job artifacts in the registry',
job_artifacts_synced_missing_on_primary_count: 'Number of job artifacts marked as synced due to the file missing on the primary', job_artifacts_synced_missing_on_primary_count: 'Number of job artifacts marked as synced due to the file missing on the primary',
attachments_count: 'Total number of local file attachments available on primary', attachments_count: 'Total number of syncable file attachments available on primary',
attachments_synced_count: 'Number of local file attachments synced on secondary', attachments_synced_count: 'Number of syncable file attachments synced on secondary',
attachments_failed_count: 'Number of local file attachments failed to sync on secondary', attachments_failed_count: 'Number of syncable file attachments failed to sync on secondary',
attachments_registry_count: 'Number of attachments in the registry', attachments_registry_count: 'Number of attachments in the registry',
attachments_synced_missing_on_primary_count: 'Number of attachments marked as synced due to the file missing on the primary', attachments_synced_missing_on_primary_count: 'Number of attachments marked as synced due to the file missing on the primary',
replication_slots_count: 'Total number of replication slots on the primary', replication_slots_count: 'Total number of replication slots on the primary',
...@@ -150,9 +150,9 @@ class GeoNodeStatus < ActiveRecord::Base ...@@ -150,9 +150,9 @@ class GeoNodeStatus < ActiveRecord::Base
self.last_event_date = latest_event&.created_at self.last_event_date = latest_event&.created_at
self.repositories_count = projects_finder.count_repositories self.repositories_count = projects_finder.count_repositories
self.wikis_count = projects_finder.count_wikis self.wikis_count = projects_finder.count_wikis
self.lfs_objects_count = lfs_objects_finder.count_local_lfs_objects self.lfs_objects_count = lfs_objects_finder.count_syncable_lfs_objects
self.job_artifacts_count = job_artifacts_finder.count_local_job_artifacts self.job_artifacts_count = job_artifacts_finder.count_syncable_job_artifacts
self.attachments_count = attachments_finder.count_local_attachments self.attachments_count = attachments_finder.count_syncable_attachments
self.last_successful_status_check_at = Time.now self.last_successful_status_check_at = Time.now
self.storage_shards = StorageShard.all self.storage_shards = StorageShard.all
......
...@@ -30,7 +30,7 @@ describe Geo::AttachmentRegistryFinder, :geo do ...@@ -30,7 +30,7 @@ describe Geo::AttachmentRegistryFinder, :geo do
end end
shared_examples 'counts all the things' do shared_examples 'counts all the things' do
describe '#count_local_attachments' do describe '#count_syncable_attachments' do
before do before do
upload_1 upload_1
upload_2 upload_2
...@@ -39,13 +39,13 @@ describe Geo::AttachmentRegistryFinder, :geo do ...@@ -39,13 +39,13 @@ describe Geo::AttachmentRegistryFinder, :geo do
end end
it 'counts attachments' do it 'counts attachments' do
expect(subject.count_local_attachments).to eq 4 expect(subject.count_syncable_attachments).to eq 4
end end
it 'ignores remote attachments' do it 'ignores remote attachments' do
upload_1.update!(store: ObjectStorage::Store::REMOTE) upload_1.update!(store: ObjectStorage::Store::REMOTE)
expect(subject.count_local_attachments).to eq 3 expect(subject.count_syncable_attachments).to eq 3
end end
context 'with selective sync' do context 'with selective sync' do
...@@ -54,13 +54,13 @@ describe Geo::AttachmentRegistryFinder, :geo do ...@@ -54,13 +54,13 @@ describe Geo::AttachmentRegistryFinder, :geo do
end end
it 'counts attachments' do it 'counts attachments' do
expect(subject.count_local_attachments).to eq 2 expect(subject.count_syncable_attachments).to eq 2
end end
it 'ignores remote attachments' do it 'ignores remote attachments' do
upload_1.update!(store: ObjectStorage::Store::REMOTE) upload_1.update!(store: ObjectStorage::Store::REMOTE)
expect(subject.count_local_attachments).to eq 1 expect(subject.count_syncable_attachments).to eq 1
end end
end end
end end
...@@ -286,7 +286,7 @@ describe Geo::AttachmentRegistryFinder, :geo do ...@@ -286,7 +286,7 @@ describe Geo::AttachmentRegistryFinder, :geo do
expect(synced_attachments).to match_ids(upload_1, upload_2, upload_6, upload_7) expect(synced_attachments).to match_ids(upload_1, upload_2, upload_6, upload_7)
end end
it 'only finds local attachments' do it 'only finds syncable attachments' do
create(:geo_file_registry, :avatar, file_id: upload_1.id) create(:geo_file_registry, :avatar, file_id: upload_1.id)
create(:geo_file_registry, :avatar, file_id: upload_2.id) create(:geo_file_registry, :avatar, file_id: upload_2.id)
upload_1.update!(store: ObjectStorage::Store::REMOTE) upload_1.update!(store: ObjectStorage::Store::REMOTE)
......
...@@ -23,7 +23,7 @@ describe Geo::JobArtifactRegistryFinder, :geo do ...@@ -23,7 +23,7 @@ describe Geo::JobArtifactRegistryFinder, :geo do
end end
shared_examples 'counts all the things' do shared_examples 'counts all the things' do
describe '#count_local_job_artifacts' do describe '#count_syncable_job_artifacts' do
before do before do
job_artifact_1 job_artifact_1
job_artifact_2 job_artifact_2
...@@ -32,13 +32,13 @@ describe Geo::JobArtifactRegistryFinder, :geo do ...@@ -32,13 +32,13 @@ describe Geo::JobArtifactRegistryFinder, :geo do
end end
it 'counts job artifacts' do it 'counts job artifacts' do
expect(subject.count_local_job_artifacts).to eq 4 expect(subject.count_syncable_job_artifacts).to eq 4
end end
it 'ignores remote job artifacts' do it 'ignores remote job artifacts' do
job_artifact_1.update_column(:file_store, ObjectStorage::Store::REMOTE) job_artifact_1.update_column(:file_store, ObjectStorage::Store::REMOTE)
expect(subject.count_local_job_artifacts).to eq 3 expect(subject.count_syncable_job_artifacts).to eq 3
end end
context 'with selective sync' do context 'with selective sync' do
...@@ -47,13 +47,13 @@ describe Geo::JobArtifactRegistryFinder, :geo do ...@@ -47,13 +47,13 @@ describe Geo::JobArtifactRegistryFinder, :geo do
end end
it 'counts job artifacts' do it 'counts job artifacts' do
expect(subject.count_local_job_artifacts).to eq 2 expect(subject.count_syncable_job_artifacts).to eq 2
end end
it 'ignores remote job artifacts' do it 'ignores remote job artifacts' do
job_artifact_1.update_column(:file_store, ObjectStorage::Store::REMOTE) job_artifact_1.update_column(:file_store, ObjectStorage::Store::REMOTE)
expect(subject.count_local_job_artifacts).to eq 1 expect(subject.count_syncable_job_artifacts).to eq 1
end end
end end
end end
......
...@@ -23,7 +23,7 @@ describe Geo::LfsObjectRegistryFinder, :geo do ...@@ -23,7 +23,7 @@ describe Geo::LfsObjectRegistryFinder, :geo do
end end
shared_examples 'counts all the things' do shared_examples 'counts all the things' do
describe '#count_local_lfs_objects' do describe '#count_syncable_lfs_objects' do
before do before do
lfs_object_1 lfs_object_1
lfs_object_2 lfs_object_2
...@@ -32,13 +32,13 @@ describe Geo::LfsObjectRegistryFinder, :geo do ...@@ -32,13 +32,13 @@ describe Geo::LfsObjectRegistryFinder, :geo do
end end
it 'counts LFS objects' do it 'counts LFS objects' do
expect(subject.count_local_lfs_objects).to eq 4 expect(subject.count_syncable_lfs_objects).to eq 4
end end
it 'ignores remote LFS objects' do it 'ignores remote LFS objects' do
lfs_object_1.update_column(:file_store, ObjectStorage::Store::REMOTE) lfs_object_1.update_column(:file_store, ObjectStorage::Store::REMOTE)
expect(subject.count_local_lfs_objects).to eq 3 expect(subject.count_syncable_lfs_objects).to eq 3
end end
context 'with selective sync' do context 'with selective sync' do
...@@ -53,13 +53,13 @@ describe Geo::LfsObjectRegistryFinder, :geo do ...@@ -53,13 +53,13 @@ describe Geo::LfsObjectRegistryFinder, :geo do
end end
it 'counts LFS objects' do it 'counts LFS objects' do
expect(subject.count_local_lfs_objects).to eq 2 expect(subject.count_syncable_lfs_objects).to eq 2
end end
it 'ignores remote LFS objects' do it 'ignores remote LFS objects' do
lfs_object_1.update_column(:file_store, ObjectStorage::Store::REMOTE) lfs_object_1.update_column(:file_store, ObjectStorage::Store::REMOTE)
expect(subject.count_local_lfs_objects).to eq 1 expect(subject.count_syncable_lfs_objects).to eq 1
end end
end end
end end
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment