MemoryNotes is durable guidance for an agent, stored as a YAML sequence (recommended) or legacy multi-line string. Each non-empty line becomes one lis

KafkaProducer wraps the franz-go producer with a channel-based interface

ASNInfo represents ASN information

AgentDailyStats represents per-agent daily statistics stored in Redis. All values are aggregated across the cluster for a given date.

AgentLogAPIEntry represents one agent log entry for the frontend.

AgentLogAPIResponse is the response payload for /agent-logs.

AgentLogComment represents a single user comment on an agent log entry.

AgentLogCommentRequest is the payload for creating a new comment.

AgentLogEntry represents a single agent processing log entry stored in Redis. It captures, from the perspective of one Agent node in a project pipelin

AgentTraceStep is one row in the persisted agent trace (Agent Logs / test API). type "llm" = one chat completion request/response (full input messages

AliyunSLSInputConfig holds Aliyun SLS-specific config.

AliyunSLSOutputConfig holds Aliyun SLS-specific config.

Append defines additional fields to append after rule matching. It supports both static values and plugin-based dynamic values.

Public response for frontend to decide login flow

BatchCountComponentUsage performs batch counting for multiple components to improve performance This is especially useful for batch operations like Ap

CEPCondition represents a fully parsed and flattened CEP condition.

--- CEP Condition (parsed result) --- CEPStage represents one stage in the temporal sequence (separated by ->).

CEPStateManager encapsulates state operations for CEP sequences.

CEPToken represents a single token in the condition expression.

CEPValueStore stores CEP event snapshots outside in-memory state. Local cache mode can keep only lightweight pointers in memory and read values back o

CacheEntry represents a cached Redis value

Enhanced pending change management structures

Transaction result for batch operations

ChatResult is the parsed response from a tool-aware LLM call.

CheckCoreCache for rule engine

CheckNodes represents a single check operation in a checklist.

Checklist contains the logical condition and nodes to check.

CircuitBreaker implements circuit breaker pattern for Redis operations

Circuit breaker states

ClickHouseAuthConfig represents authentication configuration for ClickHouse

ClickHouseOutputConfig holds ClickHouse-specific config.

ClickHouseProducer wraps an HTTP client for batch inserts into ClickHouse

ClickHouseTLSConfig represents TLS configuration for ClickHouse

ClusterErrorLogResponse represents aggregated error logs from cluster

Global cluster state variables have been removed Use common.IsCurrentNodeLeader() and common.GetNodeID() instead ClusterManager represents the simplif

ClusterOperationHistoryResponse represents aggregated operations from cluster

ClusterState manages the centralized cluster state

ClusterSystemManager manages system metrics from all cluster nodes (only on leader)

CompareOperation defines the type of string comparison

CompletionPath records which match index was used for each non-absence stage when a sequence completes. Used by enrichment to report the correct event

ComponentHealthInfo contains health information about a component

ComponentInfo represents a component extracted from ProjectNodeSequence

ComponentMonitor monitors the health of all components in running projects

ComponentOperations provides unified component operations for both API and cluster

ComponentReloadRequest represents a request to reload a component

ComponentReloadSource represents the source of component reload

ComponentUpdateManager manages component update operations

ComponentUpdateOperation represents an ongoing component update

Component update states

ComponentUsageCounter provides thread-safe methods to count component usage across projects

ComponentUsageInfo provides usage information for all component types

ContentMatch represents a match within content

DailyStatsData represents daily statistics for a component

DailyStatsManager manages daily message statistics with Redis persistence

DistributedLock represents a Redis-based distributed lock

ElasticsearchAuthConfig represents authentication configuration for Elasticsearch

ElasticsearchOutputConfig holds Elasticsearch-specific config.

ElasticsearchProducer wraps the Elasticsearch client with a channel-based interface

Enhanced change tracking

ErrorLogEntry represents a single error log entry

ErrorLogEntry represents an error log entry for Redis storage

ErrorLogFilter represents filter parameters for error logs

ErrorLogResponse represents the response for error log queries

EventDef defines the matching criteria for a single event within a sequence.

* Global event manager - Unified handling of component change events * Solves duplicate registration and memory leak issues

Note: File operation functions (GetExt, GetComponentPath, WriteComponentFile, ReadComponent) have been moved to file_operations.go for better code org

FileHashInfo represents file hash information

HeartbeatData represents heartbeat information

HeartbeatManager manages heartbeat and version sync

Input represents an input component that consumes data from external sources

InputConfig is the YAML config for an input.

InputType defines the type of input source.

Instruction represents a single operation

InstructionManager manages version-based synchronization

===================================================== INTELLIGENT DATA STRUCTURES ===================================================== IntelligentSam

IntelligentSampleDataResponse represents enhanced response with analysis

KafkaCompressionType defines supported compression types

KafkaConsumer wraps a franz-go consumer with a channel-based interface.

KafkaInputConfig holds Kafka-specific config.

KafkaOutputConfig holds Kafka-specific config.