processor/

directory
v1.0.0-alpha.28 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Mar 11, 2026 License: MIT

Directories

Path Synopsis
Package agenticdispatch provides message routing between users and agentic loops.
Package agenticdispatch provides message routing between users and agentic loops.
Package agenticgovernance provides a governance layer processor component that enforces content policies, PII redaction, injection detection, and rate limiting for agentic message flows.
Package agenticgovernance provides a governance layer processor component that enforces content policies, PII redaction, injection detection, and rate limiting for agentic message flows.
Package agenticloop provides the agentic loop orchestrator component.
Package agenticloop provides the agentic loop orchestrator component.
Package agenticmemory provides a graph-backed agent memory processor component that manages context hydration, fact extraction, and memory checkpointing for agentic loops.
Package agenticmemory provides a graph-backed agent memory processor component that manages context hydration, fact extraction, and memory checkpointing for agentic loops.
Package agenticmodel provides an OpenAI-compatible agentic model processor component that routes agent requests to configured LLM endpoints with retry logic and tool calling support.
Package agenticmodel provides an OpenAI-compatible agentic model processor component that routes agent requests to configured LLM endpoints with retry logic and tool calling support.
Package agentictools provides a tool executor processor component that routes tool calls to registered tool executors with filtering and timeout support.
Package agentictools provides a tool executor processor component that routes tool calls to registered tool executors with filtering and timeout support.
executors
Package executors provides tool executor implementations for the agentic-tools component.
Package executors provides tool executor implementations for the agentic-tools component.
Package graphclustering provides anomaly detection integration for graph-clustering.
Package graphclustering provides anomaly detection integration for graph-clustering.
Package graphembedding provides the graph-embedding component for generating entity embeddings.
Package graphembedding provides the graph-embedding component for generating entity embeddings.
Package graphindex provides the graph-index component for maintaining graph relationship indexes.
Package graphindex provides the graph-index component for maintaining graph relationship indexes.
Package graphindexspatial provides the graph-index-spatial component for spatial indexing.
Package graphindexspatial provides the graph-index-spatial component for spatial indexing.
Package graphindextemporal provides the graph-index-temporal component for temporal indexing.
Package graphindextemporal provides the graph-index-temporal component for temporal indexing.
Package graphingest provides the graph-ingest component for entity and triple ingestion.
Package graphingest provides the graph-ingest component for entity and triple ingestion.
Package graphquery community cache implementation
Package graphquery community cache implementation
Package jsonfilter provides a processor for filtering GenericJSON messages based on field values and comparison rules.
Package jsonfilter provides a processor for filtering GenericJSON messages based on field values and comparison rules.
Package jsongeneric provides a processor for wrapping plain JSON into GenericJSON (core .json.v1) format for integration with StreamKit pipelines.
Package jsongeneric provides a processor for wrapping plain JSON into GenericJSON (core .json.v1) format for integration with StreamKit pipelines.
Package jsonmapprocessor provides a processor for transforming GenericJSON messages through field mapping, adding, removing, and string transformations.
Package jsonmapprocessor provides a processor for transforming GenericJSON messages through field mapping, adding, removing, and string transformations.
Package oasfgenerator provides an OASF (Open Agent Specification Framework) record generator processor component for SemStreams.
Package oasfgenerator provides an OASF (Open Agent Specification Framework) record generator processor component for SemStreams.
Package parser provides utilities for parsing various data formats into structured maps for use with StreamKit message processing.
Package parser provides utilities for parsing various data formats into structured maps for use with StreamKit message processing.
Package reactive provides a reactive workflow engine built on rules engine primitives.
Package reactive provides a reactive workflow engine built on rules engine primitives.
testutil
Package testutil provides testing utilities for the reactive workflow engine.
Package testutil provides testing utilities for the reactive workflow engine.
Package rule - Action execution for ECA rules
Package rule - Action execution for ECA rules
boid
Package boid implements Boids-inspired local coordination rules for multi-agent teams.
Package boid implements Boids-inspired local coordination rules for multi-agent teams.
expression
Package expression - Expression evaluator implementation
Package expression - Expression evaluator implementation

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL