ActiveConnection represents the runtime state of an active connection. This is kept in memory and contains resources that cannot be persisted (gRPC cl

AuditLogger handles structured audit logging to the system/audit collection.

BackupManager manages backup operations for collections with automatic retention. Key Features: - Auto-generated paths: {DataDir}/.backup/{namespace}

BackupMetadataStore persists backup metadata to a SQLite database.

CloneManager handles collection cloning operations.

10MB Collection is the domain entity handling logic.

CollectionMetadata holds collection information with its storage path.

CollectionOption is a functional option for Collection construction

CollectionRegistryStore implements RegistryStore using a Collection. This allows the registry to be self-hosted in the "system/collections" collection

CollectionRepo defines the interface for a collection repository.

CollectionRepoService provides a persistent implementation of the CollectionRepo interface. It uses a Store (like SqliteStore) for the underlying data

Combinator handles merging multiple Collections.

Config holds server configuration options. Note: The "system" namespace is reserved for internal collections: - system/collections - Collection metad

ConnectionManager manages connections between collectors. It maintains both persisted connection records (in system/connections collection) and active

DefaultCollectionRepo is a facade that provides a simple interface for managing collections. It uses a CollectionRepoService and a Store to do the hea

A lightweight, dependency-free embedder that produces stable, fixed-dimension vectors by hashing tokens. Intended for tests and local runs.

Dispatcher implements the CollectiveDispatcher service

Embedder defines how to turn text into vectors.

ErrOperationInProgress is returned when an operation is already in progress.

Fetcher handles retrieving Collections from remote sources.

FileSystem defines the interface for file operations associated with a collection. Allows swapping local disk for cloud storage or memory-based VFS.

FileSystem implements file operations using the local OS filesystem.

Filter represents a condition on a structured field.

GRPCRegistryValidator validates services via gRPC (recommended approach) This ensures proper service-to-service communication using the gRPC stack

GrpcServer wraps the gRPC server and implements the CollectionRepoServer.

JSONConverterFactory creates ProtoToJSONConverter based on collection type

JSONConverterSetter is an optional interface that stores can implement to support setting a JSON converter for proto→JSON conversion.

JSONConverterType specifies which type of JSON converter to use

Level defines the log severity

LocalFileSystem implements the FileSystem interface. This is a compatibility wrapper around pkg/fs/local.FileSystem. New code should use pkg/fs/local.

Logger defines a structured logging interface

MessageTypeValidator validates that message types are registered before use. This interface allows dependency injection without circular dependencies.

MockCollectionRepo for testing

MockValidator implements RegistryValidator for testing

NoOpLogger is a logger that does nothing

OperationState represents an in-progress operation on a collection. Stored in Collection metadata using reserved label "_operation".

Options configures the feature set for a Collection.

PathConfig provides centralized path management for collection storage. It allows configurable base directory and consistent path generation.

FetchWithProgress fetches a collection with progress reporting.

ProtoLookupFunc looks up a FileDescriptorProto by namespace and message name. Returns the file descriptor and the message name, or an error if not fou

ProtoSizeLimits defines configurable limits for proto registration to prevent DoS attacks

ProtoToJSONConverter is a function that converts binary protobuf data to JSON string. It should return a valid JSON representation of the protobuf mes

RegistryServerValidator wraps a RegistryServer to provide validation

RegistryStore defines the interface for persisting collection metadata. The production implementation is CollectionRegistryStore (see collection_regis

RegistryValidator is an interface for validating services against a registry

SearchQuery is the generic query structure passed to the Store.

SearchResult represents a search hit with relevance info.

SemanticEngine defines intelligence operations on a Collection.

Server represents a fully configured Collector server with all services.

ServiceHandler is a function that handles a service method invocation

ServiceMethodValidator is an interface for validating service methods Can be implemented by gRPC clients or other validation mechanisms

SqliteTransport implements collection transport using SQLite operations.

Store defines the interface for the underlying database. Implementations (like SQLite) handle the specifics of query translation and storage.

StoreFactory is a function that creates a new Store instance at the given path with the given options.

SystemCollections holds references to all system collections

SystemLogger implements logging.Logger and writes to a collection

Transport defines how a Collection is moved between collectors.

TypeRegistrar is an interface for registering message types. This allows optional integration with the type registry without circular dependencies.

TypeRegistry provides type validation for collections It tracks all registered message types and validates that collections reference valid types

WAFRule defines a rule for the Web Application Firewall. This is an example/testing implementation to demonstrate gRPC interceptor patterns. Productio

grpcRegistryClientValidator wraps a gRPC Registry client to implement ServiceMethodValidator

Mock CollectionRepo for testing

mockCollectionRepo is a minimal mock for testing

Mock ServerStream for testing

mockStore is a minimal Store implementation for testing

progressReader wraps an io.Reader and reports progress.

realTestServer is for tests that need actual network connections

testServer wraps a dispatcher with a gRPC server