Interface IMigrationSource

Adapter for reading data from a migration source backend. Implementations exist for SQLite, Postgres, and Qdrant.

interface IMigrationSource {
    listTables(): Promise<string[]>;
    countRows(table): Promise<number>;
    readBatch(table, offset, limit): Promise<Record<string, unknown>[]>;
    close(): Promise<void>;
}

Methods

listTables countRows readBatch close

Methods

listTables

  • listTables(): Promise<string[]>

  • List table/collection names available for migration.

    Returns Promise<string[]>

countRows

  • countRows(table): Promise<number>

  • Count rows/points in a table.

    Parameters

    • table: string

    Returns Promise<number>

readBatch

  • readBatch(table, offset, limit): Promise<Record<string, unknown>[]>

  • Read a batch of rows starting at offset.

    Parameters

    • table: string

      Table name to read from.

    • offset: number

      Number of rows to skip.

    • limit: number

      Maximum rows to return.

    Returns Promise<Record<string, unknown>[]>

    Array of row objects with column values.

close

Settings

Member Visibility

Theme

On This Page

listTablescountRowsreadBatchclose