Functions — github.com/eth-easl/dirigent

hub / github.com/eth-easl/dirigent / functions

Functions1,276 in github.com/eth-easl/dirigent

⨍ Functions 1,276◇ Types & classes 154

↓ 1 callersMethodsendMetricsToAutoscaler

(cp proto.CpiInterfaceClient)

internal/data_plane/function_metadata/function_metadata.go:373

↓ 1 callersMethodstartGarbageCollector

()

internal/data_plane/proxy/async_proxy_handler.go:367

↓ 1 callersMethodstartLeader

startLeader switches cm into a leader state and begins process of heartbeats. Expects cm.mu to be locked.

internal/control_plane/leader_election/consensus_module.go:341

↓ 1 callersMethodsyncDeploymentCache

(cpApi *proto.CpiInterfaceClient, deployments *function_metadata.Deployments)

internal/data_plane/data_plane.go:219

↓ 1 callersFunctiontakeSqrts

()

workload/http_workload.go:49

↓ 1 callersFunctiontp

()

async/fire.go:163

↓ 1 callersMethodtriggerAutoscaling

(cp proto.CpiInterfaceClient)

internal/data_plane/function_metadata/function_metadata.go:356

↓ 1 callersFunctionwaitForCapacityOrDie

(throttler function_metadata.RequestThrottler)

internal/data_plane/proxy/load_balancing/load_balancing.go:113

↓ 1 callersMethodwaitForDrainingToComplete

(barriers []chan struct{})

internal/data_plane/function_metadata/function_metadata.go:305

↓ 1 callersMethodwindowAverage

(observedStableValue float64)

internal/control_plane/autoscaling/autoscaling.go:204

↓ 1 callersFunctionwrite_utilization_to_csv

()

cmd/monitoring/monitoring.py:27

MethodAddDeployment

(in *proto.ServiceInfo)

internal/data_plane/data_plane.go:125

MethodAddDeployment

(name string, dataplaneID string)

internal/data_plane/function_metadata/deployment.go:45

MethodAddDeployment

(ctx context.Context, in *proto.ServiceInfo)

internal/control_plane/data_plane/data_plane.go:67

MethodAddDeployment

(ctx context.Context, info *proto.ServiceInfo)

internal/control_plane/data_plane/empty_dataplane/empty_dataplane.go:45

MethodAddDeployment

(_ context.Context, in *proto.ServiceInfo)

api/data_plane_api_server.go:49

MethodAddDeployment

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

api/proto/data_plane_interface_grpc.pb.go:37

MethodAddDeployment

(context.Context, *ServiceInfo)

api/proto/data_plane_interface_grpc.pb.go:86

MethodAddDeployment

(context.Context, *ServiceInfo)

api/proto/data_plane_interface_grpc.pb.go:98

MethodAddDeployment

AddDeployment mocks base method.

mock/mock_core/mock_core.go:48

MethodAddDeployment

AddDeployment indicates an expected call of AddDeployment.

mock/mock_core/mock_core.go:57

MethodAppendEntries

(args *proto.AppendEntriesArgs)

internal/control_plane/leader_election/server.go:176

MethodAppendEntries

(args *proto.AppendEntriesArgs)

internal/control_plane/leader_election/consensus_module.go:160

MethodAppendEntries

(_ context.Context, args *proto.AppendEntriesArgs)

api/control_plane_api_server.go:320

MethodAppendEntries

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

api/proto/control_plane_interface_grpc.pb.go:156

MethodAppendEntries

(context.Context, *AppendEntriesArgs)

api/proto/control_plane_interface_grpc.pb.go:191

MethodAppendEntries

(context.Context, *AppendEntriesArgs)

api/proto/control_plane_interface_grpc.pb.go:237

MethodAppendEntries

AppendEntries mocks base method.

mock/mock_cp_api/mock_cp_api.go:45

MethodAppendEntries

AppendEntries indicates an expected call of AppendEntries.

mock/mock_cp_api/mock_cp_api.go:58

MethodAppendEntries

AppendEntries mocks base method.

mock/mock_cp_api/mock_cp_api.go:348

MethodAppendEntries

AppendEntries indicates an expected call of AppendEntries.

mock/mock_cp_api/mock_cp_api.go:357

FunctionApplyPlacementPolicy

(placementPolicy PlacementPolicy, storage synchronization.SyncStructure[string, core.WorkerNodeInterface], req

internal/control_plane/placement_policy/placement_policy.go:60

MethodAtomicGet

(key K)

pkg/synchronization/control_plane_sync.go:118

MethodAtomicGetNoCheck

(key K)

pkg/synchronization/control_plane_sync.go:125

MethodAtomicLen

()

pkg/synchronization/control_plane_sync.go:143

MethodAtomicRemove

(key K)

pkg/synchronization/control_plane_sync.go:132

MethodAtomicSet

(key K, value V)

pkg/synchronization/control_plane_sync.go:111

MethodCheckPeriodicallyDataplanes

()

internal/control_plane/control_plane.go:407

MethodConnectToWorker

()

internal/control_plane/workers/worker_node.go:111

MethodConnectToWorker

()

internal/control_plane/workers/empty_worker/empty_worker.go:59

MethodConnectToWorker

ConnectToWorker mocks base method.

mock/mock_core/mock_core.go:228

MethodConnectToWorker

ConnectToWorker indicates an expected call of ConnectToWorker.

mock/mock_core/mock_core.go:236

FunctionCreateEmptyRequestPersistence

()

internal/data_plane/proxy/persistence/empty_persistence.go:36

FunctionCreateRequestRedisClient

(ctx context.Context, redisLogin config.RedisConf)

internal/data_plane/proxy/persistence/redis_persistence.go:47

MethodCreateSandbox

(ctx context.Context, serviceInfo *proto.ServiceInfo)

internal/worker_node/sandbox/runtime_interface.go:34

MethodCreateSandbox

(ctx context.Context, in *proto.ServiceInfo)

internal/worker_node/sandbox/firecracker/runtime.go:128

MethodCreateSandbox

(grpcCtx context.Context, in *proto.ServiceInfo)

internal/worker_node/sandbox/containerd/runtime.go:102

MethodCreateSandbox

(_ context.Context, in *proto.ServiceInfo)

internal/worker_node/sandbox/fake_snapshot/runtime.go:47

MethodCreateSandbox

(ctx context.Context, info *proto.ServiceInfo, option ...grpc.CallOption)

internal/control_plane/workers/worker_node.go:95

MethodCreateSandbox

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

internal/control_plane/workers/empty_worker/empty_interface_client.go:41

MethodCreateSandbox

(ctx context.Context, info *proto.ServiceInfo, option ...grpc.CallOption)

internal/control_plane/workers/empty_worker/empty_worker.go:63

MethodCreateSandbox

(grpcCtx context.Context, in *proto.ServiceInfo)

api/worker_node_api_server.go:46

MethodCreateSandbox

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

api/proto/worker_node_interface_grpc.pb.go:35

MethodCreateSandbox

(context.Context, *ServiceInfo)

api/proto/worker_node_interface_grpc.pb.go:66

MethodCreateSandbox

(context.Context, *ServiceInfo)

api/proto/worker_node_interface_grpc.pb.go:76

MethodCreateSandbox

CreateSandbox mocks base method.

mock/mock_core/mock_core.go:242

MethodCreateSandbox

CreateSandbox indicates an expected call of CreateSandbox.

mock/mock_core/mock_core.go:255

MethodDeleteBufferedRequest

(ctx context.Context, code string)

internal/data_plane/proxy/persistence/empty_persistence.go:56

MethodDeleteBufferedRequest

(ctx context.Context, code string)

internal/data_plane/proxy/persistence/redis_persistence.go:145

MethodDeleteDataPlaneInformation

(_ context.Context, _ *proto.DataplaneInformation)

internal/control_plane/persistence/empty_persistence.go:43

MethodDeleteDataPlaneInformation

(ctx context.Context, dataplaneInfo *proto.DataplaneInformation)

internal/control_plane/persistence/redis_persistence.go:102

MethodDeleteDataPlaneInformation

DeleteDataPlaneInformation mocks base method.

mock/mock_persistence/mock_persistence.go:44

MethodDeleteDataPlaneInformation

DeleteDataPlaneInformation indicates an expected call of DeleteDataPlaneInformation.

mock/mock_persistence/mock_persistence.go:52

MethodDeleteDeployment

(name *proto.ServiceInfo)

internal/data_plane/data_plane.go:155

MethodDeleteDeployment

(name string)

internal/data_plane/function_metadata/deployment.go:75

MethodDeleteDeployment

(ctx context.Context, in *proto.ServiceInfo)

internal/control_plane/data_plane/data_plane.go:75

MethodDeleteDeployment

(ctx context.Context, info *proto.ServiceInfo)

internal/control_plane/data_plane/empty_dataplane/empty_dataplane.go:59

MethodDeleteDeployment

(_ context.Context, name *proto.ServiceInfo)

api/data_plane_api_server.go:57

MethodDeleteDeployment

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

api/proto/data_plane_interface_grpc.pb.go:46

MethodDeleteDeployment

(context.Context, *ServiceInfo)

api/proto/data_plane_interface_grpc.pb.go:87

MethodDeleteDeployment

(context.Context, *ServiceInfo)

api/proto/data_plane_interface_grpc.pb.go:101

MethodDeleteDeployment

DeleteDeployment mocks base method.

mock/mock_core/mock_core.go:63

MethodDeleteDeployment

DeleteDeployment indicates an expected call of DeleteDeployment.

mock/mock_core/mock_core.go:72

MethodDeleteSandbox

(grpcCtx context.Context, in *proto.SandboxID)

internal/worker_node/sandbox/containerd/runtime.go:183

MethodDeleteSandbox

(_ context.Context, _ *proto.SandboxID)

internal/worker_node/sandbox/fake_snapshot/runtime.go:77

MethodDeleteSandbox

(ctx context.Context, id *proto.SandboxID, option ...grpc.CallOption)

internal/control_plane/workers/worker_node.go:99

MethodDeleteSandbox

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

internal/control_plane/workers/empty_worker/empty_interface_client.go:47

MethodDeleteSandbox

(ctx context.Context, id *proto.SandboxID, option ...grpc.CallOption)

internal/control_plane/workers/empty_worker/empty_worker.go:85

MethodDeleteSandbox

(grpcCtx context.Context, in *proto.SandboxID)

api/worker_node_api_server.go:50

MethodDeleteSandbox

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

api/proto/worker_node_interface_grpc.pb.go:44

MethodDeleteSandbox

(context.Context, *SandboxID)

api/proto/worker_node_interface_grpc.pb.go:67

MethodDeleteSandbox

(context.Context, *SandboxID)

api/proto/worker_node_interface_grpc.pb.go:79

MethodDeleteSandbox

DeleteSandbox mocks base method.

mock/mock_core/mock_core.go:262

MethodDeleteSandbox

DeleteSandbox indicates an expected call of DeleteSandbox.

mock/mock_core/mock_core.go:275

MethodDeleteServiceInformation

(_ context.Context, _ *proto.ServiceInfo)

internal/control_plane/persistence/empty_persistence.go:67

MethodDeleteServiceInformation

(ctx context.Context, serviceInfo *proto.ServiceInfo)

internal/control_plane/persistence/redis_persistence.go:226

MethodDeleteServiceInformation

DeleteServiceInformation mocks base method.

mock/mock_persistence/mock_persistence.go:58

MethodDeleteServiceInformation

DeleteServiceInformation indicates an expected call of DeleteServiceInformation.

mock/mock_persistence/mock_persistence.go:66

MethodDeleteWorkerNodeInformation

(_ context.Context, _ string)

internal/control_plane/persistence/empty_persistence.go:55

MethodDeleteWorkerNodeInformation

(ctx context.Context, name string)

internal/control_plane/persistence/redis_persistence.go:164

MethodDeleteWorkerNodeInformation

DeleteWorkerNodeInformation mocks base method.

mock/mock_persistence/mock_persistence.go:72

MethodDeleteWorkerNodeInformation

DeleteWorkerNodeInformation indicates an expected call of DeleteWorkerNodeInformation.

mock/mock_persistence/mock_persistence.go:80

MethodDeregisterDataplane

(ctx context.Context, in *proto.DataplaneInfo)

api/control_plane_api_server.go:253

MethodDeregisterDataplane

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

api/proto/control_plane_interface_grpc.pb.go:111

MethodDeregisterDataplane

(context.Context, *DataplaneInfo)

api/proto/control_plane_interface_grpc.pb.go:185

MethodDeregisterDataplane

(context.Context, *DataplaneInfo)

api/proto/control_plane_interface_grpc.pb.go:222

MethodDeregisterDataplane

DeregisterDataplane mocks base method.

mock/mock_cp_api/mock_cp_api.go:65

MethodDeregisterDataplane

DeregisterDataplane indicates an expected call of DeregisterDataplane.

mock/mock_cp_api/mock_cp_api.go:78

MethodDeregisterDataplane

DeregisterDataplane mocks base method.

mock/mock_cp_api/mock_cp_api.go:363

MethodDeregisterDataplane

DeregisterDataplane indicates an expected call of DeregisterDataplane.

mock/mock_cp_api/mock_cp_api.go:372

← previous next →501–600 of 1,276, ranked by callers