Redis Storage Adapter

import { VectoriaDB, RedisStorageAdapter } from 'vectoriadb';
import Redis from 'ioredis';

const redisClient = new Redis();

const toolIndex = new VectoriaDB<ToolDocument>({
  storageAdapter: new RedisStorageAdapter({
    client: redisClient,
    namespace: 'tool-index',
    ttl: 86400,        // 24 hours (default)
    keyPrefix: 'vectoriadb',
  }),
});

await toolIndex.initialize();

if (toolIndex.size() === 0) {
  await toolIndex.addMany(documents);
  await toolIndex.saveToStorage();
}

interface RedisClient {
  get(key: string): Promise<string | null>;
  set(key: string, value: string): Promise<void | string>;
  setex(key: string, seconds: number, value: string): Promise<void | string>;
  del(key: string): Promise<number>;
  ping(): Promise<string>;
  quit(): Promise<void>;
}

import Redis from 'ioredis';

const client = new Redis({
  host: 'localhost',
  port: 6379,
  password: process.env.REDIS_PASSWORD,
});

const adapter = new RedisStorageAdapter({ client });

import { createClient } from 'redis';

const client = createClient({ url: 'redis://localhost:6379' });
await client.connect();

const adapter = new RedisStorageAdapter({ client });

const adapter = new RedisStorageAdapter({
  client: redisClient,
  ttl: 3600,     // 1 hour - for frequently changing data
  // ttl: 86400  // 24 hours - default
  // ttl: 604800 // 7 days - for stable data
});

function createTenantDB(tenantId: string) {
  return new VectoriaDB({
    storageAdapter: new RedisStorageAdapter({
      client: redisClient,
      namespace: `tenant-${tenantId}`,
      keyPrefix: 'vectoriadb',
    }),
  });
}

const tenantA = createTenantDB('a');
const tenantB = createTenantDB('b');

// You manage the client
const client = new Redis();

const db = new VectoriaDB({
  storageAdapter: new RedisStorageAdapter({ client }),
});

await db.initialize();

// ... use db ...

// Close when done
await db.close();
await client.quit();

import { StorageError } from 'vectoriadb';

try {
  await db.saveToStorage();
} catch (error) {
  if (error instanceof StorageError) {
    console.error('Redis error:', error.message);

    // Common issues:
    // - Connection refused
    // - Authentication failed
    // - Memory limit exceeded
  }
}