Functions — github.com/EBWi11/AgentSmith-HUB

hub / github.com/EBWi11/AgentSmith-HUB / functions

Functions2,165 in github.com/EBWi11/AgentSmith-HUB

⨍ Functions 2,165◇ Types & classes 243

↓ 1 callersMethodTokenParser

(ori string)

src/rules_engine/engine_condition.go:181

↓ 1 callersFunctionToolResultMessage

ToolResultMessage creates a tool-result message to feed back to the LLM.

src/agent/llm.go:101

↓ 1 callersMethodTryAcquire

TryAcquire attempts to acquire the lock with a timeout

src/common/redis.go:569

↓ 1 callersFunctionValidateComponent

Component validation helpers

src/project/project_struct.go:1139

↓ 1 callersFunctionVerify

(path string, raw string)

src/project/project.go:597

↓ 1 callersFunctionVerify

(filePath, raw string)

src/skill/skill.go:86

↓ 1 callersFunctionVerify

(path string, raw string)

src/rules_engine/engine_struct.go:1893

↓ 1 callersFunctionVerifyOIDCToken

VerifyOIDCToken verifies an ID token and returns claims map

src/api/auth.go:56

↓ 1 callersMethodWaitForAllFollowersIdle

WaitForAllFollowersIdle waits for all followers to finish executing instructions

src/cluster/instruction_sync.go:869

↓ 1 callersMethodabsenceScannerLoop

absenceScannerLoop periodically checks for expired absence sequences and triggers alerts.

src/rules_engine/engine_core.go:316

↓ 1 callersFunctionaddRuleToXML

addRuleToXML adds a new rule to the XML before the closing </root> tag

src/api/components.go:2932

↓ 1 callersFunctionanalyzeDataFields

(data map[string]interface{}, prefix string, fieldCounts map[string]int)

src/api/sample_data_intelligent.go:565

↓ 1 callersFunctionanalyzeDataQuality

(sampleData map[string]interface{}, requiredFields []string)

src/api/sample_data_intelligent.go:419

↓ 1 callersFunctionanalyzeFieldUsage

(sampleData map[string]interface{}, rulePurpose string)

src/api/sample_data_intelligent.go:489

↓ 1 callersFunctionanalyzePluginUsage

analyzePluginUsage analyzes how a plugin is used across rulesets and projects

src/api/components.go:3129

↓ 1 callersFunctionanalyzePluginUsageInRuleset

analyzePluginUsageInRuleset analyzes how a plugin is used in a specific ruleset

src/api/components.go:3187

↓ 1 callersMethodappendInstructionLocked

(instruction *Instruction)

src/cluster/instruction_sync.go:295

↓ 1 callersMethodapplyInstruction

applyInstruction applies a single instruction snapshot read during Phase 1.

src/cluster/sync_listener.go:735

↓ 1 callersMethodapplySequenceEventAppends

(seq *Sequence, matchedEventIDs []string, data map[string]interface{}, state *SequenceState, ruleCache map[str

src/rules_engine/engine_core.go:1503

↓ 1 callersFunctionassessFieldPerformanceImpact

(fieldName string, stats FieldValueStats)

src/api/sample_data_intelligent.go:645

↓ 1 callersFunctionassessPerformanceLoad

(proj *project.Project)

src/api/sample_data_intelligent.go:344

↓ 1 callersMethodattachLlmOutput

(msg map[string]interface{}, output map[string]interface{})

src/agent/agent_loop.go:417

↓ 1 callersMethodavx2BatchCompare

(data string, patterns []string, operation CompareOperation)

src/rules_engine/simd_amd64.go:118

↓ 1 callersFunctionbenchmarkFullCoverageGoldenEvent

()

src/rules_engine/engine_tps_bench_test.go:53

↓ 1 callersMethodbuildAllToolDefinitions

()

src/agent/agent.go:443

↓ 1 callersFunctionbuildCardContent

buildCardContent builds a Feishu interactive card from alert event data. Priority fields are shown first; remaining non-blank string fields are append

config/plugin/pushUrentAlertByLark.go:53

↓ 1 callersFunctionbuildClickHouseTLSConfig

buildClickHouseTLSConfig creates a *tls.Config from ClickHouseTLSConfig

src/common/clickhouse.go:52

↓ 1 callersMethodbuildEffectiveSystemPrompt

buildEffectiveSystemPrompt appends memory_notes to the system prompt so auto-generated memory can influence subsequent agent decisions.

src/agent/agent_loop.go:455

↓ 1 callersMethodbuildInsertURL

buildInsertURL constructs the ClickHouse HTTP insert URL for the given host

src/common/clickhouse.go:152

↓ 1 callersFunctionbuildIrisAlertContext

(data map[string]interface{})

config/plugin/pushAlertToIris.go:185

↓ 1 callersFunctionbuildIrisAlertDescription

(data map[string]interface{})

config/plugin/pushAlertToIris.go:123

↓ 1 callersFunctionbuildIrisAlertPayload

(customerID int, classificationID int, data map[string]interface{})

config/plugin/pushAlertToIris.go:76

↓ 1 callersFunctionbuildIrisAlertSource

(data map[string]interface{})

config/plugin/pushAlertToIris.go:163

↓ 1 callersFunctionbuildIrisAssets

(data map[string]interface{})

config/plugin/pushAlertToIris.go:204

↓ 1 callersFunctionbuildIrisEventTime

(data map[string]interface{})

config/plugin/pushAlertToIris.go:173

↓ 1 callersFunctionbuildIrisIOCs

(data map[string]interface{})

config/plugin/pushAlertToIris.go:229

↓ 1 callersFunctionbuildIrisTags

(data map[string]interface{})

config/plugin/pushAlertToIris.go:260

↓ 1 callersFunctionbuildPNSDirect

buildPNSDirect builds ProjectNodeSequence for flow nodes

src/api/testing.go:2185

↓ 1 callersFunctionbuildParametersSchema

(params []plugin.PluginParameter)

src/agent/agent_tools.go:69

↓ 1 callersFunctionbuildPluginTestArgs

(data map[string]interface{})

src/api/testing.go:51

↓ 1 callersFunctionbuildPluginUsageIndex

(includeUsage bool)

src/api/component_usage_indexes.go:49

↓ 1 callersMethodbuildRequest

buildRequest creates an HTTP request with authentication headers

src/common/clickhouse.go:166

↓ 1 callersFunctionbuildSelectedMatchedEventIDs

(seq Sequence, matchedStages []int, stageBindings map[int][]string)

src/rules_engine/engine_core.go:1469

↓ 1 callersMethodbuildSequenceResult

buildSequenceResult builds the final enriched data when a sequence completes. The current event provides the base data, enriched with: - "#<event_id>"

src/rules_engine/engine_core.go:1891

↓ 1 callersFunctionbuildStressRuleset

(t *testing.T, xmlContent string)

src/rules_engine/cep_stress_test.go:9

↓ 1 callersMethodcalculateCPUPercent

calculateCPUPercent calculates CPU usage percentage for the current process using real CPU time

src/common/system_monitor.go:150

↓ 1 callersFunctioncalculateFreshnessScore

(timestamp time.Time)

src/api/sample_data_intelligent.go:579

↓ 1 callersFunctioncalculateProjectRelevance

(proj *project.Project, rulePurpose string)

src/api/sample_data_intelligent.go:282

↓ 1 callersFunctioncalculateVolumeScore

(sampleCount int)

src/api/sample_data_intelligent.go:595

↓ 1 callersFunctioncallLLM

callLLM performs a single chat completion using apiKey and baseURL from common.Config

src/local_plugin/llm_call/llm_call.go:48

↓ 1 callersMethodcheckAbsenceFromStage

checkAbsenceFromStage recursively checks if the sequence can complete considering that the time window has expired (absence stages auto-satisfy). Uses

src/rules_engine/cep_condition.go:715

↓ 1 callersMethodcheckCompleteFromStage

checkCompleteFromStage recursively checks completion starting from stageIdx with the constraint that all matches must have timestamp > prevTimestamp.

src/rules_engine/cep_condition.go:635

↓ 1 callersMethodcheckVersionSync

checkVersionSync checks if follower needs version sync

src/cluster/heartbeat_simple.go:318

↓ 1 callersMethodcleanup

cleanup removes data older than 1 hour

src/common/system_monitor.go:358

↓ 1 callersMethodcleanup

cleanup removes data older than 5 minutes (nodes that haven't reported recently)

src/common/system_monitor.go:602

↓ 1 callersMethodcleanupExpiredData

cleanupExpiredData removes expired data

src/common/redis_sample_manager.go:299

↓ 1 callersMethodcleanupInputChannel

()

src/project/project.go:2296

↓ 1 callersMethodcleanupLoop

cleanupLoop periodically removes old data (older than 1 hour)

src/common/system_monitor.go:341

↓ 1 callersMethodcleanupLoop

cleanupLoop periodically removes old data (older than 5 minutes)

src/common/system_monitor.go:585

↓ 1 callersMethodcleanupLoop

()

src/rules_engine/cep_value_store.go:266

↓ 1 callersFunctioncleanupObsoleteChanges

()

src/api/pending_changes_sync.go:216

↓ 1 callersMethodcleanupOfflineNodes

cleanupOfflineNodes removes offline nodes

src/cluster/heartbeat_simple.go:347

↓ 1 callersMethodcleanupRulesetChannel

()

src/project/project.go:2310

↓ 1 callersFunctionclearProjectAutoStopInFlight

(projectID string)

src/project/project.go:436

↓ 1 callersFunctionclearProjectTestOutputChannels

(tempProject *project.Project)

src/api/testing.go:860

↓ 1 callersFunctioncloneAgentConfig

(cfg *AgentConfig)

src/agent/agent.go:160

↓ 1 callersFunctioncloneMessagesForTrace

(msgs []Message)

src/agent/agent_loop.go:51

↓ 1 callersMethodcollectAgentInboundEdges

(targetPNS map[string]struct{})

src/project/project.go:1527

↓ 1 callersMethodcollectAgentPNSByID

(agentID string)

src/project/project.go:1514

↓ 1 callersFunctioncollectEventIDs

collectEventIDs extracts all literal event IDs from an AST subtree.

src/rules_engine/cep_condition.go:409

↓ 1 callersFunctioncollectEventIDsRecursive

(ast ExprAST, ids *[]string)

src/rules_engine/cep_condition.go:415

↓ 1 callersFunctioncollectFieldStats

(data map[string]interface{}, prefix string, fieldStats map[string]map[interface{}]int, fieldTypes map[string

src/api/sample_data_intelligent.go:606

↓ 1 callersFunctioncollectHitFields

collectHitFields walks through all operators in a rule and collects field names that are relevant to the rule's matching logic (check, threshold, iter

src/rules_engine/engine_core.go:2534

↓ 1 callersMethodcollectInboundEdges

(targetPNS map[string]struct{})

src/project/project.go:1465

↓ 1 callersMethodcollectLoop

collectLoop periodically collects system metrics

src/common/system_monitor.go:85

↓ 1 callersFunctioncollectProjectTestOutputs

(tempProject *project.Project, outputChannels map[string]chan map[string]interface{}, outputResults map[string

src/api/testing.go:923

↓ 1 callersFunctioncollectProjectsReferencingAgent

(agentID string)

src/project/project_struct.go:738

↓ 1 callersMethodcollectRulesetPNSByID

(rulesetID string)

src/project/project.go:1452

↓ 1 callersFunctioncollectRulesetPluginUsage

(r *rules_engine.Ruleset, knownPlugins map[string]struct{})

src/api/component_usage_indexes.go:66

↓ 1 callersFunctionconnectCheck

(c echo.Context)

src/api/testing.go:1354

↓ 1 callersFunctionconnectCheckWithConfig

connectCheckWithConfig performs connectivity check using custom configuration

src/api/testing.go:1792

↓ 1 callersFunctioncontains

(slice []string, item string)

src/api/sample_data_intelligent.go:324

↓ 1 callersFunctioncontainsSequenceOp

containsSequenceOp checks if an AST subtree contains the -> operator. Used to reject expressions like !(a -> b) where -> appears inside a stage.

src/rules_engine/cep_condition.go:394

↓ 1 callersFunctionconvertPluginArgument

convertPluginArgument preserves all types for plugin consumption This allows plugins to work with original data types instead of strings

src/rules_engine/engine_utils.go:126

↓ 1 callersFunctioncopyDocsToPublic

()

web/vite.config.js:10

↓ 1 callersMethodcreate_producer

Create Kafka producer with optimized settings for high throughput

docs/kafka_producer_perf_test.py:68

↓ 1 callersMethoddeleteRedisState

(key string)

src/rules_engine/cep_state.go:603

↓ 1 callersMethoddeleteSnapshotDirect

deleteSnapshotDirect deletes a snapshot and its expiry index entry. The expiresAtNs is parsed from the ref itself instead of performing an extra db.Ge

src/rules_engine/cep_value_store.go:324

↓ 1 callersFunctiondetectARMv8Crypto

()

src/rules_engine/simd_arm64.go:20

↓ 1 callersFunctiondetectAVX2

CPU capability detection using Go's cpu package

src/rules_engine/simd_amd64.go:11

↓ 1 callersMethoddetectCycle

detectCycle detects if there are cycles in the data flow using DFS

src/project/project.go:857

↓ 1 callersFunctiondetectNEON

ARM64-specific SIMD capabilities detection

src/rules_engine/simd_arm64.go:13

↓ 1 callersFunctiondetectSSE42

()

src/rules_engine/simd_amd64.go:15

↓ 1 callersFunctiondetectSSSE3

()

src/rules_engine/simd_amd64.go:19

↓ 1 callersMethoddisconnectAgentInboundEdges

(edges []agentInboundEdge)

src/project/project.go:1546

↓ 1 callersMethoddisconnectRulesetInboundEdges

(edges []rulesetInboundEdge)

src/project/project.go:1484

↓ 1 callersMethoddownstreamSnapshot

()

src/input/input.go:586

↓ 1 callersMethoddownstreamSnapshot

()

src/agent/agent.go:235

↓ 1 callersMethoddrainRemainingMessages

drainRemainingMessages processes any remaining messages in the message channel

src/common/kafka.go:219

↓ 1 callersMethoddrainRemainingMessages

drainRemainingMessages processes any remaining messages in the Kafka client

src/common/kafka.go:491

← previous next →701–800 of 2,165, ranked by callers