Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/Climatik-Project/Climatik-Project
/ functions
Functions
210 in github.com/Climatik-Project/Climatik-Project
⨍
Functions
210
◇
Types & classes
61
↳
Endpoints
5
↓ 46 callers
Method
Error
()
api/v1alpha1/powercappingconfig_types.go:101
↓ 13 callers
Function
Run
Run executes the provided command within this context
test/utils/utils.go:50
↓ 8 callers
Method
String
()
internal/planner/grpc.pb.go:96
↓ 6 callers
Function
NewMockPowerCappingConfig
NewMockPowerCappingConfig returns a new instance of a mock PowerCappingConfig
internal/alert/tests/test_helper.go:9
↓ 5 callers
Method
GetHandler
(source string)
internal/webhook/factory/factory.go:15
↓ 5 callers
Method
Query
(ctx context.Context, query string, ts time.Time)
internal/alert/adapters/prom_alert.go:19
↓ 4 callers
Method
DeepCopyInto
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
api/v1alpha1/zz_generated.deepcopy.go:149
↓ 4 callers
Method
Subscribe
(topic string, subscriber AlertManager)
internal/alert/pubsub.go:21
↓ 4 callers
Function
file_grpc_proto_rawDescGZIP
()
internal/planner/grpc.pb.go:293
↓ 3 callers
Method
CreateAlert
(podName string, powerCapValue int, devices map[string]string, config *powercappingv1alpha1.PowerCappingConfig
internal/alert/adapters/slack.go:42
↓ 3 callers
Function
NewPrometheusAlertManager
(prometheusAddress string)
internal/alert/adapters/prom_alert.go:28
↓ 3 callers
Function
NewSlackAlertManager
(webhookURL string)
internal/alert/adapters/slack.go:36
↓ 3 callers
Function
NewSlackHandler
(signingSecret, slackBotToken string)
internal/webhook/handlers/slack_handler.go:31
↓ 3 callers
Function
monitor_power_usage
(spec, status, patch, **kwargs)
python/climatik_operator/operator.py:106
↓ 2 callers
Method
CalculateOptimalReplicas
(ctx context.Context, in *CalculateOptimalReplicasRequest, opts ...grpc.CallOption)
internal/planner/grpc_grpc.pb.go:25
↓ 2 callers
Method
CreateAlert
(podName string, powerCapValue int, devices map[string]string, config *powercappingv1alpha1.PowerCappingConfig
internal/alert/adapters/prom_alert.go:39
↓ 2 callers
Function
CreateSlackWebhook
(port int)
internal/webhook/slack_webhook.go:25
↓ 2 callers
Method
FormatPrometheusAlert
(podName string, powerCapValue int, devices map[string]string)
internal/alert/adapters/prom_alert.go:47
↓ 2 callers
Function
NewGitOpsAlertManager
(repoURL, repoDir string)
internal/alert/adapters/git_ops.go:17
↓ 2 callers
Function
NewPubSub
()
internal/alert/pubsub.go:15
↓ 2 callers
Method
Run
()
internal/webhook/runners/runner.go:5
↓ 2 callers
Method
SendAlert
(podName string, powerCapValue int, devices map[string]string, config *v1alpha1.PowerCappingConfig)
internal/alert/service.go:18
↓ 2 callers
Method
SendAlertToPrometheus
(alert PrometheusAlert)
internal/alert/adapters/prom_alert.go:69
↓ 2 callers
Function
calculate_max_replicas
(power_cap_limit)
python/climatik_operator/operator.py:210
↓ 2 callers
Function
k8s_api_instance
()
python/climatik_operator/k8s_utils.py:4
↓ 2 callers
Method
start_server
(self)
python/climatik_operator/prom_metrics.py:89
↓ 2 callers
Function
warnError
(err error)
test/utils/utils.go:37
↓ 1 callers
Method
Add
(repoDir string, files ...string)
internal/alert/tests/alert_test.go:53
↓ 1 callers
Method
CommandHandler
(w http.ResponseWriter, r *http.Request)
internal/webhook/handlers/slack_handler.go:49
↓ 1 callers
Method
CreateAlert
(podName string, powerCapValue int, devices map[string]string, config *v1alpha1.PowerCappingConfig)
internal/alert/alert.go:7
↓ 1 callers
Method
CreateAlert
(podName string, powerCapValue int, devices map[string]string, config *powercappingv1alpha1.PowerCappingConfig
internal/alert/adapters/git_ops.go:25
↓ 1 callers
Function
CreateAlertService
(config map[string]map[string]string)
internal/alert/factory.go:31
↓ 1 callers
Function
CreateWebhook
(port int)
internal/webhook/webhook.go:53
↓ 1 callers
Method
DeepCopy
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new PowerCappingConfig.
api/v1alpha1/zz_generated.deepcopy.go:67
↓ 1 callers
Method
DeepCopy
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new PowerCappingConfigList.
api/v1alpha1/zz_generated.deepcopy.go:99
↓ 1 callers
Method
DeepCopyInto
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
api/v1alpha1/zz_generated.deepcopy.go:28
↓ 1 callers
Method
DeepCopyInto
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
api/v1alpha1/zz_generated.deepcopy.go:43
↓ 1 callers
Method
DeepCopyInto
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
api/v1alpha1/zz_generated.deepcopy.go:58
↓ 1 callers
Method
DeepCopyInto
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
api/v1alpha1/zz_generated.deepcopy.go:85
↓ 1 callers
Method
DeepCopyInto
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
api/v1alpha1/zz_generated.deepcopy.go:117
↓ 1 callers
Method
DeepCopyInto
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
api/v1alpha1/zz_generated.deepcopy.go:134
↓ 1 callers
Method
DeepCopyInto
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
api/v1alpha1/zz_generated.deepcopy.go:166
↓ 1 callers
Method
DeepCopyInto
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
api/v1alpha1/zz_generated.deepcopy.go:181
↓ 1 callers
Method
DeepCopyInto
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
api/v1alpha1/zz_generated.deepcopy.go:196
↓ 1 callers
Method
GetAlerts
GetAlerts returns the current alerts (for testing purposes)
internal/alert/adapters/git_ops.go:52
↓ 1 callers
Function
GetNonEmptyLines
GetNonEmptyLines converts given command output string into individual objects according to line breakers, and ignores the empty elements in it.
test/utils/utils.go:120
↓ 1 callers
Function
GetProjectDir
GetProjectDir will return the directory where the project is
test/utils/utils.go:133
↓ 1 callers
Method
HandleAlert
(payload []byte)
internal/webhook/interfaces/interfaces.go:6
↓ 1 callers
Function
InstallCertManager
InstallCertManager installs the cert manager bundle.
test/utils/utils.go:88
↓ 1 callers
Function
InstallPrometheusOperator
InstallPrometheusOperator installs the prometheus Operator to be used to export the enabled metrics.
test/utils/utils.go:42
↓ 1 callers
Method
InteractionHandler
(w http.ResponseWriter, r *http.Request)
internal/webhook/handlers/slack_handler.go:76
↓ 1 callers
Function
LoadImageToKindClusterWithName
LoadImageToKindCluster loads a local docker image to the kind cluster
test/utils/utils.go:107
↓ 1 callers
Function
NewAlertManager
(managerType AlertManagerType, config map[string]string)
internal/alert/factory.go:18
↓ 1 callers
Function
NewAlertService
(config map[string]map[string]string)
internal/alert/service.go:10
↓ 1 callers
Method
PostMessage
(channelID string, options ...slack.MsgOption)
internal/alert/tests/alert_test.go:28
↓ 1 callers
Method
Publish
(topic string, podName string, powerCapValue int, devices map[string]string, config *v1alpha1.PowerCappingConf
internal/alert/pubsub.go:27
↓ 1 callers
Method
Reconcile
+kubebuilder:rbac:groups=climatik-project.io,resources=powercappingconfigs,verbs=get;list;watch;create;update;patch;delete +kubebuilder:rbac:groups=cl
internal/controller/powercappingconfig_controller.go:75
↓ 1 callers
Method
SetupWithManager
(mgr ctrl.Manager)
internal/controller/powercappingconfig_controller.go:92
↓ 1 callers
Function
UninstallCertManager
UninstallCertManager uninstalls the cert manager
test/utils/utils.go:79
↓ 1 callers
Function
UninstallPrometheusOperator
UninstallPrometheusOperator uninstalls the prometheus
test/utils/utils.go:70
↓ 1 callers
Method
UpdatePowerCappingConfig
(param, value string)
internal/webhook/handlers/slack_handler.go:234
↓ 1 callers
Method
calculatePowerCap
(peakPower float64, powerCapPercentage int)
internal/controller/powercappingconfig_controller.go:298
↓ 1 callers
Method
calculate_max_replicas
(self, current_replicas: Dict[str, int], power_consumptions: Dict[str, float],
python/climatik_operator/strategies/base_strategy.py:8
↓ 1 callers
Method
calculate_optimal_replicas
(self, deployment, power_cap)
python/planner/planner.py:24
↓ 1 callers
Method
createAlert
(pod *corev1.Pod, powerCap int, deviceLabels map[string]string)
internal/controller/powercappingconfig_controller.go:236
↓ 1 callers
Function
create_power_capping_config
(spec, **kwargs)
python/climatik_operator/operator.py:55
↓ 1 callers
Function
file_grpc_proto_init
()
internal/planner/grpc.pb.go:320
↓ 1 callers
Function
findRootDir
findRootDir tries to find the root directory of the project
internal/alert/tests/slack_notification_test.go:41
↓ 1 callers
Method
formatAlertMessage
(podName string, powerCapValue int, devices map[string]string)
internal/alert/adapters/git_ops.go:32
↓ 1 callers
Function
generate_synthetic_data
(start_time, end_time, step)
python/planner/mock_prometheus/mock_prometheus.py:12
↓ 1 callers
Function
getColorForAlertLevel
(level AlertLevel)
internal/alert/adapters/slack.go:113
↓ 1 callers
Function
getEnv
(key, fallback string)
internal/controller/powercappingconfig_controller.go:242
↓ 1 callers
Method
getKeplerMetrics
(ctx context.Context, podName, device string)
internal/controller/powercappingconfig_controller.go:146
↓ 1 callers
Method
getPodDevices
(pod *corev1.Pod)
internal/controller/powercappingconfig_controller.go:222
↓ 1 callers
Function
getPowerCapPercentage
(label string)
internal/controller/powercappingconfig_controller.go:302
↓ 1 callers
Function
get_power_capping_strategy
(strategy_name: str)
python/climatik_operator/strategies/__init__.py:6
↓ 1 callers
Function
get_power_consumption
(deployment_name, namespace)
python/climatik_operator/operator.py:226
↓ 1 callers
Method
handleBlockActions
(w http.ResponseWriter, payload *slack.InteractionCallback)
internal/webhook/handlers/slack_handler.go:107
↓ 1 callers
Method
handleModifyPowerConfig
(w http.ResponseWriter)
internal/webhook/handlers/slack_handler.go:199
↓ 1 callers
Method
handleParameterUpdate
(w http.ResponseWriter, payload *slack.InteractionCallback)
internal/webhook/handlers/slack_handler.go:171
↓ 1 callers
Method
handlePodAdd
(obj interface{})
internal/controller/powercappingconfig_controller.go:170
↓ 1 callers
Method
handleViewSubmission
(w http.ResponseWriter, payload *slack.InteractionCallback)
internal/webhook/handlers/slack_handler.go:119
↓ 1 callers
Function
list_pods_in_deployment
(namespace, deployment_name, debug=False)
python/climatik_operator/k8s_utils.py:11
↓ 1 callers
Method
openParameterInputModal
(w http.ResponseWriter, triggerID, parameter string)
internal/webhook/handlers/slack_handler.go:128
↓ 1 callers
Method
queryPodPeakPower
(ctx context.Context, podName, window string)
internal/controller/powercappingconfig_controller.go:275
↓ 1 callers
Method
sendWebhookAlert
(alert SlackAlert)
internal/alert/adapters/slack.go:79
↓ 1 callers
Function
serve
()
python/planner/planner.py:30
↓ 1 callers
Method
update_bpf_block_irq
(self, deployment, bpf_block_irq)
python/climatik_operator/prom_metrics.py:135
↓ 1 callers
Method
update_bpf_cpu_time_ms
(self, deployment, bpf_cpu_time_ms)
python/climatik_operator/prom_metrics.py:141
↓ 1 callers
Method
update_bpf_net_rx_irq
(self, deployment, bpf_net_rx_irq)
python/climatik_operator/prom_metrics.py:147
↓ 1 callers
Method
update_bpf_net_tx_irq
(self, deployment, bpf_net_tx_irq)
python/climatik_operator/prom_metrics.py:153
↓ 1 callers
Method
update_bpf_page_cache_hit
(self, deployment, bpf_page_cache_hit)
python/climatik_operator/prom_metrics.py:159
↓ 1 callers
Method
update_core_joules
(self, deployment, core_joules)
python/climatik_operator/prom_metrics.py:120
↓ 1 callers
Method
update_dram_joules
(self, deployment, dram_joules)
python/climatik_operator/prom_metrics.py:125
↓ 1 callers
Method
update_forecast_power_consumption
(self, deployment, forecast_power)
python/climatik_operator/prom_metrics.py:109
↓ 1 callers
Method
update_gpu_joules
(self, deployment, gpu_joules)
python/climatik_operator/prom_metrics.py:130
↓ 1 callers
Method
update_joules
(self, deployment, joules)
python/climatik_operator/prom_metrics.py:166
↓ 1 callers
Method
update_metrics
(self)
python/climatik_operator/prom_metrics.py:170
↓ 1 callers
Method
update_power_consumption
(self, deployment, power_consumption)
python/climatik_operator/prom_metrics.py:102
↓ 1 callers
Method
update_replicas
(self, deployment, count)
python/climatik_operator/prom_metrics.py:98
next →
1–100 of 210, ranked by callers