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

↓ 2 callersFunctioninstructionComponentOrder

(operation, componentType string)

src/cluster/sync_listener.go:68

↓ 2 callersFunctionint64FromValue

(value interface{})

config/plugin/pushAlertToIris.go:379

↓ 2 callersFunctionisArgumentTypeCompatible

isArgumentTypeCompatible checks if an argument is compatible with the expected type

src/rules_engine/engine_struct.go:1789

↓ 2 callersFunctionisValidCEPEventID

isValidCEPEventID checks if a string is a valid event ID (alphanumeric, underscore, hyphen).

src/rules_engine/cep_condition.go:186

↓ 2 callersFunctionisValidDomain

isValidDomain checks if the input is a valid domain

src/local_plugin/threatbook/threatbook.go:154

↓ 2 callersFunctionisValidFileHash

isValidFileHash checks if the input is a valid file hash

src/local_plugin/threatbook/threatbook.go:163

↓ 2 callersFunctionisValidHash

isValidHash checks if the input is a valid hash (MD5, SHA1, or SHA256)

src/local_plugin/virustotal/virustotal.go:87

↓ 2 callersFunctionisValidIP

isValidIP checks if the input is a valid IP address

src/local_plugin/threatbook/threatbook.go:149

↓ 2 callersFunctionisValidIP

isValidIP checks if the input is a valid IP address

src/local_plugin/shodan/shodan.go:110

↓ 2 callersFunctionisValidQueryType

isValidQueryType checks if the query type is supported

src/local_plugin/threatbook/threatbook.go:138

↓ 2 callersFunctionisValidURL

isValidURL checks if the input is a valid URL

src/local_plugin/threatbook/threatbook.go:181

↓ 2 callersFunctionisValidVariableName

isValidVariableName validates if a variable name follows the naming rules: - Must start with a letter or underscore - Can contain letters, numbers, an

src/rules_engine/engine_struct.go:49

↓ 2 callersMethodloadAllInstructions

loadAllInstructions loads all instructions from Redis and fails fast if history is incomplete.

src/cluster/instruction_sync.go:157

↓ 2 callersFunctionloadComponentDirectly

loadComponentDirectly loads a component directly into official storage using unified reload logic This bypasses the temporary file system and *New map

src/api/local_files.go:1054

↓ 2 callersFunctionloadConfig

(filePath, raw string)

src/skill/skill.go:109

↓ 2 callersFunctionloadConfig

(filePath, raw string)

src/agent/agent.go:407

↓ 2 callersFunctionloadEventsFromTestdataJSONL

loadEventsFromTestdataJSONL loads one JSON object per non-empty line.

src/rules_engine/engine_testdata_test.go:73

↓ 2 callersFunctionminDuration

(a, b time.Duration)

src/rules_engine/engine_core.go:742

↓ 2 callersMethodneonVectorizedSearch

neonVectorizedSearch implements vectorized string search for ARM64

src/rules_engine/simd_arm64.go:70

↓ 2 callersFunctionnestedRuleInfoValue

(data map[string]interface{}, key string)

config/plugin/pushAlertToIris.go:328

↓ 2 callersFunctionnewRegexCache

(maxSize int)

src/rules_engine/regex_cache.go:34

↓ 2 callersFunctionnormalizeDynamicRefKeyList

(normalizedKey string, fallback []string)

src/rules_engine/engine_utils.go:310

↓ 2 callersFunctionnormalizeElasticsearchVersion

normalizeElasticsearchVersion maps user-provided version string to internal version key. Supported values: "7"/"v7", "8"/"v8", otherwise default to "v

src/common/elasticsearch.go:77

↓ 2 callersFunctionnormalizeProjectTestInputNode

(raw string, requirePrefix bool)

src/api/testing.go:960

↓ 2 callersFunctionnormalizeTag

(value string)

config/plugin/pushAlertToIris.go:412

↓ 2 callersMethodparseAndExpr

parseAndExpr handles: and_expr := unary_expr ( 'and' unary_expr )*

src/rules_engine/cep_condition.go:283

↓ 2 callersFunctionparseAppend

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

src/rules_engine/engine_parser.go:870

↓ 2 callersFunctionparseArgs

(s string)

src/rules_engine/engine_struct.go:2209

↓ 2 callersFunctionparseIteratorChecklist

parseIteratorChecklist parses a checklist element specifically within an iterator context

src/rules_engine/engine_parser.go:427

↓ 2 callersFunctionparseNode

parseNode splits "TYPE.name" into ("TYPE", "name")

src/project/project.go:997

↓ 2 callersMethodparseNumber

()

src/rules_engine/engine_condition.go:98

↓ 2 callersMethodparseOrExpr

parseOrExpr handles: or_expr := and_expr ( 'or' and_expr )*

src/rules_engine/cep_condition.go:261

↓ 2 callersMethodparsePrimary

()

src/rules_engine/engine_condition.go:113

↓ 2 callersMethodparseSequenceExpr

parseSequenceExpr handles the lowest precedence: -> operator sequence_expr := or_expr ( '->' or_expr )*

src/rules_engine/cep_condition.go:239

↓ 2 callersFunctionparseTimestampToNs

parseTimestampToNs attempts to parse a timestamp string into unix nanoseconds. Supports: Unix seconds, Unix milliseconds, Unix microseconds, Unix nano

src/rules_engine/engine_core.go:1837

↓ 2 callersMethodparseUnaryExpr

parseUnaryExpr handles: unary_expr := '!' unary_expr | primary

src/rules_engine/cep_condition.go:305

↓ 2 callersMethodperformHealthCheck

performHealthCheck performs the actual health check on all components

src/common/component_monitor.go:83

↓ 2 callersFunctionpostJSON

postJSON sends a POST request with a JSON body and returns the response body string. Returns (body, nil) on 2xx, (body, error) on 4xx/5xx or network e

src/local_plugin/add_rule/add_rule.go:127

↓ 2 callersFunctionprocessValidationResponse

(response, componentType, showMessages = false)

web/src/composables/useComponentValidation.js:58

↓ 2 callersFunctionprojectTestHasPendingWork

(tempProject *project.Project)

src/api/testing.go:895

↓ 2 callersFunctionprojectTestRequestConfig

()

web/src/api/index.js:156

↓ 2 callersMethodreconnectAgentInboundEdges

(edges []agentInboundEdge)

src/project/project.go:1559

↓ 2 callersMethodreconnectRulesetInboundEdges

(edges []rulesetInboundEdge)

src/project/project.go:1497

↓ 2 callersMethodrecoverLoadPanic

(err *error)

src/plugin/plugin.go:270

↓ 2 callersFunctionregisterSharedPublicRoutes

(e *echo.Echo)

src/api/routes_shared.go:29

↓ 2 callersFunctionregisterSharedReadRoutes

(auth *echo.Group)

src/api/routes_shared.go:34

↓ 2 callersMethodrememberNextExpiryLocked

(expiresAt time.Time)

src/rules_engine/engine_threshold_cache.go:32

↓ 2 callersMethodrememberNextExpiryLocked

(expiresAt time.Time)

src/rules_engine/engine_threshold_cache.go:156

↓ 2 callersMethodremoveFromWheelSlot

removeFromWheelSlot removes a key from a specific wheel slot. Caller must hold absenceKeysMu.

src/rules_engine/cep_state.go:284

↓ 2 callersFunctionreplaceFromRawPlaceholders

replaceFromRawPlaceholders scans the input string and replaces all occurrences of dynamic references starting with "_$" (e.g., _$field, _$a.b.c) with

src/rules_engine/engine_utils.go:193

↓ 2 callersMethodresolveSkills

()

src/agent/agent.go:385

↓ 2 callersMethodresolveStageMatchData

(match StageMatch)

src/rules_engine/engine_core.go:1897

↓ 2 callersFunctionrunRulesEnginePipeline

runRulesEnginePipeline calls EngineCheck for each event in order (minimal "pipeline" without Hub).

src/rules_engine/engine_testdata_test.go:118

↓ 2 callersFunctionsanitizeOutputData

sanitizeOutputData removes internal helper fields that are only needed during rule execution.

src/rules_engine/engine_core.go:852

↓ 2 callersFunctionsanitizePathComponent

(s string)

src/rules_engine/cep_value_store.go:378

↓ 2 callersFunctionsaveComponent

( componentType, componentId, content, isNewComponent = false, options = {} )

web/src/composables/useComponentSave.js:21

↓ 2 callersFunctionsearchInComponentType

searchInComponentType searches within a specific component type

src/api/components.go:2369

↓ 2 callersMethodsendHeartbeat

sendHeartbeat sends heartbeat with current version and system metrics (follower only)

src/cluster/heartbeat_simple.go:128

↓ 2 callersMethodsendMessage

(msg map[string]interface{})

src/common/aliyun_sls.go:142

↓ 2 callersFunctionsetCachedResult

setCachedResult stores result in Redis cache

src/local_plugin/threatbook/threatbook.go:226

↓ 2 callersFunctionsetCachedResult

setCachedResult stores result in Redis cache

src/local_plugin/virustotal/virustotal.go:132

↓ 2 callersFunctionsetCachedResult

setCachedResult stores result in Redis cache

src/local_plugin/shodan/shodan.go:138

↓ 2 callersFunctionsimpleRuleFingerprintFromRule

simpleRuleFingerprintFromRule builds a coarse, order-insensitive fingerprint for a rule's basic logic. 覆盖 checklist（含 threshold 节点）和 standalone check，

src/api/components.go:2772

↓ 2 callersFunctionsplitList

(value string)

config/plugin/pushAlertToIris.go:395

↓ 2 callersFunctionsplitMemoryNotesFromString

(s string)

src/agent/memory_notes.go:32

↓ 2 callersMethodsse42Contains

SSE4.2-optimized implementations (placeholder for future assembly optimization)

src/rules_engine/simd_amd64.go:154

↓ 2 callersFunctionstableKeyPart

(v interface{})

src/local_plugin/suppress_once/suppress_once.go:67

↓ 2 callersFunctionstandardContains

(data, pattern string)

src/rules_engine/simd_optimizations.go:187

↓ 2 callersFunctionstart

()

web/src/composables/useSmartRefresh.js:212

↓ 2 callersMethodstartWithHook

(lock bool, beforeRun func(*Project) error)

src/project/project.go:1156

↓ 2 callersMethodstartWithRetry

startWithRetry starts the project with retry mechanism for components that fail to reach running status. It must be called WITHOUT holding ProjectOper

src/project/project.go:1836

↓ 2 callersFunctionstop

()

web/src/composables/useSmartRefresh.js:266

↓ 2 callersMethodstopInputComponents

stopInputComponents stops all input components used by this project This should be called after data processing is complete Returns a list of errors e

src/project/project.go:2190

↓ 2 callersMethodsweepExpiredLocked

(now time.Time)

src/rules_engine/engine_threshold_cache.go:162

↓ 2 callersFunctiontoInt

(v interface{})

config/plugin/pushUrentAlertByLark.go:300

↓ 2 callersFunctiontoLower

(b byte)

src/rules_engine/simd_optimizations.go:275

↓ 2 callersMethodtrackActiveProcess

(cancel context.CancelFunc)

src/agent/agent_loop.go:302

↓ 2 callersMethodtrackNodeInRedis

trackNodeInRedis tracks a node in Redis for node enumeration (48 hours TTL)

src/cluster/heartbeat_simple.go:303

↓ 2 callersFunctiontruncateString

truncateString truncates a string to the specified length

src/local_plugin/shodan/shodan.go:297

↓ 2 callersFunctionunauthorizedError

(c echo.Context, message string)

src/api/http_helpers.go:21

↓ 2 callersFunctionurgentPhone

(msgid string, userid string, token string)

config/plugin/pushUrentAlertByLark.go:236

↓ 2 callersFunctionvalidateChecklist

validateChecklist validates checklist elements

src/rules_engine/engine_struct.go:860

↓ 2 callersMethodvalidateComponent

validateComponent validates a single component exists in the system (unified approach)

src/project/project.go:1124

↓ 2 callersFunctionvalidateQueryValue

validateQueryValue validates the query value based on query type

src/local_plugin/threatbook/threatbook.go:187

↓ 2 callersMethodwaitForCompleteDataProcessingWithTimeout

waitForCompleteDataProcessingWithTimeout waits for all data to be fully processed with a given timeout

src/project/project.go:2230

↓ 1 callersMethodAcquire

Acquire attempts to acquire the distributed lock

src/common/redis.go:529

↓ 1 callersMethodApplyBatchUpdates

(dailyStatsData []DailyStatsData)

src/common/daily_stats_manager.go:296

↓ 1 callersMethodAssistantMessage

AssistantMessage converts the ChatResult back into a Message for the conversation.

src/agent/llm.go:90

↓ 1 callersFunctionCheckDeletedIntention

(i *Instruction)

src/cluster/instruction_sync.go:45

↓ 1 callersFunctionClearGlobalRegexResultCache

ClearGlobalRegexResultCache is now deprecated - kept for compatibility Use cache.Clear() directly on specific cache instances

src/rules_engine/regex_result_cache.go:224

↓ 1 callersMethodCompactAndSaveInstructions

(new *Instruction)

src/cluster/instruction_sync.go:317

↓ 1 callersMethodCopyDownstream

()

src/rules_engine/engine_struct.go:234

↓ 1 callersMethodDelTokenVal

()

src/rules_engine/engine_condition.go:258

↓ 1 callersFunctionDeleteInput

(id string)

src/project/project_struct.go:393

↓ 1 callersFunctionDeleteProject

(id string)

src/project/project_struct.go:353

↓ 1 callersFunctionDeleteRuleset

(id string)

src/project/project_struct.go:461

↓ 1 callersMethodDeleteSnapshot

(ref string)

src/rules_engine/cep_value_store.go:23

↓ 1 callersMethodDescription

()

src/skill/skill.go:35

↓ 1 callersFunctionDetectElasticsearchVersion

DetectElasticsearchVersion tries to determine ES major version from the cluster root response. It returns "v7", "v8", or "v9" on success.

src/common/elasticsearch.go:100

↓ 1 callersFunctionEnsureTopicExists

(cl *kgo.Client, topic string)

src/common/kafka.go:80

← previous next →501–600 of 2,165, ranked by callers