Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/QQ3221197721/cloudai-fusion
/ functions
Functions
4,559 in github.com/QQ3221197721/cloudai-fusion
⨍
Functions
4,559
◇
Types & classes
1,271
↳
Endpoints
11
↓ 13 callers
Method
IsEnabled
IsEnabled checks if a feature flag is enabled. Returns false for unknown flags.
pkg/feature/flags.go:233
↓ 13 callers
Method
JoinCluster
============================================================================ Cluster Federation ======================================================
pkg/multicluster/manager.go:73
↓ 13 callers
Function
New
============================================================================ Factory =================================================================
pkg/election/election.go:156
↓ 13 callers
Function
NewCircuitBreaker
NewCircuitBreaker creates a new circuit breaker with the given config.
pkg/resilience/circuit.go:78
↓ 13 callers
Function
NewGCPProvider
(cfg config.CloudProviderConfig)
pkg/cloud/providers_extended.go:423
↓ 13 callers
Function
NewManager
NewManager creates a new GitOps manager.
pkg/gitops/manager.go:67
↓ 13 callers
Function
NewManager
NewManager creates a new edge-cloud manager
pkg/edge/manager.go:166
↓ 13 callers
Function
NewService
NewService creates a new authentication service
pkg/auth/auth.go:178
↓ 13 callers
Method
Publish
Publish sends an event to all subscribers of the event's topic.
pkg/eventbus/bus.go:21
↓ 13 callers
Method
RegisterNode
RegisterNode registers a new edge node (DB + cache)
pkg/edge/manager.go:218
↓ 13 callers
Method
StartCanary
StartCanary initiates a canary deployment for a component.
pkg/deploy/deploy.go:163
↓ 13 callers
Method
analyze_incident
Analyze an incident using LLM reasoning with rule-based fallback.
ai/agents/operations_agent.py:152
↓ 13 callers
Function
assertHTTP
(t *testing.T, err *AppError, status int)
pkg/errors/errors_test.go:274
↓ 13 callers
Function
newTestBus
============================================================================ memoryBus — Publish / Subscribe =========================================
pkg/eventbus/eventbus_test.go:158
↓ 13 callers
Function
newTestCache
============================================================================ memoryCache — basic CRUD ================================================
pkg/cache/cache_test.go:32
↓ 13 callers
Function
newTestOrchestrator
============================================================================ AgentOrchestrator =======================================================
cmd/agent/main_test.go:85
↓ 12 callers
Method
Build
============================================================================ Build — instantiate all registered plugins ==============================
pkg/plugin/registry.go:97
↓ 12 callers
Method
Close
Close releases producer resources.
pkg/messaging/queue.go:118
↓ 12 callers
Function
DefaultSpotPredictionConfig
DefaultSpotPredictionConfig returns sensible defaults.
pkg/finops/spot.go:47
↓ 12 callers
Method
GetLevel
GetLevel returns the current log level as a string.
pkg/logging/logger.go:174
↓ 12 callers
Function
Load
Load reads configuration from file, environment variables, and CLI flags
pkg/config/config.go:113
↓ 12 callers
Function
NewCapacityPlanner
NewCapacityPlanner creates a new capacity planner.
pkg/aiops/capacity.go:165
↓ 12 callers
Function
NewCompressionPipeline
NewCompressionPipeline creates a new compression pipeline.
pkg/edge/model_compression.go:130
↓ 12 callers
Function
NewManager
NewManager creates a new controller manager.
pkg/controller/manager.go:80
↓ 12 callers
Function
NewRLOptimizer
NewRLOptimizer creates a new Q-learning scheduling optimizer
pkg/scheduler/rl_optimizer.go:70
↓ 12 callers
Method
RecordRequest
RecordRequest records a request outcome for SLI tracking.
pkg/metrics/slo.go:213
↓ 12 callers
Method
Value
Value returns the total counter value
pkg/edge/offline_enhanced.go:391
↓ 12 callers
Function
newFakeClient
============================================================================ Helper: build a Client with fake clientset ==============================
pkg/k8s/client_test.go:19
↓ 12 callers
Function
newTestDB
============================================================================ memoryTSDB — Write & Query ==============================================
pkg/tsdb/tsdb_test.go:77
↓ 12 callers
Function
newTestManager
()
pkg/audit/audit_test.go:11
↓ 11 callers
Function
DefaultCompressionPipelineConfig
DefaultCompressionPipelineConfig returns a production-ready pipeline config.
pkg/edge/model_compression.go:63
↓ 11 callers
Function
NewMessage
NewMessage creates a new message.
pkg/messaging/queue.go:60
↓ 11 callers
Function
NewSpotPredictionEngine
NewSpotPredictionEngine creates a new spot prediction engine.
pkg/finops/spot.go:112
↓ 11 callers
Method
RegisterAgent
RegisterAgent adds an agent to the orchestrator
cmd/agent/main.go:221
↓ 11 callers
Method
RegisterWorkload
RegisterWorkload registers a workload for auto-scaling.
pkg/aiops/autoscale.go:175
↓ 11 callers
Method
SetLevel
============================================================================ Dynamic Log Level Adjustment ============================================
pkg/logging/logger.go:163
↓ 11 callers
Method
add_datapoint
Add a data point to the metric history.
ai/anomaly/detector.py:33
↓ 10 callers
Method
AddSource
============================================================================ Source Management =======================================================
pkg/logging/centralized.go:199
↓ 10 callers
Method
ApplyPSSToNamespace
============================================================================ PSS Operations ==========================================================
pkg/security/hardening.go:236
↓ 10 callers
Method
Close
()
pkg/store/interfaces.go:12
↓ 10 callers
Method
CreateIncident
CreateIncident creates an incident from fault events.
pkg/aiops/selfheal.go:334
↓ 10 callers
Function
DefaultRIConfig
DefaultRIConfig returns sensible defaults.
pkg/finops/recommendation.go:43
↓ 10 callers
Function
NewAlertConvergenceEngine
NewAlertConvergenceEngine creates a new convergence engine.
pkg/metrics/errorbudget.go:465
↓ 10 callers
Function
NewManager
NewManager creates a new workload manager
pkg/workload/manager.go:115
↓ 10 callers
Function
NewMemoryProducer
NewMemoryProducer creates an in-memory message producer.
pkg/messaging/queue.go:197
↓ 10 callers
Method
ProcessAlert
ProcessAlert processes an incoming alert through the convergence pipeline. Returns: (shouldNotify bool, groupKey string, reason string)
pkg/metrics/errorbudget.go:487
↓ 10 callers
Method
QueryEvents
QueryEvents returns events matching the given filter.
pkg/audit/audit.go:188
↓ 10 callers
Function
ReconcilingCondition
ReconcilingCondition creates a Reconciling=True condition.
pkg/controller/types.go:359
↓ 10 callers
Method
Subscribe
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 callers
Function
ValidateRequired
ValidateRequired checks that a string field is non-empty.
pkg/validation/validator.go:155
↓ 10 callers
Method
ValidateStrict
ValidateStrict performs comprehensive security validation. In production, critical issues are returned as errors (not just warnings).
pkg/config/config.go:208
↓ 10 callers
Function
checkBudget
(t *testing.T, budgetKey string, elapsed time.Duration)
tests/performance/budget_test.go:52
↓ 10 callers
Function
containsString
(slice []string, s string)
pkg/auth/abac.go:383
↓ 10 callers
Function
percentile
============================================================================ Utility — percentile calculation (for in-process estimation) ============
pkg/metrics/slo.go:393
↓ 10 callers
Function
resetSharedQueue
============================================================================ resetSharedQueue — reset singleton between tests ========================
pkg/messaging/messaging_test.go:17
↓ 10 callers
Method
step
Execute scheduling action and return reward.
ai/scheduler/train.py:86
↓ 9 callers
Method
AddRegion
============================================================================ Cross-Region DR =========================================================
pkg/disaster/disaster.go:492
↓ 9 callers
Method
CheckHealth
CheckHealth evaluates deployment health and triggers rollback if needed.
pkg/deploy/deploy.go:444
↓ 9 callers
Method
ConfigureSSO
============================================================================ SSO Integration =========================================================
pkg/enterprise/manager.go:57
↓ 9 callers
Function
DefaultRollbackConfig
DefaultRollbackConfig returns production rollback defaults.
pkg/deploy/deploy.go:391
↓ 9 callers
Method
DoRawRequest
Raw API access
pkg/k8s/interfaces.go:26
↓ 9 callers
Method
Enqueue
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 callers
Method
GenerateToken
GenerateToken creates a new JWT token for the given user
pkg/auth/auth.go:300
↓ 9 callers
Method
GetStatus
GetStatus returns the current service mesh status.
pkg/mesh/interfaces.go:10
↓ 9 callers
Method
Healthy
Healthy checks if the TSDB backend is reachable.
pkg/tsdb/tsdb.go:132
↓ 9 callers
Method
Key
()
pkg/scheduler/rl_optimizer.go:153
↓ 9 callers
Method
Len
Len returns the current number of items in the queue.
pkg/controller/queue.go:237
↓ 9 callers
Function
New
New creates a new structured Logger.
pkg/logging/logger.go:59
↓ 9 callers
Function
NewErrorBudgetManager
NewErrorBudgetManager creates a new error budget manager.
pkg/metrics/errorbudget.go:192
↓ 9 callers
Function
NewFederationManager
NewFederationManager creates a new identity federation manager
pkg/security/oidc.go:148
↓ 9 callers
Function
NewManager
NewManager creates a new Wasm runtime manager
pkg/wasm/manager.go:133
↓ 9 callers
Function
NewManager
NewManager creates a new service mesh manager
pkg/mesh/manager.go:140
↓ 9 callers
Function
NewRIRecommendationEngine
NewRIRecommendationEngine creates a new RI recommendation engine.
pkg/finops/recommendation.go:123
↓ 9 callers
Function
NewWorkQueue
NewWorkQueue creates a new rate-limited work queue.
pkg/controller/queue.go:75
↓ 9 callers
Method
Read
(p []byte)
pkg/wasm/manager.go:402
↓ 9 callers
Method
ShutDown
ShutDown signals the queue to stop accepting new items. Existing items will be drained.
pkg/controller/queue.go:245
↓ 9 callers
Method
Start
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 callers
Method
StartDrill
============================================================================ Recovery Drills =========================================================
pkg/disaster/disaster.go:628
↓ 9 callers
Method
State
State returns the current runtime state.
pkg/edge/offline_runtime.go:142
↓ 9 callers
Method
Stats
Stats returns runtime statistics about the event bus.
pkg/eventbus/bus.go:39
↓ 9 callers
Method
Status
Status returns the current SLO status for all tracked services.
pkg/metrics/slo.go:343
↓ 9 callers
Method
Stop
()
pkg/scheduler/interfaces.go:15
↓ 9 callers
Method
String
String returns a human-readable representation.
pkg/controller/types.go:70
↓ 9 callers
Function
SupportedMIGProfiles
============================================================================ MIG (Multi-Instance GPU) Operations =====================================
pkg/scheduler/gpu_sharing.go:124
↓ 9 callers
Method
ValidateToken
ValidateToken parses and validates a JWT token string
pkg/auth/auth.go:342
↓ 9 callers
Function
clampFloat
(v, min, max float64)
pkg/aiops/capacity.go:626
↓ 9 callers
Function
setupTestRouter
============================================================================ HTTP Handlers ===========================================================
cmd/agent/main_test.go:184
↓ 8 callers
Function
DefaultCostAnalysisConfig
DefaultCostAnalysisConfig returns sensible defaults.
pkg/finops/report.go:41
↓ 8 callers
Method
Evaluate
Evaluate recalculates all service budgets and determines active policies.
pkg/metrics/errorbudget.go:244
↓ 8 callers
Method
Evaluate
Evaluate runs a single evaluation cycle for a workload.
pkg/aiops/autoscale.go:217
↓ 8 callers
Method
Exists
Exists checks if a key exists in the cache.
pkg/cache/cache.go:67
↓ 8 callers
Method
GetTenant
GetTenant returns a tenant by ID
pkg/tenant/manager.go:167
↓ 8 callers
Method
HasErrors
HasErrors returns true if any fatal validation errors were found
pkg/config/config.go:181
↓ 8 callers
Function
HashPassword
HashPassword hashes a plaintext password using bcrypt
pkg/auth/auth.go:201
↓ 8 callers
Method
ListClusters
Cluster Operations
pkg/cloud/manager.go:30
↓ 8 callers
Method
Name
Identity
pkg/cloud/manager.go:25
↓ 8 callers
Method
NamespacedName
NamespacedName returns the combined namespace/name key.
pkg/controller/types.go:81
↓ 8 callers
Function
NewGPUSharingManager
NewGPUSharingManager creates a new GPU sharing manager
pkg/scheduler/gpu_sharing.go:97
↓ 8 callers
Function
NewMemoryBus
NewMemoryBus creates an in-memory event bus.
pkg/eventbus/bus.go:70
↓ 8 callers
Function
NewRollbackController
NewRollbackController creates a new rollback controller.
pkg/deploy/deploy.go:429
← previous
next →
101–200 of 4,559, ranked by callers