registerCoreTypes registers the core collector message types

updateMessageType updates an existing message type registration

validateDependencies checks that all dependencies exist and there are no circular dependencies Dependencies are resolved by searching the current name

Attach links a secondary collection to the primary one using SQLite's ATTACH DATABASE.

BackupCollection creates a backup of a collection.

BackupFilesPath generates a backup files directory path. Format: {DataDir}/.backup/{namespace}/{collectionname}-{timestampseconds}.files

BenchmarkBackupWithLoad measures backup performance under load

Clone clones a collection either locally or to a remote collector.

CloneFallback uses VACUUM INTO as a fallback if Backup is not available. Note: This acquires locks and may block writes temporarily.

CloneToLocal creates a local copy of a collection.

Close closes the underlying collection (if needed).

Close closes all resources. Should be called when the server is no longer needed.

Close closes all system collections

ConnectTo initiates a connection to another collector.

CopyFile copies a file from srcPath to destPath within this filesystem.

CreateCollection creates a new collection.

CreateCollection forwards the request to the underlying repository.

CreateCollection creates a new collection.

DefaultAuthInterceptor is a no-op interceptor that allows all requests.

DefaultJSONConverterFactory returns converters for system types only. For unknown types, returns nil which triggers the store's fallback behavior (use

Delete removes a file at the given path.

DeleteBackup removes backup metadata.

DeleteBackup deletes a backup.

DeleteCollection forwards the request to the underlying repository.

DeleteCollection deletes a collection and all its data.

DeleteCollection removes a collection from the registry. System namespace collections cannot be deleted.

Discover finds collections based on the provided criteria.

Discover forwards the request to the underlying repository.

Discover finds collections based on the provided criteria.

Splits text on whitespace and hashes tokens into the vector space.

EstimateCollectionSize estimates the total size of a collection including files.

Exists checks if a file exists at the given path.

Fetch fetches a collection from a remote collector.

FetchFromStream reads collection data from an io.Reader and writes to localPath.

FetchRemoteDB downloads a collection database from a remote URL. The URL should point to a collection database file or packaged collection.

GetActiveConnection returns an active connection by ID.

IsReservedNamespace checks if a namespace is reserved.

List returns all files under the given prefix.

ListActiveConnections returns all active connections.

ListBackupPaths lists all backup database files for a collection. Returns sorted list (oldest to newest).

ListBackups lists available backups.

ListCollections returns all collections, optionally filtered by namespace.

MoveFile moves a file from srcPath to destPath within this filesystem.

OpenReader opens a file for reading.

OpenWriter opens a file for writing.

Pack prepares a collection for network transport. Creates a tarball containing the database and optionally files.