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
↓ 4 callersMethodRemoveDataplane
(ipAddress string, port int, restart bool)
internal/data_plane/haproxy/manager.go:160
↓ 4 callersMethodReportFailure
(ctx context.Context, in *Failure, opts ...grpc.CallOption)
api/proto/control_plane_interface_grpc.pb.go:28
↓ 4 callersMethodReviseHAProxyConfiguration
HAProxy
api/proto/control_plane_interface_grpc.pb.go:37
↓ 4 callersMethodReviseRegistrationServers
ReviseRegistrationServers Need to call restart after this call
internal/data_plane/haproxy/manager.go:341
↓ 4 callersMethodSetSchedulability
(bool)
internal/control_plane/core/interface.go:68
↓ 4 callersFunctionSetupLogger
(verbosity string)
pkg/logger/logging.go:34
↓ 4 callersFunctionStartContainer
(ctx context.Context, container containerd.Container, network cni.CNI)
internal/worker_node/sandbox/containerd/iface.go:93
↓ 4 callersFunctionWatchExitChannel
(cpApi proto.CpiInterfaceClient, metadata *managers.Metadata, extractContainerName func(*managers.Metadata) st
internal/worker_node/sandbox/containerd/iface.go:133
↓ 4 callersFunctionfile_common_proto_init
()
api/proto/common.pb.go:814
↓ 4 callersFunctionfile_raft_proto_rawDescGZIP
()
api/proto/raft.pb.go:296
↓ 4 callersFunctionfile_worker_node_interface_proto_rawDescGZIP
()
api/proto/worker_node_interface.pb.go:428
↓ 4 callersMethodprepareEndpointInfo
TODO: Refactor two following function - design can be improved
internal/control_plane/scaling_loop.go:370
↓ 3 callersMethodAddChannel
(PID uint32, notifyChannel chan uint32)
internal/worker_node/managers/process_monitor.go:75
↓ 3 callersMethodAddDataplane
(ipAddress string, port int, restart bool)
internal/data_plane/haproxy/manager.go:146
↓ 3 callersMethodAddDeployment
(ctx context.Context, in *ServiceInfo, opts ...grpc.CallOption)
api/proto/data_plane_interface_grpc.pb.go:22
↓ 3 callersMethodAtomicRemove
(key K)
pkg/synchronization/control_plane_sync.go:50
↓ 3 callersMethodConnectToWorker
()
internal/control_plane/core/interface.go:51
↓ 3 callersFunctionCreateGRPCServer
(port string, serverSpecific func(sr grpc.ServiceRegistrar), options ...grpc.ServerOption)
pkg/grpc_helpers/grpc_helpers.go:46
↓ 3 callersMethodCreateSandbox
(context.Context, *proto.ServiceInfo, ...grpc.CallOption)
internal/control_plane/core/interface.go:52
↓ 3 callersMethodCreateSandbox
(ctx context.Context, in *ServiceInfo, opts ...grpc.CallOption)
api/proto/worker_node_interface_grpc.pb.go:22
↓ 3 callersMethodDecrementQueueDepth
()
internal/data_plane/function_metadata/statistics.go:66
↓ 3 callersFunctionDeleteContainer
(ctx context.Context, network cni.CNI, metadata *managers.Metadata)
internal/worker_node/sandbox/containerd/iface.go:159
↓ 3 callersMethodDeleteDataPlaneInformation
(ctx context.Context, dataplaneInfo *proto.DataplaneInformation)
internal/control_plane/persistence/interface.go:35
↓ 3 callersMethodDeleteDeployment
(context.Context, *proto.ServiceInfo)
internal/control_plane/core/interface.go:40
↓ 3 callersMethodDeleteDeployment
(ctx context.Context, in *ServiceInfo, opts ...grpc.CallOption)
api/proto/data_plane_interface_grpc.pb.go:23
↓ 3 callersMethodDeleteSandbox
(ctx context.Context, in *proto.SandboxID)
internal/worker_node/sandbox/runtime_interface.go:35
↓ 3 callersMethodDeleteSandbox
(context.Context, *proto.SandboxID, ...grpc.CallOption)
internal/control_plane/core/interface.go:53
↓ 3 callersMethodDeleteSandbox
(ctx context.Context, in *SandboxID, opts ...grpc.CallOption)
api/proto/worker_node_interface_grpc.pb.go:23
↓ 3 callersMethodDeleteServiceInformation
(ctx context.Context, serviceInfo *proto.ServiceInfo)
internal/control_plane/persistence/interface.go:41
↓ 3 callersMethodDeregisterNodeFromControlPlane
(config config.WorkerNodeConfig, cpApi *proto.CpiInterfaceClient)
internal/worker_node/worker_node.go:165
↓ 3 callersMethodDeregisterService
(ctx context.Context, serviceInfo *proto.ServiceInfo)
internal/control_plane/control_plane.go:316
↓ 3 callersFunctionDifference
(a, b []T)
pkg/map/maps.go:47
↓ 3 callersMethodDrainSandbox
(ctx context.Context, in *DeploymentEndpointPatch, opts ...grpc.CallOption)
api/proto/data_plane_interface_grpc.pb.go:25
↓ 3 callersFunctionEvictionPolicy
(endpoint []*core.Endpoint)
internal/control_plane/eviction_policy/eviction_policy.go:32
↓ 3 callersFunctionGetContainerdClient
(containerdSocket string)
internal/worker_node/sandbox/containerd/iface.go:48
↓ 3 callersMethodGetCpuCores
()
internal/control_plane/core/interface.go:62
↓ 3 callersMethodInitializeDataPlaneConnection
(host string, port string)
internal/control_plane/core/interface.go:37
↓ 3 callersMethodIsLeader
()
internal/control_plane/leader_election/consensus_module.go:123
↓ 3 callersMethodListEndpoints
(context.Context, *emptypb.Empty, ...grpc.CallOption)
internal/control_plane/core/interface.go:54
↓ 3 callersMethodListEndpoints
(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption)
api/proto/worker_node_interface_grpc.pb.go:24
↓ 3 callersFunctionNewCpiInterfaceClient
(cc grpc.ClientConnInterface)
api/proto/control_plane_interface_grpc.pb.go:44
↓ 3 callersFunctionNewDataplane
(config config.DataPlaneConfig)
internal/data_plane/data_plane.go:56
↓ 3 callersFunctionNewHAProxyAPI
(loadBalancerAddress string)
internal/data_plane/haproxy/manager.go:64
↓ 3 callersFunctionNewPerFunctionStateController
(scalingChannel chan int, serviceInfo *proto.ServiceInfo, period time.Duration)
internal/control_plane/autoscaling/controller.go:52
↓ 3 callersFunctionNewProcessMonitor
()
internal/worker_node/managers/process_monitor.go:45
↓ 3 callersFunctionNewSandboxManager
(nodeName string)
internal/worker_node/managers/sandbox_manager.go:53
↓ 3 callersFunctionNewWorkerNode
(cpApi proto.CpiInterfaceClient, config config.WorkerNodeConfig, name ...string)
internal/worker_node/worker_node.go:70
↓ 3 callersMethodPlace
(storage synchronization.SyncStructure[string, core.WorkerNodeInterface], _ *ResourceMap)
internal/control_plane/placement_policy/round_robin.go:43
↓ 3 callersMethodRemoveKey
(key K)
pkg/atomic_map/atomic_map.go:70
↓ 3 callersMethodResetMeasurements
(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption)
api/proto/data_plane_interface_grpc.pb.go:26
↓ 3 callersMethodResourceKeys
()
internal/control_plane/placement_policy/resource_map.go:54
↓ 3 callersMethodSetCPUCores
(v uint64)
internal/control_plane/placement_policy/resource_map.go:46
↓ 3 callersMethodSetupHeartbeatLoop
(proxy proxy.Proxy)
internal/data_plane/data_plane.go:71
↓ 3 callersMethodString
()
api/proto/common.pb.go:611
↓ 3 callersFunctionUnassignPort
(port int)
internal/worker_node/sandbox/containerd/config_builder.go:73
↓ 3 callersMethodUpdateEndpointList
(context.Context, *proto.DeploymentEndpointPatch)
internal/control_plane/core/interface.go:39
↓ 3 callersMethodUpdateEndpointList
(ctx context.Context, in *DeploymentEndpointPatch, opts ...grpc.CallOption)
api/proto/data_plane_interface_grpc.pb.go:24
↓ 3 callersMethodcalculate
(retry float64)
internal/worker_node/managers/exponential_backoff.go:38
↓ 3 callersFunctioncdf
(df, column)
artifact_evaluation/plot_azure_500.py:36
↓ 3 callersMethodexcludeEndpoints
(toExclude map[*core.Endpoint]struct{})
internal/control_plane/scaling_loop.go:357
↓ 3 callersFunctionfile_data_plane_interface_proto_rawDescGZIP
()
api/proto/data_plane_interface.pb.go:252
↓ 3 callersMethodgenerateRawGatewayIP
()
internal/worker_node/managers/ip_manager.go:65
↓ 3 callersFunctiongetCpuUsage
()
pkg/hardware/hardware.go:49
↓ 3 callersFunctiongetCurve
(path, idx=0)
artifact_evaluation/plot_azure_500.py:50
↓ 3 callersFunctiongetHAProxyClient
()
internal/data_plane/haproxy/connection.go:83
↓ 3 callersFunctiongetMemoryUsage
()
pkg/hardware/hardware.go:58
↓ 3 callersFunctionkubernetesFirstAvailableLoadBalancing
(metadata *function_metadata.FunctionMetadata)
internal/data_plane/proxy/load_balancing/load_balancing.go:194
↓ 3 callersFunctionkubernetesRoundRobinLoadBalancing
(metadata *function_metadata.FunctionMetadata)
internal/data_plane/proxy/load_balancing/load_balancing.go:208
↓ 3 callersFunctionleastProcessedLoadBalancing
(metadata *function_metadata.FunctionMetadata)
internal/data_plane/proxy/load_balancing/load_balancing.go:141
↓ 3 callersFunctionparse_df
(path)
scripts/plotting/proxy_analysis.py:27
↓ 3 callersFunctionplotClusteredStackedBarchart
(dataToPlot, clusterLabels=None, clusterLabe
scripts/plotting/common.py:148
↓ 3 callersMethodpopulate
()
internal/worker_node/sandbox/firecracker/networking.go:112
↓ 3 callersFunctionrandomEndpoint
(endpoints []*function_metadata.UpstreamEndpoint)
internal/data_plane/proxy/load_balancing/load_balancing.go:124
↓ 3 callersFunctionrandomLoadBalancing
(metadata *function_metadata.FunctionMetadata)
internal/data_plane/proxy/load_balancing/load_balancing.go:129
↓ 3 callersMethodrunElectionTimer
runElectionTimer implements an election timer. It should be launched whenever we want to start a timer towards becoming a candidate in a new election.
internal/control_plane/leader_election/consensus_module.go:216
↓ 3 callersFunctionsearchEndpointByContainerName
(endpoints []*core.Endpoint, cid string)
internal/control_plane/helpers.go:108
↓ 3 callersFunctionsetupViper
(configPath string)
pkg/config/config.go:115
↓ 3 callersMethodstartElection
startElection starts a new election with this CM as a candidate. Expects cm.mu to be locked.
internal/control_plane/leader_election/consensus_module.go:259
↓ 3 callersMethodupdateEndpoints
(endpoints []*proto.EndpointInfo)
internal/control_plane/scaling_loop.go:326
↓ 2 callersFunctionAddRules
(ipt *iptables.IPTables, sourcePort int, destIP string, destPort int)
internal/worker_node/managers/iptables_manager.go:41
↓ 2 callersFunctionAssignRandomPort
()
internal/worker_node/sandbox/containerd/config_builder.go:53
↓ 2 callersMethodAtomicDecrement
(key K)
pkg/atomic_map/atomic_map_counter.go:78
↓ 2 callersMethodAtomicGet
(key K)
pkg/synchronization/control_plane_sync.go:48
↓ 2 callersMethodAtomicGetNoCheck
(key K)
pkg/synchronization/control_plane_sync.go:49
↓ 2 callersMethodAtomicSet
Not thread safe
pkg/synchronization/control_plane_sync.go:47
↓ 2 callersFunctionCreateFileIfNotExist
(path string)
pkg/tracing/tracing.go:127
↓ 2 callersFunctionCreateMetricsHandler
(deployments *function_metadata.Deployments)
internal/data_plane/proxy/metrics.go:33
↓ 2 callersFunctionCreateRedisClient
(ctx context.Context, redisLogin config.RedisConf)
internal/control_plane/persistence/redis_persistence.go:55
↓ 2 callersFunctionCreateRedisConnector
(ctx context.Context, redisLogin config.RedisConf)
pkg/redis_helpers/redis_helpers.go:34
↓ 2 callersMethodDecreaseInflight
()
internal/data_plane/function_metadata/function_metadata.go:328
↓ 2 callersMethodDecrementInflight
()
internal/data_plane/function_metadata/statistics.go:54
↓ 2 callersFunctionDeleteAllSnapshots
()
internal/worker_node/sandbox/firecracker/runtime.go:305
↓ 2 callersFunctionDeleteRules
(ipt *iptables.IPTables, sourcePort int, destIP string, destPort int)
internal/worker_node/managers/iptables_manager.go:79
↓ 2 callersMethodDeleteSandbox
(key string)
internal/worker_node/managers/sandbox_manager.go:64
↓ 2 callersFunctionDeleteUnusedNetworkDevices
()
internal/worker_node/sandbox/firecracker/networking.go:318
↓ 2 callersMethodDeregisterControlPlaneConnection
()
internal/data_plane/data_plane.go:196
↓ 2 callersMethodDisseminateHAProxyConfig
()
api/control_plane_api_server.go:330
↓ 2 callersFunctionDoLoadBalancing
(req *http.Request, metadata *function_metadata.FunctionMetadata, loadBalancingPolicy LoadBalancingPolicy)
internal/data_plane/proxy/load_balancing/load_balancing.go:72
↓ 2 callersMethodDrainSandbox
(context.Context, *proto.DeploymentEndpointPatch)
internal/control_plane/core/interface.go:41
↓ 2 callersFunctionFire
()
async/fire.go:76
← previousnext →101–200 of 1,276, ranked by callers