Variable: ImportCursorStorageSubjects

Makaio Framework

---

Makaio Framework / ai-adapters-core / ImportCursorStorageSubjects

Variable: ImportCursorStorageSubjects

const ImportCursorStorageSubjects: BusSubjects<FlatSubjectDefinitions<"storage:importCursor", { delete: { request: ZodObject<{ filePath: ZodString; }, $strip>; response: ZodObject<{ success: ZodBoolean; }, $strip>; }; get: { request: ZodObject<{ filePath: ZodString; }, $strip>; response: ZodObject<{ cursor: ZodNullable<ZodObject<{ bytesRead: ZodNumber; filePath: ZodString; lastModified: ZodString; sessionContext: ZodOptional<ZodCustom<…, …>>; }, $strip>>; }, $strip>; }; set: { request: ZodObject<{ bytesRead: ZodNumber; filePath: ZodString; lastModified: ZodString; sessionContext: ZodOptional<ZodCustom<object & object, object & object>>; }, $strip>; response: ZodObject<{ success: ZodBoolean; }, $strip>; }; }>, "storage:importCursor"> = ImportCursorStorageNamespace.subjects

Defined in: ../../../adapters/core/src/log-importer/cursor-storage.ts:153

Typed subjects for import cursor storage operations.

Provides type-safe access to cursor storage subjects for bus requests.

Example

// Get cursor
const { cursor } = await bus.request(ImportCursorStorageSubjects.get, {
  filePath: '/path/to/log.jsonl',
});

// Set cursor
await bus.request(ImportCursorStorageSubjects.set, {
  filePath: '/path/to/log.jsonl',
  bytesRead: 1024,
  lastModified: new Date().toISOString(),
});

// Delete cursor (on file rotation)
await bus.request(ImportCursorStorageSubjects.delete, {
  filePath: '/path/to/log.jsonl',
});