MCPcopy Create free account

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

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

⨍ Functions 1,276◇ Types & classes 154
↓ 1 callersMethodSetMemoryUsage
(uint64)
internal/control_plane/core/interface.go:60
↓ 1 callersMethodSetupHeartbeatLoop
(cfg *config.WorkerNodeConfig)
internal/worker_node/worker_node.go:213
↓ 1 callersFunctionSetupProfilerServer
(config config.ProfilerConfig)
pkg/profiler/profiler.go:34
↓ 1 callersFunctionStartFirecrackerVM
(networkManager *NetworkPoolManager, vmcs *VMControlStructure, vmDebugMode bool, snapshotMetadata *SnapshotMet
internal/worker_node/sandbox/firecracker/vm.go:70
↓ 1 callersMethodStartHAProxy
()
internal/data_plane/haproxy/manager.go:81
↓ 1 callersFunctionStartHTTPServer
()
workload/http_workload.go:175
↓ 1 callersMethodStartNodeMonitoring
Monitoring
internal/control_plane/control_plane.go:369
↓ 1 callersMethodStartNodeMonitoringLoop
()
api/control_plane_api_server.go:115
↓ 1 callersMethodStartProxyServer
()
internal/data_plane/proxy/proxy.go:30
↓ 1 callersFunctionStartServiceRegistrationServer
(cpApi *api.CpApiServer, registrationPort string)
internal/control_plane/registration_server/registration_server.go:219
↓ 1 callersMethodStop
()
internal/control_plane/autoscaling/controller.go:75
↓ 1 callersMethodStopAllScalingLoops
()
internal/control_plane/control_plane.go:505
↓ 1 callersFunctionStopFirecrackerVM
(vmcs *VMControlStructure)
internal/worker_node/sandbox/firecracker/vm.go:151
↓ 1 callersMethodStoreEndpoint
(ctx context.Context, endpoint core.Endpoint)
internal/control_plane/persistence/interface.go:44
↓ 1 callersFunctionSubtractResources
(a, b *ResourceMap)
internal/control_plane/placement_policy/resource_map.go:109
↓ 1 callersMethodSumAllResourceTypes
()
internal/control_plane/placement_policy/resource_map.go:73
↓ 1 callersMethodUpdateHeartBeat
()
internal/control_plane/core/interface.go:44
↓ 1 callersMethodUpdateLastHearBeat
()
internal/control_plane/core/interface.go:58
↓ 1 callersMethodUpdateLastHearBeat
()
internal/control_plane/workers/worker_node.go:124
↓ 1 callersMethodUpdateLeadership
(leadership leader_election.AnnounceLeadership)
cmd/master_node/state_management/election_management.go:66
↓ 1 callersMethodValidateHostConfig
()
internal/worker_node/sandbox/runtime_interface.go:37
↓ 1 callersMethodValues
()
pkg/atomic_map/atomic_map.go:95
↓ 1 callersMethodaddRegistrationServer
(ipAddress string, port int, transaction string, version int64)
internal/data_plane/haproxy/manager.go:190
↓ 1 callersMethodasyncRequestHandler
()
internal/data_plane/proxy/async_proxy_handler.go:202
↓ 1 callersFunctionbusySpin
(multiplier, runtimeMilli uint32)
workload/http_workload.go:57
↓ 1 callersMethodcleanCache
()
internal/data_plane/data_plane.go:145
↓ 1 callersFunctioncold_start_sweep
()
artifact_evaluation/plot_cold_start_sweep.py:113
↓ 1 callersMethodcreateAsyncInvocationHandler
()
internal/data_plane/proxy/async_proxy_handler.go:180
↓ 1 callersMethodcreateAsyncReadHandler
()
internal/data_plane/proxy/async_proxy_handler.go:349
↓ 1 callersMethodcreateInvocationHandler
TODO: Deduplicate code
internal/data_plane/proxy/sync_proxy_handler.go:103
↓ 1 callersFunctioncreateMetadata
(in *proto.ServiceInfo, vmcs *VMControlStructure)
internal/worker_node/sandbox/firecracker/runtime.go:113
↓ 1 callersFunctioncreateThrottlerChannel
(capacity uint)
internal/data_plane/function_metadata/function_metadata.go:165
↓ 1 callersMethodcreateVETHPair
(config *NetworkConfig, guestTAP string)
internal/worker_node/sandbox/firecracker/networking.go:210
↓ 1 callersMethodcreateVMCS
()
internal/worker_node/sandbox/firecracker/runtime.go:102
↓ 1 callersMethodcreateWorkerNodeFailureEvents
Fault detection
internal/control_plane/control_plane.go:433
↓ 1 callersFunctiondeleteLogs
(vmcs *VMControlStructure)
internal/worker_node/sandbox/firecracker/vm.go:161
↓ 1 callersFunctiondeleteSandbox
(key *core.Endpoint)
internal/control_plane/scaling_loop.go:308
↓ 1 callersFunctiondialBackOffHelper
(ctx context.Context, network, address string, bo wait.Backoff, tlsConf *tls.Config)
internal/data_plane/proxy/net/factory.go:52
↓ 1 callersFunctiondialConnection
(ctx context.Context, endpoint string, additionalOptions ...grpc.DialOption)
pkg/grpc_helpers/grpc_helpers.go:63
↓ 1 callersMethoddoUpscaling
(toCreateCount int, loopStarted time.Time)
internal/control_plane/scaling_loop.go:120
↓ 1 callersMethoddrainSandbox
(toEvict map[*core.Endpoint]struct{})
internal/control_plane/scaling_loop.go:275
↓ 1 callersMethodelectionTimeout
electionTimeout generates a pseudo-random election timeout duration.
internal/control_plane/leader_election/consensus_module.go:199
↓ 1 callersFunctionextractExitCode
(data *garlic.EventData)
internal/worker_node/managers/process_monitor.go:115
↓ 1 callersFunctionextractFourthField
(counterValue uint32)
internal/worker_node/managers/ip_manager.go:103
↓ 1 callersFunctionextractThirdField
(counterValue uint32)
internal/worker_node/managers/ip_manager.go:99
↓ 1 callersFunctionfile_control_plane_interface_proto_init
()
api/proto/control_plane_interface.pb.go:654
↓ 1 callersFunctionfile_data_plane_interface_proto_init
()
api/proto/data_plane_interface.pb.go:289
↓ 1 callersFunctionfile_worker_node_interface_proto_init
()
api/proto/worker_node_interface.pb.go:477
↓ 1 callersFunctionfilterMachines
(storage synchronization.SyncStructure[string, core.WorkerNodeInterface], resourceMap *ResourceMap)
internal/control_plane/placement_policy/k8s_placement.go:132
↓ 1 callersMethodfireRequest
TODO: Deduplicate code
internal/data_plane/proxy/async_proxy_handler.go:241
↓ 1 callersMethodforceResetHAProxy
()
internal/data_plane/haproxy/manager.go:111
↓ 1 callersFunctiongetConfigClient
()
internal/data_plane/haproxy/connection.go:34
↓ 1 callersFunctiongetInstalledResources
(machine core.WorkerNodeInterface)
internal/control_plane/placement_policy/k8s_placement.go:150
↓ 1 callersFunctiongetNumberNodes
(storage synchronization.SyncStructure[string, core.WorkerNodeInterface])
internal/control_plane/placement_policy/placement_policy.go:71
↓ 1 callersFunctiongetRegistrationPort
(cfg *config.ControlPlaneConfig)
cmd/master_node/main.go:133
↓ 1 callersFunctiongetRequestedResources
(machine core.WorkerNodeInterface, request *ResourceMap)
internal/control_plane/placement_policy/k8s_placement.go:154
↓ 1 callersFunctiongetRuntimeClient
(configClient *configuration.Client)
internal/data_plane/haproxy/connection.go:56
↓ 1 callersMethodgetServicesOnWorkerNode
(_ *ServiceInfoStorage, wn core.WorkerNodeInterface)
internal/control_plane/control_plane.go:453
↓ 1 callersFunctiongetTraces
(load, rootPath)
scripts/plotting/common.py:38
↓ 1 callersFunctiongetVMCommandBuild
(vmcs *VMControlStructure)
internal/worker_node/sandbox/firecracker/vm.go:55
↓ 1 callersMethodgetWorkerStatistics
()
internal/worker_node/worker_node.go:223
↓ 1 callersFunctionget_knative_data
()
artifact_evaluation/plot_cold_start_sweep.py:61
↓ 1 callersFunctionindex_result_files
(path)
artifact_evaluation/plot_cold_start_sweep.py:30
↓ 1 callersMethodinit
()
workload/http_workload.go:144
↓ 1 callersMethodinternalEventHandler
()
internal/worker_node/managers/process_monitor.go:89
↓ 1 callersMethodinternalScaleAlgorithm
(scalingMetric float64)
internal/control_plane/autoscaling/autoscaling.go:120
↓ 1 callersMethodisDownScalingDisabled
()
internal/control_plane/scaling_loop.go:396
↓ 1 callersFunctionisUserRoot
()
internal/worker_node/worker_node.go:64
↓ 1 callersFunctionkubernetesNativeLoadBalancing
(metadata *function_metadata.FunctionMetadata)
internal/data_plane/proxy/load_balancing/load_balancing.go:235
↓ 1 callersFunctionlatency
()
async/fire.go:156
↓ 1 callersMethodleaderSendHeartbeats
leaderSendHeartbeats sends a round of heartbeats to all peers, collects their replies and adjusts cm's state.
internal/control_plane/leader_election/consensus_module.go:370
↓ 1 callersFunctionleastRequestedScore
(requested, capacity uint64)
internal/control_plane/placement_policy/k8s_placement.go:55
↓ 1 callersFunctionmakeFirecrackerConfig
(vmcs *VMControlStructure, vmDebugMode bool, metadata *SnapshotMetadata)
internal/worker_node/sandbox/firecracker/iface.go:47
↓ 1 callersFunctionmakeSocketPath
(vmmID string)
internal/worker_node/sandbox/firecracker/iface.go:43
↓ 1 callersMethodmarkEndpointsAsDraining
(endpoints []*proto.EndpointInfo)
internal/data_plane/function_metadata/function_metadata.go:270
↓ 1 callersFunctionnoNodesInCluster
(storage synchronization.SyncStructure[string, core.WorkerNodeInterface])
internal/control_plane/placement_policy/placement_policy.go:75
↓ 1 callersMethodparseLoadBalancingPolicy
(dataPlaneConfig config.DataPlaneConfig)
internal/data_plane/data_plane.go:203
↓ 1 callersMethodpersistServerMetadata
(name string, ipAddress string, port int, transaction string, version int64)
internal/data_plane/haproxy/manager.go:214
↓ 1 callersFunctionplot_function_scheduling_latency
()
artifact_evaluation/plot_azure_500.py:118
↓ 1 callersFunctionplot_per_function_slowdown
()
artifact_evaluation/plot_azure_500.py:89
↓ 1 callersMethodprecreateSnapshots
(info *proto.ServiceInfo)
internal/control_plane/control_plane.go:470
↓ 1 callersMethodprepareCurrentEndpointInfoList
()
internal/control_plane/scaling_loop.go:383
↓ 1 callersFunctionprioritizeNodes
(storage synchronization.SyncStructure[string, core.WorkerNodeInterface], request *ResourceMap)
internal/control_plane/placement_policy/k8s_placement.go:159
↓ 1 callersFunctionprocessQuantile
(d, percentile)
scripts/plotting/common.py:28
↓ 1 callersMethodreconstructControlPlaneState
()
cmd/master_node/state_management/election_management.go:90
↓ 1 callersMethodreconstructDataplaneState
Single threaded function - reconstruction happened before starting the control plane
internal/control_plane/reconstruction.go:96
↓ 1 callersMethodreconstructEndpointsState
Single threaded function - reconstruction happens before starting the control plane
internal/control_plane/reconstruction.go:175
↓ 1 callersMethodreconstructServiceState
Single threaded function - reconstruction happened before starting the control plane
internal/control_plane/reconstruction.go:145
↓ 1 callersMethodreconstructWorkersState
Single threaded function - reconstruction happens before starting the control plane
internal/control_plane/reconstruction.go:114
↓ 1 callersFunctionregistrationHandler
(cpApi *api.CpApiServer)
internal/control_plane/registration_server/registration_server.go:39
↓ 1 callersMethodremoveEndointsAssociatedWithNode
(nodeID string)
internal/control_plane/helpers.go:89
↓ 1 callersMethodremoveEndpoints
(endpoints []*proto.EndpointInfo)
internal/data_plane/function_metadata/function_metadata.go:253
↓ 1 callersMethodremoveEndpoints
(ss *ServiceInfoStorage, dpConns synchronization.SyncStructure[string, core.DataPlaneInterface], endpoints []s
internal/control_plane/failure.go:53
↓ 1 callersMethodremoveRegistrationServers
(transaction string)
internal/data_plane/haproxy/manager.go:248
↓ 1 callersMethodremoveServiceFromDataplane
(ctx context.Context, serviceInfo *proto.ServiceInfo)
internal/control_plane/helpers.go:76
↓ 1 callersFunctionresetIPTables
()
cmd/worker_node/main.go:96
↓ 1 callersFunctionrunLoadBalancingAlgorithm
(metadata *function_metadata.FunctionMetadata, loadBalancingPolicy LoadBalancingPolicy)
internal/data_plane/proxy/load_balancing/load_balancing.go:46
↓ 1 callersFunctionselectOneMachine
(storage synchronization.SyncStructure[string, core.WorkerNodeInterface], scores map[string]uint64)
internal/control_plane/placement_policy/k8s_placement.go:179
↓ 1 callersMethodsendHeartbeatLoop
(cfg *config.WorkerNodeConfig)
internal/worker_node/worker_node.go:233
↓ 1 callersMethodsendHeartbeatLoop
(proxy proxy.Proxy)
internal/data_plane/data_plane.go:81
← previousnext →401–500 of 1,276, ranked by callers