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
↓ 2 callersMethodGetApiPort
()
internal/control_plane/core/interface.go:46
↓ 2 callersMethodGetLastHeartBeat
()
internal/control_plane/core/interface.go:43
↓ 2 callersMethodGetLeaderID
()
internal/control_plane/leader_election/consensus_module.go:191
↓ 2 callersMethodGetLoadBalancerAddress
()
internal/data_plane/haproxy/manager.go:120
↓ 2 callersFunctionGetLocalIP
()
pkg/network/ip.go:32
↓ 2 callersMethodGetLocalQueueLength
(endpoint *UpstreamEndpoint)
internal/data_plane/function_metadata/function_metadata.go:161
↓ 2 callersMethodGetMap
()
pkg/synchronization/control_plane_sync.go:84
↓ 2 callersFunctionGetMemory
()
pkg/hardware/hardware.go:45
↓ 2 callersFunctionGetNumberCpus
()
pkg/hardware/hardware.go:41
↓ 2 callersMethodGetPeers
()
internal/control_plane/leader_election/server.go:210
↓ 2 callersMethodGetRequestCountPerInstance
()
internal/data_plane/function_metadata/function_metadata.go:153
↓ 2 callersMethodGetSchedulability
()
internal/control_plane/core/interface.go:69
↓ 2 callersMethodGetService
()
api/proto/common.pb.go:386
↓ 2 callersFunctionGetServiceName
(r *http.Request)
internal/data_plane/proxy/utils.go:33
↓ 2 callersMethodGetUnsafe
(key K)
pkg/atomic_map/atomic_map.go:61
↓ 2 callersMethodGetValues
Not thread safe
pkg/synchronization/control_plane_sync.go:40
↓ 2 callersMethodHAProxyReconstructionCallback
(config *config.ControlPlaneConfig, reviseDataplanes ReviseDataplanesInLBCall)
internal/data_plane/haproxy/manager.go:401
↓ 2 callersMethodHandleFailure
(failures []*proto.Failure)
internal/control_plane/failure.go:35
↓ 2 callersMethodIncrementKubernetesRoundRobinCounter
()
internal/data_plane/function_metadata/function_metadata.go:149
↓ 2 callersMethodIncrementQueueDepth
()
internal/data_plane/function_metadata/statistics.go:62
↓ 2 callersMethodIncrementSuccessfulInvocations
()
internal/data_plane/function_metadata/statistics.go:42
↓ 2 callersFunctionIsRoot
()
pkg/utils/utils.go:48
↓ 2 callersMethodKeyValues
()
pkg/atomic_map/atomic_map.go:112
↓ 2 callersFunctionKeys
(m M)
pkg/map/maps.go:27
↓ 2 callersMethodListDeployments
()
internal/data_plane/function_metadata/deployment.go:89
↓ 2 callersMethodListEndpoints
(ctx context.Context, _ *emptypb.Empty)
internal/worker_node/sandbox/runtime_interface.go:36
↓ 2 callersMethodListRegistrationServers
()
internal/data_plane/haproxy/manager.go:128
↓ 2 callersFunctionNewContainerdImageManager
()
internal/worker_node/sandbox/containerd/image_manager.go:39
↓ 2 callersFunctionNewFunctionMetadata
(name string, dataplaneID string)
internal/data_plane/function_metadata/function_metadata.go:103
↓ 2 callersFunctionNewIPManager
(networkPrefix string)
internal/worker_node/managers/ip_manager.go:38
↓ 2 callersFunctionNewIptablesUtil
()
internal/worker_node/managers/iptables_manager.go:37
↓ 2 callersFunctionNewMockCpiInterfaceClient
NewMockCpiInterfaceClient creates a new mock instance.
mock/mock_cp_api/mock_cp_api.go:33
↓ 2 callersFunctionNewProxyTracingService
(outputFile string)
pkg/tracing/tracing.go:118
↓ 2 callersFunctionNewRoundRobinPlacement
()
internal/control_plane/placement_policy/round_robin.go:37
↓ 2 callersFunctionNewThreadSafeRandomGenerator
()
internal/worker_node/managers/thread_safe_random.go:38
↓ 2 callersMethodNext
()
internal/worker_node/managers/exponential_backoff.go:42
↓ 2 callersMethodPlace
(synchronization.SyncStructure[string, core.WorkerNodeInterface], *ResourceMap)
internal/control_plane/placement_policy/placement_policy.go:35
↓ 2 callersMethodRegisterNodeWithControlPlane
(config config.WorkerNodeConfig, cpApi *proto.CpiInterfaceClient)
internal/worker_node/worker_node.go:130
↓ 2 callersMethodResetMeasurements
(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption)
api/proto/control_plane_interface_grpc.pb.go:32
↓ 2 callersMethodReviseDataplanes
ReviseDataplanes Need to call restart after this call
internal/data_plane/haproxy/manager.go:353
↓ 2 callersFunctionScoreBalancedAllocation
(installed ResourceMap, requested ResourceMap)
internal/control_plane/placement_policy/k8s_placement.go:92
↓ 2 callersFunctionScoreFitLeastAllocated
(installed ResourceMap, requested ResourceMap)
internal/control_plane/placement_policy/k8s_placement.go:68
↓ 2 callersMethodSetMemory
(v uint64)
internal/control_plane/placement_policy/resource_map.go:50
↓ 2 callersMethodTryWarmStart
(cp proto.CpiInterfaceClient)
internal/data_plane/function_metadata/function_metadata.go:332
↓ 2 callersFunctionValues
(m M)
pkg/map/maps.go:37
↓ 2 callersFunctionWaitTerminationSignal
(cleanFunction func())
pkg/utils/utils.go:36
↓ 2 callersMethodaddServer
(ipAddress string, port int, transaction string, version int64)
internal/data_plane/haproxy/manager.go:174
↓ 2 callersMethodaddToEndpointList
(data []*proto.EndpointInfo)
internal/data_plane/function_metadata/function_metadata.go:185
↓ 2 callersFunctionbestOfTwoRandoms
(metadata *function_metadata.FunctionMetadata)
internal/data_plane/proxy/load_balancing/load_balancing.go:175
↓ 2 callersFunctioncontextTerminationHandler
(r *http.Request, coldStartChannel chan common.ColdStartChannelStruct)
internal/data_plane/proxy/utils.go:49
↓ 2 callersMethodcreateNetwork
()
internal/worker_node/sandbox/firecracker/networking.go:153
↓ 2 callersMethoddestroyStateFromPreviousElectionTerm
()
cmd/master_node/state_management/election_management.go:82
↓ 2 callersMethoddoDownscaling
(actualScale, desiredCount int)
internal/control_plane/scaling_loop.go:220
↓ 2 callersFunctionfile_raft_proto_init
()
api/proto/raft.pb.go:319
↓ 2 callersFunctiongenerateTwoUniformRandomEndpoints
(endpoints []*function_metadata.UpstreamEndpoint)
internal/data_plane/proxy/load_balancing/load_balancing.go:160
↓ 2 callersMethodgenericRevise
(backend string, addressesToKeep []string)
internal/data_plane/haproxy/manager.go:263
↓ 2 callersFunctiongetScalingChannel
()
internal/control_plane/autoscaling/controller_test.go:34
↓ 2 callersFunctiongetSchedulableNodes
(allNodes []core.WorkerNodeInterface)
internal/control_plane/placement_policy/placement_policy.go:38
↓ 2 callersFunctiongetServiceInfo
()
internal/control_plane/autoscaling/controller_test.go:38
↓ 2 callersMethodgetUniqueCounterValue
()
internal/worker_node/managers/ip_manager.go:45
↓ 2 callersFunctionget_dirigent_data
(technology)
artifact_evaluation/plot_cold_start_sweep.py:95
↓ 2 callersFunctionget_per_function
(path)
artifact_evaluation/plot_azure_500.py:127
↓ 2 callersFunctionget_per_invocation
(path)
artifact_evaluation/plot_azure_500.py:119
↓ 2 callersFunctionget_processing_list
(path)
artifact_evaluation/plot_cold_start_sweep.py:38
↓ 2 callersFunctiongiveBackCCCapacity
(endpoint *common.UpstreamEndpoint)
internal/data_plane/proxy/utils.go:38
↓ 2 callersFunctionhandleBodyClosing
(response *http.Response)
internal/worker_node/managers/readiness_probes.go:136
↓ 2 callersMethodlistServers
(backend string)
internal/data_plane/haproxy/manager.go:132
↓ 2 callersMethodnotifyDataplanesAndStartScalingLoop
* Helpers for control_plane.go */ Only one goroutine will execute the function per service
internal/control_plane/helpers.go:44
↓ 2 callersFunctionparseConfigPath
(configPath string)
pkg/config/config.go:103
↓ 2 callersFunctionplot_experiment
(experiment_name, input_folder, column)
scripts/plotting/plot_utilization.py:34
↓ 2 callersMethodregisterDataPlane
(cpApiServer proto.CpiInterfaceClient)
internal/data_plane/data_plane.go:112
↓ 2 callersMethodremoveEndpointFromWNStruct
(e *core.Endpoint)
internal/control_plane/scaling_loop.go:204
↓ 2 callersMethodremoveServerByName
(ipAddress string, port int, transaction string, version int64)
internal/data_plane/haproxy/manager.go:229
↓ 2 callersFunctionroundRobinLoadBalancing
(metadata *function_metadata.FunctionMetadata)
internal/data_plane/proxy/load_balancing/load_balancing.go:133
↓ 2 callersMethodscalingCycle
(isScaleFromZero bool)
internal/control_plane/autoscaling/controller.go:81
↓ 2 callersMethodsendInstructionToControlPlane
(ctx context.Context, config config.WorkerNodeConfig, cpi *proto.CpiInterfaceClient, action int)
internal/worker_node/worker_node.go:179
↓ 2 callersMethodsinglethreadUpdateEndpoints
(endpoints []*proto.EndpointInfo)
internal/control_plane/scaling_loop.go:333
↓ 2 callersFunctionsleepWithJitter
()
internal/control_plane/leader_election/server.go:167
↓ 2 callersMethodstopAutoscalingLoop
()
internal/control_plane/autoscaling/controller.go:95
↓ 1 callersMethodAddEndpoints
(endpoints []*proto.EndpointInfo)
internal/data_plane/function_metadata/function_metadata.go:201
↓ 1 callersMethodAddSnapshot
(serviceID string, metadata *SnapshotMetadata)
internal/worker_node/sandbox/firecracker/snapshot_manager.go:50
↓ 1 callersFunctionAggregateStatistics
(functions []*FunctionMetadata)
internal/data_plane/function_metadata/statistics.go:70
↓ 1 callersFunctionBufferedRequestFromRequest
(request *http.Request, code string)
internal/data_plane/proxy/requests/requests.go:71
↓ 1 callersMethodCheckPeriodicallyWorkerNodes
(stopCh chan struct{})
internal/control_plane/control_plane.go:376
↓ 1 callersMethodCleanControlPlaneInMemoryData
(args *CpApiServerCreationArguments)
api/control_plane_api_server.go:101
↓ 1 callersMethodCleanResources
()
internal/worker_node/worker_node.go:149
↓ 1 callersMethodConnectToPeer
(peerId int, addr net.Addr)
internal/control_plane/leader_election/server.go:141
↓ 1 callersFunctionCreateNewCpApiServer
(args *CpApiServerCreationArguments)
api/control_plane_api_server.go:62
↓ 1 callersFunctionCreateScoringPipeline
()
internal/control_plane/placement_policy/k8s_placement.go:42
↓ 1 callersFunctionCreateVMSnapshot
(ctx context.Context, vmcs *VMControlStructure)
internal/worker_node/sandbox/firecracker/runtime.go:230
↓ 1 callersMethodDeleteAllDataplanes
()
internal/data_plane/haproxy/manager.go:364
↓ 1 callersMethodDeleteBufferedRequest
(ctx context.Context, code string)
internal/data_plane/proxy/persistence/request_persistence.go:38
↓ 1 callersMethodDeleteSandbox
(_ context.Context, in *proto.SandboxID)
internal/worker_node/sandbox/firecracker/runtime.go:259
↓ 1 callersFunctionDeployservice
()
async/fire.go:47
↓ 1 callersFunctionDeregisterControlPlaneConnection
(cfg *config.DataPlaneConfig)
pkg/grpc_helpers/grpc_helpers.go:183
↓ 1 callersMethodDescriptor
()
api/proto/control_plane_interface.pb.go:56
↓ 1 callersMethodDescriptor
Deprecated: Use Failure.ProtoReflect.Descriptor instead.
api/proto/control_plane_interface.pb.go:379
↓ 1 callersMethodDescriptor
()
api/proto/common.pb.go:52
↓ 1 callersMethodDescriptor
Deprecated: Use Endpoint.ProtoReflect.Descriptor instead.
api/proto/common.pb.go:630
↓ 1 callersFunctionDisseminateHAProxyConfig
(config *proto.HAProxyConfig, les *leader_election.LeaderElectionServer)
internal/data_plane/haproxy/manager.go:392
← previousnext →201–300 of 1,276, ranked by callers