MCPcopy Create free account

hub / github.com/QQ3221197721/cloudai-fusion / functions

Functions4,559 in github.com/QQ3221197721/cloudai-fusion

↓ 13 callersMethodIsEnabled
IsEnabled checks if a feature flag is enabled. Returns false for unknown flags.
pkg/feature/flags.go:233
↓ 13 callersMethodJoinCluster
============================================================================ Cluster Federation ======================================================
pkg/multicluster/manager.go:73
↓ 13 callersFunctionNew
============================================================================ Factory =================================================================
pkg/election/election.go:156
↓ 13 callersFunctionNewCircuitBreaker
NewCircuitBreaker creates a new circuit breaker with the given config.
pkg/resilience/circuit.go:78
↓ 13 callersFunctionNewGCPProvider
(cfg config.CloudProviderConfig)
pkg/cloud/providers_extended.go:423
↓ 13 callersFunctionNewManager
NewManager creates a new GitOps manager.
pkg/gitops/manager.go:67
↓ 13 callersFunctionNewManager
NewManager creates a new edge-cloud manager
pkg/edge/manager.go:166
↓ 13 callersFunctionNewService
NewService creates a new authentication service
pkg/auth/auth.go:178
↓ 13 callersMethodPublish
Publish sends an event to all subscribers of the event's topic.
pkg/eventbus/bus.go:21
↓ 13 callersMethodRegisterNode
RegisterNode registers a new edge node (DB + cache)
pkg/edge/manager.go:218
↓ 13 callersMethodStartCanary
StartCanary initiates a canary deployment for a component.
pkg/deploy/deploy.go:163
↓ 13 callersMethodanalyze_incident
Analyze an incident using LLM reasoning with rule-based fallback.
ai/agents/operations_agent.py:152
↓ 13 callersFunctionassertHTTP
(t *testing.T, err *AppError, status int)
pkg/errors/errors_test.go:274
↓ 13 callersFunctionnewTestBus
============================================================================ memoryBus — Publish / Subscribe =========================================
pkg/eventbus/eventbus_test.go:158
↓ 13 callersFunctionnewTestCache
============================================================================ memoryCache — basic CRUD ================================================
pkg/cache/cache_test.go:32
↓ 13 callersFunctionnewTestOrchestrator
============================================================================ AgentOrchestrator =======================================================
cmd/agent/main_test.go:85
↓ 12 callersMethodBuild
============================================================================ Build — instantiate all registered plugins ==============================
pkg/plugin/registry.go:97
↓ 12 callersMethodClose
Close releases producer resources.
pkg/messaging/queue.go:118
↓ 12 callersFunctionDefaultSpotPredictionConfig
DefaultSpotPredictionConfig returns sensible defaults.
pkg/finops/spot.go:47
↓ 12 callersMethodGetLevel
GetLevel returns the current log level as a string.
pkg/logging/logger.go:174
↓ 12 callersFunctionLoad
Load reads configuration from file, environment variables, and CLI flags
pkg/config/config.go:113
↓ 12 callersFunctionNewCapacityPlanner
NewCapacityPlanner creates a new capacity planner.
pkg/aiops/capacity.go:165
↓ 12 callersFunctionNewCompressionPipeline
NewCompressionPipeline creates a new compression pipeline.
pkg/edge/model_compression.go:130
↓ 12 callersFunctionNewManager
NewManager creates a new controller manager.
pkg/controller/manager.go:80
↓ 12 callersFunctionNewRLOptimizer
NewRLOptimizer creates a new Q-learning scheduling optimizer
pkg/scheduler/rl_optimizer.go:70
↓ 12 callersMethodRecordRequest
RecordRequest records a request outcome for SLI tracking.
pkg/metrics/slo.go:213
↓ 12 callersMethodValue
Value returns the total counter value
pkg/edge/offline_enhanced.go:391
↓ 12 callersFunctionnewFakeClient
============================================================================ Helper: build a Client with fake clientset ==============================
pkg/k8s/client_test.go:19
↓ 12 callersFunctionnewTestDB
============================================================================ memoryTSDB — Write & Query ==============================================
pkg/tsdb/tsdb_test.go:77
↓ 12 callersFunctionnewTestManager
()
pkg/audit/audit_test.go:11
↓ 11 callersFunctionDefaultCompressionPipelineConfig
DefaultCompressionPipelineConfig returns a production-ready pipeline config.
pkg/edge/model_compression.go:63
↓ 11 callersFunctionNewMessage
NewMessage creates a new message.
pkg/messaging/queue.go:60
↓ 11 callersFunctionNewSpotPredictionEngine
NewSpotPredictionEngine creates a new spot prediction engine.
pkg/finops/spot.go:112
↓ 11 callersMethodRegisterAgent
RegisterAgent adds an agent to the orchestrator
cmd/agent/main.go:221
↓ 11 callersMethodRegisterWorkload
RegisterWorkload registers a workload for auto-scaling.
pkg/aiops/autoscale.go:175
↓ 11 callersMethodSetLevel
============================================================================ Dynamic Log Level Adjustment ============================================
pkg/logging/logger.go:163
↓ 11 callersMethodadd_datapoint
Add a data point to the metric history.
ai/anomaly/detector.py:33
↓ 10 callersMethodAddSource
============================================================================ Source Management =======================================================
pkg/logging/centralized.go:199
↓ 10 callersMethodApplyPSSToNamespace
============================================================================ PSS Operations ==========================================================
pkg/security/hardening.go:236
↓ 10 callersMethodClose
()
pkg/store/interfaces.go:12
↓ 10 callersMethodCreateIncident
CreateIncident creates an incident from fault events.
pkg/aiops/selfheal.go:334
↓ 10 callersFunctionDefaultRIConfig
DefaultRIConfig returns sensible defaults.
pkg/finops/recommendation.go:43
↓ 10 callersFunctionNewAlertConvergenceEngine
NewAlertConvergenceEngine creates a new convergence engine.
pkg/metrics/errorbudget.go:465
↓ 10 callersFunctionNewManager
NewManager creates a new workload manager
pkg/workload/manager.go:115
↓ 10 callersFunctionNewMemoryProducer
NewMemoryProducer creates an in-memory message producer.
pkg/messaging/queue.go:197
↓ 10 callersMethodProcessAlert
ProcessAlert processes an incoming alert through the convergence pipeline. Returns: (shouldNotify bool, groupKey string, reason string)
pkg/metrics/errorbudget.go:487
↓ 10 callersMethodQueryEvents
QueryEvents returns events matching the given filter.
pkg/audit/audit.go:188
↓ 10 callersFunctionReconcilingCondition
ReconcilingCondition creates a Reconciling=True condition.
pkg/controller/types.go:359
↓ 10 callersMethodSubscribe
Subscribe registers a handler for events matching the topic pattern. Topic patterns support wildcards: "cluster.*" matches "cluster.created", etc. Ret
pkg/eventbus/bus.go:26
↓ 10 callersFunctionValidateRequired
ValidateRequired checks that a string field is non-empty.
pkg/validation/validator.go:155
↓ 10 callersMethodValidateStrict
ValidateStrict performs comprehensive security validation. In production, critical issues are returned as errors (not just warnings).
pkg/config/config.go:208
↓ 10 callersFunctioncheckBudget
(t *testing.T, budgetKey string, elapsed time.Duration)
tests/performance/budget_test.go:52
↓ 10 callersFunctioncontainsString
(slice []string, s string)
pkg/auth/abac.go:383
↓ 10 callersFunctionpercentile
============================================================================ Utility — percentile calculation (for in-process estimation) ============
pkg/metrics/slo.go:393
↓ 10 callersFunctionresetSharedQueue
============================================================================ resetSharedQueue — reset singleton between tests ========================
pkg/messaging/messaging_test.go:17
↓ 10 callersMethodstep
Execute scheduling action and return reward.
ai/scheduler/train.py:86
↓ 9 callersMethodAddRegion
============================================================================ Cross-Region DR =========================================================
pkg/disaster/disaster.go:492
↓ 9 callersMethodCheckHealth
CheckHealth evaluates deployment health and triggers rollback if needed.
pkg/deploy/deploy.go:444
↓ 9 callersMethodConfigureSSO
============================================================================ SSO Integration =========================================================
pkg/enterprise/manager.go:57
↓ 9 callersFunctionDefaultRollbackConfig
DefaultRollbackConfig returns production rollback defaults.
pkg/deploy/deploy.go:391
↓ 9 callersMethodDoRawRequest
Raw API access
pkg/k8s/interfaces.go:26
↓ 9 callersMethodEnqueue
Enqueue adds a request to the specified controller's work queue. This is the primary way to trigger reconciliation from external events.
pkg/controller/manager.go:390
↓ 9 callersMethodGenerateToken
GenerateToken creates a new JWT token for the given user
pkg/auth/auth.go:300
↓ 9 callersMethodGetStatus
GetStatus returns the current service mesh status.
pkg/mesh/interfaces.go:10
↓ 9 callersMethodHealthy
Healthy checks if the TSDB backend is reachable.
pkg/tsdb/tsdb.go:132
↓ 9 callersMethodKey
()
pkg/scheduler/rl_optimizer.go:153
↓ 9 callersMethodLen
Len returns the current number of items in the queue.
pkg/controller/queue.go:237
↓ 9 callersFunctionNew
New creates a new structured Logger.
pkg/logging/logger.go:59
↓ 9 callersFunctionNewErrorBudgetManager
NewErrorBudgetManager creates a new error budget manager.
pkg/metrics/errorbudget.go:192
↓ 9 callersFunctionNewFederationManager
NewFederationManager creates a new identity federation manager
pkg/security/oidc.go:148
↓ 9 callersFunctionNewManager
NewManager creates a new Wasm runtime manager
pkg/wasm/manager.go:133
↓ 9 callersFunctionNewManager
NewManager creates a new service mesh manager
pkg/mesh/manager.go:140
↓ 9 callersFunctionNewRIRecommendationEngine
NewRIRecommendationEngine creates a new RI recommendation engine.
pkg/finops/recommendation.go:123
↓ 9 callersFunctionNewWorkQueue
NewWorkQueue creates a new rate-limited work queue.
pkg/controller/queue.go:75
↓ 9 callersMethodRead
(p []byte)
pkg/wasm/manager.go:402
↓ 9 callersMethodShutDown
ShutDown signals the queue to stop accepting new items. Existing items will be drained.
pkg/controller/queue.go:245
↓ 9 callersMethodStart
Start starts all registered controllers and blocks until ctx is cancelled. If leader election is enabled, reconciliation loops only run on the leader.
pkg/controller/manager.go:132
↓ 9 callersMethodStartDrill
============================================================================ Recovery Drills =========================================================
pkg/disaster/disaster.go:628
↓ 9 callersMethodState
State returns the current runtime state.
pkg/edge/offline_runtime.go:142
↓ 9 callersMethodStats
Stats returns runtime statistics about the event bus.
pkg/eventbus/bus.go:39
↓ 9 callersMethodStatus
Status returns the current SLO status for all tracked services.
pkg/metrics/slo.go:343
↓ 9 callersMethodStop
()
pkg/scheduler/interfaces.go:15
↓ 9 callersMethodString
String returns a human-readable representation.
pkg/controller/types.go:70
↓ 9 callersFunctionSupportedMIGProfiles
============================================================================ MIG (Multi-Instance GPU) Operations =====================================
pkg/scheduler/gpu_sharing.go:124
↓ 9 callersMethodValidateToken
ValidateToken parses and validates a JWT token string
pkg/auth/auth.go:342
↓ 9 callersFunctionclampFloat
(v, min, max float64)
pkg/aiops/capacity.go:626
↓ 9 callersFunctionsetupTestRouter
============================================================================ HTTP Handlers ===========================================================
cmd/agent/main_test.go:184
↓ 8 callersFunctionDefaultCostAnalysisConfig
DefaultCostAnalysisConfig returns sensible defaults.
pkg/finops/report.go:41
↓ 8 callersMethodEvaluate
Evaluate recalculates all service budgets and determines active policies.
pkg/metrics/errorbudget.go:244
↓ 8 callersMethodEvaluate
Evaluate runs a single evaluation cycle for a workload.
pkg/aiops/autoscale.go:217
↓ 8 callersMethodExists
Exists checks if a key exists in the cache.
pkg/cache/cache.go:67
↓ 8 callersMethodGetTenant
GetTenant returns a tenant by ID
pkg/tenant/manager.go:167
↓ 8 callersMethodHasErrors
HasErrors returns true if any fatal validation errors were found
pkg/config/config.go:181
↓ 8 callersFunctionHashPassword
HashPassword hashes a plaintext password using bcrypt
pkg/auth/auth.go:201
↓ 8 callersMethodListClusters
Cluster Operations
pkg/cloud/manager.go:30
↓ 8 callersMethodName
Identity
pkg/cloud/manager.go:25
↓ 8 callersMethodNamespacedName
NamespacedName returns the combined namespace/name key.
pkg/controller/types.go:81
↓ 8 callersFunctionNewGPUSharingManager
NewGPUSharingManager creates a new GPU sharing manager
pkg/scheduler/gpu_sharing.go:97
↓ 8 callersFunctionNewMemoryBus
NewMemoryBus creates an in-memory event bus.
pkg/eventbus/bus.go:70
↓ 8 callersFunctionNewRollbackController
NewRollbackController creates a new rollback controller.
pkg/deploy/deploy.go:429
← previousnext →101–200 of 4,559, ranked by callers