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

↓ 3 callersFunctionSetProject

(id string, project *Project)

src/project/project_struct.go:347

↓ 3 callersMethodSetState

SetState stores a SequenceState with the given TTL.

src/rules_engine/cep_state.go:250

↓ 3 callersMethodSetTestMode

SetTestMode configures the ruleset for test mode by disabling sampling and other global state interactions Note: isTestMode flag is automatically set

src/rules_engine/engine_struct.go:2127

↓ 3 callersMethodStartConverged

StartConverged starts the project and retries until all components reach running state or the retry budget is exhausted.

src/project/project.go:1418

↓ 3 callersMethodStartForTesting

(beforeRun func(*Project) error)

src/project/project.go:1149

↓ 3 callersMethodStop

Stop gracefully stops the agent. Safe to call even if Start was never called.

src/agent/agent_loop.go:260

↓ 3 callersMethodStopWithTimeout

(timeout time.Duration)

src/agent/agent_loop.go:264

↓ 3 callersMethodStoreSample

StoreSample stores a sample in Redis with TTL and size limits

src/common/redis_sample_manager.go:66

↓ 3 callersMethodSyncInstructions

(toVersion string)

src/cluster/sync_listener.go:274

↓ 3 callersMethodUpdateState

UpdateState atomically updates the state after modifications. Applies memory control before persisting. IMPORTANT: The caller MUST hold the per-key lo

src/rules_engine/cep_state.go:669

↓ 3 callersFunctionVerify

(path string, raw string, name string)

src/plugin/plugin.go:174

↓ 3 callersFunctionacquireAgentMemoryWriteLock

agentID -> *sync.Mutex

src/api/agent_memory_update.go:15

↓ 3 callersMethodbuildAbsenceResult

buildAbsenceResult constructs the result data for a sequence triggered by absence timeout.

src/rules_engine/engine_core.go:458

↓ 3 callersFunctionbuildDeferredProjectCommands

(instructions []Instruction)

src/cluster/sync_listener.go:603

↓ 3 callersFunctionbuildProjectUsageIndex

()

src/api/component_usage_indexes.go:17

↓ 3 callersFunctionbuildTestHTTPClient

--- Connection test utilities --- buildTestHTTPClient creates a temporary HTTP client for connection testing

src/common/clickhouse.go:320

↓ 3 callersFunctionbuildVerifyFailure

(message)

web/src/api/index.js:143

↓ 3 callersFunctioncallTestPluginHandler

(t *testing.T, id string, body map[string]interface{})

src/api/plugin_testing_test.go:24

↓ 3 callersFunctioncheckNodeLogic

checkNodeLogic executes the check logic for a single check node.

src/rules_engine/engine_core.go:2402

↓ 3 callersMethodcleanup

cleanup performs cleanup when normal stop fails or panic occurs

src/output/output.go:391

↓ 3 callersFunctioncloneEventForReplay

cloneEventForReplay copies a payload so repeated pipeline runs do not alias nested maps/slices mutated or reused by the engine (shallow map + meta + t

src/rules_engine/engine_testdata_test.go:104

↓ 3 callersMethodcollectExpiredFromWheelSlot

collectExpiredFromWheelSlot collects expired entries from a given slot into expired map. Uses absenceKeys as canonical source to prevent stale wheel e

src/rules_engine/cep_state.go:300

↓ 3 callersMethoddeleteComponentInstance

deleteComponentInstance deletes actual component instances

src/cluster/sync_listener.go:955

↓ 3 callersFunctiondetectLocalIP

detectLocalIP returns first non-loopback IPv4 address or "unknown"

src/logger/logger.go:43

↓ 3 callersMethoddisconnectInputsFromDownstream

disconnectInputsFromDownstream safely disconnects all input components from their downstream channels This should be called before waiting for data pr

src/project/project.go:2173

↓ 3 callersFunctiondispatchComponentChanged

(action, type, id)

web/src/api/index.js:133

↓ 3 callersFunctiondrainProjectTestOutputChannels

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

src/api/testing.go:874

↓ 3 callersMethodemit

* Trigger event callbacks * @param {string} eventType - Event type * @param {any} eventData - Event data

web/src/utils/eventManager.js:76

↓ 3 callersMethodevaluateEventDef

evaluateEventDef checks if the incoming data matches a single event definition. All checks within an event must pass (AND logic).

src/rules_engine/engine_core.go:1591

↓ 3 callersMethodexecuteThreshold

executeThreshold executes a threshold operation

src/rules_engine/engine_core.go:1063

↓ 3 callersMethodextractCorrelateValues

extractCorrelateValues extracts correlation values from the event data based on group_by configuration.

src/rules_engine/engine_core.go:1658

↓ 3 callersMethodextractCorrelateValuesForStateLookup

extractCorrelateValuesForStateLookup extracts group_by values without relying on stage match results, so sequence state can be loaded before "_@"-depe

src/rules_engine/engine_core.go:1700

↓ 3 callersMethodextractCorrelateValuesForStateLookupWithSequenceFallback

extractCorrelateValuesForStateLookupWithSequenceFallback attempts to extract group_by using sequence-level configuration when per-event extraction fai

src/rules_engine/engine_core.go:1757

↓ 3 callersFunctionextractKeysFromMap

extractKeysFromMap recursively extracts keys from a nested map structure

src/api/components.go:2093

↓ 3 callersFunctionextractLineFromEnhancedError

extractLineFromEnhancedError extracts line number from enhanced error message

src/rules_engine/engine_struct.go:471

↓ 3 callersFunctionformatMessageAsJSON

(msg map[string]interface{})

src/agent/agent_loop.go:445

↓ 3 callersMethodgetCacheStats

getCacheStats returns current cache size for monitoring.

src/rules_engine/regex_cache.go:99

↓ 3 callersMethodgetCurrentVersionUnsafe

getCurrentVersionUnsafe returns version string without locking (must be called with lock held)

src/cluster/instruction_sync.go:130

↓ 3 callersFunctiongetErrorHash

(errors, warnings)

web/src/composables/useComponentValidation.js:30

↓ 3 callersFunctiongetExpectedArgumentCount

getExpectedArgumentCount returns the expected argument count for known pseudo-variadic plugins

src/rules_engine/engine_struct.go:1779

↓ 3 callersFunctiongetLocalAggregatedAgentStatus

(agentID string)

src/project/project_struct.go:690

↓ 3 callersFunctiongetNodeFromKey

(node FlowNode)

src/project/project.go:852

↓ 3 callersFunctiongetNodeToKey

(node FlowNode)

src/project/project.go:848

↓ 3 callersFunctiongetRelatedProjectSamples

(componentType, componentID string)

src/api/sample_data_intelligent.go:882

↓ 3 callersFunctiongetSampleDataForRuleset

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

src/api/sample_data_intelligent.go:813

↓ 3 callersMethodgetTestCollectionChan

()

src/output/output.go:489

↓ 3 callersFunctionintFromField

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

config/plugin/pushAlertToIris.go:369

↓ 3 callersFunctionloadAgentYAMLForMemoryUpdates

loadAgentYAMLForMemoryUpdates returns the YAML string used for agent memory edits. Prefers the pending .new file when present, matching other agent up

src/api/agent_memory_update.go:25

↓ 3 callersFunctionnewSLSHubLogger

()

src/common/aliyun_sls.go:50

↓ 3 callersFunctionnormalizeDynamicRefKey

(checkKey string)

src/rules_engine/engine_utils.go:299

↓ 3 callersMethodon

* Register event listener * @param {string} eventType - Event type * @param {Function} callback - Callback function * @returns {Function} - F

web/src/utils/eventManager.js:36

↓ 3 callersMethodparseContent

parseContent parses the project content to build the data flow graph

src/project/project.go:752

↓ 3 callersFunctionparseOutputType

parseOutputType extracts the type field from output YAML configuration

src/api/components.go:503

↓ 3 callersFunctionparseValue

(s string)

src/rules_engine/engine_struct.go:2289

↓ 3 callersMethodprepareMessage

(msg map[string]interface{})

src/input/input.go:560

↓ 3 callersMethodresetToStoppedForRestart

()

src/output/output.go:430

↓ 3 callersMethodresetToStoppedForRestart

()

src/input/input.go:318

↓ 3 callersMethodresetToStoppedForRestart

()

src/agent/agent.go:311

↓ 3 callersMethodresetToStoppedForRestart

()

src/rules_engine/engine_core.go:281

↓ 3 callersMethodresolvedLingerDur

()

src/output/output.go:201

↓ 3 callersMethodrollbackCompactionLocked

(originalVersion int64, appliedWrites []compactionWrite, snapshots []instructionSnapshot, cause error)

src/cluster/instruction_sync.go:450

↓ 3 callersMethodscanAbsenceTimeouts

scanAbsenceTimeouts checks for expired absence sequences and triggers them.

src/rules_engine/engine_core.go:347

↓ 3 callersMethodsendToDownstream

(msg map[string]interface{})

src/rules_engine/engine_struct.go:269

↓ 3 callersMethodsendToTestCollection

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

src/output/output.go:495

↓ 3 callersMethodsetLocalState

(key string, state *SequenceState, ttlSeconds int)

src/rules_engine/cep_state.go:545

↓ 3 callersMethodsetRedisState

setRedisState writes state to Redis as zstd-compressed JSON.

src/rules_engine/cep_state.go:591

↓ 3 callersFunctionsetSequenceContextValue

(ctx map[string]interface{}, path []string, value interface{})

src/rules_engine/engine_core.go:1444

↓ 3 callersMethodstoreSample

storeSample stores sample data to Redis only

src/common/sampler.go:159

↓ 3 callersMethodsweepExpiredLocked

(now time.Time)

src/rules_engine/engine_threshold_cache.go:38

↓ 3 callersFunctionsyncProjectOperationToFollowers

syncProjectOperationToFollowers syncs a successful local project operation to follower nodes.

src/api/project_control.go:16

↓ 3 callersFunctiontestdataJoin

(elem ...string)

src/rules_engine/engine_testdata_test.go:25

↓ 3 callersFunctiontimingWheelSlot

(expiresAtMs int64)

src/rules_engine/cep_state.go:267

↓ 3 callersMethodtoStr

()

src/rules_engine/engine_condition.go:45

↓ 3 callersFunctiontrimStageMatches

trimStageMatches enforces the MaxStageMatchesPerStage limit. Keeps the most recent matches (highest timestamps) for each stage.

src/rules_engine/cep_state.go:683

↓ 3 callersFunctionvalidatePluginCall

validatePluginCall validates plugin function call syntax and parameters

src/rules_engine/engine_struct.go:1614

↓ 3 callersFunctionwaitForFollowerToken

(maxAttempts int, retryInterval time.Duration)

src/api/follower_server.go:25

↓ 2 callersMethodAddSystemMetrics

AddSystemMetrics adds or updates system metrics for a node

src/common/system_monitor.go:530

↓ 2 callersMethodAddTokenVal

(data map[string]int)

src/rules_engine/engine_condition.go:247

↓ 2 callersFunctionAuthenticateRequest

AuthenticateRequest allows either legacy token header or OIDC Bearer token

src/api/auth.go:104

↓ 2 callersMethodBatchStringCompare

BatchStringCompare performs multiple string comparisons in parallel using SIMD

src/rules_engine/simd_optimizations.go:129

↓ 2 callersFunctionCheckAllProjectComponents

CheckAllProjectComponents calls the registered project component checker

src/common/global.go:245

↓ 2 callersMethodClearFollowerExecutionFlag

ClearFollowerExecutionFlag clears the execution flag for a follower

src/cluster/sync_listener.go:489

↓ 2 callersMethodDeleteDownstream

(downstreamID string)

src/agent/agent.go:274

↓ 2 callersMethodDeleteDownstream

(downstreamID string)

src/rules_engine/engine_struct.go:255

↓ 2 callersFunctionDeleteRawConfig

DeleteRawConfig removes raw configuration by type and ID

src/common/global.go:120

↓ 2 callersMethodDeleteSnapshot

(ref string)

src/rules_engine/cep_value_store.go:175

↓ 2 callersFunctionErrPos

(s string, pos int)

src/rules_engine/engine_condition.go:34

↓ 2 callersMethodExecute

(functionName string, arguments map[string]interface{})

src/skill/skill.go:37

↓ 2 callersMethodExprASTResult

(e ExprAST, tokenVal map[string]bool)

src/rules_engine/engine_condition.go:219

↓ 2 callersMethodFunctions

()

src/skill/skill.go:36

↓ 2 callersMethodGetAllMetrics

GetAllMetrics returns all stored system metrics

src/common/system_monitor.go:418

↓ 2 callersFunctionGetAllProjectUserIntentions

GetAllProjectUserIntentions gets all user intentions (GLOBAL state) Returns map of projectID -> bool (true=running, false=stopped)

src/common/redis.go:640

↓ 2 callersFunctionGetComponentTypeFromSequence

GetComponentTypeFromSequence extracts the component type from the LAST part of ProjectNodeSequence Examples: - "INPUT.kafka1" -> "input" (last compone

src/common/daily_stats_manager.go:74

↓ 2 callersMethodGetConsumeTotal

QPS calculation and GetConsumeQPS method removed Message statistics are now handled by Daily Stats Manager GetConsumeTotal returns the total consumed

src/input/input.go:782

↓ 2 callersMethodGetPendingMessageCount

GetPendingMessageCount returns the total number of pending messages in all channels This includes upstream channels and internal producer channels

src/output/output.go:1437

↓ 2 callersFunctionGetRedisClient

GetRedisClient returns underlying redis client for advanced operations

src/common/redis.go:387

↓ 2 callersFunctionGetRedisPipeline

===================== Pipeline Operations ===================== GetRedisPipeline returns a new Redis pipeline for batch operations

src/common/redis.go:456

↓ 2 callersFunctionGetRulesetFieldsForID

GetRulesetFieldsForID is a helper function to get field keys for a specific ruleset

src/api/components.go:3051

↓ 2 callersMethodGetRunningTaskCount

GetRunningTaskCount returns the number of currently running tasks in the thread pool Returns 0 if the thread pool is not initialized

src/rules_engine/engine_core.go:2675

↓ 2 callersFunctionGetSamplerData

GetSamplerData retrieves sample data from project components

src/api/components.go:1809

← previous next →301–400 of 2,165, ranked by callers