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 callersFunctionisSupportedType

(t string)

src/local_plugin/get_config/get_config.go:65

↓ 1 callersFunctionisUserAllowed

(claims map[string]interface{})

src/api/auth.go:77

↓ 1 callersMethodlistenHeartbeats

listenHeartbeats listens for heartbeats and handles version sync (leader only)

src/cluster/heartbeat_simple.go:203

↓ 1 callersMethodlistenSyncCommands

listenSyncCommands listens for sync commands from leader

src/cluster/sync_listener.go:186

↓ 1 callersFunctionloadHubConfig

loadHubConfig loads config.yaml inside given root directory into common.Config.

src/main.go:649

↓ 1 callersFunctionloadLocalComponents

()

src/main.go:330

↓ 1 callersFunctionloadLocalProjects

()

src/main.go:549

↓ 1 callersFunctionloadRulesEngineTPSScenarios

(b *testing.B)

src/rules_engine/engine_tps_bench_test.go:90

↓ 1 callersFunctionloadRuntimeConfig

* Load runtime configuration from external file * This allows configuration changes without recompilation

web/src/config/index.js:42

↓ 1 callersFunctionmain

()

docs/kafka_producer_perf_test.py:210

↓ 1 callersFunctionmapDeepCopyWithExtraCapacity

mapDeepCopyWithExtraCapacity performs a deep copy with additional capacity for rule operations extraCap: additional capacity for fields that will be a

src/rules_engine/engine_core.go:2493

↓ 1 callersFunctionmarkProjectAutoStopInFlight

(projectID string)

src/project/project.go:426

↓ 1 callersFunctionmatchedEventIDsForStageExpr

(expr ExprAST, matchMap map[string]bool)

src/rules_engine/cep_condition.go:544

↓ 1 callersFunctionmatchesOperationFilter

matchesOperationFilter checks if an operation record matches the filter criteria

src/common/operations.go:502

↓ 1 callersFunctionmin

(a, b int)

src/api/sample_data_intelligent.go:333

↓ 1 callersMethodneonBatchCompare

neonBatchCompare processes multiple patterns using NEON concepts

src/rules_engine/simd_arm64.go:255

↓ 1 callersMethodneonCompareAtPosition

neonCompareAtPosition performs optimized string comparison using NEON concepts

src/rules_engine/simd_arm64.go:103

↓ 1 callersMethodneonVectorCompare

neonVectorCompare performs 16-byte aligned comparison using NEON concepts

src/rules_engine/simd_arm64.go:134

↓ 1 callersFunctionnewCEPParser

(tokens []CEPToken)

src/rules_engine/cep_condition.go:209

↓ 1 callersFunctionnewKnowledgeSkill

(id, description, content string)

src/skill/skill_knowledge.go:14

↓ 1 callersFunctionnewLLMTraceStep

(round int, model string, input []Message, resp *ChatResult, callErr error)

src/agent/agent_loop.go:86

↓ 1 callersFunctionnewSkillAdapter

(impl skill.SkillImplementation)

src/agent/skill.go:12

↓ 1 callersMethodnextHost

nextHost returns the next host in round-robin fashion

src/common/clickhouse.go:143

↓ 1 callersFunctionnormalizeMemoryLines

(lines []string)

src/agent/memory_notes.go:51

↓ 1 callersFunctionnormalizeParams

(params = {})

web/src/api/index.js:171

↓ 1 callersFunctionnormalizeRawContent

(raw)

web/src/api/index.js:129

↓ 1 callersMethodparseBinOpRHS

(execPrev int, lhs ExprAST)

src/rules_engine/engine_condition.go:152

↓ 1 callersFunctionparseDel

(element xml.StartElement, decoder *XMLDecoder, elementLine int)

src/rules_engine/engine_parser.go:1042

↓ 1 callersFunctionparseExpiresNsFromRef

parseExpiresNsFromRef extracts expiresAtNs encoded in the ref string. Ref format: "<expiresAtNs>|<ts>-<counter>".

src/rules_engine/cep_value_store.go:366

↓ 1 callersFunctionparseIterator

(element xml.StartElement, decoder *XMLDecoder, elementLine int)

src/rules_engine/engine_parser.go:329

↓ 1 callersFunctionparseJSONArgs

(raw string)

src/agent/agent_tools.go:151

↓ 1 callersFunctionparseModify

(element xml.StartElement, decoder *XMLDecoder, elementLine int)

src/rules_engine/engine_parser.go:938

↓ 1 callersFunctionparseOutputMessage

(content string)

src/agent/agent_loop.go:464

↓ 1 callersFunctionparsePlugin

(element xml.StartElement, decoder *XMLDecoder, elementLine int)

src/rules_engine/engine_parser.go:999

↓ 1 callersMethodparsePrimary

parsePrimary handles: primary := '(' sequence_expr ')' | literal

src/rules_engine/cep_condition.go:322

↓ 1 callersFunctionparseProjectComponentsDirect

parseProjectComponentsDirect parses project configuration and extracts component information without creating a project instance

src/api/testing.go:1675

↓ 1 callersFunctionparseProjectInputsDirect

(projectContent string)

src/api/testing.go:1284

↓ 1 callersFunctionparseProjectSequencesDirect

parseProjectSequencesDirect parses project configuration and extracts sequences without creating a project instance

src/api/testing.go:2051

↓ 1 callersFunctionparseSequence

parseSequence parses a <sequence> element and its nested <event> and <condition> children.

src/rules_engine/engine_parser.go:484

↓ 1 callersFunctionparseSequenceEvent

parseSequenceEvent parses an <event> element within a <sequence>.

src/rules_engine/engine_parser.go:587

↓ 1 callersMethodparserKey

(key string)

src/common/daily_stats_manager.go:169

↓ 1 callersMethodpersistenceLoop

persistenceLoop periodically collects data from all components and saves to Redis Improved to handle high concurrency scenarios with better error hand

src/common/daily_stats_manager.go:243

↓ 1 callersMethodplatformOptimizedBatchCompare

ARM64-optimized batch string comparison

src/rules_engine/simd_arm64.go:213

↓ 1 callersMethodpluginIdentifier

()

src/plugin/plugin.go:253

↓ 1 callersMethodprint_stats

Print performance statistics

docs/kafka_producer_perf_test.py:187

↓ 1 callersMethodprocessAndForward

(msg map[string]interface{})

src/agent/agent_loop.go:159

↓ 1 callersMethodprocessMessage

(msg map[string]interface{})

src/agent/agent_loop.go:334

↓ 1 callersFunctionprojectTestTimeoutWarning

(timeout time.Duration)

src/api/testing.go:956

↓ 1 callersFunctionpushMessage

pushMessage sends a message to a Feishu chat. msgType is "interactive" (card) or "text"; content is the pre-built content string.

config/plugin/pushUrentAlertByLark.go:187

↓ 1 callersFunctionpushMessageAndPhone

(msgType string, content string, appid string, appsk string, receive_id string, phonetimeleft int, phonetimeri

config/plugin/pushUrentAlertByLark.go:272

↓ 1 callersFunctionqueryShodanAPIWithKey

queryShodanAPIWithKey queries the Shodan API for IP information

src/local_plugin/shodan/shodan.go:166

↓ 1 callersFunctionqueryThreatBookAPIWithKey

queryThreatBookAPIWithKey queries the ThreatBook API

src/local_plugin/threatbook/threatbook.go:270

↓ 1 callersFunctionqueryVirusTotalAPIWithKey

queryVirusTotalAPIWithKey queries the VirusTotal API for file hash information

src/local_plugin/virustotal/virustotal.go:160

↓ 1 callersFunctionreadFile

(path string)

src/agent/agent.go:421

↓ 1 callersFunctionreadLocalPluginSource

readLocalPluginSource reads the source code of a built-in plugin

src/api/components.go:2198

↓ 1 callersFunctionreadToken

readToken reads token from environment variable first, then from .token file, or creates one when create==true.

src/main.go:627

↓ 1 callersFunctionrecommendFieldsForPurpose

(availableFields []string, rulePurpose string)

src/api/sample_data_intelligent.go:654

↓ 1 callersMethodreconcileBeforeStart

()

src/output/output.go:436

↓ 1 callersMethodreconcileBeforeStart

()

src/input/input.go:324

↓ 1 callersMethodreconcileBeforeStart

()

src/agent/agent.go:324

↓ 1 callersMethodreconcileBeforeStart

()

src/rules_engine/engine_core.go:287

↓ 1 callersMethodredisSymbols

()

src/plugin/plugin.go:318

↓ 1 callersMethodrefreshLock

()

src/cluster/leader_locker.go:64

↓ 1 callersFunctionremoveRuleFromXML

Helper functions for XML manipulation removeRuleFromXML removes a rule with the specified ID from the XML

src/api/components.go:2703

↓ 1 callersFunctionreplaceTimePatterns

replaceTimePatterns replaces time patterns in index name with actual values

src/common/elasticsearch.go:45

↓ 1 callersFunctionreportTPS

(b *testing.B)

src/rules_engine/engine_tps_bench_test.go:44

↓ 1 callersFunctionresetErrorCount

()

web/src/composables/useSmartRefresh.js:49

↓ 1 callersMethodresetLoadState

()

src/plugin/plugin.go:263

↓ 1 callersFunctionresolveHubAccess

resolveHubAccess returns the leader base URL and auth token, or an error if unavailable.

src/local_plugin/add_rule/add_rule.go:111

↓ 1 callersFunctionruleExistsInXML

ruleExistsInXML checks if a rule with the specified ID exists in the XML

src/api/components.go:2884

↓ 1 callersFunctionrulesetUsesPlugin

(ruleset *rules_engine.Ruleset, pluginID string)

src/project/project.go:58

↓ 1 callersMethodrun

()

src/common/elasticsearch.go:331

↓ 1 callersMethodrun

run processes messages from the input channel and sends them to Kafka It handles message serialization and error reporting

src/common/kafka.go:177

↓ 1 callersMethodrun

run continuously polls for messages from Kafka and forwards them to the message channel It handles message deserialization and error reporting

src/common/kafka.go:441

↓ 1 callersMethodrun

()

src/common/aliyun_sls.go:183

↓ 1 callersMethodrun

()

src/common/clickhouse.go:185

↓ 1 callersMethodrun

Run the performance test

docs/kafka_producer_perf_test.py:147

↓ 1 callersMethodrunComponents

()

src/project/project.go:2739

↓ 1 callersMethodrunOne

()

src/rules_engine/engine_tps_bench_test.go:38

↓ 1 callersMethodsamplingController

samplingController runs in a separate goroutine to control sampling flags

src/common/sampler.go:70

↓ 1 callersFunctionsearchInContent

searchInContent searches for query within content and returns matches

src/api/components.go:2468

↓ 1 callersMethodsendBatch

sendBatch sends a batch of documents to Elasticsearch with retry logic

src/common/elasticsearch.go:388

↓ 1 callersMethodsendBatch

sendBatch sends a batch of documents to ClickHouse via HTTP with retry logic

src/common/clickhouse.go:234

↓ 1 callersMethodsetRedisAbsenceTracker

setRedisAbsenceTracker stores an absence tracking key in Redis.

src/rules_engine/cep_state.go:490

↓ 1 callersFunctionsetupProjectTestOutputChannels

(tempProject *project.Project, testProjectId string)

src/api/testing.go:849

↓ 1 callersMethodshardFor

(pattern string)

src/rules_engine/regex_cache.go:60

↓ 1 callersFunctionshouldEnableKimiThinking

shouldEnableKimiThinking determines whether to attach Kimi-style "thinking" params. This is intentionally conservative and only triggers when explicit

src/agent/llm.go:230

↓ 1 callersFunctionshouldQueueProjectRefresh

(instruction Instruction)

src/cluster/sync_listener.go:538

↓ 1 callersFunctionshouldUseSIMD

shouldUseSIMD determines whether to use SIMD optimization based on operation type and data characteristics

src/rules_engine/engine_core.go:2683

↓ 1 callersMethodsimdExecuteANDLogic

simdExecuteANDLogic uses SIMD to process AND logic efficiently

src/rules_engine/simd_integration.go:175

↓ 1 callersMethodsimdExecuteORLogic

simdExecuteORLogic uses SIMD to process OR logic efficiently

src/rules_engine/simd_integration.go:117

↓ 1 callersMethodsnapshotEventData

snapshotEventData creates a deep copy snapshot of event data for cross-event reference. Deep copy is essential because the original data may be modifi

src/rules_engine/engine_core.go:1882

↓ 1 callersFunctionsortCheckNodes

Legacy ParseRulesetFromByte has been removed - use ParseRuleset + RulesetBuild instead

src/rules_engine/engine_struct.go:3136

↓ 1 callersMethodsse42BatchCompare

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

src/rules_engine/simd_amd64.go:164

↓ 1 callersFunctionstableKeyPart

(v interface{})

src/local_plugin/suppress/suppress.go:61

↓ 1 callersMethodstartBatchProcessor

startBatchProcessor processes samples in batches to improve Redis performance

src/common/redis_sample_manager.go:330

↓ 1 callersMethodstartCleanup

startCleanup starts the cleanup routine

src/common/redis_sample_manager.go:287

↓ 1 callersMethodstartFollowerHeartbeat

startFollowerHeartbeat starts follower heartbeat services

src/cluster/heartbeat_simple.go:109

↓ 1 callersMethodstartLeaderHeartbeat

startLeaderHeartbeat starts leader heartbeat services

src/cluster/heartbeat_simple.go:69

↓ 1 callersFunctionstartPprofServer

startPprofServer starts the pprof HTTP server if enabled in configuration

src/main.go:776

← previous next →901–1,000 of 2,165, ranked by callers