Function: registerDrizzleImportCursorStorage()

Makaio Framework

---

Makaio Framework / services-core / registerDrizzleImportCursorStorage

Function: registerDrizzleImportCursorStorage()

registerDrizzleImportCursorStorage(bus, db, _ctx): () => void

Defined in: ../../../packages/services/core/src/session/import-cursors/drizzle-handler.ts:34

Register Drizzle-backed import cursor storage handlers.

Provides persistent cursor storage for efficient log import resume. On restart, import continues from the last processed byte offset.

Parameters

bus

IMakaioBus

The bus instance to register handlers on

db

MakaioDatabase

Drizzle database instance

_ctx

ExtensionContext

Extension context (unused; reserved for future use)

Returns

Cleanup function to unsubscribe all handlers

() => void

Example

import { registerDrizzleImportCursorStorage } from '@makaio/services-core/session';

const cleanup = registerDrizzleImportCursorStorage(bus, db, ctx);

// Later, when shutting down:
cleanup();