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

↓ 240 callersMethodEngineCheck

EngineCheck executes all rules in the ruleset on the provided data using the new flexible syntax.

src/rules_engine/engine_core.go:750

↓ 82 callersFunctionbuildRulesetFromXML

helper to build and run a ruleset against data

src/rules_engine/iterator_test.go:8

↓ 81 callersMethodClose

()

src/rules_engine/cep_value_store.go:24

↓ 67 callersMethodget

(key string)

src/cluster/instruction_sync_integration_test.go:36

↓ 57 callersMethodStop

()

src/project/project_struct.go:162

↓ 53 callersMethodAddMatch

AddMatch records a stage match. Maintains timestamp-sorted order.

src/rules_engine/cep_condition.go:109

↓ 52 callersFunctionParseCEPCondition

============================================================================ Top-Level Parse Function ================================================

src/rules_engine/cep_condition.go:442

↓ 52 callersFunctionbuildTestRuleset

(tb testing.TB, xmlContent string)

src/rules_engine/cep_test.go:29

↓ 51 callersFunctionGetComponentPath

GetComponentPath returns the full file path for a component It also creates the directory if it doesn't exist Parameters: - componentType: type of com

src/api/file_operations.go:71

↓ 42 callersFunctionValidateWithDetails

ValidateWithDetails performs detailed validation and returns structured errors with line numbers

src/rules_engine/engine_struct.go:424

↓ 39 callersMethodGet

Get retrieves a cached result if it exists

src/rules_engine/regex_result_cache.go:54

↓ 36 callersMethodString

String joins lines for LLM context and prompts (plain text).

src/agent/memory_notes.go:20

↓ 32 callersMethodPut

Put stores a result in the cache

src/rules_engine/regex_result_cache.go:71

↓ 31 callersFunctionNewSequenceState

NewSequenceState creates a new SequenceState with the given expiration.

src/rules_engine/cep_condition.go:93

↓ 30 callersMethodSetStatus

SetStatus sets the output status and error information

src/output/output.go:380

↓ 29 callersFunctionfirstNonBlank

(data map[string]interface{}, keys ...string)

config/plugin/pushAlertToIris.go:316

↓ 28 callersFunctionReadComponent

ReadComponent reads content from a component file Parameters: - path: full file path to read from Returns: - content: file content as string - error:

src/api/file_operations.go:194

↓ 27 callersMethodName

()

src/skill/skill.go:34

↓ 25 callersMethodString

String returns a debug string for the state manager.

src/rules_engine/cep_state.go:773

↓ 25 callersFunctionassertStage

(t *testing.T, stage CEPStage, expectedAbsent bool, expectedEventIDs []string)

src/rules_engine/cep_test.go:75

↓ 23 callersMethodSetDownstream

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

src/input/input.go:611

↓ 23 callersFunctionlog

(message, ...args)

web/src/composables/useSmartRefresh.js:31

↓ 22 callersFunctionParseRuleset

(rawRuleset []byte)

src/rules_engine/engine_parser.go:45

↓ 22 callersMethodReset

Reset resets all samples and counters

src/common/sampler.go:215

↓ 21 callersMethodSetProjectStatus

(status common.Status, err error)

src/project/project.go:2895

↓ 20 callersMethodString

()

src/api/pending_changes.go:36

↓ 20 callersMethodscopedRedisKey

(key string)

src/plugin/plugin.go:465

↓ 20 callersMethodset

(key string, value interface{}, expiration int)

src/cluster/instruction_sync_integration_test.go:47

↓ 19 callersFunctionbuildThresholdRuleset

buildThresholdRuleset wraps buildRulesetFromXML and registers cache cleanup.

src/rules_engine/engine_threshold_cache_test.go:26

↓ 18 callersMethodCheckComplete

============================================================================ Sequence Completion Check (Phase 3: verify temporal ordering) ===========

src/rules_engine/cep_condition.go:623

↓ 18 callersMethodStart

()

src/project/project_struct.go:161

↓ 18 callersMethodcleanup

cleanup performs cleanup when normal stop fails or panic occurs

src/rules_engine/engine_struct.go:2042

↓ 17 callersMethodEvaluateEvent

============================================================================ Stage Evaluation (Phase 1+2: match event against stage expressions) =====

src/rules_engine/cep_condition.go:496

↓ 17 callersMethodSetStatus

SetStatus sets the input status and error information

src/input/input.go:264

↓ 15 callersFunctionNewRegexResultCache

NewRegexResultCache creates a new regex result cache with specified capacity

src/rules_engine/regex_result_cache.go:35

↓ 15 callersFunctionassertIntSlice

(t *testing.T, got, expected []int)

src/rules_engine/cep_test.go:95

↓ 15 callersFunctionfindRulesetPaths

findRulesetPaths resolves the actual file paths for a ruleset by checking the loaded ruleset's Path field or searching the filesystem. Returns (formal

src/api/ruleset_folders.go:56

↓ 14 callersMethodAddChange

AddChange adds or updates a pending change

src/api/pending_changes.go:97

↓ 14 callersMethodSetWithTTL

SetWithTTL stores a key set with the given TTL, overwriting any existing entry.

src/rules_engine/engine_threshold_cache.go:212

↓ 14 callersMethodStopForTesting

(timeout time.Duration)

src/project/project.go:1938

↓ 14 callersMethodclearCache

clearCache removes all entries from the cache.

src/rules_engine/regex_cache.go:111

↓ 14 callersFunctionparseProjectInfoFromPNS

parseProjectInfoFromPNS parses project information from ProjectNodeSequence Format: "INPUT.api_sec.RULESET.test.OUTPUT.print_demo" -> project: "api_se

src/rules_engine/engine_core.go:24

↓ 14 callersFunctiontraverseComponents

(dir, suffix string)

src/main.go:319

↓ 13 callersMethodSetStatus

SetStatus sets the ruleset status and error information

src/rules_engine/engine_struct.go:2031

↓ 13 callersFunctionbuildResultError

(error, fallbackMessage, fallbackPayload = {})

web/src/api/index.js:150

↓ 13 callersMethodgenericContains

SIMD implementation functions are declared in platform-specific files: - simd_amd64.go for x86_64 platforms - simd_arm64.go for ARM64 platforms - simd

src/rules_engine/simd_optimizations.go:178

↓ 12 callersFunctionNewCEPStateManager

NewCEPStateManager creates a new state manager.

src/rules_engine/cep_state.go:176

↓ 12 callersMethodToken

Token wraps the xml.Decoder Token method to track line numbers

src/rules_engine/engine_parser.go:30

↓ 12 callersMethodTrackAbsenceKey

TrackAbsenceKey registers a key for absence scanning. In Redis mode, stores a separate tracking key so any cluster node can discover it. In local cach

src/rules_engine/cep_state.go:323

↓ 12 callersMethodatEnd

atEnd returns true if all tokens have been consumed.

src/rules_engine/cep_condition.go:233

↓ 12 callersMethodgenericContainsCaseInsensitive

genericContainsCaseInsensitive provides a fast generic case-insensitive contains

src/rules_engine/simd_optimizations.go:183

↓ 12 callersMethodpeek

peek returns the current token without advancing.

src/rules_engine/cep_condition.go:228

↓ 12 callersMethodprocessInstructionInternal

processInstructionInternal processes an instruction with proper locking

src/cluster/instruction_sync.go:205

↓ 11 callersFunctionBuildStateKey

BuildStateKey constructs a state key from the GroupByID and correlation values.

src/rules_engine/cep_state.go:191

↓ 11 callersFunctionGetCheckDataFromCache

(cache map[string]common.CheckCoreCache, checkKey string, data map[string]interface{}, checkKeyList []string)

src/rules_engine/engine_utils.go:259

↓ 11 callersMethodGetExpiredAbsenceKeys

GetExpiredAbsenceKeys returns all absence keys that have expired (ExpiresAt <= nowMs). In local cache mode, uses the in-memory map. In Redis mode, sca

src/rules_engine/cep_state.go:379

↓ 11 callersMethodGetState

GetState retrieves a SequenceState by key. Returns nil if not found or expired.

src/rules_engine/cep_state.go:242

↓ 11 callersFunctionRedisExpire

RedisExpire sets the expiration time for a key

src/common/redis.go:410

↓ 11 callersMethodaddRuntimeError

(message string)

src/rules_engine/engine_struct.go:2135

↓ 11 callersFunctionfindElementInRule

findElementInRule finds the line number of an element within a specific rule

src/rules_engine/engine_struct.go:518

↓ 10 callersMethodDownstreamCount

()

src/input/input.go:604

↓ 10 callersMethodGetChange

GetChange retrieves a specific pending change

src/api/pending_changes.go:131

↓ 10 callersFunctionGetCompiledRegex

GetCompiledRegex is the public interface to get a compiled regex with caching.

src/rules_engine/regex_cache.go:122

↓ 10 callersFunctionParseFunctionCall

ParseFunctionCall parses a function call of the form "functionName(arg1, arg2, ...)"

src/rules_engine/engine_struct.go:2161

↓ 10 callersFunctionRedisKeys

(key string)

src/common/redis.go:286

↓ 10 callersFunctionRedisLPush

===================== List Helpers ===================== RedisLPush pushes value to list head, keeps maxLen if >0

src/common/redis.go:394

↓ 10 callersFunctionRulesetBuild

RulesetBuild parses and validates a Ruleset with new flexible rule syntax, initializing all field paths and check functions.

src/rules_engine/engine_struct.go:2343

↓ 10 callersMethodSetStatus

(status common.Status, err error)

src/skill/skill.go:102

↓ 10 callersFunctiongetSampleDataFromComponent

Get sample data from a specific component

src/api/sample_data_intelligent.go:708

↓ 9 callersFunctionCalculateRefCount

CalculateRefCount dynamically calculates how many running projects are using the given PNS excludeProjectID allows excluding a specific project from t

src/project/project_struct.go:51

↓ 9 callersMethodCheckExist

(t string, id string)

src/project/project.go:2105

↓ 9 callersFunctionForEachProject

Safe iteration functions

src/project/project_struct.go:1161

↓ 9 callersFunctionGetPNSAgent

PNS Agent accessors

src/project/project_struct.go:564

↓ 9 callersMethodPublishInstruction

(componentName, componentType, content, operation string, dependencies []string, metadata map[string]interface

src/cluster/instruction_sync.go:507

↓ 9 callersMethodSize

Size returns the current number of entries in the cache

src/rules_engine/regex_result_cache.go:117

↓ 9 callersFunctionnewTestLocalCache

============================================================================ Shared Test Helpers =====================================================

src/rules_engine/cep_test.go:17

↓ 8 callersMethodDeleteDownstream

(downstreamID string)

src/input/input.go:621

↓ 8 callersMethodFuncEvalOther

(funcArgs ...interface{})

src/plugin/plugin.go:741

↓ 8 callersMethodGetCurrentVersion

()

src/cluster/sync_listener.go:102

↓ 8 callersFunctionGetPNSRuleset

PNS Ruleset accessors

src/project/project_struct.go:502

↓ 8 callersMethodGetProjectInputs

===== Thread-safe accessor functions for GlobalProject ===== Project dynamic component accessors - these replace the removed project-level component m

src/project/project_struct.go:169

↓ 8 callersFunctionGetSIMDOperations

GetSIMDOperations returns the global SIMD operations instance

src/rules_engine/simd_integration.go:15

↓ 8 callersMethodGetSnapshot

(ref string)

src/rules_engine/cep_value_store.go:145

↓ 8 callersMethodRecordInvocation

RecordInvocation increments the appropriate counter based on success/failure Skip recording if plugin is in test mode

src/plugin/plugin.go:1034

↓ 8 callersMethodRestart

(recordOperation bool, triggeredBy string)

src/project/project.go:1335

↓ 8 callersFunctiongetFirstSequenceFromRuleset

(t *testing.T, rs *Ruleset)

src/rules_engine/cep_test.go:63

↓ 8 callersFunctiongetRulesetBaseDir

getRulesetBaseDir returns the base directory for rulesets

src/api/ruleset_folders.go:29

↓ 8 callersMethodresolvedBatchSize

()

src/output/output.go:185

↓ 8 callersMethodresolvedFlushDur

()

src/output/output.go:189

↓ 7 callersMethodCall

Call executes a function with circuit breaker protection

src/common/redis.go:44

↓ 7 callersMethodDel

Del removes a key from the classify map.

src/rules_engine/engine_threshold_cache.go:223

↓ 7 callersMethodFuncEvalCheckNode

(funcArgs ...interface{})

src/plugin/plugin.go:647

↓ 7 callersFunctionSIMDOptimizedANDLogic

SIMDOptimizedANDLogic performs AND logic with SIMD batch operations

src/rules_engine/simd_optimizations.go:305

↓ 7 callersFunctionSIMDOptimizedORLogic

SIMDOptimizedORLogic performs OR logic with SIMD batch operations

src/rules_engine/simd_optimizations.go:294

↓ 7 callersMethodWrite

(p []byte)

src/common/aliyun_sls.go:42

↓ 7 callersFunctionaddHitRuleID

addHitRuleID appends the hit rule ID to the data map.

src/rules_engine/engine_core.go:2508

↓ 7 callersMethodadvance

advance moves to the next token. Returns false if at end.

src/rules_engine/cep_condition.go:218

↓ 7 callersFunctioncountLocalChangesForDir

(opts localChangeCountOptions)

src/api/local_files.go:30

↓ 7 callersFunctioncreateComponent

(componentType string, c echo.Context)

src/api/components.go:941

↓ 7 callersFunctiondeleteComponent

(componentType string, c echo.Context)

src/api/components.go:1127

next →1–100 of 2,165, ranked by callers