memoryIngestion
Variable: memoryIngestion
const memoryIngestion: {
activate: (pipelineId: string) => Promise<IngestionPipelineResponse>;
create: (config: CreateIngestionPipelineParams) => Promise<IngestionPipelineResponse>;
delete: (pipelineId: string) => Promise<IngestionPipelineResponse>;
disable: (pipelineId: string) => Promise<IngestionPipelineResponse>;
duplicate: (pipelineId: string, newId?: string, newLabel?: string) => Promise<IngestionPipelineResponse>;
execute: (params: ExecuteIngestionParams) => Promise<IngestionExecuteResponse>;
get: (pipelineId: string) => Promise<IngestionPipelineResponse>;
getProcessorSpecs: () => Promise<IngestionProcessorSpecsResponse>;
list: (filters?: ListIngestionPipelineParams) => Promise<IngestionPipelineListResponse>;
update: (pipelineId: string, updates: UpdateIngestionPipelineParams) => Promise<IngestionPipelineResponse>;
validate: (pipeline: CreateIngestionPipelineParams) => Promise<IngestionValidateResponse>;
};
Defined in: packages/codeboltjs/src/modules/memoryIngestion.ts:20
Type Declaration
| Name | Type | Description | Defined in |
|---|---|---|---|
activate() | (pipelineId: string) => Promise<IngestionPipelineResponse> | Activate an ingestion pipeline | packages/codeboltjs/src/modules/memoryIngestion.ts:145 |
create() | (config: CreateIngestionPipelineParams) => Promise<IngestionPipelineResponse> | Create a new ingestion pipeline | packages/codeboltjs/src/modules/memoryIngestion.ts:25 |
delete() | (pipelineId: string) => Promise<IngestionPipelineResponse> | Delete an ingestion pipeline | packages/codeboltjs/src/modules/memoryIngestion.ts:86 |
disable() | (pipelineId: string) => Promise<IngestionPipelineResponse> | Disable an ingestion pipeline | packages/codeboltjs/src/modules/memoryIngestion.ts:160 |
duplicate() | (pipelineId: string, newId?: string, newLabel?: string) => Promise<IngestionPipelineResponse> | Duplicate an ingestion pipeline | packages/codeboltjs/src/modules/memoryIngestion.ts:177 |
execute() | (params: ExecuteIngestionParams) => Promise<IngestionExecuteResponse> | Execute an ingestion pipeline | packages/codeboltjs/src/modules/memoryIngestion.ts:101 |
get() | (pipelineId: string) => Promise<IngestionPipelineResponse> | Get an ingestion pipeline by ID | packages/codeboltjs/src/modules/memoryIngestion.ts:40 |
getProcessorSpecs() | () => Promise<IngestionProcessorSpecsResponse> | Get available processor specifications | packages/codeboltjs/src/modules/memoryIngestion.ts:130 |
list() | (filters?: ListIngestionPipelineParams) => Promise<IngestionPipelineListResponse> | List ingestion pipelines | packages/codeboltjs/src/modules/memoryIngestion.ts:55 |
update() | (pipelineId: string, updates: UpdateIngestionPipelineParams) => Promise<IngestionPipelineResponse> | Update an ingestion pipeline | packages/codeboltjs/src/modules/memoryIngestion.ts:71 |
validate() | (pipeline: CreateIngestionPipelineParams) => Promise<IngestionValidateResponse> | Validate a pipeline configuration | packages/codeboltjs/src/modules/memoryIngestion.ts:116 |