mcp_knowledge_ops library

MCP Knowledge Operations - Orchestration layer for MakeMind.

This library provides orchestration operations for MCP applications, including pipelines, workflows, scheduling, and integration with fact graphs, skills, profiles, and bundles.

Classes

ActionExecutionContext
Action execution context.
ActionResult
Action execution result.
BasicWorkflowContext
Basic workflow context implementation.
BundleInput
Bundle input.
BundlePort
Port for bundle operations.
BundleValidation
Bundle validation result.
CandidateSummary
Candidate summary.
Chunk
A chunk of a document.
ChunkingOptions
Options for chunking documents.
Cluster
A cluster of similar facts.
CommonPatterns
Common extraction patterns.
ContextBuilder
Builds context from search results.
ContextBuilderOptions
Options for context building.
ContextChunk
A chunk of context.
ContextResult
Result of context building.
ContextSource
A source reference in the context.
CronTrigger
Cron-based trigger.
CurationInput
Input for curation pipeline.
CurationOutput
Output of curation pipeline.
CurationPipeline
Pipeline for curating candidates into facts.
DeadlineProvider
Provider for deadline information.
DeadlineTrigger
Deadline-aware trigger.
Document
A document in the knowledge base.
DocumentChunker
Chunks documents into smaller pieces.
DocumentCollection
Document collection.
Embedding
Embedding vector representation.
EmbeddingProvider
Abstract embedding provider interface.
EmbeddingSimilaritySearch
Embedding similarity search.
EvaluationOutput
Evaluation output.
EventTrigger
Event-driven trigger.
EvidenceInput
Evidence input.
ExtractedEntity
An extracted entity.
ExtractedRelation
An extracted relation.
ExtractionPattern
An extraction pattern.
ExtractionResult
Result of knowledge extraction.
FactGraphPort
Port for fact graph operations.
FeatureVector
Feature vector for a fact.
FunctionHandler<TInput, TOutput>
Simple function-based handler wrapper.
HandlerContext
Context for handler execution.
HandlerFilter
Handler filter criteria.
HandlerInfo
Handler information.
IndexEntry
An entry in the knowledge index.
InvertedIndex
Inverted index for text-based search.
KnowledgeExtractor
Abstract knowledge extractor interface.
KnowledgeIndex
Abstract knowledge index interface.
KnowledgeRetriever
Knowledge retriever implementation.
LlmCompletion
LLM completion.
ManualTrigger
Manual trigger.
MatchInfo
Match information for a search result.
MatchPosition
Position of a match.
MemoryKnowledgeIndex
In-memory knowledge index.
MockEmbeddingProvider
Mock embedding provider for testing.
OpsLlmPort
Port for LLM operations in orchestration.
OpsLlmRequest
LLM request.
PatternInput
Pattern input.
PatternKnowledgeExtractor
Simple pattern-based knowledge extractor.
PatternMiningInput
Input for pattern mining pipeline.
PatternMiningOutput
Output of pattern mining pipeline.
PatternMiningPipeline
Pipeline for mining patterns from facts.
Pipeline<TInput, TOutput>
Base pipeline interface for data processing flows.
PipelineCompletedEvent
Pipeline completed event.
PipelineConfig
Pipeline configuration.
PipelineContext
Pipeline execution context.
PipelineError
Pipeline error.
PipelineEvent
Base pipeline event.
PipelineEventListener
Pipeline event listener.
PipelineExecutor
Executes pipelines.
PipelineHandler<TInput, TOutput>
Base interface for pipeline stage handlers.
PipelineHandlerRegistry
Registry for pipeline handlers.
PipelineMetrics
Pipeline execution metrics.
PipelineResult<T>
Pipeline execution result.
PipelineStage
A stage within a pipeline.
PipelineStartedEvent
Pipeline started event.
ProfileOutput
Profile application output.
ProfilePort
Port for profile operations.
Retriever
Abstract retriever interface.
RetrieverOptions
Options for the retriever.
RetryConfig
Retry configuration.
RetryConfiguration
Retry configuration.
RetryPolicy
Retry policy with per-stage overrides.
ScheduledTask
A scheduled task.
Scheduler
Scheduler for managing pipeline triggers.
SearchQuery
A search query.
SearchQueryBuilder
Query builder for constructing search queries.
SearchResult
A search result.
SearchResults
Collection of search results.
SignedBundle
Signed bundle.
SimilarityResult
Result of a similarity search.
SkillInfo
Skill information.
SkillPort
Port for skill operations.
SkillResult
Skill execution result.
SourceInfo
Source information.
StageCompletedEvent
Stage completed event.
StageFailedEvent
Stage failed event.
StageResult
Stage execution result.
StageStartedEvent
Stage started event.
SummarizationInput
Input for summarization pipeline.
SummarizationOutput
Output of summarization pipeline.
SummarizationPipeline
Pipeline for refreshing stale summaries.
TaskExecution
Task execution record.
TermEntry
Term frequency entry for text-based indexing.
Trigger
Base trigger interface.
ValidatedCandidate
Validated candidate.
ValidationResult
Validation result.
Workflow<TContext extends WorkflowContext>
Base workflow interface.
WorkflowAction
Workflow action.
WorkflowActionHandler
Action handler interface.
WorkflowActionHandlerRegistry
Action handler registry.
WorkflowCancelledEvent
Workflow cancelled event.
WorkflowCompletedEvent
Workflow completed event.
WorkflowContext
Workflow context.
WorkflowEvent
Base workflow event.
WorkflowEventIgnoredEvent
Event ignored event.
WorkflowEventListener
Workflow event listener.
WorkflowExecution
Workflow execution.
WorkflowExecutor
Executes workflows.
WorkflowFailedEvent
Workflow failed event.
WorkflowHistoryEntry
Workflow history entry.
WorkflowStartedEvent
Workflow started event.
WorkflowState
Workflow state.
WorkflowStateEnteredEvent
State entered event.
WorkflowStateExitedEvent
State exited event.
WorkflowTransition
Workflow transition.
WorkflowTransitionEvent
Transition event.
WorkflowTransitionGuardedEvent
Transition guarded event.

Enums

ActionType
Action types.
ChunkingStrategy
Chunking strategy.
ClusteringAlgorithm
Clustering algorithm options.
CurationStrategy
Curation strategy.
DocumentType
Types of documents.
ExecutionStatus
Task execution status.
HistoryEntryType
History entry types.
OnErrorStrategy
Error handling strategy.
SearchMode
Search modes.
StageStatus
Stage execution status.
StateType
State types.
TimeoutAction
Timeout action types.
TriggerType
Trigger types.
WorkflowStatus
Workflow status.

Typedefs

ScheduledAction = Future<void> Function(Map<String, dynamic> data)
Action to execute when triggered.

Exceptions / Errors

PipelineExecutionException
Pipeline execution exception.
WorkflowException
Workflow exception.