Functions — github.com/Climatik-Project/Climatik-Project

hub / github.com/Climatik-Project/Climatik-Project / functions

Functions210 in github.com/Climatik-Project/Climatik-Project

⨍ Functions 210◇ Types & classes 61 ↳ Endpoints 5

↓ 1 callersMethodupdate_scale_objects

(self, count)

python/climatik_operator/prom_metrics.py:94

↓ 1 callersMethodwatchPodPowerUsage

(ctx context.Context, podName string, window time.Duration)

internal/controller/powercappingconfig_controller.go:250

FunctionAlertHandler

Make sure this interface is defined in the factory package and imported here

internal/webhook/webhook.go:14

MethodCalculateOptimalReplicas

(self, request, context)

python/planner/planner.py:9

MethodCalculateOptimalReplicas

Missing associated documentation comment in .proto file.

python/planner/grpc_pb2_grpc.py:29

MethodCalculateOptimalReplicas

(request, target, options=(),

python/planner/grpc_pb2_grpc.py:57

MethodCalculateOptimalReplicas

(ctx context.Context, in *CalculateOptimalReplicasRequest, opts ...grpc.CallOption)

internal/planner/grpc_grpc.pb.go:36

MethodCalculateOptimalReplicas

(context.Context, *CalculateOptimalReplicasRequest)

internal/planner/grpc_grpc.pb.go:49

MethodCalculateOptimalReplicas

(context.Context, *CalculateOptimalReplicasRequest)

internal/planner/grpc_grpc.pb.go:57

MethodCommit

(repoDir, message string)

internal/alert/tests/alert_test.go:58

MethodCreateAlert

(podName string, powerCapValue int, devices map[string]string, config *v1alpha1.PowerCappingConfig)

internal/alert/tests/alert_test.go:240

MethodDeepCopy

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new AbsolutePowerCapInWattsSpec.

api/v1alpha1/zz_generated.deepcopy.go:33

MethodDeepCopy

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new AbsoluteTemperatureThresholdInCelsiusSpec.

api/v1alpha1/zz_generated.deepcopy.go:48

MethodDeepCopy

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new PowerCappingConfigSpec.

api/v1alpha1/zz_generated.deepcopy.go:124

MethodDeepCopy

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new PowerCappingConfigStatus.

api/v1alpha1/zz_generated.deepcopy.go:139

MethodDeepCopy

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new PowerCappingSpec.

api/v1alpha1/zz_generated.deepcopy.go:156

MethodDeepCopy

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new RelativePowerCapInPercentageSpec.

api/v1alpha1/zz_generated.deepcopy.go:171

MethodDeepCopy

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new RelativeTemperatureThresholdInPercentageSpec.

api/v1alpha1/zz_generated.deepcopy.go:186

MethodDeepCopy

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new TemperatureThresholdSpec.

api/v1alpha1/zz_generated.deepcopy.go:203

MethodDeepCopyObject

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

api/v1alpha1/zz_generated.deepcopy.go:77

MethodDeepCopyObject

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

api/v1alpha1/zz_generated.deepcopy.go:109

MethodDescriptor

Deprecated: Use CalculateOptimalReplicasRequest.ProtoReflect.Descriptor instead.

internal/planner/grpc.pb.go:60

MethodDescriptor

Deprecated: Use Deployment.ProtoReflect.Descriptor instead.

internal/planner/grpc.pb.go:115

MethodDescriptor

Deprecated: Use CalculateOptimalReplicasResponse.ProtoReflect.Descriptor instead.

internal/planner/grpc.pb.go:169

MethodDescriptor

Deprecated: Use DeploymentReplicas.ProtoReflect.Descriptor instead.

internal/planner/grpc.pb.go:218

MethodGetDeploymentReplicas

()

internal/planner/grpc.pb.go:173

MethodGetDeployments

()

internal/planner/grpc.pb.go:64

MethodGetHandler

(source string, runner runners.Runner)

internal/webhook/interfaces/interfaces.go:11

MethodGetName

()

internal/planner/grpc.pb.go:119

MethodGetName

()

internal/planner/grpc.pb.go:222

MethodGetNamespace

()

internal/planner/grpc.pb.go:126

MethodGetNamespace

()

internal/planner/grpc.pb.go:229

MethodGetOptimalReplicas

()

internal/planner/grpc.pb.go:236

MethodGetPowerCap

()

internal/planner/grpc.pb.go:71

MethodGetRunner

(runnerType string, path string)

internal/webhook/runners/factory.go:7

MethodHandleAlert

(body []byte)

internal/webhook/factory/factory.go:10

MethodHandleAlert

(body []byte)

internal/webhook/handlers/slack_handler.go:24

MethodHandleAlert

(payload []byte)

internal/webhook/handlers/alert_handler.go:5

MethodHandleAlert

(payload []byte)

internal/webhook/handlers/prometheus_handler.go:14

MethodHandleAlert

(payload []byte)

internal/webhook/handlers/gitops_handler.go:14

FunctionNewPlannerClient

(cc grpc.ClientConnInterface)

internal/planner/grpc_grpc.pb.go:32

MethodProtoMessage

()

internal/planner/grpc.pb.go:45

MethodProtoMessage

()

internal/planner/grpc.pb.go:100

MethodProtoMessage

()

internal/planner/grpc.pb.go:154

MethodProtoMessage

()

internal/planner/grpc.pb.go:203

MethodProtoReflect

()

internal/planner/grpc.pb.go:47

MethodProtoReflect

()

internal/planner/grpc.pb.go:102

MethodProtoReflect

()

internal/planner/grpc.pb.go:156

MethodProtoReflect

()

internal/planner/grpc.pb.go:205

MethodPush

(repoDir, remote, branch string)

internal/alert/tests/alert_test.go:63

MethodQuery

Implement all methods of v1.API interface. Here's an example for the Query method:

internal/alert/tests/alert_test.go:43

FunctionRegisterPlannerServer

(s grpc.ServiceRegistrar, srv PlannerServer)

internal/planner/grpc_grpc.pb.go:69

MethodReset

()

internal/planner/grpc.pb.go:32

MethodReset

()

internal/planner/grpc.pb.go:87

MethodReset

()

internal/planner/grpc.pb.go:141

MethodReset

()

internal/planner/grpc.pb.go:190

MethodRun

()

internal/webhook/runners/kubernetes_runner.go:28

MethodRun

()

internal/webhook/runners/ansible_runner.go:12

MethodString

()

internal/planner/grpc.pb.go:41

MethodString

()

internal/planner/grpc.pb.go:150

MethodString

()

internal/planner/grpc.pb.go:199

FunctionTestAlertHandlerFactory

(t *testing.T)

internal/webhook/tests/slack_webhook_test.go:115

FunctionTestAlertService

TestAlertService tests the AlertService

internal/alert/tests/alert_test.go:205

FunctionTestControllers

(t *testing.T)

internal/controller/suite_test.go:46

FunctionTestCreateAlert

(t *testing.T)

internal/alert/tests/alert_test.go:114

FunctionTestCreateAlertError

(t *testing.T)

internal/alert/tests/alert_test.go:145

FunctionTestCreateSlackWebhook

(t *testing.T)

internal/webhook/tests/slack_webhook_test.go:17

FunctionTestE2E

Run e2e tests using the Ginkgo runner.

test/e2e/e2e_suite_test.go:28

FunctionTestFormatPrometheusAlert

(t *testing.T)

internal/alert/tests/alert_test.go:101

FunctionTestGitOpsAlertManager

TestGitOpsAlertManager tests the GitOpsAlertManager

internal/alert/tests/alert_test.go:183

FunctionTestNewPrometheusAlertManager

TestPrometheusAlertManager tests the PrometheusAlertManager

internal/alert/tests/alert_test.go:93

FunctionTestSendAlertToPrometheus

(t *testing.T)

internal/alert/tests/alert_test.go:162

FunctionTestSlackAlertActualNotification

(t *testing.T)

internal/alert/tests/slack_notification_test.go:14

FunctionTestSlackAlertManagerMocked

(t *testing.T)

internal/alert/tests/alert_test.go:68

FunctionTestSlackHandlerCommandHandler

(t *testing.T)

internal/webhook/tests/slack_webhook_test.go:50

FunctionTestSlackHandlerInteractionHandler

(t *testing.T)

internal/webhook/tests/slack_webhook_test.go:79

MethodUpdateMessage

(channelID, timestamp string, options ...slack.MsgOption)

internal/alert/tests/alert_test.go:33

MethodUpdatePowerCappingConfig

(param, value string)

internal/webhook/interfaces/interfaces.go:7

Function_Planner_CalculateOptimalReplicas_Handler

(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor)

internal/planner/grpc_grpc.pb.go:73

Method__init__

Constructor. Args: channel: A grpc.Channel.

python/planner/grpc_pb2_grpc.py:11

Method__init__

(self, port=9092, url="http://localhost:9090")

python/climatik_operator/prom_metrics.py:21

Functionadd_PlannerServicer_to_server

(servicer, server)

python/planner/grpc_pb2_grpc.py:36

Methodcalculate_max_replicas

(self, current_replicas: Dict[str, int], power_consumptions: Dict[str, float],

python/climatik_operator/strategies/prioritize_high_replica.py:8

Methodcalculate_max_replicas

(self, current_replicas: Dict[str, int], power_consumptions: Dict[str, float],

python/climatik_operator/strategies/maximize_replicas.py:8

FunctiongetFieldsForDevices

(devices map[string]string)

internal/alert/adapters/slack.go:126

Functionget_current_replica_from_scale_object

(api_instance, namespace, scale_object)

python/climatik_operator/operator.py:218

MethodhandlePodDelete

(obj interface{})

internal/controller/powercappingconfig_controller.go:218

Functioninit

()

internal/planner/grpc.pb.go:319

Functioninit

()

internal/webhook/slack_webhook.go:17

Functioninit

()

cmd/controller/main.go:48

Functioninit

()

api/v1alpha1/powercappingconfig_types.go:115

Functionlist_resource_requests_in_deployments

(namespace, resource_name='nvidia.com/gpu',

python/climatik_operator/k8s_utils.py:40

Functionmain

()

test/webhook/slack.go:12

Functionmain

()

internal/webhook/slack_webhook.go:41

Functionmain

()

cmd/controller/main.go:55

Functionmain

()

cmd/webhook/main.go:7

MethodmustEmbedUnimplementedPlannerServer

()

internal/planner/grpc_grpc.pb.go:50

MethodmustEmbedUnimplementedPlannerServer

()

internal/planner/grpc_grpc.pb.go:60

MethodmustEmbedUnimplementedPlannerServer

()

internal/planner/grpc_grpc.pb.go:66

Functionquery

()

python/planner/mock_prometheus/mock_prometheus.py:25

← previous next →101–200 of 210, ranked by callers