SetOperationState sets the operation state in collection metadata.

WithBootstrap allows skipping validation during bootstrap

Helper function to verify database file exists

ClearOperationState removes the operation state from collection metadata.

Clone creates a consistent copy of the collection at destPath

CloneCollectionFiles copies filesystem data from source to destination.

--- Store Delegates ---

GetBackup retrieves backup metadata by ID.

IsOperationTimedOut checks if an operation has exceeded its timeout.

ListBackups lists backups with optional filters.

ListProtos returns all registered protos, optionally filtered by namespace

NewDispatcherWithRegistry creates a new dispatcher instance with registry validation

NewGrpcServer creates a new instance of our gRPC server.

RegisterCollectionRepoService registers the CollectionRepo service with the registry

Helper functions to register services with the registry RegisterCollectionService registers the CollectionService with the registry

RegisterDispatcherService registers the CollectiveDispatcher service with the registry

ValidateCollectionMessageType validates that a collection's message type is registered

ValidateName validates a namespace or collection name. Returns an error if the name is invalid.

VerifyBackup verifies a backup's integrity.

checkStringValue checks a string value against WAF rules

getPersistedConnection retrieves a connection record from the collection.

registerCollection adds a collection to the collection registry

updatePersistedConnection updates an existing connection record.

BackupFilesPathMicro generates a backup files directory path using microsecond precision. Format: {DataDir}/.backup/{namespace}/{collectionname}-{time

Maintenance

CloneLocal clones a collection within the same collector.

Disconnect closes a connection and updates the persisted record.

FetchRemote fetches a collection from a remote collector using streaming.

ListBackups lists available backups.

LookupProto retrieves a registered proto by namespace and file name

NewFileSystem creates a new local filesystem rooted at the given path.

Pack prepares a collection for transport (returns a reader for the data)

Path returns the physical location of the store (useful for transport/backup).

RegisterMessageType registers a message type from a FileDescriptor This should be called when RegisterProto is called in the registry

Unpack receives collection data and creates a new collection

Vector helper methods

Address returns the full address the server is listening on.

CloseAll closes all active connections.

DeleteBackup deletes a backup.

ExecuteRaw allows lower-level operations required for advanced features like backup (VACUUM INTO) or combination (ATTACH DATABASE).

GetClient returns a client for the given address.

ListMessageTypes returns all registered message types, optionally filtered by namespace

New creates a new Collector server with the given configuration.

NewCloneManager creates a new CloneManager.

NewCollectionRegistryStore creates a new registry store backed by a collection.

NewCollectionRepoService creates a new service instance.

NewRegistryValidator creates a validator from a RegistryServer

NewTypeRegistry creates a new TypeRegistry wrapping the system/types collection

NewWAFInterceptor creates an interceptor that blocks requests containing specific substrings. This is a demonstration interceptor for testing/validati

RecordRequest increments the request count and updates activity for a connection.

RecoverFromRestart marks connections from previous sessions as STALE. This should be called on startup before accepting new connections.

Save writes content to a file at the given path.

SetTypeValidator sets the message type validator for this repo. This is optional - if not set, type validation is skipped.

Example: How to set up a CollectionService server with registry validation SetupCollectionServiceWithValidation demonstrates how to create a Collectio

Shutdown closes all connections

Shutdown gracefully shuts down the server.

StreamValidationInterceptor creates a gRPC stream interceptor that validates incoming RPCs against the registry.

ValidateMessageType checks if a message type is registered

ValidateService checks if a service is registered in the given namespace

ValidationInterceptor creates a gRPC unary interceptor that validates incoming RPCs against the registry. It checks if the service and method are regi

WaitForShutdown blocks until a shutdown signal is received (SIGINT, SIGTERM).

buildTypeUrl builds a type URL from a collection's message type

cleanupOldBackups enforces retention policy for a collection's backups. This runs synchronously while the backup operation is still active, preventing

deleteBackupUnlocked is the internal version that doesn't acquire the lock. Used by cleanup operations that already hold the lock.