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 callersMethoddrainRemainingMessages

()

src/common/aliyun_sls.go:166

↓ 1 callersMethodenhanceMessageWithProjectNodeSequence

enhanceMessageWithProjectNodeSequence adds ProjectNodeSequence and output metadata to the message

src/output/output.go:465

↓ 1 callersFunctionensureOIDCVerifier

(ctx context.Context)

src/api/auth.go:33

↓ 1 callersFunctionestimateProjectDataVolume

(proj *project.Project)

src/api/sample_data_intelligent.go:340

↓ 1 callersMethodevaluateEventDefChecksOnly

evaluateEventDefChecksOnly evaluates an event definition's checks and checklists only, WITHOUT evaluating thresholds. Used in the first-pass correlati

src/rules_engine/engine_core.go:1572

↓ 1 callersFunctionevaluateStageExpr

evaluateStageExpr evaluates a within-stage expression against a boolean match map. Handles and/or/! logic on a single event's match results.

src/rules_engine/cep_condition.go:510

↓ 1 callersMethodexecuteCheck

executeCheck executes a standalone check operation

src/rules_engine/engine_core.go:1006

↓ 1 callersMethodexecuteFunctionCall

(call ToolCall)

src/agent/agent.go:464

↓ 1 callersMethodexecuteIterator

executeIterator executes an iterator operation

src/rules_engine/engine_core.go:2207

↓ 1 callersFunctionexecutePlugin

(name string, args map[string]interface{})

src/agent/agent_tools.go:107

↓ 1 callersMethodexecuteProjectRefreshPlans

(plans map[string]*projectRefreshPlan)

src/cluster/sync_listener.go:654

↓ 1 callersMethodexecuteRuleOperations

executeRuleOperations executes all operations in a rule according to the Queue order

src/rules_engine/engine_core.go:861

↓ 1 callersMethodexecuteSequence

Returns (completed bool, enrichedData map) where enrichedData is non-nil when the sequence completes.

src/rules_engine/engine_core.go:1270

↓ 1 callersFunctionexpiryIndexUpperBound

(nowNs int64)

src/rules_engine/cep_value_store.go:350

↓ 1 callersFunctionexpiryPrefix

()

src/rules_engine/cep_value_store.go:341

↓ 1 callersFunctionextractAffectedProjectsAndSource

(instruction Instruction)

src/cluster/sync_listener.go:504

↓ 1 callersFunctionextractComponentInfo

extractComponentInfo extracts component type and ID from a file path Returns (componentType, componentId)

src/api/file_operations.go:139

↓ 1 callersFunctionextractComponentsFromProject

extractComponentsFromProject extracts component information from an existing project

src/api/testing.go:1590

↓ 1 callersMethodextractEventTimestamp

extractEventTimestamp extracts the event timestamp from data based on event_time configuration. Returns unix nanoseconds. When event_time is not speci

src/rules_engine/engine_core.go:1809

↓ 1 callersFunctionextractInputsFromProject

extractInputsFromProject extracts input information from an existing project

src/api/testing.go:1258

↓ 1 callersFunctionextractJSON

extractJSON tries to extract a JSON object or array from LLM output that may contain markdown fences or extra text.

src/agent/agent_loop.go:482

↓ 1 callersFunctionextractLineFromXMLError

extractLineFromXMLError extracts line number from XML parsing error message

src/rules_engine/engine_struct.go:458

↓ 1 callersMethodextractParameterNamesFromSource

extractParameterNamesFromSource tries to extract parameter names from plugin source code

src/plugin/plugin.go:573

↓ 1 callersFunctionextractParseJSONFunction

extractParseJSONFunction extracts the parseJSON function from local_plugin.go

src/api/components.go:2261

↓ 1 callersFunctionextractPluginNamesFromValue

(value string, knownPlugins map[string]struct{})

src/api/component_usage_indexes.go:101

↓ 1 callersFunctionextractSequencesFromProject

extractSequencesFromProject extracts sequence information from an existing project

src/api/testing.go:1980

↓ 1 callersFunctionextractTargetComponent

Extract target component from request context

src/api/sample_data_intelligent.go:689

↓ 1 callersFunctionextractTargetRulesetFromRequest

Extract target ruleset from field requirements or rule purpose

src/api/sample_data_intelligent.go:798

↓ 1 callersMethodfallbackANDLogic

fallbackANDLogic handles cases where SIMD optimization is not applicable

src/rules_engine/simd_integration.go:244

↓ 1 callersMethodfallbackORLogic

fallbackORLogic handles cases where SIMD optimization is not applicable

src/rules_engine/simd_integration.go:233

↓ 1 callersMethodfindAbsencePathFromStage

(state *SequenceState, stageIdx int, prevTimestamp int64, path *CompletionPath)

src/rules_engine/cep_condition.go:850

↓ 1 callersMethodfindPathFromStage

(state *SequenceState, stageIdx int, prevTimestamp int64, path *CompletionPath)

src/rules_engine/cep_condition.go:795

↓ 1 callersFunctionfindProjectsUsingComponent

Find projects that use a specific component

src/api/sample_data_intelligent.go:746

↓ 1 callersFunctionfindThresholdElementLine

findThresholdElementLine finds the exact line number of the threshold element

src/rules_engine/engine_struct.go:570

↓ 1 callersFunctionflattenSequence

============================================================================ AST Flattener: Extract stages from -> chain =============================

src/rules_engine/cep_condition.go:360

↓ 1 callersFunctionflattenSequenceRecursive

(ast ExprAST, stages *[]CEPStage)

src/rules_engine/cep_condition.go:366

↓ 1 callersMethodflushPendingWrites

()

src/rules_engine/cep_value_store.go:230

↓ 1 callersFunctionforbiddenError

(c echo.Context, message string)

src/api/http_helpers.go:25

↓ 1 callersFunctionformatMapToReadableString

formatMapToReadableString converts map to pretty JSON

config/plugin/pushMsgToLark.go:17

↓ 1 callersFunctionformatMapToReadableString

formatMapToReadableString converts map into a formatted JSON string

config/plugin/pushMsgToDiscord.go:15

↓ 1 callersFunctionformatMapToReadableString

formatMapToReadableString converts map[string]interface{} to a formatted JSON string

config/plugin/pushMsgToDingDing.go:22

↓ 1 callersFunctionformatMapToReadableString

(data map[string]interface{})

config/plugin/pushMsgToTelegram.go:13

↓ 1 callersFunctionformatMapToReadableString

(data map[string]interface{})

config/plugin/pushMsgToTeams.go:12

↓ 1 callersFunctionformatNumber

(num)

web/src/utils/common.js:87

↓ 1 callersMethodformatTypeString

formatTypeString converts reflect.Type to a readable string

src/plugin/plugin.go:627

↓ 1 callersFunctiongenerateDataRecommendations

(quality DataQualityAnalysis, fieldAnalysis FieldUsageAnalysis, context ProjectContextInfo)

src/api/sample_data_intelligent.go:536

↓ 1 callersFunctiongenerateInputTemplate

(id)

web/src/utils/templateGenerator.js:59

↓ 1 callersMethodgenerateKey

(date, nodeID, projectID, projectNodeSequence string)

src/common/daily_stats_manager.go:165

↓ 1 callersFunctiongenerateOutputTemplate

(id)

web/src/utils/templateGenerator.js:105

↓ 1 callersFunctiongeneratePluginTemplate

(id)

web/src/utils/templateGenerator.js:208

↓ 1 callersFunctiongenerateProjectTemplate

(id, store)

web/src/utils/templateGenerator.js:170

↓ 1 callersFunctiongenerateRelevanceReasoning

(proj *project.Project, rulePurpose string)

src/api/sample_data_intelligent.go:303

↓ 1 callersFunctiongenerateRulesetTemplate

(id)

web/src/utils/templateGenerator.js:12

↓ 1 callersFunctiongenerateSessionID

generateSessionID generates an 8-character random session identifier

src/cluster/instruction_sync.go:89

↓ 1 callersMethodgenerate_message

Generate a test message with variations

docs/kafka_producer_perf_test.py:83

↓ 1 callersMethodgenericBatchCompare

Generic batch compare for non-SIMD platforms

src/rules_engine/simd_generic.go:29

↓ 1 callersFunctiongetAllSamplerNames

()

src/api/sample_data_intelligent.go:354

↓ 1 callersFunctiongetCPULimit

()

src/common/system_monitor.go:254

↓ 1 callersFunctiongetCachedResult

getCachedResult retrieves cached result from Redis

src/local_plugin/threatbook/threatbook.go:208

↓ 1 callersFunctiongetCachedResult

getCachedResult retrieves cached result from Redis

src/local_plugin/virustotal/virustotal.go:114

↓ 1 callersFunctiongetCachedResult

getCachedResult retrieves cached result from Redis

src/local_plugin/shodan/shodan.go:120

↓ 1 callersFunctiongetComponentTypeLabel

(type)

web/src/utils/common.js:55

↓ 1 callersFunctiongetCurrentProcessCPUTime

getCurrentProcessCPUTime gets the current process CPU time (user + system time)

src/common/system_monitor.go:203

↓ 1 callersMethodgetDailyStatsLegacy

(date, projectID, nodeID string)

src/common/daily_stats_manager.go:203

↓ 1 callersFunctiongetErrorLogs

getErrorLogs handles GET /error-logs - unified endpoint for all nodes

src/api/error_logs.go:159

↓ 1 callersMethodgetExpiredAbsenceKeysRedis

getExpiredAbsenceKeysRedis scans Redis for expired absence tracking keys. This enables any node in the cluster to detect absence timeouts.

src/rules_engine/cep_state.go:438

↓ 1 callersFunctiongetFallbackSampleData

Get fallback sample data from any available source

src/api/sample_data_intelligent.go:780

↓ 1 callersFunctiongetKnownPluginNames

()

src/api/component_usage_indexes.go:129

↓ 1 callersFunctiongetMaxPoolSize

getMaxPoolSize returns the maximum pool size based on CPU count Scales with CPU count for better resource utilization

src/rules_engine/engine_struct.go:96

↓ 1 callersFunctiongetMostCommonType

(typeMap map[string]int)

src/api/sample_data_intelligent.go:631

↓ 1 callersMethodgetOrCreateRedisStateAtomic

getOrCreateRedisStateAtomic uses a Lua script for atomic get-or-create.

src/rules_engine/cep_state.go:721

↓ 1 callersMethodgetPNS

()

src/project/project.go:942

↓ 1 callersFunctiongetPackageName

getPackageName safely extracts the package name

src/plugin/plugin.go:893

↓ 1 callersFunctiongetPendingPluginChange

Helper functions for safe access to plugin data

src/api/pending_changes.go:244

↓ 1 callersFunctiongetProcessRSSMB

getProcessRSSMB gets the current process RSS (Resident Set Size) memory in MB

src/common/system_monitor.go:219

↓ 1 callersFunctiongetProjectsUsingRulesets

(rulesetIDs []string, shouldInclude func(projectID string, p *Project) bool)

src/project/project.go:119

↓ 1 callersMethodgetRedisAbsenceTracker

getRedisAbsenceTracker reads an absence tracking key from Redis.

src/rules_engine/cep_state.go:514

↓ 1 callersMethodgetSamplesFromKey

getSamplesFromKey retrieves samples from a specific Redis key

src/common/redis_sample_manager.go:180

↓ 1 callersFunctiongetShodanAPIKey

getShodanAPIKey gets the API key from environment variable

src/local_plugin/shodan/shodan.go:157

↓ 1 callersFunctiongetSystemMemoryMB

getSystemMemoryMB attempts to get system total memory in MB

src/common/system_monitor.go:294

↓ 1 callersFunctiongetTenantAccessToken

(app_id string, app_secret string)

config/plugin/pushUrentAlertByLark.go:15

↓ 1 callersFunctiongetThreatBookAPIKey

getThreatBookAPIKey gets the API key from environment variable

src/local_plugin/threatbook/threatbook.go:245

↓ 1 callersFunctiongetURL

(AccessToken string, Secret string)

config/plugin/pushMsgToDingDing.go:86

↓ 1 callersFunctiongetUnifiedErrorLogs

getUnifiedErrorLogs gets error logs from Redis for all nodes (leader only)

src/api/error_logs.go:108

↓ 1 callersFunctiongetVirusTotalAPIKey

getVirusTotalAPIKey gets the API key from environment variable

src/local_plugin/virustotal/virustotal.go:151

↓ 1 callersFunctionhandleError

(error)

web/src/composables/useSmartRefresh.js:38

↓ 1 callersMethodhandleSyncCommand

handleSyncCommand handles a sync command

src/cluster/sync_listener.go:255

↓ 1 callersFunctionhmacSha256

(stringToSign string, secret string)

config/plugin/pushMsgToDingDing.go:80

↓ 1 callersFunctioninitAgentLoggerWithRedis

(redisWriter func(entry RedisErrorLogEntry) error)

src/logger/logger.go:265

↓ 1 callersMethodinitComponents

()

src/project/project.go:2330

↓ 1 callersFunctioninitLoggerWithRedis

(redisWriter func(entry RedisErrorLogEntry) error)

src/logger/logger.go:86

↓ 1 callersFunctioninitOidc

()

web/src/api/oidc.js:7

↓ 1 callersMethodinitPlatformSpecific

ARM64-optimized implementations

src/rules_engine/simd_arm64.go:26

↓ 1 callersFunctioninitPluginLoggerWithRedis

(redisWriter func(entry RedisErrorLogEntry) error)

src/logger/logger.go:172

↓ 1 callersFunctioninitProjectTestOutputResults

(outputChannels map[string]chan map[string]interface{})

src/api/testing.go:866

↓ 1 callersMethodinitialize

* Initialize event manager (only once)

web/src/utils/eventManager.js:18

↓ 1 callersFunctioninitializeApp

()

web/src/main.js:10

↓ 1 callersFunctionirisSeverityID

(data map[string]interface{})

config/plugin/pushAlertToIris.go:284

↓ 1 callersFunctionisPseudoVariadicPlugin

isPseudoVariadicPlugin checks if a plugin is pseudo-variadic (uses variadic syntax but only handles specific argument counts)

src/rules_engine/engine_struct.go:1765

↓ 1 callersFunctionisStandardLibraryPackage

isStandardLibraryPackage checks if a package is part of Go standard library

src/plugin/plugin.go:901

← previous next →801–900 of 2,165, ranked by callers