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

EvaluateEventBindings returns stage -> matched event IDs for stages satisfied by this event. For OR expressions, the first satisfied branch (left-firs

src/rules_engine/cep_condition.go:533

↓ 1 callersMethodExecuteCommandWithOptions

(projectID, action string, recordOperation bool)

src/project/project.go:361

↓ 1 callersMethodExecuteCommandWithOptions

(projectID, action string, recordOperation bool)

src/cluster/refactor_regression_test.go:19

↓ 1 callersMethodExecuteCommandWithOptions

(projectID, action string, recordOperation bool)

src/cluster/cluster.go:202

↓ 1 callersFunctionForEachAgent

(fn func(id string, a *agent.Agent) bool)

src/project/project_struct.go:670

↓ 1 callersFunctionForEachProjectUnsafa

Unsafe iteration functions - use with caution, caller must ensure proper locking

src/project/project_struct.go:1173

↓ 1 callersFunctionForEachRuleset

(fn func(id string, rs *rules_engine.Ruleset) bool)

src/project/project_struct.go:1203

↓ 1 callersFunctionGetAccessLogger

GetAccessLogger returns the access logger instance

src/logger/logger.go:389

↓ 1 callersFunctionGetAgentLogComments

GetAgentLogComments returns comments for a given log ID (most recent first).

src/common/agent_log_redis.go:79

↓ 1 callersMethodGetAggregatedDailyStats

GetAggregatedDailyStats returns aggregated statistics for a date (read from Redis)

src/common/daily_stats_manager.go:379

↓ 1 callersMethodGetAggregatedMetrics

GetAggregatedMetrics returns aggregated system metrics across all nodes

src/common/system_monitor.go:623

↓ 1 callersMethodGetAvgLatencyMs

GetAvgLatencyMs returns average processing latency in milliseconds (0 if no messages processed).

src/agent/agent.go:357

↓ 1 callersFunctionGetCheckDataWithTypeFromCache

GetCheckDataWithTypeFromCache retrieves typed data from cache or fetches and caches it

src/rules_engine/engine_utils.go:278

↓ 1 callersFunctionGetComponentFromSequenceID

(sequence string)

src/common/utils.go:21

↓ 1 callersFunctionGetConfigDir

getConfigDir returns the appropriate config directory based on the operating system

src/common/utils.go:360

↓ 1 callersFunctionGetExt

GetExt returns the appropriate file extension for a component type Parameters: - componentType: type of component (input, output, ruleset, project, pl

src/api/file_operations.go:36

↓ 1 callersMethodGetFailureIncrementAndUpdate

GetFailureIncrementAndUpdate returns the increment in failure count since last call and updates the baseline This method is thread-safe and designed f

src/plugin/plugin.go:1066

↓ 1 callersMethodGetHistoricalMetrics

GetHistoricalMetrics returns historical system metrics within the specified time range

src/common/system_monitor.go:403

↓ 1 callersMethodGetIncrementAndUpdate

GetIncrementAndUpdate returns the increment since last call and updates the baseline. This method is thread-safe and designed for statistics collectio

src/rules_engine/engine_core.go:2660

↓ 1 callersMethodGetNodeMetrics

GetNodeMetrics returns system metrics for a specific node

src/common/system_monitor.go:544

↓ 1 callersMethodGetNodes

GetNodes returns current node list

src/cluster/heartbeat_simple.go:387

↓ 1 callersFunctionGetOperationsHistory

GetOperationsHistory handles GET /operations-history - unified endpoint for all nodes

src/api/operations_history.go:184

↓ 1 callersMethodGetProcessTotal

()

src/agent/agent.go:352

↓ 1 callersMethodGetProcessTotal

GetProcessTotal returns the total processed message count.

src/rules_engine/engine_core.go:2646

↓ 1 callersMethodGetProjectRulesetsUnsafe

GetProjectRulesetsUnsafe returns all rulesets used by this project without acquiring locks This version should only be called when the caller already

src/project/project_struct.go:257

↓ 1 callersFunctionGetRulesetsUsingPlugin

(pluginID string)

src/project/project.go:140

↓ 1 callersMethodGetRuntimeErrors

()

src/rules_engine/engine_struct.go:2151

↓ 1 callersFunctionGetSkill

Skill accessors

src/project/project_struct.go:903

↓ 1 callersMethodGetSnapshot

(ref string)

src/rules_engine/cep_value_store.go:22

↓ 1 callersFunctionGetStatsCollector

GetStatsCollector returns the current stats collector function

src/common/daily_stats_manager.go:353

↓ 1 callersMethodGetTTL

GetTTL returns the remaining TTL for an existing non-expired key.

src/rules_engine/engine_threshold_cache.go:79

↓ 1 callersMethodImpl

Impl returns the underlying implementation for agent consumption.

src/skill/skill.go:54

↓ 1 callersFunctionInitAccessLogger

InitAccessLogger initializes the access logger for API requests

src/logger/logger.go:345

↓ 1 callersFunctionInitAgentLogger

InitAgentLogger initializes the agent tool-call logger

src/logger/logger.go:256

↓ 1 callersFunctionInitHeartbeatManager

InitHeartbeatManager initializes the heartbeat manager

src/cluster/heartbeat_simple.go:38

↓ 1 callersFunctionInitInstructionManager

InitInstructionManager initializes the instruction manager

src/cluster/instruction_sync.go:108

↓ 1 callersFunctionInitLogger

()

src/logger/logger.go:77

↓ 1 callersFunctionInitPluginLogger

InitPluginLogger initializes the plugin-specific logger for plugin failures

src/logger/logger.go:163

↓ 1 callersFunctionInitSIMDConfig

InitSIMDConfig initializes SIMD configuration from global config

src/rules_engine/engine_core.go:92

↓ 1 callersFunctionInitSyncListener

InitSyncListener initializes the sync listener

src/cluster/sync_listener.go:58

↓ 1 callersMethodInitializeLeaderInstructions

InitializeLeaderInstructions creates initial instructions for all components (leader only)

src/cluster/instruction_sync.go:629

↓ 1 callersMethodIsCompacting

IsCompacting returns whether instruction manager is currently in compaction mode During compaction, currentVersion is temporarily set to 0

src/cluster/instruction_sync.go:136

↓ 1 callersMethodKickFollowerForResync

KickFollowerForResync kicks out a slow/stuck follower and marks it for full resync

src/cluster/instruction_sync.go:847

↓ 1 callersFunctionMapDeepCopy

(m map[string]interface{})

src/common/utils.go:113

↓ 1 callersFunctionNewCircuitBreaker

NewCircuitBreaker creates a new circuit breaker

src/common/redis.go:35

↓ 1 callersFunctionNewClusterSystemManager

NewClusterSystemManager creates a new cluster system manager instance

src/common/system_monitor.go:513

↓ 1 callersFunctionNewDailyStatsManager

NewDailyStatsManager creates a new daily statistics manager instance

src/common/daily_stats_manager.go:135

↓ 1 callersFunctionNewDistributedLock

NewDistributedLock creates a new distributed lock

src/common/redis.go:520

↓ 1 callersFunctionNewFromExisting

NewFromExisting creates a new Agent instance from an existing one for a given PNS.

src/agent/agent.go:125

↓ 1 callersFunctionNewRedisFailureHandler

NewRedisFailureHandler creates a new Redis failure handler

src/common/redis.go:99

↓ 1 callersFunctionNewRedisSampleManager

NewRedisSampleManager creates a new Redis Sample Manager

src/common/redis_sample_manager.go:46

↓ 1 callersFunctionNewSIMDStringOperations

NewSIMDStringOperations creates a new SIMD string operations instance with CPU capability detection

src/rules_engine/simd_optimizations.go:20

↓ 1 callersFunctionNewSampler

NewSampler creates a new sampler instance

src/common/sampler.go:49

↓ 1 callersFunctionNewSystemMonitor

NewSystemMonitor creates a new system monitor instance

src/common/system_monitor.go:52

↓ 1 callersFunctionNewXMLDecoder

NewXMLDecoder creates a new XMLDecoder

src/rules_engine/engine_parser.go:22

↓ 1 callersFunctionObtainLeaderLocker

()

src/cluster/leader_locker.go:23

↓ 1 callersMethodObtainLeaderLocker

()

src/cluster/cluster.go:39

↓ 1 callersMethodProcessTestData

ProcessTestData processes test data through the input component's normal data flow This ensures test data goes through the same processing as producti

src/input/input.go:549

↓ 1 callersMethodPublishComponentPushChange

PublishComponentPushChange publishes push change instruction

src/cluster/instruction_sync.go:568

↓ 1 callersMethodPublishProjectRestart

PublishProjectRestart publishes project restart instruction

src/cluster/instruction_sync.go:587

↓ 1 callersMethodPublishProjectStart

PublishProjectStart publishes project start instruction

src/cluster/instruction_sync.go:577

↓ 1 callersMethodPublishProjectStop

PublishProjectStop publishes project stop instruction

src/cluster/instruction_sync.go:582

↓ 1 callersMethodPublishProjectsRestart

PublishProjectsRestart publishes multiple project restart instructions

src/cluster/instruction_sync.go:592

↓ 1 callersMethodPutSnapshot

(data map[string]interface{}, expiresAtNs int64)

src/rules_engine/cep_value_store.go:21

↓ 1 callersFunctionREGEX

(data string, regexCompile *regexp.Regex)

src/rules_engine/engine_utils.go:483

↓ 1 callersFunctionRecordChangePush

RecordChangePush records a change push operation to Redis

src/api/operations_history.go:68

↓ 1 callersFunctionRedisGetInt64

RedisGetInt64 gets a value from Redis as int64

src/common/redis.go:282

↓ 1 callersFunctionRedisHDel

RedisHDel deletes a field from a Redis hash

src/common/redis.go:382

↓ 1 callersFunctionRedisPing

()

src/common/redis.go:250

↓ 1 callersFunctionRedisSAdd

===================== Set Operations ===================== RedisSAdd adds a member to a set

src/common/redis.go:417

↓ 1 callersFunctionRedisZRemRangeByScore

RedisZRemRangeByScore removes members by score from a sorted set

src/common/redis.go:449

↓ 1 callersFunctionRedisZRevRange

RedisZRevRange returns members from a sorted set in reverse order

src/common/redis.go:439

↓ 1 callersMethodRelease

()

src/cluster/leader_locker.go:69

↓ 1 callersMethodResetAllStats

ResetAllStats resets all statistics counters (for restart scenarios)

src/plugin/plugin.go:1090

↓ 1 callersMethodResetDownstream

()

src/rules_engine/engine_struct.go:262

↓ 1 callersMethodResetFailureTotal

ResetFailureTotal resets the failure counter and baseline (for restart scenarios)

src/plugin/plugin.go:1084

↓ 1 callersMethodResetForFullResync

ResetForFullResync resets follower state to trigger full resync Called when follower is kicked out by leader due to slow sync

src/cluster/sync_listener.go:116

↓ 1 callersMethodResetProcessTotal

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

src/rules_engine/engine_core.go:2652

↓ 1 callersMethodResetSuccessTotal

ResetSuccessTotal resets the success counter and baseline (for restart scenarios)

src/plugin/plugin.go:1078

↓ 1 callersFunctionRetryWithExponentialBackoff

RetryWithExponentialBackoff executes a function with exponential backoff retry

src/common/redis.go:482

↓ 1 callersMethodSIMDContains

SIMDContains performs SIMD-optimized string contains operation

src/rules_engine/simd_optimizations.go:27

↓ 1 callersFunctionSIMDEnhancedEND

SIMDEnhancedEND provides SIMD-optimized version of END

src/rules_engine/simd_integration.go:75

↓ 1 callersFunctionSIMDEnhancedINCL

SIMDEnhancedINCL provides SIMD-optimized version of INCL

src/rules_engine/simd_integration.go:49

↓ 1 callersFunctionSIMDEnhancedNCS_END

SIMDEnhancedNCS_END provides SIMD-optimized version of NCS_END

src/rules_engine/simd_integration.go:88

↓ 1 callersFunctionSIMDEnhancedNCS_INCL

SIMDEnhancedNCS_INCL provides SIMD-optimized version of NCS_INCL

src/rules_engine/simd_integration.go:23

↓ 1 callersFunctionSIMDEnhancedNCS_START

SIMDEnhancedNCS_START provides SIMD-optimized version of NCS_START

src/rules_engine/simd_integration.go:36

↓ 1 callersFunctionSIMDEnhancedSTART

SIMDEnhancedSTART provides SIMD-optimized version of START

src/rules_engine/simd_integration.go:62

↓ 1 callersMethodSIMDHasPrefix

SIMDHasPrefix performs SIMD-optimized prefix checking

src/rules_engine/simd_optimizations.go:61

↓ 1 callersMethodSIMDHasPrefixCaseInsensitive

SIMDHasPrefixCaseInsensitive performs case-insensitive SIMD prefix checking

src/rules_engine/simd_optimizations.go:78

↓ 1 callersMethodSIMDHasSuffix

SIMDHasSuffix performs SIMD-optimized suffix checking

src/rules_engine/simd_optimizations.go:95

↓ 1 callersMethodSIMDHasSuffixCaseInsensitive

SIMDHasSuffixCaseInsensitive performs case-insensitive SIMD suffix checking

src/rules_engine/simd_optimizations.go:112

↓ 1 callersFunctionSafeDeletePluginComponent

(id string)

src/project/project.go:144

↓ 1 callersMethodSetFollowerExecutionFlag

SetFollowerExecutionFlag sets/refreshes a flag indicating follower is executing instructions

src/cluster/sync_listener.go:495

↓ 1 callersFunctionSetPNSOutput

(pns string, out *output.Output)

src/project/project_struct.go:486

↓ 1 callersFunctionSetProjectErrorStatus

SetProjectErrorStatus force-stops a project after component failure and leaves the project in error state so callers can distinguish crash recovery fr

src/project/project.go:519

↓ 1 callersFunctionSetProjectErrorStatus

SetProjectErrorStatus calls the registered project error setter

src/common/global.go:257

↓ 1 callersMethodSetTestMode

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

src/output/output.go:1431

↓ 1 callersMethodStart

Start initializes and starts the output component based on its type Returns an error if the component is already running or if initialization fails If

src/output/output.go:640

↓ 1 callersMethodStart

()

src/common/aliyun_sls.go:259

↓ 1 callersMethodStart

Start launches a goroutine for each upstream channel. Each message is treated as an independent event.

src/agent/agent_loop.go:119

← previous next →601–700 of 2,165, ranked by callers