Port returns the actual port the server is listening on.

RegisterFileDescriptor registers all message types from a FileDescriptor This is the main entry point when RegisterProto is called

RegistryDBPath returns the path for the collection registry database. Format: {DataDir}/repo/collections.db

RestoreBackup restores a collection from a backup.

Route directs a request to the appropriate collection server.

Route forwards the request to the underlying repository.

Route directs a request to the appropriate collection server.

SaveDir recursively copies a directory from srcPath on local filesystem to destPath in this filesystem.

SearchCollections searches across multiple collections.

SearchCollections forwards the request to the underlying repository.

SearchCollections searches across multiple collections.

SetSizeLimits sets custom size limits for proto registration. This allows configuring limits different from the defaults.

Start runs the gRPC server on the given port.

Stat returns the size of a file at the given path.

StreamToRemote uploads collection data to a remote endpoint.

TestBackupCollection_Simple tests basic backup functionality

TestBackupConcurrent tests concurrent backup operations

TestBackupConcurrentReads verifies that reads work during backup

TestBackupConcurrentWrites verifies that writes work during backup

TestBackupConsistency verifies backup data integrity

TestBackupEmptyCollection tests backup of empty collection

TestBackupFailureRecovery tests error handling

TestBackupLargeDataset tests backup with larger dataset

TestBackupLockDuration measures actual lock time during backup

TestBackupMetadataFiltering tests metadata filtering

TestBackupOnline tests incremental backup method

TestBackupUnderLoad simulates realistic production load

TestBackupValidation tests request validation

TestBackupWithFiles tests backup including filesystem data

TestBackupWithSpecialCharacters tests collections with special characters

TestBackwardsCompatibility ensures old code without registry still works

TestCollectionRepoIntegration tests collection repo service registration and validation

TestCollectionRepoService_DirectAccess tests the underlying service

TestCollectionRepo_Concurrency tests concurrent operations on the repo

TestCollectionRepo_CreateCollection tests creating a collection

TestCollectionRepo_DeleteCollection tests deleting a collection

TestCollectionRepo_DeleteCollection_InvalidRequest tests invalid delete requests

TestCollectionRepo_DeleteCollection_Multiple tests deleting multiple collections

TestCollectionRepo_DeleteCollection_NonExistent tests deleting a non-existent collection

TestCollectionRepo_DeleteCollection_WithActiveOperation tests that deletion is blocked during active operations

TestCollectionRepo_Discover tests discovering collections

TestCollectionRepo_GetCollection tests getting a collection instance

TestCollectionRepo_Route tests routing to a collection

TestCollectionRepo_SearchCollections tests searching across multiple collections

TestCollectionServer_Batch tests the Batch RPC

TestCollectionServer_Create tests the Create RPC

TestCollectionServer_Delete tests the Delete RPC

TestCollectionServer_Describe tests the Describe RPC

TestCollectionServer_Get tests the Get RPC

TestCollectionServer_Invoke tests the Invoke RPC (should return Unimplemented)

TestCollectionServer_List tests the List RPC

TestCollectionServer_Meta tests the Meta RPC

TestCollectionServer_Modify tests the Modify RPC

TestCollectionServer_Search tests the Search RPC

TestCollectionServer_Update tests the Update RPC

TestCollectionServiceIntegration tests the full integration of registry validation with the CollectionService

Concurrent Access Tests