RAG Sync
Types
Types
RxDBConfig
type RxDBConfig = { url: string; database: string; collections: string[]; token?: string | undefined; }
SurrealDBConfig
type SurrealDBConfig = { url: string; database: string; namespace: string; auth: { username: string; password: string; }; }
RedisConfig
type RedisConfig = { host: string; port: number; db: number; keyPrefix: string; password?: string | undefined; }
OllamaConfig
type OllamaConfig = { baseUrl: string; embeddingModel: string; timeout: number; maxRetries: number; }
AMSConfig
type AMSConfig = { url: string; pollInterval: number; auth?: { token?: string | undefined; } | undefined; }
SyncConfig
type SyncConfig = { batchSize: number; syncInterval: number; embedBatchSize: number; retryAttempts: number; retryDelay: number; }
Config
type Config = { rxdb: { url: string; database: string; collections: string[]; token?: string | undefined; }; surrealdb: { url: string; database: string; namespace: string; auth: { username: string; password: string; }; }; redis: { host: string; port: number; db: number; keyPrefix: string; password?: string | undefined; }; ollama: { baseUrl: string; embeddingModel: string; timeout: number; maxRetries: number; }; ams: { url: string; pollInterval: number; auth?: { token?: string | undefined; } | undefined; }; sync: { batchSize: number; syncInterval: number; embedBatchSize: number; retryAttempts: number; retryDelay: number; }; adminPort: number; logLevel: "debug" | "info" | "warn" | "error"; }
MemoryEventHandler
Handler function for processing memory events
type MemoryEventHandler = (event: MemoryEvent) => void | Promise<void>
DocumentChangeHandler
Handler function for processing document change events
type DocumentChangeHandler = (event: DocumentChangeEvent) => void | Promise<void>
RagSyncDatabase
Type alias for the RAG sync database instance Using any to avoid type conflicts between workspace and package rxdb versions
type RagSyncDatabase = any
RagSyncCollections
Collection types for the local RAG sync database
type RagSyncCollections = { [x: string]: RxCollection<any>; }