Functions — github.com/EBWi11/AgentSmith-HUB

CodeHub MCPcopy Create free account

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

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

⨍ Functions 2,165◇ Types & classes 243

↓ 2 callersMethodHotReloadAgent

HotReloadAgent swaps all running PNS instances of an agent in this project without restarting the project.

src/project/project.go:1727

↓ 2 callersMethodHotReloadRuleset

HotReloadRuleset swaps all running PNS instances of a ruleset in this project without restarting the project. It fully stops old ruleset instances to

src/project/project.go:1618

↓ 2 callersFunctionISNULL

(data string, _ string)

src/rules_engine/engine_utils.go:492

↓ 2 callersFunctionIsCurrentNodeLeader

IsCurrentNodeLeader returns whether current node is the leader

src/common/cluster_state.go:49

↓ 2 callersMethodLocalCacheFRQClassify

(tmpKey string, groupByKey string, rangeInt int, threshold int)

src/rules_engine/engine_utils.go:95

↓ 2 callersFunctionNewTestPlugin

NewTestPlugin creates a plugin for testing without adding it to the global registry

src/plugin/plugin.go:227

↓ 2 callersMethodParseExpression

src/rules_engine/engine_condition.go:93

↓ 2 callersMethodPublishComponentDelete

PublishComponentDelete publishes component deletion instruction

src/cluster/instruction_sync.go:551

↓ 2 callersFunctionRecordComponentDelete

RecordComponentDelete records a component deletion operation to Redis

src/api/operations_history.go:142

↓ 2 callersFunctionRedisDelMultiple

RedisDelMultiple deletes multiple keys at once

src/common/redis.go:340

↓ 2 callersFunctionRedisFRQClassify

RedisFRQClassify performs frequency classification using Redis tmpKey: Temporary key for tracking groupByKey: Base key for grouping rangeInt: Time ran

src/rules_engine/engine_utils.go:72

↓ 2 callersFunctionRedisGet

src/common/redis.go:270

↓ 2 callersMethodResetProduceTotal

ResetProduceTotal resets the total produced count to zero. This should only be called during component cleanup or forced restart.

src/output/output.go:956

↓ 2 callersMethodSIMDContainsCaseInsensitive

SIMDContainsCaseInsensitive performs case-insensitive contains with SIMD

src/rules_engine/simd_optimizations.go:44

↓ 2 callersFunctionSafeDeletePNSRulesetDownstream

(rulesetPNS, downstreamID string)

src/project/project_struct.go:1243

↓ 2 callersFunctionSafeSetAgentDownstream

(agentPNS, downstreamID string, ch *chan map[string]interface{})

src/project/project_struct.go:627

↓ 2 callersFunctionSafeSetInputDownstream

(inputID, downstreamID string, ch *chan map[string]interface{})

src/project/project_struct.go:1224

↓ 2 callersFunctionSafeSetPNSRulesetDownstream

(rulesetPNS, downstreamID string, ch *chan map[string]interface{})

src/project/project_struct.go:1252

↓ 2 callersFunctionSetClusterState

SetClusterState sets the cluster state (called during initialization)

src/common/cluster_state.go:21

↓ 2 callersFunctionSetInput

(id string, inp *input.Input)

src/project/project_struct.go:384

↓ 2 callersFunctionSetLeaderState

SetLeaderState sets the leader state for this node

src/common/global.go:36

↓ 2 callersFunctionSetRegexResultCacheCapacity

SetRegexResultCacheCapacity updates the cache capacity

src/rules_engine/regex_result_cache.go:201

↓ 2 callersFunctionSetRuleset

(id string, rs *rules_engine.Ruleset)

src/project/project_struct.go:452

↓ 2 callersMethodSetTestMode

SetTestMode configures the input for test mode by disabling sampling and other global state interactions

src/input/input.go:1053

↓ 2 callersMethodStart

Start starts the project and all its components

src/project/project.go:1145

↓ 2 callersMethodStart

Start the ruleset engine, consuming data from upstream and writing checked data to downstream.

src/rules_engine/engine_core.go:103

↓ 2 callersFunctionStringToList

(checkKey string)

src/common/utils.go:173

↓ 2 callersMethodUpdateChangeStatus

UpdateChangeStatus updates the status of a pending change

src/api/pending_changes.go:162

↓ 2 callersFunctionUrlValueToMap

UrlValueToMap converts url.Values (map[string][]string) to map[string]interface{}. Joins multiple values into a single string.

src/common/utils.go:198

↓ 2 callersFunctionVerify

(path string, raw string)

src/input/input.go:107

↓ 2 callersFunctionVerify

(filePath, raw string)

src/agent/agent.go:191

↓ 2 callersMethodVerifyChange

VerifyChange verifies a single pending change

src/api/pending_changes.go:180

↓ 2 callersMethodYaegiLoad

YaegiLoad is a public wrapper for yaegiLoad to allow external access

src/plugin/plugin.go:844

↓ 2 callersFunctionagentTestRequestConfig

web/src/api/index.js:164

↓ 2 callersFunctionanalyzeProjectProfile

(proj *project.Project, rulePurpose string)

src/api/sample_data_intelligent.go:209

↓ 2 callersFunctionapplyDefaults

(cfg *AgentConfig)

src/agent/agent.go:425

↓ 2 callersMethodareAllComponentsRunning

areAllComponentsRunning checks if all project components are in running state

src/project/project.go:1881

↓ 2 callersFunctionassertRulePluginPointers

(t *testing.T, rule Rule, expected *pluginpkg.Plugin)

src/rules_engine/ruleset_reload_test.go:62

↓ 2 callersMethodatomicStatusTransition

atomicStatusTransition performs atomic status checking and transition

src/project/project_struct.go:141

↓ 2 callersMethodavx2Contains

AVX2-optimized implementations (placeholder for future assembly optimization)

src/rules_engine/simd_amd64.go:107

↓ 2 callersFunctionbuildAPIURL

buildAPIURL builds the appropriate API URL based on query type

src/local_plugin/threatbook/threatbook.go:254

↓ 2 callersFunctionbuildAliyunSLSFields

(msg map[string]interface{})

src/common/aliyun_sls.go:125

↓ 2 callersFunctionbuildAuthMiddleware

(legacyToken string)

src/api/routes_shared.go:9

↓ 2 callersFunctionbuildClickHouseHTTPClient

buildClickHouseHTTPClient creates an HTTP client with optional TLS

src/common/clickhouse.go:87

↓ 2 callersFunctionbuildPluginToolDefinitions

(toolsConfig interface{})

src/agent/agent_tools.go:10

↓ 2 callersFunctionbuildProjectRefreshPlans

(instructions []Instruction)

src/cluster/sync_listener.go:551

↓ 2 callersFunctioncallChatWithTools

callChatWithTools performs a single tool-aware LLM call. reasoningMode: - "disabled": never send provider-specific reasoning params - "enabled" : alwa

src/agent/llm.go:114

↓ 2 callersMethodcancelActiveProcesses

src/agent/agent_loop.go:321

↓ 2 callersMethodcleanupExpired

(nowNs int64, limit int)

src/rules_engine/cep_value_store.go:281

↓ 2 callersFunctionclearValidation

web/src/composables/useComponentValidation.js:38

↓ 2 callersMethodcollectMetrics

collectMetrics collects current system metrics

src/common/system_monitor.go:105

↓ 2 callersMethodcommitPutBatch

commitPutBatch writes data and expiry-index keys for each request. The refIndex key is no longer needed because expiresAtNs is encoded in the ref stri

src/rules_engine/cep_value_store.go:248

↓ 2 callersMethodcompareVectorChunk

compareVectorChunk compares up to 16 bytes using NEON-style operations

src/rules_engine/simd_arm64.go:193

↓ 2 callersFunctioncontainsString

containsString checks if a string slice contains a specific string

src/api/components.go:3248

↓ 2 callersMethoddeleteLocalState

src/rules_engine/cep_state.go:557

↓ 2 callersMethoddownstreamSnapshot

src/rules_engine/engine_struct.go:216

↓ 2 callersMethodenrichSequenceResultData

enrichSequenceResultData adds sequence metadata to the result. Internal "#<event_id>" fields are kept during rule execution for cross-event references

src/rules_engine/engine_core.go:1914

↓ 2 callersFunctionensureLlmMap

(msg map[string]interface{})

src/agent/agent_loop.go:405

↓ 2 callersMethodevaluateEventChecklist

evaluateEventChecklist evaluates a checklist within an event definition.

src/rules_engine/engine_core.go:1618

↓ 2 callersMethodexecuteAppend

executeAppend executes an append operation

src/rules_engine/engine_core.go:1960

↓ 2 callersMethodexecuteCheckList

executeCheckList executes a checklist operation

src/rules_engine/engine_core.go:951

↓ 2 callersMethodexecuteDeferredProjectCommands

(commands []deferredProjectCommand)

src/cluster/sync_listener.go:714

↓ 2 callersMethodexecuteDel

executeDel executes a delete operation

src/rules_engine/engine_core.go:2142

↓ 2 callersMethodexecuteModify

executeModify executes a modify operation

src/rules_engine/engine_core.go:2036

↓ 2 callersMethodexecutePlugin

executePlugin executes a plugin operation

src/rules_engine/engine_core.go:2159

↓ 2 callersMethodexecutePostSequenceOps

executePostSequenceOps executes operations that follow a sequence in the rule's queue. This is needed for absence-triggered sequences which bypass the

src/rules_engine/engine_core.go:418

↓ 2 callersMethodexecuteThresholdNode

executeThresholdNode executes a threshold directly from a *Threshold pointer, avoiding the temporary map[int]Threshold + *Rule allocation required by

src/rules_engine/engine_core.go:1175

↓ 2 callersFunctionexpiryIndexKey

(expiresAtNs int64, ref string)

src/rules_engine/cep_value_store.go:345

↓ 2 callersFunctionfindRulesetPathInFolder

findRulesetPathInFolder constructs the file paths for a ruleset in a specific folder.

src/api/ruleset_folders.go:108

↓ 2 callersFunctionformatExpectedParameters

formatExpectedParameters formats all expected parameters for error messages

src/rules_engine/engine_struct.go:1881

↓ 2 callersFunctionformatRequiredParameters

formatRequiredParameters formats required parameters for error messages

src/rules_engine/engine_struct.go:1870

↓ 2 callersMethodforwardDownstream

(msg map[string]interface{})

src/agent/agent.go:288

↓ 2 callersFunctiongetArgumentTypeDescription

getArgumentTypeDescription returns a human-readable description of the argument type

src/rules_engine/engine_struct.go:1843

↓ 2 callersFunctiongetCompression

getCompression returns the appropriate compression option based on the compression type compression: The type of compression to use (Snappy, Gzip, Lz4

src/common/kafka.go:282

↓ 2 callersFunctiongetConfig

* Get merged configuration * Priority: runtime config > environment config > default config

web/src/config/index.js:71

↓ 2 callersMethodgetExpiredAbsenceKeysLocal

getExpiredAbsenceKeysLocal returns absence keys that have expired (ExpiresAt <= nowMs). When the timing wheel is used (local cache), only the current

src/rules_engine/cep_state.go:389

↓ 2 callersMethodgetLocalState

--- Local Cache Backend ---

src/rules_engine/cep_state.go:534

↓ 2 callersFunctiongetMinPoolSize

getMinPoolSize returns the minimum pool size Increased for better throughput on multi-core systems

src/rules_engine/engine_struct.go:85

↓ 2 callersMethodgetPartner

(t string, pns string)

src/project/project.go:1920

↓ 2 callersMethodgetRedisState

getRedisState reads state from Redis, auto-detecting compressed vs plain JSON.

src/rules_engine/cep_state.go:576

↓ 2 callersFunctiongetRulesetsUsingPlugin

(pluginID string)

src/project/project.go:100

↓ 2 callersFunctiongetSampleDataForInput

Get sample data for a specific input component (simplified using PNS)

src/api/sample_data_intelligent.go:835

↓ 2 callersFunctiongetSampleDataForOutput

Get sample data for a specific output component (simplified using PNS)

src/api/sample_data_intelligent.go:861

↓ 2 callersFunctiongetSampleDataForProject

Get sample data for a specific project (simplified using PNS)

src/api/sample_data_intelligent.go:945

↓ 2 callersFunctiongetSampleDataFromComponentWithFilter

getSampleDataFromComponentWithFilter gets sample data from a component with optional project-node-sequence filtering.

src/api/sample_data_intelligent.go:714

↓ 2 callersFunctiongetSuspiciousIps

config/plugin/checkSuspiciousIPs.go:17

↓ 2 callersMethodgetTokPrecedence

src/rules_engine/engine_condition.go:106

↓ 2 callersFunctiongetUnifiedOperationHistory

getUnifiedOperationHistory retrieves operations using the new efficient filtering function

src/api/operations_history.go:62

↓ 2 callersMethodhandleLockLoss

src/cluster/leader_locker.go:58

↓ 2 callersFunctionhandleNetworkChange

web/src/composables/useSmartRefresh.js:75

↓ 2 callersMethodhasNonAbsenceStageAfter

hasNonAbsenceStageAfter returns true if there is at least one non-absence stage after the given stageIdx. Used to determine if trailing absence stages

src/rules_engine/cep_condition.go:767

↓ 2 callersMethodhasRuntimeState

src/output/output.go:426

↓ 2 callersMethodhasRuntimeState

src/input/input.go:314

↓ 2 callersMethodhasRuntimeState

src/agent/agent.go:307

↓ 2 callersMethodhasRuntimeState

src/rules_engine/engine_core.go:277

↓ 2 callersFunctioninitAgentLoggerWithRedisAndNodeID

(nodeID string, redisWriter func(entry RedisErrorLogEntry) error)

src/logger/logger.go:270

↓ 2 callersFunctioninitLoggerWithRedisAndNodeID

(nodeID string, redisWriter func(entry RedisErrorLogEntry) error)

src/logger/logger.go:91

↓ 2 callersFunctioninitPluginLoggerWithRedisAndNodeID

(nodeID string, redisWriter func(entry RedisErrorLogEntry) error)

src/logger/logger.go:177

↓ 2 callersFunctioninitZstd

initZstd lazily initializes the shared zstd encoder/decoder (both are thread-safe).

src/rules_engine/cep_state.go:56

↓ 2 callersFunctioninitializeConfig

* Initialize configuration asynchronously

web/src/config/index.js:85

← previous next →401–500 of 2,165, ranked by callers